[jira] [Created] (FLINK-17399) CsvTableSink should also extend from OverwritableTableSink

godfrey he created FLINK-17399: -- Summary: CsvTableSink should also extend from OverwritableTableSink Key: FLINK-17399 URL: https://issues.apache.org/jira/browse/FLINK-17399 Project: Flink Issue

Flink 1.9.2 why always checkpoint expired

Hi all, Why my flink checkpoint always expired, I used RocksDB checkpoint, and I can’t get any useful messages for this. Could you help me ? Thanks very much.

[jira] [Created] (FLINK-17398) Support flexible path reading

Jingsong Lee created FLINK-17398: Summary: Support flexible path reading Key: FLINK-17398 URL: https://issues.apache.org/jira/browse/FLINK-17398 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-17397) Filesystem support lookup table source

Jingsong Lee created FLINK-17397: Summary: Filesystem support lookup table source Key: FLINK-17397 URL: https://issues.apache.org/jira/browse/FLINK-17397 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-17396) Support SHOW MODULES in Flink SQL

Caizhi Weng created FLINK-17396: --- Summary: Support SHOW MODULES in Flink SQL Key: FLINK-17396 URL: https://issues.apache.org/jira/browse/FLINK-17396 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-17395) Add the sign and sha logic for PyFlink wheel packages

Huang Xingbo created FLINK-17395: Summary: Add the sign and sha logic for PyFlink wheel packages Key: FLINK-17395 URL: https://issues.apache.org/jira/browse/FLINK-17395 Project: Flink Issue

Re: [DISCUSS] Add custom labels on AbstractPrometheusReporter like PrometheusPushGatewayReporter's groupingKey

Hi jinhai, I think it is a good improvement to also add groupingKey to PrometheusReporter.And making the PrometheusPushGatewayReporter and PrometheusReporter always share the same logics is important. AFAIK, they should not have differences except for the metrics exposing mechanism

[jira] [Created] (FLINK-17394) Add RemoteEnvironment and RemoteStreamEnvironment in Python

Huang Xingbo created FLINK-17394: Summary: Add RemoteEnvironment and RemoteStreamEnvironment in Python Key: FLINK-17394 URL: https://issues.apache.org/jira/browse/FLINK-17394 Project: Flink

Re: [ANNOUNCE] Apache Flink 1.9.3 released

Thanks Dian for managing this release! Best, Jingsong Lee On Sun, Apr 26, 2020 at 7:17 PM Jark Wu wrote: > Thanks Dian for being the release manager and thanks all who make this > possible. > > Best, > Jark > > On Sun, 26 Apr 2020 at 18:06, Leonard Xu wrote: > > > Thanks Dian for the release

[jira] [Created] (FLINK-17393) Improve the `FutureCompletingBlockingQueue` to wakeup blocking put() more elegantly.

Jiangjie Qin created FLINK-17393: Summary: Improve the `FutureCompletingBlockingQueue` to wakeup blocking put() more elegantly. Key: FLINK-17393 URL: https://issues.apache.org/jira/browse/FLINK-17393

[jira] [Created] (FLINK-17392) enable configuring minicluster in Flink SQL in IDE

Bowen Li created FLINK-17392: Summary: enable configuring minicluster in Flink SQL in IDE Key: FLINK-17392 URL: https://issues.apache.org/jira/browse/FLINK-17392 Project: Flink Issue Type:

Re: [DISCUSS] Adding support for Hadoop 3 and removing flink-shaded-hadoop

Indeed, that would be the assumption, that Hadoop does not expose its transitive libraries on its public API surface. >From vague memory, I think that pretty much true so far. I only remember Kinesis and Calcite as counter examples, who exposed Guava classes as part of the public API. But that is

Re: [DISCUSS] FLIP-124: Add open/close and Collector to (De)SerializationSchema

That makes sense, thanks for clarifying. Best, Stephan On Fri, Apr 24, 2020 at 2:15 PM Dawid Wysakowicz wrote: > Hi Stephan, > > I fully agree with what you said. Also as far as I can tell what was > suggested in the FLIP-124 does not contradict with what you are saying. Let > me clarify it a

[jira] [Created] (FLINK-17391) sink.rolling-policy.time.interval default value should be bigger

Jingsong Lee created FLINK-17391: Summary: sink.rolling-policy.time.interval default value should be bigger Key: FLINK-17391 URL: https://issues.apache.org/jira/browse/FLINK-17391 Project: Flink

[jira] [Created] (FLINK-17390) Container resource cannot be mapped on Hadoop 2.10+

Xintong Song created FLINK-17390: Summary: Container resource cannot be mapped on Hadoop 2.10+ Key: FLINK-17390 URL: https://issues.apache.org/jira/browse/FLINK-17390 Project: Flink Issue

[ANNOUNCE] Weekly Community Update 2020/17

Dear community, happy to share this week's community digest with an update on Flink 1.11, Flink 1.10.1 and Flink 1.9.3, the revival of FLIP-36 to support interactive programming, a new FLIP to unify (& separate) TimestampAssigners and a bit more. Flink Development == Releases

Re: [ANNOUNCE] Apache Flink 1.9.3 released

Thanks Dian for being the release manager and thanks all who make this possible. Best, Jark On Sun, 26 Apr 2020 at 18:06, Leonard Xu wrote: > Thanks Dian for the release and being the release manager ! > > Best， > Leonard Xu > > > 在 2020年4月26日，17:58，Benchao Li 写道： > > Thanks Dian for the

Re: [ANNOUNCE] Apache Flink 1.9.3 released

Thanks Dian for the release and being the release manager ! Best， Leonard Xu > 在 2020年4月26日，17:58，Benchao Li 写道： > > Thanks Dian for the effort, and all who make this release possible. Great > work! > > Konstantin Knauf mailto:konstan...@ververica.com>> > 于2020年4月26日周日 下午5:21写道： > Thanks

Re: [ANNOUNCE] Apache Flink 1.9.3 released

Thanks Dian for the effort, and all who make this release possible. Great work! Konstantin Knauf 于2020年4月26日周日 下午5:21写道： > Thanks for managing this release! > > On Sun, Apr 26, 2020 at 3:58 AM jincheng sun > wrote: > >> Thanks for your great job, Dian! >> >> Best, >> Jincheng >> >> >> Hequn

Re: [ANNOUNCE] Apache Flink 1.9.3 released

Thanks for managing this release! On Sun, Apr 26, 2020 at 3:58 AM jincheng sun wrote: > Thanks for your great job, Dian! > > Best, > Jincheng > > > Hequn Cheng 于2020年4月25日周六 下午8:30写道： > >> @Dian, thanks a lot for the release and for being the release manager. >> Also thanks to everyone who

[jira] [Created] (FLINK-17389) LocalExecutorITCase.testBatchQueryCancel asserts error

Zhijiang created FLINK-17389: Summary: LocalExecutorITCase.testBatchQueryCancel asserts error Key: FLINK-17389 URL: https://issues.apache.org/jira/browse/FLINK-17389 Project: Flink Issue Type:

[jira] [Created] (FLINK-17388) flink sql The custom function in ROW type is executed multiple times

cloudzhao created FLINK-17388: - Summary: flink sql The custom function in ROW type is executed multiple times Key: FLINK-17388 URL: https://issues.apache.org/jira/browse/FLINK-17388 Project: Flink

[jira] [Created] (FLINK-17387) Implement LookupableTableSource for Hive connector

Rui Li created FLINK-17387: -- Summary: Implement LookupableTableSource for Hive connector Key: FLINK-17387 URL: https://issues.apache.org/jira/browse/FLINK-17387 Project: Flink Issue Type: New

Integration of DataSketches into Flink

Hello All, I am a committer on DataSketches.apache.org and just learning about Flink, Since Flink is designed for stateful stream processing I would think it would make sense to have the DataSketches library integrated into its core so all users of Flink could