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 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 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 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 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 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 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 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 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 user dnishimura closed the pull request at:
https://github.com/apache/samza/pull/411
---
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 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 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 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 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 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 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 user dnishimura closed the pull request at:
https://github.com/apache/samza/pull/294
---
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
19 matches
Mail list logo