Skip to content

Commit 4049471

Browse files
author
Bingqin Zhou
committed
Fix unit tests.
1 parent 5c6805a commit 4049471

File tree

2 files changed

+3
-0
lines changed

2 files changed

+3
-0
lines changed

kcbq-connector/src/test/java/com/wepay/kafka/connect/bigquery/SinkPropertiesFactory.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -33,6 +33,7 @@ public class SinkPropertiesFactory {
3333
public Map<String, String> getProperties() {
3434
Map<String, String> properties = new HashMap<>();
3535

36+
properties.put(BigQuerySinkConfig.TABLE_CREATE_CONFIG, "false");
3637
properties.put(BigQuerySinkConfig.TOPICS_CONFIG, "kcbq-test");
3738
properties.put(BigQuerySinkConfig.PROJECT_CONFIG, "test-project");
3839
properties.put(BigQuerySinkConfig.DATASETS_CONFIG, ".*=test");

kcbq-connector/src/test/java/com/wepay/kafka/connect/bigquery/SinkTaskPropertiesFactory.java

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -18,6 +18,7 @@
1818
*/
1919

2020

21+
import com.wepay.kafka.connect.bigquery.config.BigQuerySinkConfig;
2122
import com.wepay.kafka.connect.bigquery.config.BigQuerySinkTaskConfig;
2223

2324
import java.util.Map;
@@ -28,6 +29,7 @@ public Map<String, String> getProperties() {
2829
Map<String, String> properties = super.getProperties();
2930

3031
properties.put(BigQuerySinkTaskConfig.SCHEMA_UPDATE_CONFIG, "false");
32+
properties.put(BigQuerySinkConfig.TABLE_CREATE_CONFIG, "false");
3133

3234
return properties;
3335
}

0 commit comments

Comments
 (0)