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

Posted to commits@kylin.apache.org by ma...@apache.org on 2019/03/04 08:47:49 UTC

[kylin] branch realtime-streaming updated (8b374c5 -> 74655f1)

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

magang pushed a change to branch realtime-streaming
in repository https://gitbox.apache.org/repos/asf/kylin.git.


    from 8b374c5  Minor, fix rat check failed
     new 812803c  KYLIN-3744 Add configuration and fix bugs
     new 74655f1  KYLIN-3821 Add consume lag stats

The 7561 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails.  The revisions
listed as "add" were already present in the repository and have only
been added to this reference.


Summary of changes:
 .../org/apache/kylin/common/KylinConfigBase.java   | 12 +++
 .../kylin/rest/service/StreamingV2Service.java     | 16 ++++
 .../kylin/stream/coordinator/Coordinator.java      | 30 +++++--
 .../coordinator/client/HttpCoordinatorClient.java  | 15 ++--
 .../kylin/stream/coordinator/CoordinatorTest.java  |  1 +
 .../core/client/HttpReceiverAdminClient.java       |  3 +-
 .../stream/core/consumer/IStreamingConnector.java  | 95 +++++++++++-----------
 .../core/consumer/StreamingConsumerChannel.java    | 23 +++---
 .../stream/core/model/stats/ConsumerStats.java     | 11 +++
 .../core/model/stats/PartitionConsumeStats.java    | 10 +++
 .../kylin/stream/core/source/IStreamingSource.java |  5 ++
 .../core/storage/StreamingSegmentManager.java      |  6 +-
 .../columnar/compress/LZ4CompressorTest.java       |  7 +-
 .../apache/kylin/stream/core/util/RestService.java |  2 +-
 .../kylin/stream/server/StreamingServer.java       |  6 +-
 .../kylin/stream/source/kafka/KafkaSource.java     | 56 +++++++++++--
 .../source/kafka/consumer/KafkaConnector.java      | 11 ++-
 17 files changed, 223 insertions(+), 86 deletions(-)