[kylin] 29/44: Fix type mismatch on container access

[nic]

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 <n...@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;
             }