[jira] [Resolved] (SAMZA-504) Checkpoint tool doesn't work with task names with spaces

[ https://issues.apache.org/jira/browse/SAMZA-504?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bharath Kumarasubramanian resolved SAMZA-504. - Resolution: Not A Problem It looks this problem doesn't exist anymore.

[jira] [Created] (SAMZA-1385) Coordination utils in LocalApplicationRunner uses same Zk path as ZkJobCoordinatorFactory for leader election

Bharath Kumarasubramanian created SAMZA-1385: Summary: Coordination utils in LocalApplicationRunner uses same Zk path as ZkJobCoordinatorFactory for leader election Key: SAMZA-1385 URL:

[jira] [Updated] (SAMZA-1282) Spinning up more containers than the number of tasks kills leader

[ https://issues.apache.org/jira/browse/SAMZA-1282?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bharath Kumarasubramanian updated SAMZA-1282: - Summary: Spinning up more containers than the number of tasks kills leader

[jira] [Created] (SAMZA-1282) Spinning up more containers than the number task kills leader

Bharath Kumarasubramanian created SAMZA-1282: Summary: Spinning up more containers than the number task kills leader Key: SAMZA-1282 URL: https://issues.apache.org/jira/browse/SAMZA-1282

[jira] [Assigned] (SAMZA-1282) Spinning up more containers than the number of tasks kills leader

[ https://issues.apache.org/jira/browse/SAMZA-1282?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bharath Kumarasubramanian reassigned SAMZA-1282: Assignee: Navina Ramesh > Spinning up more containers than the

[jira] [Updated] (SAMZA-1315) Rename startup script and fix configurations for wikipedia-zk application

[ https://issues.apache.org/jira/browse/SAMZA-1315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bharath Kumarasubramanian updated SAMZA-1315: - Summary: Rename startup script and fix configurations for wikipedia-zk

[jira] [Created] (SAMZA-1314) Update documentation for batch processing

Bharath Kumarasubramanian created SAMZA-1314: Summary: Update documentation for batch processing Key: SAMZA-1314 URL: https://issues.apache.org/jira/browse/SAMZA-1314 Project: Samza

[jira] [Created] (SAMZA-1315) Rename startup script and fix configurations for wikipedia zk application

Bharath Kumarasubramanian created SAMZA-1315: Summary: Rename startup script and fix configurations for wikipedia zk application Key: SAMZA-1315 URL: https://issues.apache.org/jira/browse/SAMZA-1315

[jira] [Closed] (SAMZA-1315) Rename startup script and fix configurations for wikipedia-zk application

[ https://issues.apache.org/jira/browse/SAMZA-1315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bharath Kumarasubramanian closed SAMZA-1315. > Rename startup script and fix configurations for wikipedia-zk application >

[jira] [Created] (SAMZA-1404) Add warning in case of potential process starvation due to longer window method

Bharath Kumarasubramanian created SAMZA-1404: Summary: Add warning in case of potential process starvation due to longer window method Key: SAMZA-1404 URL:

[jira] [Updated] (SAMZA-1526) Add tooling and documentation for Samza SQL

[ https://issues.apache.org/jira/browse/SAMZA-1526?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bharath Kumarasubramanian updated SAMZA-1526: - Affects Version/s: 0.14.0 > Add tooling and documentation for Samza SQL >

[jira] [Resolved] (SAMZA-1525) Provide EventHub documentation

[ https://issues.apache.org/jira/browse/SAMZA-1525?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bharath Kumarasubramanian resolved SAMZA-1525. -- Resolution: Fixed > Provide EventHub documentation >

[jira] [Closed] (SAMZA-1471) No polling for end-of-stream partitions in SystemConsumers

[ https://issues.apache.org/jira/browse/SAMZA-1471?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bharath Kumarasubramanian closed SAMZA-1471. > No polling for end-of-stream partitions in SystemConsumers >

[jira] [Resolved] (SAMZA-1471) No polling for end-of-stream partitions in SystemConsumers

[ https://issues.apache.org/jira/browse/SAMZA-1471?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bharath Kumarasubramanian resolved SAMZA-1471. -- Resolution: Fixed > No polling for end-of-stream partitions in

[jira] [Resolved] (SAMZA-1516) Another round of issues found by BEAM tests

[ https://issues.apache.org/jira/browse/SAMZA-1516?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bharath Kumarasubramanian resolved SAMZA-1516. -- Resolution: Fixed > Another round of issues found by BEAM tests >

[jira] [Resolved] (SAMZA-1436) Upgrade RocksDB to a version w/ Apache license

[ https://issues.apache.org/jira/browse/SAMZA-1436?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bharath Kumarasubramanian resolved SAMZA-1436. -- Resolution: Fixed > Upgrade RocksDB to a version w/ Apache license >

[jira] [Created] (SAMZA-1474) Upgrade RocksDB to include apache licensing changes

Bharath Kumarasubramanian created SAMZA-1474: Summary: Upgrade RocksDB to include apache licensing changes Key: SAMZA-1474 URL: https://issues.apache.org/jira/browse/SAMZA-1474 Project:

[jira] [Assigned] (SAMZA-1474) Upgrade RocksDB to include apache licensing changes

[ https://issues.apache.org/jira/browse/SAMZA-1474?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bharath Kumarasubramanian reassigned SAMZA-1474: Assignee: Bharath Kumarasubramanian > Upgrade RocksDB to include

[jira] [Updated] (SAMZA-1474) Upgrade RocksDB to include apache licensing changes

[ https://issues.apache.org/jira/browse/SAMZA-1474?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bharath Kumarasubramanian updated SAMZA-1474: - Fix Version/s: 0.14.0 > Upgrade RocksDB to include apache licensing

[jira] [Created] (SAMZA-1701) SamzaContainer should not contain any logic related to store directories

Bharath Kumarasubramanian created SAMZA-1701: Summary: SamzaContainer should not contain any logic related to store directories Key: SAMZA-1701 URL: https://issues.apache.org/jira/browse/SAMZA-1701

[jira] [Created] (SAMZA-1553) Build issues with Kafka version bump 2.10:0.10.2.70

Bharath Kumarasubramanian created SAMZA-1553: Summary: Build issues with Kafka version bump 2.10:0.10.2.70 Key: SAMZA-1553 URL: https://issues.apache.org/jira/browse/SAMZA-1553 Project:

[jira] [Commented] (SAMZA-1796) PassthroughJobCoordinator doesn't create changelog streams

[ https://issues.apache.org/jira/browse/SAMZA-1796?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16566400#comment-16566400 ] Bharath Kumarasubramanian commented on SAMZA-1796: -- [~jmakes] One of the use cases I can

[jira] [Created] (SAMZA-1803) Make InMemoryManager system aware

Bharath Kumarasubramanian created SAMZA-1803: Summary: Make InMemoryManager system aware Key: SAMZA-1803 URL: https://issues.apache.org/jira/browse/SAMZA-1803 Project: Samza

[jira] [Created] (SAMZA-1809) Logging bug: ExecutionPlanner should log details about how it arrived at the partition count for an intermediate topic

Bharath Kumarasubramanian created SAMZA-1809: Summary: Logging bug: ExecutionPlanner should log details about how it arrived at the partition count for an intermediate topic Key: SAMZA-1809 URL:

[jira] [Created] (SAMZA-1816) Extract stream related configurations from store configurations

Bharath Kumarasubramanian created SAMZA-1816: Summary: Extract stream related configurations from store configurations Key: SAMZA-1816 URL: https://issues.apache.org/jira/browse/SAMZA-1816

[jira] [Created] (SAMZA-1815) Use TableDescriptors to generate configurations during planning phase

Bharath Kumarasubramanian created SAMZA-1815: Summary: Use TableDescriptors to generate configurations during planning phase Key: SAMZA-1815 URL: https://issues.apache.org/jira/browse/SAMZA-1815

[jira] [Created] (SAMZA-1773) Side inputs for local stores

Bharath Kumarasubramanian created SAMZA-1773: Summary: Side inputs for local stores Key: SAMZA-1773 URL: https://issues.apache.org/jira/browse/SAMZA-1773 Project: Samza Issue

[jira] [Assigned] (SAMZA-1832) Race condition between SamzaContainerListener.onContainerFailure(t) and StreamProcessor.stop()

[ https://issues.apache.org/jira/browse/SAMZA-1832?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bharath Kumarasubramanian reassigned SAMZA-1832: Assignee: Bharath Kumarasubramanian > Race condition between

[jira] [Created] (SAMZA-1609) Refactor SamzaContainer to take in SystemFactories

Bharath Kumarasubramanian created SAMZA-1609: Summary: Refactor SamzaContainer to take in SystemFactories Key: SAMZA-1609 URL: https://issues.apache.org/jira/browse/SAMZA-1609 Project:

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

[ 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 >

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

[ 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 >

[jira] [Updated] (SAMZA-1949) Javadocs and configuration documentation for side inputs

[ https://issues.apache.org/jira/browse/SAMZA-1949?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bharath Kumarasubramanian updated SAMZA-1949: - Summary: Javadocs and configuration documentation for side inputs (was:

[jira] [Created] (SAMZA-1971) Fix NPE in InMemorySystemProducer when message is null

Bharath Kumarasubramanian created SAMZA-1971: Summary: Fix NPE in InMemorySystemProducer when message is null Key: SAMZA-1971 URL: https://issues.apache.org/jira/browse/SAMZA-1971 Project:

[jira] [Created] (SAMZA-1924) Documentation for case-studies and release-notes

Bharath Kumarasubramanian created SAMZA-1924: Summary: Documentation for case-studies and release-notes Key: SAMZA-1924 URL: https://issues.apache.org/jira/browse/SAMZA-1924 Project: Samza

[jira] [Closed] (SAMZA-1924) Documentation for case-studies and release-notes

[ https://issues.apache.org/jira/browse/SAMZA-1924?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bharath Kumarasubramanian closed SAMZA-1924. > Documentation for case-studies and release-notes >

[jira] [Resolved] (SAMZA-1924) Documentation for case-studies and release-notes

[ https://issues.apache.org/jira/browse/SAMZA-1924?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bharath Kumarasubramanian resolved SAMZA-1924. -- Resolution: Fixed [~nickpan47] closing it now. > Documentation for

[jira] [Commented] (SAMZA-2033) Inconsistency in the inmemory offsets managed by the TaskSideInputStorageManager.

[ https://issues.apache.org/jira/browse/SAMZA-2033?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16737410#comment-16737410 ] Bharath Kumarasubramanian commented on SAMZA-2033: -- [~spvenkat] The scenario outlined in

[jira] [Updated] (SAMZA-2055) Design and Implement async API for high level

[ https://issues.apache.org/jira/browse/SAMZA-2055?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bharath Kumarasubramanian updated SAMZA-2055: - Description: Introduce asynchronous API for high level. (was: In Samza, 

[jira] [Assigned] (SAMZA-2055) Design and Implement async API for high level

[ https://issues.apache.org/jira/browse/SAMZA-2055?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bharath Kumarasubramanian reassigned SAMZA-2055: Assignee: Bharath Kumarasubramanian (was: Peng Du) > Design and

[jira] [Created] (SAMZA-2055) Design and Implement async API for high level

Bharath Kumarasubramanian created SAMZA-2055: Summary: Design and Implement async API for high level Key: SAMZA-2055 URL: https://issues.apache.org/jira/browse/SAMZA-2055 Project: Samza

[jira] [Resolved] (SAMZA-2033) Inconsistency in the inmemory offsets managed by the TaskSideInputStorageManager.

[ https://issues.apache.org/jira/browse/SAMZA-2033?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bharath Kumarasubramanian resolved SAMZA-2033. -- Resolution: Not A Problem > Inconsistency in the inmemory offsets

[jira] [Closed] (SAMZA-2033) Inconsistency in the inmemory offsets managed by the TaskSideInputStorageManager.

[ https://issues.apache.org/jira/browse/SAMZA-2033?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bharath Kumarasubramanian closed SAMZA-2033. > Inconsistency in the inmemory offsets managed by the >

[jira] [Created] (SAMZA-1876) Add activeNs metric to capture time spent on runTasks in AsyncRunLoop

Bharath Kumarasubramanian created SAMZA-1876: Summary: Add activeNs metric to capture time spent on runTasks in AsyncRunLoop Key: SAMZA-1876 URL: https://issues.apache.org/jira/browse/SAMZA-1876

[jira] [Created] (SAMZA-2087) Use separate thread pools for AsyncStreamTaskAdapter and AsyncRunLoop

Bharath Kumarasubramanian created SAMZA-2087: Summary: Use separate thread pools for AsyncStreamTaskAdapter and AsyncRunLoop Key: SAMZA-2087 URL: https://issues.apache.org/jira/browse/SAMZA-2087

[jira] [Created] (SAMZA-2146) Expose physical name in StreamDescriptor

Bharath Kumarasubramanian created SAMZA-2146: Summary: Expose physical name in StreamDescriptor Key: SAMZA-2146 URL: https://issues.apache.org/jira/browse/SAMZA-2146 Project: Samza

[jira] [Created] (SAMZA-2145) Refactor StreamTaskTestUtil to use IntegrationTestHarness

Bharath Kumarasubramanian created SAMZA-2145: Summary: Refactor StreamTaskTestUtil to use IntegrationTestHarness Key: SAMZA-2145 URL: https://issues.apache.org/jira/browse/SAMZA-2145

[jira] [Created] (SAMZA-2127) Upgrade to Kafka 2.0

Bharath Kumarasubramanian created SAMZA-2127: Summary: Upgrade to Kafka 2.0 Key: SAMZA-2127 URL: https://issues.apache.org/jira/browse/SAMZA-2127 Project: Samza Issue Type: Task

[jira] [Commented] (SAMZA-2087) Use separate thread pools for AsyncStreamTaskAdapter and AsyncRunLoop

[ https://issues.apache.org/jira/browse/SAMZA-2087?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16752748#comment-16752748 ] Bharath Kumarasubramanian commented on SAMZA-2087: -- I am separating out the executor

[jira] [Created] (SAMZA-2092) Make window operator thread safe

Bharath Kumarasubramanian created SAMZA-2092: Summary: Make window operator thread safe Key: SAMZA-2092 URL: https://issues.apache.org/jira/browse/SAMZA-2092 Project: Samza Issue

[jira] [Updated] (SAMZA-2092) Make window operator thread safe

[ https://issues.apache.org/jira/browse/SAMZA-2092?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bharath Kumarasubramanian updated SAMZA-2092: - Description: Currently, window operator maintains some state which when

[jira] [Updated] (SAMZA-2092) Make window operator thread safe

[ https://issues.apache.org/jira/browse/SAMZA-2092?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bharath Kumarasubramanian updated SAMZA-2092: - Description: Currently, window operator maintains some state which when

[jira] [Created] (SAMZA-2162) Update Table APIs to be consistent with High level Async API

Bharath Kumarasubramanian created SAMZA-2162: Summary: Update Table APIs to be consistent with High level Async API Key: SAMZA-2162 URL: https://issues.apache.org/jira/browse/SAMZA-2162

[jira] [Commented] (SAMZA-2227) Fix to ensure that new topics detected by regex-monitor are picked up during next deployment of app

[ https://issues.apache.org/jira/browse/SAMZA-2227?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16851322#comment-16851322 ] Bharath Kumarasubramanian commented on SAMZA-2227: -- Can we add some description about

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

Bharath Kumarasubramanian created SAMZA-: Summary: Documentation for async API Key: SAMZA- URL: https://issues.apache.org/jira/browse/SAMZA- Project: Samza Issue

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

[ 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 >

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

[ https://issues.apache.org/jira/browse/SAMZA-?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bharath Kumarasubramanian closed SAMZA-. > Documentation for async API > --- > >

[jira] [Created] (SAMZA-2211) [Cleanup] Move RunLoop to container package

Bharath Kumarasubramanian created SAMZA-2211: Summary: [Cleanup] Move RunLoop to container package Key: SAMZA-2211 URL: https://issues.apache.org/jira/browse/SAMZA-2211 Project: Samza

[jira] [Resolved] (SAMZA-2172) Async High Level API does not schedule StreamOperatorTasks on separate threads

[ https://issues.apache.org/jira/browse/SAMZA-2172?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bharath Kumarasubramanian resolved SAMZA-2172. -- Resolution: Fixed > Async High Level API does not schedule

[jira] [Closed] (SAMZA-2172) Async High Level API does not schedule StreamOperatorTasks on separate threads

[ https://issues.apache.org/jira/browse/SAMZA-2172?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bharath Kumarasubramanian closed SAMZA-2172. > Async High Level API does not schedule StreamOperatorTasks on separate

[jira] [Created] (SAMZA-2203) [Cleanup] Clean up container thread pool injection to StreamOperatorTask

Bharath Kumarasubramanian created SAMZA-2203: Summary: [Cleanup] Clean up container thread pool injection to StreamOperatorTask Key: SAMZA-2203 URL: https://issues.apache.org/jira/browse/SAMZA-2203

[jira] [Resolved] (SAMZA-2055) Design and Implement async API for high level

[ https://issues.apache.org/jira/browse/SAMZA-2055?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bharath Kumarasubramanian resolved SAMZA-2055. -- Resolution: Fixed Implemented in 

[jira] [Resolved] (SAMZA-2092) Make window operator thread safe

[ https://issues.apache.org/jira/browse/SAMZA-2092?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bharath Kumarasubramanian resolved SAMZA-2092. -- Resolution: Fixed Fixed in SAMZA-2055 > Make window operator thread

[jira] [Updated] (SAMZA-1517) Remove old RunLoop

[ https://issues.apache.org/jira/browse/SAMZA-1517?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bharath Kumarasubramanian updated SAMZA-1517: - Fix Version/s: (was: 0.15.0) 1.1 > Remove old

[jira] [Resolved] (SAMZA-2175) Clean up old run loop

[ https://issues.apache.org/jira/browse/SAMZA-2175?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bharath Kumarasubramanian resolved SAMZA-2175. -- Resolution: Fixed > Clean up old run loop > - > >

[jira] [Resolved] (SAMZA-2127) Upgrade to Kafka 2.0

[ https://issues.apache.org/jira/browse/SAMZA-2127?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bharath Kumarasubramanian resolved SAMZA-2127. -- Resolution: Fixed Fixed in [https://github.com/apache/samza/pull/951]

[jira] [Resolved] (SAMZA-1517) Remove old RunLoop

[ https://issues.apache.org/jira/browse/SAMZA-1517?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bharath Kumarasubramanian resolved SAMZA-1517. -- Resolution: Fixed > Remove old RunLoop > -- > >

[jira] [Commented] (SAMZA-2037) WatermarkIntegrationTest should not use internal fields for verification

[ https://issues.apache.org/jira/browse/SAMZA-2037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16821405#comment-16821405 ] Bharath Kumarasubramanian commented on SAMZA-2037: -- With this PR - 

[jira] [Updated] (SAMZA-2037) WatermarkIntegrationTest should not use internal fields for verification

[ https://issues.apache.org/jira/browse/SAMZA-2037?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bharath Kumarasubramanian updated SAMZA-2037: - Summary: WatermarkIntegrationTest should not use internal fields for

[jira] [Updated] (SAMZA-2037) WatermarkIntegrationTest should not use internal fields for verification

[ https://issues.apache.org/jira/browse/SAMZA-2037?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bharath Kumarasubramanian updated SAMZA-2037: - Description: WatermarkIntegrationTest uses internal fields in order to

[jira] [Updated] (SAMZA-2037) WatermarkIntegrationTest should not use internal fields for verification

[ https://issues.apache.org/jira/browse/SAMZA-2037?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bharath Kumarasubramanian updated SAMZA-2037: - Description: WatermarkIntegrationTest uses reflection to extract

[jira] [Commented] (SAMZA-2172) Async High Level API does not schedule StreamOperatorTasks on separate threads

[ https://issues.apache.org/jira/browse/SAMZA-2172?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16827149#comment-16827149 ] Bharath Kumarasubramanian commented on SAMZA-2172: -- Chosen solution: Make AsyncRunLoop

[jira] [Created] (SAMZA-2175) Clean up old run loop

Bharath Kumarasubramanian created SAMZA-2175: Summary: Clean up old run loop Key: SAMZA-2175 URL: https://issues.apache.org/jira/browse/SAMZA-2175 Project: Samza Issue Type:

[jira] [Resolved] (SAMZA-2299) StreamTableJoin Operator should invoke user join function only once

[ https://issues.apache.org/jira/browse/SAMZA-2299?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bharath Kumarasubramanian resolved SAMZA-2299. -- Resolution: Fixed > StreamTableJoin Operator should invoke user join

[jira] [Assigned] (SAMZA-2295) records-lag based topic metrics not working for topics with periods (dot, '.') in them

[ https://issues.apache.org/jira/browse/SAMZA-2295?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bharath Kumarasubramanian reassigned SAMZA-2295: Assignee: Bharath Kumarasubramanian > records-lag based topic

[jira] [Commented] (SAMZA-2295) records-lag based topic metrics not working for topics with periods (dot, '.') in them

[ https://issues.apache.org/jira/browse/SAMZA-2295?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16912602#comment-16912602 ] Bharath Kumarasubramanian commented on SAMZA-2295: -- Merged [GitHub Pull Request

[jira] [Closed] (SAMZA-2295) records-lag based topic metrics not working for topics with periods (dot, '.') in them

[ https://issues.apache.org/jira/browse/SAMZA-2295?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bharath Kumarasubramanian closed SAMZA-2295. > records-lag based topic metrics not working for topics with periods (dot, >

[jira] [Resolved] (SAMZA-2295) records-lag based topic metrics not working for topics with periods (dot, '.') in them

[ https://issues.apache.org/jira/browse/SAMZA-2295?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bharath Kumarasubramanian resolved SAMZA-2295. -- Resolution: Fixed > records-lag based topic metrics not working for

[jira] [Created] (SAMZA-2305) Stream processor should ensure previous container is stopped during a rebalance

Bharath Kumarasubramanian created SAMZA-2305: Summary: Stream processor should ensure previous container is stopped during a rebalance Key: SAMZA-2305 URL:

[jira] [Created] (SAMZA-2285) Sample async application for hello-samza

Bharath Kumarasubramanian created SAMZA-2285: Summary: Sample async application for hello-samza Key: SAMZA-2285 URL: https://issues.apache.org/jira/browse/SAMZA-2285 Project: Samza

[jira] [Closed] (SAMZA-2276) Metadata store putAll

[ https://issues.apache.org/jira/browse/SAMZA-2276?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bharath Kumarasubramanian closed SAMZA-2276. > Metadata store putAll > - > > Key:

[jira] [Updated] (SAMZA-2293) Propagate the watermark future to StreamOperatorTask correctly

[ https://issues.apache.org/jira/browse/SAMZA-2293?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bharath Kumarasubramanian updated SAMZA-2293: - Summary: Propagate the watermark future to StreamOperatorTask correctly

[jira] [Updated] (SAMZA-2293) [Bug] Propagate the watermark future to StreamOperatorTask correctly

[ https://issues.apache.org/jira/browse/SAMZA-2293?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bharath Kumarasubramanian updated SAMZA-2293: - Issue Type: Bug (was: Improvement) > [Bug] Propagate the watermark

[jira] [Created] (SAMZA-2293) [Bug] Propagate the watermark future to StreamOperatorTask correctly

Bharath Kumarasubramanian created SAMZA-2293: Summary: [Bug] Propagate the watermark future to StreamOperatorTask correctly Key: SAMZA-2293 URL: https://issues.apache.org/jira/browse/SAMZA-2293

[jira] [Resolved] (SAMZA-2293) Propagate the watermark future to StreamOperatorTask correctly

[ https://issues.apache.org/jira/browse/SAMZA-2293?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bharath Kumarasubramanian resolved SAMZA-2293. -- Resolution: Fixed > Propagate the watermark future to

[jira] [Closed] (SAMZA-2293) Propagate the watermark future to StreamOperatorTask correctly

[ https://issues.apache.org/jira/browse/SAMZA-2293?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bharath Kumarasubramanian closed SAMZA-2293. > Propagate the watermark future to StreamOperatorTask correctly >

[jira] [Created] (SAMZA-2299) StreamTableJoin Operator should invoke user join function only once

Bharath Kumarasubramanian created SAMZA-2299: Summary: StreamTableJoin Operator should invoke user join function only once Key: SAMZA-2299 URL: https://issues.apache.org/jira/browse/SAMZA-2299

[jira] [Commented] (SAMZA-1982) Use TimerRegistry to track time based window triggers instead of relying on window()

[ https://issues.apache.org/jira/browse/SAMZA-1982?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16890454#comment-16890454 ] Bharath Kumarasubramanian commented on SAMZA-1982: -- I am not working on this actively.

[jira] [Resolved] (SAMZA-1658) samza-kafka module use kafka deprecated method to get topic metadata

[ https://issues.apache.org/jira/browse/SAMZA-1658?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bharath Kumarasubramanian resolved SAMZA-1658. -- Resolution: Fixed Fixed as part of recent Kafka 2.0 upgrade SAMZA-2127

[jira] [Closed] (SAMZA-1658) samza-kafka module use kafka deprecated method to get topic metadata

[ https://issues.apache.org/jira/browse/SAMZA-1658?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bharath Kumarasubramanian closed SAMZA-1658. > samza-kafka module use kafka deprecated method to get topic metadata >

[jira] [Assigned] (SAMZA-1570) Programmatic way to set input stream priority and bootstrap mode for high-level API

[ https://issues.apache.org/jira/browse/SAMZA-1570?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bharath Kumarasubramanian reassigned SAMZA-1570: Assignee: Prateek Maheshwari > Programmatic way to set input

[jira] [Resolved] (SAMZA-1303) Request for waitForFinish(time, TimeUnit) api in LocalApplicationRunner

[ https://issues.apache.org/jira/browse/SAMZA-1303?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bharath Kumarasubramanian resolved SAMZA-1303. -- Resolution: Duplicate Fix Version/s: (was: 0.15.0)

[jira] [Closed] (SAMZA-1303) Request for waitForFinish(time, TimeUnit) api in LocalApplicationRunner

[ https://issues.apache.org/jira/browse/SAMZA-1303?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bharath Kumarasubramanian closed SAMZA-1303. > Request for waitForFinish(time, TimeUnit) api in LocalApplicationRunner >

[jira] [Resolved] (SAMZA-1683) Deprecate RunLoop and job.container.single.thread.mode configuration

[ https://issues.apache.org/jira/browse/SAMZA-1683?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bharath Kumarasubramanian resolved SAMZA-1683. -- Resolution: Duplicate Fixed in [SAMZA-2175] > Deprecate RunLoop and

[jira] [Closed] (SAMZA-1683) Deprecate RunLoop and job.container.single.thread.mode configuration

[ https://issues.apache.org/jira/browse/SAMZA-1683?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bharath Kumarasubramanian closed SAMZA-1683. > Deprecate RunLoop and job.container.single.thread.mode configuration >

[jira] [Created] (SAMZA-2271) Metadata Store

Bharath Kumarasubramanian created SAMZA-2271: Summary: Metadata Store Key: SAMZA-2271 URL: https://issues.apache.org/jira/browse/SAMZA-2271 Project: Samza Issue Type: New Feature

[jira] [Assigned] (SAMZA-2274) ensure logged and non logged store to use different path

[ https://issues.apache.org/jira/browse/SAMZA-2274?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bharath Kumarasubramanian reassigned SAMZA-2274: Assignee: Bharath Kumarasubramanian > ensure logged and non

[jira] [Commented] (SAMZA-2274) ensure logged and non logged store to use different path

[ https://issues.apache.org/jira/browse/SAMZA-2274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16887428#comment-16887428 ] Bharath Kumarasubramanian commented on SAMZA-2274: -- To clarify, logged store by

[jira] [Updated] (SAMZA-2274) Cleanup store directories on startup for non-logged store only

[ https://issues.apache.org/jira/browse/SAMZA-2274?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bharath Kumarasubramanian updated SAMZA-2274: - Summary: Cleanup store directories on startup for non-logged store only

[jira] [Created] (SAMZA-2329) Chain watermark future to the result future in onMessageAsync

Bharath Kumarasubramanian created SAMZA-2329: Summary: Chain watermark future to the result future in onMessageAsync Key: SAMZA-2329 URL: https://issues.apache.org/jira/browse/SAMZA-2329

[jira] [Created] (SAMZA-2268) Mark old website and documentation files as deprecated

Bharath Kumarasubramanian created SAMZA-2268: Summary: Mark old website and documentation files as deprecated Key: SAMZA-2268 URL: https://issues.apache.org/jira/browse/SAMZA-2268 Project:

  1   2   3   4   >