grammar/typo

apache · Sep 19, 2023 · dcd6630 · dcd6630
1 parent 48ef055
commit dcd6630
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 4 deletions.
diff --git a/core/src/main/java/org/apache/iceberg/io/OutputFileFactory.java b/core/src/main/java/org/apache/iceberg/io/OutputFileFactory.java
@@ -162,8 +162,8 @@ public Builder suffix(String newSuffix) {
     }
 
     /**
-     * Configures a {@link FileIO} supplier, which is used to dynamically refresh the file IO
-     * instance when a table is refreshed.
+     * Configures a {@link FileIO} supplier, which can potentially be used to dynamically refresh
+     * the file IO instance when a table is refreshed.
      *
      * @param newIoSupplier The file IO supplier
      * @return this builder instance

diff --git a/flink/v1.17/flink/src/main/java/org/apache/iceberg/flink/sink/FlinkSink.java b/flink/v1.17/flink/src/main/java/org/apache/iceberg/flink/sink/FlinkSink.java
@@ -278,7 +278,7 @@ public Builder upsert(boolean enabled) {
      * @return {@link Builder} to connect the iceberg table.
      */
     @Experimental
-    public Builder tableRefreshInternal(Duration refreshInterval) {
+    public Builder tableRefreshInterval(Duration refreshInterval) {
       this.tableRefreshInterval = refreshInterval;
       return this;
     }

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
@@ -381,7 +381,7 @@ public void testWriteRowWithWriteTableLoader() throws Exception {
     FlinkSink.forRowData(dataStream)
         .table(table)
         .tableLoader(tableLoader)
-        .tableRefreshInternal(Duration.ofMillis(100))
+        .tableRefreshInterval(Duration.ofMillis(100))
         .writeParallelism(parallelism)
         .append();