哈哈哈,你永远不知道回踩多少坑啊!!!
改天吧报错信息总结一下
这边这篇依赖相对挺全了,好歹能直接看出效果了
4.0.0 org.example bhfae_flink_sql 1.0-SNAPSHOT 8 8 org.apache.maven.plugins maven-compiler-plugin 8 8 org.apache.flink flink-table-api-java-bridge_2.11 1.11.2 org.apache.flink flink-table-planner_2.11 1.11.2 org.apache.flink flink-table-planner-blink_2.11 1.11.2 org.apache.flink flink-json 1.11.0 com.fasterxml.jackson.core jackson-databind 2.9.8 joda-time joda-time 2.10.1 org.apache.flink flink-clients_2.11 1.11.2
我的测试代码:
StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
EnvironmentSettings settings = EnvironmentSettings.newInstance().useBlinkPlanner().inStreamingMode().build();
StreamTableEnvironment tableEnv = StreamTableEnvironment.create(env, settings);
String sql="CREATE TABLE Orders (`business_time` STRING, `prod_name` STRING, `product_type` STRING,`vol` Double,`batch_time` TIMESTAMP)WITH ( 'connector' = 'filesystem','path' = 'D:\杂文件/sql.txt','format' = 'json')";
TableResult tableResult = tableEnv.executeSql(sql);
String sql2="SELECt business_time,prod_name FROM Orders ";
Table result = tableEnv.sqlQuery(sql2);
result.execute().print();
我是可以查出来结果的,希望对大家有所帮助。



