Github user neoremind commented on a diff in the pull request:
https://github.com/apache/flink/pull/5633#discussion_r172125701
--- Diff:
flink-connectors/flink-hbase/src/test/java/org/apache/flink/addons/hbase/example/HBaseReadExample.java
---
@@ -86,8 +86,8 @@ public boolean filter(Tuple2<String, String> t) throws
Exception {
hbaseDs.print();
- // kick off execution.
- env.execute();
+ // kick off execution is not needed.
+ // env.execute();
--- End diff --
Done.---
