diff --git a/kcbq-connector/src/main/java/com/wepay/kafka/connect/bigquery/config/BigQuerySinkConfig.java b/kcbq-connector/src/main/java/com/wepay/kafka/connect/bigquery/config/BigQuerySinkConfig.java index 0a2dc8775..53b33e561 100644 --- a/kcbq-connector/src/main/java/com/wepay/kafka/connect/bigquery/config/BigQuerySinkConfig.java +++ b/kcbq-connector/src/main/java/com/wepay/kafka/connect/bigquery/config/BigQuerySinkConfig.java @@ -261,7 +261,7 @@ public class BigQuerySinkConfig extends AbstractConfig { private static final ConfigDef.Type INTERMEDIATE_TABLE_SUFFIX_TYPE = ConfigDef.Type.STRING; public static final String INTERMEDIATE_TABLE_SUFFIX_DEFAULT = "tmp"; private static final ConfigDef.Validator INTERMEDIATE_TABLE_SUFFIX_VALIDATOR = new ConfigDef.NonEmptyString(); - private static final ConfigDef.Importance INTERMEDIATE_TTABLE_SUFFIX_IMPORTANCE = ConfigDef.Importance.LOW; + private static final ConfigDef.Importance INTERMEDIATE_TABLE_SUFFIX_IMPORTANCE = ConfigDef.Importance.LOW; private static final String INTERMEDIATE_TABLE_SUFFIX_DOC = "A suffix that will be appended to the names of destination tables to create the names for " + "the corresponding intermediate tables. Multiple intermediate tables may be created for a " @@ -452,7 +452,7 @@ public static ConfigDef getConfig() { INTERMEDIATE_TABLE_SUFFIX_TYPE, INTERMEDIATE_TABLE_SUFFIX_DEFAULT, INTERMEDIATE_TABLE_SUFFIX_VALIDATOR, - INTERMEDIATE_TTABLE_SUFFIX_IMPORTANCE, + INTERMEDIATE_TABLE_SUFFIX_IMPORTANCE, INTERMEDIATE_TABLE_SUFFIX_DOC ).define( MERGE_INTERVAL_MS_CONFIG, diff --git a/kcbq-connector/src/test/java/com/wepay/kafka/connect/bigquery/SinkPropertiesFactory.java b/kcbq-connector/src/test/java/com/wepay/kafka/connect/bigquery/SinkPropertiesFactory.java index 9198bb8c2..9e20cc73a 100644 --- a/kcbq-connector/src/test/java/com/wepay/kafka/connect/bigquery/SinkPropertiesFactory.java +++ b/kcbq-connector/src/test/java/com/wepay/kafka/connect/bigquery/SinkPropertiesFactory.java @@ -19,7 +19,6 @@ import com.wepay.kafka.connect.bigquery.config.BigQuerySinkConfig; -import com.wepay.kafka.connect.bigquery.config.BigQuerySinkTaskConfig; import java.util.HashMap; import java.util.Map;