[jira] [Assigned] (SAMZA-2217) Refactoring of Couchbase table functions

2019-05-24 Thread Wei Song (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-2217?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wei Song reassigned SAMZA-2217: --- Assignee: Wei Song > Refactoring of Couchbase table functions >

[jira] [Assigned] (SAMZA-2218) Add a Couchbase example to samza-hello-samza

2019-05-24 Thread Wei Song (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-2218?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wei Song reassigned SAMZA-2218: --- Assignee: Wei Song > Add a Couchbase example to samza-hello-samza >

[jira] [Created] (SAMZA-2220) Startpoints - sync TaskInstance offset caught up logic with Startpoints

2019-05-24 Thread Daniel Nishimura (JIRA)
Daniel Nishimura created SAMZA-2220: --- Summary: Startpoints - sync TaskInstance offset caught up logic with Startpoints Key: SAMZA-2220 URL: https://issues.apache.org/jira/browse/SAMZA-2220 Project:

[jira] [Created] (SAMZA-2219) Add a dummy table read function

2019-05-24 Thread Wei Song (JIRA)
Wei Song created SAMZA-2219: --- Summary: Add a dummy table read function Key: SAMZA-2219 URL: https://issues.apache.org/jira/browse/SAMZA-2219 Project: Samza Issue Type: Improvement Repor

[jira] [Created] (SAMZA-2221) Rocks DB ChangeLog TTL should follow the TTL of rocksDB

2019-05-24 Thread Dengpan Yin (JIRA)
Dengpan Yin created SAMZA-2221: -- Summary: Rocks DB ChangeLog TTL should follow the TTL of rocksDB Key: SAMZA-2221 URL: https://issues.apache.org/jira/browse/SAMZA-2221 Project: Samza Issue Type:

[GitHub] [samza] lhaiesp commented on a change in pull request #1049: SAMZA-2217: Refactoring of Couchbase table functions

2019-05-24 Thread GitBox
lhaiesp commented on a change in pull request #1049: SAMZA-2217: Refactoring of Couchbase table functions URL: https://github.com/apache/samza/pull/1049#discussion_r287449907 ## File path: samza-kv-couchbase/src/main/java/org/apache/samza/table/remote/couchbase/CouchbaseTableWriteF

[samza] branch master updated: SAMZA-2217: Refactoring of Couchbase table functions (#1049)

2019-05-24 Thread weisong44
This is an automated email from the ASF dual-hosted git repository. weisong44 pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/samza.git The following commit(s) were added to refs/heads/master by this push: new e65bcf9 SAMZA-2217: Refactoring of Couchbase

[GitHub] [samza] weisong44 merged pull request #1049: SAMZA-2217: Refactoring of Couchbase table functions

2019-05-24 Thread GitBox
weisong44 merged pull request #1049: SAMZA-2217: Refactoring of Couchbase table functions URL: https://github.com/apache/samza/pull/1049 This is an automated message from the Apache Git Service. To respond to the message, pl

[jira] [Updated] (SAMZA-2220) Startpoints - Fully encapsulate resolution of starting offsets in OffsetManager

2019-05-24 Thread Daniel Nishimura (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-2220?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Nishimura updated SAMZA-2220: Description: Currently when a startpoint is set, the consumers are registered with the off

[jira] [Resolved] (SAMZA-2217) Refactoring of Couchbase table functions

2019-05-24 Thread Wei Song (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-2217?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wei Song resolved SAMZA-2217. - Resolution: Fixed > Refactoring of Couchbase table functions > >

[GitHub] [samza] cameronlee314 commented on a change in pull request #1044: SAMZA-2204: Consolidate some reflection-related utility methods into a common class

2019-05-24 Thread GitBox
cameronlee314 commented on a change in pull request #1044: SAMZA-2204: Consolidate some reflection-related utility methods into a common class URL: https://github.com/apache/samza/pull/1044#discussion_r287452397 ## File path: samza-sql/src/main/java/org/apache/samza/sql/data/SamzaS

[GitHub] [samza] dengpanyin opened a new pull request #1050: SAMZA-2221: Use the KafkaStreamSpec instead of the StreamSpec

2019-05-24 Thread GitBox
dengpanyin opened a new pull request #1050: SAMZA-2221: Use the KafkaStreamSpec instead of the StreamSpec URL: https://github.com/apache/samza/pull/1050 When creating a new Kafka topic, currenlty StreamSpec is used other than the KafkaStreamSpec. KafkaStreamSpec contains more properties

[jira] [Updated] (SAMZA-2220) Startpoints - Fully encapsulate resolution of starting offsets in OffsetManager

2019-05-24 Thread Daniel Nishimura (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-2220?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Nishimura updated SAMZA-2220: Summary: Startpoints - Fully encapsulate resolution of starting offsets in OffsetManager (

[GitHub] [samza] weisong44 opened a new pull request #1051: SAMZA-2219: Add a dummy table read function

2019-05-24 Thread GitBox
weisong44 opened a new pull request #1051: SAMZA-2219: Add a dummy table read function URL: https://github.com/apache/samza/pull/1051 This is a convenience class for cases only writes are required. Removed compilation warnings from various files.

[jira] [Created] (SAMZA-2222) Documentation for async API

2019-05-24 Thread Bharath Kumarasubramanian (JIRA)
Bharath Kumarasubramanian created SAMZA-: Summary: Documentation for async API Key: SAMZA- URL: https://issues.apache.org/jira/browse/SAMZA- Project: Samza Issue Type:

[GitHub] [samza] mynameborat opened a new pull request #1052: SAMZA-2222: Documentation for async API

2019-05-24 Thread GitBox
mynameborat opened a new pull request #1052: SAMZA-: Documentation for async API URL: https://github.com/apache/samza/pull/1052 This is an automated message from the Apache Git Service. To respond to the message, please

[jira] [Updated] (SAMZA-2222) Documentation for async API

2019-05-24 Thread Bharath Kumarasubramanian (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bharath Kumarasubramanian updated SAMZA-: - Fix Version/s: 1.2 > Documentation for async API > --

[GitHub] [samza] dnishimura commented on issue #1048: SAMZA-2215 : StartpointManager fix for previous CoordinatorStreamStore refactor

2019-05-24 Thread GitBox
dnishimura commented on issue #1048: SAMZA-2215 : StartpointManager fix for previous CoordinatorStreamStore refactor URL: https://github.com/apache/samza/pull/1048#issuecomment-495768795 @shanthoosh please take a look This is

[GitHub] [samza] prateekm commented on a change in pull request #1052: SAMZA-2222: Documentation for async API

2019-05-24 Thread GitBox
prateekm commented on a change in pull request #1052: SAMZA-: Documentation for async API URL: https://github.com/apache/samza/pull/1052#discussion_r287502504 ## File path: docs/learn/tutorials/versioned/samza-async-user-guide.md ## @@ -107,16 +107,96 @@ task.callback.

[GitHub] [samza] prateekm commented on a change in pull request #1052: SAMZA-2222: Documentation for async API

2019-05-24 Thread GitBox
prateekm commented on a change in pull request #1052: SAMZA-: Documentation for async API URL: https://github.com/apache/samza/pull/1052#discussion_r287504509 ## File path: docs/learn/tutorials/versioned/samza-async-user-guide.md ## @@ -107,16 +107,96 @@ task.callback.

[GitHub] [samza] prateekm commented on a change in pull request #1052: SAMZA-2222: Documentation for async API

2019-05-24 Thread GitBox
prateekm commented on a change in pull request #1052: SAMZA-: Documentation for async API URL: https://github.com/apache/samza/pull/1052#discussion_r287503895 ## File path: docs/learn/tutorials/versioned/samza-async-user-guide.md ## @@ -107,16 +107,96 @@ task.callback.

[GitHub] [samza] prateekm commented on a change in pull request #1052: SAMZA-2222: Documentation for async API

2019-05-24 Thread GitBox
prateekm commented on a change in pull request #1052: SAMZA-: Documentation for async API URL: https://github.com/apache/samza/pull/1052#discussion_r287505073 ## File path: docs/learn/tutorials/versioned/samza-async-user-guide.md ## @@ -107,16 +107,96 @@ task.callback.

[GitHub] [samza] prateekm commented on a change in pull request #1052: SAMZA-2222: Documentation for async API

2019-05-24 Thread GitBox
prateekm commented on a change in pull request #1052: SAMZA-: Documentation for async API URL: https://github.com/apache/samza/pull/1052#discussion_r287504097 ## File path: docs/learn/tutorials/versioned/samza-async-user-guide.md ## @@ -107,16 +107,96 @@ task.callback.

[GitHub] [samza] prateekm commented on a change in pull request #1052: SAMZA-2222: Documentation for async API

2019-05-24 Thread GitBox
prateekm commented on a change in pull request #1052: SAMZA-: Documentation for async API URL: https://github.com/apache/samza/pull/1052#discussion_r287504620 ## File path: docs/learn/tutorials/versioned/samza-async-user-guide.md ## @@ -107,16 +107,96 @@ task.callback.

[GitHub] [samza] PawasChhokra commented on a change in pull request #1008: SAMZA-2174: Throw a record too large exception for oversized records in changelog

2019-05-24 Thread GitBox
PawasChhokra commented on a change in pull request #1008: SAMZA-2174: Throw a record too large exception for oversized records in changelog URL: https://github.com/apache/samza/pull/1008#discussion_r287537412 ## File path: samza-kv/src/test/scala/org/apache/samza/storage/kv/TestLar

[GitHub] [samza] PawasChhokra commented on a change in pull request #1008: SAMZA-2174: Throw a record too large exception for oversized records in changelog

2019-05-24 Thread GitBox
PawasChhokra commented on a change in pull request #1008: SAMZA-2174: Throw a record too large exception for oversized records in changelog URL: https://github.com/apache/samza/pull/1008#discussion_r287537405 ## File path: samza-test/src/test/scala/org/apache/samza/storage/kv/TestL

[GitHub] [samza] PawasChhokra commented on a change in pull request #1008: SAMZA-2174: Throw a record too large exception for oversized records in changelog

2019-05-24 Thread GitBox
PawasChhokra commented on a change in pull request #1008: SAMZA-2174: Throw a record too large exception for oversized records in changelog URL: https://github.com/apache/samza/pull/1008#discussion_r287537434 ## File path: samza-kv/src/main/scala/org/apache/samza/storage/kv/LargeMe