This is an automated email from the ASF dual-hosted git repository.
lzljs3620320 pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/incubator-paimon-presto.git
The following commit(s) were added to refs/heads/main by this push:
new b76b070 Fix test for removing changelog
b76b070 is described below
commit b76b07003e77bd0b93dc2f42ecd795f21a35aba7
Author: Jingsong <[email protected]>
AuthorDate: Sun Nov 19 20:39:34 2023 +0800
Fix test for removing changelog
---
.../java/org/apache/paimon/presto/SimpleTableTestHelper.java | 9 ++-------
.../java/org/apache/paimon/presto/SimpleTableTestHelper.java | 9 ++-------
.../java/org/apache/paimon/presto/SimpleTableTestHelper.java | 9 ++-------
.../java/org/apache/paimon/prestosql/SimpleTableTestHelper.java | 7 ++-----
.../java/org/apache/paimon/prestosql/SimpleTableTestHelper.java | 7 ++-----
5 files changed, 10 insertions(+), 31 deletions(-)
diff --git
a/paimon-presto-0.236/src/test/java/org/apache/paimon/presto/SimpleTableTestHelper.java
b/paimon-presto-0.236/src/test/java/org/apache/paimon/presto/SimpleTableTestHelper.java
index 52883cd..a1057d7 100644
---
a/paimon-presto-0.236/src/test/java/org/apache/paimon/presto/SimpleTableTestHelper.java
+++
b/paimon-presto-0.236/src/test/java/org/apache/paimon/presto/SimpleTableTestHelper.java
@@ -30,7 +30,6 @@ import org.apache.paimon.table.sink.InnerTableWrite;
import org.apache.paimon.types.RowType;
import java.util.Collections;
-import java.util.HashMap;
/** A simple table test helper to write and commit. */
public class SimpleTableTestHelper {
@@ -44,12 +43,8 @@ public class SimpleTableTestHelper {
new Schema(
rowType.getFields(),
Collections.emptyList(),
- Collections.emptyList(),
- new HashMap() {
- {
- put("write-mode", "change-log");
- }
- },
+ Collections.singletonList("a"),
+ Collections.emptyMap(),
""));
FileStoreTable table =
FileStoreTableFactory.create(LocalFileIO.create(), path);
String user = "user";
diff --git
a/paimon-presto-0.268/src/test/java/org/apache/paimon/presto/SimpleTableTestHelper.java
b/paimon-presto-0.268/src/test/java/org/apache/paimon/presto/SimpleTableTestHelper.java
index 52883cd..a1057d7 100644
---
a/paimon-presto-0.268/src/test/java/org/apache/paimon/presto/SimpleTableTestHelper.java
+++
b/paimon-presto-0.268/src/test/java/org/apache/paimon/presto/SimpleTableTestHelper.java
@@ -30,7 +30,6 @@ import org.apache.paimon.table.sink.InnerTableWrite;
import org.apache.paimon.types.RowType;
import java.util.Collections;
-import java.util.HashMap;
/** A simple table test helper to write and commit. */
public class SimpleTableTestHelper {
@@ -44,12 +43,8 @@ public class SimpleTableTestHelper {
new Schema(
rowType.getFields(),
Collections.emptyList(),
- Collections.emptyList(),
- new HashMap() {
- {
- put("write-mode", "change-log");
- }
- },
+ Collections.singletonList("a"),
+ Collections.emptyMap(),
""));
FileStoreTable table =
FileStoreTableFactory.create(LocalFileIO.create(), path);
String user = "user";
diff --git
a/paimon-presto-common/src/test/java/org/apache/paimon/presto/SimpleTableTestHelper.java
b/paimon-presto-common/src/test/java/org/apache/paimon/presto/SimpleTableTestHelper.java
index 52883cd..a1057d7 100644
---
a/paimon-presto-common/src/test/java/org/apache/paimon/presto/SimpleTableTestHelper.java
+++
b/paimon-presto-common/src/test/java/org/apache/paimon/presto/SimpleTableTestHelper.java
@@ -30,7 +30,6 @@ import org.apache.paimon.table.sink.InnerTableWrite;
import org.apache.paimon.types.RowType;
import java.util.Collections;
-import java.util.HashMap;
/** A simple table test helper to write and commit. */
public class SimpleTableTestHelper {
@@ -44,12 +43,8 @@ public class SimpleTableTestHelper {
new Schema(
rowType.getFields(),
Collections.emptyList(),
- Collections.emptyList(),
- new HashMap() {
- {
- put("write-mode", "change-log");
- }
- },
+ Collections.singletonList("a"),
+ Collections.emptyMap(),
""));
FileStoreTable table =
FileStoreTableFactory.create(LocalFileIO.create(), path);
String user = "user";
diff --git
a/paimon-prestosql-332/src/test/java/org/apache/paimon/prestosql/SimpleTableTestHelper.java
b/paimon-prestosql-332/src/test/java/org/apache/paimon/prestosql/SimpleTableTestHelper.java
index e514c56..503aab1 100644
---
a/paimon-prestosql-332/src/test/java/org/apache/paimon/prestosql/SimpleTableTestHelper.java
+++
b/paimon-prestosql-332/src/test/java/org/apache/paimon/prestosql/SimpleTableTestHelper.java
@@ -30,7 +30,6 @@ import org.apache.paimon.table.sink.InnerTableWrite;
import org.apache.paimon.types.RowType;
import java.util.Collections;
-import java.util.HashMap;
/** A simple table test helper to write and commit. */
public class SimpleTableTestHelper {
@@ -39,15 +38,13 @@ public class SimpleTableTestHelper {
private final InnerTableCommit commit;
public SimpleTableTestHelper(Path path, RowType rowType) throws Exception {
- HashMap options = new HashMap();
- options.put("write-mode", "change-log");
new SchemaManager(LocalFileIO.create(), path)
.createTable(
new Schema(
rowType.getFields(),
Collections.emptyList(),
- Collections.emptyList(),
- options,
+ Collections.singletonList("a"),
+ Collections.emptyMap(),
""));
FileStoreTable table =
FileStoreTableFactory.create(LocalFileIO.create(), path);
String user = "user";
diff --git
a/paimon-prestosql-common/src/test/java/org/apache/paimon/prestosql/SimpleTableTestHelper.java
b/paimon-prestosql-common/src/test/java/org/apache/paimon/prestosql/SimpleTableTestHelper.java
index e514c56..503aab1 100644
---
a/paimon-prestosql-common/src/test/java/org/apache/paimon/prestosql/SimpleTableTestHelper.java
+++
b/paimon-prestosql-common/src/test/java/org/apache/paimon/prestosql/SimpleTableTestHelper.java
@@ -30,7 +30,6 @@ import org.apache.paimon.table.sink.InnerTableWrite;
import org.apache.paimon.types.RowType;
import java.util.Collections;
-import java.util.HashMap;
/** A simple table test helper to write and commit. */
public class SimpleTableTestHelper {
@@ -39,15 +38,13 @@ public class SimpleTableTestHelper {
private final InnerTableCommit commit;
public SimpleTableTestHelper(Path path, RowType rowType) throws Exception {
- HashMap options = new HashMap();
- options.put("write-mode", "change-log");
new SchemaManager(LocalFileIO.create(), path)
.createTable(
new Schema(
rowType.getFields(),
Collections.emptyList(),
- Collections.emptyList(),
- options,
+ Collections.singletonList("a"),
+ Collections.emptyMap(),
""));
FileStoreTable table =
FileStoreTableFactory.create(LocalFileIO.create(), path);
String user = "user";
