You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@inlong.apache.org by go...@apache.org on 2022/11/02 10:33:35 UTC

[inlong] branch master updated (af75de320 -> cd9678fa7)

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

gosonzhang pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/inlong.git


    from af75de320 [INLONG-6365][Dashboard] Modify the options of the data type and modify some files name (#6367)
     add cd9678fa7 [INLONG-6329][DataProxy] Add proxy-send mode message logic (#6351)

No new revisions were added by this update.

Summary of changes:
 .../inlong/common/enums/DataProxyErrCode.java      |  17 +-
 .../inlong/common/msg/AttributeConstants.java      |   4 +
 .../base/{OrderEvent.java => SinkRspEvent.java}    |  22 ++-
 .../channel/FailoverChannelProcessor.java          |  15 +-
 .../dataproxy/channel/FailoverChannelSelector.java |   3 +-
 .../dataproxy/consts/AttributeConstants.java       |   6 -
 .../dataproxy/http/SimpleMessageHandler.java       |   6 +-
 .../apache/inlong/dataproxy/sink/EventStat.java    |  14 +-
 .../apache/inlong/dataproxy/sink/PulsarSink.java   |  64 +++++---
 .../org/apache/inlong/dataproxy/sink/TubeSink.java |  65 ++++++--
 .../dataproxy/sink/pulsar/PulsarClientService.java | 113 +++++--------
 .../dataproxy/sink/pulsar/SendMessageCallBack.java |   8 +-
 .../inlong/dataproxy/sink/pulsar/SinkTask.java     |  38 ++---
 .../dataproxy/source/ServerMessageHandler.java     |  41 +++--
 .../inlong/dataproxy/utils/MessageUtils.java       | 181 +++++++++++++++++----
 15 files changed, 392 insertions(+), 205 deletions(-)
 rename inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/base/{OrderEvent.java => SinkRspEvent.java} (78%)