[jira] [Created] (FLINK-19447) HBaseConnectorITCase.HBaseTestingClusterAutoStarter failed with "Master not initialized after 200000ms"

Dian Fu created FLINK-19447: --- Summary: HBaseConnectorITCase.HBaseTestingClusterAutoStarter failed with "Master not initialized after 20ms" Key: FLINK-19447 URL: https://issues.apache.org/jira/browse/FLINK-19447

[jira] [Created] (FLINK-19446) canal-json has a situation that -U and +U are equal, when updating the null field to be non-null

Zhengchao Shi created FLINK-19446: - Summary: canal-json has a situation that -U and +U are equal, when updating the null field to be non-null Key: FLINK-19446 URL: https://issues.apache.org/jira/browse/FLINK-19446

[jira] [Created] (FLINK-19445) Several tests for HBase connector 1.4 failed with "NoSuchMethodError: com.google.common.base.Preconditions.checkArgument(ZLjava/lang/String;Ljava/lang/Object;)V"

Dian Fu created FLINK-19445: --- Summary: Several tests for HBase connector 1.4 failed with "NoSuchMethodError: com.google.common.base.Preconditions.checkArgument(ZLjava/lang/String;Ljava/lang/Object;)V" Key: FLINK-19445

Re: [DISCUSS] FLIP-144: Native Kubernetes HA for Flink

Hi Till, thanks for your valuable feedback. 1. Yes, leader election and storing leader information will use a same ConfigMap. When a contender successfully performs a versioned annotation update operation to the ConfigMap, it means that it has been elected as the leader. And it will write the lead

[jira] [Created] (FLINK-19444) flink 1.11 sql group by tumble Window aggregate can only be defined over a time attribute column, but TIMESTAMP(3) encountered

panxiaohu created FLINK-19444: - Summary: flink 1.11 sql group by tumble Window aggregate can only be defined over a time attribute column, but TIMESTAMP(3) encountered Key: FLINK-19444 URL: https://issues.apache.org/j

Re: [VOTE] FLIP-143: Unified Sink API

+1 (binding) Best, Jingsong On Mon, Sep 28, 2020 at 3:21 AM Kostas Kloudas wrote: > +1 (binding) > > @Steven Wu I think there will be opportunities to fine tune the API > during the implementation. > > Cheers, > Kostas > > On Sun, Sep 27, 2020 at 7:56 PM Steven Wu wrote: > > > > +1 (non-bindin

[jira] [Created] (FLINK-19443) runtime function 'splitIndex'

mytang0 created FLINK-19443: --- Summary: runtime function 'splitIndex' Key: FLINK-19443 URL: https://issues.apache.org/jira/browse/FLINK-19443 Project: Flink Issue Type: Bug Components: Tab

CheckpointedFunction initialization during checkpoint

Hey all, I've been trying to debug a job recovery performance issue and I'm noticing some interesting events in the timeline that seem unexpected to me. Here's a brief outline of the first checkpoint following a job restart: 1. All tasks are deployed and transition into the RUNNING state. 2. I se

Need help in setting up flink 1.10

Hi Team, We are using flink 1.7 currently in prod. We want to move to latest release and trying 1.10. We are using google storage for our checkpoints. In these release we need Hadoop to the integrated from our side. So following this link

How to clean up resources in a UDF?

Hi team, I'm building a UDF by implementing AbstractRichFunction, where I want to do some resource cleanup per input element when the processing result is committed. I can perform such cleanup in streaming by implementing *CheckpointListener.notifyCheckpointComplete() *but it seems like there is n

Re: [VOTE] FLIP-136: Improve interoperability between DataStream and Table API

+1 (binding) Thanks, Xingcan On Thu, Sep 24, 2020 at 4:52 AM Jark Wu wrote: > +1 (binding) > > Best, > Jark > > On Thu, 24 Sep 2020 at 16:22, Jingsong Li wrote: > > > +1 (binding) > > > > Best, > > Jingsong > > > > On Thu, Sep 24, 2020 at 4:18 PM Kurt Young wrote: > > > > > +1 (binding) > > >

Re:Apply for permission of jira contributor

Hi Billy xie： Welcome to Apache Flink! Apache Flink no needs to open jira permission. If you needed, you can open a issue, and Committer will assgin it to you. Best, Hailong Wang 在 2020-09-28 08:04:39，"Xie Billy" 写道： >Hi Guys, > >I want to contribute to Apache Flink. >Would you pl

[jira] [Created] (FLINK-19442) Unaligned checkpoints 1.1

Arvid Heise created FLINK-19442: --- Summary: Unaligned checkpoints 1.1 Key: FLINK-19442 URL: https://issues.apache.org/jira/browse/FLINK-19442 Project: Flink Issue Type: Bug Reporter:

Re: [DISCUSS] FLIP-144: Native Kubernetes HA for Flink

Thanks for creating this FLIP Yang Wang. I believe that many of our users will like a ZooKeeper-less HA setup. +1 for not separating the leader information and the leader election if possible. Maybe it is even possible that the contender writes his leader information directly when trying to obtain

[jira] [Created] (FLINK-19441) Performance regression on 24.09.2020

Arvid Heise created FLINK-19441: --- Summary: Performance regression on 24.09.2020 Key: FLINK-19441 URL: https://issues.apache.org/jira/browse/FLINK-19441 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-19440) Performance regression on 15.09.2020

Piotr Nowojski created FLINK-19440: -- Summary: Performance regression on 15.09.2020 Key: FLINK-19440 URL: https://issues.apache.org/jira/browse/FLINK-19440 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-19439) Performance regression on 24.09.2020

Piotr Nowojski created FLINK-19439: -- Summary: Performance regression on 24.09.2020 Key: FLINK-19439 URL: https://issues.apache.org/jira/browse/FLINK-19439 Project: Flink Issue Type: Bug

Re: .ORC file reading from Apache Flink +SCALA

Hi, Ajay. *Note:* in the future, please send this type of questions to the user mailing list instead (u...@flink.apache.org)! Which API and Flink version are you using? The documentation/JavaDocs have information on how to read Orc files (and other bulk-encoded formats) using the DataStream API [

Re: Apply for permission of jira contributor

Hi, Xie. You no longer need to request permission to contribute to Flink [1], and can directly comment on the issue you'd like to contribute to. Please check the contribution guide for more information on the process [2]. Marta [1] http://apache-flink-mailing-list-archive.1008284.n3.nabble.com/