[jira] [Created] (FLINK-14948) Implement shutDownCluster for MiniClusterClient

Zili Chen created FLINK-14948: - Summary: Implement shutDownCluster for MiniClusterClient Key: FLINK-14948 URL: https://issues.apache.org/jira/browse/FLINK-14948 Project: Flink Issue Type: Improve

[jira] [Created] (FLINK-14949) Task cancellation can be stuck against out-of-thread error

Hwanju Kim created FLINK-14949: -- Summary: Task cancellation can be stuck against out-of-thread error Key: FLINK-14949 URL: https://issues.apache.org/jira/browse/FLINK-14949 Project: Flink Issue

[jira] [Created] (FLINK-14947) Implement LocalExecutor as new Executor interface

Zili Chen created FLINK-14947: - Summary: Implement LocalExecutor as new Executor interface Key: FLINK-14947 URL: https://issues.apache.org/jira/browse/FLINK-14947 Project: Flink Issue Type: Sub-t

[jira] [Created] (FLINK-14946) Retraction infer would result in bad plan under corner case in blink planner

Jing Zhang created FLINK-14946: -- Summary: Retraction infer would result in bad plan under corner case in blink planner Key: FLINK-14946 URL: https://issues.apache.org/jira/browse/FLINK-14946 Project: Fli

Re: [VOTE] FLIP-86: Improve Connector Properties

Thanks all for the voting. I'm closing the vote now. So far, the vote received: * +1 votes (5 binding, 3 non-binding): - Dawid (binding) - Terry Wang - Jark Wu (binding) - Jingsong Li - Aljoscha (binding) - Kurt Young (binding) - Xuefu - Timo (binding) * 0/-1 votes: none Thereby, the com

[jira] [Created] (FLINK-14945) Simplify some code in runtime

clay created FLINK-14945: Summary: Simplify some code in runtime Key: FLINK-14945 URL: https://issues.apache.org/jira/browse/FLINK-14945 Project: Flink Issue Type: Task Components: Runtime

Re: [DISCUSS] PyFlink User-Defined Function Resource Management

Thanks for your votes and feedbacks. I have discussed with @Zhu Zhu offline and also on the design doc. It seems that we have reached consensus on the design. I would bring up the VOTE if there is no other feedbacks. Thanks, Dian > 在 2019年11月22日，下午2:51，Hequn Cheng 写道： > > Thanks a lot for pu

Re: [VOTE] Setup a secur...@flink.apache.org mailing list

NOTE: Only PMC votes is binding. Thanks for sharing your thoughts. I also think that this doesn't fall into any of the existing categories listed in the bylaws. Maybe we could do some improvements for the bylaws. This is not codebase change as Robert mentioned and it's related to how to manage

Re: [VOTE] Setup a secur...@flink.apache.org mailing list

I also think that we should only count PMC votes. This ML is to improve the security mechanism for Flink. Of course we don't expect to use this ML often. I hope that it's perfect if this ML is never used. However, the Flink community is growing rapidly, it's better to make our security mechanism

Re: [DISCUSS] Remove old WebUI

+1 to drop the old UI. Best, tison. vino yang 于2019年11月25日周一 下午8:28写道： > +1 > > Best, > Vino > > Zhu Zhu 于2019年11月25日周一 下午2:06写道： > > > +1 > > > > Thanks, > > Zhu Zhu > > > > Dian Fu 于2019年11月25日周一 上午11:09写道： > > > > > +1 to drop the old UI. > > > > > > > 在 2019年11月25日，上午10:59，Zhenghua Gao

Re:[DISCUSS] Multi-topics consuming from KafkaTableSource

If the data formats of the Multi-topics are different, what do you plan to do? On 11/26/2019 08:53??leohttps://issues.apache.org/jira/browse/FLINK-14729 Best, Leo

[jira] [Created] (FLINK-14944) Unstable test FlinkFnExecutionSyncTests.test_flink_fn_execution_pb2_synced

Dian Fu created FLINK-14944: --- Summary: Unstable test FlinkFnExecutionSyncTests.test_flink_fn_execution_pb2_synced Key: FLINK-14944 URL: https://issues.apache.org/jira/browse/FLINK-14944 Project: Flink

Re: [DISCUSS] Releasing Flink 1.8.3

Hi, @Ufuk Celebi Hi, we are very close now. There is one issue( FLINK-13995 ) left that I want to double-check with you guys. Once this is done, we can create the first RC. I already have some minor comments in the PR

[DISCUSS] Multi-topics consuming from KafkaTableSource

Hi, all. I want to propose an improvement of KafkaTableSource which can consume multiple topics at the same time. Here is proposal, https://issues.apache.org/jira/browse/FLINK-14729 Best, Leo

[jira] [Created] (FLINK-14943) make callback and related members protected so that user can override the callback handling

Steven Zhen Wu created FLINK-14943: -- Summary: make callback and related members protected so that user can override the callback handling Key: FLINK-14943 URL: https://issues.apache.org/jira/browse/FLINK-14943

Re: set job level TTL

Hi Chen There existed several problems currently: 1. State TTL cannot be applied to Flink SQL 2. No job-level state TTL 3. Window state should not be limited to TTL if existed a job-level state If your goal is to achieve #2, we could introduce a configuration via flink-conf.yaml so that we coul

[jira] [Created] (FLINK-14942) State Processing API: add an option to make deep copy

Jun Qin created FLINK-14942: --- Summary: State Processing API: add an option to make deep copy Key: FLINK-14942 URL: https://issues.apache.org/jira/browse/FLINK-14942 Project: Flink Issue Type: Impro

Re: [VOTE] Setup a secur...@flink.apache.org mailing list

I agree that we are only counting PMC votes (because this decision goes beyond the codebase) I'm undecided what to vote :) I'm not against setting up a new mailing list, but I also don't think the benefit (having a private list with PMC + committers) is enough to justify the work involved. As far

Re: [DISCUSS] Remove old WebUI

+1 Best, Vino Zhu Zhu 于2019年11月25日周一 下午2:06写道： > +1 > > Thanks, > Zhu Zhu > > Dian Fu 于2019年11月25日周一 上午11:09写道： > > > +1 to drop the old UI. > > > > > 在 2019年11月25日，上午10:59，Zhenghua Gao 写道： > > > > > > +1 to drop the old one. > > > > > > *Best Regards,* > > > *Zhenghua Gao* > > > > > > > > >

[jira] [Created] (FLINK-14941) The AbstractTableInputFormat#nextRecord in hbase connector will handle the same rowkey twice once encountered any exception

Zheng Hu created FLINK-14941: Summary: The AbstractTableInputFormat#nextRecord in hbase connector will handle the same rowkey twice once encountered any exception Key: FLINK-14941 URL: https://issues.apache.org/jira/b

Re: [DISCUSS] Releasing Flink 1.8.3

@Hequn: flink-shaded:9.0 is available in Maven central now. I think you can go ahead and create the first RC. :-) On Mon, Nov 25, 2019 at 7:47 AM Zhu Zhu wrote: > Hi Hequn, > > Looks we are not able to merge fix of FLINK-14735 to 1.8 very soon. > Given that this fix is for batch job only and bat

[jira] [Created] (FLINK-14940) Travis build passes despite Test failures

Gary Yao created FLINK-14940: Summary: Travis build passes despite Test failures Key: FLINK-14940 URL: https://issues.apache.org/jira/browse/FLINK-14940 Project: Flink Issue Type: Bug C

[jira] [Created] (FLINK-14939) StreamingKafkaITCase fails due to distDir property not being set

Gary Yao created FLINK-14939: Summary: StreamingKafkaITCase fails due to distDir property not being set Key: FLINK-14939 URL: https://issues.apache.org/jira/browse/FLINK-14939 Project: Flink Iss

[jira] [Created] (FLINK-14938) Flink elasticsearch failure handler re-add indexrequest causes ConcurrentModificationException

Shengnan YU created FLINK-14938: --- Summary: Flink elasticsearch failure handler re-add indexrequest causes ConcurrentModificationException Key: FLINK-14938 URL: https://issues.apache.org/jira/browse/FLINK-14938

[jira] [Created] (FLINK-14937) Flink WebUI could not display

Yang Wang created FLINK-14937: - Summary: Flink WebUI could not display Key: FLINK-14937 URL: https://issues.apache.org/jira/browse/FLINK-14937 Project: Flink Issue Type: Bug Components:

Re: [VOTE] Setup a secur...@flink.apache.org mailing list

Hi all, What is the voting scheme for it? I am not sure if it falls into any of the categories we have listed in our bylaws. Are committers votes binding or just PMCs'? (Personally I think it should be PMCs') Is this a binding vote or just an informational vote? Best, Dawid On 25/11/2019 07:34,