AJ-861: fix issue about 'getStreamTableTimestamp' logic;

chengyitian · chengyitian · commit c7915309a7f6 · 2025-07-18T14:51:49.000+08:00
diff --git a/src/com/xxdb/multithreadedtablewriter/MultithreadedTableWriter.java b/src/com/xxdb/multithreadedtablewriter/MultithreadedTableWriter.java
@@ -568,7 +568,7 @@ private void init(String hostName, int port, String userId, String password,
                 Entity tableType = pConn.run("typestr(" + tableName + ")");
                 if (tableType.getString().equals("STREAMING TABLE")) {
                     BasicString streamTableTimestampColName = (BasicString) pConn.run("getStreamTableTimestamp(" + tableName_ + ")");
-                    if (Objects.nonNull(streamTableTimestampColName)) {
+                    if (!Utils.isEmpty(streamTableTimestampColName.getString())) {
                         isSetStreamTableTimestamp = true;
                     }
                 }

Original file line number	Diff line number	Diff line change
`@@ -568,7 +568,7 @@ private void init(String hostName, int port, String userId, String password,`
`568`	`568`	`Entity tableType = pConn.run("typestr(" + tableName + ")");`
`569`	`569`	`if (tableType.getString().equals("STREAMING TABLE")) {`
`570`	`570`	`BasicString streamTableTimestampColName = (BasicString) pConn.run("getStreamTableTimestamp(" + tableName_ + ")");`
`571`		`- if (Objects.nonNull(streamTableTimestampColName)) {`
	`571`	`+ if (!Utils.isEmpty(streamTableTimestampColName.getString())) {`
`572`	`572`	`isSetStreamTableTimestamp = true;`
`573`	`573`	`}`
`574`	`574`	`}`