Repository: beam Updated Branches: refs/heads/master e70e608da -> 5d6dafa26
This closes #2054 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/5d6dafa2 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/5d6dafa2 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/5d6dafa2 Branch: refs/heads/master Commit: 5d6dafa26a29020afa3db2bac252ceadddbdeeac Parents: e70e608 9088a5e Author: Thomas Groh <[email protected]> Authored: Tue Feb 21 09:47:30 2017 -0800 Committer: Thomas Groh <[email protected]> Committed: Tue Feb 21 09:47:30 2017 -0800 ---------------------------------------------------------------------- .../main/java/org/apache/beam/fn/harness/FnHarness.java | 6 +++--- .../beam/fn/harness/control/BeamFnControlClient.java | 4 ++-- .../beam/fn/harness/control/ProcessBundleHandler.java | 6 +++--- .../apache/beam/fn/harness/control/RegisterHandler.java | 6 +++--- .../harness/data/BeamFnDataBufferingOutboundObserver.java | 4 ++-- .../apache/beam/fn/harness/data/BeamFnDataGrpcClient.java | 4 ++-- .../beam/fn/harness/data/BeamFnDataGrpcMultiplexer.java | 10 +++++----- .../beam/fn/harness/data/BeamFnDataInboundObserver.java | 4 ++-- .../apache/beam/runners/core/BeamFnDataReadRunner.java | 4 ++-- .../beam/sdk/io/elasticsearch/ElasticsearchIOTest.java | 8 ++++---- 10 files changed, 28 insertions(+), 28 deletions(-) ----------------------------------------------------------------------
