[06/18] samza-hello-samza git commit: Update Cookbook examples

2018-12-06 Thread jagadish
Update Cookbook examples Updating cookbook examples with latest api. I verified all the applications except table examples. Found a bug (https://github.com/apache/samza/pull/684) in metadatastore with Table example. Once the fix is in, need to verify the table examples again. Also change the

[03/18] samza-hello-samza git commit: SAMZA-1810: Added sample for remote table

2018-12-06 Thread jagadish
SAMZA-1810: Added sample for remote table Added a sample that demonstrates the usage of remote table backed by RESTful service. Author: Wei Song Reviewers: Jagadish Closes #34 from weisong44/latest Project: http://git-wip-us.apache.org/repos/asf/samza-hello-samza/repo Commit:

[17/18] samza-hello-samza git commit: Merge latest with master

2018-12-06 Thread jagadish
Merge latest with master Project: http://git-wip-us.apache.org/repos/asf/samza-hello-samza/repo Commit: http://git-wip-us.apache.org/repos/asf/samza-hello-samza/commit/82905901 Tree: http://git-wip-us.apache.org/repos/asf/samza-hello-samza/tree/82905901 Diff:

[10/18] samza-hello-samza git commit: SAMZA-1963: Verify table samples in samza-hello-samples

2018-12-06 Thread jagadish
SAMZA-1963: Verify table samples in samza-hello-samples Author: Wei Song Reviewers: Xinyu Liu Closes #40 from weisong44/SAMZA-1963 and squashes the following commits: 473608b [Wei Song] Verified and fixed minor issues for local and remote table samples ff2c171 [Wei Song] Merged from

[18/18] samza-hello-samza git commit: Merge latest with master

2018-12-06 Thread jagadish
Merge latest with master Project: http://git-wip-us.apache.org/repos/asf/samza-hello-samza/repo Commit: http://git-wip-us.apache.org/repos/asf/samza-hello-samza/commit/c838b97b Tree: http://git-wip-us.apache.org/repos/asf/samza-hello-samza/tree/c838b97b Diff:

[11/18] samza-hello-samza git commit: Update Event Hubs Example

2018-12-06 Thread jagadish
Update Event Hubs Example Update the Event Hubs Connector example for 1.0 release. Author: Daniel Chen Reviewers: Prateek Maheshwari Closes #38 from dxichen/latest Project: http://git-wip-us.apache.org/repos/asf/samza-hello-samza/repo Commit:

[07/18] samza-hello-samza git commit: Add quickstart source code tar

2018-12-06 Thread jagadish
Add quickstart source code tar Project: http://git-wip-us.apache.org/repos/asf/samza-hello-samza/repo Commit: http://git-wip-us.apache.org/repos/asf/samza-hello-samza/commit/195e181c Tree: http://git-wip-us.apache.org/repos/asf/samza-hello-samza/tree/195e181c Diff:

[09/18] samza-hello-samza git commit: Cleaned up configurations for some sample jobs.

2018-12-06 Thread jagadish
Cleaned up configurations for some sample jobs. Author: Prateek Maheshwari Reviewers: Jagadish Venkatraman Closes #37 from prateekm/latest Project: http://git-wip-us.apache.org/repos/asf/samza-hello-samza/repo Commit: http://git-wip-us.apache.org/repos/asf/samza-hello-samza/commit/4ec614c6

[15/18] samza-hello-samza git commit: SAMZA-1629: Integration Tests for all samples of hello-samza

2018-12-06 Thread jagadish
SAMZA-1629: Integration Tests for all samples of hello-samza Author: Sanil Jain Reviewers: Jagadish Closes #44 from Sanil15/latest Project: http://git-wip-us.apache.org/repos/asf/samza-hello-samza/repo Commit: http://git-wip-us.apache.org/repos/asf/samza-hello-samza/commit/f25c37d3 Tree:

[02/18] samza-hello-samza git commit: SAMZA-1592: Fix Hello-Samza latest after Kafka 0.11 upgrade in Samza

2018-12-06 Thread jagadish
SAMZA-1592: Fix Hello-Samza latest after Kafka 0.11 upgrade in Samza After the Kafka-0.11 upgrade, the latest branch in hello-samza (and hence all our open-source tutorials that rely on it) are broken. Users who follow the tutorial will see a `NoSuchMethodError` when starting their job due to a

[12/18] samza-hello-samza git commit: Upgrading to samza 1.0

2018-12-06 Thread jagadish
Upgrading to samza 1.0 * Adding WikipediaStatsStreamTaskApplication, WikipediaParserStreamTaskApplication, WikipediaFeedStreamTaskApplication * Removing task.inputs, and task.class from config. * Adding app.class. Author: Ray Matharu Reviewers: Prateek Maheshwari Closes #43 from

[14/18] samza-hello-samza git commit: SAMZA-1629: Integration Tests for all samples of hello-samza

2018-12-06 Thread jagadish
http://git-wip-us.apache.org/repos/asf/samza-hello-samza/blob/f25c37d3/src/test/resources/WikipediaEditEvents.txt -- diff --git a/src/test/resources/WikipediaEditEvents.txt b/src/test/resources/WikipediaEditEvents.txt new file

[05/18] samza-hello-samza git commit: Update Cookbook examples

2018-12-06 Thread jagadish
http://git-wip-us.apache.org/repos/asf/samza-hello-samza/blob/f9374176/src/main/java/samza/examples/cookbook/StreamTableJoinExample.java -- diff --git a/src/main/java/samza/examples/cookbook/StreamTableJoinExample.java

[08/18] samza-hello-samza git commit: Updated with changes in apache/samza master for Samza 1.0

2018-12-06 Thread jagadish
Updated with changes in apache/samza master for Samza 1.0 Author: Prateek Maheshwari Closes #36 from prateekm/latest Project: http://git-wip-us.apache.org/repos/asf/samza-hello-samza/repo Commit: http://git-wip-us.apache.org/repos/asf/samza-hello-samza/commit/2d956496 Tree:

[16/18] samza-hello-samza git commit: Fix build failures by excluding scala 2.12 versions

2018-12-06 Thread jagadish
Fix build failures by excluding scala 2.12 versions Project: http://git-wip-us.apache.org/repos/asf/samza-hello-samza/repo Commit: http://git-wip-us.apache.org/repos/asf/samza-hello-samza/commit/e971e93a Tree: http://git-wip-us.apache.org/repos/asf/samza-hello-samza/tree/e971e93a Diff:

[04/18] samza-hello-samza git commit: Update hello-samza with latest code

2018-12-06 Thread jagadish
Update hello-samza with latest code RB: https://reviews.apache.org/r/68867/ Project: http://git-wip-us.apache.org/repos/asf/samza-hello-samza/repo Commit: http://git-wip-us.apache.org/repos/asf/samza-hello-samza/commit/b6acf190 Tree:

[13/18] samza-hello-samza git commit: SAMZA-1629: Integration Tests for all samples of hello-samza

2018-12-06 Thread jagadish
http://git-wip-us.apache.org/repos/asf/samza-hello-samza/blob/f25c37d3/src/test/resources/WikitionaryEditEvents.txt -- diff --git a/src/test/resources/WikitionaryEditEvents.txt b/src/test/resources/WikitionaryEditEvents.txt new

samza-hello-samza git commit: Fix build failures by excluding scala 2.12 versions

2018-12-06 Thread jagadish
Repository: samza-hello-samza Updated Branches: refs/heads/latest f25c37d3c -> e971e93a4 Fix build failures by excluding scala 2.12 versions Project: http://git-wip-us.apache.org/repos/asf/samza-hello-samza/repo Commit: http://git-wip-us.apache.org/repos/asf/samza-hello-samza/commit/e971e93a

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

2018-12-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-1835?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16712261#comment-16712261 ] ASF GitHub Bot commented on SAMZA-1835: --- Github user asfgit closed the pull request at:

samza git commit: SAMZA-1835: Consolidate all processorId generation code.

2018-12-06 Thread jagadish
Repository: samza Updated Branches: refs/heads/master bd9387b7f -> df56f2dc1 SAMZA-1835: Consolidate all processorId generation code. Currently, the processorId creation function createProcessorId() is repeated in three different implementation of `JobCoordinator` viz `ZkJobCoordinator`,

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

2018-12-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-2028?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16712074#comment-16712074 ] ASF GitHub Bot commented on SAMZA-2028: --- GitHub user shenodaguirguis opened a pull request:

[jira] [Created] (SAMZA-2032) Remove the deprecated public methods from StreamProcessor and JobCoordinator

2018-12-06 Thread Shanthoosh Venkataraman (JIRA)
Shanthoosh Venkataraman created SAMZA-2032: -- Summary: Remove the deprecated public methods from StreamProcessor and JobCoordinator Key: SAMZA-2032 URL: https://issues.apache.org/jira/browse/SAMZA-2032

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

2018-12-06 Thread Shenoda Guirguis (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-2002?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shenoda Guirguis resolved SAMZA-2002. - Resolution: Done > SamzaSQL Diagnostics: Instrument Rest of Operators (except Join &

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

2018-12-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-2002?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16711872#comment-16711872 ] ASF GitHub Bot commented on SAMZA-2002: --- Github user asfgit closed the pull request at:

[1/2] samza git commit: SAMZA-2002: SamzaSQL Diagnostics: instrument rest of operators (except join & aggregate) and at Query level

2018-12-06 Thread srinivasulu
Repository: samza Updated Branches: refs/heads/master b126683ae -> bd9387b7f http://git-wip-us.apache.org/repos/asf/samza/blob/bd9387b7/samza-sql/src/test/java/org/apache/samza/sql/translator/TestSamzaSqlLocalTableJoinFunction.java

[2/2] samza git commit: SAMZA-2002: SamzaSQL Diagnostics: instrument rest of operators (except join & aggregate) and at Query level

2018-12-06 Thread srinivasulu
SAMZA-2002: SamzaSQL Diagnostics: instrument rest of operators (except join & aggregate) and at Query level Second phase of instrumenting SamzaSQL operators to add and maintain metrics. All operators, except join and aggregate, are instrumented to add Processing Time and Input Rate metrics.

[jira] [Updated] (SAMZA-2031) [Samza-SQL Diagnostics] Need to include the sendTo in time metrics

2018-12-06 Thread Shenoda Guirguis (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-2031?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shenoda Guirguis updated SAMZA-2031: Description: As part of SamzaSQL Diagnostics

[jira] [Created] (SAMZA-2031) [Samza-SQL Diagnostics] Need to include the sendTo in time metrics

2018-12-06 Thread Shenoda Guirguis (JIRA)
Shenoda Guirguis created SAMZA-2031: --- Summary: [Samza-SQL Diagnostics] Need to include the sendTo in time metrics Key: SAMZA-2031 URL: https://issues.apache.org/jira/browse/SAMZA-2031 Project:

[samza] Git Push Summary

2018-12-06 Thread jagadish
Repository: samza Updated Tags: refs/tags/release-1.0.0 [created] 63232e0e2

[jira] [Commented] (SAMZA-2030) Fix ScalaMapConfig:getOption to support mocking

2018-12-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-2030?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16711789#comment-16711789 ] ASF GitHub Bot commented on SAMZA-2030: --- Github user asfgit closed the pull request at:

samza git commit: SAMZA-2030: Config mock

2018-12-06 Thread boryas
Repository: samza Updated Branches: refs/heads/master e2adf8f99 -> b126683ae SAMZA-2030: Config mock Fix getOption of ScalaMapConfig to support mocking. Author: Boris S Author: Boris S Author: Boris Shkolnik Reviewers: Shanthoosh Venkataraman Closes #847 from sborya/ConfigMock

[jira] [Commented] (SAMZA-2030) Fix ScalaMapConfig:getOption to support mocking

2018-12-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-2030?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16711765#comment-16711765 ] ASF GitHub Bot commented on SAMZA-2030: --- GitHub user sborya opened a pull request:

[jira] [Created] (SAMZA-2030) Fix ScalaMapConfig:getOption to support mocking

2018-12-06 Thread Boris Shkolnik (JIRA)
Boris Shkolnik created SAMZA-2030: - Summary: Fix ScalaMapConfig:getOption to support mocking Key: SAMZA-2030 URL: https://issues.apache.org/jira/browse/SAMZA-2030 Project: Samza Issue Type: