From dcd66308c794615bc4982c4b277e60c4c181bd29 Mon Sep 17 00:00:00 2001
From: Bryan Keller <bryanck@gmail.com>
Date: Tue, 19 Sep 2023 15:54:45 -0700
Subject: [PATCH] grammar/typo

---
 .../main/java/org/apache/iceberg/io/OutputFileFactory.java    | 4 ++--
 .../main/java/org/apache/iceberg/flink/sink/FlinkSink.java    | 2 +-
 .../org/apache/iceberg/flink/sink/TestFlinkIcebergSink.java   | 2 +-
 3 files changed, 4 insertions(+), 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
index c4082c87d6f6..c46ca132ed0b 100644
--- 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
index 817b918cf018..1e699f1dc33d 100644
--- 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
index ac5c29e3d975..fce7f1a22e00 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
@@ -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();