[jira] [Commented] (SAMZA-697) Isolate Class Loader for user implemented Tasks

[ https://issues.apache.org/jira/browse/SAMZA-697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14698111#comment-14698111 ] Guozhang Wang commented on SAMZA-697: - Sure, go ahead. > Isolate Class Loader for user

[jira] [Commented] (SAMZA-697) Isolate Class Loader for user implemented Tasks

[ https://issues.apache.org/jira/browse/SAMZA-697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14608813#comment-14608813 ] Guozhang Wang commented on SAMZA-697: - Updated https://reviews.apache.org/r/35397/ addr

[jira] [Updated] (SAMZA-697) Isolate Class Loader for user implemented Tasks

[ https://issues.apache.org/jira/browse/SAMZA-697?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated SAMZA-697: Attachment: SAMZA-697.v2.patch > Isolate Class Loader for user implemented Tasks > --

[jira] [Commented] (SAMZA-697) Isolate Class Loader for user implemented Tasks

[ https://issues.apache.org/jira/browse/SAMZA-697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14592288#comment-14592288 ] Guozhang Wang commented on SAMZA-697: - [~closeuris] Thanks! I have addressed those and

[jira] [Commented] (SAMZA-557) Reuse local state in SamzaContainer on clean shutdown

[ https://issues.apache.org/jira/browse/SAMZA-557?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14592192#comment-14592192 ] Guozhang Wang commented on SAMZA-557: - I am wondering if we have already deprecated Jav

[jira] [Resolved] (SAMZA-662) Samza auto-creates changelog stream without sufficient partitions when container number > 1

[ https://issues.apache.org/jira/browse/SAMZA-662?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved SAMZA-662. - Resolution: Fixed > Samza auto-creates changelog stream without sufficient partitions when > conta

[jira] [Updated] (SAMZA-715) Add Yi and Guozhang's PGP Key to KEYS

[ https://issues.apache.org/jira/browse/SAMZA-715?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated SAMZA-715: Fix Version/s: (was: 0.9.1) > Add Yi and Guozhang's PGP Key to KEYS > ---

[jira] [Updated] (SAMZA-714) Prepare release candidate for 0.9.1

[ https://issues.apache.org/jira/browse/SAMZA-714?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated SAMZA-714: Attachment: SAMZA-714-0.9.1-changes.patch > Prepare release candidate for 0.9.1 > ---

[jira] [Updated] (SAMZA-715) Add Yi and Guozhang's PGP Key to KEYS

[ https://issues.apache.org/jira/browse/SAMZA-715?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated SAMZA-715: Attachment: KEYS.guozhang > Add Yi and Guozhang's PGP Key to KEYS > -

[jira] [Created] (SAMZA-715) Add Yi and Guozhang's PGP Key to KEYS

Guozhang Wang created SAMZA-715: --- Summary: Add Yi and Guozhang's PGP Key to KEYS Key: SAMZA-715 URL: https://issues.apache.org/jira/browse/SAMZA-715 Project: Samza Issue Type: Bug R

[jira] [Commented] (SAMZA-714) Change version in ./gradle.properties to 0.9.1

[ https://issues.apache.org/jira/browse/SAMZA-714?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14590662#comment-14590662 ] Guozhang Wang commented on SAMZA-714: - Sure I can do that. Some other questions about r

[jira] [Updated] (SAMZA-714) Change version in ./gradle.properties to 0.9.1

[ https://issues.apache.org/jira/browse/SAMZA-714?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated SAMZA-714: Attachment: rb35577.patch > Change version in ./gradle.properties to 0.9.1 >

[jira] [Updated] (SAMZA-714) Change version in ./gradle.properties to 0.9.1

[ https://issues.apache.org/jira/browse/SAMZA-714?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated SAMZA-714: Attachment: rb35577.patch > Change version in ./gradle.properties to 0.9.1 >

[jira] [Created] (SAMZA-714) Change version in ./gradle.properties to 0.9.1

Guozhang Wang created SAMZA-714: --- Summary: Change version in ./gradle.properties to 0.9.1 Key: SAMZA-714 URL: https://issues.apache.org/jira/browse/SAMZA-714 Project: Samza Issue Type: Bug

[jira] [Updated] (SAMZA-697) Isolate Class Loader for user implemented Tasks

[ https://issues.apache.org/jira/browse/SAMZA-697?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated SAMZA-697: Attachment: SAMZA-697.v1.patch > Isolate Class Loader for user implemented Tasks > --

[jira] [Commented] (SAMZA-697) Isolate Class Loader for user implemented Tasks

[ https://issues.apache.org/jira/browse/SAMZA-697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14583783#comment-14583783 ] Guozhang Wang commented on SAMZA-697: - Created reviewboard https://reviews.apache.org/r

[jira] [Resolved] (SAMZA-703) KafkaSystemAdmin should ignore ReplicaNotAvailable error code while fetching offset

[ https://issues.apache.org/jira/browse/SAMZA-703?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved SAMZA-703. - Resolution: Duplicate > KafkaSystemAdmin should ignore ReplicaNotAvailable error code while fetchin

[jira] [Created] (SAMZA-703) KafkaSystemAdmin should ignore ReplicaNotAvailable error code while fetching offset

Guozhang Wang created SAMZA-703: --- Summary: KafkaSystemAdmin should ignore ReplicaNotAvailable error code while fetching offset Key: SAMZA-703 URL: https://issues.apache.org/jira/browse/SAMZA-703 Projec

[jira] [Created] (SAMZA-697) Isolate Class Loader for user implemented Tasks

Guozhang Wang created SAMZA-697: --- Summary: Isolate Class Loader for user implemented Tasks Key: SAMZA-697 URL: https://issues.apache.org/jira/browse/SAMZA-697 Project: Samza Issue Type: Bug

[jira] [Updated] (SAMZA-686) SAMZA-662 needs a test

[ https://issues.apache.org/jira/browse/SAMZA-686?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated SAMZA-686: Attachment: rb34607.patch > SAMZA-662 needs a test > -- > > Key:

[jira] [Commented] (SAMZA-686) SAMZA-662 needs a test

[ https://issues.apache.org/jira/browse/SAMZA-686?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14556653#comment-14556653 ] Guozhang Wang commented on SAMZA-686: - Created review board: https://reviews.apache.org

[jira] [Assigned] (SAMZA-686) SAMZA-662 needs a test

[ https://issues.apache.org/jira/browse/SAMZA-686?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang reassigned SAMZA-686: --- Assignee: Guozhang Wang > SAMZA-662 needs a test > -- > >

[jira] [Commented] (SAMZA-662) Samza auto-creates changelog stream without sufficient partitions when container number > 1

[ https://issues.apache.org/jira/browse/SAMZA-662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14553527#comment-14553527 ] Guozhang Wang commented on SAMZA-662: - +1 on the patch for 0.9.0, LGTM. > Samza auto-c

[jira] [Commented] (SAMZA-340) Support metrics report via Graphite

[ https://issues.apache.org/jira/browse/SAMZA-340?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14552517#comment-14552517 ] Guozhang Wang commented on SAMZA-340: - For this checkystyle constant name, I have overr

[jira] [Commented] (SAMZA-676) Implement Broadcast Stream

[ https://issues.apache.org/jira/browse/SAMZA-676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14548373#comment-14548373 ] Guozhang Wang commented on SAMZA-676: - Yup. > Implement Broadcast Stream > ---

[jira] [Commented] (SAMZA-676) Implement Broadcast Stream

[ https://issues.apache.org/jira/browse/SAMZA-676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14546151#comment-14546151 ] Guozhang Wang commented on SAMZA-676: - [~closeuris] Yeah with the current simple consum

[jira] [Commented] (SAMZA-662) Samza auto-creates changelog stream without sufficient partitions when container number > 1

[ https://issues.apache.org/jira/browse/SAMZA-662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14542320#comment-14542320 ] Guozhang Wang commented on SAMZA-662: - [~closeuris] attached. Thanks! > Samza auto-cre

[jira] [Updated] (SAMZA-662) Samza auto-creates changelog stream without sufficient partitions when container number > 1

[ https://issues.apache.org/jira/browse/SAMZA-662?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated SAMZA-662: Attachment: SAMZA-662.v1.patch > Samza auto-creates changelog stream without sufficient partitions wh

[jira] [Commented] (SAMZA-662) Samza auto-creates changelog stream without sufficient partitions when container number > 1

[ https://issues.apache.org/jira/browse/SAMZA-662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14538929#comment-14538929 ] Guozhang Wang commented on SAMZA-662: - Created https://reviews.apache.org/r/34066/ > S

[jira] [Assigned] (SAMZA-662) Samza auto-creates changelog stream without sufficient partitions when container number > 1

[ https://issues.apache.org/jira/browse/SAMZA-662?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang reassigned SAMZA-662: --- Assignee: Guozhang Wang > Samza auto-creates changelog stream without sufficient partitions wh

[jira] [Commented] (SAMZA-658) Iterator.remove breaks caching layer

[ https://issues.apache.org/jira/browse/SAMZA-658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14533826#comment-14533826 ] Guozhang Wang commented on SAMZA-658: - Thanks [~nickpan47]! > Iterator.remove breaks c

[jira] [Updated] (SAMZA-658) Iterator.remove breaks caching layer

[ https://issues.apache.org/jira/browse/SAMZA-658?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated SAMZA-658: Attachment: SAMZA-658.v4.patch SAMZA-658.v4.patch > Iterator.remove breaks caching la

[jira] [Updated] (SAMZA-658) Iterator.remove breaks caching layer

[ https://issues.apache.org/jira/browse/SAMZA-658?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated SAMZA-658: Attachment: (was: SAMZA-658.v4.patch) > Iterator.remove breaks caching layer > --

[jira] [Commented] (SAMZA-658) Iterator.remove breaks caching layer

[ https://issues.apache.org/jira/browse/SAMZA-658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14533388#comment-14533388 ] Guozhang Wang commented on SAMZA-658: - Updated https://reviews.apache.org/r/33761/ for

[jira] [Updated] (SAMZA-657) Integrate checkstyle for Java code

[ https://issues.apache.org/jira/browse/SAMZA-657?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated SAMZA-657: Attachment: SAMZA-657.v2.patch > Integrate checkstyle for Java code > ---

[jira] [Updated] (SAMZA-658) Iterator.remove breaks caching layer

[ https://issues.apache.org/jira/browse/SAMZA-658?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated SAMZA-658: Attachment: SAMZA-658.v3.patch > Iterator.remove breaks caching layer > -

[jira] [Commented] (SAMZA-657) Integrate checkstyle for Java code

[ https://issues.apache.org/jira/browse/SAMZA-657?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14533077#comment-14533077 ] Guozhang Wang commented on SAMZA-657: - Updated reviewboard https://reviews.apache.org/r

[jira] [Commented] (SAMZA-650) Implement window metadata store

[ https://issues.apache.org/jira/browse/SAMZA-650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14527316#comment-14527316 ] Guozhang Wang commented on SAMZA-650: - [~nickpan47] Could you add the RB link for this

[jira] [Commented] (SAMZA-658) Iterator.remove breaks caching layer

[ https://issues.apache.org/jira/browse/SAMZA-658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14527281#comment-14527281 ] Guozhang Wang commented on SAMZA-658: - Updated https://reviews.apache.org/r/33761/ addr

[jira] [Commented] (SAMZA-658) Iterator.remove breaks caching layer

[ https://issues.apache.org/jira/browse/SAMZA-658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14526959#comment-14526959 ] Guozhang Wang commented on SAMZA-658: - [~closeuris] This bug was reported by some users

[jira] [Assigned] (SAMZA-658) Iterator.remove breaks caching layer

[ https://issues.apache.org/jira/browse/SAMZA-658?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang reassigned SAMZA-658: --- Assignee: Guozhang Wang > Iterator.remove breaks caching layer > -

[jira] [Commented] (SAMZA-658) Iterator.remove breaks caching layer

[ https://issues.apache.org/jira/browse/SAMZA-658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14522430#comment-14522430 ] Guozhang Wang commented on SAMZA-658: - [~nsomasun] which caching layer are you referrin

[jira] [Assigned] (SAMZA-653) Stream-to-stream join operator w/ time-based window

[ https://issues.apache.org/jira/browse/SAMZA-653?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang reassigned SAMZA-653: --- Assignee: Guozhang Wang > Stream-to-stream join operator w/ time-based window > --

[jira] [Commented] (SAMZA-657) Integrate checkstyle for Java code

[ https://issues.apache.org/jira/browse/SAMZA-657?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14514858#comment-14514858 ] Guozhang Wang commented on SAMZA-657: - Updated reviewboard https://reviews.apache.org/r

[jira] [Commented] (SAMZA-657) Integrate checkstyle for Java code

[ https://issues.apache.org/jira/browse/SAMZA-657?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14509842#comment-14509842 ] Guozhang Wang commented on SAMZA-657: - [~jghoman] I actually have a different opinion a

[jira] [Updated] (SAMZA-657) Integrate checkstyle for Java code

[ https://issues.apache.org/jira/browse/SAMZA-657?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated SAMZA-657: Issue Type: Sub-task (was: Bug) Parent: SAMZA-36 > Integrate checkstyle for Java code >

[jira] [Commented] (SAMZA-657) Integrate checkstyle for Java code

[ https://issues.apache.org/jira/browse/SAMZA-657?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14509516#comment-14509516 ] Guozhang Wang commented on SAMZA-657: - I think this is rather a sub-task of SAMZA-36 as

[jira] [Commented] (SAMZA-657) Integrate checkstyle for Java code

[ https://issues.apache.org/jira/browse/SAMZA-657?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14509511#comment-14509511 ] Guozhang Wang commented on SAMZA-657: - Created reviewboard https://reviews.apache.org/r

[jira] [Created] (SAMZA-657) Integrate checkstyle for Java code

Guozhang Wang created SAMZA-657: --- Summary: Integrate checkstyle for Java code Key: SAMZA-657 URL: https://issues.apache.org/jira/browse/SAMZA-657 Project: Samza Issue Type: Bug Repo

[jira] [Commented] (SAMZA-571) Add task interface suppress uncaught exceptions

[ https://issues.apache.org/jira/browse/SAMZA-571?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14350845#comment-14350845 ] Guozhang Wang commented on SAMZA-571: - If you resend, it will become m1, m2, m4, m3. In