From a48f4d17893c49a26844c044b19a3d28c0ccda50 Mon Sep 17 00:00:00 2001 From: Bryan Keller Date: Thu, 21 Sep 2023 13:24:31 -0700 Subject: [PATCH] fix typo in variable name --- .../main/java/org/apache/iceberg/flink/FlinkWriteConf.java | 4 ++-- .../main/java/org/apache/iceberg/flink/FlinkWriteOptions.java | 2 +- .../org/apache/iceberg/flink/sink/TestFlinkIcebergSink.java | 2 +- .../main/java/org/apache/iceberg/flink/FlinkWriteConf.java | 4 ++-- .../main/java/org/apache/iceberg/flink/FlinkWriteOptions.java | 2 +- .../org/apache/iceberg/flink/sink/TestFlinkIcebergSink.java | 2 +- .../main/java/org/apache/iceberg/flink/FlinkWriteConf.java | 4 ++-- .../main/java/org/apache/iceberg/flink/FlinkWriteOptions.java | 2 +- .../org/apache/iceberg/flink/sink/TestFlinkIcebergSink.java | 2 +- 9 files changed, 12 insertions(+), 12 deletions(-) diff --git a/flink/v1.15/flink/src/main/java/org/apache/iceberg/flink/FlinkWriteConf.java b/flink/v1.15/flink/src/main/java/org/apache/iceberg/flink/FlinkWriteConf.java index f1424b0d29c6..19c62404d717 100644 --- a/flink/v1.15/flink/src/main/java/org/apache/iceberg/flink/FlinkWriteConf.java +++ b/flink/v1.15/flink/src/main/java/org/apache/iceberg/flink/FlinkWriteConf.java @@ -198,8 +198,8 @@ public Integer writeParallelism() { public Duration tableRefreshInterval() { return confParser .durationConf() - .option(FlinkWriteOptions.TABLE_REFRSH_INTERVAL.key()) - .flinkConfig(FlinkWriteOptions.TABLE_REFRSH_INTERVAL) + .option(FlinkWriteOptions.TABLE_REFRESH_INTERVAL.key()) + .flinkConfig(FlinkWriteOptions.TABLE_REFRESH_INTERVAL) .parseOptional(); } } diff --git a/flink/v1.15/flink/src/main/java/org/apache/iceberg/flink/FlinkWriteOptions.java b/flink/v1.15/flink/src/main/java/org/apache/iceberg/flink/FlinkWriteOptions.java index ddc93f27944e..97f722e0c5e6 100644 --- a/flink/v1.15/flink/src/main/java/org/apache/iceberg/flink/FlinkWriteOptions.java +++ b/flink/v1.15/flink/src/main/java/org/apache/iceberg/flink/FlinkWriteOptions.java @@ -68,6 +68,6 @@ private FlinkWriteOptions() {} ConfigOptions.key("write-parallelism").intType().noDefaultValue(); @Experimental - public static final ConfigOption TABLE_REFRSH_INTERVAL = + public static final ConfigOption TABLE_REFRESH_INTERVAL = ConfigOptions.key("table-refresh-interval").durationType().noDefaultValue(); } diff --git a/flink/v1.15/flink/src/test/java/org/apache/iceberg/flink/sink/TestFlinkIcebergSink.java b/flink/v1.15/flink/src/test/java/org/apache/iceberg/flink/sink/TestFlinkIcebergSink.java index d0c394e35520..d771fe140b1a 100644 --- a/flink/v1.15/flink/src/test/java/org/apache/iceberg/flink/sink/TestFlinkIcebergSink.java +++ b/flink/v1.15/flink/src/test/java/org/apache/iceberg/flink/sink/TestFlinkIcebergSink.java @@ -400,7 +400,7 @@ public void testWriteRowWithTableRefreshInterval() throws Exception { .map(CONVERTER::toInternal, FlinkCompatibilityUtil.toTypeInfo(SimpleDataUtil.ROW_TYPE)); Configuration flinkConf = new Configuration(); - flinkConf.setString(FlinkWriteOptions.TABLE_REFRSH_INTERVAL.key(), "100ms"); + flinkConf.setString(FlinkWriteOptions.TABLE_REFRESH_INTERVAL.key(), "100ms"); FlinkSink.forRowData(dataStream) .table(table) diff --git a/flink/v1.16/flink/src/main/java/org/apache/iceberg/flink/FlinkWriteConf.java b/flink/v1.16/flink/src/main/java/org/apache/iceberg/flink/FlinkWriteConf.java index f1424b0d29c6..19c62404d717 100644 --- a/flink/v1.16/flink/src/main/java/org/apache/iceberg/flink/FlinkWriteConf.java +++ b/flink/v1.16/flink/src/main/java/org/apache/iceberg/flink/FlinkWriteConf.java @@ -198,8 +198,8 @@ public Integer writeParallelism() { public Duration tableRefreshInterval() { return confParser .durationConf() - .option(FlinkWriteOptions.TABLE_REFRSH_INTERVAL.key()) - .flinkConfig(FlinkWriteOptions.TABLE_REFRSH_INTERVAL) + .option(FlinkWriteOptions.TABLE_REFRESH_INTERVAL.key()) + .flinkConfig(FlinkWriteOptions.TABLE_REFRESH_INTERVAL) .parseOptional(); } } diff --git a/flink/v1.16/flink/src/main/java/org/apache/iceberg/flink/FlinkWriteOptions.java b/flink/v1.16/flink/src/main/java/org/apache/iceberg/flink/FlinkWriteOptions.java index ddc93f27944e..97f722e0c5e6 100644 --- a/flink/v1.16/flink/src/main/java/org/apache/iceberg/flink/FlinkWriteOptions.java +++ b/flink/v1.16/flink/src/main/java/org/apache/iceberg/flink/FlinkWriteOptions.java @@ -68,6 +68,6 @@ private FlinkWriteOptions() {} ConfigOptions.key("write-parallelism").intType().noDefaultValue(); @Experimental - public static final ConfigOption TABLE_REFRSH_INTERVAL = + public static final ConfigOption TABLE_REFRESH_INTERVAL = ConfigOptions.key("table-refresh-interval").durationType().noDefaultValue(); } diff --git a/flink/v1.16/flink/src/test/java/org/apache/iceberg/flink/sink/TestFlinkIcebergSink.java b/flink/v1.16/flink/src/test/java/org/apache/iceberg/flink/sink/TestFlinkIcebergSink.java index d0c394e35520..d771fe140b1a 100644 --- a/flink/v1.16/flink/src/test/java/org/apache/iceberg/flink/sink/TestFlinkIcebergSink.java +++ b/flink/v1.16/flink/src/test/java/org/apache/iceberg/flink/sink/TestFlinkIcebergSink.java @@ -400,7 +400,7 @@ public void testWriteRowWithTableRefreshInterval() throws Exception { .map(CONVERTER::toInternal, FlinkCompatibilityUtil.toTypeInfo(SimpleDataUtil.ROW_TYPE)); Configuration flinkConf = new Configuration(); - flinkConf.setString(FlinkWriteOptions.TABLE_REFRSH_INTERVAL.key(), "100ms"); + flinkConf.setString(FlinkWriteOptions.TABLE_REFRESH_INTERVAL.key(), "100ms"); FlinkSink.forRowData(dataStream) .table(table) diff --git a/flink/v1.17/flink/src/main/java/org/apache/iceberg/flink/FlinkWriteConf.java b/flink/v1.17/flink/src/main/java/org/apache/iceberg/flink/FlinkWriteConf.java index f1424b0d29c6..19c62404d717 100644 --- a/flink/v1.17/flink/src/main/java/org/apache/iceberg/flink/FlinkWriteConf.java +++ b/flink/v1.17/flink/src/main/java/org/apache/iceberg/flink/FlinkWriteConf.java @@ -198,8 +198,8 @@ public Integer writeParallelism() { public Duration tableRefreshInterval() { return confParser .durationConf() - .option(FlinkWriteOptions.TABLE_REFRSH_INTERVAL.key()) - .flinkConfig(FlinkWriteOptions.TABLE_REFRSH_INTERVAL) + .option(FlinkWriteOptions.TABLE_REFRESH_INTERVAL.key()) + .flinkConfig(FlinkWriteOptions.TABLE_REFRESH_INTERVAL) .parseOptional(); } } diff --git a/flink/v1.17/flink/src/main/java/org/apache/iceberg/flink/FlinkWriteOptions.java b/flink/v1.17/flink/src/main/java/org/apache/iceberg/flink/FlinkWriteOptions.java index ddc93f27944e..97f722e0c5e6 100644 --- a/flink/v1.17/flink/src/main/java/org/apache/iceberg/flink/FlinkWriteOptions.java +++ b/flink/v1.17/flink/src/main/java/org/apache/iceberg/flink/FlinkWriteOptions.java @@ -68,6 +68,6 @@ private FlinkWriteOptions() {} ConfigOptions.key("write-parallelism").intType().noDefaultValue(); @Experimental - public static final ConfigOption TABLE_REFRSH_INTERVAL = + public static final ConfigOption TABLE_REFRESH_INTERVAL = ConfigOptions.key("table-refresh-interval").durationType().noDefaultValue(); } diff --git a/flink/v1.17/flink/src/test/java/org/apache/iceberg/flink/sink/TestFlinkIcebergSink.java b/flink/v1.17/flink/src/test/java/org/apache/iceberg/flink/sink/TestFlinkIcebergSink.java index 2aac7882644c..11a73d2cc144 100644 --- a/flink/v1.17/flink/src/test/java/org/apache/iceberg/flink/sink/TestFlinkIcebergSink.java +++ b/flink/v1.17/flink/src/test/java/org/apache/iceberg/flink/sink/TestFlinkIcebergSink.java @@ -379,7 +379,7 @@ public void testWriteRowWithTableRefreshInterval() throws Exception { .map(CONVERTER::toInternal, FlinkCompatibilityUtil.toTypeInfo(SimpleDataUtil.ROW_TYPE)); Configuration flinkConf = new Configuration(); - flinkConf.setString(FlinkWriteOptions.TABLE_REFRSH_INTERVAL.key(), "100ms"); + flinkConf.setString(FlinkWriteOptions.TABLE_REFRESH_INTERVAL.key(), "100ms"); FlinkSink.forRowData(dataStream) .table(table)