[incubator-seatunnel] branch dev updated: [Improve][Connector-v2][Pulsar] Set the name of the pulsar consumption thread. (#4182)

[tyrantlucifer]

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

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


The following commit(s) were added to refs/heads/dev by this push:
     new e567203f7 [Improve][Connector-v2][Pulsar] Set the name of the pulsar 
consumption thread. (#4182)
e567203f7 is described below

commit e567203f7dbb613da0676b2520315cd89d042990
Author: lightzhao <40714172+lightz...@users.noreply.github.com>
AuthorDate: Thu Feb 23 14:53:33 2023 +0800

    [Improve][Connector-v2][Pulsar] Set the name of the pulsar consumption 
thread. (#4182)
    
    * Set the name of PulsarSplitReaderThread.
    
    * fix code style.
    
    ---------
    
    Co-authored-by: lightzhao <zhaolianyong...@gmail.com>
---
 .../connectors/seatunnel/pulsar/source/reader/PulsarSourceReader.java  | 3 +++
 1 file changed, 3 insertions(+)

diff --git 
a/seatunnel-connectors-v2/connector-pulsar/src/main/java/org/apache/seatunnel/connectors/seatunnel/pulsar/source/reader/PulsarSourceReader.java
 
b/seatunnel-connectors-v2/connector-pulsar/src/main/java/org/apache/seatunnel/connectors/seatunnel/pulsar/source/reader/PulsarSourceReader.java
index 9e6878b08..9c986dd13 100644
--- 
a/seatunnel-connectors-v2/connector-pulsar/src/main/java/org/apache/seatunnel/connectors/seatunnel/pulsar/source/reader/PulsarSourceReader.java
+++ 
b/seatunnel-connectors-v2/connector-pulsar/src/main/java/org/apache/seatunnel/connectors/seatunnel/pulsar/source/reader/PulsarSourceReader.java
@@ -172,6 +172,9 @@ public class PulsarSourceReader<T> implements 
SourceReader<T, PulsarPartitionSpl
                     PulsarSplitReaderThread splitReaderThread =
                             createPulsarSplitReaderThread(split);
                     try {
+                        splitReaderThread.setName(
+                                "Pulsar Source Data Consumer "
+                                        + split.getPartition().getPartition());
                         splitReaderThread.open();
                         splitReaders.put(split.splitId(), splitReaderThread);
                         splitReaderThread.start();