Re: 关于如何贡献社区

@Kyle Zhang 你需要在jira上说明自己的看法或者修复方案 然后commiter会分配给你 Best Regards jinhai...@gmail.com > 2020年9月27日 下午5:43，Kyle Zhang 写道： > > Hi， > 我在jira上建了一个issue(FLINK-19433 > > )，后续如何跟进呢，是否要有commiter把任务指配给我？ > > Best regards

Re: 自定义具有Exactly-Once语义的sink

FlinkKafkaProducer、StreamingFileSink的实现都支持Exactly-Once，可以研究下 Best Regards jinhai...@gmail.com > 2020年4月15日 上午11:00，阿华田 写道： > > 如果自定义具有Exactly-Once语义的sink，继承TwoPhaseCommitSinkFunction，怎么确保真正的Exactly-Once，大佬们有已经上线使用的案例demo吗？ > | | > 王志华 > | > | > a15733178...@163.com > | > 签名由网易邮箱大师定制 >

Re: ddl es 报错

优秀！可以提个improve issue Best Regards jinhai...@gmail.com > 2020年3月25日 下午1:40，zhisheng 写道： > > hi，Leonar Xu > > 官方 ES DDL 现在不支持填写 ES 集群的用户名和密码，我现在在公司已经做了扩展，加了这个功能，请问社区是否需要这个功能？我该怎么贡献呢？ > > 效果如图：http://zhisheng-blog.oss-cn-hangzhou.aliyuncs.com/2020-03-25-053948.png > > Best Wishes！ > >

Re: ddl

Page on “User-defined Sources & Sinks”. For flink 1.10: https://ci.apache.org/projects/flink/flink-docs-release-1.10/dev/table/sourceSinks.html Best Regards jinhai...@gmail.com > 2020年3月13日 下午7:17，王志华

Re: [DISCUSS] FLIP-115: Filesystem connector in Table

Thanks for FLIP-115. It is really useful feature for platform developers who manage hundreds of Flink to Hive jobs in production. I think we need add 'connector.sink.username' for UserGroupInformation when data is written to HDFS 在 2020/3/13 下午3:33，“Jingsong Li” 写入: Hi everyone,

Re: [DISCUSS] FLIP-115: Filesystem connector in Table

Thanks for FLIP-115. It is really useful feature for platform developers who manage hundreds of Flink to Hive jobs in production. I think we need add 'connector.sink.username' for UserGroupInformation when data is written to HDFS Jingsong Li 于2020年3月13日周五 下午3:33写道： > Hi everyone, > > I'd like

Re: flinkSQL join 表的历史信息保存在哪里保存多久

应该是withIdleStateRetentionTime参数的配置时间。具体文档：https://ci.apache.org/projects/flink/flink-docs-release-1.10/dev/table/streaming/query_configuration.html#idle-state-retention-time 在 2020/3/12 下午12:37，“wangl...@geekplus.com.cn” 写入: 两个从 kafka 创建的表： tableA： key valueA tableB： key