forbiden write

apache · Nov 5, 2024 · 4ba3d37 · 4ba3d37
1 parent 4ce761e
commit 4ba3d37
Show file tree

Hide file tree

Showing 2 changed files with 24 additions and 0 deletions.
diff --git a/paimon-core/src/main/java/org/apache/paimon/table/object/ObjectTable.java b/paimon-core/src/main/java/org/apache/paimon/table/object/ObjectTable.java
@@ -18,11 +18,14 @@
 
 package org.apache.paimon.table.object;
 
+import org.apache.paimon.manifest.ManifestCacheFilter;
 import org.apache.paimon.schema.TableSchema;
 import org.apache.paimon.table.DelegatedFileStoreTable;
 import org.apache.paimon.table.FileStoreTable;
 import org.apache.paimon.table.sink.BatchWriteBuilder;
 import org.apache.paimon.table.sink.StreamWriteBuilder;
+import org.apache.paimon.table.sink.TableCommitImpl;
+import org.apache.paimon.table.sink.TableWriteImpl;
 import org.apache.paimon.types.DataTypes;
 import org.apache.paimon.types.RowType;
 
@@ -120,6 +123,21 @@ public StreamWriteBuilder newStreamWriteBuilder() {
             throw new UnsupportedOperationException("Object table does not support Write.");
         }
 
+        @Override
+        public TableWriteImpl<?> newWrite(String commitUser) {
+            throw new UnsupportedOperationException("Object table does not support Write.");
+        }
+
+        @Override
+        public TableWriteImpl<?> newWrite(String commitUser, ManifestCacheFilter manifestFilter) {
+            throw new UnsupportedOperationException("Object table does not support Write.");
+        }
+
+        @Override
+        public TableCommitImpl newCommit(String commitUser) {
+            throw new UnsupportedOperationException("Object table does not support Write.");
+        }
+
         @Override
         public String objectLocation() {
             return objectLocation;

diff --git a/...on-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/ObjectTableITCase.java b/...on-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/ObjectTableITCase.java
@@ -73,5 +73,11 @@ public void testObjectTableRefresh() throws IOException {
         // time travel
         assertThat(sql("SELECT name, length FROM T /*+ OPTIONS('scan.snapshot-id' = '1') */"))
                 .containsExactlyInAnyOrder(Row.of("f0", 5L));
+
+        // insert into
+        assertThatThrownBy(() -> sql("INSERT INTO T SELECT * FROM T"))
+                .rootCause()
+                .hasMessageContaining("Object table does not support Write.");
+        assertThat(sql("SELECT name, length FROM T")).containsExactlyInAnyOrder(Row.of("f1", 5L));
     }
 }