?????? flink-1.10.0 hive-1.2.1 No operators defined in streaming topology

[kcz]

?? ?? 




----
??:"Benchao Li"

Re: flink-1.10.0 hive-1.2.1 No operators defined in streaming topology

[Benchao Li]

我不是特别确定，但是看起来跟这两行代码有关系：
 List 于2020年5月29日周五 下午3:48写道：

> 代码如下：这是error提示：Exception in thread "main" java.lang.IllegalStateException:
> No operators defined in streaming topology. Cannot execute其实insert成功了，去hive
> cli确认过，select也查了数据，为什么还是提示我没有算子被定义呢？我需要batch table吗 EnvironmentSettings
> settings =
> EnvironmentSettings.newInstance().useBlinkPlanner().inBatchMode().build();
>  TableEnvironment tableEnv = TableEnvironment.create(settings);
>
>  String name= "myhive";
>  String defaultDatabase = "situation";
>  String hiveConfDir = "/load/data/hive/hive-conf"; // a local path
>  String version = "1.2.1";
>  String CATALOG_NAME = "myhive";
>
>  HiveCatalog hiveCatalog = new HiveCatalog(name, defaultDatabase,
> hiveConfDir, version);
>  hiveCatalog.open();
>  tableEnv.registerCatalog(CATALOG_NAME, hiveCatalog);
>
>  Optional  ObjectPath myTablePath = new ObjectPath("situation", "flink_test");
>  System.out.println(myHive.get().getTable(myTablePath).getSchema());
>
>
>  //集成Hive内置函数
> tableEnv.loadModule("hiveModule",new HiveModule(version));
>
>  tableEnv.useCatalog(CATALOG_NAME);
>
>  tableEnv.sqlUpdate("insert into situation.flink_test values (3,'kcz3')");
>  Table table = tableEnv.sqlQuery(" select * from situation.flink_test");
>  List  System.out.println(rowList);
>
>
>  tableEnv.execute("test");



-- 

Best,
Benchao Li

flink-1.10.0 hive-1.2.1 No operators defined in streaming topology

[??????????????]

??error??Exception in thread "main" 
java.lang.IllegalStateException: No operators defined in streaming topology. 
Cannot executeinsert??hive 
cliselectbatch 
table?? EnvironmentSettings settings = 
EnvironmentSettings.newInstance().useBlinkPlanner().inBatchMode().build();
 TableEnvironment tableEnv = TableEnvironment.create(settings);

 String name= "myhive";
 String defaultDatabase = "situation";
 String hiveConfDir = "/load/data/hive/hive-conf"; // a local path
 String version = "1.2.1";
 String CATALOG_NAME = "myhive";

 HiveCatalog hiveCatalog = new HiveCatalog(name, defaultDatabase, hiveConfDir, 
version);
 hiveCatalog.open();
 tableEnv.registerCatalog(CATALOG_NAME, hiveCatalog);

 Optional