Navina Ramesh created SAMZA-1523:
Summary: Cleanup table entries before shutting down the processor
Key: SAMZA-1523
URL: https://issues.apache.org/jira/browse/SAMZA-1523
Project: Samza
Issue
Title: Message Title
Navina Ramesh edited a page
Samza Enhancement Proposal
... SEP Number Next SEP Number: 910 Use this number as the identifier for your SEP and increment this value. ...
SEP
Title: Message Title
Navina Ramesh created a page
SEP-10 Exactly-once Processing in Samza
Status Current state: [ UNDER DISCUSSION | ACCEPTED | REJECTED ] Discussion thread: <link to mailing l
7:36 2017 -0700
Committer: navina <nav...@apache.org>
Committed: Thu Sep 14 21:18:55 2017 -0700
--
.../samza/zk/ScheduleAfterDebounceTime.java | 172 +--
.../org/apache/samza/zk/ZkJobCoordinat
[
https://issues.apache.org/jira/browse/SAMZA-1413?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Navina Ramesh resolved SAMZA-1413.
--
Resolution: Fixed
Fix Version/s: 0.14.0
Issue resolved by pull request 290
[https
Repository: samza
Updated Tags: refs/tags/release-0.13.1-rc0 [created] c0048c2b7
Repository: samza
Updated Tags: refs/tags/release-0.13.1-rc0 [deleted] 694682d35
Repository: samza
Updated Branches:
refs/heads/master e21ff7146 -> 1d253c757
SAMZA-1401: update NOTICE for 0.13.1 release with RocksDB BSD+patents license
Please see details in SAMZA-1401.
Author: Fred Ji <haifeng...@gmail.com>
Reviewers: Navina Ramesh <nav...@apache.org>
C
Repository: samza
Updated Tags: refs/tags/release-0.13.1-rc0 [created] 694682d35
Repository: samza
Updated Branches:
refs/heads/0.13.1 651d269b3 -> 3042b3057
SAMZA-1396 TestZkLocalApplicationRunner tests fails after SAMZA-1385
* Fixes ZkPath issues
* Fixes appname / jobname mismatch
Author: Navina Ramesh <nav...@apache.org>
Reviewers: Xinyu Liu <xi..
PR)
Author: PawasChhokra <Jaimatadi1$>
Author: PawasChhokra <pawas2...@gmail.com>
Reviewers: Navina Ramesh <nav...@apache.org>
Closes #258 from PawasChhokra/TableUtils
Project: http://git-wip-us.apache.org/repos/asf/samza/repo
Commit: http://git-wip-us.apache.org/repos/asf/samza
atadi1$>
Author: PawasChhokra <pawas2...@gmail.com>
Reviewers: Navina Ramesh <nav...@apache.org>
Closes #257 from PawasChhokra/BlobUtils
Project: http://git-wip-us.apache.org/repos/asf/samza/repo
Commit: http://git-wip-us.apache.org/repos/asf/samza/commit/a9866d62
Tree: http://git-wi
Repository: samza
Updated Branches:
refs/heads/master cf5efe761 -> f5c5cb223
SAMZA-1376: Create a leasing utility class for blobs in Azure
navina
PR 1: AzureClient + AzureConfig
**PR 2: LeaseBlobManager** (current PR)
Author: PawasChhokra <Jaimatadi1$>
Author: PawasChhokr
man <svenkatara...@linkedin.com>
Reviewers: Navina Ramesh <nav...@apache.org>
Closes #250 from shanthoosh/fix_broken_tests
Project: http://git-wip-us.apache.org/repos/asf/samza/repo
Commit: http://git-wip-us.apache.org/repos/asf/samza/commit/cf5efe76
Tree: http://git-wip-us.apache.org/
Repository: samza
Updated Branches:
refs/heads/master 69dbada6a -> 966730ee6
Samza-1379: Create Azure Client
navina
**PR 1: AzureClient + AzureConfig** (current PR)
Author: PawasChhokra <Jaimatadi1$>
Reviewers: Navina Ramesh <nav...@apache.org>
Closes #254 fr
osh Venkataraman <svenkatara...@linkedin.com>
Reviewers: Bharath Kumarasubramanian <codin.mart...@gmail.com>, Navina Ramesh
<nav...@apache.org>
Closes #260 from shanthoosh/FIX_ZK_PROCESSOR_FLAKY_TESTS
Project: http://git-wip-us.apache.org/repos/asf/samza/repo
Commit: http://
[
https://issues.apache.org/jira/browse/SAMZA-1365?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Navina Ramesh resolved SAMZA-1365.
--
Resolution: Fixed
Issue resolved by pull request 253
[https://github.com/apache/samza/pull/253
Repository: samza
Updated Branches:
refs/heads/master fde556440 -> 0a4ecb232
SAMZA-1365: Calling zkClient.close from zkWatch impl blocks indefinitely.
Author: Shanthoosh Venkataraman <svenkatara...@linkedin.com>
Reviewers: Navina Ramesh <nav...@apache.org>
Closes #253 from s
[
https://issues.apache.org/jira/browse/SAMZA-1348?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16109635#comment-16109635
]
Navina Ramesh commented on SAMZA-1348:
--
[~boryas] is this still a pending task? SAMZA-1349 looks like
[
https://issues.apache.org/jira/browse/SAMZA-1310?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Navina Ramesh resolved SAMZA-1310.
--
Resolution: Implemented
> If LocalAppRunner is used - use ZkJobCoordinator by defa
[
https://issues.apache.org/jira/browse/SAMZA-1310?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16109628#comment-16109628
]
Navina Ramesh commented on SAMZA-1310:
--
I am assuming this has already been fixed by Xinyu. Please re
[
https://issues.apache.org/jira/browse/SAMZA-1333?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16109625#comment-16109625
]
Navina Ramesh commented on SAMZA-1333:
--
[~boryas] [~spvenkat] Can we add some description
[
https://issues.apache.org/jira/browse/SAMZA-1364?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Navina Ramesh resolved SAMZA-1364.
--
Resolution: Fixed
Issue resolved by pull request 246
[https://github.com/apache/samza/pull/246
proper shutdown).
Author: Shanthoosh Venkataraman <svenkatara...@linkedin.com>
Reviewers: Boris Shkolnik <bor...@apache.org>, Navina Ramesh <nav...@apache.org>
Closes #246 from shanthoosh/SAMZA-1364
Project: http://git-wip-us.apache.org/repos/asf/samza/repo
Commit: http://gi
[
https://issues.apache.org/jira/browse/SAMZA-1364?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16100983#comment-16100983
]
Navina Ramesh commented on SAMZA-1364:
--
[~spvenkat] sorry about the late reply. Yes. Any unhandled
Repository: samza
Updated Branches:
refs/heads/master 57758615b -> 95d96b944
Fix build failures after master merge
Changes
* Fix checkstyle errors from #243
* Fix failure after bad merge in #244
Author: Shanthoosh Venkataraman <svenkatara...@linkedin.com>
Reviewers: Navina Ra
[
https://issues.apache.org/jira/browse/SAMZA-1282?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Navina Ramesh resolved SAMZA-1282.
--
Resolution: Fixed
Issue resolved by pull request 244
[https://github.com/apache/samza/pull/244
thoosh Venkataraman <svenkatara...@linkedin.com>
Reviewers: Boris Shkolnik <bor...@apache.org>, Navina Ramesh <nav...@apache.org>
Closes #244 from shanthoosh/more_processor_than_tasks
Project: http://git-wip-us.apache.org/repos/asf/samza/repo
Commit: http://git-wip-us.apache.or
ove StreamProcessor.toString since it has no usages.
Author: Shanthoosh Venkataraman <svenkatara...@linkedin.com>
Reviewers: Navina Ramesh <nav...@apache.org>
Closes #249 from shanthoosh/fix_logging_in_stream_processor
Project: http://git-wip-us.apache.org/repos/asf/samza/repo
Commit:
Repository: samza
Updated Branches:
refs/heads/master 45931fd5d -> ce777164d
http://git-wip-us.apache.org/repos/asf/samza/blob/ce777164/samza-test/src/test/java/org/apache/samza/test/processor/TestZkStreamProcessorFailures.java
<bor...@apache.org>
Author: Boris Shkolnik <bshko...@bshkolni-ld1.linkedin.biz>
Author: Boris Shkolnik <bshko...@linkedin.com>
Reviewers: Navina Ramesh <nav...@apache.org>, Shanthoosh Venkataraman
<svenkatara...@linkedin.com>
Closes #229 from sborya/SessionFailReregi
[
https://issues.apache.org/jira/browse/SAMZA-1304?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Navina Ramesh resolved SAMZA-1304.
--
Resolution: Fixed
Issue resolved by pull request 240
[https://github.com/apache/samza/pull/240
hor: Shanthoosh Venkataraman <svenkatara...@linkedin.com>
Reviewers: Navina Ramesh <nav...@apache.org>, Jagadish V <jvenk...@linkedin.com>
Closes #240 from shanthoosh/standalone_duplicate_processor_fix
Project: http://git-wip-us.apache.org/repos/asf/samza/repo
Commit: http://git-wip-us
ava default
for uninitialized field is null resulting in NPE.
Fix:
Initialize private fields of ZkUtils class with appropriate defaults.
Author: Shanthoosh Venkataraman <svenkatara...@linkedin.com>
Reviewers: Navina Ramesh <nav...@apache.org>
Closes #235 from shanthoosh/fix_zkutil
[
https://issues.apache.org/jira/browse/SAMZA-1296?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Navina Ramesh resolved SAMZA-1296.
--
Resolution: Fixed
Fix Version/s: 0.13.1
Issue resolved by pull request 196
[https
tor/ZKUtils.
Author: Shanthoosh Venkataraman <svenkatara...@linkedin.com>
Reviewers: Navina Ramesh <nav...@apache.org>, Jagadish V <jvenk...@linkedin.com>
Closes #196 from shanthoosh/standalone_happy_integration_tests
Project: http://git-wip-us.apache.org/repos/asf/samza/repo
C
Navina Ramesh created SAMZA-1350:
Summary: Flaky test - frequently failing in jenkins
Key: SAMZA-1350
URL: https://issues.apache.org/jira/browse/SAMZA-1350
Project: Samza
Issue Type: Bug
[
https://issues.apache.org/jira/browse/SAMZA-1349?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Navina Ramesh updated SAMZA-1349:
-
Issue Type: Improvement (was: Bug)
> Fix stop() sequence in the StreamProces
[
https://issues.apache.org/jira/browse/SAMZA-1348?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16065758#comment-16065758
]
Navina Ramesh commented on SAMZA-1348:
--
bq. Note. Since we are using scheduler's thread to run stop
Title: Message Title
Navina Ramesh created a page
SEP-8
Status Current state: [ UNDER DISCUSSION | ACCEPTED | REJECTED ] Discussion thread: <link to mailing list DISCUSS thread> JIRA: SAM
Repository: samza
Updated Branches:
refs/heads/master 4072c9e85 -> 26dc77b08
Add a basic .travis.yml file to run on Travis.
Enable gradle caching
Use Trusty as a platform
Set JDK to 8
Author: Nacho Solis <nso...@linkedin.com>
Reviewers: Navina Ramesh <nav...@apache.org>
C
t;
Author: Pawas Chhokra <pchho...@pchhokra-mn1.linkedin.biz>
Author: PawasChhokra <pawas2...@gmail.com>
Reviewers: Navina Ramesh <nav...@apache.org>
Closes #223 from PawasChhokra/ZkJobCoordinatorMetrics
Project: http://git-wip-us.apache.org/repos/asf/samza/repo
Commit: http://
[
https://issues.apache.org/jira/browse/SAMZA-1337?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Navina Ramesh resolved SAMZA-1337.
--
Resolution: Fixed
Fix Version/s: (was: 0.13.0)
Issue resolved by pull request 231
Repository: samza
Updated Branches:
refs/heads/master 8aa75467e -> 4875842b3
SAMZA-1337: Use StreamTask with the LocalApplicationRunner
Author: Boris Shkolnik <bor...@apache.org>
Reviewers: Navina Ramesh <nav...@apache.org>, Xinyu Liu <xi...@apache.org>,
Bhar
[
https://issues.apache.org/jira/browse/SAMZA-1337?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Navina Ramesh reassigned SAMZA-1337:
Assignee: Boris Shkolnik
> LocalApplicationRunner needs to support StreamT
[
https://issues.apache.org/jira/browse/SAMZA-1310?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Navina Ramesh updated SAMZA-1310:
-
Fix Version/s: 0.13.0
> If LocalAppRunner is used - use ZkJobCoordinator by defa
[
https://issues.apache.org/jira/browse/SAMZA-1311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16063571#comment-16063571
]
Navina Ramesh commented on SAMZA-1311:
--
[~boryas] Can you please update the description in the JIRA
[
https://issues.apache.org/jira/browse/SAMZA-1310?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Navina Ramesh updated SAMZA-1310:
-
Fix Version/s: (was: 0.13.0)
> If LocalAppRunner is used - use ZkJobCoordinator by defa
[
https://issues.apache.org/jira/browse/SAMZA-1311?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Navina Ramesh updated SAMZA-1311:
-
Fix Version/s: (was: 0.13.0)
> HappyPath Testing. Using local stor
[
https://issues.apache.org/jira/browse/SAMZA-1311?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Navina Ramesh updated SAMZA-1311:
-
Fix Version/s: 0.13.0
> HappyPath Testing. Using local stor
[
https://issues.apache.org/jira/browse/SAMZA-1310?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16063566#comment-16063566
]
Navina Ramesh commented on SAMZA-1310:
--
[~boryas] Can you please update the description of the JIRA
[
https://issues.apache.org/jira/browse/SAMZA-1346?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16063523#comment-16063523
]
Navina Ramesh commented on SAMZA-1346:
--
> It should validate all of its inputs as best as possi
[
https://issues.apache.org/jira/browse/SAMZA-1282?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Navina Ramesh reassigned SAMZA-1282:
Assignee: Shanthoosh Venkataraman (was: Navina Ramesh)
> Spinning up more containers t
Navina Ramesh created SAMZA-1343:
Summary: Modify the existing failure-testing script for Zookeeper
based deployment
Key: SAMZA-1343
URL: https://issues.apache.org/jira/browse/SAMZA-1343
Project
Navina Ramesh created SAMZA-1340:
Summary: StreamProcessor does not propagate container failures
from StreamTask
Key: SAMZA-1340
URL: https://issues.apache.org/jira/browse/SAMZA-1340
Project: Samza
[
https://issues.apache.org/jira/browse/SAMZA-656?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16058633#comment-16058633
]
Navina Ramesh commented on SAMZA-656:
-
[~spvenkat] Is there anything pending in this JIRA
[
https://issues.apache.org/jira/browse/SAMZA-1338?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Navina Ramesh resolved SAMZA-1338.
--
Resolution: Duplicate
Resolving as this is a duplicate of SAMZA-1282
> Number of process
[
https://issues.apache.org/jira/browse/SAMZA-1282?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Navina Ramesh updated SAMZA-1282:
-
Fix Version/s: 0.13.1
> Spinning up more containers than the number of tasks kills lea
[
https://issues.apache.org/jira/browse/SAMZA-1153?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16058422#comment-16058422
]
Navina Ramesh commented on SAMZA-1153:
--
[~pawas2...@gmail.com]
Thanks for listing out the metrics
[
https://issues.apache.org/jira/browse/SAMZA-1338?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Navina Ramesh updated SAMZA-1338:
-
Fix Version/s: 0.13.1
> Number of processors greater then number of tasks results in an incorr
[
https://issues.apache.org/jira/browse/SAMZA-1304?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Navina Ramesh updated SAMZA-1304:
-
Issue Type: Bug (was: Sub-task)
Parent: (was: SAMZA-1064)
> Improve duplic
[
https://issues.apache.org/jira/browse/SAMZA-1304?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Navina Ramesh updated SAMZA-1304:
-
Fix Version/s: (was: 0.14.0)
0.13.1
> Improve duplicate process
Author: navina
Date: Fri Jun 9 18:21:16 2017
New Revision: 19970
Log:
Releasing Apache Samza 0.13.0 Source Tarballs
Added:
release/samza/0.13.0/
release/samza/0.13.0/apache-samza-0.13.0-src.tgz (with props)
release/samza/0.13.0/apache-samza-0.13.0-src.tgz.MD5
release/samza
[
https://issues.apache.org/jira/browse/SAMZA-942?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Navina Ramesh resolved SAMZA-942.
-
Resolution: Duplicate
SAMZA-702
> Document the core set of metrics Samza gener
Repository: samza
Updated Branches:
refs/heads/master c1c4289c8 -> 451b2e538
SAMZA-1326: Revert to use getGlobalAppId for zk path
Author: Boris Shkolnik <bor...@apache.org>
Reviewers: Navina Ramesh <nav...@apache.org>
Closes #216 from sborya/getGlobalId
Project:
[
https://issues.apache.org/jira/browse/SAMZA-1326?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Navina Ramesh resolved SAMZA-1326.
--
Resolution: Fixed
Fix Version/s: 0.13.1
Issue resolved by pull request 216
[https
[
https://issues.apache.org/jira/browse/SAMZA-1324?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Navina Ramesh reassigned SAMZA-1324:
Assignee: Pawas Chhokra (was: Navina Ramesh)
> Add a metricsreporter lifecy
[
https://issues.apache.org/jira/browse/SAMZA-1324?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Navina Ramesh updated SAMZA-1324:
-
Reporter: Navina Ramesh (was: Boris Shkolnik)
> Add a metricsreporter lifecy
[
https://issues.apache.org/jira/browse/SAMZA-1324?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Navina Ramesh updated SAMZA-1324:
-
Issue Type: Improvement (was: Sub-task)
Parent: (was: SAMZA-1064)
>
[
https://issues.apache.org/jira/browse/SAMZA-1324?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Navina Ramesh updated SAMZA-1324:
-
Description: In order to make any metrics available from ZkJobCoordinator,
we need to create
[
https://issues.apache.org/jira/browse/SAMZA-1324?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Navina Ramesh updated SAMZA-1324:
-
Fix Version/s: (was: 0.13.0)
0.13.1
> Add a metricsreporter lifecy
Navina Ramesh created SAMZA-1324:
Summary: Add a metricsreporter lifecycle for JobCoordinator
component of StreamProcessor
Key: SAMZA-1324
URL: https://issues.apache.org/jira/browse/SAMZA-1324
[
https://issues.apache.org/jira/browse/SAMZA-1308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16030487#comment-16030487
]
Navina Ramesh commented on SAMZA-1308:
--
[~spvenkat] Thanks for listing out the scenarios.
A, C, D
[
https://issues.apache.org/jira/browse/SAMZA-1309?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Navina Ramesh resolved SAMZA-1309.
--
Resolution: Fixed
Issue resolved by pull request 203
[https://github.com/apache/samza/pull/203
Repository: samza
Updated Branches:
refs/heads/master 8f1609d0b -> 0c05cb344
SAMZA-1309; Debounce time config
Author: Boris Shkolnik <bor...@apache.org>
Reviewers: Navina Ramesh <nav...@apache.org>
Closes #203 from sborya/DebounceConfig
Project: http://git-wip-us.apach
[
https://issues.apache.org/jira/browse/SAMZA-1313?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Navina Ramesh resolved SAMZA-1313.
--
Resolution: Fixed
Fix Version/s: (was: 0.13.0)
0.9.1
Issue
[
https://issues.apache.org/jira/browse/SAMZA-1313?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Navina Ramesh updated SAMZA-1313:
-
Fix Version/s: (was: 0.9.1)
0.13.0
> renam StandaloneJobCoordina
Repository: samza
Updated Branches:
refs/heads/master e5e9705c1 -> 8f1609d0b
SAMZA-1313 : Rename StandaloneJobCoordinator to PassthroughJobCoordinator
Author: Boris Shkolnik <bor...@apache.org>
Reviewers: Navina Ramesh <nav...@apache.org>
Closes #
Repository: samza
Updated Branches:
refs/heads/master 7355a4503 -> e5e9705c1
Updating committer page on samza.apache.org
Giving more screen time for currently active Apache Samza committers (no JIRA)
Author: Navina Ramesh <nav...@apache.org>
Reviewers: Yi Pan <nickpa...@gmail.
Repository: samza
Updated Tags: refs/tags/release-0.13.0-rc1 [created] 752790813
interface
* Renamed ZkBarrierForVersionUpgrade to ZkBarrier and introduces a listener
ZkBarrierListener
* Simplified the ZkBarrier class and its integration test
Author: Navina Ramesh <nav...@apache.org>
Reviewers: Boris Shkolnik <bor...@apache.org>, Bharath Kumarasubramanian
<
Repository: samza
Updated Branches:
refs/heads/0.13.0 06860479f -> 82d5cca2d
SAMZA-1307 - Fix ZkKeyBuilder null checks for pathPrefix
Author: Navina Ramesh <nav...@apache.org>
Reviewers: Jagadish V <jagad...@apache.org>
Closes #202 from navina/SAMZA-1307
Project:
[
https://issues.apache.org/jira/browse/SAMZA-1128?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Navina Ramesh resolved SAMZA-1128.
--
Resolution: Fixed
Issue resolved by pull request 195
[https://github.com/apache/samza/pull/195
ler that the Jobcoordinator's main thread.
* Removes CoordinationUtils#getBarrier, BarrierForVersionUpgrade interface
* Renamed ZkBarrierForVersionUpgrade to ZkBarrier and introduces a listener
ZkBarrierListener
* Simplified the ZkBarrier class and its integration test
Author: Navina Ramesh <nav...@apache.org>
[
https://issues.apache.org/jira/browse/SAMZA-1307?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Navina Ramesh resolved SAMZA-1307.
--
Resolution: Fixed
Issue resolved by pull request 202
[https://github.com/apache/samza/pull/202
Repository: samza
Updated Branches:
refs/heads/master c3db20483 -> 90f3ff622
SAMZA-1307 - Fix ZkKeyBuilder null checks for pathPrefix
Author: Navina Ramesh <nav...@apache.org>
Reviewers: Jagadish V <jagad...@apache.org>
Closes #202 from navina/SAMZA-1307
Project:
Navina Ramesh created SAMZA-1307:
Summary: Fix ZkKeyBuilder null checks for pathPrefix
Key: SAMZA-1307
URL: https://issues.apache.org/jira/browse/SAMZA-1307
Project: Samza
Issue Type: Bug
[
https://issues.apache.org/jira/browse/SAMZA-1303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16022105#comment-16022105
]
Navina Ramesh commented on SAMZA-1303:
--
That's a good point and also, brings me to my next question
[
https://issues.apache.org/jira/browse/SAMZA-1303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16022034#comment-16022034
]
Navina Ramesh commented on SAMZA-1303:
--
[~xiliu] Yes. That's what I would assumed when I read
[
https://issues.apache.org/jira/browse/SAMZA-1303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16022027#comment-16022027
]
Navina Ramesh commented on SAMZA-1303:
--
Fwiw, if we are stopping the processor by invoking {{kill
[
https://issues.apache.org/jira/browse/SAMZA-1304?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16020037#comment-16020037
]
Navina Ramesh commented on SAMZA-1304:
--
[~boryas] I think he is talking about rogue or orphaned
[
https://issues.apache.org/jira/browse/SAMZA-1294?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Navina Ramesh updated SAMZA-1294:
-
Issue Type: Sub-task (was: Bug)
Parent: SAMZA-1150
> Modify schedule
[
https://issues.apache.org/jira/browse/SAMZA-1294?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Navina Ramesh updated SAMZA-1294:
-
Description:
Modify schedule api in ScheduleAfterDebounceTime to take an error handling
callback
[
https://issues.apache.org/jira/browse/SAMZA-1128?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Navina Ramesh updated SAMZA-1128:
-
Description:
ZkBarrierForVersionUpgrade is tightly coupled with the _ZkJobCoordinator_
Navina Ramesh created SAMZA-1294:
Summary: Modify schedule api in ScheduleAfterDebounceTime to take
an error handling callback
Key: SAMZA-1294
URL: https://issues.apache.org/jira/browse/SAMZA-1294
[
https://issues.apache.org/jira/browse/SAMZA-1128?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Navina Ramesh updated SAMZA-1128:
-
Parent Issue: SAMZA-1173 (was: SAMZA-1064)
> Remove dependency of debounce timer f
[
https://issues.apache.org/jira/browse/SAMZA-1293?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16011764#comment-16011764
]
Navina Ramesh commented on SAMZA-1293:
--
> I am working on the SEP and will provide link to the
[
https://issues.apache.org/jira/browse/SAMZA-1293?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16011735#comment-16011735
]
Navina Ramesh commented on SAMZA-1293:
--
[~lindong] Can you please explain what this JIRA is about
[
https://issues.apache.org/jira/browse/SAMZA-1162?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Navina Ramesh reassigned SAMZA-1162:
Assignee: (was: Navina Ramesh)
> Review tryBecomeLeader implementation to
[
https://issues.apache.org/jira/browse/SAMZA-1128?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Navina Ramesh reassigned SAMZA-1128:
Assignee: Navina Ramesh (was: Boris Shkolnik)
> Remove dependency of debounce timer f
1 - 100 of 939 matches
Mail list logo
