开发者好:
               目前想把flink-sql 建表的操作集成到我们自己的平台中,但是发现一个比较尴尬的现象,如果使用Table api 
,应用中只有create 语句的话,那么应用执行会报错,报没有定义算子:The main method caused an error: No 
operators defined in streaming topology. Cannot generate StreamGraph. 
但是,这个表却创建成功了,代码如下:


        final StreamExecutionEnvironment env = 
StreamExecutionEnvironment.getExecutionEnvironment();
        EnvironmentSettings bsSettings = 
EnvironmentSettings.newInstance().useBlinkPlanner().inStreamingMode().build();
        env.setRestartStrategy(RestartStrategies.fixedDelayRestart(MAX_RESTART, 
Time.of(DURING_RESTART, TimeUnit.SECONDS)));
        env.enableCheckpointing(CHECKPOINT_INTERVAL);
        StreamTableEnvironment tableEnv = 
StreamTableEnvironment.create(env,bsSettings);
        Catalog catalog = new 
HiveCatalog(CATALOG_NAME,DEFAULTDATABASE,HIVECONFDIR);
        tableEnv.registerCatalog(CATALOG_NAME,catalog);
        tableEnv.useCatalog("myhive");
        tableEnv.executeSql("create table .....");
        tableEnv.execute("test-job");


加上目前flink-sql 没有show create table 功能,在hive中的元数据没法把已经建的表很好的管理,所以想集成到我们自己的元数据管理平台中


想问下各位大佬,如果只有建表操作,有没有对应的API,单独调用flink-sql 的建表操作 ,上述操作除非加个insert 
操作就不报错,但是只是为了建表,加个insert也不行
各位的元数据管理都是咋实现的呢?

回复