This closes #2550
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/946778c5 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/946778c5 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/946778c5 Branch: refs/heads/jstorm-runner Commit: 946778c5bb114814d1ba5ebe71a27bc960f9e59b Parents: 9b8f230 7cf06f5 Author: Jean-Baptiste Onofré <jbono...@apache.org> Authored: Mon Apr 17 11:55:52 2017 +0200 Committer: Jean-Baptiste Onofré <jbono...@apache.org> Committed: Mon Apr 17 11:55:52 2017 +0200 ---------------------------------------------------------------------- .../org/apache/beam/runners/apex/ApexYarnLauncher.java | 2 -- .../apache/beam/runners/direct/ModelEnforcement.java | 13 ++++++------- .../beam/runners/direct/TransformEvaluatorFactory.java | 10 +++++----- .../src/main/java/org/apache/beam/sdk/io/AvroIO.java | 13 ++++++------- .../src/main/java/org/apache/beam/sdk/io/Sink.java | 2 +- .../main/java/org/apache/beam/sdk/io/jdbc/JdbcIO.java | 2 -- .../apache/beam/sdk/io/mongodb/MongoDbGridFSIO.java | 7 +------ 7 files changed, 19 insertions(+), 30 deletions(-) ----------------------------------------------------------------------
