[jira] [Updated] (SAMZA-1697) Flush hung on using default serde with MetricsSnapshotReporter

[ https://issues.apache.org/jira/browse/SAMZA-1697?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rayman updated SAMZA-1697: -- Description: If a serde is not specified for the snapshot stream then the reporter's send to kafka  simply han

[jira] [Updated] (SAMZA-1697) Flush hung on using default serde with MetricsSnapshotReporter

[ https://issues.apache.org/jira/browse/SAMZA-1697?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rayman updated SAMZA-1697: -- Description: If a serde is not specified for the snapshot stream then the reporter's send to kafka  simply han

[jira] [Created] (SAMZA-1697) Flush hung on using default serde with MetricsSnapshotReporter

Rayman created SAMZA-1697: - Summary: Flush hung on using default serde with MetricsSnapshotReporter Key: SAMZA-1697 URL: https://issues.apache.org/jira/browse/SAMZA-1697 Project: Samza Issue Type: B

[jira] [Updated] (SAMZA-1648) Integration Test Framework: Collection Stream Impl

[ https://issues.apache.org/jira/browse/SAMZA-1648?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sanil Jain updated SAMZA-1648: -- Summary: Integration Test Framework: Collection Stream Impl (was: Collection Stream ) > Integration Te

[jira] [Commented] (SAMZA-1696) Flaky test: TestKeyValueStores testParallelReadWriteSameKey

[ https://issues.apache.org/jira/browse/SAMZA-1696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16461388#comment-16461388 ] ASF GitHub Bot commented on SAMZA-1696: --- GitHub user ahmedahamid opened a pull reque

[jira] [Updated] (SAMZA-1498) Support arbitrary system clock timer in operators

[ https://issues.apache.org/jira/browse/SAMZA-1498?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xinyu Liu updated SAMZA-1498: - Fix Version/s: (was: 0.15.0) 0.14.1 > Support arbitrary system clock timer in opera

[jira] [Updated] (SAMZA-1539) KafkaProducer potential hang on close() when task.drop.producer.errors==true

[ https://issues.apache.org/jira/browse/SAMZA-1539?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xinyu Liu updated SAMZA-1539: - Fix Version/s: (was: 0.15.0) 0.14.1 > KafkaProducer potential hang on close() when

[jira] [Updated] (SAMZA-1528) Implement async NodeManager interactions

[ https://issues.apache.org/jira/browse/SAMZA-1528?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xinyu Liu updated SAMZA-1528: - Fix Version/s: (was: 0.15.0) 0.14.1 > Implement async NodeManager interactions > --

[jira] [Updated] (SAMZA-1557) Broadcast operator

[ https://issues.apache.org/jira/browse/SAMZA-1557?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xinyu Liu updated SAMZA-1557: - Fix Version/s: (was: 0.15.0) 0.14.1 > Broadcast operator > -- > >

[jira] [Updated] (SAMZA-1548) Add start() and stop() to SystemAdmin

[ https://issues.apache.org/jira/browse/SAMZA-1548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xinyu Liu updated SAMZA-1548: - Fix Version/s: (was: 0.15.0) 0.14.1 > Add start() and stop() to SystemAdmin > -

[jira] [Updated] (SAMZA-1558) State restore metrics should be duplicated and deprecated to avoid type conflicts

[ https://issues.apache.org/jira/browse/SAMZA-1558?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xinyu Liu updated SAMZA-1558: - Fix Version/s: (was: 0.15.0) 0.14.1 > State restore metrics should be duplicated an

[jira] [Updated] (SAMZA-1582) Updated yajl-ruby ~> 1.3.1

[ https://issues.apache.org/jira/browse/SAMZA-1582?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xinyu Liu updated SAMZA-1582: - Fix Version/s: (was: 0.15.0) 0.14.1 > Updated yajl-ruby ~> 1.3.1 >

[jira] [Updated] (SAMZA-1596) Staging direcroty in HDFS config

[ https://issues.apache.org/jira/browse/SAMZA-1596?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xinyu Liu updated SAMZA-1596: - Fix Version/s: (was: 0.15.0) 0.14.1 > Staging direcroty in HDFS config > --

[jira] [Updated] (SAMZA-1578) Fix watermark bug found by BEAM tests

[ https://issues.apache.org/jira/browse/SAMZA-1578?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xinyu Liu updated SAMZA-1578: - Fix Version/s: (was: 0.15.0) 0.14.1 > Fix watermark bug found by BEAM tests > -

[jira] [Updated] (SAMZA-1530) Bump up Kafka dependency to 0.11

[ https://issues.apache.org/jira/browse/SAMZA-1530?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xinyu Liu updated SAMZA-1530: - Fix Version/s: (was: 0.15.0) 0.14.1 > Bump up Kafka dependency to 0.11 > --

[jira] [Updated] (SAMZA-1407) upgrade junit version to 4.12

[ https://issues.apache.org/jira/browse/SAMZA-1407?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xinyu Liu updated SAMZA-1407: - Fix Version/s: (was: 0.15.0) 0.14.1 > upgrade junit version to 4.12 >

[jira] [Updated] (SAMZA-1489) TaskInstance should commit offset before it closes() if auto commit is enabled

[ https://issues.apache.org/jira/browse/SAMZA-1489?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xinyu Liu updated SAMZA-1489: - Fix Version/s: (was: 0.15.0) 0.14.1 > TaskInstance should commit offset before it c

[jira] [Updated] (SAMZA-1476) Flaky test: TestStatefulTask testShouldStartAndRestore

[ https://issues.apache.org/jira/browse/SAMZA-1476?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xinyu Liu updated SAMZA-1476: - Fix Version/s: (was: 0.15.0) 0.14.1 > Flaky test: TestStatefulTask testShouldStartA

[jira] [Resolved] (SAMZA-1133) TestApplicationRunner for executing Samza StreamApplication in testing environment

[ https://issues.apache.org/jira/browse/SAMZA-1133?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xinyu Liu resolved SAMZA-1133. -- Resolution: Won't Fix Dup for current TestRunner. > TestApplicationRunner for executing Samza StreamApp

[jira] [Assigned] (SAMZA-1133) TestApplicationRunner for executing Samza StreamApplication in testing environment

[ https://issues.apache.org/jira/browse/SAMZA-1133?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xinyu Liu reassigned SAMZA-1133: Assignee: (was: Xinyu Liu) > TestApplicationRunner for executing Samza StreamApplication in tes

[jira] [Updated] (SAMZA-1535) Support UDFS in where clause

[ https://issues.apache.org/jira/browse/SAMZA-1535?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xinyu Liu updated SAMZA-1535: - Fix Version/s: (was: 0.15.0) 0.14.1 > Support UDFS in where clause > --

[jira] [Updated] (SAMZA-1602) Samza-Test: Moving StreamAssert from src/test to src/main

[ https://issues.apache.org/jira/browse/SAMZA-1602?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xinyu Liu updated SAMZA-1602: - Fix Version/s: (was: 0.15.0) 0.14.1 > Samza-Test: Moving StreamAssert from src/test

[jira] [Updated] (SAMZA-1556) Samza SQL: Add support for multi level sources in SQL query

[ https://issues.apache.org/jira/browse/SAMZA-1556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xinyu Liu updated SAMZA-1556: - Fix Version/s: (was: 0.15.0) 0.14.1 > Samza SQL: Add support for multi level source

[jira] [Assigned] (SAMZA-1535) Support UDFS in where clause

[ https://issues.apache.org/jira/browse/SAMZA-1535?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xinyu Liu reassigned SAMZA-1535: Assignee: Srinivasulu Punuru > Support UDFS in where clause > > >

[jira] [Updated] (SAMZA-1599) AsyncRunLoop Slow When Some Partitions Are Empty

[ https://issues.apache.org/jira/browse/SAMZA-1599?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xinyu Liu updated SAMZA-1599: - Fix Version/s: (was: 0.15.0) 0.14.1 > AsyncRunLoop Slow When Some Partitions Are Em

[jira] [Assigned] (SAMZA-1556) Samza SQL: Add support for multi level sources in SQL query

[ https://issues.apache.org/jira/browse/SAMZA-1556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xinyu Liu reassigned SAMZA-1556: Assignee: Srinivasulu Punuru > Samza SQL: Add support for multi level sources in SQL query > --

[jira] [Updated] (SAMZA-1572) Add fixed retries on failure in KafkaCheckpointManager

[ https://issues.apache.org/jira/browse/SAMZA-1572?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xinyu Liu updated SAMZA-1572: - Fix Version/s: (was: 0.15.0) 0.14.1 > Add fixed retries on failure in KafkaCheckpoi

[jira] [Updated] (SAMZA-1183) Fix TestAsyncRunLoop flaky tests

[ https://issues.apache.org/jira/browse/SAMZA-1183?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xinyu Liu updated SAMZA-1183: - Fix Version/s: (was: 0.15.0) 0.14.1 > Fix TestAsyncRunLoop flaky tests > --

[jira] [Updated] (SAMZA-1478) Delete unneeded data from intermediate Kafka topic on offset commit

[ https://issues.apache.org/jira/browse/SAMZA-1478?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xinyu Liu updated SAMZA-1478: - Fix Version/s: (was: 0.15.0) 0.14.1 > Delete unneeded data from intermediate Kafka

[jira] [Updated] (SAMZA-1500) Add metrics for RocksDB state store memory usage

[ https://issues.apache.org/jira/browse/SAMZA-1500?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xinyu Liu updated SAMZA-1500: - Fix Version/s: (was: 0.15.0) 0.14.1 > Add metrics for RocksDB state store memory us