Skip to content

Commit e2267cf

Browse files
committed
Enhancement: Add execution id to key.
1 parent 2320988 commit e2267cf

File tree

1 file changed

+3
-3
lines changed
  • spark-connector-oceanbase/spark-connector-oceanbase-base/src/main/java/com/oceanbase/spark/directload

1 file changed

+3
-3
lines changed

spark-connector-oceanbase/spark-connector-oceanbase-base/src/main/java/com/oceanbase/spark/directload/DirectLoaderBuilder.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -148,7 +148,7 @@ public DirectLoaderBuilder executionId(String executionId) {
148148
}
149149

150150
private String buildSchemaTableName() {
151-
return String.format("%s.%s#%s", schema, table, tenant);
151+
return String.format("%s.%s#%s-%s", schema, table, tenant, executionId);
152152
}
153153

154154
public DirectLoader build() {
@@ -193,9 +193,9 @@ private ObDirectLoadConnection buildConnection(int writeThreadNum)
193193
}
194194
});
195195
LOG.info(
196-
"The Connection Map Size: {}, keys: {}",
196+
"The direct-load connection map size: {}, keys: {}",
197197
directLoadConnMap.size(),
198-
directLoadConnMap.keys());
198+
String.join(",", directLoadConnMap.keySet()));
199199
return conn;
200200
}
201201

0 commit comments

Comments
 (0)