This is an automated email from the ASF dual-hosted git repository.
diwu pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris-flink-connector.git
The following commit(s) were added to refs/heads/master by this push:
new 07afbcd7 [typo] A simple comment typo (#440)
07afbcd7 is described below
commit 07afbcd7b1e8f8fb7238cf21326317c9cbf4d3c1
Author: JasonLee <[email protected]>
AuthorDate: Wed Jul 24 10:05:45 2024 +0800
[typo] A simple comment typo (#440)
---
.../java/org/apache/doris/flink/table/DorisDynamicTableFactory.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisDynamicTableFactory.java
b/flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisDynamicTableFactory.java
index 5edefe6b..e8ac4dbf 100644
---
a/flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisDynamicTableFactory.java
+++
b/flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisDynamicTableFactory.java
@@ -281,7 +281,7 @@ public final class DorisDynamicTableFactory
DorisConfigOptions.getStreamLoadProp(context.getCatalogTable().getOptions());
TableSchema physicalSchema =
TableSchemaUtils.getPhysicalSchema(context.getCatalogTable().getSchema());
- // create and return dynamic table source
+ // create and return dynamic table sink
return new DorisDynamicTableSink(
getDorisOptions(helper.getOptions()),
getDorisReadOptions(helper.getOptions()),
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
