Apache Flink TableEnvironment 中的方法问题

Question

我尝试开始使用flink。但是编码的时候出现了问题

 EnvironmentSettings settings = EnvironmentSettings
            .newInstance()
            .inStreamingMode()
            //.inBatchMode()
            .build();
    TableEnvironment tEnv =  TableEnvironment.create(settings); 
    tEnv.executeSql(""); #This gets me error can't resolve executesql 
    TableResult result =tEnv.executeSql(""); #This will work 

我首先想到的是因为这个方法有一个返回类型，所以我们应该给它赋值。但如果我使用返回类型为 void 的东西，问题仍然是一样的

Answer 1

我不确定你的问题到底是什么，但如果你的 SQL 查询不包含任何内容 (

""

)，请不要对空结果或错误感到惊讶。

应该是这样的：

tEnv.executeSql("SELECT * FROM yourTableName")

看这个例子 -> 链接

阅读一些文档它可能会有所帮助