(seatunnel) branch dev updated: [PulsarSource]Improve pulsar throughput performance. (#6234)

[wanghailin]

This is an automated email from the ASF dual-hosted git repository.

wanghailin pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/seatunnel.git


The following commit(s) were added to refs/heads/dev by this push:
     new 37461f4f3e [PulsarSource]Improve pulsar throughput performance. (#6234)
37461f4f3e is described below

commit 37461f4f3e76201c6c425bb2b92a71ab5637dde5
Author: lightzhao <40714172+lightz...@users.noreply.github.com>
AuthorDate: Wed Jan 17 21:41:39 2024 +0800

    [PulsarSource]Improve pulsar throughput performance. (#6234)
---
 .../seatunnel/pulsar/source/reader/PulsarSplitReaderThread.java        | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git 
a/seatunnel-connectors-v2/connector-pulsar/src/main/java/org/apache/seatunnel/connectors/seatunnel/pulsar/source/reader/PulsarSplitReaderThread.java
 
b/seatunnel-connectors-v2/connector-pulsar/src/main/java/org/apache/seatunnel/connectors/seatunnel/pulsar/source/reader/PulsarSplitReaderThread.java
index 301d62d96c..6073cf26be 100644
--- 
a/seatunnel-connectors-v2/connector-pulsar/src/main/java/org/apache/seatunnel/connectors/seatunnel/pulsar/source/reader/PulsarSplitReaderThread.java
+++ 
b/seatunnel-connectors-v2/connector-pulsar/src/main/java/org/apache/seatunnel/connectors/seatunnel/pulsar/source/reader/PulsarSplitReaderThread.java
@@ -96,8 +96,9 @@ public class PulsarSplitReaderThread extends Thread 
implements Closeable {
                         sourceReader.handleNoMoreElements(split.splitId(), 
message.getMessageId());
                         break;
                     }
+                } else {
+                    Thread.sleep(pollInterval);
                 }
-                Thread.sleep(pollInterval);
             }
         } catch (Throwable t) {
             LOG.error("Pulsar Consumer receive data error", t);