我试着开始使用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的东西,问题仍然是一样的
1条答案
按热度按时间oug3syen1#
我不知道你的问题到底是什么,但是如果你的SQL查询不包含任何内容(
""
),那么得到空结果或错误也不必感到惊讶。它应该是这样的:
字符串
例如:link
读一些documentation它可以帮助