[jira] [Updated] (SAMZA-816) LocalityManager.register() should not register coordinator stream SystemConsumer in SamzaContainer context

[ https://issues.apache.org/jira/browse/SAMZA-816?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Pan (Data Infrastructure) updated SAMZA-816: --- Attachment: SAMZA-816-1.patch > LocalityManager.register() should not

[jira] [Commented] (SAMZA-816) LocalityManager.register() should not register coordinator stream SystemConsumer in SamzaContainer context

[ https://issues.apache.org/jira/browse/SAMZA-816?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15015471#comment-15015471 ] Yi Pan (Data Infrastructure) commented on SAMZA-816: Per comments from RB, merged and

[jira] [Commented] (SAMZA-767) yarn.queue option is not used anywhere

[ https://issues.apache.org/jira/browse/SAMZA-767?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15014129#comment-15014129 ] Yi Pan (Data Infrastructure) commented on SAMZA-767: Hi, [~a.pejakovic], left a minor

[jira] [Commented] (SAMZA-661) Provide docs for default serde names

[ https://issues.apache.org/jira/browse/SAMZA-661?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15014211#comment-15014211 ] Yi Pan (Data Infrastructure) commented on SAMZA-661: +1. Merged and submitted. Thanks!

[jira] [Assigned] (SAMZA-772) Kafka in-memory buffer may cause OOM: Heap Space errors

[ https://issues.apache.org/jira/browse/SAMZA-772?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Pan (Data Infrastructure) reassigned SAMZA-772: -- Assignee: Yi Pan (Data Infrastructure) > Kafka in-memory buffer

[jira] [Updated] (SAMZA-772) Kafka in-memory buffer may cause OOM: Heap Space errors

[ https://issues.apache.org/jira/browse/SAMZA-772?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Pan (Data Infrastructure) updated SAMZA-772: --- Fix Version/s: (was: 0.10.0) > Kafka in-memory buffer may cause

[jira] [Updated] (SAMZA-772) Kafka in-memory buffer may cause OOM: Heap Space errors

[ https://issues.apache.org/jira/browse/SAMZA-772?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Pan (Data Infrastructure) updated SAMZA-772: --- Fix Version/s: 0.10.0 > Kafka in-memory buffer may cause OOM: Heap

[jira] [Updated] (SAMZA-41) Support static partition assignment in LocalJobFactory

[ https://issues.apache.org/jira/browse/SAMZA-41?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Pan (Data Infrastructure) updated SAMZA-41: -- Fix Version/s: 0.10.0 > Support static partition assignment in

[jira] [Commented] (SAMZA-788) coordinator stream configuration should not guess the system names

[ https://issues.apache.org/jira/browse/SAMZA-788?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15014041#comment-15014041 ] Yi Pan (Data Infrastructure) commented on SAMZA-788: +1. RB lgtm, except one minor

[jira] [Commented] (SAMZA-41) Support static partition assignment in LocalJobFactory

[ https://issues.apache.org/jira/browse/SAMZA-41?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15014427#comment-15014427 ] Yi Pan (Data Infrastructure) commented on SAMZA-41: --- [~mdaxini], any update? Thanks! >

[jira] [Commented] (SAMZA-772) Kafka in-memory buffer may cause OOM: Heap Space errors

[ https://issues.apache.org/jira/browse/SAMZA-772?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15014422#comment-15014422 ] Yi Pan (Data Infrastructure) commented on SAMZA-772: Hi, [~mdaxini], thanks a lot. You

[jira] [Commented] (SAMZA-775) Specify prefetch buffer in terms of bytes rather than count using fetchThreshold

[ https://issues.apache.org/jira/browse/SAMZA-775?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15014425#comment-15014425 ] Yi Pan (Data Infrastructure) commented on SAMZA-775: Hi, [~mdaxini], as discussed in

[jira] [Commented] (SAMZA-41) Support static partition assignment in LocalJobFactory

[ https://issues.apache.org/jira/browse/SAMZA-41?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15014741#comment-15014741 ] Yi Pan (Data Infrastructure) commented on SAMZA-41: --- Hi, [~mdaxini], did you mean that

[jira] [Commented] (SAMZA-775) Specify prefetch buffer in terms of bytes rather than count using fetchThreshold

[ https://issues.apache.org/jira/browse/SAMZA-775?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15014746#comment-15014746 ] Yi Pan (Data Infrastructure) commented on SAMZA-775: [~mdaxini], thanks! I will work on

[jira] [Updated] (SAMZA-775) Specify prefetch buffer in terms of bytes rather than count using fetchThreshold

[ https://issues.apache.org/jira/browse/SAMZA-775?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Pan (Data Infrastructure) updated SAMZA-775: --- Fix Version/s: 0.10.0 > Specify prefetch buffer in terms of bytes

[jira] [Commented] (SAMZA-41) Support static partition assignment in LocalJobFactory

[ https://issues.apache.org/jira/browse/SAMZA-41?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15011609#comment-15011609 ] Yi Pan (Data Infrastructure) commented on SAMZA-41: --- [~mdaxini], did you get a chance to

[jira] [Commented] (SAMZA-818) Jython support

[ https://issues.apache.org/jira/browse/SAMZA-818?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15011602#comment-15011602 ] Yi Pan (Data Infrastructure) commented on SAMZA-818: [~toidi], that's awesome! We will

[jira] [Commented] (SAMZA-772) Kafka in-memory buffer may cause OOM: Heap Space errors

[ https://issues.apache.org/jira/browse/SAMZA-772?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15011607#comment-15011607 ] Yi Pan (Data Infrastructure) commented on SAMZA-772: [~mdaxini], I thought that Netflix

[jira] [Updated] (SAMZA-353) Support assigning the same SSP to multiple tasknames

[ https://issues.apache.org/jira/browse/SAMZA-353?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Pan (Data Infrastructure) updated SAMZA-353: --- Fix Version/s: (was: 0.10.0) > Support assigning the same SSP to

[jira] [Updated] (SAMZA-689) When Kafka has topic auto-creation turned on, checkpoint topics may be created w/ wrong partition numbers

[ https://issues.apache.org/jira/browse/SAMZA-689?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Pan (Data Infrastructure) updated SAMZA-689: --- Fix Version/s: (was: 0.10.0) > When Kafka has topic auto-creation

[jira] [Updated] (SAMZA-788) coordinator stream configuration should not guess the system names

[ https://issues.apache.org/jira/browse/SAMZA-788?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Pan (Data Infrastructure) updated SAMZA-788: --- Priority: Minor (was: Major) > coordinator stream configuration

[jira] [Updated] (SAMZA-788) coordinator stream configuration should not guess the system names

[ https://issues.apache.org/jira/browse/SAMZA-788?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Pan (Data Infrastructure) updated SAMZA-788: --- Fix Version/s: (was: 0.10.0) > coordinator stream configuration

[jira] [Commented] (SAMZA-788) coordinator stream configuration should not guess the system names

[ https://issues.apache.org/jira/browse/SAMZA-788?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15011748#comment-15011748 ] Yi Pan (Data Infrastructure) commented on SAMZA-788: This is not urgent for 0.10. Move

[jira] [Updated] (SAMZA-816) LocalityManager.register() should not register coordinator stream SystemConsumer in SamzaContainer context

[ https://issues.apache.org/jira/browse/SAMZA-816?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Pan (Data Infrastructure) updated SAMZA-816: --- Fix Version/s: 0.10.0 > LocalityManager.register() should not register

[jira] [Updated] (SAMZA-754) Race condition between coordinator stream producer and coordinator stream consumer in JobRunner

[ https://issues.apache.org/jira/browse/SAMZA-754?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Pan (Data Infrastructure) updated SAMZA-754: --- Labels: (was: patch-available) > Race condition between coordinator

[jira] [Updated] (SAMZA-754) Race condition between coordinator stream producer and coordinator stream consumer in JobRunner

[ https://issues.apache.org/jira/browse/SAMZA-754?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Pan (Data Infrastructure) updated SAMZA-754: --- Labels: patch-available (was: ) > Race condition between coordinator

[jira] [Updated] (SAMZA-754) Race condition between coordinator stream producer and coordinator stream consumer in JobRunner

[ https://issues.apache.org/jira/browse/SAMZA-754?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Pan (Data Infrastructure) updated SAMZA-754: --- Attachment: SAMZA-754-0.patch > Race condition between coordinator

[jira] [Commented] (SAMZA-614) Document coordinator stream

[ https://issues.apache.org/jira/browse/SAMZA-614?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15011739#comment-15011739 ] Yi Pan (Data Infrastructure) commented on SAMZA-614: [~navina], do you want to take

[jira] [Updated] (SAMZA-348) Configure Samza jobs through a stream

[ https://issues.apache.org/jira/browse/SAMZA-348?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Pan (Data Infrastructure) updated SAMZA-348: --- Fix Version/s: (was: 0.10.0) > Configure Samza jobs through a

[jira] [Commented] (SAMZA-816) LocalityManager.register() should not register coordinator stream SystemConsumer in SamzaContainer context

[ https://issues.apache.org/jira/browse/SAMZA-816?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15011756#comment-15011756 ] Yi Pan (Data Infrastructure) commented on SAMZA-816: Need this in 0.10 since this

[jira] [Assigned] (SAMZA-816) LocalityManager.register() should not register coordinator stream SystemConsumer in SamzaContainer context

[ https://issues.apache.org/jira/browse/SAMZA-816?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Pan (Data Infrastructure) reassigned SAMZA-816: -- Assignee: Yi Pan (Data Infrastructure) >

[jira] [Created] (SAMZA-819) RocksDbKeyValueStore.flush() should be implemented

Yi Pan (Data Infrastructure) created SAMZA-819: -- Summary: RocksDbKeyValueStore.flush() should be implemented Key: SAMZA-819 URL: https://issues.apache.org/jira/browse/SAMZA-819 Project:

[jira] [Commented] (SAMZA-819) RocksDbKeyValueStore.flush() should be implemented

[ https://issues.apache.org/jira/browse/SAMZA-819?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15013054#comment-15013054 ] Yi Pan (Data Infrastructure) commented on SAMZA-819: [~TaoFeng], assigned to you.

[jira] [Commented] (SAMZA-817) Add metrics to gauge effectiveness of host-affinity solution

[ https://issues.apache.org/jira/browse/SAMZA-817?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15013065#comment-15013065 ] Yi Pan (Data Infrastructure) commented on SAMZA-817: +1. Feel free to commit. Thanks!

[jira] [Updated] (SAMZA-819) RocksDbKeyValueStore.flush() should be implemented

[ https://issues.apache.org/jira/browse/SAMZA-819?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Pan (Data Infrastructure) updated SAMZA-819: --- Assignee: Tao > RocksDbKeyValueStore.flush() should be implemented >

[jira] [Updated] (SAMZA-816) LocalityManager.register() should not register coordinator stream SystemConsumer in SamzaContainer context

[ https://issues.apache.org/jira/browse/SAMZA-816?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Pan (Data Infrastructure) updated SAMZA-816: --- Attachment: SAMZA-816-0.patch > LocalityManager.register() should not

[jira] [Commented] (SAMZA-816) LocalityManager.register() should not register coordinator stream SystemConsumer in SamzaContainer context

[ https://issues.apache.org/jira/browse/SAMZA-816?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15013094#comment-15013094 ] Yi Pan (Data Infrastructure) commented on SAMZA-816: RB available:

[jira] [Commented] (SAMZA-754) Race condition between coordinator stream producer and coordinator stream consumer in JobRunner

[ https://issues.apache.org/jira/browse/SAMZA-754?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1500#comment-1500 ] Yi Pan (Data Infrastructure) commented on SAMZA-754: RB available:

[jira] [Assigned] (SAMZA-754) Race condition between coordinator stream producer and coordinator stream consumer in JobRunner

[ https://issues.apache.org/jira/browse/SAMZA-754?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Pan (Data Infrastructure) reassigned SAMZA-754: -- Assignee: Yi Pan (Data Infrastructure) > Race condition between

[jira] [Commented] (SAMZA-754) Race condition between coordinator stream producer and coordinator stream consumer in JobRunner

[ https://issues.apache.org/jira/browse/SAMZA-754?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15009670#comment-15009670 ] Yi Pan (Data Infrastructure) commented on SAMZA-754: Noticed that [~criccomini] has

[jira] [Commented] (SAMZA-754) Race condition between coordinator stream producer and coordinator stream consumer in JobRunner

[ https://issues.apache.org/jira/browse/SAMZA-754?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15009562#comment-15009562 ] Yi Pan (Data Infrastructure) commented on SAMZA-754: Turns out that this is related to

[jira] [Commented] (SAMZA-560) StreamAppender not working after upgrading kafka producer API

[ https://issues.apache.org/jira/browse/SAMZA-560?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15002569#comment-15002569 ] Yi Pan (Data Infrastructure) commented on SAMZA-560: [~cpsoman], as SAMZA-723 is fixed,

[jira] [Commented] (SAMZA-812) CachedStore flushes too often

[ https://issues.apache.org/jira/browse/SAMZA-812?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1566#comment-1566 ] Yi Pan (Data Infrastructure) commented on SAMZA-812: Overall LGTM. Left one comment on

[jira] [Updated] (SAMZA-810) add list-yarn-job.sh script

[ https://issues.apache.org/jira/browse/SAMZA-810?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Pan (Data Infrastructure) updated SAMZA-810: --- Fix Version/s: 0.10.0 > add list-yarn-job.sh script >

[jira] [Commented] (SAMZA-783) Unable to connect to Job coordinator server

[ https://issues.apache.org/jira/browse/SAMZA-783?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14996102#comment-14996102 ] Yi Pan (Data Infrastructure) commented on SAMZA-783: [~afilipchik] and

[jira] [Updated] (SAMZA-802) KafkaSystemAdmin needs to handle empty topic offsets

[ https://issues.apache.org/jira/browse/SAMZA-802?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Pan (Data Infrastructure) updated SAMZA-802: --- Summary: KafkaSystemAdmin needs to handle empty topic offsets (was:

[jira] [Commented] (SAMZA-801) MetricsSnapshotReporter cannot tolerate errors

[ https://issues.apache.org/jira/browse/SAMZA-801?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14978917#comment-14978917 ] Yi Pan (Data Infrastructure) commented on SAMZA-801: [~theduderog], thanks for

[jira] [Commented] (SAMZA-801) MetricsSnapshotReporter cannot tolerate errors

[ https://issues.apache.org/jira/browse/SAMZA-801?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14979873#comment-14979873 ] Yi Pan (Data Infrastructure) commented on SAMZA-801: Hi, [~theduderog], I was referring

[jira] [Commented] (SAMZA-723) hello-samza hangs when we use StreamAppender

[ https://issues.apache.org/jira/browse/SAMZA-723?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14976929#comment-14976929 ] Yi Pan (Data Infrastructure) commented on SAMZA-723: +1. Thanks! > hello-samza hangs

[jira] [Updated] (SAMZA-798) Performance and stability issue after combining checkpoint and coordinator stream

[ https://issues.apache.org/jira/browse/SAMZA-798?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Pan (Data Infrastructure) updated SAMZA-798: --- Fix Version/s: 0.10.0 > Performance and stability issue after

[jira] [Updated] (SAMZA-793) Configure rewriter should be moved back to JobRunner

[ https://issues.apache.org/jira/browse/SAMZA-793?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Pan (Data Infrastructure) updated SAMZA-793: --- Flags: Patch > Configure rewriter should be moved back to JobRunner >

[jira] [Commented] (SAMZA-796) "task.broadcast.inputs" is incorrectly documented as task.global.inputs

[ https://issues.apache.org/jira/browse/SAMZA-796?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14970101#comment-14970101 ] Yi Pan (Data Infrastructure) commented on SAMZA-796: +1. Merged and submitted. >

[jira] [Commented] (SAMZA-797) "task.broadcast.inputs" does not support stream names with periods in them

[ https://issues.apache.org/jira/browse/SAMZA-797?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14970133#comment-14970133 ] Yi Pan (Data Infrastructure) commented on SAMZA-797: +1, merged and submitted. Thanks!

[jira] [Commented] (SAMZA-793) Configure rewriter should be moved back to JobRunner

[ https://issues.apache.org/jira/browse/SAMZA-793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14970158#comment-14970158 ] Yi Pan (Data Infrastructure) commented on SAMZA-793: RB:

[jira] [Updated] (SAMZA-793) Configure rewriter should be moved back to JobRunner

[ https://issues.apache.org/jira/browse/SAMZA-793?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Pan (Data Infrastructure) updated SAMZA-793: --- Attachment: SAMZA-793-0.patch > Configure rewriter should be moved

[jira] [Created] (SAMZA-798) Performance and stability issue after combining checkpoint and coordinator stream

Yi Pan (Data Infrastructure) created SAMZA-798: -- Summary: Performance and stability issue after combining checkpoint and coordinator stream Key: SAMZA-798 URL:

[jira] [Commented] (SAMZA-747) Release RocksDB 3.11.1 java package

[ https://issues.apache.org/jira/browse/SAMZA-747?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14959903#comment-14959903 ] Yi Pan (Data Infrastructure) commented on SAMZA-747: +1. Thanks! > Release RocksDB

[jira] [Commented] (SAMZA-423) Add document store to Samza

[ https://issues.apache.org/jira/browse/SAMZA-423?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14955428#comment-14955428 ] Yi Pan (Data Infrastructure) commented on SAMZA-423: Hi, [~rzuljevic], [~closeuris] is

[jira] [Created] (SAMZA-793) Configure rewriter should be moved back to JobRunner

Yi Pan (Data Infrastructure) created SAMZA-793: -- Summary: Configure rewriter should be moved back to JobRunner Key: SAMZA-793 URL: https://issues.apache.org/jira/browse/SAMZA-793 Project:

[jira] [Assigned] (SAMZA-793) Configure rewriter should be moved back to JobRunner

[ https://issues.apache.org/jira/browse/SAMZA-793?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Pan (Data Infrastructure) reassigned SAMZA-793: -- Assignee: Yi Pan (Data Infrastructure) > Configure rewriter

[jira] [Commented] (SAMZA-789) CoordinatorStreamSystemConsumer should not register the coordinator stream partition after the SystemConsumer has already started

[ https://issues.apache.org/jira/browse/SAMZA-789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14950045#comment-14950045 ] Yi Pan (Data Infrastructure) commented on SAMZA-789: Thanks! Merged and submitted. >

[jira] [Commented] (SAMZA-784) Posible installation bug in version 0.10.0

[ https://issues.apache.org/jira/browse/SAMZA-784?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14949447#comment-14949447 ] Yi Pan (Data Infrastructure) commented on SAMZA-784: Hi, [~jblasi], this error is the

[jira] [Resolved] (SAMZA-786) Improve reliability of multithreaded host affinity tests.

[ https://issues.apache.org/jira/browse/SAMZA-786?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Pan (Data Infrastructure) resolved SAMZA-786. Resolution: Fixed Fix Version/s: 0.10.0 > Improve reliability

[jira] [Commented] (SAMZA-786) Improve reliability of multithreaded host affinity tests.

[ https://issues.apache.org/jira/browse/SAMZA-786?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14946077#comment-14946077 ] Yi Pan (Data Infrastructure) commented on SAMZA-786: +1. Merged and submitted. Thanks!

[jira] [Created] (SAMZA-789) CoordinatorStreamSystemConsumer should not register the coordinator stream partition after the SystemConsumer has already started

Yi Pan (Data Infrastructure) created SAMZA-789: -- Summary: CoordinatorStreamSystemConsumer should not register the coordinator stream partition after the SystemConsumer has already started Key: SAMZA-789

[jira] [Created] (SAMZA-790) SystemConsumer should have more rigorous runtime state management during the life-cycle

Yi Pan (Data Infrastructure) created SAMZA-790: -- Summary: SystemConsumer should have more rigorous runtime state management during the life-cycle Key: SAMZA-790 URL:

[jira] [Updated] (SAMZA-789) CoordinatorStreamSystemConsumer should not register the coordinator stream partition after the SystemConsumer has already started

[ https://issues.apache.org/jira/browse/SAMZA-789?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Pan (Data Infrastructure) updated SAMZA-789: --- Attachment: SAMZA-789-0.patch RB is online as well:

[jira] [Created] (SAMZA-787) task.log4j.system should not be guessed if not configured

Yi Pan (Data Infrastructure) created SAMZA-787: -- Summary: task.log4j.system should not be guessed if not configured Key: SAMZA-787 URL: https://issues.apache.org/jira/browse/SAMZA-787

[jira] [Created] (SAMZA-788) coordinator stream configuration should not guess the system names

Yi Pan (Data Infrastructure) created SAMZA-788: -- Summary: coordinator stream configuration should not guess the system names Key: SAMZA-788 URL: https://issues.apache.org/jira/browse/SAMZA-788

[jira] [Updated] (SAMZA-788) coordinator stream configuration should not guess the system names

[ https://issues.apache.org/jira/browse/SAMZA-788?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Pan (Data Infrastructure) updated SAMZA-788: --- Fix Version/s: 0.10.0 > coordinator stream configuration should not

[jira] [Assigned] (SAMZA-788) coordinator stream configuration should not guess the system names

[ https://issues.apache.org/jira/browse/SAMZA-788?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Pan (Data Infrastructure) reassigned SAMZA-788: -- Assignee: Yi Pan (Data Infrastructure) > coordinator stream

[jira] [Commented] (SAMZA-341) Support metrics report via Ganglia

[ https://issues.apache.org/jira/browse/SAMZA-341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14940322#comment-14940322 ] Yi Pan (Data Infrastructure) commented on SAMZA-341: Hi, [~a.pejakovic], thanks for

[jira] [Updated] (SAMZA-769) Replace deprecated method call and fix warnings

[ https://issues.apache.org/jira/browse/SAMZA-769?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Pan (Data Infrastructure) updated SAMZA-769: --- Fix Version/s: 0.10.0 > Replace deprecated method call and fix

[jira] [Assigned] (SAMZA-341) Support metrics report via Ganglia

[ https://issues.apache.org/jira/browse/SAMZA-341?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Pan (Data Infrastructure) reassigned SAMZA-341: -- Assignee: Yi Pan (Data Infrastructure) (was: Aleksandar

[jira] [Commented] (SAMZA-560) StreamAppender not working after upgrading kafka producer API

[ https://issues.apache.org/jira/browse/SAMZA-560?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14940369#comment-14940369 ] Yi Pan (Data Infrastructure) commented on SAMZA-560: I think that this issue is a dup

[jira] [Commented] (SAMZA-763) Organise imports in scala packages

[ https://issues.apache.org/jira/browse/SAMZA-763?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14940326#comment-14940326 ] Yi Pan (Data Infrastructure) commented on SAMZA-763: [~a.pejakovic], I agree with

[jira] [Commented] (SAMZA-762) java arrays not usable as keys anymore

[ https://issues.apache.org/jira/browse/SAMZA-762?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14940348#comment-14940348 ] Yi Pan (Data Infrastructure) commented on SAMZA-762: Based on the discussion above, put

[jira] [Commented] (SAMZA-626) Read KV state store for a running job

[ https://issues.apache.org/jira/browse/SAMZA-626?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14940397#comment-14940397 ] Yi Pan (Data Infrastructure) commented on SAMZA-626: Hi, [~closeuris], I added a few

[jira] [Commented] (SAMZA-333) Large samza configurations results in yarn job failure

[ https://issues.apache.org/jira/browse/SAMZA-333?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14936936#comment-14936936 ] Yi Pan (Data Infrastructure) commented on SAMZA-333: Since coordinator stream has been

[jira] [Commented] (SAMZA-778) KafkaCheckpointMigration should not start/stop the same instance of CoordinatorStreamSystemConsumer multiple times

[ https://issues.apache.org/jira/browse/SAMZA-778?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14933616#comment-14933616 ] Yi Pan (Data Infrastructure) commented on SAMZA-778: Merged and submitted. Thanks! >

[jira] [Commented] (SAMZA-563) Upgrade Samza to YARN 2.6.0 and 2.7.1

[ https://issues.apache.org/jira/browse/SAMZA-563?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14908433#comment-14908433 ] Yi Pan (Data Infrastructure) commented on SAMZA-563: Got +1 from [~navina] on the

[jira] [Created] (SAMZA-778) KafkaCheckpointMigration should not start/stop the same instance of CoordinatorStreamSystemConsumer multiple times

Yi Pan (Data Infrastructure) created SAMZA-778: -- Summary: KafkaCheckpointMigration should not start/stop the same instance of CoordinatorStreamSystemConsumer multiple times Key: SAMZA-778 URL:

[jira] [Commented] (SAMZA-777) Samza AM REST API not reachable from RM REST API, and not versioned

[ https://issues.apache.org/jira/browse/SAMZA-777?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14908787#comment-14908787 ] Yi Pan (Data Infrastructure) commented on SAMZA-777: Hi, [~llamahunter], it seems to be

[jira] [Updated] (SAMZA-778) KafkaCheckpointMigration should not start/stop the same instance of CoordinatorStreamSystemConsumer multiple times

[ https://issues.apache.org/jira/browse/SAMZA-778?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Pan (Data Infrastructure) updated SAMZA-778: --- Attachment: SAMZA-778-0.patch Verified by running local migration of

[jira] [Commented] (SAMZA-777) Samza AM REST API not reachable from RM REST API, and not versioned

[ https://issues.apache.org/jira/browse/SAMZA-777?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14908960#comment-14908960 ] Yi Pan (Data Infrastructure) commented on SAMZA-777: Hi, [~llamahunter], RB=reviewboard

[jira] [Commented] (SAMZA-615) Migrate checkpoint from checkpoint topic to Coordinator stream

[ https://issues.apache.org/jira/browse/SAMZA-615?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14907077#comment-14907077 ] Yi Pan (Data Infrastructure) commented on SAMZA-615: Thanks! Merged and submitted. >

[jira] [Resolved] (SAMZA-615) Migrate checkpoint from checkpoint topic to Coordinator stream

[ https://issues.apache.org/jira/browse/SAMZA-615?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Pan (Data Infrastructure) resolved SAMZA-615. Resolution: Fixed > Migrate checkpoint from checkpoint topic to

[jira] [Commented] (SAMZA-563) Upgrade Samza to YARN 2.6.0

[ https://issues.apache.org/jira/browse/SAMZA-563?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14905129#comment-14905129 ] Yi Pan (Data Infrastructure) commented on SAMZA-563: Cool. I just post a closing VOTE

[jira] [Commented] (SAMZA-615) Migrate checkpoint from checkpoint topic to Coordinator stream

[ https://issues.apache.org/jira/browse/SAMZA-615?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14905655#comment-14905655 ] Yi Pan (Data Infrastructure) commented on SAMZA-615: [~navina] and [~closeuris], could

[jira] [Updated] (SAMZA-615) Migrate checkpoint from checkpoint topic to Coordinator stream

[ https://issues.apache.org/jira/browse/SAMZA-615?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Pan (Data Infrastructure) updated SAMZA-615: --- Attachment: SAMZA-615-1.patch RB: https://reviews.apache.org/r/38614

[jira] [Commented] (SAMZA-731) CoordinatorStream Equality not working

[ https://issues.apache.org/jira/browse/SAMZA-731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14903066#comment-14903066 ] Yi Pan (Data Infrastructure) commented on SAMZA-731: +1. Merged and committed. Thanks!

[jira] [Updated] (SAMZA-731) CoordinatorStream Equality not working

[ https://issues.apache.org/jira/browse/SAMZA-731?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Pan (Data Infrastructure) updated SAMZA-731: --- Fix Version/s: 0.10.0 > CoordinatorStream Equality not working >

[jira] [Updated] (SAMZA-615) Migrate checkpoint from checkpoint topic to Coordinator stream

[ https://issues.apache.org/jira/browse/SAMZA-615?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Pan (Data Infrastructure) updated SAMZA-615: --- Attachment: SAMZA-615-2.patch Fixed an intermittent unit test failure

[jira] [Commented] (SAMZA-563) Upgrade Samza to YARN 2.6.0

[ https://issues.apache.org/jira/browse/SAMZA-563?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14903716#comment-14903716 ] Yi Pan (Data Infrastructure) commented on SAMZA-563: Hi, [~a.pejakovic], I tried the

[jira] [Commented] (SAMZA-747) Release RocksDB 3.11.1 java package

[ https://issues.apache.org/jira/browse/SAMZA-747?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14746234#comment-14746234 ] Yi Pan (Data Infrastructure) commented on SAMZA-747: Taking ownership of the ticket for

[jira] [Resolved] (SAMZA-765) Update samza-hello-samza README.md to include the step of publish the latest samza packages to maven local

[ https://issues.apache.org/jira/browse/SAMZA-765?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Pan (Data Infrastructure) resolved SAMZA-765. Resolution: Fixed Fix Version/s: 0.10.0 > Update

[jira] [Updated] (SAMZA-725) Fix RELEASE.md document

[ https://issues.apache.org/jira/browse/SAMZA-725?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Pan (Data Infrastructure) updated SAMZA-725: --- Attachment: SAMZA-725-1.patch > Fix RELEASE.md document >

[jira] [Commented] (SAMZA-725) Fix RELEASE.md document

[ https://issues.apache.org/jira/browse/SAMZA-725?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14726343#comment-14726343 ] Yi Pan (Data Infrastructure) commented on SAMZA-725: [~navina], thanks! Merged and

[jira] [Updated] (SAMZA-765) Update samza-hello-samza README.md to include the step of publish the latest samza packages to maven local

[ https://issues.apache.org/jira/browse/SAMZA-765?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Pan (Data Infrastructure) updated SAMZA-765: --- Attachment: SAMZA-765-1.patch Updated based on review comments. >

[jira] [Resolved] (SAMZA-764) Change java version in hello-samza

[ https://issues.apache.org/jira/browse/SAMZA-764?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Pan (Data Infrastructure) resolved SAMZA-764. Resolution: Fixed Fix Version/s: 0.10.0 Change java version

<    1   2   3   4   5   6   7   8   >