[jira] [Commented] (SAMZA-1950) SAMZA 1.0 DOCUMENTATION Fixing styling and cleanup

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

samza git commit: Polish contents of the case-studies page

2018-10-12 Thread jagadish
Repository: samza Updated Branches: refs/heads/master 074d70e2c -> 59cee32c7 Polish contents of the case-studies page - Only display case-studies that have high-impact - Also, fix titles Author: Jagadish Reviewers: Jagadish Closes #718 from vjagadish1989/website-reorg14 Project: http://g

samza git commit: Add Slack to our Powered By page

2018-10-12 Thread jagadish
Repository: samza Updated Branches: refs/heads/master 59cee32c7 -> 17113e163 Add Slack to our Powered By page Author: Jagadish Reviewers: Jagadish Closes #719 from vjagadish1989/website-reorg16 Project: http://git-wip-us.apache.org/repos/asf/samza/repo Commit: http://git-wip-us.apache.or

[CONF] Apache Samza > SEP-14: System and Stream Descriptors

2018-10-12 Thread Prateek Maheshwari (Confluence)
Title: Message Title There's 1 new edit on this page   SEP-14: System and Stream Descriptors Prateek Maheshwari edited this page

[jira] [Commented] (SAMZA-1776) Refactor KafkaSystemConsumer to remove the usage of deprecated SimpleConsumer client

2018-10-12 Thread Zihao Zhang (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-1776?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16648220#comment-16648220 ] Zihao Zhang commented on SAMZA-1776: Hi [~nickpan47], sounds good. thanks for the upd

[jira] [Commented] (SAMZA-1836) StreamApplicationIntegrationTest and TestLocalTableWithSideInput fails due to wrong system configured

2018-10-12 Thread Yi Pan (Data Infrastructure) (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-1836?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16648219#comment-16648219 ] Yi Pan (Data Infrastructure) commented on SAMZA-1836: - This is fixed

[jira] [Resolved] (SAMZA-1836) StreamApplicationIntegrationTest and TestLocalTableWithSideInput fails due to wrong system configured

2018-10-12 Thread Yi Pan (Data Infrastructure) (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-1836?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Pan (Data Infrastructure) resolved SAMZA-1836. - Resolution: Fixed Assignee: Sanil Jain > StreamApplicationI

[jira] [Commented] (SAMZA-1888) minor improvements for the after commit for KafkaSystemAdmin and KafkaSystemConsumer.

2018-10-12 Thread Boris Shkolnik (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-1888?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16648283#comment-16648283 ] Boris Shkolnik commented on SAMZA-1888: --- also fix the following warnings: :samza-k

[jira] [Commented] (SAMZA-1937) Enable users to perform Sql queries (SELECT statement)

2018-10-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-1937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16648322#comment-16648322 ] ASF GitHub Bot commented on SAMZA-1937: --- Github user weiqingy closed the pull reque

[jira] [Commented] (SAMZA-1937) Enable users to perform Sql queries (SELECT statement)

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

samza git commit: Fix broken tests on master.

2018-10-12 Thread pmaheshwari
Repository: samza Updated Branches: refs/heads/master 17113e163 -> 954fb25e7 Fix broken tests on master. Author: Prateek Maheshwari Reviewers: Prateek Maheshwari Closes #722 from prateekm/test-fixes Project: http://git-wip-us.apache.org/repos/asf/samza/repo Commit: http://git-wip-us.apac

[CONF] Apache Samza > SEP-13: unify high- and low-level user applications in YARN and standalone

2018-10-12 Thread Yi Pan (Confluence)
Title: Message Title There's 1 new edit on this page   SEP-13: unify high- and low-level user applications in YARN and standalone Yi Pan edited this page

[CONF] Apache Samza > Samza Enhancement Proposal

2018-10-12 Thread Yi Pan (Confluence)
Title: Message Title There's 1 new edit on this page   Samza Enhancement Proposal Yi Pan edited this page Here's what chang

[CONF] Apache Samza > Samza Enhancement Proposal

2018-10-12 Thread Prateek Maheshwari (Confluence)
Title: Message Title There's 1 new edit on this page   Samza Enhancement Proposal Prateek Maheshwari edited this page Here'

[CONF] Apache Samza > SEP-14: System and Stream Descriptors

2018-10-12 Thread Prateek Maheshwari (Confluence)
Title: Message Title There's 1 new comment and 2 new edits on this page   SEP-14: System and Stream Descriptors 1 new comment Yi Pan StreamGraph

samza git commit: SAMZA-1937: Make DSL converter work when sql is a query

2018-10-12 Thread srinivasulu
Repository: samza Updated Branches: refs/heads/master 954fb25e7 -> e5ea9bef1 SAMZA-1937: Make DSL converter work when sql is a query ## What changes were proposed in this pull request? To support the use case that users use Samza Sql Console or Samza Sql shell to perform SELECT query. ## How

[jira] [Commented] (SAMZA-1937) Enable users to perform Sql queries (SELECT statement)

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

[jira] [Resolved] (SAMZA-1395) Add in-memory system consumer & producer

2018-10-12 Thread Bharath Kumarasubramanian (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-1395?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bharath Kumarasubramanian resolved SAMZA-1395. -- Resolution: Fixed > Add in-memory system consumer & producer >

[CONF] Apache Samza > SEP-8: Add in-memory system consumer & producer

2018-10-12 Thread Bharath Kumarasubramanian (Confluence)
Title: Message Title There's 1 new edit on this page   SEP-8: Add in-memory system consumer & producer Bharath Kumarasubramanian edited this page

[jira] [Closed] (SAMZA-1395) Add in-memory system consumer & producer

2018-10-12 Thread Bharath Kumarasubramanian (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-1395?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bharath Kumarasubramanian closed SAMZA-1395. > Add in-memory system consumer & producer > --

[CONF] Apache Samza > Samza Enhancement Proposal

2018-10-12 Thread Bharath Kumarasubramanian (Confluence)
Title: Message Title There's 1 new edit on this page   Samza Enhancement Proposal Bharath Kumarasubramanian edited this page

[CONF] Apache Samza > Samza Enhancement Proposal

2018-10-12 Thread Xinyu Liu (Confluence)
Title: Message Title There's 1 new edit on this page   Samza Enhancement Proposal Xinyu Liu edited this page Here's what ch

samza git commit: Clean-up the case-studies page for Ebay, add a diagram

2018-10-12 Thread jagadish
Repository: samza Updated Branches: refs/heads/master e5ea9bef1 -> 0b0a0cabf Clean-up the case-studies page for Ebay, add a diagram Author: Jagadish Reviewers: Jagadish Closes #724 from vjagadish1989/website-reorg17 Project: http://git-wip-us.apache.org/repos/asf/samza/repo Commit: http:/

samza git commit: Use different paths for logged and non-logged stores in test runner

2018-10-12 Thread pmaheshwari
Repository: samza Updated Branches: refs/heads/master 0b0a0cabf -> 9a5094d68 Use different paths for logged and non-logged stores in test runner We have scattered logic to determine the store paths between SamzaContainer and StorageManager. Ideally, it would nice to consolidate them into Stor

[12/12] samza git commit: Consolidating package names for System, Stream, Application and Table descriptors.

2018-10-12 Thread pmaheshwari
Consolidating package names for System, Stream, Application and Table descriptors. Everything in this PR is either: 1. A package name change and a corresponding file move. 2. Javadoc changes to use FQN in link tags to fix checkstyle complaints about unused imports, and corresponding fixes to mak

[04/12] samza git commit: Consolidating package names for System, Stream, Application and Table descriptors.

2018-10-12 Thread pmaheshwari
http://git-wip-us.apache.org/repos/asf/samza/blob/74675cea/samza-kafka/src/main/java/org/apache/samza/system/kafka/KafkaInputDescriptor.java -- diff --git a/samza-kafka/src/main/java/org/apache/samza/system/kafka/KafkaInputDescrip

[06/12] samza git commit: Consolidating package names for System, Stream, Application and Table descriptors.

2018-10-12 Thread pmaheshwari
http://git-wip-us.apache.org/repos/asf/samza/blob/74675cea/samza-core/src/main/java/org/apache/samza/table/remote/descriptors/RemoteTableDescriptor.java -- diff --git a/samza-core/src/main/java/org/apache/samza/table/remote/descri

[11/12] samza git commit: Consolidating package names for System, Stream, Application and Table descriptors.

2018-10-12 Thread pmaheshwari
http://git-wip-us.apache.org/repos/asf/samza/blob/74675cea/samza-api/src/main/java/org/apache/samza/operators/descriptors/base/system/SimpleInputDescriptorProvider.java -- diff --git a/samza-api/src/main/java/org/apache/samza/oper

[02/12] samza git commit: Consolidating package names for System, Stream, Application and Table descriptors.

2018-10-12 Thread pmaheshwari
http://git-wip-us.apache.org/repos/asf/samza/blob/74675cea/samza-kv/src/test/java/org/apache/samza/storage/kv/TestBaseLocalStoreBackedTableProvider.java -- diff --git a/samza-kv/src/test/java/org/apache/samza/storage/kv/TestBaseLo

[09/12] samza git commit: Consolidating package names for System, Stream, Application and Table descriptors.

2018-10-12 Thread pmaheshwari
http://git-wip-us.apache.org/repos/asf/samza/blob/74675cea/samza-azure/src/main/java/org/apache/samza/system/eventhub/EventHubsOutputDescriptor.java -- diff --git a/samza-azure/src/main/java/org/apache/samza/system/eventhub/EventH

[07/12] samza git commit: Consolidating package names for System, Stream, Application and Table descriptors.

2018-10-12 Thread pmaheshwari
http://git-wip-us.apache.org/repos/asf/samza/blob/74675cea/samza-core/src/main/java/org/apache/samza/runtime/LocalApplicationRunner.java -- diff --git a/samza-core/src/main/java/org/apache/samza/runtime/LocalApplicationRunner.java

[01/12] samza git commit: Consolidating package names for System, Stream, Application and Table descriptors.

2018-10-12 Thread pmaheshwari
Repository: samza Updated Branches: refs/heads/master 9a5094d68 -> 74675cea5 http://git-wip-us.apache.org/repos/asf/samza/blob/74675cea/samza-test/src/test/java/org/apache/samza/test/operator/RepartitionWindowApp.java -- diff -

[08/12] samza git commit: Consolidating package names for System, Stream, Application and Table descriptors.

2018-10-12 Thread pmaheshwari
http://git-wip-us.apache.org/repos/asf/samza/blob/74675cea/samza-core/src/main/java/org/apache/samza/application/LegacyTaskApplication.java -- diff --git a/samza-core/src/main/java/org/apache/samza/application/LegacyTaskApplicatio

[10/12] samza git commit: Consolidating package names for System, Stream, Application and Table descriptors.

2018-10-12 Thread pmaheshwari
http://git-wip-us.apache.org/repos/asf/samza/blob/74675cea/samza-api/src/test/java/org/apache/samza/operators/descriptors/TestExpandingInputDescriptor.java -- diff --git a/samza-api/src/test/java/org/apache/samza/operators/descrip

[05/12] samza git commit: Consolidating package names for System, Stream, Application and Table descriptors.

2018-10-12 Thread pmaheshwari
http://git-wip-us.apache.org/repos/asf/samza/blob/74675cea/samza-core/src/test/java/org/apache/samza/application/descriptors/TestStreamApplicationDescriptorImpl.java -- diff --git a/samza-core/src/test/java/org/apache/samza/applic

[03/12] samza git commit: Consolidating package names for System, Stream, Application and Table descriptors.

2018-10-12 Thread pmaheshwari
http://git-wip-us.apache.org/repos/asf/samza/blob/74675cea/samza-kv-inmemory/src/test/java/org/apache/samza/storage/kv/inmemory/descriptors/TestInMemoryTableProvider.java -- diff --git a/samza-kv-inmemory/src/test/java/org/apache/

[1/2] samza git commit: Application Descriptor implementation cleanup.

2018-10-12 Thread pmaheshwari
Repository: samza Updated Branches: refs/heads/master 74675cea5 -> ef3599721 http://git-wip-us.apache.org/repos/asf/samza/blob/ef359972/samza-core/src/test/java/org/apache/samza/operators/spec/TestPartitionByOperatorSpec.java -

[2/2] samza git commit: Application Descriptor implementation cleanup.

2018-10-12 Thread pmaheshwari
Application Descriptor implementation cleanup. Major changes: 1. Move withDefaultSystem to the base ApplicationDescriptor interface so that it can be used for TaskApplication as well. 2. Move some of the common state (input/output/system/table descriptors) and corresponding helper methods from