Flink-Sql执行所需依赖2.0v

Flink-Sql执行所需依赖2.0v

哈哈哈，你永远不知道回踩多少坑啊！！！
改天吧报错信息总结一下
这边这篇依赖相对挺全了，好歹能直接看出效果了

    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();

我是可以查出来结果的，希望对大家有所帮助。