This is an automated email from the ASF dual-hosted git repository.
yuzelin pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-paimon.git
The following commit(s) were added to refs/heads/master by this push:
new 7ffec3b2d [test] Fix test problem: libc++abi: pure virtual function
called (#1925)
7ffec3b2d is described below
commit 7ffec3b2d54c60954f4059966e74d945bb724d3f
Author: YeJunHao <[email protected]>
AuthorDate: Thu Aug 31 11:58:54 2023 +0800
[test] Fix test problem: libc++abi: pure virtual function called (#1925)
---
.../test/java/org/apache/paimon/flink/lookup/RocksDBListStateTest.java | 1 +
.../org/apache/paimon/flink/sink/index/GlobalIndexAssignerTest.java | 2 ++
2 files changed, 3 insertions(+)
diff --git
a/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/lookup/RocksDBListStateTest.java
b/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/lookup/RocksDBListStateTest.java
index 2a2006a28..da209d3d9 100644
---
a/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/lookup/RocksDBListStateTest.java
+++
b/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/lookup/RocksDBListStateTest.java
@@ -67,6 +67,7 @@ public class RocksDBListStateTest {
listState.add(key, row("1"));
assertThat(getString(listState.get(key))).containsExactlyInAnyOrder("1", "2,3",
"1");
assertThat(listState.get(row("bbb"))).isEmpty();
+ factory.close();
}
public GenericRow row(String value) {
diff --git
a/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/sink/index/GlobalIndexAssignerTest.java
b/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/sink/index/GlobalIndexAssignerTest.java
index 17b120282..0c508a0cb 100644
---
a/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/sink/index/GlobalIndexAssignerTest.java
+++
b/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/sink/index/GlobalIndexAssignerTest.java
@@ -170,6 +170,7 @@ public class GlobalIndexAssignerTest extends TableTestBase {
assigner.process(GenericRowData.of(2, 4, 4));
assertThat(output.stream().map(t -> t.f1)).containsExactly(0, 0, 0);
output.clear();
+ assigner.close();
}
@Test
@@ -194,5 +195,6 @@ public class GlobalIndexAssignerTest extends TableTestBase {
assigner.process(GenericRowData.of(2, 4, 4));
assertThat(output.stream().map(t -> t.f1)).containsExactly(0, 0, 0);
output.clear();
+ assigner.close();
}
}