This closes #3957: Fixes TextIO and AvroIO tests of watchForNewFiles
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/5130cab4 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/5130cab4 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/5130cab4 Branch: refs/heads/master Commit: 5130cab4a1d39300a266915cac4efebc1ffd658e Parents: ec1782c 35183c7 Author: Eugene Kirpichov <kirpic...@google.com> Authored: Mon Oct 9 11:33:07 2017 -0700 Committer: Eugene Kirpichov <kirpic...@google.com> Committed: Mon Oct 9 11:33:07 2017 -0700 ---------------------------------------------------------------------- .../java/org/apache/beam/sdk/io/AvroIOTest.java | 21 +++++--- .../org/apache/beam/sdk/io/TextIOReadTest.java | 56 +++++++------------- 2 files changed, 34 insertions(+), 43 deletions(-) ----------------------------------------------------------------------
