You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ja...@apache.org on 2019/08/20 02:09:35 UTC
[flink] branch release-1.9 updated: [hotfix][[FLINK-13699][hbase]
Fix compile problem in HBaseConnectorITCase
This is an automated email from the ASF dual-hosted git repository.
jark pushed a commit to branch release-1.9
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/release-1.9 by this push:
new d505749 [hotfix][[FLINK-13699][hbase] Fix compile problem in HBaseConnectorITCase
d505749 is described below
commit d5057491519278b638a90ee02d9b588d814d0516
Author: Jark Wu <wu...@alibaba-inc.com>
AuthorDate: Tue Aug 20 09:42:27 2019 +0800
[hotfix][[FLINK-13699][hbase] Fix compile problem in HBaseConnectorITCase
---
.../java/org/apache/flink/addons/hbase/HBaseConnectorITCase.java | 5 +----
1 file changed, 1 insertion(+), 4 deletions(-)
diff --git a/flink-connectors/flink-hbase/src/test/java/org/apache/flink/addons/hbase/HBaseConnectorITCase.java b/flink-connectors/flink-hbase/src/test/java/org/apache/flink/addons/hbase/HBaseConnectorITCase.java
index d7231ab..a66dd38 100644
--- a/flink-connectors/flink-hbase/src/test/java/org/apache/flink/addons/hbase/HBaseConnectorITCase.java
+++ b/flink-connectors/flink-hbase/src/test/java/org/apache/flink/addons/hbase/HBaseConnectorITCase.java
@@ -28,7 +28,6 @@ import org.apache.flink.api.java.tuple.Tuple1;
import org.apache.flink.api.java.typeutils.RowTypeInfo;
import org.apache.flink.streaming.api.datastream.DataStream;
import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;
-import org.apache.flink.table.api.EnvironmentSettings;
import org.apache.flink.table.api.Table;
import org.apache.flink.table.api.TableConfig;
import org.apache.flink.table.api.TableEnvironment;
@@ -563,9 +562,7 @@ public class HBaseConnectorITCase extends HBaseTestBase {
CollectTableSink<Row> configuredSink = (CollectTableSink<Row>) sink.configure(
schema.getFieldNames(), types.toArray(new TypeInformation[0]));
return JavaScalaConversionUtil.toJava(
- BatchTableEnvUtil.collect(
- t.getTableEnvironment(), table, configuredSink, Option.apply("JOB"),
- EnvironmentSettings.DEFAULT_BUILTIN_CATALOG, EnvironmentSettings.DEFAULT_BUILTIN_DATABASE));
+ BatchTableEnvUtil.collect(t.getTableEnvironment(), table, configuredSink, Option.apply("JOB")));
}
}