GitHub user bharathkk opened a pull request:
https://github.com/apache/samza/pull/786
SAMZA-1971: Fix NPE in partition key computation for InMemorySystemProducer
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/bharathkk/samza
GitHub user bharathkk opened a pull request:
https://github.com/apache/samza/pull/748
SAMZA-1949: Add java docs and configuration documentation for side inputs
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/bharathkk/samza side
GitHub user bharathkk opened a pull request:
https://github.com/apache/samza/pull/707
Fix local side input table tests to use java.io.tmp directory
Use java.io.tmp directory for tests instead of temporary folder inside
module directories.
You can merge this pull request into a Git
GitHub user bharathkk opened a pull request:
https://github.com/apache/samza/pull/701
Fix side input stores to use logged store directory
Side input stores are non-changelog stores that still needs to use logged
stored directory to guarantee durability.
You can merge this pull
GitHub user bharathkk opened a pull request:
https://github.com/apache/samza/pull/700
Fix broken tests caused due to merging
Due to interleaved ordering of the PRs
(https://github.com/apache/samza/pull/675 and
https://github.com/apache/samza/pull/673), FaultInjectionTest is broken
GitHub user bharathkk opened a pull request:
https://github.com/apache/samza/pull/699
Fix potential null pointer issues in StreamOperatorTask
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/bharathkk/samza bug-fix
Alternatively
GitHub user bharathkk opened a pull request:
https://github.com/apache/samza/pull/674
SAMZA-1924: Documentation for case-studies and release-notes
This PR covers the following
- Documentation work for case-studies (Slack and Linkedin use-case)
- Documentation work for past
Github user bharathkk closed the pull request at:
https://github.com/apache/samza/pull/660
---
GitHub user bharathkk opened a pull request:
https://github.com/apache/samza/pull/673
SAMZA-1832: Fix race condition between StreamProcessor and
SamzaContainerListener
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/bharathkk
GitHub user bharathkk opened a pull request:
https://github.com/apache/samza/pull/660
Samza 1832 - Fix race condition between StreamProcessor and
SamzaContainerListener
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/bharathkk
GitHub user bharathkk opened a pull request:
https://github.com/apache/samza/pull/607
SAMZA-1809: Add more logging to intermediate topic partition count inference
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/bharathkk/samza
GitHub user bharathkk opened a pull request:
https://github.com/apache/samza/pull/601
SAMZA-1803: Make InMemoryManager system aware
- Fix getSystemStreamMetadata in InMemoryManager to filter based on the
system name on top of stream names
You can merge this pull request into a Git
GitHub user bharathkk opened a pull request:
https://github.com/apache/samza/pull/594
SideInput: Added tests and fixed serde issue during writing offsets
- Fixed serde issues during persisted offsets locally
- Added unit tests for TaskSideInputStorageManager
- Added
GitHub user bharathkk opened a pull request:
https://github.com/apache/samza/pull/582
Handle end of stream in BootstrapChooser
Handle end of stream envelopes in bootstrap chooser and don't invoke check
offsets since offset of end of stream are not comparable.
You can merge
GitHub user bharathkk opened a pull request:
https://github.com/apache/samza/pull/580
Side inputs: Bug fixes
- Use the correct regex in Util#getSystemStreamFromNameOrId
- Handle end of stream during dispatch of message to side input
processor
- Fix validation to check
Github user bharathkk closed the pull request at:
https://github.com/apache/samza/pull/569
---
GitHub user bharathkk opened a pull request:
https://github.com/apache/samza/pull/570
SAMZA-1773: Side inputs for local stores
@prateekm @vjagadish
Please take a look.
I will update the PR with the unit tests for SideInputStorageManager and
the util functions.
You
GitHub user bharathkk opened a pull request:
https://github.com/apache/samza/pull/569
Initial implementation of side input stores
@prateekm
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/bharathkk/samza side-input-v2
GitHub user bharathkk opened a pull request:
https://github.com/apache/samza/pull/503
SAMZA-1653: Support waitForFinish in remote application runner and add
waitForFinish
Added the following APIs to AbstractApplicationRunner
`void waitForFinish()`
`void waitForFinish
GitHub user bharathkk opened a pull request:
https://github.com/apache/samza/pull/491
Samza-1563: Make RocksDB store base directory configurable
@xinyuiscool ^^
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/bharathkk/samza
GitHub user bharathkk opened a pull request:
https://github.com/apache/samza/pull/459
Initial version for in memory system.
Getting the PR out to unblock sanil.
Pending tasks
1. Add documentation
2. Add more tests
3. Currently initialization of the stream happens
GitHub user bharathkk opened a pull request:
https://github.com/apache/samza/pull/344
SAMZA-1474: Bump up rocksdb version to 5.7.3 to include licensing changes
You can find more details on the bug fixes and API changes
[here](https://github.com/facebook/rocksdb/releases). I
GitHub user bharathkk opened a pull request:
https://github.com/apache/samza/pull/291
Remove latch sharing between task and tests to enable parallel execution
Refactoring the tests to enable parallel execution. Also, removed
unnecessary sleeping during execution. This PR will serve
GitHub user bharathkk reopened a pull request:
https://github.com/apache/samza/pull/281
SAMZA-1404: Add warning in case of potential process starvation due to
longer window method
Currently, we use the average windowNs as the lower bound for window
trigger time to determine
Github user bharathkk closed the pull request at:
https://github.com/apache/samza/pull/281
---
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
GitHub user bharathkk opened a pull request:
https://github.com/apache/samza/pull/281
SAMZA-1404: Add warning in case of potential process starvation due to
longer window method
Currently, we use the average windowNs as the lower bound for window
trigger time to determine if user
GitHub user bharathkk opened a pull request:
https://github.com/apache/samza/pull/265
SAMZA-1385: Fix zookeeper path conflict between LocalApplicationRunner and
ZkJobCoordinator
Tested the fix w/ sample page view adclick joiner job.
@navina @sborya @nickpan47 can you please
GitHub user bharathkk opened a pull request:
https://github.com/apache/samza/pull/205
Extract hdfs docs into its own section
@jmakes
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/bharathkk/samza master
Alternatively you can
28 matches
Mail list logo
