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

Reply via email to