[GitHub] samza pull request #869: SAMZA-2022: Integrate startpoints with SystemConsum...

2018-12-21 Thread dnishimura
GitHub user dnishimura opened a pull request: https://github.com/apache/samza/pull/869 SAMZA-2022: Integrate startpoints with SystemConsumers This PR integrates the `Startpoint` with the `SystemConsumers` multiplexer class. The general logic is if there is a `Startpoint` for an SSP

[GitHub] samza pull request #868: Minor: Disable outdated sonar-scanner in .travis.ym...

2018-12-21 Thread dnishimura
GitHub user dnishimura opened a pull request: https://github.com/apache/samza/pull/868 Minor: Disable outdated sonar-scanner in .travis.yml file. Causing Travis-CI builds to appear broken on master. You can merge this pull request into a Git repository by running: $ git pull

[GitHub] samza pull request #860: SAMZA-1985: Startpoint and StartpointManager implem...

2018-12-12 Thread dnishimura
GitHub user dnishimura opened a pull request: https://github.com/apache/samza/pull/860 SAMZA-1985: Startpoint and StartpointManager implementation. This is the first PR for [SEP-18](https://cwiki.apache.org/confluence/display/SAMZA/SEP-18%3A+Startpoints+-+Manipulating+Starting

[GitHub] samza pull request #801: SAMZA-1988: Properly suffix modules with direct Sca...

2018-11-09 Thread dnishimura
GitHub user dnishimura opened a pull request: https://github.com/apache/samza/pull/801 SAMZA-1988: Properly suffix modules with direct Scala dependencies with the Scala version. List of modules without a Scala version suffix that have direct Scala dependencies and the direct Scala

[GitHub] samza pull request #669: SAMZA-1918: Convert Kafka connector doc to `.md`

2018-09-27 Thread dnishimura
GitHub user dnishimura opened a pull request: https://github.com/apache/samza/pull/669 SAMZA-1918: Convert Kafka connector doc to `.md` @vjagadish1989 please review. ![screen shot 2018-09-27 at 10 42 08 am](https://user-images.githubusercontent.com/512169/46164266-69980280

[GitHub] samza pull request #550: SAMZA-1742: Add metrics reporter parameter to Local...

2018-06-07 Thread dnishimura
GitHub user dnishimura opened a pull request: https://github.com/apache/samza/pull/550 SAMZA-1742: Add metrics reporter parameter to LocalApplicationRunner constructor. @vjagadish1989 this has already been reviewed and approved by you and @cameronlee314 internally. Please approve

[GitHub] samza pull request #442: SAMZA-1608 : Add hidden config to enable explicit s...

2018-03-09 Thread dnishimura
GitHub user dnishimura opened a pull request: https://github.com/apache/samza/pull/442 SAMZA-1608 : Add hidden config to enable explicit stream creation in StreamAppender due to bug. Due to a intermittent bug that causes the explicit stream creation in `StreamAppender` to hang

[GitHub] samza pull request #423: SAMZA-1460: StreamAppender does not explicitly crea...

2018-02-16 Thread dnishimura
GitHub user dnishimura opened a pull request: https://github.com/apache/samza/pull/423 SAMZA-1460: StreamAppender does not explicitly create logging topic Creates the StreamAppender stream explicitly instead of relying on auto stream creation. You can merge this pull request

[GitHub] samza pull request #413: SAMZA-1555: Move creation of checkpoint and changel...

2018-01-23 Thread dnishimura
GitHub user dnishimura opened a pull request: https://github.com/apache/samza/pull/413 SAMZA-1555: Move creation of checkpoint and changelog streams to the Job Coordinators **Overview** The purpose of this PR is to consolidate the creation of the changelog and checkpoint

[GitHub] samza pull request #411: Move the changelog and checkpoint stream creation t...

2018-01-23 Thread dnishimura
Github user dnishimura closed the pull request at: https://github.com/apache/samza/pull/411 ---

[GitHub] samza pull request #411: Move the changelog and checkpoint stream creation t...

2018-01-22 Thread dnishimura
GitHub user dnishimura opened a pull request: https://github.com/apache/samza/pull/411 Move the changelog and checkpoint stream creation to the job coordinators. **Overview** The purpose of this PR is to consolidate the creation of the changelog and checkpoint streams

[GitHub] samza pull request #371: SAMZA-1514: Prevent changelog stream names with emp...

2017-11-28 Thread dnishimura
GitHub user dnishimura opened a pull request: https://github.com/apache/samza/pull/371 SAMZA-1514: Prevent changelog stream names with empty strings. This fix prevents changelog stream names with empty or whitespace-only strings. You can merge this pull request into a Git

[GitHub] samza pull request #323: SAMZA-1453: Update README with Travis-CI badge.

2017-10-11 Thread dnishimura
GitHub user dnishimura opened a pull request: https://github.com/apache/samza/pull/323 SAMZA-1453: Update README with Travis-CI badge. Added Travis-CI to README.md file. You can merge this pull request into a Git repository by running: $ git pull https://github.com/dnishimura

[GitHub] samza pull request #306: SAMZA-1429: Add callback success/failure metrics to...

2017-09-28 Thread dnishimura
GitHub user dnishimura opened a pull request: https://github.com/apache/samza/pull/306 SAMZA-1429: Add callback success/failure metrics to async tasks @jmakes & @nickpan47 please take a look when you get the chance. You can merge this pull request into a Git repository by run

[GitHub] samza pull request #305: SAMZA-1431: Enable SonarCloud integration with Trav...

2017-09-27 Thread dnishimura
GitHub user dnishimura opened a pull request: https://github.com/apache/samza/pull/305 SAMZA-1431: Enable SonarCloud integration with Travis-CI. These are modifications needed to integrate Travis-CI with SonarCloud. Also, the JaCoCo plugin is enabled in gradle for code coverage

[GitHub] samza pull request #298: SAMZA-1414: SamzaContainer log statements incorrect...

2017-09-19 Thread dnishimura
GitHub user dnishimura opened a pull request: https://github.com/apache/samza/pull/298 SAMZA-1414: SamzaContainer log statements incorrectly expect containerId is a number Correctly log ID as a string in SamzaContainer. @jmakes You can merge this pull request into a Git

[GitHub] samza pull request #296: SAMZA-1416 : Better logging around the exception wh...

2017-09-15 Thread dnishimura
GitHub user dnishimura opened a pull request: https://github.com/apache/samza/pull/296 SAMZA-1416 : Better logging around the exception where class loading failed in initializing the SystemFactory for a input/output system Also added test coverage for the Util.getObj method

[GitHub] samza pull request #294: Travis build script

2017-09-08 Thread dnishimura
Github user dnishimura closed the pull request at: https://github.com/apache/samza/pull/294 ---

[GitHub] samza pull request #294: Travis build script

2017-09-08 Thread dnishimura
GitHub user dnishimura opened a pull request: https://github.com/apache/samza/pull/294 Travis build script You can merge this pull request into a Git repository by running: $ git pull https://github.com/dnishimura/samza travis-build-script Alternatively you can review