[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_r264944248 ## File path: samza-core/src/main/java/org/apache/samza/runtime/LocalApplicationRunner.java ##

[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_r264938632 ## File path: samza-core/src/main/java/org/apache/samza/runtime/LocalApplicationRunner.java ##

[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_r264937342 ## File path: samza-core/src/main/java/org/apache/samza/runtime/LocalApplicationRunner.java ##

[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_r264937250 ## File path: samza-core/src/main/java/org/apache/samza/runtime/LocalApplicationRunner.java ##

[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_r264843464 ## File path: samza-core/src/main/java/org/apache/samza/runtime/LocalApplicationRunner.java ##

[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_r264938259 ## File path: samza-core/src/main/java/org/apache/samza/runtime/LocalApplicationRunner.java ##

[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_r264811329 ## File path: samza-core/src/main/java/org/apache/samza/runtime/LocalApplicationRunner.java ##

[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_r264802724 ## File path: samza-core/src/main/java/org/apache/samza/execution/LocalJobPlanner.java ###

[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_r264798931 ## File path: samza-core/src/main/java/org/apache/samza/coordinator/CoordinationConstants.java

[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_r264802046 ## File path: samza-core/src/main/java/org/apache/samza/execution/LocalJobPlanner.java ###

[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_r264797657 ## File path: samza-core/src/main/java/org/apache/samza/execution/LocalJobPlanner.java ###

[VOTE] Apache Samza 1.1.0 RC2

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-rc2/ The release candidate is signed with pgp key 0xF8B95961A401BF0F, which

[GitHub] [samza-beam-examples] dxichen commented on a change in pull request #2: Update scripts and docs based on Beam 2.11.0 release

dxichen commented on a change in pull request #2: Update scripts and docs based on Beam 2.11.0 release URL: https://github.com/apache/samza-beam-examples/pull/2#discussion_r264905811 ## File path: pom.xml ## @@ -27,7 +27,7 @@ jar -2.9.0 +2.11.0 0.14.1

[GitHub] [samza-hello-samza] xinyuiscool merged pull request #51: Fix build issues on master, update versions

xinyuiscool merged pull request #51: Fix build issues on master, update versions URL: https://github.com/apache/samza-hello-samza/pull/51 This is an automated message from the Apache Git Service. To respond to the message, pl

[GitHub] [samza-beam-examples] dxichen commented on a change in pull request #2: Update scripts and docs based on Beam 2.11.0 release

dxichen commented on a change in pull request #2: Update scripts and docs based on Beam 2.11.0 release URL: https://github.com/apache/samza-beam-examples/pull/2#discussion_r264896844 ## File path: pom.xml ## @@ -27,7 +27,7 @@ jar -2.9.0 +2.11.0 0.14.1

[GitHub] [samza-hello-samza] dxichen opened a new pull request #51: Fix build issues on master, update versions

dxichen opened a new pull request #51: Fix build issues on master, update versions URL: https://github.com/apache/samza-hello-samza/pull/51 - fix rat license errors - upgrade versions This is an automated message from the

[GitHub] [samza-beam-examples] xinyuiscool opened a new pull request #2: Update scripts and docs based on Beam 2.11.0 release

xinyuiscool opened a new pull request #2: Update scripts and docs based on Beam 2.11.0 release URL: https://github.com/apache/samza-beam-examples/pull/2 This is an automated message from the Apache Git Service. To respond to

[GitHub] [samza] shanthoosh merged pull request #948: SAMZA-2124: Add Beam API doc to the website

shanthoosh merged pull request #948: SAMZA-2124: Add Beam API doc to the website URL: https://github.com/apache/samza/pull/948 This is an automated message from the Apache Git Service. To respond to the message, please log on

[GitHub] [samza] dxichen commented on issue #948: SAMZA-2124: Add Beam API doc to the website

dxichen commented on issue #948: SAMZA-2124: Add Beam API doc to the website URL: https://github.com/apache/samza/pull/948#issuecomment-472144603 LGTM, thanks! This is an automated message from the Apache Git Service. To respo

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

xinyuiscool merged pull request #950: SAMZA-2126: Bug fixes for batch-mode generated stream specs URL: https://github.com/apache/samza/pull/950 This is an automated message from the Apache Git Service. To respond to the mess

[GitHub] [samza] xinyuiscool commented on a change in pull request #948: SAMZA-2124: Add Beam API doc to the website

xinyuiscool commented on a change in pull request #948: SAMZA-2124: Add Beam API doc to the website URL: https://github.com/apache/samza/pull/948#discussion_r264836697 ## File path: docs/startup/code-examples/versioned/beam.md ## @@ -0,0 +1,125 @@ +--- +layout: page +title

[GitHub] [samza] xinyuiscool commented on a change in pull request #948: SAMZA-2124: Add Beam API doc to the website

xinyuiscool commented on a change in pull request #948: SAMZA-2124: Add Beam API doc to the website URL: https://github.com/apache/samza/pull/948#discussion_r264831770 ## File path: docs/startup/code-examples/versioned/beam.md ## @@ -0,0 +1,125 @@ +--- +layout: page +title

[GitHub] [samza] xinyuiscool commented on a change in pull request #948: SAMZA-2124: Add Beam API doc to the website

xinyuiscool commented on a change in pull request #948: SAMZA-2124: Add Beam API doc to the website URL: https://github.com/apache/samza/pull/948#discussion_r264831459 ## File path: docs/learn/documentation/versioned/api/beam-api.md ## @@ -0,0 +1,109 @@ +--- +layout: page

[GitHub] [samza] xinyuiscool commented on a change in pull request #948: SAMZA-2124: Add Beam API doc to the website

xinyuiscool commented on a change in pull request #948: SAMZA-2124: Add Beam API doc to the website URL: https://github.com/apache/samza/pull/948#discussion_r264830709 ## File path: docs/learn/documentation/versioned/api/beam-api.md ## @@ -0,0 +1,109 @@ +--- +layout: page

[GitHub] [samza] xinyuiscool commented on a change in pull request #948: SAMZA-2124: Add Beam API doc to the website

xinyuiscool commented on a change in pull request #948: SAMZA-2124: Add Beam API doc to the website URL: https://github.com/apache/samza/pull/948#discussion_r264829957 ## File path: docs/learn/documentation/versioned/api/beam-api.md ## @@ -0,0 +1,109 @@ +--- +layout: page

[GitHub] [samza] xinyuiscool commented on a change in pull request #948: SAMZA-2124: Add Beam API doc to the website

xinyuiscool commented on a change in pull request #948: SAMZA-2124: Add Beam API doc to the website URL: https://github.com/apache/samza/pull/948#discussion_r264828840 ## File path: docs/startup/code-examples/versioned/samza.md ## @@ -0,0 +1,59 @@ +--- +layout: page +title

[GitHub] [samza] xinyuiscool commented on a change in pull request #948: SAMZA-2124: Add Beam API doc to the website

xinyuiscool commented on a change in pull request #948: SAMZA-2124: Add Beam API doc to the website URL: https://github.com/apache/samza/pull/948#discussion_r264819667 ## File path: docs/startup/code-examples/versioned/beam.md ## @@ -0,0 +1,125 @@ +--- +layout: page +title

[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_r264819333 ## File path: samza-kafka/src/main/scala/org/apache/samza/system/kafka/KafkaSystemFactory.scala #

[GitHub] [samza] xinyuiscool commented on a change in pull request #948: SAMZA-2124: Add Beam API doc to the website

xinyuiscool commented on a change in pull request #948: SAMZA-2124: Add Beam API doc to the website URL: https://github.com/apache/samza/pull/948#discussion_r264819011 ## File path: docs/startup/code-examples/versioned/beam.md ## @@ -0,0 +1,125 @@ +--- +layout: page +title

[GitHub] [samza] xinyuiscool commented on a change in pull request #948: SAMZA-2124: Add Beam API doc to the website

xinyuiscool commented on a change in pull request #948: SAMZA-2124: Add Beam API doc to the website URL: https://github.com/apache/samza/pull/948#discussion_r264818525 ## File path: docs/learn/documentation/versioned/api/beam-api.md ## @@ -0,0 +1,109 @@ +--- +layout: page

[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_r263820649 ## File path: samza-azure/src/main/java/org/apache/samza/coordinator/AzureCoordinationUtils.jav

[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_r263843961 ## File path: samza-core/src/main/java/org/apache/samza/coordinator/DistributedDataAccess.java

[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_r263825107 ## File path: samza-core/src/main/java/org/apache/samza/coordinator/CoordinationUtils.java ###

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

xinyuiscool 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_r264769050 ## File path: samza-core/src/main/java/org/apache/samza/execution/StreamEdge.java ## @@ -

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

xinyuiscool 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_r264772383 ## File path: samza-kafka/src/test/java/org/apache/samza/system/kafka/TestKafkaSystemFactoryJava.j

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

xinyuiscool 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_r264784148 ## File path: samza-kafka/src/test/java/org/apache/samza/system/kafka/TestKafkaSystemFactoryJava.j

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

xinyuiscool 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_r264770420 ## File path: samza-core/src/test/java/org/apache/samza/execution/TestStreamEdge.java ##

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

xinyuiscool 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_r264771950 ## File path: samza-kafka/src/main/scala/org/apache/samza/system/kafka/KafkaSystemFactory.scala #

[GitHub] [samza-hello-samza] xinyuiscool merged pull request #50: Merge latest to master

xinyuiscool merged pull request #50: Merge latest to master URL: https://github.com/apache/samza-hello-samza/pull/50 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

[GitHub] [samza] shanthoosh commented on a change in pull request #948: SAMZA-2124: Add Beam API doc to the website

shanthoosh commented on a change in pull request #948: SAMZA-2124: Add Beam API doc to the website URL: https://github.com/apache/samza/pull/948#discussion_r264771114 ## File path: docs/learn/documentation/versioned/api/beam-api.md ## @@ -0,0 +1,109 @@ +--- +layout: page +

[GitHub] [samza] shanthoosh commented on a change in pull request #948: SAMZA-2124: Add Beam API doc to the website

shanthoosh commented on a change in pull request #948: SAMZA-2124: Add Beam API doc to the website URL: https://github.com/apache/samza/pull/948#discussion_r264772832 ## File path: docs/startup/code-examples/versioned/beam.md ## @@ -0,0 +1,125 @@ +--- +layout: page +title:

[GitHub] [samza] shanthoosh commented on a change in pull request #948: SAMZA-2124: Add Beam API doc to the website

shanthoosh commented on a change in pull request #948: SAMZA-2124: Add Beam API doc to the website URL: https://github.com/apache/samza/pull/948#discussion_r264770191 ## File path: docs/learn/documentation/versioned/api/beam-api.md ## @@ -0,0 +1,109 @@ +--- +layout: page +

[GitHub] [samza] shanthoosh commented on a change in pull request #948: SAMZA-2124: Add Beam API doc to the website

shanthoosh commented on a change in pull request #948: SAMZA-2124: Add Beam API doc to the website URL: https://github.com/apache/samza/pull/948#discussion_r264772299 ## File path: docs/startup/code-examples/versioned/beam.md ## @@ -0,0 +1,125 @@ +--- +layout: page +title:

[GitHub] [samza] shanthoosh commented on a change in pull request #948: SAMZA-2124: Add Beam API doc to the website

shanthoosh commented on a change in pull request #948: SAMZA-2124: Add Beam API doc to the website URL: https://github.com/apache/samza/pull/948#discussion_r264770716 ## File path: docs/learn/documentation/versioned/api/beam-api.md ## @@ -0,0 +1,109 @@ +--- +layout: page +

Re: "send to" ordering is inconsistent

Bummer! Yes, that works. The phase from "pending" to "running" is a nice-to-have at the moment (operations don't take long enough yet to warrant the extra state) so we just removed it for the time being. Prateek Maheshwari writes: Hi Tom, It looks like we won't be able to include SAMZA-2116 i

[GitHub] [samza] shanthoosh edited a comment on issue #950: SAMZA-2126: Bug fixes for batch-mode generated stream specs

shanthoosh edited a comment on issue #950: SAMZA-2126: Bug fixes for batch-mode generated stream specs URL: https://github.com/apache/samza/pull/950#issuecomment-472046147 > Kafka properties doesn't support replication.factor when creating topic, so change the way to override intermediate

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

shanthoosh merged pull request #949: Remove scala 2.10 version from documentation. URL: https://github.com/apache/samza/pull/949 This is an automated message from the Apache Git Service. To respond to the message, please log

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

shanthoosh commented on issue #950: SAMZA-2126: Bug fixes for batch-mode generated stream specs URL: https://github.com/apache/samza/pull/950#issuecomment-472046147 > Kafka properties doesn't support replication.factor when creating topic, so change the way to override intermediate stream

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

Is zookeeper required for the tech stack? If samza does all of its checkpointing on kafka, I may be able to save us some money by eliminating the ZK cluster. Jeremiah Adams Software Engineer www.helixeducation.com Blog | Twi

[GitHub] [samza] dxichen commented on a change in pull request #948: SAMZA-2124: Add Beam API doc to the website

dxichen commented on a change in pull request #948: SAMZA-2124: Add Beam API doc to the website URL: https://github.com/apache/samza/pull/948#discussion_r264568558 ## File path: docs/startup/code-examples/versioned/beam.md ## @@ -0,0 +1,125 @@ +--- +layout: page +title: Be

[GitHub] [samza] dxichen commented on a change in pull request #948: SAMZA-2124: Add Beam API doc to the website

dxichen commented on a change in pull request #948: SAMZA-2124: Add Beam API doc to the website URL: https://github.com/apache/samza/pull/948#discussion_r264569121 ## File path: docs/startup/code-examples/versioned/beam.md ## @@ -0,0 +1,125 @@ +--- +layout: page +title: Be

[GitHub] [samza] dxichen commented on a change in pull request #948: SAMZA-2124: Add Beam API doc to the website

dxichen commented on a change in pull request #948: SAMZA-2124: Add Beam API doc to the website URL: https://github.com/apache/samza/pull/948#discussion_r264566604 ## File path: docs/learn/documentation/versioned/api/beam-api.md ## @@ -0,0 +1,109 @@ +--- +layout: page +tit

[GitHub] [samza] dxichen commented on a change in pull request #948: SAMZA-2124: Add Beam API doc to the website

dxichen commented on a change in pull request #948: SAMZA-2124: Add Beam API doc to the website URL: https://github.com/apache/samza/pull/948#discussion_r264570055 ## File path: docs/startup/code-examples/versioned/samza.md ## @@ -0,0 +1,59 @@ +--- +layout: page +title: Sa

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

dxichen 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_r264563956 ## File path: samza-kafka/src/test/java/org/apache/samza/system/kafka/TestKafkaSystemFactoryJava.java

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

dxichen 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_r264562730 ## File path: samza-kafka/src/test/java/org/apache/samza/system/kafka/TestKafkaSystemFactoryJava.java

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

dxichen 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_r264557242 ## File path: samza-core/src/main/java/org/apache/samza/execution/StreamEdge.java ## @@ -75,7

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

dxichen 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_r264560110 ## File path: samza-kafka/src/main/scala/org/apache/samza/system/kafka/KafkaSystemFactory.scala #

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

dxichen 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_r264557923 ## File path: samza-core/src/test/java/org/apache/samza/execution/TestStreamEdge.java ## @@