Skip to content

Commit 3d35318

Browse files
committed
further address rebase issue
1 parent 58f0a07 commit 3d35318

File tree

1 file changed

+1
-6
lines changed

1 file changed

+1
-6
lines changed

clients/da-vinci-client/src/main/java/com/linkedin/davinci/kafka/consumer/StoreIngestionTask.java

+1-6
Original file line numberDiff line numberDiff line change
@@ -3426,9 +3426,7 @@ public void unsubscribeFromTopic(PubSubTopic topic, PartitionConsumptionState pa
34263426
* leader-follower state vs the intended state when the message was polled. Thus, we use an increased timeout of up to
34273427
* 30 minutes according to the maximum value of the metric consumer_records_producing_to_write_buffer_latency.
34283428
*/
3429-
void consumerUnSubscribeForStateTransition(
3430-
PubSubTopic topic,
3431-
PartitionConsumptionState partitionConsumptionState) {
3429+
void consumerUnSubscribeForStateTransition(PubSubTopic topic, PartitionConsumptionState partitionConsumptionState) {
34323430
Instant startTime = Instant.now();
34333431
int partitionId = partitionConsumptionState.getPartition();
34343432
PubSubTopicPartition topicPartition = new PubSubTopicPartitionImpl(topic, partitionId);
@@ -4412,9 +4410,6 @@ public boolean hasAllPartitionReportedCompleted() {
44124410

44134411
return true;
44144412
}
4415-
public boolean isSeparatedRealtimeTopicEnabled() {
4416-
return isSeparatedRealtimeTopicEnabled;
4417-
}
44184413

44194414
public boolean isSeparatedRealtimeTopicEnabled() {
44204415
return isSeparatedRealtimeTopicEnabled;

0 commit comments

Comments
 (0)