[GitHub] flink pull request #6365: [FLINK-9849] [hbase] Hbase upgrade to 2.0.1

2018-07-18 Thread yanghua
Github user yanghua commented on a diff in the pull request: https://github.com/apache/flink/pull/6365#discussion_r203439890 --- Diff: flink-connectors/flink-hbase/src/test/java/org/apache/flink/addons/hbase/example/HBaseWriteStreamExample.java --- @@ -87,22 +90,22 @@ public void

[GitHub] flink pull request #6365: [FLINK-9849] [hbase] Hbase upgrade to 2.0.1

2018-07-18 Thread yanghua
Github user yanghua commented on a diff in the pull request: https://github.com/apache/flink/pull/6365#discussion_r203440989 --- Diff: flink-connectors/flink-hbase/src/test/java/org/apache/flink/addons/hbase/example/HBaseWriteStreamExample.java --- @@ -87,22 +90,22 @@ public void

[GitHub] flink pull request #6365: [FLINK-9849] [hbase] Hbase upgrade to 2.0.1

2018-07-18 Thread yanghua
Github user yanghua commented on a diff in the pull request: https://github.com/apache/flink/pull/6365#discussion_r203438579 --- Diff: flink-connectors/flink-hbase/src/main/java/org/apache/flink/addons/hbase/TableInputFormat.java --- @@ -81,7 +85,9 @@ private HTable createTable()

[GitHub] flink pull request #6365: [FLINK-9849] [hbase] Hbase upgrade to 2.0.1

2018-07-18 Thread yanghua
Github user yanghua commented on a diff in the pull request: https://github.com/apache/flink/pull/6365#discussion_r203439523 --- Diff: flink-connectors/flink-hbase/src/test/java/org/apache/flink/addons/hbase/example/HBaseWriteStreamExample.java --- @@ -87,22 +90,22 @@ public void

[GitHub] flink pull request #6365: [FLINK-9849] [hbase] Hbase upgrade to 2.0.1

2018-07-18 Thread yanghua
Github user yanghua commented on a diff in the pull request: https://github.com/apache/flink/pull/6365#discussion_r203439859 --- Diff: flink-connectors/flink-hbase/src/test/java/org/apache/flink/addons/hbase/example/HBaseWriteStreamExample.java --- @@ -87,22 +90,22 @@ public void