Skip to content

Commit

Permalink
Minor changes
Browse files Browse the repository at this point in the history
  • Loading branch information
jzakaryan committed Jun 16, 2021
1 parent 8daaa94 commit ec338ee
Showing 1 changed file with 2 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -147,8 +147,8 @@ public Map<String, Set<DatastreamTask>> assignPartitions(Map<String, Set<Datastr
}

@VisibleForTesting
Map<String, Set<DatastreamTask>> doAssignment(ClusterThroughputInfo clusterThroughputInfo, Map<String,
Set<DatastreamTask>> currentAssignment, List<String> unassignedPartitions,
Map<String, Set<DatastreamTask>> doAssignment(ClusterThroughputInfo clusterThroughputInfo,
Map<String, Set<DatastreamTask>> currentAssignment, List<String> unassignedPartitions,
DatastreamGroupPartitionsMetadata datastreamPartitions) {
LoadBasedPartitionAssigner partitionAssigner = new LoadBasedPartitionAssigner();
Map<String, Set<DatastreamTask>> assignment = partitionAssigner.assignPartitions(clusterThroughputInfo,
Expand Down

0 comments on commit ec338ee

Please sign in to comment.