[jira] [Resolved] (SAMZA-1752) Samza-SQL: SQL IO Resolver needs full configs

2018-08-10 Thread Prateek Maheshwari (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-1752?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Prateek Maheshwari resolved SAMZA-1752. --- Resolution: Fixed > Samza-SQL: SQL IO Resolver needs full configs > -

samza git commit: SAMZA-1752: Pass full config to the IO resolver

2018-08-10 Thread pmaheshwari
Repository: samza Updated Branches: refs/heads/master b706ecebe -> a8ddede18 SAMZA-1752: Pass full config to the IO resolver SQL IO Resolver needs full configs so that it can filter out the configs specific to the source that the SQL application is interested in. This change provides the IO

[jira] [Commented] (SAMZA-1806) Configuring task.broadcast.inputs to an empty string raises IllegalArgumentException

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

samza git commit: SAMZA-1806: Allow `task.broadcast.inputs` to be set to empty string

2018-08-10 Thread jagadish
Repository: samza Updated Branches: refs/heads/master 7bb206151 -> b706ecebe SAMZA-1806: Allow `task.broadcast.inputs` to be set to empty string This fix addresses the issue that getBroadcastSystemStreamPartitions in TaskConfigJava throws an IllegalArgumentException exception when `task.broadc

[jira] [Commented] (SAMZA-1808) Clean up tasks for Samza 1.0 documentation

2018-08-10 Thread Peng Du (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-1808?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16576923#comment-16576923 ] Peng Du commented on SAMZA-1808: Kinesis support is available already and below can be cl

[jira] [Created] (SAMZA-1808) Clean up tasks for Samza 1.0 documentation

2018-08-10 Thread Jagadish (JIRA)
Jagadish created SAMZA-1808: --- Summary: Clean up tasks for Samza 1.0 documentation Key: SAMZA-1808 URL: https://issues.apache.org/jira/browse/SAMZA-1808 Project: Samza Issue Type: Bug Re

[jira] [Commented] (SAMZA-1788) Introduce LocationIdProvider abstraction

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

samza git commit: SAMZA-1788: Add LocationIdProvider abstraction.

2018-08-10 Thread jagadish
Repository: samza Updated Branches: refs/heads/master a08040dcb -> 7bb206151 SAMZA-1788: Add LocationIdProvider abstraction. Currently in standalone, by default hostName of the standalone processor is used as LocationId. However, for containerized environments like azure cloud, kubernetes th

[jira] [Updated] (SAMZA-1807) Create specific execute() for each async table API

2018-08-10 Thread Jagadish (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-1807?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jagadish updated SAMZA-1807: Labels: newbie newbie++ table-api (was: table-api) > Create specific execute() for each async table API >

[jira] [Created] (SAMZA-1807) Create specific execute() for each async table API

2018-08-10 Thread Peng Du (JIRA)
Peng Du created SAMZA-1807: -- Summary: Create specific execute() for each async table API Key: SAMZA-1807 URL: https://issues.apache.org/jira/browse/SAMZA-1807 Project: Samza Issue Type: Improvement

[jira] [Resolved] (SAMZA-1763) Implement async versions of the table API

2018-08-10 Thread Peng Du (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-1763?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Peng Du resolved SAMZA-1763. Resolution: Fixed > Implement async versions of the table API > --

[jira] [Commented] (SAMZA-1763) Implement async versions of the table API

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

[1/2] samza git commit: SAMZA-1763: Add async methods to Table API

2018-08-10 Thread jagadish
Repository: samza Updated Branches: refs/heads/master 8aa879aa6 -> a08040dcb http://git-wip-us.apache.org/repos/asf/samza/blob/a08040dc/samza-core/src/test/java/org/apache/samza/table/caching/TestCachingTable.java -- diff --git

[2/2] samza git commit: SAMZA-1763: Add async methods to Table API

2018-08-10 Thread jagadish
SAMZA-1763: Add async methods to Table API Currently, Table API only has blocking/sync methods which limit the throughput of remote tables. This change adds async methods to the API to enable high throughput remote table accesses through usage of async IO. The new methods are added to ReadableTabl