Re: [ANNOUNCE] Apache Flink 1.12.0 released

2020-12-10 Thread Matthias Pohl
I agree - thanks for managing the release, Dian & Robert! +1 Matthias On Fri, Dec 11, 2020 at 7:58 AM Yu Li wrote: > Hurray! Thanks everyone who contributed and thanks Robert and Dian for > being our release managers! > > Best Regards, > Yu > > > On Fri, 11 Dec 2020 at 14:56, Congxian Qiu

[jira] [Created] (FLINK-20572) HiveCatalog should be a standalone module

2020-12-10 Thread Rui Li (Jira)
Rui Li created FLINK-20572: -- Summary: HiveCatalog should be a standalone module Key: FLINK-20572 URL: https://issues.apache.org/jira/browse/FLINK-20572 Project: Flink Issue Type: Improvement

Re: [ANNOUNCE] Apache Flink 1.12.0 released

2020-12-10 Thread Yu Li
Hurray! Thanks everyone who contributed and thanks Robert and Dian for being our release managers! Best Regards, Yu On Fri, 11 Dec 2020 at 14:56, Congxian Qiu wrote: > Thanks Dian and Robert for the great work as release manager, and everyone > who makes this release possible. > > Best, >

Re: [ANNOUNCE] Apache Flink 1.12.0 released

2020-12-10 Thread Congxian Qiu
Thanks Dian and Robert for the great work as release manager, and everyone who makes this release possible. Best, Congxian Xintong Song 于2020年12月11日周五 下午1:49写道: > Congratulations~! Thanks Robert, Dian and everyone. > > Thank you~ > > Xintong Song > > > > On Thu, Dec 10, 2020 at 11:23 PM

[jira] [Created] (FLINK-20571) Add dynamic open/close LatencyMarksEmitter to support online debug and monitoring

2020-12-10 Thread zlzhang0122 (Jira)
zlzhang0122 created FLINK-20571: --- Summary: Add dynamic open/close LatencyMarksEmitter to support online debug and monitoring Key: FLINK-20571 URL: https://issues.apache.org/jira/browse/FLINK-20571

[jira] [Created] (FLINK-20570) `/docs/stream/operators/process_function.md`, line 252. The `NOTE tip` css style is different from the others.

2020-12-10 Thread shizhengchao (Jira)
shizhengchao created FLINK-20570: Summary: `/docs/stream/operators/process_function.md`, line 252. The `NOTE tip` css style is different from the others. Key: FLINK-20570 URL:

Re: [ANNOUNCE] Apache Flink 1.12.0 released

2020-12-10 Thread Xintong Song
Congratulations~! Thanks Robert, Dian and everyone. Thank you~ Xintong Song On Thu, Dec 10, 2020 at 11:23 PM Robert Metzger wrote: > Thanks Nick! > > This is blocked on the maintainers of the official images to merge this PR: > https://github.com/docker-library/official-images/pull/9249 > I

Re: [DISCUSS] FLIP-152: Hive Query Syntax Compatibility

2020-12-10 Thread Zhijiang
Thanks for the further info and explanations! I have no other concerns. Best, Zhijiang -- From:Rui Li Send Time:2020年12月10日(星期四) 20:35 To:dev ; Zhijiang Subject:Re: [DISCUSS] FLIP-152: Hive Query Syntax Compatibility Hi

[jira] [Created] (FLINK-20569) testKafkaSourceSinkWithMetadata hangs

2020-12-10 Thread Huang Xingbo (Jira)
Huang Xingbo created FLINK-20569: Summary: testKafkaSourceSinkWithMetadata hangs Key: FLINK-20569 URL: https://issues.apache.org/jira/browse/FLINK-20569 Project: Flink Issue Type: Bug

Re: [VOTE] Release 1.11.3, release candidate #1

2020-12-10 Thread Xintong Song
Hi everyone, Stephan and Becket reported some missing commits from the FLIP-27 backportings, some of which are quite significant that they would consider as release blockers. Therefore, I'm hereby canceling this release candidate. The next release candidate will be created as soon as the missing

[jira] [Created] (FLINK-20568) Kerberized YARN per-job on Docker test failed with "Hadoop security with Kerberos is enabled but the login user does not have Kerberos credentials or delegation tokens!"

2020-12-10 Thread Huang Xingbo (Jira)
Huang Xingbo created FLINK-20568: Summary: Kerberized YARN per-job on Docker test failed with "Hadoop security with Kerberos is enabled but the login user does not have Kerberos credentials or delegation tokens!" Key:

[jira] [Created] (FLINK-20567) Document Error

2020-12-10 Thread appleyuchi (Jira)
appleyuchi created FLINK-20567: -- Summary: Document Error Key: FLINK-20567 URL: https://issues.apache.org/jira/browse/FLINK-20567 Project: Flink Issue Type: Test Reporter: appleyuchi

Re: [ANNOUNCE] Apache Flink 1.12.0 released

2020-12-10 Thread nick toker
Hi first good job and tank you i don't find in docker hub the new version 1.12 when it will be there ? nick ‫בתאריך יום ה׳, 10 בדצמ׳ 2020 ב-14:17 מאת ‪Robert Metzger‬‏ <‪ rmetz...@apache.org‬‏>:‬ > The Apache Flink community is very happy to announce the release of Apache > Flink 1.12.0,

Re: [ANNOUNCE] Apache Flink 1.12.0 released

2020-12-10 Thread Robert Metzger
Thanks Nick! This is blocked on the maintainers of the official images to merge this PR: https://github.com/docker-library/official-images/pull/9249 I can not really make an estimate when they'll merge it. On Thu, Dec 10, 2020 at 4:20 PM nick toker wrote: > Hi > first good job and tank you >

Re: Re: [ANNOUNCE] Apache Flink 1.12.0 released

2020-12-10 Thread Till Rohrmann
Congratulations to everyone who contributed and thanks a lot for being our release managers Dian and Robert! Cheers, Till On Thu, Dec 10, 2020 at 1:47 PM Rui Li wrote: > Congrats! Thanks to Dian and Robert for driving the release! > > On Thu, Dec 10, 2020 at 8:42 PM hailongwang

[jira] [Created] (FLINK-20566) Fix typo in `Cassandra Connector` docs.

2020-12-10 Thread xiaozilong (Jira)
xiaozilong created FLINK-20566: -- Summary: Fix typo in `Cassandra Connector` docs. Key: FLINK-20566 URL: https://issues.apache.org/jira/browse/FLINK-20566 Project: Flink Issue Type: Bug

Re: Re: [ANNOUNCE] Apache Flink 1.12.0 released

2020-12-10 Thread Rui Li
Congrats! Thanks to Dian and Robert for driving the release! On Thu, Dec 10, 2020 at 8:42 PM hailongwang <18868816...@163.com> wrote: > > > Congratulations! Thanks Dian and Robert for the great work! > > > Best, > Hailong > At 2020-12-10 19:35:44, "Yun Tang" wrote: > >Thanks Dian and Robert for

Re: Re: [ANNOUNCE] Apache Flink 1.12.0 released

2020-12-10 Thread Xingbo Huang
Congratulations! Thanks Dian and Robert for the great work! And thanks everyone who makes the release possible ! Best, Xingbo hailongwang <18868816...@163.com> 于2020年12月10日周四 下午8:42写道: > > > Congratulations! Thanks Dian and Robert for the great work! > > > Best, > Hailong > At 2020-12-10

Re:Re: [ANNOUNCE] Apache Flink 1.12.0 released

2020-12-10 Thread hailongwang
Congratulations! Thanks Dian and Robert for the great work! Best, Hailong At 2020-12-10 19:35:44, "Yun Tang" wrote: >Thanks Dian and Robert for driving this release and thanks everyone who makes >this great work possible ! > >Best >Yun Tang > >From: Wei Zhong

Re: [ANNOUNCE] Apache Flink 1.12.0 released

2020-12-10 Thread Yun Tang
Thanks Dian and Robert for driving this release and thanks everyone who makes this great work possible ! Best Yun Tang From: Wei Zhong Sent: Thursday, December 10, 2020 20:32 To: dev@flink.apache.org Cc: user ; annou...@apache.org Subject: Re: [ANNOUNCE]

Re: [DISCUSS] FLIP-152: Hive Query Syntax Compatibility

2020-12-10 Thread Rui Li
Hi Zhijiang, Glad to know you're interested in this FLIP. I wouldn't claim 100% compatibility with this FLIP. That's because Flink doesn't have the functionalities to support all Hive's features. To list a few examples: 1. Hive allows users to process data with shell scripts -- very similar

Re: [ANNOUNCE] Apache Flink 1.12.0 released

2020-12-10 Thread Wei Zhong
Congratulations! Thanks Dian and Robert for the great work! Best, Wei > 在 2020年12月10日,20:26,Leonard Xu 写道: > > > Thanks Dian and Robert for the great work as release manager ! > And thanks everyone who makes the release possible ! > > > Best, > Leonard > >> 在 2020年12月10日,20:17,Robert

Re: [ANNOUNCE] Apache Flink 1.12.0 released

2020-12-10 Thread Leonard Xu
Thanks Dian and Robert for the great work as release manager ! And thanks everyone who makes the release possible ! Best, Leonard > 在 2020年12月10日,20:17,Robert Metzger 写道: > > The Apache Flink community is very happy to announce the release of Apache > Flink 1.12.0, which is the latest

[ANNOUNCE] Apache Flink 1.12.0 released

2020-12-10 Thread Robert Metzger
The Apache Flink community is very happy to announce the release of Apache Flink 1.12.0, which is the latest major release. Apache Flink® is an open-source stream processing framework for distributed, high-performing, always-available, and accurate data streaming applications. The release is

[jira] [Created] (FLINK-20565) Fix typo in EXPLAIN Statements docs.

2020-12-10 Thread xiaozilong (Jira)
xiaozilong created FLINK-20565: -- Summary: Fix typo in EXPLAIN Statements docs. Key: FLINK-20565 URL: https://issues.apache.org/jira/browse/FLINK-20565 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-20564) Add metrics for ElasticSearch connector

2020-12-10 Thread Peidian Li (Jira)
Peidian Li created FLINK-20564: -- Summary: Add metrics for ElasticSearch connector Key: FLINK-20564 URL: https://issues.apache.org/jira/browse/FLINK-20564 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-20563) Support built-in functions for Hive versions prior to 1.2.0

2020-12-10 Thread Rui Li (Jira)
Rui Li created FLINK-20563: -- Summary: Support built-in functions for Hive versions prior to 1.2.0 Key: FLINK-20563 URL: https://issues.apache.org/jira/browse/FLINK-20563 Project: Flink Issue Type:

Re: [DISCUSS] FLIP-152: Hive Query Syntax Compatibility

2020-12-10 Thread Zhijiang
Thanks for launching the discussion and the FLIP, Rui! It is really nice to see our continuous efforts for compatibility with Hive and benefiting users in this area. I am only curious that are there any other compatible limitations for Hive users after this FLIP? Or can I say that the Hive

[jira] [Created] (FLINK-20562) Support ExplainDetails for EXPLAIN sytnax

2020-12-10 Thread Jark Wu (Jira)
Jark Wu created FLINK-20562: --- Summary: Support ExplainDetails for EXPLAIN sytnax Key: FLINK-20562 URL: https://issues.apache.org/jira/browse/FLINK-20562 Project: Flink Issue Type: New Feature

Re: [DISCUSS] Pod template for native K8s integration

2020-12-10 Thread Till Rohrmann
Hi Yang Wang, thanks for starting this discussion. I like the idea of providing a general mechanism to customize Flink's K8s deployment instead of implementing each feature separately. This should lower the maintenance overhead and people coming from K8s should already be familiar with how to

Re: [VOTE] Release 1.11.3, release candidate #1

2020-12-10 Thread Xintong Song
Hi Yun, Thanks for the information. IMHO, FLINK-20554 should not be a release blocker. I'd rather not reject RC1 on it. However, if the RC1 does not pass this vote, and if the issue is managed to be fixed before the next RC, we can still include it for release 1.11.3. BTW, I think there only

Re: [DISCUSS] Programmatically submit Flink job jar to session cluster

2020-12-10 Thread Flavio Pompermaier
To me creating the PackagedProgram on the client side is very bad, at least for 2 things: 1. You must ensure to have almost the same classpath of the Flink cluster otherwise you can face problems in deserializing the submitted job graph (for example jackson automatically tries to create modules

[jira] [Created] (FLINK-20561) Add documentation for `records-lag-max` metric.

2020-12-10 Thread xiaozilong (Jira)
xiaozilong created FLINK-20561: -- Summary: Add documentation for `records-lag-max` metric. Key: FLINK-20561 URL: https://issues.apache.org/jira/browse/FLINK-20561 Project: Flink Issue Type:

[jira] [Created] (FLINK-20560) history-server: update archives while they're being loaded

2020-12-10 Thread yazgoo (Jira)
yazgoo created FLINK-20560: -- Summary: history-server: update archives while they're being loaded Key: FLINK-20560 URL: https://issues.apache.org/jira/browse/FLINK-20560 Project: Flink Issue Type:

[jira] [Created] (FLINK-20559) history-server: don't add caching headers for /jobs/overview.json

2020-12-10 Thread yazgoo (Jira)
yazgoo created FLINK-20559: -- Summary: history-server: don't add caching headers for /jobs/overview.json Key: FLINK-20559 URL: https://issues.apache.org/jira/browse/FLINK-20559 Project: Flink

Re: [DISCUSS] FLIP-152: Hive Query Syntax Compatibility

2020-12-10 Thread Rui Li
Thanks Kurt for your inputs! I agree we should extend Hive code to support non-Hive tables. I have updated the wiki page to remove the limitations you mentioned, and add typical use cases in the "Motivation" section. Regarding comment #b, the interface is defined in flink-table-planner-blink and

[jira] [Created] (FLINK-20558) ParquetAvroStreamingFileSinkITCase.testWriteParquetAvroSpecific test failure

2020-12-10 Thread Matthias (Jira)
Matthias created FLINK-20558: Summary: ParquetAvroStreamingFileSinkITCase.testWriteParquetAvroSpecific test failure Key: FLINK-20558 URL: https://issues.apache.org/jira/browse/FLINK-20558 Project: Flink

[jira] [Created] (FLINK-20557) Support statement set in SQL CLI

2020-12-10 Thread Jark Wu (Jira)
Jark Wu created FLINK-20557: --- Summary: Support statement set in SQL CLI Key: FLINK-20557 URL: https://issues.apache.org/jira/browse/FLINK-20557 Project: Flink Issue Type: New Feature

Re: [VOTE] Release 1.11.3, release candidate #1

2020-12-10 Thread Yun Tang
Hi Xintong Thanks for driving this release! Someone reported that the checkpointed data size on overview page is broken [1] and I confirmed that really exists. I hope to include that fix in release-1.11.3 as that could be a quick fix and impact the usability. BTW, I think there only existed