[GitHub] samza pull request #53: Samza 1075 - Refactor SystemAdmin Interface to expos...

2017-02-15 Thread jmakes
GitHub user jmakes opened a pull request: https://github.com/apache/samza/pull/53 Samza 1075 - Refactor SystemAdmin Interface to expose a common method to create streams. You can merge this pull request into a Git repository by running: $ git pull https://github.com/jmakes

[GitHub] samza pull request #56: SAMZA-1075: fix partitionCount assertion from PR53

2017-02-17 Thread jmakes
GitHub user jmakes opened a pull request: https://github.com/apache/samza/pull/56 SAMZA-1075: fix partitionCount assertion from PR53 You can merge this pull request into a Git repository by running: $ git pull https://github.com/jmakes/samza samza-1075 Alternatively you can

[GitHub] samza pull request #56: SAMZA-1075: fix partitionCount assertion from PR53

2017-02-17 Thread jmakes
Github user jmakes closed the pull request at: https://github.com/apache/samza/pull/56 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[GitHub] samza pull request #57: SAMZA-1075: fix partitionCount assertion from PR53

2017-02-17 Thread jmakes
GitHub user jmakes opened a pull request: https://github.com/apache/samza/pull/57 SAMZA-1075: fix partitionCount assertion from PR53 @nickpan47 here's the fix for the issue you found in PR53 You can merge this pull request into a Git repository by running: $ git pull

[GitHub] samza pull request #74: SAMZA-1096: StreamSpec constructors in the Execution...

2017-03-03 Thread jmakes
GitHub user jmakes opened a pull request: https://github.com/apache/samza/pull/74 SAMZA-1096: StreamSpec constructors in the ExecutionEnvironments You can merge this pull request into a Git repository by running: $ git pull https://github.com/jmakes/samza samza-1096

[GitHub] samza pull request #93: samza-1156: Improve ApplicationRunner method naming ...

2017-03-20 Thread jmakes
GitHub user jmakes opened a pull request: https://github.com/apache/samza/pull/93 samza-1156: Improve ApplicationRunner method naming and class structure @navina @xinyuiscoool @nickpan47 take a look You can merge this pull request into a Git repository by running: $ git pull

[GitHub] samza pull request #101: SAMZA-1167: New streamId-specific configs do not ov...

2017-03-28 Thread jmakes
GitHub user jmakes opened a pull request: https://github.com/apache/samza/pull/101 SAMZA-1167: New streamId-specific configs do not override equivalent system-scoped configs You can merge this pull request into a Git repository by running: $ git pull https://github.com

[GitHub] samza pull request #106: SAMZA-1089: Runner should support kill and status c...

2017-03-31 Thread jmakes
GitHub user jmakes opened a pull request: https://github.com/apache/samza/pull/106 SAMZA-1089: Runner should support kill and status commands You can merge this pull request into a Git repository by running: $ git pull https://github.com/jmakes/samza samza-1089-2

[GitHub] samza pull request #111: SAMZA-1189: Fix file system closed issue on hdfs sy...

2017-04-04 Thread jmakes
GitHub user jmakes opened a pull request: https://github.com/apache/samza/pull/111 SAMZA-1189: Fix file system closed issue on hdfs system producer You can merge this pull request into a Git repository by running: $ git pull https://github.com/jmakes/samza samza-1189

[GitHub] samza pull request #114: SAMZA-1089: Enable YarnJob and ClientHelper to kill...

2017-04-06 Thread jmakes
GitHub user jmakes opened a pull request: https://github.com/apache/samza/pull/114 SAMZA-1089: Enable YarnJob and ClientHelper to kill a job by name rather than YARN ApplicationID Missed a couple files in the previous commit to enable YarnJob to kill and get status of a Job based

[GitHub] samza pull request #141: Samza 1214: Allow users to set a default replicatio...

2017-04-26 Thread jmakes
GitHub user jmakes opened a pull request: https://github.com/apache/samza/pull/141 Samza 1214: Allow users to set a default replication.factor for intermediate topics * Add a new "systems.sysName.default.stream.*" config structure that allows users to set system-wide de

[GitHub] samza pull request #150: SAMZA-1214: Bug - system-scoped stream default conf...

2017-05-01 Thread jmakes
GitHub user jmakes opened a pull request: https://github.com/apache/samza/pull/150 SAMZA-1214: Bug - system-scoped stream default configs may not be honored * Re-introduced deprecated system-stream configs into config table * Fixed position of task.consumer.batch.size in config

[GitHub] samza pull request #152: SAMZA-1250: JobRunner.kill doesn't terminate cleanl...

2017-05-01 Thread jmakes
GitHub user jmakes opened a pull request: https://github.com/apache/samza/pull/152 SAMZA-1250: JobRunner.kill doesn't terminate cleanly with YarnJob. 1. The ClientHelper now checks inactive application IDs so it can get status for terminated jobs in addition to running jobs

[GitHub] samza pull request #155: SAMZA-1256: Improve trace logging for troubleshooti...

2017-05-02 Thread jmakes
GitHub user jmakes opened a pull request: https://github.com/apache/samza/pull/155 SAMZA-1256: Improve trace logging for troubleshooting the fluent API You can merge this pull request into a Git repository by running: $ git pull https://github.com/jmakes/samza operator-trace

[GitHub] samza pull request #165: SAMZA-1263: Samza Fluent: NPE is streams.id.samza.s...

2017-05-04 Thread jmakes
GitHub user jmakes opened a pull request: https://github.com/apache/samza/pull/165 SAMZA-1263: Samza Fluent: NPE is streams.id.samza.system is missing You can merge this pull request into a Git repository by running: $ git pull https://github.com/jmakes/samza samza-1263

[GitHub] samza pull request #167: SAMZA-1266: Unable to use MetricsSnapshotReporterFa...

2017-05-05 Thread jmakes
GitHub user jmakes opened a pull request: https://github.com/apache/samza/pull/167 SAMZA-1266: Unable to use MetricsSnapshotReporterFactory with fluent API You can merge this pull request into a Git repository by running: $ git pull https://github.com/jmakes/samza samza-1266

[GitHub] samza pull request #176: SAMZA-1275: Kafka throws when users configure repli...

2017-05-09 Thread jmakes
GitHub user jmakes opened a pull request: https://github.com/apache/samza/pull/176 SAMZA-1275: Kafka throws when users configure replication.factor for … …Kafka default stream You can merge this pull request into a Git repository by running: $ git pull https://github.com

[GitHub] samza pull request #190: SAMZA-1290: Fix javadoc for ApplicationRuner

2017-05-12 Thread jmakes
GitHub user jmakes opened a pull request: https://github.com/apache/samza/pull/190 SAMZA-1290: Fix javadoc for ApplicationRuner You can merge this pull request into a Git repository by running: $ git pull https://github.com/jmakes/samza samza-1290 Alternatively you can

[GitHub] samza pull request #204: SAMZA-1234: Documentation for 0.13.0 release

2017-05-26 Thread jmakes
GitHub user jmakes opened a pull request: https://github.com/apache/samza/pull/204 SAMZA-1234: Documentation for 0.13.0 release You can merge this pull request into a Git repository by running: $ git pull https://github.com/jmakes/samza samza-1236-tutorial-1 Alternatively

[GitHub] samza pull request #209: Adding gpg key for Jake Maes

2017-06-01 Thread jmakes
GitHub user jmakes opened a pull request: https://github.com/apache/samza/pull/209 Adding gpg key for Jake Maes You can merge this pull request into a Git repository by running: $ git pull https://github.com/jmakes/samza gpg-key Alternatively you can review and apply these

[GitHub] samza pull request #212: SAMZA-1317: Changelog topic configuration should ac...

2017-06-02 Thread jmakes
GitHub user jmakes opened a pull request: https://github.com/apache/samza/pull/212 SAMZA-1317: Changelog topic configuration should accept streams.[streamId] configurations You can merge this pull request into a Git repository by running: $ git pull https://github.com/jmakes

[GitHub] samza pull request #213: SAMZA-1317: Changelog validation error for topics w...

2017-06-02 Thread jmakes
GitHub user jmakes opened a pull request: https://github.com/apache/samza/pull/213 SAMZA-1317: Changelog validation error for topics with period in the You can merge this pull request into a Git repository by running: $ git pull https://github.com/jmakes/samza samza-1317

[GitHub] samza pull request #215: Website updates for 0.13.0 release

2017-06-05 Thread jmakes
GitHub user jmakes opened a pull request: https://github.com/apache/samza/pull/215 Website updates for 0.13.0 release You can merge this pull request into a Git repository by running: $ git pull https://github.com/jmakes/samza samza-0.13.0-website Alternatively you can

[GitHub] samza pull request #226: SAMZA-1335: Improve logging for LocalStoreMonitor

2017-06-15 Thread jmakes
GitHub user jmakes opened a pull request: https://github.com/apache/samza/pull/226 SAMZA-1335: Improve logging for LocalStoreMonitor You can merge this pull request into a Git repository by running: $ git pull https://github.com/jmakes/samza samza-1335 Alternatively you can

[GitHub] samza pull request #232: SAMZA-1346: GroupByContainerCount.balance() should ...

2017-06-26 Thread jmakes
GitHub user jmakes opened a pull request: https://github.com/apache/samza/pull/232 SAMZA-1346: GroupByContainerCount.balance() should guard against null… … LocalityManager You can merge this pull request into a Git repository by running: $ git pull https://github.com

[GitHub] samza pull request #233: SAMZA-1347: GroupByContainerIds NPE if containerIds...

2017-06-26 Thread jmakes
GitHub user jmakes opened a pull request: https://github.com/apache/samza/pull/233 SAMZA-1347: GroupByContainerIds NPE if containerIds list is null You can merge this pull request into a Git repository by running: $ git pull https://github.com/jmakes/samza samza-1347

[GitHub] samza pull request #241: SAMZA-1356: Improve monitoring for state restore

2017-06-30 Thread jmakes
GitHub user jmakes opened a pull request: https://github.com/apache/samza/pull/241 SAMZA-1356: Improve monitoring for state restore You can merge this pull request into a Git repository by running: $ git pull https://github.com/jmakes/samza samza-1356 Alternatively you can

[GitHub] samza pull request #245: SAMZA-1366: ScriptRunner should allow callers to co...

2017-07-20 Thread jmakes
GitHub user jmakes opened a pull request: https://github.com/apache/samza/pull/245 SAMZA-1366: ScriptRunner should allow callers to control the child pr… …ocess environment. You can merge this pull request into a Git repository by running: $ git pull https://github.com

[GitHub] samza pull request #263: SAMZA-1384: Race condition with async commit affect...

2017-08-08 Thread jmakes
GitHub user jmakes opened a pull request: https://github.com/apache/samza/pull/263 SAMZA-1384: Race condition with async commit affects checkpoint correctness You can merge this pull request into a Git repository by running: $ git pull https://github.com/jmakes/samza samza

[GitHub] samza pull request #266: SAMZA-1387: Unable to Start Samza App Because Regex...

2017-08-10 Thread jmakes
GitHub user jmakes opened a pull request: https://github.com/apache/samza/pull/266 SAMZA-1387: Unable to Start Samza App Because Regex Check You can merge this pull request into a Git repository by running: $ git pull https://github.com/jmakes/samza samza-1387 Alternatively

[GitHub] samza pull request #269: SAMZA-1388: Flaky test - TestStatefulTask#testShoul...

2017-08-11 Thread jmakes
GitHub user jmakes opened a pull request: https://github.com/apache/samza/pull/269 SAMZA-1388: Flaky test - TestStatefulTask#testShouldStartAndRestore I believe the problem originated from SAMZA-173. The core issue is testShouldRestoreStore was not updated to expect 6

[GitHub] samza pull request #272: SAMZA-1392: KafkaSystemProducer performance and cor...

2017-08-15 Thread jmakes
GitHub user jmakes opened a pull request: https://github.com/apache/samza/pull/272 SAMZA-1392: KafkaSystemProducer performance and correctness with conc… …urrent sends and flushes You can merge this pull request into a Git repository by running: $ git pull https

[GitHub] samza pull request #300: SAMZA-1428: Fix scala 2.10 compilation issue with j...

2017-09-21 Thread jmakes
GitHub user jmakes opened a pull request: https://github.com/apache/samza/pull/300 SAMZA-1428: Fix scala 2.10 compilation issue with java 8 interface st… …atic methods You can merge this pull request into a Git repository by running: $ git pull https://github.com/jmakes

[GitHub] samza pull request #313: SAMZA-1439: Address late review feedback from SAMZA...

2017-10-04 Thread jmakes
GitHub user jmakes opened a pull request: https://github.com/apache/samza/pull/313 SAMZA-1439: Address late review feedback from SAMZA-1434 You can merge this pull request into a Git repository by running: $ git pull https://github.com/jmakes/samza samza-1439 Alternatively

[GitHub] samza pull request #331: Restore old startingOffset behavior for KafakCheckp...

2017-10-17 Thread jmakes
GitHub user jmakes opened a pull request: https://github.com/apache/samza/pull/331 Restore old startingOffset behavior for KafakCheckpointManager You can merge this pull request into a Git repository by running: $ git pull https://github.com/jmakes/samza master Alternatively

[GitHub] samza pull request #338: SAMZA-1470: Wrong job status returned by YarnRestJo...

2017-10-25 Thread jmakes
GitHub user jmakes opened a pull request: https://github.com/apache/samza/pull/338 SAMZA-1470: Wrong job status returned by YarnRestJobStatusProvider when there are multiple app attempts You can merge this pull request into a Git repository by running: $ git pull https

[GitHub] samza pull request #339: SAMZA-1470: Wrong job status returned by YarnRestJo...

2017-10-25 Thread jmakes
GitHub user jmakes opened a pull request: https://github.com/apache/samza/pull/339 SAMZA-1470: Wrong job status returned by YarnRestJobStatusProvider wh… …en there are multiple app You can merge this pull request into a Git repository by running: $ git pull https

[GitHub] samza pull request #338: SAMZA-1470: Wrong job status returned by YarnRestJo...

2017-10-25 Thread jmakes
Github user jmakes closed the pull request at: https://github.com/apache/samza/pull/338 ---

[GitHub] samza pull request #340: SAMZA-1472: YarnRestJobStatusProvider constructor m...

2017-10-25 Thread jmakes
GitHub user jmakes opened a pull request: https://github.com/apache/samza/pull/340 SAMZA-1472: YarnRestJobStatusProvider constructor must be public You can merge this pull request into a Git repository by running: $ git pull https://github.com/jmakes/samza samza-1472

[GitHub] samza pull request #350: SAMZA-1480: TaskStorageManager improperly initializ...

2017-11-02 Thread jmakes
GitHub user jmakes opened a pull request: https://github.com/apache/samza/pull/350 SAMZA-1480: TaskStorageManager improperly initializes changelog consu… …mer position when restoring a store from disk You can merge this pull request into a Git repository by running: $ git

[GitHub] samza pull request #367: SAMZA-1508: JobRunner should not return success unt...

2017-11-22 Thread jmakes
GitHub user jmakes opened a pull request: https://github.com/apache/samza/pull/367 SAMZA-1508: JobRunner should not return success until the job is healthy You can merge this pull request into a Git repository by running: $ git pull https://github.com/jmakes/samza samza-1508

[GitHub] samza pull request #372: SAMZA-1518: Add CPU utilization and thread count to...

2017-11-28 Thread jmakes
GitHub user jmakes opened a pull request: https://github.com/apache/samza/pull/372 SAMZA-1518: Add CPU utilization and thread count to JVM metrics You can merge this pull request into a Git repository by running: $ git pull https://github.com/jmakes/samza samza-1518

[GitHub] samza pull request #388: SAMZA-1537: StreamAppender can deadlock due to lock...

2017-12-14 Thread jmakes
GitHub user jmakes opened a pull request: https://github.com/apache/samza/pull/388 SAMZA-1537: StreamAppender can deadlock due to locks held by Kafka an… …d Log4j You can merge this pull request into a Git repository by running: $ git pull https://github.com/jmakes/samza

[GitHub] samza pull request #390: SAMZA-1539: KafkaProducer potential hang on close()...

2017-12-20 Thread jmakes
GitHub user jmakes opened a pull request: https://github.com/apache/samza/pull/390 SAMZA-1539: KafkaProducer potential hang on close() when task.drop.pr… …oducer.errors==true You can merge this pull request into a Git repository by running: $ git pull https://github.com

[GitHub] samza pull request #391: Merge script improvement - use colons instead of se...

2017-12-20 Thread jmakes
GitHub user jmakes opened a pull request: https://github.com/apache/samza/pull/391 Merge script improvement - use colons instead of semicolons You can merge this pull request into a Git repository by running: $ git pull https://github.com/jmakes/samza merge-script

[GitHub] samza pull request #393: Fix a couple sonarcloud issues with samza-1537

2017-12-22 Thread jmakes
GitHub user jmakes opened a pull request: https://github.com/apache/samza/pull/393 Fix a couple sonarcloud issues with samza-1537 You can merge this pull request into a Git repository by running: $ git pull https://github.com/jmakes/samza streamappender-sonarcloud

[GitHub] samza pull request #407: SAMZA-1558: State restore metrics should be duplica...

2018-01-17 Thread jmakes
GitHub user jmakes opened a pull request: https://github.com/apache/samza/pull/407 SAMZA-1558: State restore metrics should be duplicated and deprecated… … to avoid type conflicts You can merge this pull request into a Git repository by running: $ git pull https

[GitHub] samza pull request #412: SAMZA-1562: TaskStorageManager should delete any lo...

2018-01-22 Thread jmakes
GitHub user jmakes opened a pull request: https://github.com/apache/samza/pull/412 SAMZA-1562: TaskStorageManager should delete any local store it canno… …t open. You can merge this pull request into a Git repository by running: $ git pull https://github.com/jmakes/samza