This is an automated email from the ASF dual-hosted git repository.
loogn pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/geaflow.git
The following commit(s) were added to refs/heads/master by this push:
new 817bdd93 [ISSUE-620] fix: remove the directory of db after running
PaimonRWHandleTest (#621)
817bdd93 is described below
commit 817bdd9306b77d83e0bf475c6dbf0f8d28494589
Author: dingyi <[email protected]>
AuthorDate: Thu Sep 18 10:26:24 2025 +0800
[ISSUE-620] fix: remove the directory of db after running
PaimonRWHandleTest (#621)
---
.../org/apache/geaflow/store/paimon/PaimonRWHandleTest.java | 11 ++++++++---
1 file changed, 8 insertions(+), 3 deletions(-)
diff --git
a/geaflow/geaflow-plugins/geaflow-store/geaflow-store-paimon/src/test/java/org/apache/geaflow/store/paimon/PaimonRWHandleTest.java
b/geaflow/geaflow-plugins/geaflow-store/geaflow-store-paimon/src/test/java/org/apache/geaflow/store/paimon/PaimonRWHandleTest.java
index d48f1788..4856d88c 100644
---
a/geaflow/geaflow-plugins/geaflow-store/geaflow-store-paimon/src/test/java/org/apache/geaflow/store/paimon/PaimonRWHandleTest.java
+++
b/geaflow/geaflow-plugins/geaflow-store/geaflow-store-paimon/src/test/java/org/apache/geaflow/store/paimon/PaimonRWHandleTest.java
@@ -65,7 +65,7 @@ public class PaimonRWHandleTest {
@Override
public void drop() {
-
+ super.drop();
}
}
@@ -77,7 +77,8 @@ public class PaimonRWHandleTest {
config.put(ExecutionConfigKeys.JOB_APP_NAME, "test_paimon_app");
storeBase.init(new
StoreContext("test_paimon_store").withConfig(config));
- PaimonTableRWHandle edgeHandle = storeBase.createEdgeTableHandle(new
Identifier("test_paimon_store", "edge"));
+ PaimonTableRWHandle edgeHandle = storeBase.createEdgeTableHandle(
+ new Identifier(storeBase.paimonStoreName, "edge"));
// 写入一条数据 - 根据 schema 定义构造完整的行数据
String srcId = "src1";
@@ -114,12 +115,16 @@ public class PaimonRWHandleTest {
String readValue = new String(internalRow.getBinary(5));
if (srcId.equals(readSrcId) && targetId.equals(readTargetId) &&
timestamp == readTs
- && direction == readDirection && label.equals(readLabel) &&
value.equals(readValue)) {
+ && direction == readDirection && label.equals(readLabel) &&
value.equals(
+ readValue)) {
found = true;
break;
}
}
iterator.close();
assertTrue(found);
+
+ storeBase.drop();
+ storeBase.close();
}
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
