Re: Samza 0.14.1 not correctly handling OffsetOutOfRangeException exception?

2018-08-24 Thread Gaurav Agarwal
Hi All, By patching the samza codebase locally that this error goes away: Patch involves changing the import for OffsetOutOfRangeException class in file *samza/samza-kafka/src/main/scala/org/apache/samza/system/kafka/GetOffset.scala* to *import org.apache.kafka.common.errors.OffsetOutOfRangeExcept

Re: Samza 0.14.1 not correctly handling OffsetOutOfRangeException exception?

2018-08-24 Thread Debraj Manna
It seems the above issue is coming because of KIP-35 & its related PR (KAFKA-3264 ). Filed https://issues.apache.org/

[GitHub] samza pull request #615: SAMZA-1824: Handle errors from the async-NMClient w...

2018-08-24 Thread vjagadish1989
GitHub user vjagadish1989 opened a pull request: https://github.com/apache/samza/pull/615 SAMZA-1824: Handle errors from the async-NMClient when launching containers - Updated internal state that tracks "pending" containers correctly - Refactored `YarnClusterResourceManager` for

[GitHub] samza pull request #616: SAMZA-1821: fix the IllegalStateException complaini...

2018-08-24 Thread weiqingy
GitHub user weiqingy opened a pull request: https://github.com/apache/samza/pull/616 SAMZA-1821: fix the IllegalStateException complaining duplicate key when fetching systemStream configs This PR is to fix IllegalStateException complaining duplicate key when fetching resource confi

[GitHub] samza pull request #617: SAMZA-1826: Fix unit test failure in table tests

2018-08-24 Thread nickpan47
GitHub user nickpan47 opened a pull request: https://github.com/apache/samza/pull/617 SAMZA-1826: Fix unit test failure in table tests The way that we verify the join counts in PageViewToProfileJoinFunction across multiple table tests (i.e. TestLocalTable, TestRemoteTable, TestLoca

Re: Samza 0.14.1 not correctly handling OffsetOutOfRangeException exception?

2018-08-24 Thread Yi Pan
Hi, Gaurav, Thanks for working on the patch for the problem. Could you open a ticket and PR for the change? The dev mailing list stripping off all attachments and is hard to follow if the change is not embedded as text in the email. And to Debraj's comment, yes, we are aware of it and are working