GitHub user lindong28 opened a pull request:
https://github.com/apache/samza/pull/193
SAMZA-1293: Enable partition expansion of input streams (SEP-4)
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/lindong28/samza SAMZA-1293
Github user lindong28 closed the pull request at:
https://github.com/apache/samza/pull/193
---
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 user lindong28 opened a pull request:
https://github.com/apache/samza/pull/214
SAMZA-1293: Enable partition expansion of input streams (SEP-5)
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/lindong28/samza SAMZA-1293
GitHub user lindong28 opened a pull request:
https://github.com/apache/samza/pull/347
SAMZA-1478; Delete unneeded data from intermediate Kafka topic on offset
commit
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/lindong28
GitHub user lindong28 opened a pull request:
https://github.com/apache/samza/pull/356
SAMZA-1478; Delete unneeded data from intermediate Kafka topic on offset
commit
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/lindong28
GitHub user lindong28 opened a pull request:
https://github.com/apache/samza/pull/395
SAMZA-1530; Bump up Kafka dependency to 0.11
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/lindong28/samza SAMZA-1530
Alternatively you can
GitHub user lindong28 opened a pull request:
https://github.com/apache/samza/pull/397
SAMZA-1548; Add start() and stop() to SystemAdmin
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/lindong28/samza SAMZA-1548
Alternatively
Github user lindong28 closed the pull request at:
https://github.com/apache/samza/pull/395
---
GitHub user lindong28 reopened a pull request:
https://github.com/apache/samza/pull/395
SAMZA-1530; Bump up Kafka dependency to 0.11
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/lindong28/samza SAMZA-1530
Alternatively you
GitHub user lindong28 opened a pull request:
https://github.com/apache/samza/pull/417
SAMZA-1489; TaskInstance should commit offset before it closes() if auto
commit is enabled
You can merge this pull request into a Git repository by running:
$ git pull https://github.com
GitHub user lindong28 opened a pull request:
https://github.com/apache/samza/pull/418
SAMZA-1579; RemoteApplicationRunner should allow user to kill app or query
app status
You can merge this pull request into a Git repository by running:
$ git pull https://github.com
Github user lindong28 closed the pull request at:
https://github.com/apache/samza/pull/418
---
Github user lindong28 closed the pull request at:
https://github.com/apache/samza/pull/214
---
GitHub user lindong28 opened a pull request:
https://github.com/apache/samza/pull/668
SAMZA-1919; Add KafkaSystemDescriptor constructor to allow arbitrary
factory class
Currently KafkaSystemDescriptor is hardcoded to use
org.apache.samza.system.kafka.KafkaSystemFactory as the
Github user lindong28 closed the pull request at:
https://github.com/apache/samza/pull/668
---
15 matches
Mail list logo