Repository: samza
Updated Branches:
refs/heads/master d87ca67e5 -> 0405f25f0
Add release PGP keys for Jagadish <jagad...@apache.org>
Project: http://git-wip-us.apache.org/repos/asf/samza/repo
Commit: http://git-wip-us.apache.org/repos/asf/samza/commit/0405f25f
Tree: http:
Repository: samza
Updated Tags: refs/tags/release-0.12.0-rc0 [created] 591d511d4
Repository: samza
Updated Branches:
refs/heads/master 0405f25f0 -> fcb44be80
Update Samza version to prepare for 0.12.0 Samza release
Project: http://git-wip-us.apache.org/repos/asf/samza/repo
Commit: http://git-wip-us.apache.org/repos/asf/samza/commit/fcb44be8
Tree:
Repository: samza
Updated Tags: refs/tags/release-0.12.0-rc1 [created] e2e037514
Repository: samza
Updated Branches:
refs/heads/master 1f4a59328 -> e57b4a342
Fix integration test config issue in 0.12 release candidate
Project: http://git-wip-us.apache.org/repos/asf/samza/repo
Commit: http://git-wip-us.apache.org/repos/asf/samza/commit/e57b4a34
Tree:
Repository: samza
Updated Tags: refs/tags/release-0.12.0-rc2 [created] 69ad49515
Repository: samza
Updated Branches:
refs/heads/master db8b228d9 -> f01b28628
SAMZA-1025: Documentation for HdfsSystemConsumer
Project: http://git-wip-us.apache.org/repos/asf/samza/repo
Commit: http://git-wip-us.apache.org/repos/asf/samza/commit/f01b2862
Tree:
Repository: samza
Updated Branches:
refs/heads/master 6dc33a850 -> c6c10d31e
SAMZA-1077: SamzaContainer should catch all Throwables instead of only
exceptions
Author: vjagadish1989
Reviewers: Jake Maes
Closes #30 from vjagadish1989/samza-1077
Specification of various Window and Trigger APIs in Samza
- Defined APIs for specifying different types of windows - sessions, tumbling,
global and keyed variants.
- Defined APIs for specifying early and late triggers for a window.
- Standardized all above Window types to be expressed as a
http://git-wip-us.apache.org/repos/asf/samza/blob/6dc33a85/samza-api/src/main/java/org/apache/samza/operators/windows/Windows.java
--
diff --git
a/samza-api/src/main/java/org/apache/samza/operators/windows/Windows.java
Repository: samza
Updated Branches:
refs/heads/master 1c7e4d7aa -> bf9bc2c37
SAMZA-1079: Add timeouts for reads from HttpFileSystem. Add tests.
* Wrote a unit/integration test to simulate a stuck connection when reading
binaries for the job.
Other misc. changes:
- Moved some debug log
Repository: samza
Updated Branches:
refs/heads/master c6c10d31e -> 1c7e4d7aa
SAMZA-984; Upgraded RocksDB version to 5.0.1 and added configuration for
managing RocksDB logging.
Author: Prateek Maheshwari <pmahe...@linkedin.com>
Reviewers: Jake Maes <jacob.m...@gmail.com>, Jaga
Repository: samza
Updated Branches:
refs/heads/master bf9bc2c37 -> 154cda2c7
SAMZA-1074; Fix builds for hello-samza on various CDH versions
This issue is mainly related of hello-samza, but modification of document is
needed to help user understand this process well.
Author: Dongkyu Hwangbo
Repository: samza-hello-samza
Updated Branches:
refs/heads/master 51253ee28 -> 4384cb034
SAMZA-1099: Changes to hello-samza for the 0.12.0 release
Project: http://git-wip-us.apache.org/repos/asf/samza-hello-samza/repo
Commit:
Repository: samza-hello-samza
Updated Branches:
refs/heads/latest e02c9564b -> 4d20c2bde
SAMZA-1099: Changes to hello-samza (latest branch) for the 0.12 release
Project: http://git-wip-us.apache.org/repos/asf/samza-hello-samza/repo
Commit:
Author: jagadish
Date: Wed Feb 22 20:59:57 2017
New Revision: 1784061
URL: http://svn.apache.org/viewvc?rev=1784061=rev
Log:
updating welcome page
[This commit notification would consist of 51 parts,
which exceeds the limit of 50 ones, so it was shortened to the summary.]
Added:
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/windows/internal/package-tree.html
URL:
http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/windows/internal/package-tree.html?rev=1784062=auto
Modified:
samza/site/learn/documentation/latest/rest/javadocs/org/apache/samza/rest/proxy/installation/package-tree.html
URL:
Modified:
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/task/AsyncStreamTask.html
URL:
http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/task/AsyncStreamTask.html?rev=1784062=1784061=1784062=diff
Added:
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/MessageStream.html
URL:
http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/MessageStream.html?rev=1784062=auto
Modified: samza/site/learn/documentation/latest/api/javadocs/index-all.html
URL:
http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/index-all.html?rev=1784062=1784061=1784062=diff
==
---
Added:
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/data/Offset.html
URL:
http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/data/Offset.html?rev=1784062=auto
Added:
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/windows/Windows.html
URL:
http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/windows/Windows.html?rev=1784062=auto
Repository: samza
Updated Branches:
refs/heads/0.12.0 e57b4a342 -> 549a632d7
SAMZA-1099: Documentation updates for Samza 0.12 release (for 0.12.0 branch)
Project: http://git-wip-us.apache.org/repos/asf/samza/repo
Commit: http://git-wip-us.apache.org/repos/asf/samza/commit/549a632d
Tree:
Repository: samza
Updated Branches:
refs/heads/master eab180010 -> b5ea8776e
SAMZA-1099: Documentation updates for Samza 0.12 release (for master branch)
Project: http://git-wip-us.apache.org/repos/asf/samza/repo
Commit: http://git-wip-us.apache.org/repos/asf/samza/commit/b5ea8776
Tree:
Added:
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/windows/AccumulationMode.html
URL:
http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/windows/AccumulationMode.html?rev=1784062=auto
Modified: samza/site/learn/documentation/latest/api/javadocs/overview-tree.html
URL:
http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/overview-tree.html?rev=1784062=1784061=1784062=diff
==
Added:
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/functions/SinkFunction.html
URL:
http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/functions/SinkFunction.html?rev=1784062=auto
Modified: samza/site/learn/documentation/latest/api/javadocs/index.html
URL:
http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/index.html?rev=1784062=1784061=1784062=diff
==
---
Modified: samza/site/learn/documentation/latest/jobs/configuration-table.html
URL:
http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/jobs/configuration-table.html?rev=1784062=1784061=1784062=diff
==
---
Added:
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/StreamOperatorTask.html
URL:
http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/StreamOperatorTask.html?rev=1784062=auto
Author: jagadish
Date: Wed Feb 22 21:01:21 2017
New Revision: 1784062
URL: http://svn.apache.org/viewvc?rev=1784062=rev
Log:
updating welcome page
Added:
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/annotation/
samza/site/learn/documentation/latest/api/javadocs
Modified:
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/container/TaskName.html
URL:
http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/container/TaskName.html?rev=1784062=1784061=1784062=diff
Added:
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/StreamSpec.html
URL:
http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/StreamSpec.html?rev=1784062=auto
Added:
samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/triggers/TimeSinceFirstMessageTrigger.html
URL:
Repository: samza
Updated Branches:
refs/heads/0.12.0 [created] e57b4a342
Modified:
samza/site/learn/documentation/versioned/rest/javadocs/org/apache/samza/rest/model/JobStatus.html
URL:
http://svn.apache.org/viewvc/samza/site/learn/documentation/versioned/rest/javadocs/org/apache/samza/rest/model/JobStatus.html?rev=1784679=1784678=1784679=diff
Modified:
samza/site/learn/documentation/versioned/api/javadocs/org/apache/samza/operators/triggers/TimeSinceFirstMessageTrigger.html
URL:
Repository: samza
Updated Branches:
refs/heads/0.12.0 d47cf7d13 -> 01caa5c8e
Fix a rendering issue in the Samza security web-page
Project: http://git-wip-us.apache.org/repos/asf/samza/repo
Commit: http://git-wip-us.apache.org/repos/asf/samza/commit/01caa5c8
Tree:
Author: jagadish
Date: Tue Feb 28 01:43:37 2017
New Revision: 1784678
URL: http://svn.apache.org/viewvc?rev=1784678=rev
Log:
updating welcome page
[This commit notification would consist of 53 parts,
which exceeds the limit of 50 ones, so it was shortened to the summary.]
Repository: samza
Updated Branches:
refs/heads/0.12.0 549a632d7 -> d47cf7d13
SAMZA-1104; fix yarn security page link from index.html page
Author: Chen Song <cs...@appnexus.com>
Reviewers: Jagadish <jagad...@apache.org>
Closes #62 from garlicbulb-puzhuo/SAMZA-1104
Project:
Modified:
samza/site/learn/documentation/versioned/api/javadocs/org/apache/samza/metrics/package-tree.html
URL:
http://svn.apache.org/viewvc/samza/site/learn/documentation/versioned/api/javadocs/org/apache/samza/metrics/package-tree.html?rev=1784679=1784678=1784679=diff
Modified: samza/site/learn/documentation/versioned/api/javadocs/index-all.html
URL:
http://svn.apache.org/viewvc/samza/site/learn/documentation/versioned/api/javadocs/index-all.html?rev=1784679=1784678=1784679=diff
==
---
Author: jagadish
Date: Tue Feb 28 01:45:28 2017
New Revision: 1784679
URL: http://svn.apache.org/viewvc?rev=1784679=rev
Log:
updating welcome page
Modified:
samza/site/archive/index.html
samza/site/community/committers.html
samza/site/community/irc.html
samza/site/community
Modified: samza/site/learn/documentation/versioned/api/javadocs/index.html
URL:
http://svn.apache.org/viewvc/samza/site/learn/documentation/versioned/api/javadocs/index.html?rev=1784679=1784678=1784679=diff
==
---
Modified:
samza/site/learn/documentation/versioned/api/javadocs/org/apache/samza/operators/windows/Windows.html
URL:
http://svn.apache.org/viewvc/samza/site/learn/documentation/versioned/api/javadocs/org/apache/samza/operators/windows/Windows.html?rev=1784679=1784678=1784679=diff
Modified:
samza/site/learn/documentation/versioned/api/javadocs/org/apache/samza/util/NoOpMetricsRegistry.html
URL:
http://svn.apache.org/viewvc/samza/site/learn/documentation/versioned/api/javadocs/org/apache/samza/util/NoOpMetricsRegistry.html?rev=1784679=1784678=1784679=diff
Modified:
samza/site/learn/documentation/versioned/api/javadocs/org/apache/samza/system/SystemAdmin.html
URL:
http://svn.apache.org/viewvc/samza/site/learn/documentation/versioned/api/javadocs/org/apache/samza/system/SystemAdmin.html?rev=1784679=1784678=1784679=diff
Modified:
samza/site/learn/documentation/versioned/api/javadocs/org/apache/samza/operators/windows/internal/WindowInternal.html
URL:
Modified:
samza/site/learn/documentation/versioned/api/javadocs/org/apache/samza/operators/data/package-summary.html
URL:
http://svn.apache.org/viewvc/samza/site/learn/documentation/versioned/api/javadocs/org/apache/samza/operators/data/package-summary.html?rev=1784679=1784678=1784679=diff
Repository: samza
Updated Branches:
refs/heads/master 985822028 -> 317b6ff1b
SAMZA-1020: Remove methods in Kafka checkpoint classes that were deprecated in
the 0.10 release.
Project: http://git-wip-us.apache.org/repos/asf/samza/repo
Commit:
SAMZA-995: Remove deprecated property yarn.container.count from config table.
Project: http://git-wip-us.apache.org/repos/asf/samza/repo
Commit: http://git-wip-us.apache.org/repos/asf/samza/commit/317b6ff1
Tree: http://git-wip-us.apache.org/repos/asf/samza/tree/317b6ff1
Diff:
Repository: samza
Updated Branches:
refs/heads/master 317b6ff1b -> 61d35f26c
SAMZA-1028: Fix KafkaSystemProducer logging and use an AtomicReference for
tracking producer exceptions
Project: http://git-wip-us.apache.org/repos/asf/samza/repo
Commit:
Repository: samza
Updated Branches:
refs/heads/master 49dac97cb -> 1c0a60bb7
SAMZA-1021 : Remove the redundent poll waiting inside AsyncRunLoop blockIfBusy
Project: http://git-wip-us.apache.org/repos/asf/samza/repo
Commit: http://git-wip-us.apache.org/repos/asf/samza/commit/1c0a60bb
Tree:
Repository: samza
Updated Branches:
refs/heads/master 36bcbacc2 -> 7ae261afa
SAMZA-1015 Add support for streams, Lambdas and other JDK 8 like features in
checkstyle
Project: http://git-wip-us.apache.org/repos/asf/samza/repo
Commit:
SAMZA-1016: Fix support for joint compilation of scala and java sources
Project: http://git-wip-us.apache.org/repos/asf/samza/repo
Commit: http://git-wip-us.apache.org/repos/asf/samza/commit/7ae261af
Tree: http://git-wip-us.apache.org/repos/asf/samza/tree/7ae261af
Diff:
Repository: samza
Updated Branches:
refs/heads/master 7ae261afa -> 9126d373d
SAMZA-974 Support finite data sources that have a notion of end of stream
Project: http://git-wip-us.apache.org/repos/asf/samza/repo
Commit: http://git-wip-us.apache.org/repos/asf/samza/commit/9126d373
Tree:
nd committers
Also, updated the merge script with constants to match from the website
documentation.
Author: Navina Ramesh <nram...@linkedin.com>
Reviewers: Jagadish <jagad...@apache.org>
Closes #16 from navina/adding-docs
Project: http://git-wip-us.apache.org/repos/asf/samza/re
Repository: samza
Updated Branches:
refs/heads/master 362658938 -> 202a15809
SAMZA-1046: Docs for checkpointable consumer
Project: http://git-wip-us.apache.org/repos/asf/samza/repo
Commit: http://git-wip-us.apache.org/repos/asf/samza/commit/202a1580
Tree:
Repository: samza
Updated Branches:
refs/heads/master 99667d902 -> 4660d4ddd
Fix a minor typo in the web-page
Project: http://git-wip-us.apache.org/repos/asf/samza/repo
Commit: http://git-wip-us.apache.org/repos/asf/samza/commit/4660d4dd
Tree:
SAMZA-1045: Move classes from operator/api into samza-api
Project: http://git-wip-us.apache.org/repos/asf/samza/repo
Commit: http://git-wip-us.apache.org/repos/asf/samza/commit/1dac25e1
Tree: http://git-wip-us.apache.org/repos/asf/samza/tree/1dac25e1
Diff:
http://git-wip-us.apache.org/repos/asf/samza/blob/1dac25e1/samza-operator/src/main/java/org/apache/samza/operators/api/Windows.java
--
diff --git
a/samza-operator/src/main/java/org/apache/samza/operators/api/Windows.java
http://git-wip-us.apache.org/repos/asf/samza/blob/1dac25e1/samza-api/src/main/java/org/apache/samza/operators/task/StreamOperatorTask.java
--
diff --git
Repository: samza
Updated Branches:
refs/heads/samza-sql adcd26678 -> 1dac25e17
http://git-wip-us.apache.org/repos/asf/samza/blob/1dac25e1/samza-operator/src/test/java/org/apache/samza/operators/api/TestTriggerBuilder.java
--
in.com>
Reviewers: Jagadish <jagad...@apache.org>, Navina Ramesh <nav...@apache.org>
Closes #89 from fredji97/mockitoUpgrade
Project: http://git-wip-us.apache.org/repos/asf/samza/repo
Commit: http://git-wip-us.apache.org/repos/asf/samza/commit/1c27ba88
Tree: http://git-wip-us.apach
SAMZA-1135 - Support scala 2.12
Added support for scala 2.12
Author: Maxim Logvinenko <mlogvine...@gmail.com>
Reviewers: Jagadish <jagad...@apache.org>,Prateek Maheshwari
<prate...@linkedin.com>
Closes #82 from metamx:scala-2.12
Project: http://git
Repository: samza
Updated Branches:
refs/heads/master d7fc811d6 -> 9db47b861
http://git-wip-us.apache.org/repos/asf/samza/blob/9db47b86/samza-kafka/src/main/scala/org/apache/samza/config/KafkaConfig.scala
--
diff --git
SAMZA-1108: Implementation of Windows and various kinds of Triggers
* Implemented various triggers and the orchestration logic of the window
operator.
* Implemented wire-up of window and the flow of messages through various
trigger implementations.
* Implementations for count, time,
Repository: samza
Updated Branches:
refs/heads/master 5910ea669 -> 5f7b25027
Fix an import issue on TestJoinOperator
Project: http://git-wip-us.apache.org/repos/asf/samza/repo
Commit: http://git-wip-us.apache.org/repos/asf/samza/commit/5f7b2502
Tree:
Repository: samza
Updated Branches:
refs/heads/master 944c70878 -> 71004e1eb
SAMZA-1176; Make TestJoinOperator unit tests safe for concurrent execution
Author: Prateek Maheshwari <pmahe...@linkedin.com>
Reviewers: Jagadish <jagad...@apache.org>
Closes #105 from prateekm/join-
sim Logvinenko <mlogvine...@gmail.com>
Reviewers: Jagadish <jagad...@apache.org>
Closes #84 from logarithm/yarn-properties-fix
Project: http://git-wip-us.apache.org/repos/asf/samza/repo
Commit: http://git-wip-us.apache.org/repos/asf/samza/commit/101ca439
Tree: http://git-wip-us.apache.org/
<f...@linkedin.com>
Author: vjagadish1989 <jvenk...@linkedin.com>
Reviewers: Jagadish <jagad...@apache.org>
Closes #97 from fredji97/fsImplSubkeys
Project: http://git-wip-us.apache.org/repos/asf/samza/repo
Commit: http://git-wip-us.apache.org/repos/asf/samza/commit/c1b778a0
Tree: http://
a look.
Author: Prateek Maheshwari <pmahe...@linkedin.com>
Reviewers: Jagadish <jagad...@apache.org>
Closes #113 from prateekm/flaky-ess-test-fix
Project: http://git-wip-us.apache.org/repos/asf/samza/repo
Commit: http://git-wip-us.apache.org/repos/asf/samza/commit/b5e45b7e
T
Repository: samza-hello-samza
Updated Branches:
refs/heads/latest 4d20c2bde -> c87ed565f
SAMZA-1225: Add demo examples for programming with the fluent API
Project: http://git-wip-us.apache.org/repos/asf/samza-hello-samza/repo
Commit:
Repository: samza
Updated Branches:
refs/heads/master 925866d9b -> 8df1e16ee
SAMZA-1211; Remove Thread.sleep() from TestJoinOperator tests
Author: Prateek Maheshwari <pmahe...@linkedin.com>
Reviewers: Jagadish <jagad...@apache.org>
Closes #123 from prateekm/join-test-no-
Repository: samza
Updated Branches:
refs/heads/master e3f85871c -> 5a88b9e47
SAMZA-1112; BrokerProxy does not log fatal errors
Add an UncaughtExceptionHandler to the broker proxy thread so
failures there get logged.
Author: Tommy Becker <tobec...@tivo.com>
Reviewers: Jagadi
Repository: samza
Updated Branches:
refs/heads/master 5a88b9e47 -> ffd04d9d6
SAMZA-1100; Exception when using a stream as both bootstrap and broadcast.
When a task input stream is used as both broadcast and bootstrap stream in a
samza job, Bootstrappingchooser marks the stream as
nce users
don't expect log statements to throw exceptions, this can cause unexpected
failures scenarios. We should catch exceptions and log to stderr instead.
Author: Prateek Maheshwari <pmahe...@linkedin.com>
Reviewers: Jagadish <jagad...@apache.org>
Closes #78 from prateekm/stre
.
2. Updated and cleaned up the StreamGraphBuilder examples.
3. Renamed SinkOperatorSpec to OutputOperatorSpec since its used by sink,
sendTo and partitionBy.
nickpan47 and xinyuiscool, please take a look.
Author: Prateek Maheshwari <pmahe...@linkedin.com>
Reviewers: Jagadish <jagad...@a
Repository: samza
Updated Branches:
refs/heads/master 65af13df1 -> 4bf8ab6eb
http://git-wip-us.apache.org/repos/asf/samza/blob/4bf8ab6e/samza-core/src/test/java/org/apache/samza/operators/triggers/TestWindowOperator.java
--
http://git-wip-us.apache.org/repos/asf/samza/blob/4bf8ab6e/samza-core/src/test/java/org/apache/samza/example/TestBroadcastExample.java
--
diff --git
a/samza-core/src/test/java/org/apache/samza/example/TestBroadcastExample.java
Repository: samza
Updated Branches:
refs/heads/master 8df1e16ee -> e95088d96
SAMZA-1205; Disable flaky tests in TestJmxServer.
Author: Shanthoosh Venkataraman <svenkatara...@linkedin.com>
Reviewers: Jagadish <jagad...@apache.org?
Closes #120 from shanthoosh/disable_jmx_
Repository: samza
Updated Branches:
refs/heads/master d50b1791b -> 1f3db9cc6
SAMZA-1209; Improve error handling in LocalStoreMonitor
Changes:
1. Add opt-in configuration to continue garbage collection of local stores
when thereâs a failure in garbage collecting one local store.
2.
Repository: samza
Updated Branches:
refs/heads/master 0feb5c2da -> 49cf06fc5
SAMZA-1202; Multiple calls to getInputStream() result in non-deterministic
behavior
Author: vjagadish1989
Reviewers: Prateek Maheshwari
Closes #136 from
s/master
Commit: 1c1139399599c1cb31249e8d7a28291e2ad9d27e
Parents: 4eb5153
Author: Boris Shkolnik <bor...@apache.org>
Authored: Fri Jul 21 15:32:58 2017 -0700
Committer: Jagadish <jagad...@apache.org>
Committed: Fri
> 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: Jagad
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 <pmahe...@linkedin.com>
Reviewers: Jagadish <jagad...@apachce.org>
Closes #24
Repository: samza
Updated Branches:
refs/heads/master c91da7842 -> 0feb5c2da
SAMZA-1229; Disk space monitor should only count data in use by the container
Author: Prateek Maheshwari <pmahe...@linkedin.com>
Reviewers: Jagadish <jagad...@apache.org>
Closes #134 from prat
Repository: samza
Updated Branches:
refs/heads/master f7e173651 -> 92ae4c628
SAMZA-1219; Add metrics for operator message received and execution times
Author: Prateek Maheshwari <pmahe...@linkedin.com>
Reviewers: Jagadish <jagad...@apache.org>
Closes #142 from prateekm/o
fer.
Author: Prateek Maheshwari <pmahe...@linkedin.com>
Reviewers: Jagadish <jagad...@apache.org>
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-wi
Repository: samza
Updated Tags: refs/tags/release-0.13.0-rc0 [created] 170d9fac5
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:
Repository: samza
Updated Branches:
refs/heads/0.13.0 [created] f6d0d6551
Repository: samza
Updated Branches:
refs/heads/master 46b1333c4 -> f6d0d6551
SAMZA-871; Heart-beat mechanism between JobCoordinator and all running
containers
Author: Abhishek Shivanna <ashiva...@linkedin.com>
Reviewers: Navina Ramesh <nav...@apache.org>, Jagadish V <j
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:
Repository: samza
Updated Branches:
refs/heads/master d89d1ba3a -> 9e2ee35d6
SAMZA-1274; Update kafka-python and kafka broker version for integration tests
Author: Prateek Maheshwari <pmahe...@linkedin.com>
Reviewers: Jagadish <jagad...@apache.org>
Closes #174 from prateekm/i
Repository: samza
Updated Branches:
refs/heads/master c50dd080b -> df5aa6c4e
Disable flaky tests.
Author: Shanthoosh Venkataraman
Reviewers: Navina Ramesh
Closes #158 from shanthoosh/master
Project:
ois.edu>
Reviewers: Prateek Maheshwari <pmahe...@linkedin.com>, Jagadish V
<jagad...@apache.org>
Closes #132 from s-noghabi/master
Project: http://git-wip-us.apache.org/repos/asf/samza/repo
Commit: http://git-wip-us.apache.org/repos/asf/samza/commit/014a59c6
Tree: http://git-wip-us.ap
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:
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 <bor...@apache.org>
Reviewers: Jagadish <jagad...@apache.
1 - 100 of 1058 matches
Mail list logo