This is an automated email from the ASF dual-hosted git repository.
dockerzhang pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/inlong.git
from 5678f5446 [INLONG-7831][Sort] Using spilling disk map to reduce memory
loss for buffer per parititon data (#7878)
add 2431f2f39 [INLONG-7936][Manager] Support issued pulsar subscriptions
to sort (#7937)
No new revisions were added by this update.
Summary of changes:
.../manager/pojo/sort/util/ExtractNodeUtils.java | 8 ++++++-
.../manager/pojo/source/pulsar/PulsarSource.java | 3 +++
.../pojo/source/pulsar/PulsarSourceDTO.java | 4 ++++
.../pojo/source/pulsar/PulsarSourceRequest.java | 3 +++
.../queue/pulsar/PulsarResourceOperator.java | 2 +-
.../source/pulsar/PulsarSourceOperator.java | 25 +++++++++++++++++++++-
.../protocol/node/extract/PulsarExtractNode.java | 17 +++++++++++++--
.../node/extract/PulsarExtractNodeTest.java | 2 ++
.../inlong/sort/parser/PulsarSqlParserTest.java | 2 ++
9 files changed, 61 insertions(+), 5 deletions(-)
