Skip to content

Commit

Permalink
Update CosmosDBSourceTaskTest.java
Browse files Browse the repository at this point in the history
  • Loading branch information
xinlian12 authored Feb 29, 2024
1 parent fbb83ea commit 8be3ede
Showing 1 changed file with 0 additions and 7 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -32,8 +32,6 @@
import org.mockito.Mockito;

public class CosmosDBSourceTaskTest {
private final static String COSMOS_EMULATOR_KEY = "C2y6yDjf5/R+ob0N8A7Cgv30VRDJIWEHLM+4QDU5DE2nQ9nDuVTqobD4b8mGGyPMbIZnqyMsEcaGQy67XIw/Jw==";
private final static String COSMOS_EMULATOR_HOST = "https://localhost:8081/";
private CosmosDBSourceTask testTask;
private final String topicName = "testtopic";
private final String containerName = "container666";
Expand Down Expand Up @@ -102,11 +100,6 @@ public void setup() throws IllegalAccessException {
@Test(expected = IllegalArgumentException.class)
public void start() {
CosmosDBSourceTask testTask = new CosmosDBSourceTask();
HashMap<String, String> configs = new HashMap<>();
configs.put(CosmosDBSourceConfig.COSMOS_CONN_ENDPOINT_CONF, COSMOS_EMULATOR_HOST);
configs.put(CosmosDBSourceConfig.COSMOS_CONN_KEY_CONF, COSMOS_EMULATOR_KEY);
configs.put(CosmosDBSourceConfig.COSMOS_DATABASE_NAME_CONF, "mydb");
configs.put(CosmosDBSourceConfig.COSMOS_CONTAINER_TOPIC_MAP_CONF, "mytopic5#mycontainer6");
testTask.start(sourceSettings);
}

Expand Down

0 comments on commit 8be3ede

Please sign in to comment.