Yizhou-Yang commented on code in PR #6541:
URL: https://github.com/apache/inlong/pull/6541#discussion_r1024930497
##########
inlong-sort/sort-connectors/doris/src/main/java/org/apache/inlong/sort/doris/table/DorisDynamicTableSink.java:
##########
@@ -86,30 +84,30 @@ public ChangelogMode getChangelogMode(ChangelogMode
changelogMode) {
@SuppressWarnings({"unchecked"})
@Override
public SinkRuntimeProvider getSinkRuntimeProvider(Context context) {
- if (!multipleSink) {
- DorisDynamicOutputFormat.Builder builder =
DorisDynamicOutputFormat.builder()
- .setFenodes(options.getFenodes())
- .setUsername(options.getUsername())
- .setPassword(options.getPassword())
- .setTableIdentifier(options.getTableIdentifier())
- .setReadOptions(readOptions)
- .setExecutionOptions(executionOptions)
- .setFieldDataTypes(tableSchema.getFieldDataTypes())
- .setFieldNames(tableSchema.getFieldNames());
- return OutputFormatProvider.of(builder.build());
- }
DorisDynamicSchemaOutputFormat.Builder builder =
DorisDynamicSchemaOutputFormat.builder()
.setFenodes(options.getFenodes())
.setUsername(options.getUsername())
.setPassword(options.getPassword())
.setReadOptions(readOptions)
.setExecutionOptions(executionOptions)
- .setDatabasePattern(databasePattern)
- .setTablePattern(tablePattern)
- .setDynamicSchemaFormat(sinkMultipleFormat)
- .setIgnoreSingleTableErrors(ignoreSingleTableErrors)
.setInlongMetric(inlongMetric)
.setAuditHostAndPorts(auditHostAndPorts);
+
+ if (!multipleSink) {
Review Comment:
fixed
##########
inlong-sort/sort-connectors/doris/src/main/java/org/apache/inlong/sort/doris/table/DorisDynamicSchemaOutputFormat.java:
##########
@@ -493,8 +690,12 @@ public static class Builder {
private String databasePattern;
private String tablePattern;
private boolean ignoreSingleTableErrors;
+ private boolean isSingle;
Review Comment:
fixed
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
