From 7f8a1393d8cce96173ca49816f88c36e8d49869e Mon Sep 17 00:00:00 2001 From: chaos <71205599+chaos-cn@users.noreply.github.com> Date: Fri, 9 Aug 2024 10:04:44 +0800 Subject: [PATCH] Update ConsoleSinkFactory.java Add existing rules to the optionRule --- .../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 858357d282b..169a281fc19 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 String factoryIdentifier() { @Override public OptionRule optionRule() { - return OptionRule.builder().build(); + return OptionRule.builder().optional(LOG_PRINT_DATA, LOG_PRINT_DELAY).build(); } @Override