Yukiton opened a new issue, #89:
URL: https://github.com/apache/doris-kafka-connector/issues/89
看上去是自动生成的Label过长导致正则检测不通过。不知道有解决方案吗？
doris-kafka-connector版本：25
报错如下：
[2025-10-30 08:08:54,861] INFO stream load started for
AVeryLongTopicPerfix_AVeryLongDatabaseName_20251030_dbo_AVeryLongTableName__KC_-1__KC_AVeryLongDatabaseName_20251030_AVeryLongTableName__KC_10404__KC_849
on host 192.168.2.110:8030
(org.apache.doris.kafka.connector.writer.load.AsyncDorisStreamLoad)
[2025-10-30 08:08:54,891] INFO load Result {
"TxnId": -1,
"Label":
"AVeryLongTopicPerfix_AVeryLongDatabaseName_20251030_dbo_AVeryLongTableName__KC_-1__KC_AVeryLongDatabaseName_20251030_AVeryLongTableName__KC_10404__KC_849",
"Comment": "",
"TwoPhaseCommit": "false",
"Status": "Fail",
"Message": "[ANALYSIS_ERROR]TStatus: errCode = 2, detailMessage = Label
format error. regex: ^[-_A-Za-z0-9:]{1,128}$, label:
AVeryLongTopicPerfix_AVeryLongDatabaseName_20251030_dbo_AVeryLongTableName__KC_-1__KC_AVeryLongDatabaseName_20251030_AVeryLongTableName__KC_10404__KC_849",
"NumberTotalRows": 0,
"NumberLoadedRows": 0,
"NumberFilteredRows": 0,
"NumberUnselectedRows": 0,
"LoadBytes": 0,
"LoadTimeMs": 0,
"BeginTxnTimeMs": 0,
"StreamLoadPutTimeMs": 0,
"ReadDataTimeMs": 0,
"WriteDataTimeMs": 0,
"ReceiveDataTimeMs": 0,
"CommitAndPublishTimeMs": 0
}
(org.apache.doris.kafka.connector.writer.load.AsyncDorisStreamLoad)
[2025-10-30 08:08:54,892] WARN failed to stream load data with label:
AVeryLongTopicPerfix_AVeryLongDatabaseName_20251030_dbo_AVeryLongTableName__KC_-1__KC_AVeryLongDatabaseName_20251030_AVeryLongTableName__KC_10404__KC_849
(org.apache.doris.kafka.connector.writer.load.AsyncDorisStreamLoad)
org.apache.doris.kafka.connector.exception.StreamLoadException: stream load
error: [ANALYSIS_ERROR]TStatus: errCode = 2, detailMessage = Label format
error. regex: ^[-_A-Za-z0-9:]{1,128}$, label:
AVeryLongTopicPerfix_AVeryLongDatabaseName_20251030_dbo_AVeryLongTableName__KC_-1__KC_AVeryLongDatabaseName_20251030_AVeryLongTableName__KC_10404__KC_849,
see more in null
at
org.apache.doris.kafka.connector.writer.load.AsyncDorisStreamLoad$LoadAsyncExecutor.load(AsyncDorisStreamLoad.java:230)
~[doris-kafka-connector-25.0.0.jar:25.0.0]
at
org.apache.doris.kafka.connector.writer.load.AsyncDorisStreamLoad$LoadAsyncExecutor.run(AsyncDorisStreamLoad.java:175)
~[doris-kafka-connector-25.0.0.jar:25.0.0]
at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown
Source) ~[?:?]
at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown
Source) ~[?:?]
at java.base/java.lang.Thread.run(Unknown Source) [?:?]
[2025-10-30 08:08:54,892] ERROR worker running error
(org.apache.doris.kafka.connector.writer.load.AsyncDorisStreamLoad)
org.apache.doris.kafka.connector.exception.StreamLoadException: failed to
stream load data with label:
AVeryLongTopicPerfix_AVeryLongDatabaseName_20251030_dbo_AVeryLongTableName__KC_-1__KC_AVeryLongDatabaseName_20251030_AVeryLongTableName__KC_10404__KC_849
at
org.apache.doris.kafka.connector.writer.load.AsyncDorisStreamLoad$LoadAsyncExecutor.load(AsyncDorisStreamLoad.java:247)
~[doris-kafka-connector-25.0.0.jar:25.0.0]
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
