[jira] [Assigned] (SAMZA-2784) Clean up noisy checkpoint logs

2024-01-19 Thread Daniel Chen (Jira)
[ https://issues.apache.org/jira/browse/SAMZA-2784?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Chen reassigned SAMZA-2784: -- Assignee: Daniel Chen > Clean up noisy checkpoint logs > -- > >

[jira] [Created] (SAMZA-2744) RocksDB version update to 7.0.3

2022-05-25 Thread Daniel Chen (Jira)
Daniel Chen created SAMZA-2744: -- Summary: RocksDB version update to 7.0.3 Key: SAMZA-2744 URL: https://issues.apache.org/jira/browse/SAMZA-2744 Project: Samza Issue Type: Improvement

[jira] [Created] (SAMZA-2738) RemoteApplicatonRunner getstatus should not require recreating the job endpoints

2022-04-28 Thread Daniel Chen (Jira)
Daniel Chen created SAMZA-2738: -- Summary: RemoteApplicatonRunner getstatus should not require recreating the job endpoints Key: SAMZA-2738 URL: https://issues.apache.org/jira/browse/SAMZA-2738 Project: S

[jira] [Updated] (SAMZA-2737) Change RemoteAppRunner to plan for local deployments

2022-04-28 Thread Daniel Chen (Jira)
[ https://issues.apache.org/jira/browse/SAMZA-2737?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Chen updated SAMZA-2737: --- Summary: Change RemoteAppRunner to plan for local deployments (was: Change RemoteAppRunner to plan f

[jira] [Created] (SAMZA-2737) Change RemoteAppRunner to plan for local deployements

2022-04-28 Thread Daniel Chen (Jira)
Daniel Chen created SAMZA-2737: -- Summary: Change RemoteAppRunner to plan for local deployements Key: SAMZA-2737 URL: https://issues.apache.org/jira/browse/SAMZA-2737 Project: Samza Issue Type: I

[jira] [Updated] (SAMZA-2727) Fix UTFDataFormatException on large file writes

2022-03-03 Thread Daniel Chen (Jira)
[ https://issues.apache.org/jira/browse/SAMZA-2727?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Chen updated SAMZA-2727: --- Issue Type: Bug (was: Improvement) > Fix UTFDataFormatException on large file writes >

[jira] [Created] (SAMZA-2727) Fix UTFDataFormatException on large file writes

2022-03-03 Thread Daniel Chen (Jira)
Daniel Chen created SAMZA-2727: -- Summary: Fix UTFDataFormatException on large file writes Key: SAMZA-2727 URL: https://issues.apache.org/jira/browse/SAMZA-2727 Project: Samza Issue Type: Improv

[jira] [Resolved] (SAMZA-2723) Fix Scala 2.11 tests and yarn version for 1.7 release

2022-03-01 Thread Daniel Chen (Jira)
[ https://issues.apache.org/jira/browse/SAMZA-2723?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Chen resolved SAMZA-2723. Resolution: Fixed > Fix Scala 2.11 tests and yarn version for 1.7 release > ---

[jira] [Created] (SAMZA-2723) Fix Scala 2.11 tests and yarn version for 1.7 release

2022-02-28 Thread Daniel Chen (Jira)
Daniel Chen created SAMZA-2723: -- Summary: Fix Scala 2.11 tests and yarn version for 1.7 release Key: SAMZA-2723 URL: https://issues.apache.org/jira/browse/SAMZA-2723 Project: Samza Issue Type: I

[jira] [Updated] (SAMZA-2723) Fix Scala 2.11 tests and yarn version for 1.7 release

2022-02-28 Thread Daniel Chen (Jira)
[ https://issues.apache.org/jira/browse/SAMZA-2723?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Chen updated SAMZA-2723: --- Fix Version/s: 1.7 > Fix Scala 2.11 tests and yarn version for 1.7 release >

[jira] [Resolved] (SAMZA-2657) Blob store backed state backup and restore

2022-01-26 Thread Daniel Chen (Jira)
[ https://issues.apache.org/jira/browse/SAMZA-2657?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Chen resolved SAMZA-2657. Fix Version/s: 1.7 Resolution: Implemented > Blob store backed state backup and restore > --

[jira] [Resolved] (SAMZA-2590) Async State Backup

2022-01-24 Thread Daniel Chen (Jira)
[ https://issues.apache.org/jira/browse/SAMZA-2590?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Chen resolved SAMZA-2590. Resolution: Done https://github.com/apache/samza/pull/1514 > Async State Backup >

[jira] [Updated] (SAMZA-2590) Async State Backup

2022-01-24 Thread Daniel Chen (Jira)
[ https://issues.apache.org/jira/browse/SAMZA-2590?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Chen updated SAMZA-2590: --- Fix Version/s: 1.7 > Async State Backup > -- > > Key: SAMZA-2590 >

[jira] [Resolved] (SAMZA-2674) Remove unused StorageEngine and KeyValues stores Init

2022-01-24 Thread Daniel Chen (Jira)
[ https://issues.apache.org/jira/browse/SAMZA-2674?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Chen resolved SAMZA-2674. Resolution: Fixed https://github.com/apache/samza/pull/1521 > Remove unused StorageEngine and KeyV

[jira] [Updated] (SAMZA-2674) Remove unused StorageEngine and KeyValues stores Init

2022-01-24 Thread Daniel Chen (Jira)
[ https://issues.apache.org/jira/browse/SAMZA-2674?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Chen updated SAMZA-2674: --- Fix Version/s: 1.7 > Remove unused StorageEngine and KeyValues stores Init > ---

[jira] [Resolved] (SAMZA-2683) Bump up Scalatra version to pull latest dependencies

2021-10-01 Thread Daniel Chen (Jira)
[ https://issues.apache.org/jira/browse/SAMZA-2683?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Chen resolved SAMZA-2683. Resolution: Fixed closed in https://github.com/apache/samza/pull/1527 > Bump up Scalatra version t

[jira] [Updated] (SAMZA-2683) Bump up Scalatra version to pull latest dependencies

2021-08-30 Thread Daniel Chen (Jira)
[ https://issues.apache.org/jira/browse/SAMZA-2683?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Chen updated SAMZA-2683: Description: Scalatra 2.5.0 is pulling in outdated libraries, namely log4j:1.2.14 which possesses

[jira] [Created] (SAMZA-2683) Bump up Scalatra version to pull latest dependencies

2021-08-30 Thread Daniel Chen (Jira)
Daniel Chen created SAMZA-2683: --- Summary: Bump up Scalatra version to pull latest dependencies Key: SAMZA-2683 URL: https://issues.apache.org/jira/browse/SAMZA-2683 Project: Samza Issue Type:

[jira] [Created] (SAMZA-2675) Fix Jenkins build for Azure-blob-store version not found

2021-08-19 Thread Daniel Chen (Jira)
Daniel Chen created SAMZA-2675: --- Summary: Fix Jenkins build for Azure-blob-store version not found Key: SAMZA-2675 URL: https://issues.apache.org/jira/browse/SAMZA-2675 Project: Samza Issue Ty

[jira] [Created] (SAMZA-2674) Remove unused StorageEngine and KeyValues stores Init

2021-08-19 Thread Daniel Chen (Jira)
Daniel Chen created SAMZA-2674: --- Summary: Remove unused StorageEngine and KeyValues stores Init Key: SAMZA-2674 URL: https://issues.apache.org/jira/browse/SAMZA-2674 Project: Samza Issue Type

[jira] [Created] (SAMZA-2658) Remove kafka checkpoint key validation for forwards compatibility

2021-05-19 Thread Daniel Chen (Jira)
Daniel Chen created SAMZA-2658: --- Summary: Remove kafka checkpoint key validation for forwards compatibility Key: SAMZA-2658 URL: https://issues.apache.org/jira/browse/SAMZA-2658 Project: Samza

[jira] [Created] (SAMZA-2656) Restore thread management for TaskRestoreManager

2021-05-12 Thread Daniel Chen (Jira)
Daniel Chen created SAMZA-2656: --- Summary: Restore thread management for TaskRestoreManager Key: SAMZA-2656 URL: https://issues.apache.org/jira/browse/SAMZA-2656 Project: Samza Issue Type: Impr

[jira] [Commented] (SAMZA-2531) Async Commit is Blocking for Window, Timer & End of Stream

2020-10-26 Thread Daniel Chen (Jira)
[ https://issues.apache.org/jira/browse/SAMZA-2531?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17221008#comment-17221008 ] Daniel Chen commented on SAMZA-2531: - Thanks, will take a look > Async Commit is Bl

[jira] [Updated] (SAMZA-2590) Async State Backup

2020-09-10 Thread Daniel Chen (Jira)
[ https://issues.apache.org/jira/browse/SAMZA-2590?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Chen updated SAMZA-2590: Attachment: Samza State Backup and Async Checkpointing (1).pdf > Async State Backup > -

[jira] [Updated] (SAMZA-2590) Async State Backup

2020-09-10 Thread Daniel Chen (Jira)
[ https://issues.apache.org/jira/browse/SAMZA-2590?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Chen updated SAMZA-2590: Attachment: (was: Samza State Backup and Async Checkpointing.pdf) > Async State Backup > --

[jira] [Updated] (SAMZA-2590) Async State Backup

2020-09-10 Thread Daniel Chen (Jira)
[ https://issues.apache.org/jira/browse/SAMZA-2590?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Chen updated SAMZA-2590: Attachment: Samza State Backup and Async Checkpointing.pdf > Async State Backup > -

[jira] [Updated] (SAMZA-2591) Introduce Async State Backup API

2020-09-09 Thread Daniel Chen (Jira)
[ https://issues.apache.org/jira/browse/SAMZA-2591?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Chen updated SAMZA-2591: Issue Type: Task (was: New Feature) > Introduce Async State Backup API >

[jira] [Created] (SAMZA-2591) Introduce Async State Backup API

2020-09-09 Thread Daniel Chen (Jira)
Daniel Chen created SAMZA-2591: --- Summary: Introduce Async State Backup API Key: SAMZA-2591 URL: https://issues.apache.org/jira/browse/SAMZA-2591 Project: Samza Issue Type: New Feature

[jira] [Created] (SAMZA-2590) Async State Backup

2020-09-09 Thread Daniel Chen (Jira)
Daniel Chen created SAMZA-2590: --- Summary: Async State Backup Key: SAMZA-2590 URL: https://issues.apache.org/jira/browse/SAMZA-2590 Project: Samza Issue Type: New Feature Reporter:

[jira] [Created] (SAMZA-2309) Remote table descriptor requires read function

2019-08-23 Thread Daniel Chen (Jira)
Daniel Chen created SAMZA-2309: --- Summary: Remote table descriptor requires read function Key: SAMZA-2309 URL: https://issues.apache.org/jira/browse/SAMZA-2309 Project: Samza Issue Type: Bug

[jira] [Resolved] (SAMZA-2137) Add 1.0 release notes and download link to website.

2019-07-22 Thread Daniel Chen (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-2137?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Chen resolved SAMZA-2137. - Resolution: Fixed > Add 1.0 release notes and download link to website. > ---

[jira] [Resolved] (SAMZA-2259) Change Boolean Gauges to Integer for metric system compatibility

2019-07-10 Thread Daniel Chen (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-2259?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Chen resolved SAMZA-2259. - Resolution: Fixed > Change Boolean Gauges to Integer for metric system compatibility > --

[jira] [Created] (SAMZA-2259) Change Boolean Gauges to Integer for metric system compatibility

2019-06-21 Thread Daniel Chen (JIRA)
Daniel Chen created SAMZA-2259: --- Summary: Change Boolean Gauges to Integer for metric system compatibility Key: SAMZA-2259 URL: https://issues.apache.org/jira/browse/SAMZA-2259 Project: Samza

[jira] [Updated] (SAMZA-1973) Unify the TaskNameGrouper interface for yarn and standalone

2019-03-22 Thread Daniel Chen (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-1973?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Chen updated SAMZA-1973: Fix Version/s: 1.1 > Unify the TaskNameGrouper interface for yarn and standalone >

[jira] [Updated] (SAMZA-1952) StreamPartitionCountMonitor for standalone.

2019-03-22 Thread Daniel Chen (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-1952?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Chen updated SAMZA-1952: Fix Version/s: 1.1 > StreamPartitionCountMonitor for standalone. >

[jira] [Updated] (SAMZA-2018) State restore improvements

2019-03-22 Thread Daniel Chen (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-2018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Chen updated SAMZA-2018: Fix Version/s: 1.1 > State restore improvements > -- > > Ke

[jira] [Created] (SAMZA-2139) Fix kvPerformanceTest runTestGetAllVsGetWriteManyReadMany NPE

2019-03-21 Thread Daniel Chen (JIRA)
Daniel Chen created SAMZA-2139: --- Summary: Fix kvPerformanceTest runTestGetAllVsGetWriteManyReadMany NPE Key: SAMZA-2139 URL: https://issues.apache.org/jira/browse/SAMZA-2139 Project: Samza Is

[jira] [Updated] (SAMZA-2139) Fix kvPerformanceTest runTestGetAllVsGetWriteManyReadMany NPE

2019-03-21 Thread Daniel Chen (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-2139?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Chen updated SAMZA-2139: Description: TestKeyValuePerformance.runTestGetAllVsGetWriteManyReadMany throws an NPE some of the

[jira] [Created] (SAMZA-2137) Add 1.0 release notes and download link to website.

2019-03-20 Thread Daniel Chen (JIRA)
Daniel Chen created SAMZA-2137: --- Summary: Add 1.0 release notes and download link to website. Key: SAMZA-2137 URL: https://issues.apache.org/jira/browse/SAMZA-2137 Project: Samza Issue Type: T

[jira] [Updated] (SAMZA-1946) Problem with Race between TimerListener initialization and timers fired from init()

2019-03-18 Thread Daniel Chen (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-1946?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Chen updated SAMZA-1946: Summary: Problem with Race between TimerListener initialization and timers fired from init() (was:

[jira] [Resolved] (SAMZA-2106) Samza App & Job Config Refactor

2019-03-06 Thread Daniel Chen (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-2106?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Chen resolved SAMZA-2106. - Resolution: Fixed Fix Version/s: 1.1 > Samza App & Job Config Refactor > -

[jira] [Resolved] (SAMZA-2071) Skip StartpointManager instantiation for PassThroughCoordinator.

2019-03-06 Thread Daniel Chen (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-2071?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Chen resolved SAMZA-2071. - Fix Version/s: (was: 1.0.1) 1.1 > Skip StartpointManager instantiation for

[jira] [Updated] (SAMZA-2022) Startpoints - SystemConsumers (not to be confused with SystemConsumer) modifications including integration with MessageChooser.

2019-03-06 Thread Daniel Chen (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-2022?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Chen updated SAMZA-2022: Fix Version/s: 1.1 > Startpoints - SystemConsumers (not to be confused with SystemConsumer) > modi

[jira] [Updated] (SAMZA-1985) Implement Startpoints model and StartpointManager

2019-03-06 Thread Daniel Chen (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-1985?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Chen updated SAMZA-1985: Fix Version/s: 1.1 > Implement Startpoints model and StartpointManager > --

[jira] [Updated] (SAMZA-2004) Add ability to disable table metrics

2019-03-06 Thread Daniel Chen (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-2004?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Chen updated SAMZA-2004: Fix Version/s: (was: 1.0.1) 1.1 > Add ability to disable table metrics > ---

[jira] [Updated] (SAMZA-2010) Handle null value in LocalReadWriteTable.putAll()

2019-03-06 Thread Daniel Chen (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-2010?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Chen updated SAMZA-2010: Fix Version/s: (was: 1.0.1) 1.1 > Handle null value in LocalReadWriteTable.p

[jira] [Updated] (SAMZA-2013) Account for cycles in graph traversal within Execution Planner

2019-03-06 Thread Daniel Chen (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-2013?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Chen updated SAMZA-2013: Fix Version/s: (was: 1.0.1) 1.1 > Account for cycles in graph traversal with

[jira] [Updated] (SAMZA-2015) Refactor timer handling in tables to be consistent with stores

2019-03-06 Thread Daniel Chen (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-2015?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Chen updated SAMZA-2015: Fix Version/s: (was: 1.0.1) 1.1 > Refactor timer handling in tables to be co

[jira] [Resolved] (SAMZA-2084) Samza Sql: add logging when exceptions are swallowed and rename util package

2019-03-06 Thread Daniel Chen (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-2084?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Chen resolved SAMZA-2084. - Resolution: Fixed > Samza Sql: add logging when exceptions are swallowed and rename util package

[jira] [Updated] (SAMZA-2084) Samza Sql: add logging when exceptions are swallowed and rename util package

2019-03-06 Thread Daniel Chen (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-2084?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Chen updated SAMZA-2084: Fix Version/s: (was: 0.15) > Samza Sql: add logging when exceptions are swallowed and rename ut

[jira] [Updated] (SAMZA-2043) Consolidate ReadableTable and ReadWriteTable

2019-03-06 Thread Daniel Chen (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-2043?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Chen updated SAMZA-2043: Fix Version/s: (was: 1.0.1) 1.1 > Consolidate ReadableTable and ReadWriteTab

[jira] [Updated] (SAMZA-1946) Problem with Race between TimerListenener initialization and timers fired from init()

2019-03-06 Thread Daniel Chen (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-1946?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Chen updated SAMZA-1946: Fix Version/s: (was: 1.0.1) 1.1 > Problem with Race between TimerListenener

[jira] [Updated] (SAMZA-2108) Check for host affinity config before resolving preferred host matching

2019-03-06 Thread Daniel Chen (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-2108?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Chen updated SAMZA-2108: Fix Version/s: (was: 1.0.1) 1.1 > Check for host affinity config before reso

[jira] [Updated] (SAMZA-2097) Allow table parts configuration generation

2019-03-06 Thread Daniel Chen (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-2097?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Chen updated SAMZA-2097: Fix Version/s: (was: 1.0.1) 1.1 > Allow table parts configuration generation

[jira] [Updated] (SAMZA-2081) Samza SQL : Type system for Samza SQL

2019-03-06 Thread Daniel Chen (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-2081?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Chen updated SAMZA-2081: Fix Version/s: (was: 1.0.1) 1.1 > Samza SQL : Type system for Samza SQL > -

[jira] [Updated] (SAMZA-2090) Fix flush behavior for remote and hybrid tables

2019-03-06 Thread Daniel Chen (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-2090?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Chen updated SAMZA-2090: Fix Version/s: (was: 1.0.1) 1.1 > Fix flush behavior for remote and hybrid t

[jira] [Updated] (SAMZA-2095) Fix flaky timeout error in TestZKUtils

2019-03-06 Thread Daniel Chen (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-2095?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Chen updated SAMZA-2095: Fix Version/s: (was: 1.0.1) 1.1 > Fix flaky timeout error in TestZKUtils > -

[jira] [Updated] (SAMZA-2076) RocksDbTableDescriptor should use Long type for TTL

2019-03-06 Thread Daniel Chen (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-2076?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Chen updated SAMZA-2076: Fix Version/s: (was: 1.0.1) 1.1 > RocksDbTableDescriptor should use Long typ

[jira] [Updated] (SAMZA-2072) Update guava to 23.0

2019-03-06 Thread Daniel Chen (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-2072?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Chen updated SAMZA-2072: Fix Version/s: (was: 1.0.1) 1.1 > Update guava to 23.0 > ---

[jira] [Updated] (SAMZA-2070) Upgrade calcite and add support for Arrays and maps

2019-03-06 Thread Daniel Chen (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-2070?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Chen updated SAMZA-2070: Fix Version/s: (was: 1.0.1) 1.1 > Upgrade calcite and add support for Arrays

[jira] [Updated] (SAMZA-2068) Separating container launch logic into util class

2019-03-06 Thread Daniel Chen (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-2068?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Chen updated SAMZA-2068: Fix Version/s: (was: 1.0.1) 1.1 > Separating container launch logic into uti

[jira] [Updated] (SAMZA-2061) Make fixes in Samza 1.0 documentation

2019-03-06 Thread Daniel Chen (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-2061?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Chen updated SAMZA-2061: Fix Version/s: (was: 1.0.1) 1.1 > Make fixes in Samza 1.0 documentation > -

[jira] [Updated] (SAMZA-2066) Refactor remote tables to separate various concerns

2019-03-06 Thread Daniel Chen (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-2066?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Chen updated SAMZA-2066: Fix Version/s: (was: 1.0.1) 1.1 > Refactor remote tables to separate various

[jira] [Updated] (SAMZA-2059) Create the configuration in coordinator stream for standalone.

2019-03-06 Thread Daniel Chen (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-2059?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Chen updated SAMZA-2059: Fix Version/s: (was: 1.0.1) 1.1 > Create the configuration in coordinator st

[jira] [Updated] (SAMZA-2012) Add API for wiring an external context through to application processing code

2019-03-06 Thread Daniel Chen (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-2012?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Chen updated SAMZA-2012: Fix Version/s: (was: 1.0.1) 1.1 > Add API for wiring an external context thr

[jira] [Updated] (SAMZA-2041) Add system descriptors for HDFS and Kinesis

2019-03-06 Thread Daniel Chen (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-2041?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Chen updated SAMZA-2041: Fix Version/s: (was: 1.0.1) 1.1 > Add system descriptors for HDFS and Kinesi

[jira] [Updated] (SAMZA-2026) Refactor remote table API to separate retry policy settings

2019-03-06 Thread Daniel Chen (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-2026?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Chen updated SAMZA-2026: Fix Version/s: (was: 1.0.1) 1.1 > Refactor remote table API to separate retr

[jira] [Updated] (SAMZA-1835) Consolidate all processorId generation code to StreamProcessor

2019-03-06 Thread Daniel Chen (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-1835?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Chen updated SAMZA-1835: Fix Version/s: (was: 1.0.1) 1.1 > Consolidate all processorId generation cod

[jira] [Updated] (SAMZA-1638) Recreate SystemProducer on KafkaCheckpointManager.writeCheckpoint failure.

2019-03-06 Thread Daniel Chen (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-1638?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Chen updated SAMZA-1638: Fix Version/s: (was: 1.0.1) 1.1 > Recreate SystemProducer on KafkaCheckpoint

[jira] [Resolved] (SAMZA-2108) Check for host affinity config before resolving preferred host matching

2019-02-25 Thread Daniel Chen (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-2108?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Chen resolved SAMZA-2108. - Resolution: Fixed > Check for host affinity config before resolving preferred host matching > ---

[jira] [Updated] (SAMZA-2108) Check for host affinity config before resolving preferred host matching

2019-02-25 Thread Daniel Chen (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-2108?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Chen updated SAMZA-2108: Fix Version/s: 1.0.1 > Check for host affinity config before resolving preferred host matching > --

[jira] [Created] (SAMZA-2108) Check for host affinity config before resolving preferred host matching

2019-02-19 Thread Daniel Chen (JIRA)
Daniel Chen created SAMZA-2108: --- Summary: Check for host affinity config before resolving preferred host matching Key: SAMZA-2108 URL: https://issues.apache.org/jira/browse/SAMZA-2108 Project: Samza

[jira] [Updated] (SAMZA-2095) Fix flaky timeout error in TestZKUtils

2019-02-01 Thread Daniel Chen (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-2095?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Chen updated SAMZA-2095: Description: We observed recurring build failures in LinkedIn build machines(not in local dev-setu

[jira] [Created] (SAMZA-2095) Fix flaky timeout error in TestZKUtils

2019-02-01 Thread Daniel Chen (JIRA)
Daniel Chen created SAMZA-2095: --- Summary: Fix flaky timeout error in TestZKUtils Key: SAMZA-2095 URL: https://issues.apache.org/jira/browse/SAMZA-2095 Project: Samza Issue Type: Bug

[jira] [Assigned] (SAMZA-1966) Get serdes configuration by name in SamzaContainer

2018-10-23 Thread Daniel Chen (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-1966?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Chen reassigned SAMZA-1966: --- Assignee: (was: Daniel Chen ) > Get serdes configuration by name in SamzaContainer > ---

[jira] [Created] (SAMZA-1966) Get serdes configuration by name in SamzaContainer

2018-10-23 Thread Daniel Chen (JIRA)
Daniel Chen created SAMZA-1966: --- Summary: Get serdes configuration by name in SamzaContainer Key: SAMZA-1966 URL: https://issues.apache.org/jira/browse/SAMZA-1966 Project: Samza Issue Type: Bu

[jira] [Resolved] (SAMZA-1956) Value Serde only in Event Hubs in/output descriptors

2018-10-17 Thread Daniel Chen (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-1956?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Chen resolved SAMZA-1956. - Resolution: Fixed > Value Serde only in Event Hubs in/output descriptors > --

[jira] [Created] (SAMZA-1956) Value Serde only in Event Hubs in/output descriptors

2018-10-16 Thread Daniel Chen (JIRA)
Daniel Chen created SAMZA-1956: --- Summary: Value Serde only in Event Hubs in/output descriptors Key: SAMZA-1956 URL: https://issues.apache.org/jira/browse/SAMZA-1956 Project: Samza Issue Type:

[jira] [Closed] (SAMZA-1900) Logging improvement: Changelog restore logs should log store name including task name/store path

2018-10-11 Thread Daniel Chen (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-1900?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Chen closed SAMZA-1900. --- > Logging improvement: Changelog restore logs should log store name including > task name/store path > -

[jira] [Closed] (SAMZA-1856) Implement system descriptors for Eventhubs

2018-10-11 Thread Daniel Chen (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-1856?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Chen closed SAMZA-1856. --- > Implement system descriptors for Eventhubs > -- > >

[jira] [Created] (SAMZA-1939) Improve Event Hubs connector configs

2018-10-08 Thread Daniel Chen (JIRA)
Daniel Chen created SAMZA-1939: --- Summary: Improve Event Hubs connector configs Key: SAMZA-1939 URL: https://issues.apache.org/jira/browse/SAMZA-1939 Project: Samza Issue Type: Improvement

[jira] [Created] (SAMZA-1900) Logging improvement: Changelog restore logs should log store name including task name/store path

2018-09-21 Thread Daniel Chen (JIRA)
Daniel Chen created SAMZA-1900: --- Summary: Logging improvement: Changelog restore logs should log store name including task name/store path Key: SAMZA-1900 URL: https://issues.apache.org/jira/browse/SAMZA-1900

[jira] [Closed] (SAMZA-1437) Samza integration with EventHub

2017-12-13 Thread Daniel Chen (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-1437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Chen closed SAMZA-1437. --- > Samza integration with EventHub > --- > > Key: SAMZA-1437 >

[jira] [Closed] (SAMZA-1532) Change EventhubSystemProducer destination stream source

2017-12-13 Thread Daniel Chen (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-1532?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Chen closed SAMZA-1532. --- > Change EventhubSystemProducer destination stream source > --

[jira] [Resolved] (SAMZA-1532) Change EventhubSystemProducer destination stream source

2017-12-13 Thread Daniel Chen (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-1532?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Chen resolved SAMZA-1532. - Resolution: Fixed > Change EventhubSystemProducer destination stream source >

[jira] [Resolved] (SAMZA-1437) Samza integration with EventHub

2017-12-13 Thread Daniel Chen (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-1437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Chen resolved SAMZA-1437. - Resolution: Fixed > Samza integration with EventHub > --- > >

[jira] [Closed] (SAMZA-1485) Make eventData creation extensible. Add interceptor tests

2017-12-13 Thread Daniel Chen (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-1485?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Chen closed SAMZA-1485. --- > Make eventData creation extensible. Add interceptor tests >

[jira] [Resolved] (SAMZA-1485) Make eventData creation extensible. Add interceptor tests

2017-12-13 Thread Daniel Chen (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-1485?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Chen resolved SAMZA-1485. - Resolution: Fixed > Make eventData creation extensible. Add interceptor tests > --

[jira] [Closed] (SAMZA-1486) Implement a Checkpoint Provider for Azure Tables

2017-12-13 Thread Daniel Chen (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-1486?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Chen closed SAMZA-1486. --- > Implement a Checkpoint Provider for Azure Tables > > >

[jira] [Resolved] (SAMZA-1486) Implement a Checkpoint Provider for Azure Tables

2017-12-13 Thread Daniel Chen (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-1486?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Chen resolved SAMZA-1486. - Resolution: Fixed > Implement a Checkpoint Provider for Azure Tables > ---

[jira] [Resolved] (SAMZA-1438) Implement the SystemProducer, SystemConsumer and SystemAdmin interfaces for EventHubs

2017-12-13 Thread Daniel Chen (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-1438?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Chen resolved SAMZA-1438. - Resolution: Fixed > Implement the SystemProducer, SystemConsumer and SystemAdmin interfaces for >

[jira] [Closed] (SAMZA-1438) Implement the SystemProducer, SystemConsumer and SystemAdmin interfaces for EventHubs

2017-12-13 Thread Daniel Chen (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-1438?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Chen closed SAMZA-1438. --- > Implement the SystemProducer, SystemConsumer and SystemAdmin interfaces for > EventHubs > -

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

2017-12-13 Thread Daniel Chen (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-1525?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Chen closed SAMZA-1525. --- > Provide EventHub documentation > -- > > Key: SAMZA-1525 >

[jira] [Closed] (SAMZA-1524) Create EventHub example in Hello Samza

2017-12-11 Thread Daniel Chen (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-1524?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Chen closed SAMZA-1524. --- > Create EventHub example in Hello Samza > -- > > Key:

[jira] [Created] (SAMZA-1532) Change EventhubSystemProducer destination stream source

2017-12-11 Thread Daniel Chen (JIRA)
Daniel Chen created SAMZA-1532: --- Summary: Change EventhubSystemProducer destination stream source Key: SAMZA-1532 URL: https://issues.apache.org/jira/browse/SAMZA-1532 Project: Samza Issue Typ

[jira] [Updated] (SAMZA-1532) Change EventhubSystemProducer destination stream source

2017-12-11 Thread Daniel Chen (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-1532?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Chen updated SAMZA-1532: Fix Version/s: 0.14.0 > Change EventhubSystemProducer destination stream source > --

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

2017-12-05 Thread Daniel Chen (JIRA)
Daniel Chen created SAMZA-1525: --- Summary: Provide EventHub documentation Key: SAMZA-1525 URL: https://issues.apache.org/jira/browse/SAMZA-1525 Project: Samza Issue Type: Sub-task R

[jira] [Created] (SAMZA-1524) Create EventHub example in Hello Samza

2017-12-05 Thread Daniel Chen (JIRA)
Daniel Chen created SAMZA-1524: --- Summary: Create EventHub example in Hello Samza Key: SAMZA-1524 URL: https://issues.apache.org/jira/browse/SAMZA-1524 Project: Samza Issue Type: Sub-task

[jira] [Assigned] (SAMZA-1437) Samza integration with EventHub

2017-11-13 Thread Daniel Chen (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-1437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Chen reassigned SAMZA-1437: --- Assignee: Daniel Chen > Samza integration with EventHub > --- >

[jira] [Assigned] (SAMZA-1485) Make eventData creation extensible. Add interceptor tests

2017-11-13 Thread Daniel Chen (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-1485?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Chen reassigned SAMZA-1485: --- Assignee: Daniel Chen > Make eventData creation extensible. Add interceptor tests >

  1   2   >