You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kylin.apache.org by ni...@apache.org on 2020/02/07 14:26:24 UTC
[kylin] 29/44: Fix type mismatch on container access
This is an automated email from the ASF dual-hosted git repository.
nic pushed a commit to branch 3.0.x
in repository https://gitbox.apache.org/repos/asf/kylin.git
commit 0d83874099cce6d3cb4057d381467516815a69e3
Author: nichunen <ni...@apache.org>
AuthorDate: Sun Jan 12 18:47:31 2020 +0800
Fix type mismatch on container access
---
.../stream/coordinator/assign/CubePartitionRoundRobinAssigner.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/stream-coordinator/src/main/java/org/apache/kylin/stream/coordinator/assign/CubePartitionRoundRobinAssigner.java b/stream-coordinator/src/main/java/org/apache/kylin/stream/coordinator/assign/CubePartitionRoundRobinAssigner.java
index 8232177..c03340d 100644
--- a/stream-coordinator/src/main/java/org/apache/kylin/stream/coordinator/assign/CubePartitionRoundRobinAssigner.java
+++ b/stream-coordinator/src/main/java/org/apache/kylin/stream/coordinator/assign/CubePartitionRoundRobinAssigner.java
@@ -146,9 +146,9 @@ public class CubePartitionRoundRobinAssigner implements Assigner {
Collections.sort(replicaSets, new Comparator<ReplicaSet>() {
@Override
public int compare(ReplicaSet o1, ReplicaSet o2) {
- Integer partitionNum1Obj = replicaSetPartitionNumMap.get(o1);
+ Integer partitionNum1Obj = replicaSetPartitionNumMap.get(o1.getReplicaSetID());
int partitionNum1 = partitionNum1Obj == null ? 0 : partitionNum1Obj;
- Integer partitionNum2Obj = replicaSetPartitionNumMap.get(o2);
+ Integer partitionNum2Obj = replicaSetPartitionNumMap.get(o2.getReplicaSetID());
int partitionNum2 = partitionNum2Obj == null ? 0 : partitionNum2Obj;
return partitionNum1 - partitionNum2;
}