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 <71205599+chaos...@users.noreply.github.com> 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