You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by dh...@apache.org on 2017/05/04 21:21:41 UTC
[1/2] beam git commit: Move thrown.expect to correct place
Repository: beam
Updated Branches:
refs/heads/master 44589c6f9 -> 727476590
Move thrown.expect to correct place
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/1d9089c9
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/1d9089c9
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/1d9089c9
Branch: refs/heads/master
Commit: 1d9089c968535090ba77977ddecc6cdfb936655f
Parents: 44589c6
Author: Mark Liu <ma...@google.com>
Authored: Thu May 4 12:48:55 2017 -0700
Committer: Dan Halperin <dh...@google.com>
Committed: Thu May 4 14:21:33 2017 -0700
----------------------------------------------------------------------
.../src/test/java/org/apache/beam/sdk/io/hbase/HBaseIOTest.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/beam/blob/1d9089c9/sdks/java/io/hbase/src/test/java/org/apache/beam/sdk/io/hbase/HBaseIOTest.java
----------------------------------------------------------------------
diff --git a/sdks/java/io/hbase/src/test/java/org/apache/beam/sdk/io/hbase/HBaseIOTest.java b/sdks/java/io/hbase/src/test/java/org/apache/beam/sdk/io/hbase/HBaseIOTest.java
index 6308931..dbeab04 100644
--- a/sdks/java/io/hbase/src/test/java/org/apache/beam/sdk/io/hbase/HBaseIOTest.java
+++ b/sdks/java/io/hbase/src/test/java/org/apache/beam/sdk/io/hbase/HBaseIOTest.java
@@ -287,11 +287,11 @@ public class HBaseIOTest {
PCollection<KV<byte[], Iterable<Mutation>>> emptyInput =
p.apply(Create.empty(HBaseIO.WRITE_CODER));
+ emptyInput.apply("write", HBaseIO.write().withConfiguration(conf).withTableId(table));
+
// Exception will be thrown by write.validate() when write is applied.
thrown.expect(IllegalArgumentException.class);
thrown.expectMessage(String.format("Table %s does not exist", table));
-
- emptyInput.apply("write", HBaseIO.write().withConfiguration(conf).withTableId(table));
p.run();
}
[2/2] beam git commit: This closes #2899
Posted by dh...@apache.org.
This closes #2899
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/72747659
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/72747659
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/72747659
Branch: refs/heads/master
Commit: 727476590c3b4c805a23b06d985c81447d19895a
Parents: 44589c6 1d9089c
Author: Dan Halperin <dh...@google.com>
Authored: Thu May 4 14:21:35 2017 -0700
Committer: Dan Halperin <dh...@google.com>
Committed: Thu May 4 14:21:35 2017 -0700
----------------------------------------------------------------------
.../src/test/java/org/apache/beam/sdk/io/hbase/HBaseIOTest.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------