[jira] [Updated] (SAMZA-1455) Shutdown coordinator stream producers and consumers cleanly in JobRunner

[ https://issues.apache.org/jira/browse/SAMZA-1455?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jagadish updated SAMZA-1455: Description: Currently, we do not cleanly close the producer and consumer in the JobRunner. This means

[jira] [Updated] (SAMZA-1455) Shutdown coordinator stream producers and consumers cleanly in JobRunner

[ https://issues.apache.org/jira/browse/SAMZA-1455?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jagadish updated SAMZA-1455: Description: Currently, we do not cleanly close the producer and consumer in the JobRunner. This means

[jira] [Created] (SAMZA-1455) Shutdown coordinator stream producers and consumers cleanly in JobRunner

Jagadish created SAMZA-1455: --- Summary: Shutdown coordinator stream producers and consumers cleanly in JobRunner Key: SAMZA-1455 URL: https://issues.apache.org/jira/browse/SAMZA-1455 Project: Samza

[jira] [Commented] (SAMZA-1455) Shutdown coordinator stream producers and consumers cleanly in JobRunner

[ https://issues.apache.org/jira/browse/SAMZA-1455?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16201372#comment-16201372 ] Jagadish commented on SAMZA-1455: - The fix is straightforward: 1. Cleanly close the coordinatorStream

[jira] [Updated] (SAMZA-1455) Shutdown coordinator stream producers and consumers cleanly in JobRunner

[ https://issues.apache.org/jira/browse/SAMZA-1455?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jagadish updated SAMZA-1455: Description: Currently, we do not cleanly close the producer and consumer in the JobRunner. This means

[jira] [Resolved] (SAMZA-1453) Update README with Travis-CI badge.

[ https://issues.apache.org/jira/browse/SAMZA-1453?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jagadish resolved SAMZA-1453. - Resolution: Fixed > Update README with Travis-CI ba

[jira] [Closed] (SAMZA-1453) Update README with Travis-CI badge.

[ https://issues.apache.org/jira/browse/SAMZA-1453?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jagadish closed SAMZA-1453. --- > Update README with Travis-CI badge. > --- > > Key

[jira] [Closed] (SAMZA-1461) Expose RocksDB properties as metrics

[ https://issues.apache.org/jira/browse/SAMZA-1461?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jagadish closed SAMZA-1461. --- > Expose RocksDB properties as metrics > > > Key

[jira] [Created] (SAMZA-1503) Implement event time support for windowing

Jagadish created SAMZA-1503: --- Summary: Implement event time support for windowing Key: SAMZA-1503 URL: https://issues.apache.org/jira/browse/SAMZA-1503 Project: Samza Issue Type: Sub-task

[jira] [Closed] (SAMZA-1513) Doc updates for Windows and joins with durable state

[ https://issues.apache.org/jira/browse/SAMZA-1513?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jagadish closed SAMZA-1513. --- > Doc updates for Windows and joins with durable st

[jira] [Created] (SAMZA-1515) Implement a consumer for Kinesis

Jagadish created SAMZA-1515: --- Summary: Implement a consumer for Kinesis Key: SAMZA-1515 URL: https://issues.apache.org/jira/browse/SAMZA-1515 Project: Samza Issue Type: Sub-task

[jira] [Resolved] (SAMZA-1515) Implement a consumer for Kinesis

[ https://issues.apache.org/jira/browse/SAMZA-1515?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jagadish resolved SAMZA-1515. - Resolution: Fixed > Implement a consumer for Kine

[jira] [Closed] (SAMZA-1515) Implement a consumer for Kinesis

[ https://issues.apache.org/jira/browse/SAMZA-1515?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jagadish closed SAMZA-1515. --- > Implement a consumer for Kinesis > > > Key

[jira] [Resolved] (SAMZA-1513) Doc updates for Windows and joins with durable state

[ https://issues.apache.org/jira/browse/SAMZA-1513?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jagadish resolved SAMZA-1513. - Resolution: Fixed > Doc updates for Windows and joins with durable st

[jira] [Created] (SAMZA-1513) Doc updates for Windows and joins with durable state

Jagadish created SAMZA-1513: --- Summary: Doc updates for Windows and joins with durable state Key: SAMZA-1513 URL: https://issues.apache.org/jira/browse/SAMZA-1513 Project: Samza Issue Type: Sub

[jira] [Closed] (SAMZA-1494) Flush operator state on end of stream

[ https://issues.apache.org/jira/browse/SAMZA-1494?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jagadish closed SAMZA-1494. --- > Flush operator state on end of stream > - > >

[jira] [Updated] (SAMZA-1513) Doc updates for Windows and joins with durable state

[ https://issues.apache.org/jira/browse/SAMZA-1513?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jagadish updated SAMZA-1513: Description: - The website needs to be updated with examples for using Windows and Joins with durable

[jira] [Assigned] (SAMZA-1513) Doc updates for Windows and joins with durable state

[ https://issues.apache.org/jira/browse/SAMZA-1513?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jagadish reassigned SAMZA-1513: --- Assignee: Jagadish > Doc updates for Windows and joins with durable st

[jira] [Closed] (SAMZA-1473) Fix handling of initial values in windows with aggregating functions

[ https://issues.apache.org/jira/browse/SAMZA-1473?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jagadish closed SAMZA-1473. --- > Fix handling of initial values in windows with aggregating functi

[jira] [Assigned] (SAMZA-1473) Fix handling of initial values in windows with aggregating functions

[ https://issues.apache.org/jira/browse/SAMZA-1473?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jagadish reassigned SAMZA-1473: --- Assignee: Jagadish > Fix handling of initial values in windows with aggregating functi

[jira] [Commented] (SAMZA-1425) Implement persistent tumbling and session windows

[ https://issues.apache.org/jira/browse/SAMZA-1425?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16259616#comment-16259616 ] Jagadish commented on SAMZA-1425: - https://github.com/apache/samza/pull/321 > Implement persist

[jira] [Closed] (SAMZA-1423) Implement a RocksDb backed time-series store for storing and retrieving messages time-ranges

[ https://issues.apache.org/jira/browse/SAMZA-1423?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jagadish closed SAMZA-1423. --- > Implement a RocksDb backed time-series store for storing and retrieving > messages time-

[jira] [Commented] (SAMZA-1426) Wire-up windowed stores in the Operatorgraph

[ https://issues.apache.org/jira/browse/SAMZA-1426?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16259615#comment-16259615 ] Jagadish commented on SAMZA-1426: - Resolved by https://github.com/apache/samza/pull/321 > Wire

[jira] [Closed] (SAMZA-1426) Wire-up windowed stores in the Operatorgraph

[ https://issues.apache.org/jira/browse/SAMZA-1426?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jagadish closed SAMZA-1426. --- > Wire-up windowed stores in the Operatorgr

[jira] [Updated] (SAMZA-1494) Flush operator state on end of stream

[ https://issues.apache.org/jira/browse/SAMZA-1494?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jagadish updated SAMZA-1494: Issue Type: Sub-task (was: Bug) Parent: SAMZA-1421 > Flush operator state on end of str

[jira] [Closed] (SAMZA-1479) Proposal for Kafka checkpoint manager improvements

[ https://issues.apache.org/jira/browse/SAMZA-1479?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jagadish closed SAMZA-1479. --- > Proposal for Kafka checkpoint manager improveme

[jira] [Updated] (SAMZA-1479) Proposal Kafka checkpoint manager improvements

[ https://issues.apache.org/jira/browse/SAMZA-1479?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jagadish updated SAMZA-1479: Summary: Proposal Kafka checkpoint manager improvements (was: Kafka checkpoint manager improvements

[jira] [Assigned] (SAMZA-1479) Proposal for Kafka checkpoint manager improvements

[ https://issues.apache.org/jira/browse/SAMZA-1479?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jagadish reassigned SAMZA-1479: --- Assignee: Jagadish > Proposal for Kafka checkpoint manager improveme

[jira] [Updated] (SAMZA-1479) Proposal for Kafka checkpoint manager improvements

[ https://issues.apache.org/jira/browse/SAMZA-1479?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jagadish updated SAMZA-1479: Description: This proposal adds the following improvements to KafkaCheckpointManager for better

[jira] [Commented] (SAMZA-1479) Proposal for Kafka checkpoint manager improvements

[ https://issues.apache.org/jira/browse/SAMZA-1479?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16234645#comment-16234645 ] Jagadish commented on SAMZA-1479: - cc: [~pmaheshwari] [~jmaes] [~nickpan47] > Proposal for Ka

[jira] [Updated] (SAMZA-1479) Proposal for Kafka checkpoint manager improvements

[ https://issues.apache.org/jira/browse/SAMZA-1479?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jagadish updated SAMZA-1479: Description: This proposal adds the following improvements to KafkaCheckpointManager for better

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

Jagadish created SAMZA-1485: --- Summary: Make eventData creation extensible. Add interceptor tests Key: SAMZA-1485 URL: https://issues.apache.org/jira/browse/SAMZA-1485 Project: Samza Issue Type

[jira] [Updated] (SAMZA-1484) Host affinity improvements for YARN

[ https://issues.apache.org/jira/browse/SAMZA-1484?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jagadish updated SAMZA-1484: Description: 1. Currently, if an attempt to start a container times out, it also times out other buffered

[jira] [Created] (SAMZA-1484) Host affinity improvements for YARN

Jagadish created SAMZA-1484: --- Summary: Host affinity improvements for YARN Key: SAMZA-1484 URL: https://issues.apache.org/jira/browse/SAMZA-1484 Project: Samza Issue Type: Bug Reporter

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

Jagadish created SAMZA-1486: --- Summary: Implement a Checkpoint Provider for Azure Tables Key: SAMZA-1486 URL: https://issues.apache.org/jira/browse/SAMZA-1486 Project: Samza Issue Type: Bug

[jira] [Updated] (SAMZA-1479) Proposal for Kafka checkpoint manager improvements

[ https://issues.apache.org/jira/browse/SAMZA-1479?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jagadish updated SAMZA-1479: Description: This proposal adds the following improvements to KafkaCheckpointManager for better

[jira] [Created] (SAMZA-1528) Implement async NodeManager interactions

Jagadish created SAMZA-1528: --- Summary: Implement async NodeManager interactions Key: SAMZA-1528 URL: https://issues.apache.org/jira/browse/SAMZA-1528 Project: Samza Issue Type: Bug

[jira] [Created] (SAMZA-1473) Fix handling of initial values in windows with aggregating functions

Jagadish created SAMZA-1473: --- Summary: Fix handling of initial values in windows with aggregating functions Key: SAMZA-1473 URL: https://issues.apache.org/jira/browse/SAMZA-1473 Project: Samza

[jira] [Commented] (SAMZA-1469) Hello-samza demo not working on master branch, following the steps in the website

[ https://issues.apache.org/jira/browse/SAMZA-1469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16219898#comment-16219898 ] Jagadish commented on SAMZA-1469: - It looks like your ApplicationState is "waiting for AM cont

[jira] [Created] (SAMZA-1476) Flaky test: testShouldStartAndRestore

Jagadish created SAMZA-1476: --- Summary: Flaky test: testShouldStartAndRestore Key: SAMZA-1476 URL: https://issues.apache.org/jira/browse/SAMZA-1476 Project: Samza Issue Type: Bug

[jira] [Created] (SAMZA-1699) NPE in ClusterResourceManager

Jagadish created SAMZA-1699: --- Summary: NPE in ClusterResourceManager Key: SAMZA-1699 URL: https://issues.apache.org/jira/browse/SAMZA-1699 Project: Samza Issue Type: Bug Reporter

[jira] [Resolved] (SAMZA-1699) NPE in ClusterResourceManager

[ https://issues.apache.org/jira/browse/SAMZA-1699?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jagadish resolved SAMZA-1699. - Resolution: Fixed > NPE in ClusterResourceManager > - > >

[jira] [Updated] (SAMZA-1699) NPE in ClusterResourceManager

[ https://issues.apache.org/jira/browse/SAMZA-1699?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jagadish updated SAMZA-1699: Fix Version/s: 0.14.1 0.15.0 > NPE in ClusterResourceMana

[jira] [Closed] (SAMZA-1699) NPE in ClusterResourceManager

[ https://issues.apache.org/jira/browse/SAMZA-1699?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jagadish closed SAMZA-1699. --- Assignee: Jagadish > NPE in ClusterResourceManager > - > >

[jira] [Updated] (SAMZA-1702) Prepare 0.14.1 release

[ https://issues.apache.org/jira/browse/SAMZA-1702?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jagadish updated SAMZA-1702: Fix Version/s: 0.14.1 > Prepare 0.14.1 release > -- > > Key

[jira] [Resolved] (SAMZA-1702) Prepare 0.14.1 release

[ https://issues.apache.org/jira/browse/SAMZA-1702?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jagadish resolved SAMZA-1702. - Resolution: Fixed > Prepare 0.14.1 release > -- > > Key

[jira] [Closed] (SAMZA-1702) Prepare 0.14.1 release

[ https://issues.apache.org/jira/browse/SAMZA-1702?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jagadish closed SAMZA-1702. --- > Prepare 0.14.1 release > -- > > Key: SAMZA-1702 >

[jira] [Closed] (SAMZA-1571) Make Eventhubs system configs compatible with Samza standalone.

[ https://issues.apache.org/jira/browse/SAMZA-1571?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jagadish closed SAMZA-1571. --- > Make Eventhubs system configs compatible with Samza standal

[jira] [Resolved] (SAMZA-1571) Make Eventhubs system configs compatible with Samza standalone.

[ https://issues.apache.org/jira/browse/SAMZA-1571?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jagadish resolved SAMZA-1571. - Resolution: Fixed > Make Eventhubs system configs compatible with Samza standal

[jira] [Closed] (SAMZA-1692) Standalone stability fixes.

[ https://issues.apache.org/jira/browse/SAMZA-1692?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jagadish closed SAMZA-1692. --- > Standalone stability fixes. > --- > > Key

[jira] [Closed] (SAMZA-1704) Fix compatibility issues with scala 2.12

[ https://issues.apache.org/jira/browse/SAMZA-1704?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jagadish closed SAMZA-1704. --- > Fix compatibility issues with scala 2.12 > - > >

[jira] [Resolved] (SAMZA-1704) Fix compatibility issues with scala 2.12

[ https://issues.apache.org/jira/browse/SAMZA-1704?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jagadish resolved SAMZA-1704. - Resolution: Fixed > Fix compatibility issues with scala 2

[jira] [Resolved] (SAMZA-1692) Standalone stability fixes.

[ https://issues.apache.org/jira/browse/SAMZA-1692?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jagadish resolved SAMZA-1692. - Resolution: Fixed > Standalone stability fixes. > --- > >

[jira] [Closed] (SAMZA-1643) StreamPartitionCountMonitor should only restart/shut down the job if partition count increases

[ https://issues.apache.org/jira/browse/SAMZA-1643?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jagadish closed SAMZA-1643. --- > StreamPartitionCountMonitor should only restart/shut down the job if > partition count inc

[jira] [Resolved] (SAMZA-1632) KinesisConfig: Making getProxyHost and getProxyPort APIs protected

[ https://issues.apache.org/jira/browse/SAMZA-1632?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jagadish resolved SAMZA-1632. - Resolution: Fixed > KinesisConfig: Making getProxyHost and getProxyPort APIs protec

[jira] [Resolved] (SAMZA-1640) JobModel Json deserialization error in ZkJobCoordinator

[ https://issues.apache.org/jira/browse/SAMZA-1640?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jagadish resolved SAMZA-1640. - Resolution: Fixed > JobModel Json deserialization error in ZkJobCoordina

[jira] [Closed] (SAMZA-1640) JobModel Json deserialization error in ZkJobCoordinator

[ https://issues.apache.org/jira/browse/SAMZA-1640?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jagadish closed SAMZA-1640. --- > JobModel Json deserialization error in ZkJobCoordina

[jira] [Closed] (SAMZA-1687) Prioritize preferred host requests over ANY-HOST requests

[ https://issues.apache.org/jira/browse/SAMZA-1687?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jagadish closed SAMZA-1687. --- > Prioritize preferred host requests over ANY-HOST reque

[jira] [Updated] (SAMZA-1640) JobModel Json deserialization error in ZkJobCoordinator

[ https://issues.apache.org/jira/browse/SAMZA-1640?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jagadish updated SAMZA-1640: Fix Version/s: 0.14.1 > JobModel Json deserialization error in ZkJobCoordina

[jira] [Resolved] (SAMZA-1687) Prioritize preferred host requests over ANY-HOST requests

[ https://issues.apache.org/jira/browse/SAMZA-1687?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jagadish resolved SAMZA-1687. - Resolution: Fixed Fix Version/s: 0.14.1 > Prioritize preferred host requests over ANY-H

[jira] [Updated] (SAMZA-1627) Watermark broadcast enhancements

[ https://issues.apache.org/jira/browse/SAMZA-1627?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jagadish updated SAMZA-1627: Fix Version/s: 0.14.0 > Watermark broadcast enhanceme

[jira] [Assigned] (SAMZA-1632) KinesisConfig: Making getProxyHost and getProxyPort APIs protected

[ https://issues.apache.org/jira/browse/SAMZA-1632?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jagadish reassigned SAMZA-1632: --- Assignee: Aditya > KinesisConfig: Making getProxyHost and getProxyPort APIs protec

[jira] [Resolved] (SAMZA-1627) Watermark broadcast enhancements

[ https://issues.apache.org/jira/browse/SAMZA-1627?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jagadish resolved SAMZA-1627. - Resolution: Fixed Fix Version/s: 0.14.1 > Watermark broadcast enhanceme

[jira] [Closed] (SAMZA-1627) Watermark broadcast enhancements

[ https://issues.apache.org/jira/browse/SAMZA-1627?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jagadish closed SAMZA-1627. --- > Watermark broadcast enhancements > > > Key

[jira] [Closed] (SAMZA-1632) KinesisConfig: Making getProxyHost and getProxyPort APIs protected

[ https://issues.apache.org/jira/browse/SAMZA-1632?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jagadish closed SAMZA-1632. --- > KinesisConfig: Making getProxyHost and getProxyPort APIs protec

[jira] [Updated] (SAMZA-1632) KinesisConfig: Making getProxyHost and getProxyPort APIs protected

[ https://issues.apache.org/jira/browse/SAMZA-1632?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jagadish updated SAMZA-1632: Fix Version/s: 0.14.0 > KinesisConfig: Making getProxyHost and getProxyPort APIs protec

[jira] [Created] (SAMZA-1723) Schedule barrier changes on the debounce thread

Jagadish created SAMZA-1723: --- Summary: Schedule barrier changes on the debounce thread Key: SAMZA-1723 URL: https://issues.apache.org/jira/browse/SAMZA-1723 Project: Samza Issue Type: Bug

[jira] [Created] (SAMZA-1718) Simplify coordination state in Zookeeper

Jagadish created SAMZA-1718: --- Summary: Simplify coordination state in Zookeeper Key: SAMZA-1718 URL: https://issues.apache.org/jira/browse/SAMZA-1718 Project: Samza Issue Type: Bug

[jira] [Closed] (SAMZA-1669) Prioritize preferred host requests over ANY-HOST requests

[ https://issues.apache.org/jira/browse/SAMZA-1669?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jagadish closed SAMZA-1669. --- > Prioritize preferred host requests over ANY-HOST reque

[jira] [Resolved] (SAMZA-1669) Prioritize preferred host requests over ANY-HOST requests

[ https://issues.apache.org/jira/browse/SAMZA-1669?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jagadish resolved SAMZA-1669. - Resolution: Duplicate > Prioritize preferred host requests over ANY-HOST reque

[jira] [Commented] (SAMZA-1669) Prioritize preferred host requests over ANY-HOST requests

[ https://issues.apache.org/jira/browse/SAMZA-1669?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16487664#comment-16487664 ] Jagadish commented on SAMZA-1669: - dup of SAMZA-1687. Resolved by https://github.com/apache/samza/pull/488

[jira] [Updated] (SAMZA-1552) Host affinity improvements - Improve matching of hosts to allocated resources

[ https://issues.apache.org/jira/browse/SAMZA-1552?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jagadish updated SAMZA-1552: Issue Type: Sub-task (was: Bug) Parent: SAMZA-1484 > Host affinity improvements - Impr

[jira] [Closed] (SAMZA-1747) Add metrics to measure the effectiveness of host affinity

[ https://issues.apache.org/jira/browse/SAMZA-1747?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jagadish closed SAMZA-1747. --- > Add metrics to measure the effectiveness of host affin

[jira] [Resolved] (SAMZA-1747) Add metrics to measure the effectiveness of host affinity

[ https://issues.apache.org/jira/browse/SAMZA-1747?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jagadish resolved SAMZA-1747. - Resolution: Fixed > Add metrics to measure the effectiveness of host affin

[jira] [Updated] (SAMZA-1747) Add metrics to measure the effectiveness of host affinity

[ https://issues.apache.org/jira/browse/SAMZA-1747?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jagadish updated SAMZA-1747: Issue Type: Sub-task (was: Bug) Parent: SAMZA-1484 > Add metrics to measure the effectiven

[jira] [Updated] (SAMZA-1649) Improve host-aware allocation to account for strict locality

[ https://issues.apache.org/jira/browse/SAMZA-1649?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jagadish updated SAMZA-1649: Issue Type: Sub-task (was: Bug) Parent: SAMZA-1484 > Improve host-aware allocation to acco

[jira] [Updated] (SAMZA-1687) Prioritize preferred host requests over ANY-HOST requests

[ https://issues.apache.org/jira/browse/SAMZA-1687?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jagadish updated SAMZA-1687: Issue Type: Sub-task (was: Bug) Parent: SAMZA-1484 > Prioritize preferred host requests over

[jira] [Updated] (SAMZA-1699) Race condition in ClusterResourceManager

[ https://issues.apache.org/jira/browse/SAMZA-1699?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jagadish updated SAMZA-1699: Summary: Race condition in ClusterResourceManager (was: NPE in ClusterResourceManager) > Race condit

[jira] [Updated] (SAMZA-1699) Race condition in ClusterResourceManager

[ https://issues.apache.org/jira/browse/SAMZA-1699?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jagadish updated SAMZA-1699: Issue Type: Sub-task (was: Bug) Parent: SAMZA-1484 > Race condition in ClusterResourceMana

[jira] [Updated] (SAMZA-1484) Host affinity improvements for YARN

[ https://issues.apache.org/jira/browse/SAMZA-1484?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jagadish updated SAMZA-1484: Description: https://docs.google.com/document/u/1/d/1oeNKDnG4JIGT2846us-jpnGW_RUjMjPIKDeEUlE_-jg/edit

[jira] [Closed] (SAMZA-1528) Implement async NodeManager interactions

[ https://issues.apache.org/jira/browse/SAMZA-1528?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jagadish closed SAMZA-1528. --- > Implement async NodeManager interactions > > >

[jira] [Updated] (SAMZA-1528) Implement async NodeManager interactions

[ https://issues.apache.org/jira/browse/SAMZA-1528?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jagadish updated SAMZA-1528: Issue Type: Sub-task (was: Bug) Parent: SAMZA-1484 > Implement async NodeManager interacti

[jira] [Closed] (SAMZA-1528) Implement async NodeManager interactions

[ https://issues.apache.org/jira/browse/SAMZA-1528?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jagadish closed SAMZA-1528. --- > Implement async NodeManager interactions > > >

[jira] [Created] (SAMZA-1747) Add metrics to measure the effectiveness of host affinity

Jagadish created SAMZA-1747: --- Summary: Add metrics to measure the effectiveness of host affinity Key: SAMZA-1747 URL: https://issues.apache.org/jira/browse/SAMZA-1747 Project: Samza Issue Type

[jira] [Created] (SAMZA-1750) Samza host-affinity fixes

Jagadish created SAMZA-1750: --- Summary: Samza host-affinity fixes Key: SAMZA-1750 URL: https://issues.apache.org/jira/browse/SAMZA-1750 Project: Samza Issue Type: Bug Reporter: Jagadish

[jira] [Resolved] (SAMZA-1718) Simplify coordination state in Zookeeper

[ https://issues.apache.org/jira/browse/SAMZA-1718?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jagadish resolved SAMZA-1718. - Resolution: Fixed > Simplify coordination state in Zookee

[jira] [Updated] (SAMZA-1692) Standalone stability fixes.

[ https://issues.apache.org/jira/browse/SAMZA-1692?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jagadish updated SAMZA-1692: Fix Version/s: 0.15.0 0.15 > Standalone stability fi

[jira] [Updated] (SAMZA-1552) Host affinity improvements - Improve matching of hosts to allocated resources

[ https://issues.apache.org/jira/browse/SAMZA-1552?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jagadish updated SAMZA-1552: Description: Kudos to [~abkshvn] for observing this! We have observed host-affinity not being honored

[jira] [Created] (SAMZA-1552) Host affinity improvements - Improve matching of hosts to allocated resources

Jagadish created SAMZA-1552: --- Summary: Host affinity improvements - Improve matching of hosts to allocated resources Key: SAMZA-1552 URL: https://issues.apache.org/jira/browse/SAMZA-1552 Project: Samza

[jira] [Updated] (SAMZA-1552) Host affinity improvements - Improve matching of hosts to allocated resources

[ https://issues.apache.org/jira/browse/SAMZA-1552?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jagadish updated SAMZA-1552: Description: Kudos to [~abkshvn] for observing this! We have observed host-affinity not being honored

[jira] [Closed] (SAMZA-1500) Add metrics for RocksDB state store memory usage

[ https://issues.apache.org/jira/browse/SAMZA-1500?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jagadish closed SAMZA-1500. --- > Add metrics for RocksDB state store memory us

[jira] [Closed] (SAMZA-1556) Samza SQL: Add support for multi level sources in SQL query

[ https://issues.apache.org/jira/browse/SAMZA-1556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jagadish closed SAMZA-1556. --- > Samza SQL: Add support for multi level sources in SQL qu

[jira] [Updated] (SAMZA-1556) Samza SQL: Add support for multi level sources in SQL query

[ https://issues.apache.org/jira/browse/SAMZA-1556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jagadish updated SAMZA-1556: Fix Version/s: 0.15.0 > Samza SQL: Add support for multi level sources in SQL qu

[jira] [Resolved] (SAMZA-1523) Cleanup table entries before shutting down the processor

[ https://issues.apache.org/jira/browse/SAMZA-1523?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jagadish resolved SAMZA-1523. - Resolution: Fixed > Cleanup table entries before shutting down the proces

[jira] [Closed] (SAMZA-1523) Cleanup table entries before shutting down the processor

[ https://issues.apache.org/jira/browse/SAMZA-1523?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jagadish closed SAMZA-1523. --- > Cleanup table entries before shutting down the proces

[jira] [Created] (SAMZA-1560) Skip checkpoint validations for Key Serdes

Jagadish created SAMZA-1560: --- Summary: Skip checkpoint validations for Key Serdes Key: SAMZA-1560 URL: https://issues.apache.org/jira/browse/SAMZA-1560 Project: Samza Issue Type: Bug

[jira] [Updated] (SAMZA-1560) Skip checkpoint validations for Key Serdes

[ https://issues.apache.org/jira/browse/SAMZA-1560?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jagadish updated SAMZA-1560: Description: Currently, when "validateCheckpoints" is set to false, we ignore validat

[jira] [Resolved] (SAMZA-1556) Samza SQL: Add support for multi level sources in SQL query

[ https://issues.apache.org/jira/browse/SAMZA-1556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jagadish resolved SAMZA-1556. - Resolution: Fixed > Samza SQL: Add support for multi level sources in SQL qu

[jira] [Updated] (SAMZA-1592) Hello-Samza latest branch is broken after Kafka 0.11 upgrade in Samza

[ https://issues.apache.org/jira/browse/SAMZA-1592?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jagadish updated SAMZA-1592: Description: After the 0.11 upgrade, the latest branch in hello-samza (and hence all our open-source

[jira] [Commented] (SAMZA-1592) Hello-Samza latest branch is broken after Kafka 0.11 upgrade in Samza

[ https://issues.apache.org/jira/browse/SAMZA-1592?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16375737#comment-16375737 ] Jagadish commented on SAMZA-1592: - [~xinyu] Here's the PR for this: https://github.com/apache/samza-hello

<    5   6   7   8   9   10   11   >