Skip to content

Commit 873a25d

Browse files
authored
Bump up LiKafkaVersion to pull in a version without the Kafka message format bump changes, fix build issue (#833)
1 parent ab2f817 commit 873a25d

File tree

2 files changed

+2
-1
lines changed

2 files changed

+2
-1
lines changed

datastream-server/src/main/java/com/linkedin/datastream/server/assignment/LoadBasedPartitionAssignmentStrategy.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -102,6 +102,7 @@ public Map<String, Set<DatastreamTask>> assignPartitions(Map<String, Set<Datastr
102102
// TODO Get task count estimate based on throughput and pick a winner
103103
LoadBasedTaskCountEstimator estimator = new LoadBasedTaskCountEstimator(_taskCapacityMBps, _taskCapacityUtilizationPct);
104104
int maxTaskCount = estimator.getTaskCount(clusterThroughputInfo, Collections.emptyList(), Collections.emptyList());
105+
LOG.info("Max task count obtained from estimator: {}", maxTaskCount);
105106

106107
// TODO Get unassigned partitions
107108
// Calculating unassigned partitions

gradle/dependency-versions.gradle

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,5 @@
11
ext {
2-
LIKafkaVersion = "1.0.61"
2+
LIKafkaVersion = "1.0.65"
33
apacheHttpClientVersion = "4.5.3"
44
avroVersion = "1.7.7"
55
commonsCliVersion = "1.2"

0 commit comments

Comments
 (0)