test fix

apache · Sep 20, 2023 · d8c472e · d8c472e
1 parent 1290e20
commit d8c472e
Showing 1 changed file with 1 addition and 1 deletion.
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
@@ -379,7 +379,7 @@ public void testWriteRowWithTableRefreshInterval() throws Exception {
             .map(CONVERTER::toInternal, FlinkCompatibilityUtil.toTypeInfo(SimpleDataUtil.ROW_TYPE));
 
     Configuration flinkConf = new Configuration();
-    flinkConf.setLong(FlinkWriteOptions.TABLE_REFRSH_MS.key(), 100L);
+    flinkConf.setString(FlinkWriteOptions.TABLE_REFRSH_INTERVAL.key(), "100ms");
 
     FlinkSink.forRowData(dataStream)
         .table(table)