[jira] (SAMZA-984) Upgrade to RocksDB to 4.8.0

Title: Message Title Prateek Maheshwari commented on SAMZA-984

[jira] [Created] (SAMZA-1091) Implement key-based inner join operator with no time constraints

Prateek Maheshwari created SAMZA-1091: - Summary: Implement key-based inner join operator with no time constraints Key: SAMZA-1091 URL: https://issues.apache.org/jira/browse/SAMZA-1091 Project:

[jira] [Updated] (SAMZA-1017) Disk Quotas - Add throttling support for AsyncRunLoop

[ https://issues.apache.org/jira/browse/SAMZA-1017?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Prateek Maheshwari updated SAMZA-1017: -- Summary: Disk Quotas - Add throttling support for AsyncRunLoop (was: Disk Quotas - Add

[jira] [Created] (SAMZA-1017) Disk Quotas - Add throttler for AsyncRunLoop

Prateek Maheshwari created SAMZA-1017: - Summary: Disk Quotas - Add throttler for AsyncRunLoop Key: SAMZA-1017 URL: https://issues.apache.org/jira/browse/SAMZA-1017 Project: Samza Issue

[jira] [Updated] (SAMZA-1017) Disk Quotas - Add throttling support for AsyncRunLoop

[ https://issues.apache.org/jira/browse/SAMZA-1017?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Prateek Maheshwari updated SAMZA-1017: -- Attachment: throttling-scheduler-2.patch Removed uses of Java 8 features. Added

[jira] [Created] (SAMZA-1065) Change the commit order to support at least once processing when deduping with local state store

Prateek Maheshwari created SAMZA-1065: - Summary: Change the commit order to support at least once processing when deduping with local state store Key: SAMZA-1065 URL:

[jira] [Updated] (SAMZA-1065) Change the commit order to support at least once processing when deduping with local state store

[ https://issues.apache.org/jira/browse/SAMZA-1065?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Prateek Maheshwari updated SAMZA-1065: -- Description: The current commit order for a task instance is

[jira] [Resolved] (SAMZA-1054) Refactor public Operator APIs

[ https://issues.apache.org/jira/browse/SAMZA-1054?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Prateek Maheshwari resolved SAMZA-1054. --- Resolution: Fixed > Refactor public Operator APIs > - > >

[jira] [Created] (SAMZA-1057) Window documentation refers to single-threaded-only execution model

Prateek Maheshwari created SAMZA-1057: - Summary: Window documentation refers to single-threaded-only execution model Key: SAMZA-1057 URL: https://issues.apache.org/jira/browse/SAMZA-1057 Project:

[jira] [Closed] (SAMZA-1054) Refactor public Operator APIs

[ https://issues.apache.org/jira/browse/SAMZA-1054?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Prateek Maheshwari closed SAMZA-1054. - > Refactor public Operator APIs > - > > Key:

[jira] [Commented] (SAMZA-1065) Change the commit order to support at least once processing when deduping with local state store

[ https://issues.apache.org/jira/browse/SAMZA-1065?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15771030#comment-15771030 ] Prateek Maheshwari commented on SAMZA-1065: --- Re: 3.1, 3.2 and 3.3: I think the current order

[jira] [Updated] (SAMZA-1065) Change the commit order to support at least once processing when deduping with local state store

[ https://issues.apache.org/jira/browse/SAMZA-1065?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Prateek Maheshwari updated SAMZA-1065: -- Description: The current commit order for a task instance is

[jira] [Created] (SAMZA-1070) Use a separate SystemProducer for changelog

Prateek Maheshwari created SAMZA-1070: - Summary: Use a separate SystemProducer for changelog Key: SAMZA-1070 URL: https://issues.apache.org/jira/browse/SAMZA-1070 Project: Samza Issue

[jira] [Commented] (SAMZA-1159) Move StreamSpec from a public API to an ApplicationRunner internal API

[ https://issues.apache.org/jira/browse/SAMZA-1159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15934964#comment-15934964 ] Prateek Maheshwari commented on SAMZA-1159: --- We're currently using the StreamSpec as a mapping

[jira] [Created] (SAMZA-1176) Make TestJoinOperator unit tests safe for concurrent execution

Prateek Maheshwari created SAMZA-1176: - Summary: Make TestJoinOperator unit tests safe for concurrent execution Key: SAMZA-1176 URL: https://issues.apache.org/jira/browse/SAMZA-1176 Project:

[jira] [Created] (SAMZA-1148) Wire up fluent API input/output stream serdes

Prateek Maheshwari created SAMZA-1148: - Summary: Wire up fluent API input/output stream serdes Key: SAMZA-1148 URL: https://issues.apache.org/jira/browse/SAMZA-1148 Project: Samza Issue

[jira] [Created] (SAMZA-1200) Scala compile for samza-core occassionally fails with ambiguous reference error

Prateek Maheshwari created SAMZA-1200: - Summary: Scala compile for samza-core occassionally fails with ambiguous reference error Key: SAMZA-1200 URL: https://issues.apache.org/jira/browse/SAMZA-1200

[jira] [Resolved] (SAMZA-1159) Move StreamSpec from a public API to an ApplicationRunner internal API

[ https://issues.apache.org/jira/browse/SAMZA-1159?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Prateek Maheshwari resolved SAMZA-1159. --- Resolution: Fixed Resolved in https://github.com/apache/samza/pull/92. > Move

[jira] [Closed] (SAMZA-1159) Move StreamSpec from a public API to an ApplicationRunner internal API

[ https://issues.apache.org/jira/browse/SAMZA-1159?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Prateek Maheshwari closed SAMZA-1159. - > Move StreamSpec from a public API to an ApplicationRunner internal API >

[jira] [Created] (SAMZA-1192) TestJoinOperator tests fail on JDK 1.8.0_05

Prateek Maheshwari created SAMZA-1192: - Summary: TestJoinOperator tests fail on JDK 1.8.0_05 Key: SAMZA-1192 URL: https://issues.apache.org/jira/browse/SAMZA-1192 Project: Samza Issue

[jira] [Updated] (SAMZA-1192) TestJoinOperator tests fail on JDK 1.8.0_05

[ https://issues.apache.org/jira/browse/SAMZA-1192?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Prateek Maheshwari updated SAMZA-1192: -- Description: TestJoinOperator tests fail on JDK 1.8.0_05 due to a JDK bug:

[jira] [Created] (SAMZA-1199) ClassCastException in partitionBy if input type M does not equal msg.serde type

Prateek Maheshwari created SAMZA-1199: - Summary: ClassCastException in partitionBy if input type M does not equal msg.serde type Key: SAMZA-1199 URL: https://issues.apache.org/jira/browse/SAMZA-1199

[jira] [Updated] (SAMZA-1162) Review tryBecomeLeader implementation to see if it can be simplified.

[ https://issues.apache.org/jira/browse/SAMZA-1162?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Prateek Maheshwari updated SAMZA-1162: -- Summary: Review tryBecomeLeader implementation to see if it can be simplified. (was:

[jira] [Updated] (SAMZA-1210) Fix ZK path issues + container IDs generation.

[ https://issues.apache.org/jira/browse/SAMZA-1210?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Prateek Maheshwari updated SAMZA-1210: -- Summary: Fix ZK path issues + container IDs generation. (was: fix ZK path issues +

[jira] [Updated] (SAMZA-1130) ApplicationRunner for running StreamApplication

[ https://issues.apache.org/jira/browse/SAMZA-1130?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Prateek Maheshwari updated SAMZA-1130: -- Fix Version/s: 0.13.0 > ApplicationRunner for running StreamApplication >

[jira] [Resolved] (SAMZA-1149) upgrade mockito from 1.8.4 to 1.10.19

[ https://issues.apache.org/jira/browse/SAMZA-1149?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Prateek Maheshwari resolved SAMZA-1149. --- Resolution: Fixed Assignee: Fred Ji > upgrade mockito from 1.8.4 to 1.10.19 >

[jira] [Updated] (SAMZA-1149) upgrade mockito from 1.8.4 to 1.10.19

[ https://issues.apache.org/jira/browse/SAMZA-1149?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Prateek Maheshwari updated SAMZA-1149: -- Fix Version/s: 0.13.0 > upgrade mockito from 1.8.4 to 1.10.19 >

[jira] [Updated] (SAMZA-1143) Universal config support for localized resource

[ https://issues.apache.org/jira/browse/SAMZA-1143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Prateek Maheshwari updated SAMZA-1143: -- Fix Version/s: 0.13.0 > Universal config support for localized resource >

[jira] [Updated] (SAMZA-1142) Create documentation for non blocking commit in AsyncRunLoop.

[ https://issues.apache.org/jira/browse/SAMZA-1142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Prateek Maheshwari updated SAMZA-1142: -- Fix Version/s: 0.13.0 > Create documentation for non blocking commit in AsyncRunLoop. >

[jira] [Resolved] (SAMZA-1143) Universal config support for localized resource

[ https://issues.apache.org/jira/browse/SAMZA-1143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Prateek Maheshwari resolved SAMZA-1143. --- Resolution: Fixed Assignee: Fred Ji > Universal config support for localized

[jira] [Updated] (SAMZA-1144) Deprecate yarn.package.path and change package localizer to use the universal resource localization config

[ https://issues.apache.org/jira/browse/SAMZA-1144?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Prateek Maheshwari updated SAMZA-1144: -- Fix Version/s: 0.13.0 > Deprecate yarn.package.path and change package localizer to use

[jira] [Updated] (SAMZA-1160) Migrate MapConfig inherited Java classes to use composition over inheritance

[ https://issues.apache.org/jira/browse/SAMZA-1160?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Prateek Maheshwari updated SAMZA-1160: -- Fix Version/s: 0.13.0 > Migrate MapConfig inherited Java classes to use composition

[jira] [Updated] (SAMZA-1075) Refactor SystemAdmin Interface to expose a common method to create streams.

[ https://issues.apache.org/jira/browse/SAMZA-1075?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Prateek Maheshwari updated SAMZA-1075: -- Fix Version/s: 0.13.0 > Refactor SystemAdmin Interface to expose a common method to

[jira] [Updated] (SAMZA-1202) Multiple calls to `graph.getInputStream()` with the same streamId results in non-deterministic behavior

[ https://issues.apache.org/jira/browse/SAMZA-1202?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Prateek Maheshwari updated SAMZA-1202: -- Fix Version/s: 0.13.0 > Multiple calls to `graph.getInputStream()` with the same

[jira] [Updated] (SAMZA-1212) Refactor interaction between StreamProcessor, JobCoordinator and SamzaContainer

[ https://issues.apache.org/jira/browse/SAMZA-1212?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Prateek Maheshwari updated SAMZA-1212: -- Fix Version/s: 0.13.0 > Refactor interaction between StreamProcessor, JobCoordinator

[jira] [Updated] (SAMZA-1204) Visualize StreamGraph and ExecutionPlan

[ https://issues.apache.org/jira/browse/SAMZA-1204?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Prateek Maheshwari updated SAMZA-1204: -- Fix Version/s: 0.13.0 > Visualize StreamGraph and ExecutionPlan >

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

[ https://issues.apache.org/jira/browse/SAMZA-1183?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Prateek Maheshwari resolved SAMZA-1183. --- Resolution: Fixed > Fix TestAsyncRunLoop flaky tests >

[jira] [Updated] (SAMZA-1184) Improvements to Merge Script

[ https://issues.apache.org/jira/browse/SAMZA-1184?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Prateek Maheshwari updated SAMZA-1184: -- Fix Version/s: 0.13.0 > Improvements to Merge Script > > >

[jira] [Updated] (SAMZA-1193) Fix the flaky test TestZkBarrierForVersionUpgrade.testZkBarrierForVersionUpgrade

[ https://issues.apache.org/jira/browse/SAMZA-1193?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Prateek Maheshwari updated SAMZA-1193: -- Fix Version/s: 0.13.0 > Fix the flaky test >

[jira] [Updated] (SAMZA-1201) Zk path setup for leader elector and barrier should be separated

[ https://issues.apache.org/jira/browse/SAMZA-1201?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Prateek Maheshwari updated SAMZA-1201: -- Fix Version/s: 0.13.0 > Zk path setup for leader elector and barrier should be

[jira] [Updated] (SAMZA-1188) Document local store monitor support in configuration table under samza-rest

[ https://issues.apache.org/jira/browse/SAMZA-1188?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Prateek Maheshwari updated SAMZA-1188: -- Fix Version/s: 0.13.0 > Document local store monitor support in configuration table

[jira] [Updated] (SAMZA-1205) Disable Flaky test : TestJmxServer#serverStartsUp

[ https://issues.apache.org/jira/browse/SAMZA-1205?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Prateek Maheshwari updated SAMZA-1205: -- Fix Version/s: 0.13.0 > Disable Flaky test : TestJmxServer#serverStartsUp >

[jira] [Updated] (SAMZA-1207) Samza should publish test utilities in a test artifact

[ https://issues.apache.org/jira/browse/SAMZA-1207?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Prateek Maheshwari updated SAMZA-1207: -- Fix Version/s: 0.13.0 > Samza should publish test utilities in a test artifact >

[jira] [Updated] (SAMZA-1209) Improve error handling in LocalStoreMonitor

[ https://issues.apache.org/jira/browse/SAMZA-1209?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Prateek Maheshwari updated SAMZA-1209: -- Fix Version/s: 0.13.0 > Improve error handling in LocalStoreMonitor >

[jira] [Updated] (SAMZA-1173) Evaluate CoordinationService design and resolve unresolved questions from PR#91

[ https://issues.apache.org/jira/browse/SAMZA-1173?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Prateek Maheshwari updated SAMZA-1173: -- Fix Version/s: 0.13.0 > Evaluate CoordinationService design and resolve unresolved

[jira] [Resolved] (SAMZA-272) TestExponentialSleepStrategy failing randomly

[ https://issues.apache.org/jira/browse/SAMZA-272?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Prateek Maheshwari resolved SAMZA-272. -- Resolution: Fixed Assignee: Prateek Maheshwari Fix Version/s: 0.13.0 >

[jira] [Resolved] (SAMZA-1106) Create test utils for Zk based Standalone testing

[ https://issues.apache.org/jira/browse/SAMZA-1106?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Prateek Maheshwari resolved SAMZA-1106. --- Resolution: Fixed > Create test utils for Zk based Standalone testing >

[jira] [Updated] (SAMZA-1106) Create test utils for Zk based Standalone testing

[ https://issues.apache.org/jira/browse/SAMZA-1106?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Prateek Maheshwari updated SAMZA-1106: -- Summary: Create test utils for Zk based Standalone testing (was: create test utils for

[jira] [Resolved] (SAMZA-1170) Integration testing harness for StreamApplications

[ https://issues.apache.org/jira/browse/SAMZA-1170?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Prateek Maheshwari resolved SAMZA-1170. --- Resolution: Fixed > Integration testing harness for StreamApplications >

[jira] [Updated] (SAMZA-1179) Documentation of ApplicationRunner

[ https://issues.apache.org/jira/browse/SAMZA-1179?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Prateek Maheshwari updated SAMZA-1179: -- Fix Version/s: 0.13.0 > Documentation of ApplicationRunner >

[jira] [Updated] (SAMZA-1174) Profiling State Perfromance

[ https://issues.apache.org/jira/browse/SAMZA-1174?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Prateek Maheshwari updated SAMZA-1174: -- Fix Version/s: 0.13.0 > Profiling State Perfromance > --- > >

[jira] [Updated] (SAMZA-1170) Integration testing harness for StreamApplications

[ https://issues.apache.org/jira/browse/SAMZA-1170?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Prateek Maheshwari updated SAMZA-1170: -- Fix Version/s: 0.13.0 > Integration testing harness for StreamApplications >

[jira] [Assigned] (SAMZA-860) Expose RocksDB log options via Samza configuration

[ https://issues.apache.org/jira/browse/SAMZA-860?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Prateek Maheshwari reassigned SAMZA-860: Assignee: Prateek Maheshwari > Expose RocksDB log options via Samza configuration >

[jira] [Resolved] (SAMZA-860) Expose RocksDB log options via Samza configuration

[ https://issues.apache.org/jira/browse/SAMZA-860?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Prateek Maheshwari resolved SAMZA-860. -- Resolution: Fixed Fix Version/s: 0.13.0 > Expose RocksDB log options via Samza

[jira] [Resolved] (SAMZA-984) Upgrade to RocksDB to 4.8.0

[ https://issues.apache.org/jira/browse/SAMZA-984?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Prateek Maheshwari resolved SAMZA-984. -- Resolution: Fixed > Upgrade to RocksDB to 4.8.0 > --- > >

[jira] [Updated] (SAMZA-984) Upgrade to RocksDB to 4.8.0

[ https://issues.apache.org/jira/browse/SAMZA-984?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Prateek Maheshwari updated SAMZA-984: - Fix Version/s: 0.13.0 > Upgrade to RocksDB to 4.8.0 > --- > >

[jira] [Updated] (SAMZA-1111) Design logo for Apache Samza

[ https://issues.apache.org/jira/browse/SAMZA-?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Prateek Maheshwari updated SAMZA-: -- Fix Version/s: 0.13.0 > Design logo for Apache Samza > > >

[jira] [Closed] (SAMZA-1175) Removing CoordinationUtils from JobCoordinationFactory interface

[ https://issues.apache.org/jira/browse/SAMZA-1175?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Prateek Maheshwari closed SAMZA-1175. - > Removing CoordinationUtils from JobCoordinationFactory interface >

[jira] [Resolved] (SAMZA-1176) Make TestJoinOperator unit tests safe for concurrent execution

[ https://issues.apache.org/jira/browse/SAMZA-1176?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Prateek Maheshwari resolved SAMZA-1176. --- Resolution: Fixed > Make TestJoinOperator unit tests safe for concurrent execution >

[jira] [Updated] (SAMZA-1147) ZkJobCoordinator does not honor the interface contract of JobCoordinator

[ https://issues.apache.org/jira/browse/SAMZA-1147?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Prateek Maheshwari updated SAMZA-1147: -- Fix Version/s: 0.13.0 > ZkJobCoordinator does not honor the interface contract of

[jira] [Updated] (SAMZA-1163) Samza 0.12 build with scala 2.10

[ https://issues.apache.org/jira/browse/SAMZA-1163?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Prateek Maheshwari updated SAMZA-1163: -- Fix Version/s: 0.13.0 > Samza 0.12 build with scala 2.10 >

[jira] [Updated] (SAMZA-1157) When throwable is caught in serialization/deserialzation, Samza should propagate the throwable via exception, instead of suppressing

[ https://issues.apache.org/jira/browse/SAMZA-1157?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Prateek Maheshwari updated SAMZA-1157: -- Fix Version/s: 0.13.0 > When throwable is caught in serialization/deserialzation, Samza

[jira] [Updated] (SAMZA-1164) Add capability to cancel in LeaderElection

[ https://issues.apache.org/jira/browse/SAMZA-1164?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Prateek Maheshwari updated SAMZA-1164: -- Fix Version/s: 0.13.0 > Add capability to cancel in LeaderElection >

[jira] [Updated] (SAMZA-1166) Leader should hold a lock to avoid failures on long GC pause/timeouts

[ https://issues.apache.org/jira/browse/SAMZA-1166?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Prateek Maheshwari updated SAMZA-1166: -- Fix Version/s: 0.13.0 > Leader should hold a lock to avoid failures on long GC

[jira] [Updated] (SAMZA-1168) Migrate yarn local runner to use StreamProcessor

[ https://issues.apache.org/jira/browse/SAMZA-1168?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Prateek Maheshwari updated SAMZA-1168: -- Fix Version/s: 0.13.0 > Migrate yarn local runner to use StreamProcessor >

[jira] [Resolved] (SAMZA-1132) LocalApplicationRunner for local exeuction of Samza StreamApplication

[ https://issues.apache.org/jira/browse/SAMZA-1132?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Prateek Maheshwari resolved SAMZA-1132. --- Resolution: Fixed > LocalApplicationRunner for local exeuction of Samza

[jira] [Resolved] (SAMZA-1117) set up certificate signing request in the context for resource localization

[ https://issues.apache.org/jira/browse/SAMZA-1117?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Prateek Maheshwari resolved SAMZA-1117. --- Resolution: Fixed > set up certificate signing request in the context for resource

[jira] [Updated] (SAMZA-1117) set up certificate signing request in the context for resource localization

[ https://issues.apache.org/jira/browse/SAMZA-1117?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Prateek Maheshwari updated SAMZA-1117: -- Fix Version/s: 0.13.0 > set up certificate signing request in the context for resource

[jira] [Updated] (SAMZA-1119) Introduce a common job.metadata.system config to specify the system for all Samza metadata topics.

[ https://issues.apache.org/jira/browse/SAMZA-1119?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Prateek Maheshwari updated SAMZA-1119: -- Fix Version/s: 0.13.0 > Introduce a common job.metadata.system config to specify the

[jira] [Updated] (SAMZA-1118) Deprecate the SystemStream configurations in favor of StreamId

[ https://issues.apache.org/jira/browse/SAMZA-1118?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Prateek Maheshwari updated SAMZA-1118: -- Fix Version/s: 0.13.0 > Deprecate the SystemStream configurations in favor of StreamId

[jira] [Updated] (SAMZA-1056) Provide Operator implementations access to KeyValueStorageEngines

[ https://issues.apache.org/jira/browse/SAMZA-1056?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Prateek Maheshwari updated SAMZA-1056: -- Fix Version/s: 0.13.0 > Provide Operator implementations access to

[jira] [Updated] (SAMZA-1057) Window documentation refers to single-threaded-only execution model

[ https://issues.apache.org/jira/browse/SAMZA-1057?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Prateek Maheshwari updated SAMZA-1057: -- Fix Version/s: 0.13.0 > Window documentation refers to single-threaded-only execution

[jira] [Updated] (SAMZA-1063) Samza Standalone Project

[ https://issues.apache.org/jira/browse/SAMZA-1063?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Prateek Maheshwari updated SAMZA-1063: -- Fix Version/s: 0.13.0 > Samza Standalone Project > > >

[jira] [Updated] (SAMZA-1150) Handling Error propagation between ZkJobCoordinator & DebounceTimer

[ https://issues.apache.org/jira/browse/SAMZA-1150?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Prateek Maheshwari updated SAMZA-1150: -- Fix Version/s: 0.13.0 > Handling Error propagation between ZkJobCoordinator &

[jira] [Updated] (SAMZA-1135) Support Scala 2.12

[ https://issues.apache.org/jira/browse/SAMZA-1135?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Prateek Maheshwari updated SAMZA-1135: -- Fix Version/s: 0.13.0 > Support Scala 2.12 > -- > >

[jira] [Updated] (SAMZA-1088) TestStreamProcessor hangs during job initialization due to Kafka broker is not available

[ https://issues.apache.org/jira/browse/SAMZA-1088?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Prateek Maheshwari updated SAMZA-1088: -- Fix Version/s: 0.13.0 > TestStreamProcessor hangs during job initialization due to

[jira] [Updated] (SAMZA-1154) Tasks endpoint to list the complete details of all tasks related to a job

[ https://issues.apache.org/jira/browse/SAMZA-1154?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Prateek Maheshwari updated SAMZA-1154: -- Fix Version/s: 0.13.0 > Tasks endpoint to list the complete details of all tasks

[jira] [Updated] (SAMZA-1158) Adding monitor to clean up stale local stores of tasks.

[ https://issues.apache.org/jira/browse/SAMZA-1158?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Prateek Maheshwari updated SAMZA-1158: -- Fix Version/s: 0.13.0 > Adding monitor to clean up stale local stores of tasks. >

[jira] [Updated] (SAMZA-1138) Yarn capability check is broken

[ https://issues.apache.org/jira/browse/SAMZA-1138?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Prateek Maheshwari updated SAMZA-1138: -- Fix Version/s: 0.13.0 > Yarn capability check is broken >

[jira] [Updated] (SAMZA-1072) Make scalaVersion configurable through ENV variable in samza-test json files

[ https://issues.apache.org/jira/browse/SAMZA-1072?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Prateek Maheshwari updated SAMZA-1072: -- Fix Version/s: 0.13.0 > Make scalaVersion configurable through ENV variable in

[jira] [Resolved] (SAMZA-1110) Use "equals" instead of "==" in StreamGraphImpl.getInputStream()

[ https://issues.apache.org/jira/browse/SAMZA-1110?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Prateek Maheshwari resolved SAMZA-1110. --- Resolution: Fixed Fix Version/s: 0.13.0 Not necessary anymore. > Use "equals"

[jira] [Assigned] (SAMZA-955) Upgrade RocksDB JNI to 4.5.1

[ https://issues.apache.org/jira/browse/SAMZA-955?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Prateek Maheshwari reassigned SAMZA-955: Assignee: Prateek Maheshwari > Upgrade RocksDB JNI to 4.5.1 >

[jira] [Resolved] (SAMZA-955) Upgrade RocksDB JNI to 4.5.1

[ https://issues.apache.org/jira/browse/SAMZA-955?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Prateek Maheshwari resolved SAMZA-955. -- Resolution: Fixed > Upgrade RocksDB JNI to 4.5.1 > > >

[jira] [Updated] (SAMZA-1076) getKafkaChangelogEnabledStores() should use StorageConfig.getChangelogStream to get changelog system.stream

[ https://issues.apache.org/jira/browse/SAMZA-1076?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Prateek Maheshwari updated SAMZA-1076: -- Fix Version/s: 0.13.0 > getKafkaChangelogEnabledStores() should use

[jira] [Updated] (SAMZA-1074) Cannot build hello-samza on various CDH version

[ https://issues.apache.org/jira/browse/SAMZA-1074?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Prateek Maheshwari updated SAMZA-1074: -- Fix Version/s: 0.13.0 > Cannot build hello-samza on various CDH version >

[jira] [Updated] (SAMZA-1132) LocalApplicationRunner for local exeuction of Samza StreamApplication

[ https://issues.apache.org/jira/browse/SAMZA-1132?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Prateek Maheshwari updated SAMZA-1132: -- Fix Version/s: 0.13.0 > LocalApplicationRunner for local exeuction of Samza

[jira] [Updated] (SAMZA-1155) Allow configuring window.ms to specify trigger duration

[ https://issues.apache.org/jira/browse/SAMZA-1155?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Prateek Maheshwari updated SAMZA-1155: -- Fix Version/s: 0.13.0 > Allow configuring window.ms to specify trigger duration >

[jira] [Updated] (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 ] Prateek Maheshwari updated SAMZA-1133: -- Fix Version/s: 0.13.0 > TestApplicationRunner for executing Samza StreamApplication in

[jira] [Resolved] (SAMZA-1074) Cannot build hello-samza on various CDH version

[ https://issues.apache.org/jira/browse/SAMZA-1074?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Prateek Maheshwari resolved SAMZA-1074. --- Resolution: Fixed > Cannot build hello-samza on various CDH version >

[jira] [Resolved] (SAMZA-1076) getKafkaChangelogEnabledStores() should use StorageConfig.getChangelogStream to get changelog system.stream

[ https://issues.apache.org/jira/browse/SAMZA-1076?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Prateek Maheshwari resolved SAMZA-1076. --- Resolution: Fixed > getKafkaChangelogEnabledStores() should use

[jira] [Updated] (SAMZA-1203) Use ProcessorId instead of Zk node Id in JobModel generation

[ https://issues.apache.org/jira/browse/SAMZA-1203?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Prateek Maheshwari updated SAMZA-1203: -- Fix Version/s: 0.13.0 > Use ProcessorId instead of Zk node Id in JobModel generation >

[jira] [Updated] (SAMZA-1181) Fix AppMaster hang after submitting jobs to Yarn

[ https://issues.apache.org/jira/browse/SAMZA-1181?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Prateek Maheshwari updated SAMZA-1181: -- Fix Version/s: 0.13.0 > Fix AppMaster hang after submitting jobs to Yarn >

[jira] [Updated] (SAMZA-1109) Creating Serde regristry to support typed data serdes in samza-api

[ https://issues.apache.org/jira/browse/SAMZA-1109?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Prateek Maheshwari updated SAMZA-1109: -- Fix Version/s: 0.13.0 > Creating Serde regristry to support typed data serdes in

[jira] [Updated] (SAMZA-1092) Updated fluent API to use the refactored StreamSpec class

[ https://issues.apache.org/jira/browse/SAMZA-1092?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Prateek Maheshwari updated SAMZA-1092: -- Fix Version/s: 0.13.0 > Updated fluent API to use the refactored StreamSpec class >

[jira] [Resolved] (SAMZA-1091) Implement key-based inner join operator with no time constraints

[ https://issues.apache.org/jira/browse/SAMZA-1091?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Prateek Maheshwari resolved SAMZA-1091. --- Resolution: Fixed > Implement key-based inner join operator with no time constraints

[jira] [Resolved] (SAMZA-1108) Implement core windowing and triggering logic

[ https://issues.apache.org/jira/browse/SAMZA-1108?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Prateek Maheshwari resolved SAMZA-1108. --- Resolution: Fixed > Implement core windowing and triggering logic >

[jira] [Updated] (SAMZA-1101) Delay the creation of actual function to send to a physical stream until OperatorImpl instantiation

[ https://issues.apache.org/jira/browse/SAMZA-1101?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Prateek Maheshwari updated SAMZA-1101: -- Fix Version/s: 0.13.0 > Delay the creation of actual function to send to a physical

[jira] [Updated] (SAMZA-1108) Implement core windowing and triggering logic

[ https://issues.apache.org/jira/browse/SAMZA-1108?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Prateek Maheshwari updated SAMZA-1108: -- Fix Version/s: 0.13.0 > Implement core windowing and triggering logic >

[jira] [Updated] (SAMZA-1099) Release Samza 0.12.0

[ https://issues.apache.org/jira/browse/SAMZA-1099?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Prateek Maheshwari updated SAMZA-1099: -- Fix Version/s: 0.12.0 > Release Samza 0.12.0 > > >

[jira] [Resolved] (SAMZA-1099) Release Samza 0.12.0

[ https://issues.apache.org/jira/browse/SAMZA-1099?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Prateek Maheshwari resolved SAMZA-1099. --- Resolution: Fixed > Release Samza 0.12.0 > > >

  1   2   3   4   5   6   >