diff --git a/flink/v1.13/flink/src/main/java/org/apache/iceberg/flink/sink/FlinkSink.java b/flink/v1.13/flink/src/main/java/org/apache/iceberg/flink/sink/FlinkSink.java index 24e23941f6d7..1997d8bafb75 100644 --- a/flink/v1.13/flink/src/main/java/org/apache/iceberg/flink/sink/FlinkSink.java +++ b/flink/v1.13/flink/src/main/java/org/apache/iceberg/flink/sink/FlinkSink.java @@ -491,7 +491,7 @@ static IcebergStreamWriter createStreamWriter(Table table, RowType flinkRowType, List equalityFieldIds, boolean upsert) { - Preconditions.checkArgument(table != null, "Iceberg table should't be null"); + Preconditions.checkArgument(table != null, "Iceberg table shouldn't be null"); Map props = table.properties(); long targetFileSize = getTargetFileSizeBytes(props); FileFormat fileFormat = getFileFormat(props); diff --git a/flink/v1.14/flink/src/main/java/org/apache/iceberg/flink/sink/FlinkSink.java b/flink/v1.14/flink/src/main/java/org/apache/iceberg/flink/sink/FlinkSink.java index 72f0580cf856..219857c364c0 100644 --- a/flink/v1.14/flink/src/main/java/org/apache/iceberg/flink/sink/FlinkSink.java +++ b/flink/v1.14/flink/src/main/java/org/apache/iceberg/flink/sink/FlinkSink.java @@ -514,7 +514,7 @@ static IcebergStreamWriter createStreamWriter(Table table, RowType flinkRowType, List equalityFieldIds, boolean upsert) { - Preconditions.checkArgument(table != null, "Iceberg table should't be null"); + Preconditions.checkArgument(table != null, "Iceberg table shouldn't be null"); Map props = table.properties(); long targetFileSize = getTargetFileSizeBytes(props); FileFormat fileFormat = getFileFormat(props); diff --git a/flink/v1.15/flink/src/main/java/org/apache/iceberg/flink/sink/FlinkSink.java b/flink/v1.15/flink/src/main/java/org/apache/iceberg/flink/sink/FlinkSink.java index 56fafab067d0..7b597e427bad 100644 --- a/flink/v1.15/flink/src/main/java/org/apache/iceberg/flink/sink/FlinkSink.java +++ b/flink/v1.15/flink/src/main/java/org/apache/iceberg/flink/sink/FlinkSink.java @@ -511,7 +511,7 @@ static IcebergStreamWriter createStreamWriter(Table table, FlinkWriteConf flinkWriteConf, RowType flinkRowType, List equalityFieldIds) { - Preconditions.checkArgument(table != null, "Iceberg table should't be null"); + Preconditions.checkArgument(table != null, "Iceberg table shouldn't be null"); Table serializableTable = SerializableTable.copyOf(table); TaskWriterFactory taskWriterFactory = new RowDataTaskWriterFactory(