Merge branch 'master' of https://github.com/apache/samza
Project: http://git-wip-us.apache.org/repos/asf/samza/repo Commit: http://git-wip-us.apache.org/repos/asf/samza/commit/2e7a6cdb Tree: http://git-wip-us.apache.org/repos/asf/samza/tree/2e7a6cdb Diff: http://git-wip-us.apache.org/repos/asf/samza/diff/2e7a6cdb Branch: refs/heads/master Commit: 2e7a6cdba16349e6bf8b3cdbe0f5128cd0463712 Parents: 07120f4 6b31894 Author: Jagadish <jvenkatra...@linkedin.com> Authored: Fri Oct 5 11:04:23 2018 -0700 Committer: Jagadish <jvenkatra...@linkedin.com> Committed: Fri Oct 5 11:04:23 2018 -0700 ---------------------------------------------------------------------- docs/_includes/footer.html | 4 +- docs/_includes/main-navigation.html | 2 +- docs/_layouts/default.html | 6 +- docs/_menu/index.html | 4 +- docs/community/contact-us.md | 77 +++++ docs/community/mailing-lists.md | 28 -- docs/contribute/contributors-corner.md | 123 ++++--- docs/contribute/design-documents.md | 58 ---- docs/contribute/enhancement-proposal.md | 96 ++++++ docs/css/main.new.css | 6 +- .../versioned/jobs/basic-configurations.md | 168 ---------- .../versioned/jobs/configuration.md | 4 +- .../versioned/jobs/samza-configurations.md | 335 +++++++++++++++++++ .../versioned/operations/monitoring.md | 6 +- .../StreamApplicationDescriptor.java | 6 - .../apache/samza/operators/MessageStream.java | 25 +- .../StreamApplicationDescriptorImpl.java | 17 +- .../TaskApplicationDescriptorImpl.java | 2 +- .../apache/samza/container/LocalityManager.java | 8 - .../grouper/task/GroupByContainerCount.java | 88 ++--- .../task/GroupByContainerCountFactory.java | 4 +- .../grouper/task/TaskAssignmentManager.java | 2 +- .../samza/operators/MessageStreamImpl.java | 11 - .../apache/samza/processor/StreamProcessor.java | 64 ++-- .../apache/samza/container/SamzaContainer.scala | 17 +- .../TestStreamApplicationDescriptorImpl.java | 13 +- .../grouper/task/TestGroupByContainerCount.java | 106 +++--- .../grouper/task/TestGroupByContainerIds.java | 12 +- .../grouper/task/TestTaskAssignmentManager.java | 12 +- .../samza/coordinator/TestJobModelManager.java | 11 +- .../execution/ExecutionPlannerTestBase.java | 8 +- .../samza/execution/TestExecutionPlanner.java | 17 +- .../execution/TestJobGraphJsonGenerator.java | 6 +- .../TestJobNodeConfigurationGenerator.java | 22 -- .../samza/operators/TestMessageStreamImpl.java | 30 -- .../operators/impl/TestOperatorImplGraph.java | 4 +- .../spec/TestPartitionByOperatorSpec.java | 12 +- .../samza/processor/TestStreamProcessor.java | 7 +- .../samza/rest/proxy/task/SamzaTaskProxy.java | 4 +- .../EndOfStreamIntegrationTest.java | 11 +- .../WatermarkIntegrationTest.java | 4 +- .../test/framework/FaultInjectionTest.java | 126 +++++++ .../StreamApplicationIntegrationTest.java | 98 +++--- ...StreamApplicationIntegrationTestHarness.java | 8 +- .../processor/TestZkLocalApplicationRunner.java | 10 +- .../apache/samza/test/table/TestLocalTable.java | 2 +- .../table/TestLocalTableWithSideInputs.java | 2 +- .../webapp/TestApplicationMasterRestClient.java | 5 +- 48 files changed, 988 insertions(+), 703 deletions(-) ----------------------------------------------------------------------
