samza git commit: Add release PGP keys for Jagadish <jagad...@apache.org>

2017-02-01 Thread jagadish
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:

[samza] Git Push Summary

2017-02-01 Thread jagadish
Repository: samza Updated Tags: refs/tags/release-0.12.0-rc0 [created] 591d511d4

samza git commit: Update Samza version to prepare for 0.12.0 Samza release

2017-02-02 Thread jagadish
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:

[samza] Git Push Summary

2017-02-02 Thread jagadish
Repository: samza Updated Tags: refs/tags/release-0.12.0-rc1 [created] e2e037514

samza git commit: Fix integration test config issue in 0.12 release candidate

2017-02-06 Thread jagadish
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:

[samza] Git Push Summary

2017-02-06 Thread jagadish
Repository: samza Updated Tags: refs/tags/release-0.12.0-rc2 [created] 69ad49515

samza git commit: SAMZA-1025: Documentation for HdfsSystemConsumer

2017-01-30 Thread jagadish
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:

samza git commit: SAMZA-1077: SamzaContainer should catch all Throwables instead of only exceptions

2017-01-30 Thread jagadish
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

[3/3] samza git commit: Specification of various Window and Trigger APIs in Samza

2017-01-30 Thread jagadish
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

[2/3] samza git commit: Specification of various Window and Trigger APIs in Samza

2017-01-30 Thread jagadish
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

samza git commit: SAMZA-1079: Add timeouts for reads from HttpFileSystem. Add tests.

2017-01-30 Thread jagadish
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

samza git commit: SAMZA-984; Upgraded RocksDB version to 5.0.1 and added configuration for managing RocksDB logging.

2017-01-30 Thread jagadish
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

samza git commit: SAMZA-1074; Fix builds for hello-samza on various CDH versions

2017-01-30 Thread jagadish
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

samza-hello-samza git commit: SAMZA-1099: Changes to hello-samza for the 0.12.0 release

2017-02-21 Thread jagadish
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:

samza-hello-samza git commit: SAMZA-1099: Changes to hello-samza (latest branch) for the 0.12 release

2017-02-22 Thread jagadish
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:

svn commit: r1784061 - in /samza/site: ./ archive/ community/ contribute/ img/0.12/ img/0.12/learn/ img/0.12/learn/documentation/ img/0.12/learn/documentation/comparisons/ img/0.12/learn/documentation

2017-02-22 Thread jagadish
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.]

svn commit: r1784062 [12/17] - in /samza/site: ./ archive/ community/ contribute/ learn/documentation/latest/ learn/documentation/latest/api/ learn/documentation/latest/api/javadocs/ learn/documentati

2017-02-22 Thread jagadish
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

svn commit: r1784062 [17/17] - in /samza/site: ./ archive/ community/ contribute/ learn/documentation/latest/ learn/documentation/latest/api/ learn/documentation/latest/api/javadocs/ learn/documentati

2017-02-22 Thread jagadish
Modified: samza/site/learn/documentation/latest/rest/javadocs/org/apache/samza/rest/proxy/installation/package-tree.html URL:

svn commit: r1784062 [14/17] - in /samza/site: ./ archive/ community/ contribute/ learn/documentation/latest/ learn/documentation/latest/api/ learn/documentation/latest/api/javadocs/ learn/documentati

2017-02-22 Thread jagadish
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

svn commit: r1784062 [5/17] - in /samza/site: ./ archive/ community/ contribute/ learn/documentation/latest/ learn/documentation/latest/api/ learn/documentation/latest/api/javadocs/ learn/documentatio

2017-02-22 Thread jagadish
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

svn commit: r1784062 [2/17] - in /samza/site: ./ archive/ community/ contribute/ learn/documentation/latest/ learn/documentation/latest/api/ learn/documentation/latest/api/javadocs/ learn/documentatio

2017-02-22 Thread jagadish
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 == ---

svn commit: r1784062 [7/17] - in /samza/site: ./ archive/ community/ contribute/ learn/documentation/latest/ learn/documentation/latest/api/ learn/documentation/latest/api/javadocs/ learn/documentatio

2017-02-22 Thread jagadish
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

svn commit: r1784062 [11/17] - in /samza/site: ./ archive/ community/ contribute/ learn/documentation/latest/ learn/documentation/latest/api/ learn/documentation/latest/api/javadocs/ learn/documentati

2017-02-22 Thread jagadish
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

samza git commit: SAMZA-1099: Documentation updates for Samza 0.12 release (for 0.12.0 branch)

2017-02-22 Thread jagadish
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:

samza git commit: SAMZA-1099: Documentation updates for Samza 0.12 release (for master branch)

2017-02-22 Thread jagadish
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:

svn commit: r1784062 [10/17] - in /samza/site: ./ archive/ community/ contribute/ learn/documentation/latest/ learn/documentation/latest/api/ learn/documentation/latest/api/javadocs/ learn/documentati

2017-02-22 Thread jagadish
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

svn commit: r1784062 [15/17] - in /samza/site: ./ archive/ community/ contribute/ learn/documentation/latest/ learn/documentation/latest/api/ learn/documentation/latest/api/javadocs/ learn/documentati

2017-02-22 Thread jagadish
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 ==

svn commit: r1784062 [8/17] - in /samza/site: ./ archive/ community/ contribute/ learn/documentation/latest/ learn/documentation/latest/api/ learn/documentation/latest/api/javadocs/ learn/documentatio

2017-02-22 Thread jagadish
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

svn commit: r1784062 [3/17] - in /samza/site: ./ archive/ community/ contribute/ learn/documentation/latest/ learn/documentation/latest/api/ learn/documentation/latest/api/javadocs/ learn/documentatio

2017-02-22 Thread jagadish
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 == ---

svn commit: r1784062 [16/17] - in /samza/site: ./ archive/ community/ contribute/ learn/documentation/latest/ learn/documentation/latest/api/ learn/documentation/latest/api/javadocs/ learn/documentati

2017-02-22 Thread jagadish
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 == ---

svn commit: r1784062 [6/17] - in /samza/site: ./ archive/ community/ contribute/ learn/documentation/latest/ learn/documentation/latest/api/ learn/documentation/latest/api/javadocs/ learn/documentatio

2017-02-22 Thread jagadish
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

svn commit: r1784062 [1/17] - in /samza/site: ./ archive/ community/ contribute/ learn/documentation/latest/ learn/documentation/latest/api/ learn/documentation/latest/api/javadocs/ learn/documentatio

2017-02-22 Thread jagadish
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

svn commit: r1784062 [4/17] - in /samza/site: ./ archive/ community/ contribute/ learn/documentation/latest/ learn/documentation/latest/api/ learn/documentation/latest/api/javadocs/ learn/documentatio

2017-02-22 Thread jagadish
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

svn commit: r1784062 [13/17] - in /samza/site: ./ archive/ community/ contribute/ learn/documentation/latest/ learn/documentation/latest/api/ learn/documentation/latest/api/javadocs/ learn/documentati

2017-02-22 Thread jagadish
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

svn commit: r1784062 [9/17] - in /samza/site: ./ archive/ community/ contribute/ learn/documentation/latest/ learn/documentation/latest/api/ learn/documentation/latest/api/javadocs/ learn/documentatio

2017-02-22 Thread jagadish
Added: samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/triggers/TimeSinceFirstMessageTrigger.html URL:

[samza] Git Push Summary

2017-02-21 Thread jagadish
Repository: samza Updated Branches: refs/heads/0.12.0 [created] e57b4a342

svn commit: r1784679 [11/11] - in /samza/site: ./ archive/ community/ contribute/ learn/documentation/versioned/ learn/documentation/versioned/api/ learn/documentation/versioned/api/javadocs/ learn/do

2017-02-27 Thread jagadish
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

svn commit: r1784679 [6/11] - in /samza/site: ./ archive/ community/ contribute/ learn/documentation/versioned/ learn/documentation/versioned/api/ learn/documentation/versioned/api/javadocs/ learn/doc

2017-02-27 Thread jagadish
Modified: samza/site/learn/documentation/versioned/api/javadocs/org/apache/samza/operators/triggers/TimeSinceFirstMessageTrigger.html URL:

samza git commit: Fix a rendering issue in the Samza security web-page

2017-02-27 Thread jagadish
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:

svn commit: r1784678 - in /samza/site: ./ archive/ community/ contribute/ img/versioned/ img/versioned/learn/ img/versioned/learn/documentation/ img/versioned/learn/documentation/comparisons/ img/vers

2017-02-27 Thread jagadish
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.]

samza git commit: SAMZA-1104; fix yarn security page link from index.html page

2017-02-27 Thread jagadish
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:

svn commit: r1784679 [4/11] - in /samza/site: ./ archive/ community/ contribute/ learn/documentation/versioned/ learn/documentation/versioned/api/ learn/documentation/versioned/api/javadocs/ learn/doc

2017-02-27 Thread jagadish
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

svn commit: r1784679 [2/11] - in /samza/site: ./ archive/ community/ contribute/ learn/documentation/versioned/ learn/documentation/versioned/api/ learn/documentation/versioned/api/javadocs/ learn/doc

2017-02-27 Thread jagadish
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 == ---

svn commit: r1784679 [1/11] - in /samza/site: ./ archive/ community/ contribute/ learn/documentation/versioned/ learn/documentation/versioned/api/ learn/documentation/versioned/api/javadocs/ learn/doc

2017-02-27 Thread jagadish
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

svn commit: r1784679 [3/11] - in /samza/site: ./ archive/ community/ contribute/ learn/documentation/versioned/ learn/documentation/versioned/api/ learn/documentation/versioned/api/javadocs/ learn/doc

2017-02-27 Thread jagadish
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 == ---

svn commit: r1784679 [7/11] - in /samza/site: ./ archive/ community/ contribute/ learn/documentation/versioned/ learn/documentation/versioned/api/ learn/documentation/versioned/api/javadocs/ learn/doc

2017-02-27 Thread jagadish
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

svn commit: r1784679 [10/11] - in /samza/site: ./ archive/ community/ contribute/ learn/documentation/versioned/ learn/documentation/versioned/api/ learn/documentation/versioned/api/javadocs/ learn/do

2017-02-27 Thread jagadish
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

svn commit: r1784679 [9/11] - in /samza/site: ./ archive/ community/ contribute/ learn/documentation/versioned/ learn/documentation/versioned/api/ learn/documentation/versioned/api/javadocs/ learn/doc

2017-02-27 Thread jagadish
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

svn commit: r1784679 [8/11] - in /samza/site: ./ archive/ community/ contribute/ learn/documentation/versioned/ learn/documentation/versioned/api/ learn/documentation/versioned/api/javadocs/ learn/doc

2017-02-27 Thread jagadish
Modified: samza/site/learn/documentation/versioned/api/javadocs/org/apache/samza/operators/windows/internal/WindowInternal.html URL:

svn commit: r1784679 [5/11] - in /samza/site: ./ archive/ community/ contribute/ learn/documentation/versioned/ learn/documentation/versioned/api/ learn/documentation/versioned/api/javadocs/ learn/doc

2017-02-27 Thread jagadish
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

[1/2] samza git commit: SAMZA-1020: Remove methods in Kafka checkpoint classes that were deprecated in the 0.10 release.

2016-09-29 Thread jagadish
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:

[2/2] samza git commit: SAMZA-995: Remove deprecated property yarn.container.count from config table.

2016-09-29 Thread jagadish
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:

samza git commit: SAMZA-1028: Fix KafkaSystemProducer logging and use an AtomicReference for tracking producer exceptions

2016-09-29 Thread jagadish
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:

samza git commit: SAMZA-1021 : Remove the redundent poll waiting inside AsyncRunLoop blockIfBusy

2016-09-22 Thread jagadish
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:

[1/2] samza git commit: SAMZA-1015 Add support for streams, Lambdas and other JDK 8 like features in checkstyle

2016-09-30 Thread jagadish
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:

[2/2] samza git commit: SAMZA-1016: Fix support for joint compilation of scala and java sources

2016-09-30 Thread jagadish
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:

samza git commit: SAMZA-974 Support finite data sources that have a notion of end of stream

2016-10-01 Thread jagadish
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:

samza git commit: SAMZA-1030; Add documentation for change in the contribution process

2016-09-29 Thread jagadish
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

samza git commit: SAMZA-1046: Docs for checkpointable consumer

2016-11-22 Thread jagadish
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:

samza git commit: Fix a minor typo in the web-page

2016-10-31 Thread jagadish
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:

[4/4] samza git commit: SAMZA-1045: Move classes from operator/api into samza-api

2016-11-01 Thread jagadish
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:

[2/4] samza git commit: SAMZA-1045: Move classes from operator/api into samza-api

2016-11-01 Thread jagadish
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

[3/4] samza git commit: SAMZA-1045: Move classes from operator/api into samza-api

2016-11-01 Thread jagadish
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

[1/4] samza git commit: SAMZA-1045: Move classes from operator/api into samza-api

2016-11-01 Thread jagadish
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 --

samza git commit: SAMZA-1149; upgrade mockito from 1.8.4 to 1.10.19

2017-03-22 Thread jagadish
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

[3/3] samza git commit: SAMZA-1135 - Support scala 2.12

2017-03-31 Thread jagadish
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

[1/3] samza git commit: SAMZA-1135 - Support scala 2.12

2017-03-31 Thread jagadish
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

[2/2] samza git commit: SAMZA-1108: Implementation of Windows and various kinds of Triggers

2017-03-19 Thread jagadish
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,

samza git commit: Fix an import issue on TestJoinOperator

2017-03-14 Thread jagadish
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:

samza git commit: SAMZA-1176; Make TestJoinOperator unit tests safe for concurrent execution

2017-03-31 Thread jagadish
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-

samza git commit: SAMZA-1138; Yarn capability check is broken

2017-04-02 Thread jagadish
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/

samza git commit: SAMZA-1143; Include fs..impl.* subkeys to YarnConfiguration used in YarnJobFactory and YarnClusterResourceManager

2017-04-05 Thread jagadish
<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://

samza git commit: SAMZA-1191; Fixed flaky test: TestExponentialSleepStrategy testThreadInterruptInRetryLoop

2017-04-05 Thread jagadish
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

samza-hello-samza git commit: SAMZA-1225: Add demo examples for programming with the fluent API

2017-04-20 Thread jagadish
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:

samza git commit: SAMZA-1211; Remove Thread.sleep() from TestJoinOperator tests

2017-04-17 Thread jagadish
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-

samza git commit: SAMZA-1112; BrokerProxy does not log fatal errors

2017-03-11 Thread jagadish
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

samza git commit: SAMZA-1100; Exception when using a stream as both bootstrap and broadcast.

2017-03-13 Thread jagadish
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

samza git commit: SAMZA-1121; StreamAppender should not propagate exceptions to the caller

2017-03-08 Thread jagadish
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

[4/4] samza git commit: SAMZA-1094 SAMZA-1101 SAMZA-1159; Remove MessageEnvelope from public operator APIs. : Delay the creation of SinkFunction for output streams. : Move StreamSpec from a public API

2017-04-05 Thread jagadish
. 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

[1/4] samza git commit: SAMZA-1094 SAMZA-1101 SAMZA-1159; Remove MessageEnvelope from public operator APIs. : Delay the creation of SinkFunction for output streams. : Move StreamSpec from a public API

2017-04-05 Thread jagadish
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 --

[2/4] samza git commit: SAMZA-1094 SAMZA-1101 SAMZA-1159; Remove MessageEnvelope from public operator APIs. : Delay the creation of SinkFunction for output streams. : Move StreamSpec from a public API

2017-04-05 Thread jagadish
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

samza git commit: SAMZA-1205; Disable flaky tests in TestJmxServer.

2017-04-17 Thread jagadish
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_

samza git commit: SAMZA-1209; Improve error handling in LocalStoreMonitor

2017-04-19 Thread jagadish
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.

samza git commit: SAMZA-1202; Multiple calls to getInputStream() result in non-deterministic behavior

2017-04-24 Thread jagadish
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

samza git commit: SAMZA-1368; make sure new job model will be generated in case of barrier timeout.

2017-07-21 Thread jagadish
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

samza git commit: SAMZA-1359; Handle phantom container notifications cleanly during an RM fail-over

2017-07-25 Thread jagadish
> 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

samza git commit: SAMZA-1361; OperatorImplGraph is using wrong keys to store/retrieve OperatorImpl in the map

2017-07-27 Thread jagadish
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

samza git commit: SAMZA-1229; Disk space monitor should only count data in use by the container

2017-04-24 Thread jagadish
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

samza git commit: SAMZA-1219; Add metrics for operator message received and execution times

2017-04-27 Thread jagadish
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

samza git commit: SAMZA-1370; Memory leak in CachedStore when using ByteBufferSerde as key Serde

2017-07-27 Thread jagadish
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

[samza] Git Push Summary

2017-05-10 Thread jagadish
Repository: samza Updated Tags: refs/tags/release-0.13.0-rc0 [created] 170d9fac5

samza git commit: Update SNAPSHOT version for 0.13 release

2017-05-10 Thread jagadish
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:

[samza] Git Push Summary

2017-05-10 Thread jagadish
Repository: samza Updated Branches: refs/heads/0.13.0 [created] f6d0d6551

samza git commit: SAMZA-871; Heart-beat mechanism between JobCoordinator and all running containers

2017-05-10 Thread jagadish
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

samza git commit: Revert "Disable flaky tests."

2017-05-10 Thread jagadish
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:

samza git commit: SAMZA-1274; Update kafka-python and kafka broker version for integration tests

2017-05-09 Thread jagadish
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

samza git commit: Disable flaky tests.

2017-05-10 Thread jagadish
Repository: samza Updated Branches: refs/heads/master c50dd080b -> df5aa6c4e Disable flaky tests. Author: Shanthoosh Venkataraman Reviewers: Navina Ramesh Closes #158 from shanthoosh/master Project:

samza git commit: SAMZA-1174; Profiling state store performance

2017-05-11 Thread jagadish
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

samza git commit: Minor: Re-word a couple of lines in javadoc with explicit notes about failures

2017-05-10 Thread jagadish
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:

samza git commit: SAMZA-1298; Create zk path.

2017-05-22 Thread jagadish
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   2   3   4   5   6   7   8   9   10   >