[Fix] Fix error log name for SourceSplitEnumerator implements class (#8817)

fcb-xiaobo · web-flow · commit 55ed90ecaf24 · 2025-02-25T13:56:38.000+08:00
diff --git a/seatunnel-connectors-v2/connector-amazondynamodb/src/main/java/org/apache/seatunnel/connectors/seatunnel/amazondynamodb/source/AmazonDynamoDBSourceSplitEnumerator.java b/seatunnel-connectors-v2/connector-amazondynamodb/src/main/java/org/apache/seatunnel/connectors/seatunnel/amazondynamodb/source/AmazonDynamoDBSourceSplitEnumerator.java
@@ -153,7 +153,7 @@ public void handleSplitRequest(int subtaskId) {}
 
     @Override
     public void registerReader(int subtaskId) {
-        log.debug("Register reader {} to IoTDBSourceSplitEnumerator.", subtaskId);
+        log.debug("Register reader {} to AmazonDynamoDBSourceSplitEnumerator.", subtaskId);
         if (!pendingSplits.isEmpty()) {
             assignSplit(Collections.singleton(subtaskId));
         }
diff --git a/seatunnel-connectors-v2/connector-easysearch/src/main/java/org/apache/seatunnel/connectors/seatunnel/easysearch/source/EasysearchSourceSplitEnumerator.java b/seatunnel-connectors-v2/connector-easysearch/src/main/java/org/apache/seatunnel/connectors/seatunnel/easysearch/source/EasysearchSourceSplitEnumerator.java
@@ -196,7 +196,7 @@ public void handleSplitRequest(int subtaskId) {
 
     @Override
     public void registerReader(int subtaskId) {
-        log.debug("Register reader {} to IoTDBSourceSplitEnumerator.", subtaskId);
+        log.debug("Register reader {} to EasysearchSourceSplitEnumerator.", subtaskId);
         if (!pendingSplit.isEmpty()) {
             assignSplit(Collections.singletonList(subtaskId));
         }
diff --git a/seatunnel-connectors-v2/connector-elasticsearch/src/main/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/source/ElasticsearchSourceSplitEnumerator.java b/seatunnel-connectors-v2/connector-elasticsearch/src/main/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/source/ElasticsearchSourceSplitEnumerator.java
@@ -186,7 +186,7 @@ public void handleSplitRequest(int subtaskId) {
 
     @Override
     public void registerReader(int subtaskId) {
-        log.debug("Register reader {} to IoTDBSourceSplitEnumerator.", subtaskId);
+        log.debug("Register reader {} to ElasticsearchSourceSplitEnumerator.", subtaskId);
         if (!pendingSplit.isEmpty()) {
             assignSplit(Collections.singletonList(subtaskId));
         }
diff --git a/seatunnel-connectors-v2/connector-typesense/src/main/java/org/apache/seatunnel/connectors/seatunnel/typesense/source/TypesenseSourceSplitEnumerator.java b/seatunnel-connectors-v2/connector-typesense/src/main/java/org/apache/seatunnel/connectors/seatunnel/typesense/source/TypesenseSourceSplitEnumerator.java
@@ -169,7 +169,7 @@ public void handleSplitRequest(int subtaskId) {
 
     @Override
     public void registerReader(int subtaskId) {
-        log.debug("Register reader {} to IoTDBSourceSplitEnumerator.", subtaskId);
+        log.debug("Register reader {} to TypesenseSourceSplitEnumerator.", subtaskId);
         if (!pendingSplit.isEmpty()) {
             assignSplit(Collections.singletonList(subtaskId));
         }

Original file line number	Diff line number	Diff line change
`@@ -153,7 +153,7 @@ public void handleSplitRequest(int subtaskId) {}`
`153`	`153`
`154`	`154`	`@Override`
`155`	`155`	`public void registerReader(int subtaskId) {`
`156`		`- log.debug("Register reader {} to IoTDBSourceSplitEnumerator.", subtaskId);`
	`156`	`+ log.debug("Register reader {} to AmazonDynamoDBSourceSplitEnumerator.", subtaskId);`
`157`	`157`	`if (!pendingSplits.isEmpty()) {`
`158`	`158`	`assignSplit(Collections.singleton(subtaskId));`
`159`	`159`	`}`
Original file line number	Diff line number	Diff line change
`@@ -196,7 +196,7 @@ public void handleSplitRequest(int subtaskId) {`
`196`	`196`
`197`	`197`	`@Override`
`198`	`198`	`public void registerReader(int subtaskId) {`
`199`		`- log.debug("Register reader {} to IoTDBSourceSplitEnumerator.", subtaskId);`
	`199`	`+ log.debug("Register reader {} to EasysearchSourceSplitEnumerator.", subtaskId);`
`200`	`200`	`if (!pendingSplit.isEmpty()) {`
`201`	`201`	`assignSplit(Collections.singletonList(subtaskId));`
`202`	`202`	`}`
Original file line number	Diff line number	Diff line change
`@@ -186,7 +186,7 @@ public void handleSplitRequest(int subtaskId) {`
`186`	`186`
`187`	`187`	`@Override`
`188`	`188`	`public void registerReader(int subtaskId) {`
`189`		`- log.debug("Register reader {} to IoTDBSourceSplitEnumerator.", subtaskId);`
	`189`	`+ log.debug("Register reader {} to ElasticsearchSourceSplitEnumerator.", subtaskId);`
`190`	`190`	`if (!pendingSplit.isEmpty()) {`
`191`	`191`	`assignSplit(Collections.singletonList(subtaskId));`
`192`	`192`	`}`
Original file line number	Diff line number	Diff line change
`@@ -169,7 +169,7 @@ public void handleSplitRequest(int subtaskId) {`
`169`	`169`
`170`	`170`	`@Override`
`171`	`171`	`public void registerReader(int subtaskId) {`
`172`		`- log.debug("Register reader {} to IoTDBSourceSplitEnumerator.", subtaskId);`
	`172`	`+ log.debug("Register reader {} to TypesenseSourceSplitEnumerator.", subtaskId);`
`173`	`173`	`if (!pendingSplit.isEmpty()) {`
`174`	`174`	`assignSplit(Collections.singletonList(subtaskId));`
`175`	`175`	`}`