diff --git a/starrocks-stream-load-sdk/src/main/java/com/starrocks/data/load/stream/DefaultStreamLoader.java b/starrocks-stream-load-sdk/src/main/java/com/starrocks/data/load/stream/DefaultStreamLoader.java index 508b3198..f0d39671 100644 --- a/starrocks-stream-load-sdk/src/main/java/com/starrocks/data/load/stream/DefaultStreamLoader.java +++ b/starrocks-stream-load-sdk/src/main/java/com/starrocks/data/load/stream/DefaultStreamLoader.java @@ -391,7 +391,7 @@ protected String parseHttpResponse(String requestType, String db, String table, if (307 == code) { String errorMsg = String.format("Request %s failed because http response code is 307 which means 'Temporary Redirect'. " + "This can happen when FE responds the request slowly , you should find the reason first. The reason may be " + - "StarRocks FE/Flink GC, network delay, or others. db: %s, table: %s, label: %s, response status line: %s", + "StarRocks FE/Flink/Spark GC, network delay, or others. db: %s, table: %s, label: %s, response status line: %s", requestType, db, table, label, response.getStatusLine()); log.error("{}", errorMsg); throw new StreamLoadFailException(errorMsg); diff --git a/starrocks-stream-load-sdk/src/main/java/com/starrocks/data/load/stream/TransactionStreamLoader.java b/starrocks-stream-load-sdk/src/main/java/com/starrocks/data/load/stream/TransactionStreamLoader.java index 35523202..de5d7c00 100644 --- a/starrocks-stream-load-sdk/src/main/java/com/starrocks/data/load/stream/TransactionStreamLoader.java +++ b/starrocks-stream-load-sdk/src/main/java/com/starrocks/data/load/stream/TransactionStreamLoader.java @@ -270,7 +270,7 @@ public boolean commit(StreamLoadSnapshot.Transaction transaction) { // there are many corner cases that can lead to non-ok status. some of them are // 1. TXN_NOT_EXISTS: transaction timeout and the label is cleanup up // 2. Failed: the error message can be "has no backend", The case is that FE leader restarts, and after - // that commit the transaction repeatedly because flink job continues failover for some reason , but + // that commit the transaction repeatedly because flink/spark job continues failover for some reason , but // the transaction actually success, and this commit should be successful // To reduce the dependency for the returned status type, always check the label state String labelState = getLabelState(host, transaction.getDatabase(), transaction.getTable(), transaction.getLabel(), Collections.emptySet()); diff --git a/starrocks-stream-load-sdk/src/main/java/com/starrocks/data/load/stream/v2/StreamLoadManagerV2.java b/starrocks-stream-load-sdk/src/main/java/com/starrocks/data/load/stream/v2/StreamLoadManagerV2.java index 1b7e3a76..39425bf6 100644 --- a/starrocks-stream-load-sdk/src/main/java/com/starrocks/data/load/stream/v2/StreamLoadManagerV2.java +++ b/starrocks-stream-load-sdk/src/main/java/com/starrocks/data/load/stream/v2/StreamLoadManagerV2.java @@ -223,14 +223,14 @@ public void init() { } } } - }, "Flink-StarRocks-Sink-Manager"); + }, "StarRocks-Sink-Manager"); manager.setDaemon(true); manager.start(); manager.setUncaughtExceptionHandler((t, ee) -> { LOG.error("StarRocks-Sink-Manager error", ee); e = ee; }); - LOG.info("Flink-StarRocks-Sink-Manager start, enableAutoCommit: {}, streamLoader: {}, {}", + LOG.info("StarRocks-Sink-Manager start, enableAutoCommit: {}, streamLoader: {}, {}", enableAutoCommit, streamLoader.getClass().getName(), EnvUtils.getGitInformation()); streamLoader.start(properties, this);