(paimon) branch master updated: [flink] end.input.watermark to end-input.watermark

[lzljs3620320]

This is an automated email from the ASF dual-hosted git repository.

lzljs3620320 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/paimon.git


The following commit(s) were added to refs/heads/master by this push:
     new eff957552 [flink] end.input.watermark to end-input.watermark
eff957552 is described below

commit eff9575525f60ed8cd15e0175758a7f4a6c5927d
Author: Jingsong <jingsongl...@gmail.com>
AuthorDate: Tue Jun 4 10:25:54 2024 +0800

    [flink] end.input.watermark to end-input.watermark
---
 docs/layouts/shortcodes/generated/flink_connector_configuration.html    | 2 +-
 .../src/main/java/org/apache/paimon/flink/FlinkConnectorOptions.java    | 2 +-
 .../test/java/org/apache/paimon/flink/FlinkEndInputWatermarkITCase.java | 2 +-
 3 files changed, 3 insertions(+), 3 deletions(-)

diff --git 
a/docs/layouts/shortcodes/generated/flink_connector_configuration.html 
b/docs/layouts/shortcodes/generated/flink_connector_configuration.html
index f45486f02..8a826acc1 100644
--- a/docs/layouts/shortcodes/generated/flink_connector_configuration.html
+++ b/docs/layouts/shortcodes/generated/flink_connector_configuration.html
@@ -33,7 +33,7 @@ under the License.
             <td>When changelog-producer is set to LOOKUP, commit will wait for 
changelog generation by lookup.</td>
         </tr>
         <tr>
-            <td><h5>end.input.watermark</h5></td>
+            <td><h5>end-input.watermark</h5></td>
             <td style="word-wrap: break-word;">(none)</td>
             <td>Long</td>
             <td>Optional endInput watermark used in case of batch mode or 
bounded stream.</td>
diff --git 
a/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/FlinkConnectorOptions.java
 
b/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/FlinkConnectorOptions.java
index ea48e8bf1..c821ab445 100644
--- 
a/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/FlinkConnectorOptions.java
+++ 
b/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/FlinkConnectorOptions.java
@@ -425,7 +425,7 @@ public class FlinkConnectorOptions {
                                     + "and P represent the sink parallelism, 
then S=F×P. The minimum allowed sample factor is 20.");
 
     public static final ConfigOption<Long> END_INPUT_WATERMARK =
-            key("end.input.watermark")
+            key("end-input.watermark")
                     .longType()
                     .noDefaultValue()
                     .withDescription(
diff --git 
a/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/FlinkEndInputWatermarkITCase.java
 
b/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/FlinkEndInputWatermarkITCase.java
index 3480a426e..19fd139d8 100644
--- 
a/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/FlinkEndInputWatermarkITCase.java
+++ 
b/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/FlinkEndInputWatermarkITCase.java
@@ -114,7 +114,7 @@ public class FlinkEndInputWatermarkITCase extends 
CatalogITCaseBase {
     @TestTemplate
     public void testEndInputWatermarkBySQL() throws Exception {
         batchSql(
-                "INSERT INTO T /*+ OPTIONS('end.input.watermark'= '%s') */ 
VALUES (1, 11, 111), (2, 22, 222)",
+                "INSERT INTO T /*+ OPTIONS('end-input.watermark'= '%s') */ 
VALUES (1, 11, 111), (2, 22, 222)",
                 String.valueOf(END_INPUT_WATERMARK));
 
         FileStoreTable table = paimonTable("T");