[jira] [Created] (FLINK-20953) canal-json.table.include Supports regular or wildcard characters

2021-01-12 Thread wangfei (Jira)
wangfei created FLINK-20953: --- Summary: canal-json.table.include Supports regular or wildcard characters Key: FLINK-20953 URL: https://issues.apache.org/jira/browse/FLINK-20953 Project: Flink Issue

Re: [DISCUSS] Releasing Apache Flink 1.10.3

2021-01-12 Thread Xintong Song
Thanks for bringing this up, Matthias. Per the "Update Policy for old releases" [1], normally we do not release 1.10.x after 1.12.0 is released. However, the policy also says that we are "open to discussing bugfix releases for even older versions". In this case, I'm +1 for releasing 1.10.3, for t

Re: [ANNOUNCE] Welcome Danny Cranmer as a new Apache Flink Committer

2021-01-12 Thread Yun Gao
Congratulations, Danny! Best, Yun -- From:Xintong Song Send Time:2021 Jan. 13 (Wed.) 15:29 To:dev Subject:Re: [ANNOUNCE] Welcome Danny Cranmer as a new Apache Flink Committer Congratulations, Danny. Welcome aboard. Thank you~

Re: [ANNOUNCE] Welcome Danny Cranmer as a new Apache Flink Committer

2021-01-12 Thread Xintong Song
Congratulations, Danny. Welcome aboard. Thank you~ Xintong Song On Wed, Jan 13, 2021 at 3:25 PM Yun Tang wrote: > Congratulations Danny! > > Best > Yun Tang > > From: Jingsong Li > Sent: Wednesday, January 13, 2021 14:23 > To: dev > Subject: Re: [ANNOUNCE]

Re: [ANNOUNCE] Welcome Danny Cranmer as a new Apache Flink Committer

2021-01-12 Thread Yun Tang
Congratulations Danny! Best Yun Tang From: Jingsong Li Sent: Wednesday, January 13, 2021 14:23 To: dev Subject: Re: [ANNOUNCE] Welcome Danny Cranmer as a new Apache Flink Committer Congrats, Danny! Best, Jingsong On Tue, Jan 12, 2021 at 7:55 PM Leonard Xu wro

Re: Idea import Flink source code

2021-01-12 Thread Matthias Pohl
Hi, you might want to move these kinds of questions into the u...@flink.apache.org which is the mailing list for community support questions [1]. Coming back to your question: Is it just me or is the image not accessible? Could you provide a textual description of your problem? Best, Matthias [1

[jira] [Created] (FLINK-20952) Changelog json formats should support inherit options from JSON format

2021-01-12 Thread Jark Wu (Jira)
Jark Wu created FLINK-20952: --- Summary: Changelog json formats should support inherit options from JSON format Key: FLINK-20952 URL: https://issues.apache.org/jira/browse/FLINK-20952 Project: Flink

[jira] [Created] (FLINK-20951) Flink SQL cli queries the partition table with hive as two fields. If the where condition does not specify all the two fields, an exception will occur

2021-01-12 Thread YUJIANBO (Jira)
table is partitioned by two fields:datekey and event I have do this test: (1)First: SELECT vid From table_A WHERE datekey = '20210112' AND event = 'XXX' AND vid = 'aa';(OK) SELECT vid From table_A WHERE datekey = '20210112' AND vid = 'aa&#x

[jira] [Created] (FLINK-20950) SinkITCase.writerAndGlobalCommitterExecuteInStreamingMode test failed with "AssertionError"

2021-01-12 Thread Huang Xingbo (Jira)
Huang Xingbo created FLINK-20950: Summary: SinkITCase.writerAndGlobalCommitterExecuteInStreamingMode test failed with "AssertionError" Key: FLINK-20950 URL: https://issues.apache.org/jira/browse/FLINK-20950

Re: [ANNOUNCE] Welcome Danny Cranmer as a new Apache Flink Committer

2021-01-12 Thread Jingsong Li
Congrats, Danny! Best, Jingsong On Tue, Jan 12, 2021 at 7:55 PM Leonard Xu wrote: > Congratulations Danny! > > Best, > Leonard > > 在 2021年1月12日,19:44,Wei Zhong 写道: > > > > Congratulations Danny! > > > > Best, > > Wei > > > >> 在 2021年1月12日,19:09,hailongwang <18868816...@163.com> 写道: > >> > >> C

[jira] [Created] (FLINK-20949) Separate the implementation of sink nodes

2021-01-12 Thread godfrey he (Jira)
godfrey he created FLINK-20949: -- Summary: Separate the implementation of sink nodes Key: FLINK-20949 URL: https://issues.apache.org/jira/browse/FLINK-20949 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-20948) Separate the implementation of StreamExecDeduplicate

2021-01-12 Thread godfrey he (Jira)
godfrey he created FLINK-20948: -- Summary: Separate the implementation of StreamExecDeduplicate Key: FLINK-20948 URL: https://issues.apache.org/jira/browse/FLINK-20948 Project: Flink Issue Type:

Idea import Flink source code

2021-01-12 Thread penguin.
Hello, When importing the Flink source code into idea, the following error occurred. And several mirrors were configured in the setting file of maven, which did not solve the problem

7UUNA`SE$DZI74Y)S)T)GZB

2021-01-12 Thread penguin.
Hello, When importing the Flink source code into idea, the following error occurred. And several mirrors were configured in the setting file of maven, which did not solve the problem

[jira] [Created] (FLINK-20947) Unable to trigger Hive partition commit when use table sql to write data from Kafka into a Hive table

2021-01-12 Thread Weijia Xu (Jira)
Weijia Xu created FLINK-20947: - Summary: Unable to trigger Hive partition commit when use table sql to write data from Kafka into a Hive table Key: FLINK-20947 URL: https://issues.apache.org/jira/browse/FLINK-20947

[jira] [Created] (FLINK-20946) Optimize Python ValueState Implementation In PyFlink

2021-01-12 Thread Huang Xingbo (Jira)
Huang Xingbo created FLINK-20946: Summary: Optimize Python ValueState Implementation In PyFlink Key: FLINK-20946 URL: https://issues.apache.org/jira/browse/FLINK-20946 Project: Flink Issue Ty

[jira] [Created] (FLINK-20945) flink hive insert heap out of memory

2021-01-12 Thread Bruce GAO (Jira)
Bruce GAO created FLINK-20945: - Summary: flink hive insert heap out of memory Key: FLINK-20945 URL: https://issues.apache.org/jira/browse/FLINK-20945 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-20944) Launching in application mode requesting a ClusterIP rest service type results in an Exception

2021-01-12 Thread Jason Brome (Jira)
Jason Brome created FLINK-20944: --- Summary: Launching in application mode requesting a ClusterIP rest service type results in an Exception Key: FLINK-20944 URL: https://issues.apache.org/jira/browse/FLINK-20944

[jira] [Created] (FLINK-20943) AsyncCheckpointRunnable.cleanup() runs in the main task thread

2021-01-12 Thread Roman Khachatryan (Jira)
Roman Khachatryan created FLINK-20943: - Summary: AsyncCheckpointRunnable.cleanup() runs in the main task thread Key: FLINK-20943 URL: https://issues.apache.org/jira/browse/FLINK-20943 Project: Fli

[DISCUSS] Support obtaining Hive delegation tokens when submitting application to Yarn

2021-01-12 Thread 王 杰
Hi everyone, Currently, Hive delegation token is not obtained when Flink submits the application in Yarn mode using kinit way. The ticket is https://issues.apache.org/jira/browse/FLINK-20714. I'd like to start a discussion about how to support this feature. Maybe we have two options: 1. Using

[jira] [Created] (FLINK-20942) Digest of FLOAT literals throws UnsupportedOperationException

2021-01-12 Thread Timo Walther (Jira)
Timo Walther created FLINK-20942: Summary: Digest of FLOAT literals throws UnsupportedOperationException Key: FLINK-20942 URL: https://issues.apache.org/jira/browse/FLINK-20942 Project: Flink

Re: Compiling flink-runtime module of Flink

2021-01-12 Thread Chesnay Schepler
The fastest way to replace the bits of flink-runtime within flink-dist is to build everything once (via mvn install), and then for each modification in flink-runtime, run mvn install -pl flink-runtime,flink-dist.This will recompile flink-runtime, and repackage flink-dist, but it will use the pr

Compiling flink-runtime module of Flink

2021-01-12 Thread penguin.
Hi, Does anyone know how to compile the Flink runtime module separately ? Is it possible to replace the directory(org.apache.flink.runtime) in the flink-dist.jar with the changed part I changed? It's too slow to compile all at once. thank you! penguin

[jira] [Created] (FLINK-20941) Separate the implementation of StreamExecMatch

2021-01-12 Thread godfrey he (Jira)
godfrey he created FLINK-20941: -- Summary: Separate the implementation of StreamExecMatch Key: FLINK-20941 URL: https://issues.apache.org/jira/browse/FLINK-20941 Project: Flink Issue Type: Sub-ta

Re: [ANNOUNCE] Welcome Danny Cranmer as a new Apache Flink Committer

2021-01-12 Thread Leonard Xu
Congratulations Danny! Best, Leonard > 在 2021年1月12日,19:44,Wei Zhong 写道: > > Congratulations Danny! > > Best, > Wei > >> 在 2021年1月12日,19:09,hailongwang <18868816...@163.com> 写道: >> >> Congratulations Danny! >> >> Best, >> Hailong在 2021-01-12 17:05:31,"Jark Wu" 写道: >>> Congratulations Danny!

Re: [ANNOUNCE] Welcome Danny Cranmer as a new Apache Flink Committer

2021-01-12 Thread Wei Zhong
Congratulations Danny! Best, Wei > 在 2021年1月12日,19:09,hailongwang <18868816...@163.com> 写道: > > Congratulations Danny! > > Best, > Hailong在 2021-01-12 17:05:31,"Jark Wu" 写道: >> Congratulations Danny! >> >> Best, >> Jark >> >> On Tue, 12 Jan 2021 at 17:59, Yangze Guo wrote: >> >>> Congrats,

[DISCUSS] Releasing Apache Flink 1.10.3

2021-01-12 Thread Matthias Pohl
Hi, I'd like to initiate a discussion on releasing Flink 1.10.3. There were a few requests in favor of this already in [1] and [2]. I checked the release-1.10 branch: 55 commits are not released, yet. Some non-released fixes that might be relevant are: - FLINK-20218 [3] - fix "module 'urllib' has

Re:Re: [ANNOUNCE] Welcome Danny Cranmer as a new Apache Flink Committer

2021-01-12 Thread hailongwang
Congratulations Danny! Best, Hailong在 2021-01-12 17:05:31,"Jark Wu" 写道: >Congratulations Danny! > >Best, >Jark > >On Tue, 12 Jan 2021 at 17:59, Yangze Guo wrote: > >> Congrats, Danny! >> >> Best, >> Yangze Guo >> >> On Tue, Jan 12, 2021 at 5:55 PM Xingbo Huang wrote: >> > >> > Congratulations,

Re: [ANNOUNCE] Welcome Danny Cranmer as a new Apache Flink Committer

2021-01-12 Thread Matthias Pohl
Congratulations, Danny. Best, Matthias On Tue, Jan 12, 2021 at 11:05 AM Jark Wu wrote: > Congratulations Danny! > > Best, > Jark > > On Tue, 12 Jan 2021 at 17:59, Yangze Guo wrote: > > > Congrats, Danny! > > > > Best, > > Yangze Guo > > > > On Tue, Jan 12, 2021 at 5:55 PM Xingbo Huang wrote:

[jira] [Created] (FLINK-20940) The LOCALTIME/LOCALTIMSTAMP functions should use session time zone

2021-01-12 Thread Leonard Xu (Jira)
Leonard Xu created FLINK-20940: -- Summary: The LOCALTIME/LOCALTIMSTAMP functions should use session time zone Key: FLINK-20940 URL: https://issues.apache.org/jira/browse/FLINK-20940 Project: Flink

Re: [ANNOUNCE] Welcome Danny Cranmer as a new Apache Flink Committer

2021-01-12 Thread Jark Wu
Congratulations Danny! Best, Jark On Tue, 12 Jan 2021 at 17:59, Yangze Guo wrote: > Congrats, Danny! > > Best, > Yangze Guo > > On Tue, Jan 12, 2021 at 5:55 PM Xingbo Huang wrote: > > > > Congratulations, Danny! > > > > Best, > > Xingbo > > > > Dian Fu 于2021年1月12日周二 下午5:48写道: > > > > > Congra

Re: [ANNOUNCE] Welcome Danny Cranmer as a new Apache Flink Committer

2021-01-12 Thread Yangze Guo
Congrats, Danny! Best, Yangze Guo On Tue, Jan 12, 2021 at 5:55 PM Xingbo Huang wrote: > > Congratulations, Danny! > > Best, > Xingbo > > Dian Fu 于2021年1月12日周二 下午5:48写道: > > > Congratulations, Danny! > > > > Regards, > > Dian > > > > > 在 2021年1月12日,下午5:40,Till Rohrmann 写道: > > > > > > Congrats

Re: [ANNOUNCE] Welcome Danny Cranmer as a new Apache Flink Committer

2021-01-12 Thread Xingbo Huang
Congratulations, Danny! Best, Xingbo Dian Fu 于2021年1月12日周二 下午5:48写道: > Congratulations, Danny! > > Regards, > Dian > > > 在 2021年1月12日,下午5:40,Till Rohrmann 写道: > > > > Congrats and welcome Danny! > > > > Cheers, > > Till > > > > On Tue, Jan 12, 2021 at 10:09 AM Dawid Wysakowicz < > dwysakow...@

Re: [ANNOUNCE] Welcome Danny Cranmer as a new Apache Flink Committer

2021-01-12 Thread Dian Fu
Congratulations, Danny! Regards, Dian > 在 2021年1月12日,下午5:40,Till Rohrmann 写道: > > Congrats and welcome Danny! > > Cheers, > Till > > On Tue, Jan 12, 2021 at 10:09 AM Dawid Wysakowicz > wrote: > >> Congratulations, Danny! >> >> Best, >> >> Dawid >> >> On 12/01/2021 09:52, Paul Lam wrote:

Re: [ANNOUNCE] Welcome Danny Cranmer as a new Apache Flink Committer

2021-01-12 Thread Till Rohrmann
Congrats and welcome Danny! Cheers, Till On Tue, Jan 12, 2021 at 10:09 AM Dawid Wysakowicz wrote: > Congratulations, Danny! > > Best, > > Dawid > > On 12/01/2021 09:52, Paul Lam wrote: > > Congrats, Danny! > > > > Best, > > Paul Lam > > > >> 2021年1月12日 16:48,Tzu-Li (Gordon) Tai 写道: > >> > >> H

[jira] [Created] (FLINK-20939) Missing images in Docker hub

2021-01-12 Thread Damian G (Jira)
Damian G created FLINK-20939: Summary: Missing images in Docker hub Key: FLINK-20939 URL: https://issues.apache.org/jira/browse/FLINK-20939 Project: Flink Issue Type: Wish Components: f

[jira] [Created] (FLINK-20938) Implement Flink's own tencent COS filesystem

2021-01-12 Thread hayden zhou (Jira)
hayden zhou created FLINK-20938: --- Summary: Implement Flink's own tencent COS filesystem Key: FLINK-20938 URL: https://issues.apache.org/jira/browse/FLINK-20938 Project: Flink Issue Type: New Fe

Re: [ANNOUNCE] Welcome Danny Cranmer as a new Apache Flink Committer

2021-01-12 Thread Dawid Wysakowicz
Congratulations, Danny! Best, Dawid On 12/01/2021 09:52, Paul Lam wrote: > Congrats, Danny! > > Best, > Paul Lam > >> 2021年1月12日 16:48,Tzu-Li (Gordon) Tai 写道: >> >> Hi everyone, >> >> I'm very happy to announce that the Flink PMC has accepted Danny Cranmer to >> become a committer of the projec

[jira] [Created] (FLINK-20937) Drop table can fails, when i create a table with "watermark for proctime()" syntax

2021-01-12 Thread wangzq (Jira)
wangzq created FLINK-20937: -- Summary: Drop table can fails, when i create a table with "watermark for proctime()" syntax Key: FLINK-20937 URL: https://issues.apache.org/jira/browse/FLINK-20937 Project: Flink

Re: [ANNOUNCE] Welcome Danny Cranmer as a new Apache Flink Committer

2021-01-12 Thread Paul Lam
Congrats, Danny! Best, Paul Lam > 2021年1月12日 16:48,Tzu-Li (Gordon) Tai 写道: > > Hi everyone, > > I'm very happy to announce that the Flink PMC has accepted Danny Cranmer to > become a committer of the project. > > Danny has been extremely helpful on the mailing lists with answering user > ques

[ANNOUNCE] Welcome Danny Cranmer as a new Apache Flink Committer

2021-01-12 Thread Tzu-Li (Gordon) Tai
Hi everyone, I'm very happy to announce that the Flink PMC has accepted Danny Cranmer to become a committer of the project. Danny has been extremely helpful on the mailing lists with answering user questions on the AWS Kinesis connector, and has driven numerous new features and timely bug fixes f