table ??join?? ??
baiyg25...@hundsun.com
492341344
?? 2019-04-02 14:42
user-zh
?? ??:
??blink
sql
??
??AB??AC??
baiyg25...@hundsun.com
IORI
?? 2019-03-26 09:46
user-zh
?? flink
AB
是不是跟这个访问控制有关？
high-availability.zookeeper.client.acl: open
baiyg25...@hundsun.com
发件人： Han Xiao
发送时间： 2019-03-26 09:33
收件人： user-zh@flink.apache.org
主题： Re: Re: flink ha模式进程hang！！！
Hi，早上好，谢谢您的回复，以下是我的配置项及参数：
flink-conf.yaml
common：
jobmanager.rpc.address: test10
jobmanager.rpc.port: 6123
大家好！
有没有伙伴对 blink 中 flink-table 模块下的 UpsertStreamTableSink , BatchTableSink
这两个接口比较熟悉？或者对TableSink这块处理原理比较熟悉？我想实现这两个接口，以实现JDBC更新功能，自己看源码只能看懂表面，希望熟悉的伙伴能给些指导。。。
baiyg25...@hundsun.com
y 调用时该怎么赋值？
@Override
public void setKeyFields(String[] keys) {}
@Override
public void setIsAppendOnly(Boolean isAppendOnly){}
baiyg25...@hundsun.com
大家好！
可爱的flink贡献者，能不能增加个JDBC Sink
更新策略接口？目前只有增量插入，实际中对更新需求还是非常普遍的，目前要想支持更新，只能自己修改源码增加，这样感觉不是很友好。棒棒的贡献者，期待JDBC
Sink 更新策略接口的出现。
基于flink工作的伙伴们，如果有谁实现了JDBC Sink 更新策略接口，希望能分享下代码，感谢！
baiyg25...@hundsun.com
savepoint
??savepoints
baiyg25...@hundsun.com
?? 2019-03-27 11:03
user-zh
?? ?? flink
savepointssavepoints
baiyg25...@hundsun.com
?? 2019-03-27 10:48
user-zh
?? flink savepoints ?? checkpoints??
??flink savepoints ??
checkpoints
感谢！可以了。
baiyg25...@hundsun.com
发件人： Shi Quan
发送时间： 2019-05-20 17:28
收件人： user-zh@flink.apache.org
主题： RE: flink Table API Date 类型 是否支持 ？
可以用SqlTimeTypeInfo.DATE 。
在FlinkTypeFactory typeInfoToSqlTypeName中的类型转换关系：
// temporal types
case SqlTimeTypeInfo.DATE => D
l.java:657)
at
org.apache.flink.table.calcite.FlinkPlannerImpl.validate(FlinkPlannerImpl.scala:99)
... 4 more
baiyg25...@hundsun.com
大家好！
有没有哪位伙伴知道：
flink 怎么向 StreamExecutionEnvironment 或 TableEnvironment 上下文中注册全局变量，在sql
或 算子中以 ${name] 形式或其它形式获取？
目前在百度、官网API上没有找到相关信息。
baiyg25...@hundsun.com
退订
退订
13 matches
Mail list logo
