Title: Message Title
Shanthoosh Venkataraman edited a page
SEP-11: Host affinity in standalone.
...
Code Block
language
java
// '+' denotes addition, '-' denotes
Title: Message Title
Shanthoosh Venkataraman edited a page
SEP-11: Host affinity in standalone.
... After the rebalancing phase, before the start of processing each stream processor will register the
Title: Message Title
Shanthoosh Venkataraman edited a page
SEP-11: Host affinity in standalone.
... After this change, we will have one method in TaskNameGrouper interface clearly defining the contract and
Title: Message Title
Shanthoosh Venkataraman edited a page
SEP-11: Host affinity in standalone.
...
Code Block
language
java
// '+' denotes addition, '-' denotes
Title: Message Title
Shanthoosh Venkataraman edited a page
SEP-11: Host affinity in standalone.
...
Code Block
language
java
// '+' denotes addition, '-' denotes
Title: Message Title
Shanthoosh Venkataraman edited a page
SEP-11: Host affinity in standalone.
... High level flow in standalone with HostAffinity Image Added ZK Data Model to
Title: Message Title
Shanthoosh Venkataraman edited a page
SEP-11: Host affinity in standalone.
... If an optimal assignment for each task to a particular processor is generated in the JobModel as part of
[
https://issues.apache.org/jira/browse/SAMZA-1548?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16340404#comment-16340404
]
ASF GitHub Bot commented on SAMZA-1548:
---
Github user asfgit closed the pull request at:
SAMZA-1548; Add start() and stop() to SystemAdmin
This patch adds start() and stop() to SystemAdmin interface. This can be useful
for e.g. kafka.admin.AdminClient which needs to be started before it can be
used.
Since we add this method in interface and expect AdminClient to be stateful and
Repository: samza
Updated Branches:
refs/heads/master 2e04e1772 -> 75e70e569
http://git-wip-us.apache.org/repos/asf/samza/blob/75e70e56/samza-core/src/test/java/org/apache/samza/clustermanager/TestClusterBasedJobCoordinator.java
Title: Message Title
Shanthoosh Venkataraman edited a page
SEP-11: Host affinity in standalone.
Status Current state: UNDER DISCUSSION ... JIRA:
JIRA
server
ASF JIRA
Jake Maes created SAMZA-1576:
Summary: Reorganize topics in Documentation page
Key: SAMZA-1576
URL: https://issues.apache.org/jira/browse/SAMZA-1576
Project: Samza
Issue Type: Sub-task
Title: Message Title
Shanthoosh Venkataraman edited a page
Host affinity in standalone.
...
Code Block
language
java
-
Jake Maes created SAMZA-1575:
Summary: Update overview page
Key: SAMZA-1575
URL: https://issues.apache.org/jira/browse/SAMZA-1575
Project: Samza
Issue Type: Sub-task
Reporter: Jake
Jake Maes created SAMZA-1574:
Summary: Update logos
Key: SAMZA-1574
URL: https://issues.apache.org/jira/browse/SAMZA-1574
Project: Samza
Issue Type: Sub-task
Reporter: Jake Maes
[
https://issues.apache.org/jira/browse/SAMZA-1238?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jake Maes resolved SAMZA-1238.
--
Resolution: Fixed
Superseded by SAMZA-1573
> Documentation for Samza 0.13.0: Architecture overview
>
Jake Maes created SAMZA-1573:
Summary: Website Documentation Updates
Key: SAMZA-1573
URL: https://issues.apache.org/jira/browse/SAMZA-1573
Project: Samza
Issue Type: Improvement
Shanthoosh Venkataraman created SAMZA-1572:
--
Summary: Add fixed retries on failure in KafkaCheckpointManager
Key: SAMZA-1572
URL: https://issues.apache.org/jira/browse/SAMZA-1572
Project:
[
https://issues.apache.org/jira/browse/SAMZA-1345?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jake Maes resolved SAMZA-1345.
--
Resolution: Fixed
Fix Version/s: 0.13.1
This was done in SAMZA-1366
> Samza REST: ScriptRunner
Boris Shkolnik created SAMZA-1571:
-
Summary: Make Eventhubs system configs compatible with Samza
standalone.
Key: SAMZA-1571
URL: https://issues.apache.org/jira/browse/SAMZA-1571
Project: Samza
[
https://issues.apache.org/jira/browse/SAMZA-1568?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shanthoosh Venkataraman updated SAMZA-1568:
---
Description:
When zookeeper session failures occur in a stream processor,
[
https://issues.apache.org/jira/browse/SAMZA-1568?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shanthoosh Venkataraman updated SAMZA-1568:
---
Description:
When zookeeper session failures occur in a stream processor,
[
https://issues.apache.org/jira/browse/SAMZA-1568?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shanthoosh Venkataraman updated SAMZA-1568:
---
Description:
When zookeeper session failures occur in a stream processor,
Jake Maes created SAMZA-1570:
Summary: Programmatic way to set input stream priority and
bootstrap mode for high-level API
Key: SAMZA-1570
URL: https://issues.apache.org/jira/browse/SAMZA-1570
Project:
Xinyu Liu created SAMZA-1569:
Summary: Support Broadcast input stream in high-level API
Key: SAMZA-1569
URL: https://issues.apache.org/jira/browse/SAMZA-1569
Project: Samza
Issue Type: Bug
[
https://issues.apache.org/jira/browse/SAMZA-1569?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xinyu Liu updated SAMZA-1569:
-
Fix Version/s: 0.15.0
> Support Broadcast input stream in high-level API
>
[
https://issues.apache.org/jira/browse/SAMZA-1568?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shanthoosh Venkataraman updated SAMZA-1568:
---
Description:
When zookeeper session failures occur in a stream processor,
Shanthoosh Venkataraman created SAMZA-1568:
--
Summary: Handle ZkInterruptedException in zkclient.close.
Key: SAMZA-1568
URL: https://issues.apache.org/jira/browse/SAMZA-1568
Project: Samza
28 matches
Mail list logo
