Skip to content

[Backport] Fix state check bug in Kafka Index Task #5204#5248

Merged
jon-wei merged 1 commit intoapache:0.12.0from
pjain1:backport_fix
Jan 10, 2018
Merged

[Backport] Fix state check bug in Kafka Index Task #5204#5248
jon-wei merged 1 commit intoapache:0.12.0from
pjain1:backport_fix

Conversation

@pjain1
Copy link
Copy Markdown
Member

@pjain1 pjain1 commented Jan 10, 2018

Fix state check bug in Kafka Index Task

  • fix state check for replacement task

  • fix comments

  • rebase with master

* fix state check for replacement task

* fix comments

* rebase with master
@pjain1 pjain1 added this to the 0.12.0 milestone Jan 10, 2018
@jon-wei jon-wei changed the title Backport #5204 [Backport] Fix state check bug in Kafka Index Task #5204 Jan 10, 2018
@jon-wei jon-wei merged commit 61bef7d into apache:0.12.0 Jan 10, 2018
@pjain1 pjain1 deleted the backport_fix branch January 10, 2018 22:40
seoeun25 added a commit to seoeun25/incubator-druid that referenced this pull request Jan 10, 2020
* Kafka Index Task that supports Incremental handoffs apache#4815

* prevent NPE from supressing actual exception (apache#5146)

* prevent npe on mismatch between number of kafka partitions and task count (apache#5139)

* Throw away rows with timestamps beyond long bounds in kafka indexing (apache#5215) (apache#5232)

* Fix state check bug in Kafka Index Task (apache#5204) (apache#5248)
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Projects

None yet

Development

Successfully merging this pull request may close these issues.

2 participants