GitHub user nickpan47 opened a pull request:
https://github.com/apache/samza/pull/746
Adding Samza 1.0 API docs
@jagadish-v0 @prateekm please take a look. Thanks!
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/nickpan47/samza
GitHub user nickpan47 opened a pull request:
https://github.com/apache/samza/pull/642
Samza 1814: consolidate JobNode and JobGraph configuration generation for
high and low-level API applications
High-level changes:
- Move configuration generation to
GitHub user nickpan47 opened a pull request:
https://github.com/apache/samza/pull/620
Samza 1836: StreamManager created before ExecutionPlanner should also apply
configuration overrides
Our integration test framework uses configuration overrides (i.e. jobs.*)
to override the user
GitHub user nickpan47 opened a pull request:
https://github.com/apache/samza/pull/617
SAMZA-1826: Fix unit test failure in table tests
The way that we verify the join counts in PageViewToProfileJoinFunction
across multiple table tests (i.e. TestLocalTable, TestRemoteTable
GitHub user nickpan47 opened a pull request:
https://github.com/apache/samza/pull/606
SAMZA-1789: unify ApplicationDescriptor and ApplicationRunner for high- and
low-level APIs in YARN and standalone environment
This is the initial PR for SEP-13. High-lighted changes:
- Define
GitHub user nickpan47 opened a pull request:
https://github.com/apache/samza/pull/523
SAMZA-1715: Unit test for Kafka admin deletedMessagesCalled() fail
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/nickpan47/samza fix
GitHub user nickpan47 opened a pull request:
https://github.com/apache/samza/pull/475
SAMZA-1659: Serializable OperatorSpec
This change is to make the user supplied functions serializable. Hence,
making the full user defined DAG serializable.
You can merge this pull request into a
GitHub user nickpan47 opened a pull request:
https://github.com/apache/samza/pull/435
SAMZA-1600: remove the combination of cleanup policy "compact,delete"â¦
⦠in changelog topic properties
You can merge this pull request into a Git repository by running:
$ git
GitHub user nickpan47 opened a pull request:
https://github.com/apache/samza/pull/363
SAMZA-1482: add config documentation for auto-restart/fail behavior oâ¦
â¦n partition count changes
You can merge this pull request into a Git repository by running:
$ git pull https
GitHub user nickpan47 opened a pull request:
https://github.com/apache/samza/pull/351
SAMZA-1482: Restart or fail Samza jobs in YARN when detecting changesâ¦
⦠in input topic partitions
Some high-lights of the changes:
# always instantiating
GitHub user nickpan47 opened a pull request:
https://github.com/apache/samza/pull/242
SAMZA-1358: fix the bug in validating task.class empty string when apâ¦
â¦p.class is configured
Another bug due to scala/java differences.
You can merge this pull request into a Git
GitHub user nickpan47 opened a pull request:
https://github.com/apache/samza/pull/228
SAMZA-1334: fix pre-condition for ContainerAllocator to work properly
We have observed issues when the LocalityManager reports the container
locality mapping while the host-affinity is disabled in
GitHub user nickpan47 opened a pull request:
https://github.com/apache/samza/pull/133
SAMZA-1226: relax type parameters in MessageStream functions
relax the type parameter in user supplied functions in fluent API
You can merge this pull request into a Git repository by running
GitHub user nickpan47 opened a pull request:
https://github.com/apache/samza/pull/129
SAMZA-1215, SAMZA-1216: remove ProcessKiller and change the ZooKeeper
connection string in test
⦠test to use 127.0.0.1 in connect string
You can merge this pull request into a Git repository
GitHub user nickpan47 opened a pull request:
https://github.com/apache/samza/pull/128
SAMZA-1157: Serialization/deserialization throwables should not be
suppressed
â¦ppressed if user don't configure to drop those errors
You can merge this pull request into a Git reposito
GitHub user nickpan47 opened a pull request:
https://github.com/apache/samza/pull/65
SAMZA-1093: instantiating StreamOperatorTask in SamzaContainer (WIP)
SAMZA-1093: Instantiating StreamOperatorTask in SamzaContainer
- minor refactor to get the TaskFactory based on task
GitHub user nickpan47 opened a pull request:
https://github.com/apache/samza/pull/59
SAMZA-1097: update master branch to use 0.13.0-SNAPSHOT version
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/nickpan47/samza SAMZA-1097
GitHub user nickpan47 opened a pull request:
https://github.com/apache/samza/pull/58
SAMZA-1092: replace stream spec in fluent API
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/nickpan47/samza replace-stream-spec
Github user nickpan47 closed the pull request at:
https://github.com/apache/samza/pull/55
---
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 nickpan47 opened a pull request:
https://github.com/apache/samza/pull/55
SAMZA-1073: Remove operator module. Move all classes into samza-core
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/nickpan47/samza remove
GitHub user nickpan47 opened a pull request:
https://github.com/apache/samza/pull/51
SAMZA-1073: top-level fluent API
`Initial draft of top-level fluent API for operator DAGs
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/apache
Github user nickpan47 closed the pull request at:
https://github.com/apache/samza/pull/22
---
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 nickpan47 closed the pull request at:
https://github.com/apache/samza/pull/23
---
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 nickpan47 opened a pull request:
https://github.com/apache/samza/pull/23
Samza 1051
Merged all changes from operator APIs and added interface stability
annotation.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com
GitHub user nickpan47 opened a pull request:
https://github.com/apache/samza/pull/22
SAMZA-1050: Make samza-operator independent of avro version
Prep for merging the samza-operator APIs to master: removing the direct
dependency on avro.
You can merge this pull request into a Git
Github user nickpan47 closed the pull request at:
https://github.com/apache/samza/pull/21
---
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 nickpan47 opened a pull request:
https://github.com/apache/samza/pull/21
SAMZA-1050: Make samza-operator independent of avro version
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/apache/samza master
Alternatively
27 matches
Mail list logo
