Skip to content

KAFKA-3522: add missing guards for TimestampedXxxStore#6356

Merged
bbejeck merged 2 commits intoapache:trunkfrom
mjsax:minor-add-missing-store-guards
Mar 12, 2019
Merged

KAFKA-3522: add missing guards for TimestampedXxxStore#6356
bbejeck merged 2 commits intoapache:trunkfrom
mjsax:minor-add-missing-store-guards

Conversation

@mjsax
Copy link
Copy Markdown
Member

@mjsax mjsax commented Mar 2, 2019

Follow up to #6152 and #6173

@mjsax mjsax added the streams label Mar 2, 2019
@mjsax mjsax changed the title MINOR: add missing guards for TimestampedKeyValueStore KAFKA-3522: add missing guards for TimestampedKeyValueStore Mar 2, 2019
@mjsax
Copy link
Copy Markdown
Member Author

mjsax commented Mar 2, 2019

Call for review @guozhangwang @bbejeck @vvcephei @ableegoldman

@mjsax mjsax changed the title KAFKA-3522: add missing guards for TimestampedKeyValueStore KAFKA-3522: add missing guards for TimestampedXxxStore Mar 9, 2019
@mjsax mjsax force-pushed the minor-add-missing-store-guards branch from dc414ef to ed47f2f Compare March 9, 2019 04:40
@mjsax
Copy link
Copy Markdown
Member Author

mjsax commented Mar 9, 2019

Rebased this. Call for review.

Copy link
Copy Markdown
Contributor

@vvcephei vvcephei left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Looks right to me. Thanks!

Copy link
Copy Markdown
Member

@bbejeck bbejeck left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

LGTM

@bbejeck bbejeck merged commit ab7ea07 into apache:trunk Mar 12, 2019
@bbejeck
Copy link
Copy Markdown
Member

bbejeck commented Mar 12, 2019

Merged #6356 into trunk

@mjsax mjsax deleted the minor-add-missing-store-guards branch March 12, 2019 17:05
jarekr pushed a commit to confluentinc/kafka that referenced this pull request Apr 18, 2019
* warn-apache-kafka/trunk: (41 commits)
  MINOR: Avoid double null check in KStream#transform() (apache#6429)
  KAFKA-7944: Improve Suppress test coverage (apache#6382)
  KAFKA-3522: add missing guards for TimestampedXxxStore (apache#6356)
  MINOR: Change Trogdor agent's cleanup executor to a cached thread pool (apache#6309)
  KAFKA-7976; Update config before notifying controller of unclean leader update (apache#6426)
  KAFKA-7801: TopicCommand should not be able to alter transaction topic partition count
  KAFKA-8091; Wait for processor shutdown before testing removed listeners (apache#6425)
  MINOR: Update delete topics zk path in assertion error messages
  KAFKA-7939: Fix timing issue in KafkaAdminClientTest.testCreateTopicsRetryBackoff
  KAFKA-7922: Return authorized operations in Metadata request response (KIP-430 Part-2)
  MINOR: Print usage when parse fails during console producer
  MINOR: fix Scala compiler warning (apache#6417)
  KAFKA-7288; Fix check in SelectorTest to wait for no buffered bytes (apache#6415)
  KAFKA-8065: restore original input record timestamp in forward() (apache#6393)
  MINOR: cleanup deprectaion annotations (apache#6290)
  KAFKA-3522: Add TimestampedWindowStore builder/runtime classes (apache#6173)
  KAFKA-8069; Fix early expiration of offsets due to invalid loading of expire timestamp (apache#6401)
  KAFKA-8070: Increase consumer startup timeout in system tests (apache#6405)
  KAFKA-8040: Streams handle initTransactions timeout (apache#6372)
  KAFKA-7980 - Fix timing issue in SocketServerTest.testConnectionRateLimit (apache#6391)
  ...
pengxiaolong pushed a commit to pengxiaolong/kafka that referenced this pull request Jun 14, 2019
Reviewers: John Roesler <john@confluent.io>, Bill Bejeck <bbejeck@gmail.com>
@mjsax mjsax added the kip Requires or implements a KIP label Jun 12, 2020
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

kip Requires or implements a KIP streams

Projects

None yet

Development

Successfully merging this pull request may close these issues.

3 participants