[GitHub] [samza] lhaiesp commented on a change in pull request #950: SAMZA-2126: Bug fixes for batch-mode generated stream specs

lhaiesp commented on a change in pull request #950: SAMZA-2126: Bug fixes for batch-mode generated stream specs URL: https://github.com/apache/samza/pull/950#discussion_r264500671 ## File path: samza-kafka/src/main/scala/org/apache/samza/system/kafka/KafkaSystemFactory.scala #

[GitHub] [samza] lhaiesp commented on a change in pull request #950: SAMZA-2126: Bug fixes for batch-mode generated stream specs

lhaiesp commented on a change in pull request #950: SAMZA-2126: Bug fixes for batch-mode generated stream specs URL: https://github.com/apache/samza/pull/950#discussion_r264499493 ## File path: samza-core/src/test/java/org/apache/samza/execution/TestStreamEdge.java ## @@

[GitHub] [samza] xinyuiscool commented on issue #950: SAMZA-2126: Bug fixes for batch-mode generated stream specs

xinyuiscool commented on issue #950: SAMZA-2126: Bug fixes for batch-mode generated stream specs URL: https://github.com/apache/samza/pull/950#issuecomment-471816464 @lhaiesp and @dxichen : please take a look! This is an auto

[GitHub] [samza] xinyuiscool opened a new pull request #950: SAMZA-2126: Bug fixes for batch-mode generated stream specs

xinyuiscool opened a new pull request #950: SAMZA-2126: Bug fixes for batch-mode generated stream specs URL: https://github.com/apache/samza/pull/950 - Kafka properties doesn't support replication.factor when creating topic, so change the way to override intermediate stream properties.

[GitHub] [samza] lakshmi-manasa-g commented on a change in pull request #938: SAMZA-1531: Support run.id in standalone for batch processing.

lakshmi-manasa-g commented on a change in pull request #938: SAMZA-1531: Support run.id in standalone for batch processing. URL: https://github.com/apache/samza/pull/938#discussion_r264494176 ## File path: samza-core/src/main/java/org/apache/samza/zk/ZkDistributedReadWriteLock.java

[GitHub] [samza] lakshmi-manasa-g commented on a change in pull request #938: SAMZA-1531: Support run.id in standalone for batch processing.

lakshmi-manasa-g commented on a change in pull request #938: SAMZA-1531: Support run.id in standalone for batch processing. URL: https://github.com/apache/samza/pull/938#discussion_r264494103 ## File path: samza-core/src/main/java/org/apache/samza/zk/ZkDistributedReadWriteLock.java

[GitHub] [samza] lakshmi-manasa-g commented on a change in pull request #938: SAMZA-1531: Support run.id in standalone for batch processing.

lakshmi-manasa-g commented on a change in pull request #938: SAMZA-1531: Support run.id in standalone for batch processing. URL: https://github.com/apache/samza/pull/938#discussion_r264494115 ## File path: samza-core/src/main/java/org/apache/samza/zk/ZkDistributedReadWriteLock.java

[GitHub] [samza] lakshmi-manasa-g commented on a change in pull request #938: SAMZA-1531: Support run.id in standalone for batch processing.

lakshmi-manasa-g commented on a change in pull request #938: SAMZA-1531: Support run.id in standalone for batch processing. URL: https://github.com/apache/samza/pull/938#discussion_r264494092 ## File path: samza-core/src/main/java/org/apache/samza/zk/ZkDistributedDataAccess.java #

[GitHub] [samza] lakshmi-manasa-g commented on a change in pull request #938: SAMZA-1531: Support run.id in standalone for batch processing.

lakshmi-manasa-g commented on a change in pull request #938: SAMZA-1531: Support run.id in standalone for batch processing. URL: https://github.com/apache/samza/pull/938#discussion_r264494077 ## File path: samza-core/src/main/java/org/apache/samza/runtime/LocalApplicationRunner.jav

[GitHub] [samza] lakshmi-manasa-g commented on a change in pull request #938: SAMZA-1531: Support run.id in standalone for batch processing.

lakshmi-manasa-g commented on a change in pull request #938: SAMZA-1531: Support run.id in standalone for batch processing. URL: https://github.com/apache/samza/pull/938#discussion_r264494088 ## File path: samza-core/src/main/java/org/apache/samza/zk/ZkDistributedDataAccess.java #

[GitHub] [samza] lakshmi-manasa-g commented on a change in pull request #938: SAMZA-1531: Support run.id in standalone for batch processing.

lakshmi-manasa-g commented on a change in pull request #938: SAMZA-1531: Support run.id in standalone for batch processing. URL: https://github.com/apache/samza/pull/938#discussion_r264494011 ## File path: samza-core/src/main/java/org/apache/samza/runtime/LocalApplicationRunner.jav

[GitHub] [samza] lakshmi-manasa-g commented on a change in pull request #938: SAMZA-1531: Support run.id in standalone for batch processing.

lakshmi-manasa-g commented on a change in pull request #938: SAMZA-1531: Support run.id in standalone for batch processing. URL: https://github.com/apache/samza/pull/938#discussion_r264493948 ## File path: samza-core/src/main/java/org/apache/samza/runtime/LocalApplicationRunner.jav

[GitHub] [samza] lakshmi-manasa-g commented on a change in pull request #938: SAMZA-1531: Support run.id in standalone for batch processing.

lakshmi-manasa-g commented on a change in pull request #938: SAMZA-1531: Support run.id in standalone for batch processing. URL: https://github.com/apache/samza/pull/938#discussion_r264493699 ## File path: samza-core/src/main/java/org/apache/samza/zk/ZkDistributedReadWriteLock.java

[GitHub] [samza] lakshmi-manasa-g commented on a change in pull request #938: SAMZA-1531: Support run.id in standalone for batch processing.

lakshmi-manasa-g commented on a change in pull request #938: SAMZA-1531: Support run.id in standalone for batch processing. URL: https://github.com/apache/samza/pull/938#discussion_r264493679 ## File path: samza-core/src/main/java/org/apache/samza/runtime/LocalApplicationRunner.jav

[GitHub] [samza] lakshmi-manasa-g commented on a change in pull request #938: SAMZA-1531: Support run.id in standalone for batch processing.

lakshmi-manasa-g commented on a change in pull request #938: SAMZA-1531: Support run.id in standalone for batch processing. URL: https://github.com/apache/samza/pull/938#discussion_r264493684 ## File path: samza-core/src/main/java/org/apache/samza/runtime/LocalApplicationRunner.jav

[GitHub] [samza] lakshmi-manasa-g commented on a change in pull request #938: SAMZA-1531: Support run.id in standalone for batch processing.

lakshmi-manasa-g commented on a change in pull request #938: SAMZA-1531: Support run.id in standalone for batch processing. URL: https://github.com/apache/samza/pull/938#discussion_r264492763 ## File path: samza-core/src/main/java/org/apache/samza/runtime/LocalApplicationRunner.jav

[GitHub] [samza] lakshmi-manasa-g commented on a change in pull request #938: SAMZA-1531: Support run.id in standalone for batch processing.

lakshmi-manasa-g commented on a change in pull request #938: SAMZA-1531: Support run.id in standalone for batch processing. URL: https://github.com/apache/samza/pull/938#discussion_r264492772 ## File path: samza-core/src/main/java/org/apache/samza/execution/LocalJobPlanner.java ##

[GitHub] [samza] lakshmi-manasa-g commented on a change in pull request #938: SAMZA-1531: Support run.id in standalone for batch processing.

lakshmi-manasa-g commented on a change in pull request #938: SAMZA-1531: Support run.id in standalone for batch processing. URL: https://github.com/apache/samza/pull/938#discussion_r264492694 ## File path: samza-azure/src/main/java/org/apache/samza/coordinator/AzureCoordinationUtil

[GitHub] [samza] lakshmi-manasa-g commented on a change in pull request #938: SAMZA-1531: Support run.id in standalone for batch processing.

lakshmi-manasa-g commented on a change in pull request #938: SAMZA-1531: Support run.id in standalone for batch processing. URL: https://github.com/apache/samza/pull/938#discussion_r264492750 ## File path: samza-core/src/main/java/org/apache/samza/coordinator/DistributedDataStateLi

[GitHub] [samza] lakshmi-manasa-g commented on a change in pull request #938: SAMZA-1531: Support run.id in standalone for batch processing.

lakshmi-manasa-g commented on a change in pull request #938: SAMZA-1531: Support run.id in standalone for batch processing. URL: https://github.com/apache/samza/pull/938#discussion_r264492678 ## File path: samza-azure/src/main/java/org/apache/samza/coordinator/AzureCoordinationUtil

[GitHub] [samza-hello-samza] dxichen opened a new pull request #50: Merge latest to master

dxichen opened a new pull request #50: Merge latest to master URL: https://github.com/apache/samza-hello-samza/pull/50 @jagadish-v0 @xinyuiscool need the updated gitbox fix for master This is an automated message from the Apac

[GitHub] [samza] cameronlee314 commented on a change in pull request #947: SAMZA-2120: Enable custom handling of ConsumerRecords consumed by Kafka

cameronlee314 commented on a change in pull request #947: SAMZA-2120: Enable custom handling of ConsumerRecords consumed by Kafka URL: https://github.com/apache/samza/pull/947#discussion_r264485463 ## File path: samza-kafka/src/main/scala/org/apache/samza/system/kafka/KafkaConsumer

[GitHub] [samza] cameronlee314 commented on a change in pull request #947: SAMZA-2120: Enable custom handling of ConsumerRecords consumed by Kafka

cameronlee314 commented on a change in pull request #947: SAMZA-2120: Enable custom handling of ConsumerRecords consumed by Kafka URL: https://github.com/apache/samza/pull/947#discussion_r264485430 ## File path: samza-kafka/src/main/java/org/apache/samza/system/kafka/KafkaSystemCon

[GitHub] [samza] shanthoosh commented on a change in pull request #947: SAMZA-2120: Enable custom handling of ConsumerRecords consumed by Kafka

shanthoosh commented on a change in pull request #947: SAMZA-2120: Enable custom handling of ConsumerRecords consumed by Kafka URL: https://github.com/apache/samza/pull/947#discussion_r264483279 ## File path: samza-kafka/src/main/scala/org/apache/samza/system/kafka/KafkaConsumerPro

[GitHub] [samza] shanthoosh commented on a change in pull request #947: SAMZA-2120: Enable custom handling of ConsumerRecords consumed by Kafka

shanthoosh commented on a change in pull request #947: SAMZA-2120: Enable custom handling of ConsumerRecords consumed by Kafka URL: https://github.com/apache/samza/pull/947#discussion_r264482486 ## File path: samza-kafka/src/main/java/org/apache/samza/system/kafka/KafkaSystemConsum

[GitHub] [samza] asfgit closed pull request #947: SAMZA-2120: Enable custom handling of ConsumerRecords consumed by Kafka

asfgit closed pull request #947: SAMZA-2120: Enable custom handling of ConsumerRecords consumed by Kafka URL: https://github.com/apache/samza/pull/947 This is an automated message from the Apache Git Service. To respond to t

Re: Backing Kafka/Yarn/Zookeeper version for Samza 1.0.0?

Hi Jeremiah, We're in the process of upgrading Samza to use Kafka clients version 2.0, and YARN client version 2.9. This should be available in the next release (version 1.2). In the mean time, Kafka 0.11 and YARN 2.6 / 2.7 are the recommended versions. Can you clarify what you mean about hard re

[GitHub] [samza] prateekm commented on a change in pull request #947: SAMZA-2120: Enable custom handling of ConsumerRecords consumed by Kafka

prateekm commented on a change in pull request #947: SAMZA-2120: Enable custom handling of ConsumerRecords consumed by Kafka URL: https://github.com/apache/samza/pull/947#discussion_r264480611 ## File path: samza-kafka/src/main/scala/org/apache/samza/system/kafka/KafkaConsumerProxy

[GitHub] [samza] sborya commented on a change in pull request #938: SAMZA-1531: Support run.id in standalone for batch processing.

sborya commented on a change in pull request #938: SAMZA-1531: Support run.id in standalone for batch processing. URL: https://github.com/apache/samza/pull/938#discussion_r264467907 ## File path: samza-core/src/main/java/org/apache/samza/execution/LocalJobPlanner.java ##

[GitHub] [samza] sborya commented on a change in pull request #938: SAMZA-1531: Support run.id in standalone for batch processing.

sborya commented on a change in pull request #938: SAMZA-1531: Support run.id in standalone for batch processing. URL: https://github.com/apache/samza/pull/938#discussion_r264474872 ## File path: samza-core/src/main/java/org/apache/samza/zk/ZkDistributedDataAccess.java ##

[GitHub] [samza] sborya commented on a change in pull request #938: SAMZA-1531: Support run.id in standalone for batch processing.

sborya commented on a change in pull request #938: SAMZA-1531: Support run.id in standalone for batch processing. URL: https://github.com/apache/samza/pull/938#discussion_r264474987 ## File path: samza-core/src/main/java/org/apache/samza/zk/ZkDistributedReadWriteLock.java

[GitHub] [samza] sborya commented on a change in pull request #938: SAMZA-1531: Support run.id in standalone for batch processing.

sborya commented on a change in pull request #938: SAMZA-1531: Support run.id in standalone for batch processing. URL: https://github.com/apache/samza/pull/938#discussion_r264414547 ## File path: samza-core/src/main/java/org/apache/samza/runtime/LocalApplicationRunner.java ###

[GitHub] [samza] sborya commented on a change in pull request #938: SAMZA-1531: Support run.id in standalone for batch processing.

sborya commented on a change in pull request #938: SAMZA-1531: Support run.id in standalone for batch processing. URL: https://github.com/apache/samza/pull/938#discussion_r264474790 ## File path: samza-core/src/main/java/org/apache/samza/zk/ZkDistributedDataAccess.java ##

[GitHub] [samza] sborya commented on a change in pull request #938: SAMZA-1531: Support run.id in standalone for batch processing.

sborya commented on a change in pull request #938: SAMZA-1531: Support run.id in standalone for batch processing. URL: https://github.com/apache/samza/pull/938#discussion_r264472956 ## File path: samza-core/src/main/java/org/apache/samza/runtime/LocalApplicationRunner.java ###

[GitHub] [samza] sborya commented on a change in pull request #938: SAMZA-1531: Support run.id in standalone for batch processing.

sborya commented on a change in pull request #938: SAMZA-1531: Support run.id in standalone for batch processing. URL: https://github.com/apache/samza/pull/938#discussion_r264469001 ## File path: samza-core/src/main/java/org/apache/samza/runtime/LocalApplicationRunner.java ###

[GitHub] [samza] sborya commented on a change in pull request #938: SAMZA-1531: Support run.id in standalone for batch processing.

sborya commented on a change in pull request #938: SAMZA-1531: Support run.id in standalone for batch processing. URL: https://github.com/apache/samza/pull/938#discussion_r264388397 ## File path: samza-core/src/main/java/org/apache/samza/coordinator/DistributedDataStateListener.jav

[GitHub] [samza] sborya commented on a change in pull request #938: SAMZA-1531: Support run.id in standalone for batch processing.

sborya commented on a change in pull request #938: SAMZA-1531: Support run.id in standalone for batch processing. URL: https://github.com/apache/samza/pull/938#discussion_r264470992 ## File path: samza-core/src/main/java/org/apache/samza/zk/ZkDistributedReadWriteLock.java

[GitHub] [samza] sborya commented on a change in pull request #938: SAMZA-1531: Support run.id in standalone for batch processing.

sborya commented on a change in pull request #938: SAMZA-1531: Support run.id in standalone for batch processing. URL: https://github.com/apache/samza/pull/938#discussion_r264473744 ## File path: samza-core/src/main/java/org/apache/samza/runtime/LocalApplicationRunner.java ###

[GitHub] [samza] sborya commented on a change in pull request #938: SAMZA-1531: Support run.id in standalone for batch processing.

sborya commented on a change in pull request #938: SAMZA-1531: Support run.id in standalone for batch processing. URL: https://github.com/apache/samza/pull/938#discussion_r264468919 ## File path: samza-core/src/main/java/org/apache/samza/runtime/LocalApplicationRunner.java ###

[GitHub] [samza] sborya commented on a change in pull request #938: SAMZA-1531: Support run.id in standalone for batch processing.

sborya commented on a change in pull request #938: SAMZA-1531: Support run.id in standalone for batch processing. URL: https://github.com/apache/samza/pull/938#discussion_r264474066 ## File path: samza-core/src/main/java/org/apache/samza/runtime/LocalApplicationRunner.java ###

[GitHub] [samza] sborya commented on a change in pull request #938: SAMZA-1531: Support run.id in standalone for batch processing.

sborya commented on a change in pull request #938: SAMZA-1531: Support run.id in standalone for batch processing. URL: https://github.com/apache/samza/pull/938#discussion_r264475624 ## File path: samza-core/src/main/java/org/apache/samza/zk/ZkDistributedReadWriteLock.java

[GitHub] [samza] sborya commented on a change in pull request #938: SAMZA-1531: Support run.id in standalone for batch processing.

sborya commented on a change in pull request #938: SAMZA-1531: Support run.id in standalone for batch processing. URL: https://github.com/apache/samza/pull/938#discussion_r264469347 ## File path: samza-core/src/main/java/org/apache/samza/runtime/LocalApplicationRunner.java ###

[GitHub] [samza] sborya commented on a change in pull request #938: SAMZA-1531: Support run.id in standalone for batch processing.

sborya commented on a change in pull request #938: SAMZA-1531: Support run.id in standalone for batch processing. URL: https://github.com/apache/samza/pull/938#discussion_r264387433 ## File path: samza-azure/src/main/java/org/apache/samza/coordinator/AzureCoordinationUtils.java ##

[GitHub] [samza] sborya commented on a change in pull request #938: SAMZA-1531: Support run.id in standalone for batch processing.

sborya commented on a change in pull request #938: SAMZA-1531: Support run.id in standalone for batch processing. URL: https://github.com/apache/samza/pull/938#discussion_r264475902 ## File path: samza-core/src/main/java/org/apache/samza/zk/ZkDistributedReadWriteLock.java

[GitHub] [samza] sborya commented on a change in pull request #938: SAMZA-1531: Support run.id in standalone for batch processing.

sborya commented on a change in pull request #938: SAMZA-1531: Support run.id in standalone for batch processing. URL: https://github.com/apache/samza/pull/938#discussion_r264387509 ## File path: samza-azure/src/main/java/org/apache/samza/coordinator/AzureCoordinationUtils.java ##

[CANCEL][VOTE] Apache Samza 1.1.0 RC1

Hi all, This is the CANCEL notification for the samza 1.1.0 RC1. We found few bugs with batch processing in samza which we will fix in SAMZA-2126. Thanks,

[GitHub] [samza] mynameborat commented on a change in pull request #938: SAMZA-1531: Support run.id in standalone for batch processing.

mynameborat commented on a change in pull request #938: SAMZA-1531: Support run.id in standalone for batch processing. URL: https://github.com/apache/samza/pull/938#discussion_r262818100 ## File path: samza-core/src/main/java/org/apache/samza/coordinator/DistributedReadWriteLock.ja

[GitHub] [samza] shanthoosh opened a new pull request #949: Remove scala 2.10 version from documentation.

shanthoosh opened a new pull request #949: Remove scala 2.10 version from documentation. URL: https://github.com/apache/samza/pull/949 Post 1.0, samza does not support scala 2.10 version. This patch removes the references of the scala 2.10 version from the documentation. -

[VOTE] Apache Samza 1.1.0 RC1

Hi, This is a call for a vote on a release of Apache Samza 1.1.0. Thanks to everyone who has contributed to this release. The release candidate can be downloaded from here: http://home.apache.org/~shanthoosh/samza-1.1.0-rc1/ The release candidate is signed with pgp key 0xF8B95961A401BF0F, which

[GitHub] [samza] cameronlee314 commented on a change in pull request #947: SAMZA-2120: Enable custom handling of ConsumerRecords consumed by Kafka

cameronlee314 commented on a change in pull request #947: SAMZA-2120: Enable custom handling of ConsumerRecords consumed by Kafka URL: https://github.com/apache/samza/pull/947#discussion_r264370317 ## File path: samza-kafka/src/main/scala/org/apache/samza/system/kafka/KafkaConsumer

[GitHub] [samza] cameronlee314 commented on a change in pull request #947: SAMZA-2120: Enable custom handling of ConsumerRecords consumed by Kafka

cameronlee314 commented on a change in pull request #947: SAMZA-2120: Enable custom handling of ConsumerRecords consumed by Kafka URL: https://github.com/apache/samza/pull/947#discussion_r264368204 ## File path: samza-kafka/src/main/scala/org/apache/samza/system/kafka/KafkaConsumer

[GitHub] [samza] cameronlee314 commented on a change in pull request #947: SAMZA-2120: Enable custom handling of ConsumerRecords consumed by Kafka

cameronlee314 commented on a change in pull request #947: SAMZA-2120: Enable custom handling of ConsumerRecords consumed by Kafka URL: https://github.com/apache/samza/pull/947#discussion_r264368454 ## File path: samza-kafka/src/main/scala/org/apache/samza/system/kafka/KafkaConsumer

[GitHub] [samza] cameronlee314 commented on a change in pull request #947: SAMZA-2120: Enable custom handling of ConsumerRecords consumed by Kafka

cameronlee314 commented on a change in pull request #947: SAMZA-2120: Enable custom handling of ConsumerRecords consumed by Kafka URL: https://github.com/apache/samza/pull/947#discussion_r264371601 ## File path: samza-kafka/src/main/scala/org/apache/samza/util/KafkaUtilJava.java ##

[CANCEL][VOTE] Apache Samza 1.1.0 RC0

Hi all, This is the CANCEL notification for the 1.1.0 RC0. We found gpg key issues with the artifacts published in the RC0. This will be fixed in the follow-up RC. Thanks,

[GitHub] [samza] prateekm commented on a change in pull request #947: SAMZA-2120: Enable custom handling of ConsumerRecords consumed by Kafka

prateekm commented on a change in pull request #947: SAMZA-2120: Enable custom handling of ConsumerRecords consumed by Kafka URL: https://github.com/apache/samza/pull/947#discussion_r264352847 ## File path: samza-kafka/src/main/scala/org/apache/samza/system/kafka/KafkaConsumerProxy

[GitHub] [samza] prateekm commented on a change in pull request #947: SAMZA-2120: Enable custom handling of ConsumerRecords consumed by Kafka

prateekm commented on a change in pull request #947: SAMZA-2120: Enable custom handling of ConsumerRecords consumed by Kafka URL: https://github.com/apache/samza/pull/947#discussion_r264352561 ## File path: samza-kafka/src/main/scala/org/apache/samza/system/kafka/KafkaConsumerProxy

[GitHub] [samza] prateekm commented on a change in pull request #947: SAMZA-2120: Enable custom handling of ConsumerRecords consumed by Kafka

prateekm commented on a change in pull request #947: SAMZA-2120: Enable custom handling of ConsumerRecords consumed by Kafka URL: https://github.com/apache/samza/pull/947#discussion_r264353406 ## File path: samza-kafka/src/main/scala/org/apache/samza/util/KafkaUtilJava.java ###

[GitHub] [samza] prateekm commented on a change in pull request #947: SAMZA-2120: Enable custom handling of ConsumerRecords consumed by Kafka

prateekm commented on a change in pull request #947: SAMZA-2120: Enable custom handling of ConsumerRecords consumed by Kafka URL: https://github.com/apache/samza/pull/947#discussion_r264352668 ## File path: samza-kafka/src/main/scala/org/apache/samza/system/kafka/KafkaConsumerProxy

[VOTE] Apache Samza 1.1.0 RC0

Hi all, This is a call for a vote on a release of Apache Samza 1.1.0. Thanks to everyone who has contributed to this release. The release candidate can be downloaded from here: http://home.apache.org/~shanthoosh/samza-1.1.0-rc0/ The release candidate is signed with pgp key 0x2F38CB810438EDE3, wh