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

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: htt

samza git commit: SAMZA-977: User doc for samza multi-threading

Repository: samza Updated Branches: refs/heads/master 3228ed9c4 -> 40ffe4ea5 SAMZA-977: User doc for samza multi-threading Project: http://git-wip-us.apache.org/repos/asf/samza/repo Commit: http://git-wip-us.apache.org/repos/asf/samza/commit/40ffe4ea Tree: http://git-wip-us.apache.org/repos/a

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

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: http://git-wip-us.apache.org/repos/asf/samza/commit

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

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: http://git-wip-us.ap

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

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: http://git-wip-us.apache.org/repos/asf/samza

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

ors and committers Also, updated the merge script with constants to match from the website documentation. Author: Navina Ramesh Reviewers: Jagadish Closes #16 from navina/adding-docs Project: http://git-wip-us.apache.org/repos/asf/samza/repo Commit: http://git-wip-us.apache.org/repos/asf/sam

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

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: http://git-wip-us.apache.o

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

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: http://git-wip-us.apache.org/repos/asf/samza/commit/19ef7cdf

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

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: http://g

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

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: http://git-wip-us.apache.org/repos/asf/samza/tree

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

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/s

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

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 b/samza-

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

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 a/samza-api/src/main/java/org/apache/samza/operators/task/StreamOperatorTask.

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

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 -- d

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

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: http://git-wip-us.apache.org/repos/as

samza git commit: SAMZA-1076; getKafkaChangelogEnabledStores() should use StorageConfig.getChangelo…

Repository: samza Updated Branches: refs/heads/master a47e8819f -> ec1934ca8 SAMZA-1076; getKafkaChangelogEnabledStores() should use StorageConfig.getChangelo… getKafkaChangelogEnabledStores() should use StorageConfig.getChangelogStream to get changelog system.stream Author: Boris Shkolni

samza git commit: SAMZA-1025: Documentation for HdfsSystemConsumer

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: http://git-wip-us.apache.org/repo

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

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 b/samza-ap

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

Repository: samza Updated Branches: refs/heads/master f01b28628 -> 6dc33a850 http://git-wip-us.apache.org/repos/asf/samza/blob/6dc33a85/samza-operator/src/test/java/org/apache/samza/operators/TestMessageStreamImpl.java -- diff

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

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 combin

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

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 Project: http://git-wip-us.apache.org/repos/

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

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 Reviewers: Jake Maes , Jagadish Closes #46 from prateekm/rocksdb-upgrade Proj

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

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 message

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

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 git commit: Update README.md to point to the most recent hello-samza release

Repository: samza Updated Branches: refs/heads/master 2a3a5ac7f -> d87ca67e5 Update README.md to point to the most recent hello-samza release Project: http://git-wip-us.apache.org/repos/asf/samza/repo Commit: http://git-wip-us.apache.org/repos/asf/samza/commit/d87ca67e Tree: http://git-wip-us

samza git commit: Add release PGP keys for Jagadish

Repository: samza Updated Branches: refs/heads/master d87ca67e5 -> 0405f25f0 Add release PGP keys for Jagadish 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://git-wip-us.apache.org/repos/asf/sa

[samza] Git Push Summary

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

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: http://git-wip-us.apache.

[samza] Git Push Summary

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

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: http://git-wip-us.apac

[samza] Git Push Summary

Repository: samza Updated Tags: refs/tags/release-0.12.0-rc2 [created] 69ad49515

[samza] Git Push Summary

Repository: samza Updated Branches: refs/heads/0.12.0 [created] e57b4a342

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

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: http://git-wip-us.apache.org/repos/asf/samza-hello-samza/commit/438

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

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: http:

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

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: http

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

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: http://git-wip-us.apache.org/repos/asf/samza-hello-sa

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

Author: jagadish Date: Wed Feb 22 20:59:57 2017 New Revision: 1784061 URL: http://svn.apache.org/viewvc?rev=1784061&view=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 [16/17] - in /samza/site: ./ archive/ community/ contribute/ learn/documentation/latest/ learn/documentation/latest/api/ learn/documentation/latest/api/javadocs/ learn/documentati

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&r1=1784061&r2=1784062&view=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

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&view=auto ==

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

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&view=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

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&r1=1784061&r2=1784062&view=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

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&view=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

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&r1=1784061&r2=1784062&view=diff == --- sam

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

Author: jagadish Date: Wed Feb 22 21:01:21 2017 New Revision: 1784062 URL: http://svn.apache.org/viewvc?rev=1784062&view=rev Log: updating welcome page Added: samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/annotation/ samza/site/learn/documentation/latest

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

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&r1=1784061&r2=1784062&view=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

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&view=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

Added: samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/triggers/TimeSinceFirstMessageTrigger.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/triggers/TimeSinceFirstMessageTrigger.html?rev=1784062&vi

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

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&view=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

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&view=auto

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

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&r1=1784061&r2=1784062&view=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

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&view=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

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&r1=1784061&r2=1784062&view=diff ==

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

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&view=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

Modified: samza/site/learn/documentation/latest/rest/javadocs/org/apache/samza/rest/proxy/installation/package-tree.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/rest/javadocs/org/apache/samza/rest/proxy/installation/package-tree.html?rev=1784062&r1=1784061&r2=17840

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

Repository: samza Updated Branches: refs/heads/master 65df0b5df -> 098a11d77 SAMZA-1104; fix yarn security page link from index.html page Author: Chen Song Reviewers: Jagadish Closes #62 from garlicbulb-puzhuo/SAMZA-1104 Project: http://git-wip-us.apache.org/repos/asf/samza/repo Com

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

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 Reviewers: Jagadish Closes #62 from garlicbulb-puzhuo/SAMZA-1104 Project: http://git-wip-us.apache.org/repos/asf/samza/repo Com

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

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: http://git-wip-us.apache.org/

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

Repository: samza Updated Branches: refs/heads/master 098a11d77 -> c58d74b35 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/c58d74b3 Tree: http://git-wip-us.apache.org/

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

Author: jagadish Date: Tue Feb 28 01:43:37 2017 New Revision: 1784678 URL: http://svn.apache.org/viewvc?rev=1784678&view=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.]

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

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&r1=1784678&r2=1784679&view=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

Modified: samza/site/learn/documentation/versioned/api/javadocs/org/apache/samza/operators/triggers/TimeSinceFirstMessageTrigger.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/versioned/api/javadocs/org/apache/samza/operators/triggers/TimeSinceFirstMessageTrigger.html?rev=1

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

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&r1=1784678&r2=1784679&view=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

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&r1=1784678&r2=1784679&view=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

Author: jagadish Date: Tue Feb 28 01:45:28 2017 New Revision: 1784679 URL: http://svn.apache.org/viewvc?rev=1784679&view=rev Log: updating welcome page Modified: samza/site/archive/index.html samza/site/community/committers.html samza/site/community/irc.html samza/site/commu

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

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&r1=1784678&r2=1784679&view=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

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&r1=1784678&r2=1784679&view=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

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&r1=1784678&r2=1784679&view=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

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&r1=1784678&r2=1784679&view=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

Modified: samza/site/learn/documentation/versioned/api/javadocs/org/apache/samza/operators/windows/internal/WindowInternal.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/versioned/api/javadocs/org/apache/samza/operators/windows/internal/WindowInternal.html?rev=1784679&r1=17

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

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&r1=1784678&r2=1784679&view=

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

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 Reviewers: Jagadish Closes #78 from prateekm/stream-appender-fix Project: http://git-wip-us.apache.o

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

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 Reviewers: Jagadish Closes #80 from twbecker/SA

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

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 bootstrapped

samza git commit: SAMZA-1091; Implement key-based inner join operator with no time constraints

Repository: samza Updated Branches: refs/heads/master ffd04d9d6 -> 5910ea669 SAMZA-1091; Implement key-based inner join operator with no time constraints Author: Prateek Maheshwari Author: Prateek Maheshwari Reviewers: Jagadish Venkatraman , Yi Pan Closes #60 from prateekm/mas

samza git commit: Fix an import issue on TestJoinOperator

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: http://git-wip-us.apache.org/repos/asf/sam

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

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, timeSinceFir

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

Repository: samza Updated Branches: refs/heads/master 05915bfc8 -> d399d6f3c http://git-wip-us.apache.org/repos/asf/samza/blob/d399d6f3/samza-core/src/main/java/org/apache/samza/operators/triggers/TimeSinceLastMessageTriggerImpl.java -

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

Repository: samza Updated Branches: refs/heads/master e2c35c000 -> 1c27ba88a SAMZA-1149; upgrade mockito from 1.8.4 to 1.10.19 More details: https://issues.apache.org/jira/browse/SAMZA-1149 Test: gradlew clean check successfully. All unit tests passed. Author: Fred Ji Reviewers: Jagad

samza git commit: SAMZA-1143; Universal config support for localized resource

Ji Reviewers: Jagadish Closes #90 from fredji97/universalLocalizer Project: http://git-wip-us.apache.org/repos/asf/samza/repo Commit: http://git-wip-us.apache.org/repos/asf/samza/commit/e4cfeebe Tree: http://git-wip-us.apache.org/repos/asf/samza/tree/e4cfeebe Diff: http://git-wip-us.apache.org/repos/

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

http://git-wip-us.apache.org/repos/asf/samza/blob/9db47b86/samza-core/src/test/scala/org/apache/samza/checkpoint/TestOffsetManager.scala -- diff --git a/samza-core/src/test/scala/org/apache/samza/checkpoint/TestOffsetManager.scala

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

SAMZA-1135 - Support scala 2.12 Added support for scala 2.12 Author: Maxim Logvinenko Reviewers: Jagadish ,Prateek Maheshwari Closes #82 from metamx:scala-2.12 Project: http://git-wip-us.apache.org/repos/asf/samza/repo Commit: http://git-wip-us.apache.org/repos/asf

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

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 a/samza

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

Repository: samza Updated Branches: refs/heads/master 944c70878 -> 71004e1eb SAMZA-1176; Make TestJoinOperator unit tests safe for concurrent execution Author: Prateek Maheshwari Reviewers: Jagadish Closes #105 from prateekm/join-tests Project: http://git-wip-us.apache.org/repos/

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

sim Logvinenko Reviewers: Jagadish 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/repos/asf/samza/tree/101ca439 Diff: http://git-

[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

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 -- dif

[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

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 b/

[3/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

http://git-wip-us.apache.org/repos/asf/samza/blob/4bf8ab6e/samza-core/src/main/java/org/apache/samza/operators/spec/OperatorSpecs.java -- diff --git a/samza-core/src/main/java/org/apache/samza/operators/spec/OperatorSpecs.java b/

[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

. 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 Reviewers: Jagadish , Yi Pan Closes #92 from prateekm/message

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

lease take a look. Author: Prateek Maheshwari Reviewers: Jagadish 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 Tree: http://git-wip-us.apache.org/repos/asf/samza/tree/b5

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

0. Author: Fred Ji Author: vjagadish1989 Reviewers: Jagadish 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://git-wip-us.apache.org/repos/asf/samza/tree/c1

samza git commit: SAMZA-1170: Integration testing harness for StreamApplications

Repository: samza Updated Branches: refs/heads/master 260414dbf -> 8a18a708a SAMZA-1170: Integration testing harness for StreamApplications - Added an integration testing harness for testing `StreamApplication`s. This is convenient for running and interacting with Kafka brokers, Zk servers an

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

Repository: samza Updated Branches: refs/heads/master 925866d9b -> 8df1e16ee SAMZA-1211; Remove Thread.sleep() from TestJoinOperator tests Author: Prateek Maheshwari Reviewers: Jagadish Closes #123 from prateekm/join-test-no-sleep Project: http://git-wip-us.apache.org/repos/asf/sa

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

Repository: samza Updated Branches: refs/heads/master 8df1e16ee -> e95088d96 SAMZA-1205; Disable flaky tests in TestJmxServer. Author: Shanthoosh Venkataraman Reviewers: Jagadish http://git-wip-us.apache.org/repos/asf/samza/repo Commit: http://git-wip-us.apache.org/repos/asf/samza/com

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

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. Handle

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

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: http://git-wip-us.apache.org/repos/asf/samza-hello-samza/co

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

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 Reviewers: Jagadish Closes #134 from prateekm/disk-space-monitor Project: http://git-wip-us.apache.

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

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 vjagadish1989/samza-1202 Project: http://git-wip-us.apache

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

Repository: samza Updated Branches: refs/heads/master f7e173651 -> 92ae4c628 SAMZA-1219; Add metrics for operator message received and execution times Author: Prateek Maheshwari Reviewers: Jagadish Closes #142 from prateekm/operator-metrics Project: http://git-wip-us.apache.org/re

samza git commit: SAMZA-1155; Validate users configure window.ms when using the fluent API

Repository: samza Updated Branches: refs/heads/master d8534b5d8 -> e6cc3b713 SAMZA-1155; Validate users configure window.ms when using the fluent API We will compute triggering duration as follows: - If user configures `task.window.ms` we will honor it as the triggering duration - If not, we

samza git commit: SAMZA-1232; Log configuration value in RunLoopFactory

Repository: samza Updated Branches: refs/heads/master ad41f9a7f -> 29c4844fd SAMZA-1232; Log configuration value in RunLoopFactory Author: Shanthoosh Venkataraman Reviewers: Xinyu Liu Closes #137 from shanthoosh/adding_logging_into_asyncrunloop Project: http://git-wip-us.apache.org/repos

  1   2   3   4   5   6   7   8   9   10   >