??
restorerestore??
error
-- --
??: "Benchao Li"
周五 下午4:02写道：
> 各位大佬有遇到过类似问题吗？
>
>
>
>
> -- 原始邮件 --
> 发件人: "star"<3149768...@qq.com>;
> 发送时间: 2020年6月5日(星期五) 上午10:40
> 收件人: "user-zh@flink.apache.org"
> 主题: 回复：flink1.9 Sql 注册的中间临时表不自动存state的吗？
>
&g
-- --
??: "star"<3149768...@qq.com>;
: 2020??6??5??(??) 10:40
??: "user-zh@flink.apache.org"
??
-- --
??: "zhiyezou"<1530130...@qq.com>;
: 2020??6??5??(??) 10:31
??: "user-zh"
Hi
??TTL
-- --
??: "star"<3149768...@qq.com>;
: 2020??6??5??(??) 10:22
??: "user-zh@flink.apache.org"
?? flink 1.9??blink planner
?? ?? id
hbasemonthtable rowkey??month+city
?? city ??hbasetotalTable ??rowkey?? city
18?? restore??ck??
???
是的，是这个问题，发现包打在胖包里面了，但是找不到，把包放在flink lib 目录下就好了，很奇怪
> 在 2019年9月11日，上午9:35，Dian Fu 写道：
>
> 看你的报错，Kafka010TableSourceSinkFactory不在classpath里，需要把kafka
> connector的jar（0.10需要依赖flink-connector-kafka-0.10_2.11或者flink-connector-kafka-0.10_2.12）放到依赖里。
>
>
>> 在 2019年9月10日，下午12:31，越张 写道：
>>
>> 代码:
>>
看你的报错，Kafka010TableSourceSinkFactory不在classpath里，需要把kafka
connector的jar（0.10需要依赖flink-connector-kafka-0.10_2.11或者flink-connector-kafka-0.10_2.12）放到依赖里。
> 在 2019年9月10日，下午12:31，越张 写道：
>
> 代码:
> EnvironmentSettings bsSettings =
> EnvironmentSettings.newInstance().useBlinkPlanner().inStreamingMod
kafka??kafka??group
-- --
??:
代码:
EnvironmentSettings bsSettings =
EnvironmentSettings.newInstance().useBlinkPlanner().inStreamingMode().build();
StreamExecutionEnvironment streamEnv =
StreamExecutionEnvironment.getExecutionEnvironment();
TableEnvironment tableEnv = StreamTableEnvironment.create(streamEnv,
bsSettings);
tabl
10 matches
Mail list logo
