[jira] [Created] (SAMZA-959) allow empty serde for SystemConsumer

2016-06-03 Thread Boris Shkolnik (JIRA)
Boris Shkolnik created SAMZA-959: Summary: allow empty serde for SystemConsumer Key: SAMZA-959 URL: https://issues.apache.org/jira/browse/SAMZA-959 Project: Samza Issue Type: Bug

[jira] [Created] (SAMZA-962) Add Java friendly api to KafkaSystemConsumerMetrics.

2016-06-07 Thread Boris Shkolnik (JIRA)
Boris Shkolnik created SAMZA-962: Summary: Add Java friendly api to KafkaSystemConsumerMetrics. Key: SAMZA-962 URL: https://issues.apache.org/jira/browse/SAMZA-962 Project: Samza Issue Type:

[jira] [Updated] (SAMZA-962) Add Java friendly api to KafkaSystemConsumerMetrics.

2016-06-07 Thread Boris Shkolnik (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-962?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boris Shkolnik updated SAMZA-962: - Attachment: samza_apache_KafkaSystemMetrics_java_api.patch > Add Java friendly api to KafkaSystemCo

[jira] [Updated] (SAMZA-959) allow empty serde for SystemConsumer

2016-06-07 Thread Boris Shkolnik (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-959?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boris Shkolnik updated SAMZA-959: - Attachment: samza_apache_empty_serde.patch > allow empty serde for SystemConsumer > ---

[jira] [Commented] (SAMZA-962) Add Java friendly api to KafkaSystemConsumerMetrics.

2016-06-07 Thread Boris Shkolnik (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15319730#comment-15319730 ] Boris Shkolnik commented on SAMZA-962: -- uploaded new patch with the changes mentioned

[jira] [Updated] (SAMZA-962) Add Java friendly api to KafkaSystemConsumerMetrics.

2016-06-07 Thread Boris Shkolnik (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-962?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boris Shkolnik updated SAMZA-962: - Attachment: samza_apache_KafkaSystemMetrics_java_api.patch1 > Add Java friendly api to KafkaSystemC

[jira] [Updated] (SAMZA-969) allow empty serde for SystemStream for SystemConsumer

2016-06-17 Thread Boris Shkolnik (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boris Shkolnik updated SAMZA-969: - Description: If serde is configured as "" (empty string), we shouldn't create a serde and that wi

[jira] [Created] (SAMZA-969) allow empty serde for SystemStream for SystemConsumer

2016-06-17 Thread Boris Shkolnik (JIRA)
Boris Shkolnik created SAMZA-969: Summary: allow empty serde for SystemStream for SystemConsumer Key: SAMZA-969 URL: https://issues.apache.org/jira/browse/SAMZA-969 Project: Samza Issue Type:

[jira] [Commented] (SAMZA-969) allow empty serde for SystemStream for SystemConsumer

2016-06-17 Thread Boris Shkolnik (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-969?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15336621#comment-15336621 ] Boris Shkolnik commented on SAMZA-969: -- added getNonEmptyOption method in ScalaConfig

[jira] [Updated] (SAMZA-969) allow empty serde for SystemStream for SystemConsumer

2016-06-17 Thread Boris Shkolnik (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boris Shkolnik updated SAMZA-969: - Attachment: patch > allow empty serde for SystemStream for SystemConsumer > ---

[jira] [Created] (SAMZA-999) Checkpoint-tool needs to use the rewriter to rewrite the configs.

2016-08-11 Thread Boris Shkolnik (JIRA)
Boris Shkolnik created SAMZA-999: Summary: Checkpoint-tool needs to use the rewriter to rewrite the configs. Key: SAMZA-999 URL: https://issues.apache.org/jira/browse/SAMZA-999 Project: Samza

[jira] [Updated] (SAMZA-999) Checkpoint-tool needs to use the rewriter to rewrite the configs.

2016-08-15 Thread Boris Shkolnik (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-999?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boris Shkolnik updated SAMZA-999: - Attachment: SAMZA-999.patch > Checkpoint-tool needs to use the rewriter to rewrite the configs. > -

[jira] [Commented] (SAMZA-999) Checkpoint-tool needs to use the rewriter to rewrite the configs.

2016-08-17 Thread Boris Shkolnik (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-999?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15424987#comment-15424987 ] Boris Shkolnik commented on SAMZA-999: -- I sure will. Thanks! > Checkpoint-tool needs

[jira] [Created] (SAMZA-1019) reopen a Kafka system producer if send() method is called again

2016-09-15 Thread Boris Shkolnik (JIRA)
Boris Shkolnik created SAMZA-1019: - Summary: reopen a Kafka system producer if send() method is called again Key: SAMZA-1019 URL: https://issues.apache.org/jira/browse/SAMZA-1019 Project: Samza

[jira] [Created] (SAMZA-1022) convert warn() to debug() for 'hostname .. resolves to a loopback address'

2016-09-19 Thread Boris Shkolnik (JIRA)
Boris Shkolnik created SAMZA-1022: - Summary: convert warn() to debug() for 'hostname .. resolves to a loopback address' Key: SAMZA-1022 URL: https://issues.apache.org/jira/browse/SAMZA-1022 Project: S

[jira] [Commented] (SAMZA-927) Document split-deployment feature for Samza website

2016-09-21 Thread Boris Shkolnik (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-927?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15511669#comment-15511669 ] Boris Shkolnik commented on SAMZA-927: -- rb patch - https://reviews.apache.org/r/52140/

[jira] [Updated] (SAMZA-1019) reopen a Kafka system producer if send() method is called again

2016-09-21 Thread Boris Shkolnik (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-1019?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boris Shkolnik updated SAMZA-1019: -- Attachment: SAMZA-1019.1.patch new patch. > reopen a Kafka system producer if send() method is

[jira] [Updated] (SAMZA-927) Document split-deployment feature for Samza website

2016-09-22 Thread Boris Shkolnik (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-927?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boris Shkolnik updated SAMZA-927: - Attachment: split-deployment.md addressed review comments. > Document split-deployment feature for

[jira] [Created] (SAMZA-1042) [DISCUSS] Allow offset notifications for input systems

2016-10-24 Thread Boris Shkolnik (JIRA)
Boris Shkolnik created SAMZA-1042: - Summary: [DISCUSS] Allow offset notifications for input systems Key: SAMZA-1042 URL: https://issues.apache.org/jira/browse/SAMZA-1042 Project: Samza Issue

[jira] [Updated] (SAMZA-1042) [DISCUSS] Allow offset notifications for input systems

2016-10-24 Thread Boris Shkolnik (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-1042?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boris Shkolnik updated SAMZA-1042: -- Attachment: NotifiableConsumer.md > [DISCUSS] Allow offset notifications for input systems > ---

[jira] [Updated] (SAMZA-1042) [DISCUSS] Allow offset notifications for input systems

2016-10-24 Thread Boris Shkolnik (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-1042?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boris Shkolnik updated SAMZA-1042: -- Attachment: NotifiableConsumer.pdf > [DISCUSS] Allow offset notifications for input systems > --

[jira] [Updated] (SAMZA-1042) [DISCUSS] Allow offset notifications for input systems

2016-11-03 Thread Boris Shkolnik (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-1042?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boris Shkolnik updated SAMZA-1042: -- Attachment: notifiable-consumer2.pdf notifiable consumer2.md > [DISCUSS] Allow o

[jira] [Updated] (SAMZA-1042) Allow offset notifications for input systems

2016-11-04 Thread Boris Shkolnik (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-1042?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boris Shkolnik updated SAMZA-1042: -- Summary: Allow offset notifications for input systems (was: [DISCUSS] Allow offset notification

[jira] [Updated] (SAMZA-1042) Allow offset notifications for input systems

2016-11-14 Thread Boris Shkolnik (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-1042?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boris Shkolnik updated SAMZA-1042: -- Attachment: rb53453.patch > Allow offset notifications for input systems > -

[jira] [Commented] (SAMZA-1042) Allow offset notifications for input systems

2016-11-14 Thread Boris Shkolnik (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-1042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15664634#comment-15664634 ] Boris Shkolnik commented on SAMZA-1042: --- great. Thanks. > Allow offset notificatio

[jira] [Commented] (SAMZA-1046) Document Notifiable Consumer for the Samza website

2016-11-16 Thread Boris Shkolnik (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-1046?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15672059#comment-15672059 ] Boris Shkolnik commented on SAMZA-1046: --- https://reviews.apache.org/r/53826/ > Docu

[jira] [Updated] (SAMZA-1046) Document Notifiable Consumer for the Samza website

2016-11-18 Thread Boris Shkolnik (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-1046?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boris Shkolnik updated SAMZA-1046: -- Attachment: rb53826.patch > Document Notifiable Consumer for the Samza website > ---

[jira] [Updated] (SAMZA-1046) Document Notifiable Consumer for the Samza website

2016-11-22 Thread Boris Shkolnik (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-1046?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boris Shkolnik updated SAMZA-1046: -- Attachment: rb53826_1.patch review comments. > Document Notifiable Consumer for the Samza websi

[jira] [Created] (SAMZA-1060) add new config job.changelog.system

2016-12-08 Thread Boris Shkolnik (JIRA)
Boris Shkolnik created SAMZA-1060: - Summary: add new config job.changelog.system Key: SAMZA-1060 URL: https://issues.apache.org/jira/browse/SAMZA-1060 Project: Samza Issue Type: Bug

[jira] [Assigned] (SAMZA-1060) add new config job.changelog.system

2016-12-08 Thread Boris Shkolnik (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-1060?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boris Shkolnik reassigned SAMZA-1060: - Assignee: Boris Shkolnik > add new config job.changelog.system >

[jira] [Created] (SAMZA-1062) document new config options job.changelog.system

2016-12-15 Thread Boris Shkolnik (JIRA)
Boris Shkolnik created SAMZA-1062: - Summary: document new config options job.changelog.system Key: SAMZA-1062 URL: https://issues.apache.org/jira/browse/SAMZA-1062 Project: Samza Issue Type:

[jira] [Created] (SAMZA-1076) getKafkaChangelogEnabledStores() should use StorageConfig.getChangelogStream to get changelog system.stream

2017-01-05 Thread Boris Shkolnik (JIRA)
Boris Shkolnik created SAMZA-1076: - Summary: getKafkaChangelogEnabledStores() should use StorageConfig.getChangelogStream to get changelog system.stream Key: SAMZA-1076 URL: https://issues.apache.org/jira/browse/S

[jira] [Updated] (SAMZA-1066) Update JavaStorageConfig after SAMZA-1060

2017-01-09 Thread Boris Shkolnik (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-1066?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boris Shkolnik updated SAMZA-1066: -- Summary: Update JavaStorageConfig after SAMZA-1060 (was: Update JavaStorageConfig after LISAMZA

[jira] [Resolved] (SAMZA-1061) Add job.changelog.system config to configuration table

2017-01-10 Thread Boris Shkolnik (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-1061?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boris Shkolnik resolved SAMZA-1061. --- Resolution: Fixed https://github.com/apache/samza/pull/32 > Add job.changelog.system config t

[jira] [Created] (SAMZA-1086) Implement Simple grouper by container, with support for arbitrary container ids

2017-02-10 Thread Boris Shkolnik (JIRA)
Boris Shkolnik created SAMZA-1086: - Summary: Implement Simple grouper by container, with support for arbitrary container ids Key: SAMZA-1086 URL: https://issues.apache.org/jira/browse/SAMZA-1086 Proje

[jira] [Created] (SAMZA-1087) Implement debounce scheduler

2017-02-13 Thread Boris Shkolnik (JIRA)
Boris Shkolnik created SAMZA-1087: - Summary: Implement debounce scheduler Key: SAMZA-1087 URL: https://issues.apache.org/jira/browse/SAMZA-1087 Project: Samza Issue Type: Sub-task

[jira] [Created] (SAMZA-1102) ZkController for communication with the ZK

2017-02-23 Thread Boris Shkolnik (JIRA)
Boris Shkolnik created SAMZA-1102: - Summary: ZkController for communication with the ZK Key: SAMZA-1102 URL: https://issues.apache.org/jira/browse/SAMZA-1102 Project: Samza Issue Type: Sub-ta

[jira] [Created] (SAMZA-1103) Barrier for job model update

2017-02-23 Thread Boris Shkolnik (JIRA)
Boris Shkolnik created SAMZA-1103: - Summary: Barrier for job model update Key: SAMZA-1103 URL: https://issues.apache.org/jira/browse/SAMZA-1103 Project: Samza Issue Type: Sub-task

[jira] [Created] (SAMZA-1106) create test utils for Zk based Standalone testing

2017-02-24 Thread Boris Shkolnik (JIRA)
Boris Shkolnik created SAMZA-1106: - Summary: create test utils for Zk based Standalone testing Key: SAMZA-1106 URL: https://issues.apache.org/jira/browse/SAMZA-1106 Project: Samza Issue Type:

[jira] [Created] (SAMZA-1107) add utils for publishing job model and job model version.

2017-02-27 Thread Boris Shkolnik (JIRA)
Boris Shkolnik created SAMZA-1107: - Summary: add utils for publishing job model and job model version. Key: SAMZA-1107 URL: https://issues.apache.org/jira/browse/SAMZA-1107 Project: Samza Iss

[jira] [Created] (SAMZA-1115) create ZK based JobCoordinator

2017-03-01 Thread Boris Shkolnik (JIRA)
Boris Shkolnik created SAMZA-1115: - Summary: create ZK based JobCoordinator Key: SAMZA-1115 URL: https://issues.apache.org/jira/browse/SAMZA-1115 Project: Samza Issue Type: Sub-task

[jira] [Created] (SAMZA-1124) add a time out for ZkVersionUpgradeBarrier

2017-03-07 Thread Boris Shkolnik (JIRA)
Boris Shkolnik created SAMZA-1124: - Summary: add a time out for ZkVersionUpgradeBarrier Key: SAMZA-1124 URL: https://issues.apache.org/jira/browse/SAMZA-1124 Project: Samza Issue Type: Sub-ta

[jira] [Created] (SAMZA-1127) verify that SamzaContainerController.stop shuts down the container completely.

2017-03-08 Thread Boris Shkolnik (JIRA)
Boris Shkolnik created SAMZA-1127: - Summary: verify that SamzaContainerController.stop shuts down the container completely. Key: SAMZA-1127 URL: https://issues.apache.org/jira/browse/SAMZA-1127 Projec

[jira] [Created] (SAMZA-1128) Convert ZkBarrierForVersionUpgrade to be more general.

2017-03-08 Thread Boris Shkolnik (JIRA)
Boris Shkolnik created SAMZA-1128: - Summary: Convert ZkBarrierForVersionUpgrade to be more general. Key: SAMZA-1128 URL: https://issues.apache.org/jira/browse/SAMZA-1128 Project: Samza Issue

[jira] [Assigned] (SAMZA-1134) simplify ZK barrier for version upgrade.

2017-03-10 Thread Boris Shkolnik (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-1134?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boris Shkolnik reassigned SAMZA-1134: - Assignee: Boris Shkolnik > simplify ZK barrier for version upgrade. > ---

[jira] [Created] (SAMZA-1134) simplify ZK barrier for version upgrade.

2017-03-10 Thread Boris Shkolnik (JIRA)
Boris Shkolnik created SAMZA-1134: - Summary: simplify ZK barrier for version upgrade. Key: SAMZA-1134 URL: https://issues.apache.org/jira/browse/SAMZA-1134 Project: Samza Issue Type: Sub-task

[jira] [Updated] (SAMZA-1064) Standalone Samza with Zookeeper for Coordination

2017-03-16 Thread Boris Shkolnik (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-1064?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boris Shkolnik updated SAMZA-1064: -- Attachment: SamzaStandalone1.md SamzaStandalone1.pdf Updated the document with t

[jira] [Created] (SAMZA-1151) create ZkCoordination service

2017-03-17 Thread Boris Shkolnik (JIRA)
Boris Shkolnik created SAMZA-1151: - Summary: create ZkCoordination service Key: SAMZA-1151 URL: https://issues.apache.org/jira/browse/SAMZA-1151 Project: Samza Issue Type: Sub-task

[jira] [Updated] (SAMZA-1151) create ZkCoordination service

2017-03-17 Thread Boris Shkolnik (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-1151?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boris Shkolnik updated SAMZA-1151: -- Description: This will allow ApplicationRunner to use the same services. The services will inclu

[jira] [Resolved] (SAMZA-1115) create ZK based JobCoordinator

2017-03-17 Thread Boris Shkolnik (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-1115?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boris Shkolnik resolved SAMZA-1115. --- Resolution: Fixed > create ZK based JobCoordinator > -- > >

[jira] [Created] (SAMZA-1152) [DISCUSS] List integration tests needed for the StandAlone project

2017-03-17 Thread Boris Shkolnik (JIRA)
Boris Shkolnik created SAMZA-1152: - Summary: [DISCUSS] List integration tests needed for the StandAlone project Key: SAMZA-1152 URL: https://issues.apache.org/jira/browse/SAMZA-1152 Project: Samza

[jira] [Created] (SAMZA-1153) [DISCUSS] list of new metrics needed for ZK coordinated StandAlone project.

2017-03-17 Thread Boris Shkolnik (JIRA)
Boris Shkolnik created SAMZA-1153: - Summary: [DISCUSS] list of new metrics needed for ZK coordinated StandAlone project. Key: SAMZA-1153 URL: https://issues.apache.org/jira/browse/SAMZA-1153 Project:

[jira] [Commented] (SAMZA-1152) [DISCUSS] List integration tests needed for the StandAlone project

2017-03-17 Thread Boris Shkolnik (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-1152?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15930365#comment-15930365 ] Boris Shkolnik commented on SAMZA-1152: --- this is the list of tests I think we need.

[jira] [Commented] (SAMZA-1153) [DISCUSS] list of new metrics needed for ZK coordinated StandAlone project.

2017-03-17 Thread Boris Shkolnik (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-1153?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15930368#comment-15930368 ] Boris Shkolnik commented on SAMZA-1153: --- here is the list of metrics we should add f

[jira] [Created] (SAMZA-1162) review tryBecomeLeader implementation to see if it can be simplified.

2017-03-22 Thread Boris Shkolnik (JIRA)
Boris Shkolnik created SAMZA-1162: - Summary: review tryBecomeLeader implementation to see if it can be simplified. Key: SAMZA-1162 URL: https://issues.apache.org/jira/browse/SAMZA-1162 Project: Samza

[jira] [Commented] (SAMZA-1162) review tryBecomeLeader implementation to see if it can be simplified.

2017-03-22 Thread Boris Shkolnik (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-1162?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15937238#comment-15937238 ] Boris Shkolnik commented on SAMZA-1162: --- Comment from Navina regarding this code: We

[jira] [Commented] (SAMZA-1113) Implement startup and shutdown sequence of jobs in ZK environment

2017-03-22 Thread Boris Shkolnik (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-1113?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15937327#comment-15937327 ] Boris Shkolnik commented on SAMZA-1113: --- GenerationId sounds like approach in genera

[jira] [Created] (SAMZA-1165) ZK cleanup

2017-03-23 Thread Boris Shkolnik (JIRA)
Boris Shkolnik created SAMZA-1165: - Summary: ZK cleanup Key: SAMZA-1165 URL: https://issues.apache.org/jira/browse/SAMZA-1165 Project: Samza Issue Type: Sub-task Reporter: Boris S

[jira] [Created] (SAMZA-1210) fix ZK path issues + container IDs generation.

2017-04-13 Thread Boris Shkolnik (JIRA)
Boris Shkolnik created SAMZA-1210: - Summary: fix ZK path issues + container IDs generation. Key: SAMZA-1210 URL: https://issues.apache.org/jira/browse/SAMZA-1210 Project: Samza Issue Type: Su

[jira] [Assigned] (SAMZA-1210) fix ZK path issues + container IDs generation.

2017-04-13 Thread Boris Shkolnik (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-1210?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boris Shkolnik reassigned SAMZA-1210: - Assignee: Boris Shkolnik > fix ZK path issues + container IDs generation. > -

[jira] [Updated] (SAMZA-1152) List integration tests needed for the StandAlone project

2017-04-19 Thread Boris Shkolnik (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-1152?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boris Shkolnik updated SAMZA-1152: -- Summary: List integration tests needed for the StandAlone project (was: [DISCUSS] List integrat

[jira] [Created] (SAMZA-1248) Fix StandAlone barrier start list.

2017-04-28 Thread Boris Shkolnik (JIRA)
Boris Shkolnik created SAMZA-1248: - Summary: Fix StandAlone barrier start list. Key: SAMZA-1248 URL: https://issues.apache.org/jira/browse/SAMZA-1248 Project: Samza Issue Type: Bug

[jira] [Updated] (SAMZA-1248) Fix StandAlone barrier start list.

2017-05-01 Thread Boris Shkolnik (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-1248?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boris Shkolnik updated SAMZA-1248: -- Attachment: rb58866.patch > Fix StandAlone barrier start list. > ---

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

2015-06-19 Thread Boris Shkolnik (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14593682#comment-14593682 ] Boris Shkolnik commented on SAMZA-697: -- [~guozhang] I've added some comments to the pa

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

2015-09-03 Thread Boris Shkolnik (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-697?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boris Shkolnik reassigned SAMZA-697: Assignee: Boris Shkolnik (was: Guozhang Wang) > Isolate Class Loader for user implemented T

[jira] [Created] (SAMZA-805) "task.opts" config is not passed in case of ProcessJobFactory

2015-11-03 Thread Boris Shkolnik (JIRA)
Boris Shkolnik created SAMZA-805: Summary: "task.opts" config is not passed in case of ProcessJobFactory Key: SAMZA-805 URL: https://issues.apache.org/jira/browse/SAMZA-805 Project: Samza I

[jira] [Updated] (SAMZA-805) "task.opts" config is not passed in case of ProcessJobFactory

2015-11-05 Thread Boris Shkolnik (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-805?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boris Shkolnik updated SAMZA-805: - Description: ProcessJobFactory is creating a separate process by using ProcessBuilder. ProcessBu

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

2015-11-05 Thread Boris Shkolnik (JIRA)
Boris Shkolnik created SAMZA-810: Summary: add list-yarn-job.sh script Key: SAMZA-810 URL: https://issues.apache.org/jira/browse/SAMZA-810 Project: Samza Issue Type: Improvement R

[jira] [Commented] (SAMZA-805) "task.opts" config is not passed in case of ProcessJobFactory

2015-11-11 Thread Boris Shkolnik (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-805?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15000792#comment-15000792 ] Boris Shkolnik commented on SAMZA-805: -- Thanks Navina and Yi. > "task.opts" config i

[jira] [Created] (SAMZA-836) 0.10.0 :samza-kv-rocksdb_2.10:test fails

2015-12-09 Thread Boris Shkolnik (JIRA)
Boris Shkolnik created SAMZA-836: Summary: 0.10.0 :samza-kv-rocksdb_2.10:test fails Key: SAMZA-836 URL: https://issues.apache.org/jira/browse/SAMZA-836 Project: Samza Issue Type: Bug Affe

[jira] [Created] (SAMZA-849) Split-deployment of samza framework

2016-01-04 Thread Boris Shkolnik (JIRA)
Boris Shkolnik created SAMZA-849: Summary: Split-deployment of samza framework Key: SAMZA-849 URL: https://issues.apache.org/jira/browse/SAMZA-849 Project: Samza Issue Type: New Feature

[jira] [Assigned] (SAMZA-849) Split-deployment of samza framework

2016-01-04 Thread Boris Shkolnik (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-849?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boris Shkolnik reassigned SAMZA-849: Assignee: Boris Shkolnik > Split-deployment of samza framework > ---

[jira] [Updated] (SAMZA-849) Split-deployment of samza framework

2016-01-04 Thread Boris Shkolnik (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-849?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boris Shkolnik updated SAMZA-849: - Attachment: SplitDeploymentDesign.pdf SplitDeploymentDesign.md Attaching design doc

[jira] [Created] (SAMZA-861) move KV storage api into samza-api package

2016-01-21 Thread Boris Shkolnik (JIRA)
Boris Shkolnik created SAMZA-861: Summary: move KV storage api into samza-api package Key: SAMZA-861 URL: https://issues.apache.org/jira/browse/SAMZA-861 Project: Samza Issue Type: Improvemen

[jira] [Updated] (SAMZA-861) move KV storage api into samza-api package

2016-01-21 Thread Boris Shkolnik (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-861?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boris Shkolnik updated SAMZA-861: - Flags: Patch > move KV storage api into samza-api package > ---

[jira] [Created] (SAMZA-862) change log level to warn for RocksDB with TTL and changelog

2016-01-25 Thread Boris Shkolnik (JIRA)
Boris Shkolnik created SAMZA-862: Summary: change log level to warn for RocksDB with TTL and changelog Key: SAMZA-862 URL: https://issues.apache.org/jira/browse/SAMZA-862 Project: Samza Issu

[jira] [Created] (SAMZA-864) allow job not to fail in case of incorrect number of partitions on checkpoint topic

2016-01-27 Thread Boris Shkolnik (JIRA)
Boris Shkolnik created SAMZA-864: Summary: allow job not to fail in case of incorrect number of partitions on checkpoint topic Key: SAMZA-864 URL: https://issues.apache.org/jira/browse/SAMZA-864 Proje

[jira] [Commented] (SAMZA-862) change log level to warn for RocksDB with TTL and changelog

2016-02-01 Thread Boris Shkolnik (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-862?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15126679#comment-15126679 ] Boris Shkolnik commented on SAMZA-862: -- https://reviews.apache.org/r/42815/ > change

[jira] [Updated] (SAMZA-861) move KV storage api into samza-api package

2016-02-01 Thread Boris Shkolnik (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-861?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boris Shkolnik updated SAMZA-861: - Attachment: rb42619.patch > move KV storage api into samza-api package > --

[jira] [Updated] (SAMZA-862) change log level to warn for RocksDB with TTL and changelog

2016-02-01 Thread Boris Shkolnik (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-862?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boris Shkolnik updated SAMZA-862: - Attachment: rb42815.patch attached the patch > change log level to warn for RocksDB with TTL and c

[jira] [Updated] (SAMZA-805) "task.opts" config is not passed in case of ProcessJobFactory

2016-02-01 Thread Boris Shkolnik (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-805?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boris Shkolnik updated SAMZA-805: - Attachment: rb3.patch > "task.opts" config is not passed in case of ProcessJobFactory > --

[jira] [Updated] (SAMZA-864) allow job not to fail in case of incorrect number of partitions on checkpoint topic

2016-02-05 Thread Boris Shkolnik (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-864?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boris Shkolnik updated SAMZA-864: - Attachment: rb43053.patch > allow job not to fail in case of incorrect number of partitions on chec

[jira] [Commented] (SAMZA-861) move KV storage api into samza-api package

2016-02-05 Thread Boris Shkolnik (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-861?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15135093#comment-15135093 ] Boris Shkolnik commented on SAMZA-861: -- Hi Yi, thanks for applying my patch. This one

[jira] [Updated] (SAMZA-849) Split-deployment of samza framework

2016-02-05 Thread Boris Shkolnik (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-849?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boris Shkolnik updated SAMZA-849: - Attachment: SplitDeploymentDesignProposal1.pdf SplitDeploymentDesign.md Address com

[jira] [Updated] (SAMZA-864) allow job not to fail in case of incorrect number of partitions on checkpoint topic

2016-02-16 Thread Boris Shkolnik (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-864?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boris Shkolnik updated SAMZA-864: - Attachment: patch addressed Yi's comments and merged the latest code. > allow job not to fail in c

[jira] [Updated] (SAMZA-864) allow job not to fail in case of incorrect number of partitions on checkpoint topic

2016-02-18 Thread Boris Shkolnik (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-864?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boris Shkolnik updated SAMZA-864: - Attachment: rb43053-1.patch Found the problem. I tested it by running one test at a time. Turns out

[jira] [Created] (SAMZA-877) ThreadJobFactory doesn't need JobCoordinator service running

2016-02-18 Thread Boris Shkolnik (JIRA)
Boris Shkolnik created SAMZA-877: Summary: ThreadJobFactory doesn't need JobCoordinator service running Key: SAMZA-877 URL: https://issues.apache.org/jira/browse/SAMZA-877 Project: Samza Iss

[jira] [Commented] (SAMZA-849) Split-deployment of samza framework

2016-03-09 Thread Boris Shkolnik (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-849?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15188540#comment-15188540 ] Boris Shkolnik commented on SAMZA-849: -- https://reviews.apache.org/r/44604/ > Split-d

[jira] [Updated] (SAMZA-849) Split-deployment of samza framework

2016-03-15 Thread Boris Shkolnik (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-849?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boris Shkolnik updated SAMZA-849: - Attachment: split_deploy_os.patch > Split-deployment of samza framework > -

[jira] [Updated] (SAMZA-849) Split-deployment of samza framework

2016-04-01 Thread Boris Shkolnik (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-849?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boris Shkolnik updated SAMZA-849: - Attachment: split_deploy_os2.patch merged with the master. > Split-deployment of samza framework >

[jira] [Updated] (SAMZA-927) Document split-deployment feature for Samza website

2016-04-07 Thread Boris Shkolnik (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-927?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boris Shkolnik updated SAMZA-927: - Attachment: split_deploy_os_md.patch Add .md documentation file. > Document split-deployment featu

[jira] [Created] (SAMZA-1257) StandAlone LeaderElector sometimes passes null listener in DataChange subscription.

2017-05-02 Thread Boris Shkolnik (JIRA)
Boris Shkolnik created SAMZA-1257: - Summary: StandAlone LeaderElector sometimes passes null listener in DataChange subscription. Key: SAMZA-1257 URL: https://issues.apache.org/jira/browse/SAMZA-1257 P

[jira] [Created] (SAMZA-1258) HappyPathTesting. Single and multiple processors happy path.

2017-05-02 Thread Boris Shkolnik (JIRA)
Boris Shkolnik created SAMZA-1258: - Summary: HappyPathTesting. Single and multiple processors happy path. Key: SAMZA-1258 URL: https://issues.apache.org/jira/browse/SAMZA-1258 Project: Samza

[jira] [Assigned] (SAMZA-1153) [DISCUSS] list of new metrics needed for ZK coordinated StandAlone project.

2017-05-05 Thread Boris Shkolnik (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-1153?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boris Shkolnik reassigned SAMZA-1153: - Assignee: Navina Ramesh (was: Boris Shkolnik) > [DISCUSS] list of new metrics needed for

[jira] [Updated] (SAMZA-1128) Convert ZkBarrierForVersionUpgrade to be more general.

2017-05-05 Thread Boris Shkolnik (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-1128?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boris Shkolnik updated SAMZA-1128: -- Fix Version/s: (was: 0.13.0) > Convert ZkBarrierForVersionUpgrade to be more general. >

[jira] [Assigned] (SAMZA-1237) Hello Samza Tutorial for Samza Standalone feature

2017-05-05 Thread Boris Shkolnik (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-1237?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boris Shkolnik reassigned SAMZA-1237: - Assignee: Navina Ramesh (was: Boris Shkolnik) > Hello Samza Tutorial for Samza Standalon

[jira] [Updated] (SAMZA-1173) Evaluate CoordinationService design and resolve unresolved questions from PR#91

2017-05-05 Thread Boris Shkolnik (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-1173?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boris Shkolnik updated SAMZA-1173: -- Fix Version/s: (was: 0.13.0) 0.14.0 > Evaluate CoordinationService design

[jira] [Updated] (SAMZA-1162) Review tryBecomeLeader implementation to see if it can be simplified.

2017-05-05 Thread Boris Shkolnik (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-1162?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boris Shkolnik updated SAMZA-1162: -- Fix Version/s: (was: 0.13.0) > Review tryBecomeLeader implementation to see if it can be sim

[jira] [Commented] (SAMZA-1165) ZK cleanup

2017-05-05 Thread Boris Shkolnik (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-1165?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15998983#comment-15998983 ] Boris Shkolnik commented on SAMZA-1165: --- It may be called from ApplicationRunner (i

[jira] [Created] (SAMZA-1279) list of children in onProcessorsChange throws NPE when there an exception in ZK

2017-05-10 Thread Boris Shkolnik (JIRA)
Boris Shkolnik created SAMZA-1279: - Summary: list of children in onProcessorsChange throws NPE when there an exception in ZK Key: SAMZA-1279 URL: https://issues.apache.org/jira/browse/SAMZA-1279 Proje

  1   2   3   4   >