src/main/java/com/aliyun/odps/kafka/connect/utils/ConverterHelper.java (3 lines): - line 45: // TODO add Time zone config, now use system default - line 49: // TODO add Time zone config, now use system default - line 61: // TODO add Time zone config, now use system default src/main/java/com/aliyun/odps/kafka/connect/MaxComputeSinkConnector.java (1 line): - line 74: // TODO: validate table schema src/main/java/com/aliyun/odps/kafka/connect/converter/CsvRecordConverter.java (1 line): - line 118: // TODO: bug, could have multi quotes src/main/java/com/aliyun/odps/kafka/connect/MaxComputeSinkTask.java (1 line): - line 132: // TODO: Consider a way to resume when running in key or value mode src/main/java/com/aliyun/odps/kafka/connect/MaxComputeSinkWriter.java (1 line): - line 335: // TODO: random backoff