flink遇到的问题
·
1.测试flink sql的时候
Exception in thread "main" org.apache.flink.table.api.TableException: Failed to execute sql
Caused by: java.lang.IllegalStateException: No ExecutorFactory found to execute the application.
解决办法 添加flink-clients jar
<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-clients_2.11</artifactId>
<version>1.14.4</version>
</dependency>
2.Too many fields referenced from an atomic type.
没有无参构造器,加上即可。
3. org.apache.orc.TypeDescription.fromString(Ljava/lang/String;)Lorg/apache/orc/TypeDescription;
这个原因是 hive-exec 2.1.1-cdh6.3.2 中TypeDescription 没有from方法,要使用hive.3.1版本的才有

---慢慢更新
更多推荐


所有评论(0)