Repository: samza
Updated Branches:
refs/heads/master 29c4844fd -> 9d66772d1
SAMZA-1196; Fix TestJmxReporter
Author: Shanthoosh Venkataraman
Reviewers: Navina Ramesh
Closes #140 from shanthoosh/fix-test-jmx-reporter
Project: http://git-wip-us.apache.org/repos/asf/samza/repo
Commit: http:
Repository: samza
Updated Branches:
refs/heads/master 9d66772d1 -> 28afae09d
SAMZA-1206; Fix TestJMXServer.
Author: Shanthoosh Venkataraman
Reviewers: Navina Ramesh
Closes #164 from shanthoosh/fix-test-jmx-server-1
Project: http://git-wip-us.apache.org/repos/asf/samza/repo
Commit: http://
Repository: samza
Updated Branches:
refs/heads/master d89d1ba3a -> 9e2ee35d6
SAMZA-1274; Update kafka-python and kafka broker version for integration tests
Author: Prateek Maheshwari
Reviewers: Jagadish
Closes #174 from prateekm/integration-test-updates
Project: http://git-
Repository: samza
Updated Branches:
refs/heads/master c50dd080b -> df5aa6c4e
Disable flaky tests.
Author: Shanthoosh Venkataraman
Reviewers: Navina Ramesh
Closes #158 from shanthoosh/master
Project: http://git-wip-us.apache.org/repos/asf/samza/repo
Commit: http://git-wip-us.apache.org/rep
Repository: samza
Updated Branches:
refs/heads/master df5aa6c4e -> 5eb470c02
Revert "Disable flaky tests."
This reverts commit df5aa6c4eeb9b89a40780b19e08bb6d96b97730b.
Project: http://git-wip-us.apache.org/repos/asf/samza/repo
Commit: http://git-wip-us.apache.org/repos/asf/samza/commit/5eb4
Repository: samza
Updated Branches:
refs/heads/master 5eb470c02 -> 601c11d87
Minor: Re-word a couple of lines in javadoc with explicit notes about failures
Project: http://git-wip-us.apache.org/repos/asf/samza/repo
Commit: http://git-wip-us.apache.org/repos/asf/samza/commit/601c11d8
Tree: htt
Repository: samza
Updated Branches:
refs/heads/master 46b1333c4 -> f6d0d6551
SAMZA-871; Heart-beat mechanism between JobCoordinator and all running
containers
Author: Abhishek Shivanna
Reviewers: Navina Ramesh , Jagadish V
Closes #163 from abhishekshivanna/master
Project: http://
Repository: samza
Updated Tags: refs/tags/release-0.13.0-rc0 [created] 170d9fac5
Repository: samza
Updated Branches:
refs/heads/0.13.0 [created] f6d0d6551
Repository: samza
Updated Branches:
refs/heads/0.13.0 f6d0d6551 -> 9f60e980b
Update SNAPSHOT version for 0.13 release
Project: http://git-wip-us.apache.org/repos/asf/samza/repo
Commit: http://git-wip-us.apache.org/repos/asf/samza/commit/9f60e980
Tree: http://git-wip-us.apache.org/repos/asf/sa
etc.) happening on
the state and publishing them into a kafka topic. It is names as "Access Log"
behaving similar to changelog, but gathering log information.
Author: jmehar2
Author: Jayasi Mehar
Author: s-noghabi
Reviewers: Prateek Maheshwari , Jagadish V
Closes #132 from s-noghabi/mas
Repository: samza
Updated Branches:
refs/heads/master 1e9ae7395 -> f758fb591
SAMZA-1298; Create zk path.
if ZK path contains extra path at the end, it needs to be created in ZK at
first connect.
Author: Boris Shkolnik
Reviewers: Jagadish
Closes #197 from sborya/createZkPath
Proj
Repository: samza
Updated Branches:
refs/heads/master f758fb591 -> 2a75a209b
SAMZA-1280; document for the general/universal resource localization in YARN
This PR added a MD for localizing resource in Samza on YARN by configuring
path, local.name, local.type and local.visibility, and also upd
Repository: samza
Updated Branches:
refs/heads/master 2a75a209b -> c3db20483
Improve documentation for Resource Localization
This is a follow-up to Fred Ji's original PR :
https://github.com/apache/samza/pull/191 .
Author: vjagadish1989
Reviewers: Prateek Maheshwari
Closes #199 from vjag
SAMZA-1234: Documentation for 0.13.0 release
Author: Jacob Maes
Reviewers: Yi Pan (Data Infrastructure) , Boris Shkolnik
Closes #204 from jmakes/samza-1236-tutorial-1
Project: http://git-wip-us.apache.org/repos/asf/samza/repo
Commit: http://git-wip-us.apache.org/repos/asf/samza/commit/bd132
SAMZA-1313 : Rename StandaloneJobCoordinator to PassthroughJobCoordinator
Author: Boris Shkolnik
Reviewers: Navina Ramesh
Closes #206 from sborya/RenameStandAloneGJobCoordinator
Project: http://git-wip-us.apache.org/repos/asf/samza/repo
Commit: http://git-wip-us.apache.org/repos/asf/samza/co
nk">
+https://twitter.com/nickpan47"; target="_blank">
-**Jay Kreps**
+**Navina Ramesh**
Committer, and PMC member
-http://www.linkedin.com/in/jaykreps"; target="_blank">
-http://twitter.com/jaykreps"; target="_blank">
+https://www.lin
http://git-wip-us.apache.org/repos/asf/samza/blob/bd132538/docs/startup/preview/index.md
--
diff --git a/docs/startup/preview/index.md b/docs/startup/preview/index.md
new file mode 100644
index 000..963b3fb
--- /dev/null
+++ b/
SAMZA-1309; Debounce time config
Author: Boris Shkolnik
Reviewers: Navina Ramesh
Closes #203 from sborya/DebounceConfig
Project: http://git-wip-us.apache.org/repos/asf/samza/repo
Commit: http://git-wip-us.apache.org/repos/asf/samza/commit/1ffcbc2c
Tree: http://git-wip-us.apache.org/repos/asf
Repository: samza
Updated Tags: refs/tags/release-0.13.0-rc2 [created] 09e656b12
Repository: samza
Updated Branches:
refs/heads/master 026ef7f78 -> a19f86f8f
SAMZA-1264; Make Operator Functions Closable
- Added `close()` to the lifecycle of `OperatorImpl`s, and all `Function`s.
- Added unit tests to verify calls to `close()`
Author: vjagadish1989
Reviewers: Prateek Mahe
Repository: samza
Updated Tags: refs/tags/release-0.13.0-rc3 [created] e2f978620
Repository: samza
Updated Branches:
refs/heads/0.13.0 bf77c88b7 -> 48b05c7d3
Update correct version for integration tests
Project: http://git-wip-us.apache.org/repos/asf/samza/repo
Commit: http://git-wip-us.apache.org/repos/asf/samza/commit/48b05c7d
Tree: http://git-wip-us.apache.org/repos/as
Repository: samza
Updated Tags: refs/tags/release-0.13.0-rc4 [created] 35af33f1a
Repository: samza
Updated Branches:
refs/heads/master d9bf8256f -> e565856aa
Update RELEASE documentation to include steps related to integration tests
Project: http://git-wip-us.apache.org/repos/asf/samza/repo
Commit: http://git-wip-us.apache.org/repos/asf/samza/commit/e565856a
Tree: http://
Repository: samza
Updated Branches:
refs/heads/master a4174309a -> ad8ba96e7
SAMZA-1271; Guarantee predictable, deterministic order for operator
initialization and finalization
Currently, the order of initialization of operators in the Samza high level API
is not deterministic. The non-deter
Repository: samza
Updated Branches:
refs/heads/master ad8ba96e7 -> 95bb8e27d
Update docs for ClosableFunction
Project: http://git-wip-us.apache.org/repos/asf/samza/repo
Commit: http://git-wip-us.apache.org/repos/asf/samza/commit/95bb8e27
Tree: http://git-wip-us.apache.org/repos/asf/samza/tree
Repository: samza
Updated Branches:
refs/heads/master 5418a981d -> 53c43dcec
Update release instructions to publish artifacts for different scala versions
Author: vjagadish1989
Reviewers: Jake Maes, Prateek
Maheshwari
Closes #222 from vjagadish1989/release-instr
Project: http://git-wip-u
the same level.
Author: Maksim Logvinenko
Reviewers: Jagadish V
Closes #221 from logarithm/fix-snapshot
Project: http://git-wip-us.apache.org/repos/asf/samza/repo
Commit: http://git-wip-us.apache.org/repos/asf/samza/commit/371473dd
Tree: http://git-wip-us.apache.org/repos/asf/samza/tree/37147
716
Author: Boris Shkolnik
Authored: Fri Jul 21 13:43:18 2017 -0700
Committer: Jagadish
Committed: Fri Jul 21 13:43:18 2017 -0700
--
.../org/apache/samza/config/TaskConfigJava.java | 2 +-
.../samza
27e
Parents: 4eb5153
Author: Boris Shkolnik
Authored: Fri Jul 21 15:32:58 2017 -0700
Committer: Jagadish
Committed: Fri Jul 21 15:32:58 2017 -0700
--
.../java/org/apache/samza/zk/ZkJobCoordinator.java | 16 +++-
1 f
art -> RM fail-over ->
phantom notification with a different exit code)
4. As an aside, there are a whole bunch of tests in ContainerProcessManager
that rely on Thread.sleep to ensure that threads get to run in a certain order.
Removed this non-determinism and made them predictable.
Author:
or ByteBuffer.
Author: Prateek Maheshwari
Reviewers: Jagadish
Closes #251 from prateekm/bytebufferserde
Project: http://git-wip-us.apache.org/repos/asf/samza/repo
Commit: http://git-wip-us.apache.org/repos/asf/samza/commit/c27a2532
Tree: http://git-wip-us.apache.org/repos/asf/samza/tree/c27a25
Repository: samza
Updated Branches:
refs/heads/master c27a25328 -> c2b55dc39
SAMZA-1361; OperatorImplGraph is using wrong keys to store/retrieve
OperatorImpl in the map
Author: Prateek Maheshwari
Reviewers: Jagadish
Closes #248 from prateekm/operatorimpl-key and squashes the follow
mon threads spawned for
`SamzaMonitorService` are alive.
This affects samza-rest jvm process lifecycle management. To fix this, plugging
in ThreadFactory which sets Thread name format & marks them as daemon.
Author: Shanthoosh Venkataraman
Reviewers: Jagadish
Closes #270 from sha
Repository: samza
Updated Branches:
refs/heads/master 119e2fa01 -> 202af33bf
SAMZA-1397; log.debug loop to run only if debug is enabled
Author: Boris Shkolnik
Reviewers: Jagadish http://git-wip-us.apache.org/repos/asf/samza/repo
Commit: http://git-wip-us.apache.org/repos/asf/samza/com
tp://git-wip-us.apache.org/repos/asf/samza/tree/2a4ccfdd
Diff: http://git-wip-us.apache.org/repos/asf/samza/diff/2a4ccfdd
Branch: refs/heads/master
Commit: 2a4ccfdd72513a8a3809c3d01e8fd0d9c23dd1e1
Parents: 80d82b6
Author: Jagadish
Authored: Wed Aug 23 21:47:50 2017 -0700
Committer: Jagadish
Commit
get some
feedback on this testing pattern which eliminates state sharing between the
tests and opens up the avenue for parallel execution.
This change brings down the test time for these 4 tests to **14 sec** compared
to **44 secs**.
Author: Bharath Kumarasubramanian
Reviewers: Jagadish
Clo
Repository: samza
Updated Branches:
refs/heads/master 987180a17 -> f16ba2692
http://git-wip-us.apache.org/repos/asf/samza/blob/f16ba269/samza-test/src/test/java/org/apache/samza/test/operator/PageView.java
--
diff --git
a/samz
http://git-wip-us.apache.org/repos/asf/samza/blob/f16ba269/samza-core/src/main/java/org/apache/samza/operators/impl/InputOperatorImpl.java
--
diff --git
a/samza-core/src/main/java/org/apache/samza/operators/impl/InputOperatorImpl.
SAMZA-1109; Allow setting Serdes for fluent API operators in code
Author: Prateek Maheshwari
Reviewers: Jagadish , Jacob Maes
Closes #293 from prateekm/serde-instance
Project: http://git-wip-us.apache.org/repos/asf/samza/repo
Commit: http://git-wip-us.apache.org/repos/asf/samza/commit
http://git-wip-us.apache.org/repos/asf/samza/blob/f16ba269/samza-core/src/test/java/org/apache/samza/execution/TestExecutionPlanner.java
--
diff --git
a/samza-core/src/test/java/org/apache/samza/execution/TestExecutionPlanner.java
ing:
* Documentation, and minor clean-ups
* Wire-up of stores from ExecutionPlanner
* Usage of the store to implement various windows and joins
Author: Jagadish
Author: Jagadish
Reviewers: Prateek Maheshwari ,Xinyu
Liu
Closes #303 from vjagadish1989/window-store
Project: http://git-
ree: http://git-wip-us.apache.org/repos/asf/samza/tree/92894e5e
Diff: http://git-wip-us.apache.org/repos/asf/samza/diff/92894e5e
Branch: refs/heads/master
Commit: 92894e5e283d605e6243177cc5ed11c3139aa7bc
Parents: 56d564c
Author: Jagadish
Authored: Mon Oct 2 12:54:22 2017 -0700
Committer: Jagad
Repository: samza
Updated Branches:
refs/heads/master caec9c536 -> a47ed9d18
SAMZA-1453; Update README with Travis-CI badge.
Added Travis-CI to README.md file.
Author: Daniel Nishimura
Reviewers: Jagadish
Closes #323 from dnishimura/samza-1453-readme-travisci
Project: http://git-
Repository: samza
Updated Branches:
refs/heads/master a47ed9d18 -> 24170389c
SAMZA-1409; add missing parts and make guideline clearer for docs/README.md
Author: Fred Ji
Reviewers: Jagadish
Closes #288 from fredji97/master_docs_readme
Project: http://git-wip-us.apache.org/repos/asf/sa
rce intensive.
Author: Abhishek Shivanna
Reviewers: Jagadish
Closes #317 from abhishekshivanna/samza-rest-oom
Project: http://git-wip-us.apache.org/repos/asf/samza/repo
Commit: http://git-wip-us.apache.org/repos/asf/samza/commit/072457a2
Tree: http://git-wip-us.apache.org/repos/asf/samza/t
low-up with a PR for hello-samza soon.
Note: Majority of changes are in
`samza-core/src/main/java/org/apache/samza/operators/impl/WindowOperatorImpl.java`
and github collapsed the diff.
Author: Jagadish
Reviewers: Prateek Maheshwari
Closes #321 from vjagadish1989/window-operator-serde
Proj
Repository: samza
Updated Branches:
refs/heads/master 8b2120954 -> 663b8daff
http://git-wip-us.apache.org/repos/asf/samza/blob/663b8daf/samza-azure/src/test/java/org/apache/samza/system/eventhub/MockEventHubClientManagerFactory.java
--
SAMZA-1438; SystemProducer, Consumer and Admin interfaces for EventHubs
Author: Daniel Chen <29577458+dxic...@users.noreply.github.com>
Reviewers: Jagadish , Prateek M
Closes #308 from dxichen/eventHub-Connector
Project: http://git-wip-us.apache.org/repos/asf/samza/repo
Commit: http://g
Repository: samza
Updated Branches:
refs/heads/master 663b8daff -> c94a26afe
SAMZA-1473; Fix handling of initial values for aggregating windows
- Handle initial values for windows with foldLeftFunctions configured
- Improve trace level logging
Author: Jagadish
Reviewers: Pratee
git-wip-us.apache.org/repos/asf/samza/tree/2d107324
Diff: http://git-wip-us.apache.org/repos/asf/samza/diff/2d107324
Branch: refs/heads/master
Commit: 2d1073249174975f81b9187004aacbd46a91a1d0
Parents: c94a26a
Author: Jagadish
Authored: Tue Oct 31 08:50:19 2017 -0700
Committer: Jagadish
Committed:
Repository: samza
Updated Branches:
refs/heads/master 52d8ddd6e -> 05113c339
SAMZA-1437; Added tests, make eventData creation extensible
vjagadish1989 Required for internal custom eventData creation
Author: Daniel Chen <29577458+dxic...@users.noreply.github.com>
Reviewers: Jagadis
Repository: samza
Updated Branches:
refs/heads/master 05113c339 -> adfc4bfc4
SAMZA-1486; Checkpoint manager implementation with Azure Table
vjagadish1989
Author: Daniel Chen <29577458+dxic...@users.noreply.github.com>
Reviewers: Jagadish
Closes #341 from dxichen/azure-checkpoin
tils for creating producer, consumer and admin
instances
* Convert/consolidate most long-running integration tests into unit tests
Author: Jagadish
Reviewers: Prateek Maheshwari
Closes #348 from vjagadish1989/kafka-checkpointmanager-refactor
Project: http://git-wip-us.apache.org/repos/asf/samza/rep
eam irrespective of auto-commit behavior.
Author: Jagadish
Reviewers: Xinyu Liu
Closes #366 from vjagadish1989/eos-flush
Project: http://git-wip-us.apache.org/repos/asf/samza/repo
Commit: http://git-wip-us.apache.org/repos/asf/samza/commit/7a2e1925
Tree: http://git-wip-us.apache.org/repos/asf/sa
Repository: samza
Updated Branches:
refs/heads/master a5a69c4df -> 5e68d621a
SAMZA-1513; Doc updates for persistent windows, joins and serdes.
jmakes prateekm nickpan47 for review.
Author: Jagadish
Reviewers: Jake Maes
Closes #369 from vjagadish1989/doc-updates
Project: http://git-
Repository: samza
Updated Branches:
refs/heads/master 5e68d621a -> 9961023f7
http://git-wip-us.apache.org/repos/asf/samza/blob/9961023f/samza-aws/src/test/java/org/apache/samza/system/kinesis/TestKinesisSystemFactory.java
--
di
SAMZA-1515; Implement a consumer for Kinesis
Author: Aditya Toomula
Reviewers: Jagadish
Closes #368 from atoomula/kinesis
Project: http://git-wip-us.apache.org/repos/asf/samza/repo
Commit: http://git-wip-us.apache.org/repos/asf/samza/commit/9961023f
Tree: http://git-wip-us.apache.org/repos
8+dxic...@users.noreply.github.com>
Reviewers: Jagadish
Closes #377 from dxichen/eventhub-connector-fix
Project: http://git-wip-us.apache.org/repos/asf/samza/repo
Commit: http://git-wip-us.apache.org/repos/asf/samza/commit/1d420e75
Tree: http://git-wip-us.apache.org/repos/asf/samza/tree/1d420e75
Diff: http:
Repository: samza-hello-samza
Updated Branches:
refs/heads/latest e7811dbf7 -> f48c7f9f3
SAMZA-1524: Azure checkpoint and eventhubs fluent api standalone example
Tutorial and docs coming soon
Author: Daniel Chen <29577458+dxic...@users.noreply.github.com>
Reviewers: Jagadish
C
Repository: samza-hello-samza
Updated Branches:
refs/heads/latest f48c7f9f3 -> 004e03fad
Fixed stateful operator name
Author: Prateek Maheshwari
Reviewers: Jagadish
Closes #25 from prateekm/latest
Project: http://git-wip-us.apache.org/repos/asf/samza-hello-samza/repo
Commit: http://
0.2, and 1.0.0. Changed the repo to the main apache repo.
Author: Sardana
Reviewers: Jagadish
Closes #28 from capdaha/patch-1
Project: http://git-wip-us.apache.org/repos/asf/samza-hello-samza/repo
Commit: http://git-wip-us.apache.org/repos/asf/samza-hello-samza/commit/cb436535
Tree: http://git-
or: Imre Nagi
Reviewers: Jagadish
Closes #26 from imrenagi/master
Project: http://git-wip-us.apache.org/repos/asf/samza-hello-samza/repo
Commit: http://git-wip-us.apache.org/repos/asf/samza-hello-samza/commit/5fa742ac
Tree: http://git-wip-us.apache.org/repos/asf/samza-hello-samza/tree/5fa742ac
Di
Repository: samza
Updated Branches:
refs/heads/master 1d420e750 -> 42bac30ad
http://git-wip-us.apache.org/repos/asf/samza/blob/42bac30a/samza-tools/src/main/java/org/apache/samza/tools/schemas/ProfileChangeEvent.avsc
--
diff --
-1526
Author: Srinivasulu Punuru
Reviewers: Yi Pan, Jagadish
Closes #374 from srinipunuru/docs.1
Project: http://git-wip-us.apache.org/repos/asf/samza/repo
Commit: http://git-wip-us.apache.org/repos/asf/samza/commit/42bac30a
Tree: http://git-wip-us.apache.org/repos/asf/samza/tree/42bac30a
Diff
asf/samza/tree/7887b6d8
Diff: http://git-wip-us.apache.org/repos/asf/samza/diff/7887b6d8
Branch: refs/heads/master
Commit: 7887b6d868ee048767c11c2db3a5d38093d9abf9
Parents: cb92cf1
Author: Aditya Toomula
Authored: Tue Dec 12 21:41:37 2017 -0800
Committer: Jagadish
Committed: Tue Dec 12 21:41:37 2
the config and passing it to
grouper.
Author: Aditya Toomula
Reviewers: Yi Pan , Shanthoosh V
Closes #383 from atoomula/samza
(cherry picked from commit 7887b6d868ee048767c11c2db3a5d38093d9abf9)
Signed-off-by: Jagadish
Project: http://git-wip-us.apache.org/repos/asf/samza/repo
Commit: http://
ub.com>
Reviewers: Jagadish
Closes #382 from dxichen/eventhub-docs
Project: http://git-wip-us.apache.org/repos/asf/samza/repo
Commit: http://git-wip-us.apache.org/repos/asf/samza/commit/2e5ceec1
Tree: http://git-wip-us.apache.org/repos/asf/samza/tree/2e5ceec1
Diff: http://git-wip-us.apache.org/
ub.com>
Reviewers: Jagadish
Closes #382 from dxichen/eventhub-docs
(cherry picked from commit 2e5ceec19f52b300b98efb06b292cf9a3db60388)
Signed-off-by: Jagadish
Project: http://git-wip-us.apache.org/repos/asf/samza/repo
Commit: http://git-wip-us.apache.org/repos/asf/samza/commit/c7150cf2
Tree: h
Repository: samza-hello-samza
Updated Branches:
refs/heads/master 5fa742ac4 -> 90bbe75f2
Adding hello-samza example for kinesis
Author: Aditya Toomula
Reviewers: Jagadish
Closes #30 from atoomula/kinesis
Project: http://git-wip-us.apache.org/repos/asf/samza-hello-samza/repo
Commit: h
Repository: samza
Updated Branches:
refs/heads/master 54dc4a03e -> ed8dad54b
SAMZA-1536; Adding docs for Kinesis consumer
Author: Aditya Toomula
Reviewers: Jagadish
Closes #384 from atoomula/kinesis-docs
Project: http://git-wip-us.apache.org/repos/asf/samza/repo
Commit: http://git-
Repository: samza
Updated Branches:
refs/heads/0.14.0 c7150cf2d -> ef506a3c5
SAMZA-1536; Adding docs for Kinesis consumer
Author: Aditya Toomula
Reviewers: Jagadish
Closes #384 from atoomula/kinesis-docs
(cherry picked from commit ed8dad54bf04c3f81c2d68678672225ca432)
Signed-off
Repository: samza
Updated Branches:
refs/heads/master 9a8099cda -> 93219c78d
SAMZA-1547; Parse default value grouper-factory config in KafkaCheckpointMgr
- Additionally, updated all unit-tests.
Author: Jagadish
Reviewers: Prateek M
Closes #394 from vjagadish1989/kcm-fix
Project: h
Repository: samza
Updated Branches:
refs/heads/0.14.0 804aea2b9 -> 7b42474d3
SAMZA-1547; Parse default value grouper-factory config in KafkaCheckpointMgr
- Additionally, updated all unit-tests.
Author: Jagadish
Reviewers: Prateek M
Closes #394 from vjagadish1989/kcm-fix
(cherry pic
job.
Author: Jagadish
Author: Fred Ji
Author: Srinivasulu Punuru
Reviewers: Jacob Maes, Xinyu Liu
Closes #380 from vjagadish1989/cluster-mgr-refactor1
Project: http://git-wip-us.apache.org/repos/asf/samza/repo
Commit: http://git-wip-us.apache.org/repos/asf/samza/commit/882f61a6
Tree: http://git-
ize + rocksdb.size-all-mem-tables +
rocksdb.estimate-table-readers-mem
Author: Prateek Maheshwari
Reviewers: Jagadish
Closes #404 from prateekm/rocksdb-memory
Project: http://git-wip-us.apache.org/repos/asf/samza/repo
Commit: http://git-wip-us.apache.org/repos/asf/samza/commit/3a9e8064
Tree: http://git-
nts: 3a9e806
Author: Srinivasulu Punuru
Authored: Wed Jan 17 10:06:50 2018 -0800
Committer: Jagadish
Committed: Wed Jan 17 10:06:50 2018 -0800
--
.../impl/ConfigBasedSourceResolverFactory.java | 8 ++--
.../sql/interfa
wip-us.apache.org/repos/asf/samza/tree/95a71fb9
Diff: http://git-wip-us.apache.org/repos/asf/samza/diff/95a71fb9
Branch: refs/heads/master
Commit: 95a71fb9e234c9fc7fcb8a4ec0bbab33c9555738
Parents: fcd2b9a
Author: navina
Authored: Wed Jan 17 10:11:40 2018 -0800
Committer: Jagadish
Committed: Wed Jan 17 10:11
Repository: samza
Updated Branches:
refs/heads/master b38e6622f -> b7805df10
SAMZA-1560: Handle key-serde errors in KafkaCheckpointManager
Author: Jagadish
Reviewers: Xinyu Liu
Closes #408 from vjagadish1989/kcm-fix
Project: http://git-wip-us.apache.org/repos/asf/samza/repo
Commit: h
Repository: samza
Updated Branches:
refs/heads/master b7805df10 -> e075e956f
SAMZA-1407: upgrade junit version to 4.12
"./gradlew clean check" passed
Author: Fred Ji
Reviewers: Jagadish
Closes #406 from fredji97/junit4_12_new
Project: http://git-wip-us.apache.org/repos/a
Repository: samza
Updated Branches:
refs/heads/master e075e956f -> 24d22bb80
SAMZA-1561: Fix inconsistency problem in JobModel publish.
Author: Shanthoosh Venkataraman
Reviewers: Jagadish V, Xinyu Liu
Closes #409 from shanthoosh/master
Project: http://git-wip-us.apache.org/repos/
Repository: samza
Updated Branches:
refs/heads/master 24d22bb80 -> d6686b0f0
upTime should be field not method
Author: zhangyijun
Reviewers: Jagadish
Closes #9 from zhangyijun/patch-1
Project: http://git-wip-us.apache.org/repos/asf/samza/repo
Commit: http://git-wip-us.apache.org/re
14:08:29 2018 -0800
Committer: Jagadish
Committed: Mon Jan 22 14:08:29 2018 -0800
--
docs/learn/documentation/versioned/jobs/web-ui-rest-api.md | 2 +-
1 file changed, 1 insertion(+), 1 delet
Repository: samza
Updated Branches:
refs/heads/master d6686b0f0 -> 1756b0597
fix the bug containsValue method
containsValue method should invoke map.containsValue not map.containsKey
Author: michaelwong
Reviewers: Jagadish
Closes #12 from jwongo/master
Project: http://git-
Repository: samza
Updated Branches:
refs/heads/master 75e70e569 -> 9674836f6
Added some logging to stdout for easier parsing by tools.
Author: Prateek Maheshwari
Reviewers: Jagadish
Closes #414 from prateekm/print-container-info
Project: http://git-wip-us.apache.org/repos/asf/samza/r
Repository: samza
Updated Branches:
refs/heads/master 7e68e4b10 -> 03e5026cf
SAMZA-1552: Host affinity improvements - Improve matching of hosts to allocated
resources
Author: Jagadish
Reviewers: Prateek
Closes #401 from vjagadish1989/host-affinity-fix
Project: http://git-
Repository: samza
Updated Branches:
refs/heads/master 03e5026cf -> c51693bcd
SAMZA-1489: TaskInstance should commit offset before it closes() if auto commit
is enabled
Author: Dong Lin
Reviewers: Jagadish
Closes #417 from lindong28/SAMZA-1489
Project: http://git-wip-us.apache.org/re
mit: 002e131784d52e02f6d4b46453b31d47f20cad31
Parents: c51693b
Author: Shanthoosh Venkataraman
Authored: Tue Feb 13 11:22:34 2018 -0800
Committer: Jagadish
Committed: Tue Feb 13 11:22:34 2018 -0800
--
.../kafka/KafkaCheckpointManager.scala |
: Shanthoosh Venkataraman
Reviewers: Jagadish
Closes #416 from shanthoosh/zk_utils_close
Project: http://git-wip-us.apache.org/repos/asf/samza/repo
Commit: http://git-wip-us.apache.org/repos/asf/samza/commit/4123b160
Tree: http://git-wip-us.apache.org/repos/asf/samza/tree/4123b160
Diff: ht
Repository: samza
Updated Branches:
refs/heads/master 6dc89e100 -> 6270e40b2
Fixes to get the build working with Scala 2.10 build
The fixes needed to get the build working with the Scala 2.10.
Author: Srinivasulu Punuru
Reviewers: Jagadish , Jacob M, Bharath
K, Xinyu L
Closes #424 f
pos/asf/samza/tree/963bd308
Diff: http://git-wip-us.apache.org/repos/asf/samza/diff/963bd308
Branch: refs/heads/master
Commit: 963bd3085e0284b40917c3ddfd02e70f882d1a19
Parents: 6af104e
Author: Wei Song
Authored: Tue Feb 27 11:47:51 2018 -0800
Committer: Jagadish
Committed: Tue Feb 27 11:47:51 2
oes not parse
from config, but only systems.%s.stagingDirectory only parses instead.
Solution is to add formatter to getStagingDirectory method.
Author: Akim Akimov
Reviewers: Jagadish , Hai L
Closes #431 from Zedmor/FixStagingDirHDFS
Project: http://git-wip-us.apache.org/repos/asf/samza/r
mit: bc0a47b7ca0f3f2ff506673224ec7da4880429fd
Parents: ed7e4af
Author: Daniel Nishimura
Authored: Sat Mar 3 16:29:44 2018 -0800
Committer: Jagadish
Committed: Sat Mar 3 16:29:44 2018 -0800
--
README.md | 4 ++--
1 file changed, 2 insertions(+)
few checkstyle warning about missing param/throws documentation.
Author: Prateek Maheshwari
Reviewers: Jagadish , Jacob M
Closes #433 from prateekm/container-thread-pool-name
Project: http://git-wip-us.apache.org/repos/asf/samza/repo
Commit: http://git-wip-us.apache.org/repos/asf/samza/com
org/repos/asf/samza/diff/810d8bd8
Branch: refs/heads/master
Commit: 810d8bd805f386f79ce73efdee0d2ef341a65e83
Parents: 1dfc5ce
Author: Daniel Nishimura
Authored: Mon Mar 5 16:02:49 2018 -0800
Committer: Jagadish
Committed: Mon Mar 5 16:02:49 2018 -0
Repository: samza
Updated Branches:
refs/heads/master 810d8bd80 -> 78ee98261
SAMZA-1600: remove the combination of cleanup policy "compact,delete"â¦
⦠in changelog topic properties
Author: Yi Pan (Data Infrastructure)
Reviewers: Jagadish
Closes #435 from nickpan47/SAMZA-1
Repository: samza
Updated Branches:
refs/heads/master 89dc18e96 -> 6492826e1
SAMZA-1589: Reduce failure retry duration in
KafkaCheckpointManager.writeCheckpoint
Author: Shanthoosh Venkataraman
Reviewers: Jagadish
Closes #438 from shanthoosh/SAMZA-1589
Project: http://git-
SAMZA-1610: Implementation of remote table provider
Please see commit messages for detailed descriptions.
Author: Peng Du
Reviewers: Jagadish , Wei Song
Closes #432 from pdu-mn1/remote-table-0222
Project: http://git-wip-us.apache.org/repos/asf/samza/repo
Commit: http://git-wip
Repository: samza
Updated Branches:
refs/heads/master 1971d596c -> 2be7061d4
http://git-wip-us.apache.org/repos/asf/samza/blob/2be7061d/samza-core/src/test/java/org/apache/samza/util/TestEmbeddedTaggedRateLimiter.java
--
diff -
101 - 200 of 1132 matches
Mail list logo
