Skip to content

Commit 115f51f

Browse files
committed
add error debug info for issue: datavane/tis#467
1 parent 202d360 commit 115f51f

1 file changed

Lines changed: 7 additions & 3 deletions

File tree

tis-incr/tis-flink-cdc-kafka-plugin/src/main/java/com/qlangtech/tis/plugin/datax/kafka/reader/DataXKafkaReader.java

Lines changed: 7 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -211,9 +211,13 @@ final KafkaConsumerFactory createKafkaFactory() {
211211
private transient Map<String /**tabName*/, Map<String /**colName*/, ColumnMetaData>> _tabColsMeta;
212212

213213
public static List<String> getTablesInDB(SubFormFilter filter) {
214-
DataXKafkaReader reader = DataxReader.getDataxReader(filter);
215-
return reader.getTargetTabsEntities().getLogicalTableEntites()
216-
.stream().map(FocusWildcardTabName::getLogicalTableName).collect(Collectors.toList());
214+
try {
215+
DataXKafkaReader reader = DataxReader.getDataxReader(filter);
216+
return reader.getTargetTabsEntities().getLogicalTableEntites()
217+
.stream().map(FocusWildcardTabName::getLogicalTableName).collect(Collectors.toList());
218+
} catch (Exception e) {
219+
throw new RuntimeException(String.valueOf(filter.uploadPluginMeta), e);
220+
}
217221
// return Lists.newArrayList();
218222
}
219223

0 commit comments

Comments
 (0)