[GitHub] samza pull request #265: SAMZA-1385: Fix zookeeper path conflict between Loc...

2017-08-14 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/samza/pull/265 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enabl

[GitHub] samza pull request #270: SAMZA-1390: Update SamzaMonitorService to spawn dea...

2017-08-14 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/samza/pull/270 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enabl

[GitHub] samza pull request #271: Refactor coordination utils (with the ZkLock)

2017-08-14 Thread sborya
GitHub user sborya opened a pull request: https://github.com/apache/samza/pull/271 Refactor coordination utils (with the ZkLock) please ignore these changes (they come form Pawas' pr #264 ): TestStatefulTask.scala TestKafkaSystemAdminJava.java KafkaSystemAdmin.scala T

[GitHub] samza pull request #270: SAMZA-1390: Update SamzaMonitorService to spawn dea...

2017-08-14 Thread shanthoosh
GitHub user shanthoosh opened a pull request: https://github.com/apache/samza/pull/270 SAMZA-1390: Update SamzaMonitorService to spawn deamon threads Observed in LinkedIn production setup that samza-rest jvm process doesn’t stop after main thread death(due to jetty server fail

Re: Issue with TopicExistsException in 0.13.0

2017-08-14 Thread Jacob Maes
Correction, the exception seems to have moved between kafka version 0.10.0.1 and 0.10.1.1 Here's the patch that changed both the kafka version and the import statement for TopicExistsException: https://github.com/apache/samza/commit/9db47b86120f80b127d2bca857b6a1cd5578a6d4#diff-2beed65293202568c54

Re: Issue with TopicExistsException in 0.13.0

2017-08-14 Thread Jacob Maes
Hey Jeremiah, It looks like the TopicExistsException should be handled by the system admin and not rethrown: https://github.com/apache/samza/blob/06702af8fda1d016ae55461c404b55b84b20ffd2/samza-kafka/src/main/scala/org/apache/samza/system/kafka/KafkaSystemAdmin.scala#L442 I have a theory what's ha

Issue with TopicExistsException in 0.13.0

2017-08-14 Thread Jeremiah Adams
I am having an issue with topic creation after updating dependencies. I bumped samza dependencies from scala 2.10 v 0.10.1 to scala 2.11 0.13.0 and org.apache.kafka dependency from kafka_2.10 0.8.1 to kafka_2.11 0.10.1.1. I am seeing an error that the topic already exists and the job gets stuck

Re: [Discuss] Samza 0.13.1 release

2017-08-14 Thread xinyu liu
+1. Thanks for pushing the release. Xinyu On Mon, Aug 14, 2017 at 10:58 AM, Boris S wrote: > +1 for the release. > > On Mon, Aug 14, 2017 at 10:38 AM, Yi Pan wrote: > > > +1 for the list! Let's proceed! > > > > On Fri, Aug 11, 2017 at 6:13 PM, Ignacio Solis wrote: > > > > > +1 > > > > > > On

Re: [Discuss] Samza 0.13.1 release

2017-08-14 Thread Boris S
+1 for the release. On Mon, Aug 14, 2017 at 10:38 AM, Yi Pan wrote: > +1 for the list! Let's proceed! > > On Fri, Aug 11, 2017 at 6:13 PM, Ignacio Solis wrote: > > > +1 > > > > On Fri, Aug 11, 2017 at 3:52 PM, Jacob Maes > wrote: > > > Looks good! > > > > > > +1 > > > > > > On Thu, Aug 10, 201

Re: [Discuss] Samza 0.13.1 release

2017-08-14 Thread Yi Pan
+1 for the list! Let's proceed! On Fri, Aug 11, 2017 at 6:13 PM, Ignacio Solis wrote: > +1 > > On Fri, Aug 11, 2017 at 3:52 PM, Jacob Maes wrote: > > Looks good! > > > > +1 > > > > On Thu, Aug 10, 2017 at 6:53 PM, Jagadish Venkatraman < > > jagadish1...@gmail.com> wrote: > > > >> +1 for the rel