[jira] [Commented] (SAMZA-2012) Add API for wiring an external context through to application processing code

[ https://issues.apache.org/jira/browse/SAMZA-2012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16710808#comment-16710808 ] ASF GitHub Bot commented on SAMZA-2012: --- Github user asfgit closed the pull request at:

[1/2] samza git commit: SAMZA-2012: Add API for wiring an external context through to application processing code

Repository: samza Updated Branches: refs/heads/master 1a7e27097 -> e2adf8f99 http://git-wip-us.apache.org/repos/asf/samza/blob/e2adf8f9/samza-sql/src/test/java/org/apache/samza/sql/e2e/TestSamzaSqlRemoteTable.java -- diff

[2/2] samza git commit: SAMZA-2012: Add API for wiring an external context through to application processing code

SAMZA-2012: Add API for wiring an external context through to application processing code This PR also refactors TestSamzaSqlRemoteTable to be in samza-test instead of samza-sql, since it seems to actually be an integration test. It is useful to move that test in this PR so that tests that may

[jira] [Updated] (SAMZA-1997) Samza-sql Diagnostics: instrument Project operator

[ https://issues.apache.org/jira/browse/SAMZA-1997?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shenoda Guirguis updated SAMZA-1997: Summary: Samza-sql Diagnostics: instrument Project operator (was: Samza-sql: instrument

[jira] [Updated] (SAMZA-2029) Samza-SQL Diagnostics: propagate eventTime and assign arrivalTime

[ https://issues.apache.org/jira/browse/SAMZA-2029?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shenoda Guirguis updated SAMZA-2029: Summary: Samza-SQL Diagnostics: propagate eventTime and assign arrivalTime (was:

[jira] [Commented] (SAMZA-2002) Instrument Rest of Operators (except Join) and Query

[ https://issues.apache.org/jira/browse/SAMZA-2002?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16710740#comment-16710740 ] Shenoda Guirguis commented on SAMZA-2002: - PR: https://github.com/apache/samza/pull/831 >

[jira] [Updated] (SAMZA-2028) Samza-SQL Diagnostics: instrument Join and Aggregate operators adding and maintaining metrics

[ https://issues.apache.org/jira/browse/SAMZA-2028?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shenoda Guirguis updated SAMZA-2028: Summary: Samza-SQL Diagnostics: instrument Join and Aggregate operators adding and

[jira] [Updated] (SAMZA-2002) SamzaSQL Diagnostics: Instrument Rest of Operators (except Join & Aggregate) and Query

[ https://issues.apache.org/jira/browse/SAMZA-2002?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shenoda Guirguis updated SAMZA-2002: Summary: SamzaSQL Diagnostics: Instrument Rest of Operators (except Join & Aggregate) and

[jira] [Created] (SAMZA-2029) Samza-sql diagnostics: propagate eventTime and assign arrivalTime

Shenoda Guirguis created SAMZA-2029: --- Summary: Samza-sql diagnostics: propagate eventTime and assign arrivalTime Key: SAMZA-2029 URL: https://issues.apache.org/jira/browse/SAMZA-2029 Project: Samza

[jira] [Created] (SAMZA-2028) Samza-sql: instrument Join and Aggregate operators adding and maintaining metrics

Shenoda Guirguis created SAMZA-2028: --- Summary: Samza-sql: instrument Join and Aggregate operators adding and maintaining metrics Key: SAMZA-2028 URL: https://issues.apache.org/jira/browse/SAMZA-2028

[jira] [Commented] (SAMZA-2019) support per stream broadcast config

[ https://issues.apache.org/jira/browse/SAMZA-2019?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16710682#comment-16710682 ] ASF GitHub Bot commented on SAMZA-2019: --- Github user asfgit closed the pull request at:

samza git commit: SAMZA-2019: for 1 partition broadcast topic generate topic#0 config

Repository: samza Updated Branches: refs/heads/master b668b5bea -> 1a7e27097 SAMZA-2019: for 1 partition broadcast topic generate topic#0 config + address few review comments Author: Boris S Author: Boris S Author: Boris Shkolnik Reviewers: xiliu Closes #846 from sborya/isBroadcast1

[jira] [Commented] (SAMZA-2019) support per stream broadcast config

[ https://issues.apache.org/jira/browse/SAMZA-2019?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16710656#comment-16710656 ] ASF GitHub Bot commented on SAMZA-2019: --- GitHub user sborya opened a pull request:

[jira] [Commented] (SAMZA-2019) support per stream broadcast config

[ https://issues.apache.org/jira/browse/SAMZA-2019?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16710566#comment-16710566 ] ASF GitHub Bot commented on SAMZA-2019: --- Github user asfgit closed the pull request at:

samza git commit: SAMZA-2019: add Is broadcast per stream config

Repository: samza Updated Branches: refs/heads/master 5ea72584f -> b668b5bea SAMZA-2019: add Is broadcast per stream config Author: Boris S Author: Boris S Author: Boris Shkolnik Reviewers: xinyuiscool , Prateek M Closes #837 from sborya/isBroadcast Project:

[2/3] samza git commit: SAMZA-1973: Unify the TaskNameGrouper interface for yarn and standalone.

http://git-wip-us.apache.org/repos/asf/samza/blob/5ea72584/samza-core/src/main/scala/org/apache/samza/coordinator/JobModelManager.scala -- diff --git a/samza-core/src/main/scala/org/apache/samza/coordinator/JobModelManager.scala

[3/3] samza git commit: SAMZA-1973: Unify the TaskNameGrouper interface for yarn and standalone.

SAMZA-1973: Unify the TaskNameGrouper interface for yarn and standalone. This patch consists of the following changes: * Unify the different methods present in the TaskNameGrouper interface. This will enable us to have a single interface method usable for both the yarn and standalone models. *

[1/3] samza git commit: SAMZA-1973: Unify the TaskNameGrouper interface for yarn and standalone.

Repository: samza Updated Branches: refs/heads/master c7e5dcba4 -> 5ea72584f http://git-wip-us.apache.org/repos/asf/samza/blob/5ea72584/samza-core/src/test/java/org/apache/samza/zk/TestZkUtils.java -- diff --git

[jira] [Resolved] (SAMZA-1638) Recreate SystemProducer on KafkaCheckpointManager.writeCheckpoint failure.

[ https://issues.apache.org/jira/browse/SAMZA-1638?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Prateek Maheshwari resolved SAMZA-1638. --- Resolution: Fixed > Recreate SystemProducer on

[jira] [Resolved] (SAMZA-1946) Problem with Race between TimerListenener initialization and timers fired from init()

[ https://issues.apache.org/jira/browse/SAMZA-1946?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Prateek Maheshwari resolved SAMZA-1946. --- Resolution: Fixed Assignee: Xinyu Liu > Problem with Race between

[jira] [Created] (SAMZA-2027) Config support in through Set statement

Weiqing Yang created SAMZA-2027: --- Summary: Config support in through Set statement Key: SAMZA-2027 URL: https://issues.apache.org/jira/browse/SAMZA-2027 Project: Samza Issue Type: Sub-task

[jira] [Commented] (SAMZA-1835) Consolidate all processorId generation code to StreamProcessor

[ https://issues.apache.org/jira/browse/SAMZA-1835?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16709715#comment-16709715 ] ASF GitHub Bot commented on SAMZA-1835: --- GitHub user shanthoosh opened a pull request: