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 5b85ebe KYLIN-3768 Save streaming metadata a standard kylin path in
zookeeper
new 55f3bbd KYLIN-3759 Fix classnotfound if lambda is enable
new 50514f8 KYLIN-3744 Make coordinator well tested and add some javadoc
new ca0a8ac6 KYLIN-3784 Hadoop Common ReflectionUtils.printThreadInfo
signature change
The 7553 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:
assembly/pom.xml | 5 +
stream-coordinator/pom.xml | 27 ++
.../kylin/stream/coordinator/Coordinator.java | 265 +++++++++++++++-----
.../exception/ClusterStateException.java | 59 +++++
.../kylin/stream/coordinator/CoordinatorTest.java | 274 +++++++++++++++++++++
.../server/rest/controller/SystemController.java | 64 ++++-
stream-source-kafka/pom.xml | 5 -
7 files changed, 622 insertions(+), 77 deletions(-)
create mode 100644
stream-coordinator/src/main/java/org/apache/kylin/stream/coordinator/exception/ClusterStateException.java
create mode 100644
stream-coordinator/src/test/java/org/apache/kylin/stream/coordinator/CoordinatorTest.java
