[
https://issues.apache.org/jira/browse/SAMZA-676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14546545#comment-14546545
]
Yan Fang commented on SAMZA-676:
{quote}
What I meant to say is "allow the consumer to regi
[
https://issues.apache.org/jira/browse/SAMZA-676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14546542#comment-14546542
]
Yan Fang commented on SAMZA-676:
Is it in the 0.9.0 Consumer redesign?
> Implement Broadca
[
https://issues.apache.org/jira/browse/SAMZA-552?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14546497#comment-14546497
]
Yi Pan (Data Infrastructure) commented on SAMZA-552:
Merged to samza-sq
Repository: samza
Updated Branches:
refs/heads/samza-sql b47e47fd7 -> 41c4cd012
http://git-wip-us.apache.org/repos/asf/samza/blob/41c4cd01/samza-sql-core/src/main/java/org/apache/samza/sql/operators/relation/JoinSpec.java
--
di
SAMZA-552 update operator APIs
Project: http://git-wip-us.apache.org/repos/asf/samza/repo
Commit: http://git-wip-us.apache.org/repos/asf/samza/commit/41c4cd01
Tree: http://git-wip-us.apache.org/repos/asf/samza/tree/41c4cd01
Diff: http://git-wip-us.apache.org/repos/asf/samza/diff/41c4cd01
Branch:
[
https://issues.apache.org/jira/browse/SAMZA-552?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yi Pan (Data Infrastructure) updated SAMZA-552:
---
Attachment: SAMZA-552-0.patch
RB: https://reviews.apache.org/r/34206/.
[
https://issues.apache.org/jira/browse/SAMZA-671?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Naveen Somasundaram reassigned SAMZA-671:
-
Assignee: Naveen Somasundaram
> Disable checkpoint in coordinator stream
> ---
Luis De Pombo created SAMZA-681:
---
Summary: Create a unit test harness to easily test samza tasks
Key: SAMZA-681
URL: https://issues.apache.org/jira/browse/SAMZA-681
Project: Samza
Issue Type: T
[
https://issues.apache.org/jira/browse/SAMZA-465?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14546353#comment-14546353
]
Naveen Somasundaram commented on SAMZA-465:
---
[~closeuris], Sorry for the late rep
Naveen Somasundaram created SAMZA-680:
-
Summary: Invert the JobCoordinator and AM logic
Key: SAMZA-680
URL: https://issues.apache.org/jira/browse/SAMZA-680
Project: Samza
Issue Type: Impr
[
https://issues.apache.org/jira/browse/SAMZA-676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14546344#comment-14546344
]
Yi Pan (Data Infrastructure) commented on SAMZA-676:
{quote}
Yi Pan (Da
[
https://issues.apache.org/jira/browse/SAMZA-614?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14546339#comment-14546339
]
Naveen Somasundaram commented on SAMZA-614:
---
Update the docs for refreshJobModel
[
https://issues.apache.org/jira/browse/SAMZA-678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14546316#comment-14546316
]
Naveen Somasundaram commented on SAMZA-678:
---
Also, as a part of this ticket. As [
Naveen Somasundaram created SAMZA-679:
-
Summary: Optimize CoordinatorStream's bootstrap mechanism
Key: SAMZA-679
URL: https://issues.apache.org/jira/browse/SAMZA-679
Project: Samza
Issue
Naveen Somasundaram created SAMZA-678:
-
Summary: Integrate CoordinatorStream to use SystemConsumers and
SystemProducers
Key: SAMZA-678
URL: https://issues.apache.org/jira/browse/SAMZA-678
Project:
[
https://issues.apache.org/jira/browse/SAMZA-615?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Naveen Somasundaram reassigned SAMZA-615:
-
Assignee: Naveen Somasundaram
> Migrate checkpoint from checkpoint topic to Coordi
[
https://issues.apache.org/jira/browse/SAMZA-614?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Naveen Somasundaram reassigned SAMZA-614:
-
Assignee: Naveen Somasundaram
> Document coordinator stream
>
[
https://issues.apache.org/jira/browse/SAMZA-676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14546298#comment-14546298
]
Navina Ramesh commented on SAMZA-676:
-
bq. I did not put it in the design doc is becau
[
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
[
https://issues.apache.org/jira/browse/SAMZA-676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14546147#comment-14546147
]
Yan Fang commented on SAMZA-676:
{quote}
GroupByPartition now takes the Config as a constru
[
https://issues.apache.org/jira/browse/SAMZA-676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14546002#comment-14546002
]
Yi Pan (Data Infrastructure) commented on SAMZA-676:
{quote}
Yet, there
[
https://issues.apache.org/jira/browse/SAMZA-643?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14546003#comment-14546003
]
Yan Fang commented on SAMZA-643:
+1. Committed. Thank you for the contributing, [~gustavoan
Repository: samza
Updated Branches:
refs/heads/master a94e1ed89 -> db2d93e34
SAMZA-643: Improve error messages fro null stream in OutgoingMessageEnvelop
Project: http://git-wip-us.apache.org/repos/asf/samza/repo
Commit: http://git-wip-us.apache.org/repos/asf/samza/commit/db2d93e3
Tree: http:/
[
https://issues.apache.org/jira/browse/SAMZA-676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14545987#comment-14545987
]
Navina Ramesh commented on SAMZA-676:
-
Thanks for pointing it out [~twbecker] ! I was l
[
https://issues.apache.org/jira/browse/SAMZA-676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14545970#comment-14545970
]
Yi Pan (Data Infrastructure) commented on SAMZA-676:
Hi, [~closeuris],
[
https://issues.apache.org/jira/browse/SAMZA-375?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14545866#comment-14545866
]
Zach Cox commented on SAMZA-375:
[~nickpan47] yes it's samza 0.8.0, we haven't upgraded to
[
https://issues.apache.org/jira/browse/SAMZA-375?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14545782#comment-14545782
]
Yi Pan (Data Infrastructure) commented on SAMZA-375:
[~zcox], awesome w
[
https://issues.apache.org/jira/browse/SAMZA-676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14545644#comment-14545644
]
Tommy Becker commented on SAMZA-676:
As noted above this is what I did. The SystemStre
[
https://issues.apache.org/jira/browse/SAMZA-676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14545640#comment-14545640
]
Tommy Becker commented on SAMZA-676:
GroupByPartition now takes the Config as a constru
[
https://issues.apache.org/jira/browse/SAMZA-375?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14545593#comment-14545593
]
Konstantin Alexandroff commented on SAMZA-375:
--
There's a problem we discovere
[
https://issues.apache.org/jira/browse/SAMZA-375?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14545397#comment-14545397
]
Zach Cox commented on SAMZA-375:
[~drcrallen] I wrote a nice long reply, but jira lost it.
31 matches
Mail list logo
