[GitHub] [samza] xinyuiscool opened a new pull request #948: SAMZA-2124: Add Beam API doc to the website

xinyuiscool opened a new pull request #948: SAMZA-2124: Add Beam API doc to the website URL: https://github.com/apache/samza/pull/948 Add beam quick start, examples and api docs. This is an automated message from the Apache G

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

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

[GitHub] [samza] cameronlee314 commented on issue #941: SAMZA-2120: Enable custom handling of ConsumerRecords consumed by Kafka

cameronlee314 commented on issue #941: SAMZA-2120: Enable custom handling of ConsumerRecords consumed by Kafka URL: https://github.com/apache/samza/pull/941#issuecomment-471124735 Replaced by https://github.com/apache/samza/pull/947. ---

[GitHub] [samza] cameronlee314 opened a new pull request #947: SAMZA-2120: Enable custom handling of ConsumerRecords consumed by Kafka

cameronlee314 opened a new pull request #947: SAMZA-2120: Enable custom handling of ConsumerRecords consumed by Kafka URL: https://github.com/apache/samza/pull/947 This replaces https://github.com/apache/samza/pull/941. Instead of adding an object hook into KafkaConsumerProxy, this allows

[GitHub] [samza] cameronlee314 closed pull request #940: SAMZA-2121: Add checkpoint offset field to IncomingMessageEnvelope

cameronlee314 closed pull request #940: SAMZA-2121: Add checkpoint offset field to IncomingMessageEnvelope URL: https://github.com/apache/samza/pull/940 This is an automated message from the Apache Git Service. To respond to

[GitHub] [samza] cameronlee314 commented on issue #940: SAMZA-2121: Add checkpoint offset field to IncomingMessageEnvelope

cameronlee314 commented on issue #940: SAMZA-2121: Add checkpoint offset field to IncomingMessageEnvelope URL: https://github.com/apache/samza/pull/940#issuecomment-471117914 This is no longer necessary. See SAMZA-2121 for more details. -

[GitHub] [samza] shanthoosh merged pull request #945: [javadoc] Clarify semantics of the offset in IncomingMessageEnvelope as the offset provided by the system consumer for the message

shanthoosh merged pull request #945: [javadoc] Clarify semantics of the offset in IncomingMessageEnvelope as the offset provided by the system consumer for the message URL: https://github.com/apache/samza/pull/945 This is a

[GitHub] [samza] asfgit closed pull request #946: SEP-19: Removing standbytasks.enabled config

asfgit closed pull request #946: SEP-19: Removing standbytasks.enabled config URL: https://github.com/apache/samza/pull/946 This is an automated message from the Apache Git Service. To respond to the message, please log on to

[GitHub] [samza] rmatharu opened a new pull request #946: SEP-19: Removing standbytasks.enabled config

rmatharu opened a new pull request #946: SEP-19: Removing standbytasks.enabled config URL: https://github.com/apache/samza/pull/946 This is an automated message from the Apache Git Service. To respond to the message, please

[GitHub] [samza] cameronlee314 opened a new pull request #945: [javadoc] Clarify semantics of the offset in IncomingMessageEnvelope as the offset provided by the system consumer for the message

cameronlee314 opened a new pull request #945: [javadoc] Clarify semantics of the offset in IncomingMessageEnvelope as the offset provided by the system consumer for the message URL: https://github.com/apache/samza/pull/945

Re: [POSSIBLE PHISHING] Task Partition Commit Failed After Upgrade

Prateek, Migrating to v1.0.0 went off without a hitch. Thanks. Jeremiah Adams Software Engineer www.helixeducation.com Blog | Twitter | Facebook

Re: [DISCUSS] Samza 1.1.0 release

Thanks to everyone who joined the discussion! We will set the SAMZA-2116 ticket for the next release. Now we have 3 binding votes from Yi, Xinyu and Prateek, so I will go ahead with the release procedure and closing the discussion Thanks, Daniel On Thu, Mar 7, 2019 at 1:58 PM Daniel Chen wrote:

[GitHub] [samza] asfgit closed pull request #942: Bugfix: Recent CSM refactor was causing some metrics to not be emitted. Fixed -restore-time metric.

asfgit closed pull request #942: Bugfix: Recent CSM refactor was causing some metrics to not be emitted. Fixed -restore-time metric. URL: https://github.com/apache/samza/pull/942 This is an automated message from the Apache

Backing Kafka/Yarn/Zookeeper version for Samza 1.0.0?

I am in the process of updating our stack. I’m not seeing documentation on what versions of Kafka, Zookeeper and Yarn Samza 1.0.0 should be run on. Best I can tell is a 2.6.1 dependency on Hadoop jars and 0.11.0.2 kafka jars. If these jars are meant to match versions of the software, they are

[GitHub] [samza] rmatharu commented on issue #942: Bugfix: Recent CSM refactor was causing some metrics to not be emitted. Fixed -restore-time metric.

rmatharu commented on issue #942: Bugfix: Recent CSM refactor was causing some metrics to not be emitted. Fixed -restore-time metric. URL: https://github.com/apache/samza/pull/942#issuecomment-471027740 Addressed all comments. ---

[GitHub] [samza] rmatharu commented on a change in pull request #942: Bugfix: Recent CSM refactor was causing some metrics to not be emitted. Fixed -restore-time metric.

rmatharu commented on a change in pull request #942: Bugfix: Recent CSM refactor was causing some metrics to not be emitted. Fixed -restore-time metric. URL: https://github.com/apache/samza/pull/942#discussion_r263878762 ## File path: samza-core/src/main/scala/org/apache/samza/sto

[GitHub] [samza] rmatharu commented on a change in pull request #942: Bugfix: Recent CSM refactor was causing some metrics to not be emitted. Fixed -restore-time metric.

rmatharu commented on a change in pull request #942: Bugfix: Recent CSM refactor was causing some metrics to not be emitted. Fixed -restore-time metric. URL: https://github.com/apache/samza/pull/942#discussion_r263878839 ## File path: samza-core/src/main/scala/org/apache/samza/sys

[GitHub] [samza] prateekm commented on a change in pull request #942: Bugfix: Recent CSM refactor was causing some metrics to not be emitted. Fixed -restore-time metric.

prateekm commented on a change in pull request #942: Bugfix: Recent CSM refactor was causing some metrics to not be emitted. Fixed -restore-time metric. URL: https://github.com/apache/samza/pull/942#discussion_r263877257 ## File path: samza-core/src/main/scala/org/apache/samza/sys

[GitHub] [samza] prateekm commented on a change in pull request #942: Bugfix: Recent CSM refactor was causing some metrics to not be emitted. Fixed -restore-time metric.

prateekm commented on a change in pull request #942: Bugfix: Recent CSM refactor was causing some metrics to not be emitted. Fixed -restore-time metric. URL: https://github.com/apache/samza/pull/942#discussion_r263865477 ## File path: samza-core/src/main/scala/org/apache/samza/con

[GitHub] [samza] prateekm commented on a change in pull request #942: Bugfix: Recent CSM refactor was causing some metrics to not be emitted. Fixed -restore-time metric.

prateekm commented on a change in pull request #942: Bugfix: Recent CSM refactor was causing some metrics to not be emitted. Fixed -restore-time metric. URL: https://github.com/apache/samza/pull/942#discussion_r263866650 ## File path: samza-core/src/main/scala/org/apache/samza/sto

[GitHub] [samza] prateekm commented on a change in pull request #942: Bugfix: Recent CSM refactor was causing some metrics to not be emitted. Fixed -restore-time metric.

prateekm commented on a change in pull request #942: Bugfix: Recent CSM refactor was causing some metrics to not be emitted. Fixed -restore-time metric. URL: https://github.com/apache/samza/pull/942#discussion_r263866440 ## File path: samza-core/src/main/scala/org/apache/samza/sys

[GitHub] [samza] prateekm commented on a change in pull request #942: Bugfix: Recent CSM refactor was causing some metrics to not be emitted. Fixed -restore-time metric.

prateekm commented on a change in pull request #942: Bugfix: Recent CSM refactor was causing some metrics to not be emitted. Fixed -restore-time metric. URL: https://github.com/apache/samza/pull/942#discussion_r263865573 ## File path: samza-core/src/main/scala/org/apache/samza/con

Re: [POSSIBLE PHISHING] Task Partition Commit Failed After Upgrade

Thanks for checking Prateek. There’s a similar thread in the group. I decided to follow advice there and am working on migrating to V1.0.0 instead of 0.14. Jeremiah Adams Software Engineer www.helixeducation.com Blog | Twitte