而且，官网connector中的kafka的flink-sql-connector-kafka_2.11-1.11.2.jar是干嘛用的。 我发现我自己sql-client方式创建kafka流失表，以及查询等都用不到这个依赖。 用的是：flink-connector-kafka_2.12-1.10.0.jar flink-connector-kafka-base_2.12-1.10.0.jar .
赵一旦 <[email protected]> 于2020年9月24日周四 下午3:08写道： > 通过zeppelin写sql，之前sql-client可行的sql总是报错。 > > zeppelin配置的FLINK_HOME的目录中lib下是有相关包的，但远程remote集群没有。 > 之前sql-client方式是基于-l方式指定的。 > > zeppelin情况下，貌似有个flink.execution.packages，但是并没说明这个指定的包去哪找的？是zeppelin配置的FLINK_HOME中的lib嘛？我lib中有包，但还是报错。 > > > >
