This is an automated email from the ASF dual-hosted git repository.
wanghailin pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/seatunnel.git
The following commit(s) were added to refs/heads/dev by this push:
new 921662722f Update ConsoleSinkFactory.java (#7350)
921662722f is described below
commit 921662722f01fd6e7bffb3b582e7624f21cddfee
Author: chaos <[email protected]>
AuthorDate: Fri Aug 9 13:53:28 2024 +0800
Update ConsoleSinkFactory.java (#7350)
Add existing rules to the optionRule
---
.../seatunnel/connectors/seatunnel/console/sink/ConsoleSinkFactory.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/seatunnel-connectors-v2/connector-console/src/main/java/org/apache/seatunnel/connectors/seatunnel/console/sink/ConsoleSinkFactory.java
b/seatunnel-connectors-v2/connector-console/src/main/java/org/apache/seatunnel/connectors/seatunnel/console/sink/ConsoleSinkFactory.java
index 858357d282..169a281fc1 100644
---
a/seatunnel-connectors-v2/connector-console/src/main/java/org/apache/seatunnel/connectors/seatunnel/console/sink/ConsoleSinkFactory.java
+++
b/seatunnel-connectors-v2/connector-console/src/main/java/org/apache/seatunnel/connectors/seatunnel/console/sink/ConsoleSinkFactory.java
@@ -52,7 +52,7 @@ public class ConsoleSinkFactory implements TableSinkFactory {
@Override
public OptionRule optionRule() {
- return OptionRule.builder().build();
+ return OptionRule.builder().optional(LOG_PRINT_DATA,
LOG_PRINT_DELAY).build();
}
@Override
