beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From dhalp...@apache.org
Subject [1/2] beam git commit: Move thrown.expect to correct place
Date Thu, 04 May 2017 21:21:41 GMT
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 <markliu@google.com>
Authored: Thu May 4 12:48:55 2017 -0700
Committer: Dan Halperin <dhalperi@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();
     }
 


Mime
View raw message