[jira] [Created] (FLINK-22386) Introduce cache for docker images

2021-04-20 Thread Dawid Wysakowicz (Jira)
Dawid Wysakowicz created FLINK-22386: Summary: Introduce cache for docker images Key: FLINK-22386 URL: https://issues.apache.org/jira/browse/FLINK-22386 Project: Flink Issue Type: Task

[jira] [Created] (FLINK-22385) Type mismatch in NetworkBufferPool

2021-04-20 Thread sharkd tu (Jira)
sharkd tu created FLINK-22385: - Summary: Type mismatch in NetworkBufferPool Key: FLINK-22385 URL: https://issues.apache.org/jira/browse/FLINK-22385 Project: Flink Issue Type: Bug Repo

[jira] [Created] (FLINK-22384) Chinese typos

2021-04-20 Thread simenliuxing (Jira)
simenliuxing created FLINK-22384: Summary: Chinese typos Key: FLINK-22384 URL: https://issues.apache.org/jira/browse/FLINK-22384 Project: Flink Issue Type: Improvement Components: D

[jira] [Created] (FLINK-22383) HiveParser may fail to call Flink functions

2021-04-20 Thread Rui Li (Jira)
Rui Li created FLINK-22383: -- Summary: HiveParser may fail to call Flink functions Key: FLINK-22383 URL: https://issues.apache.org/jira/browse/FLINK-22383 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-22382) ProcessFailureCancelingITCase.testCancelingOnProcessFailure

2021-04-20 Thread Dawid Wysakowicz (Jira)
Dawid Wysakowicz created FLINK-22382: Summary: ProcessFailureCancelingITCase.testCancelingOnProcessFailure Key: FLINK-22382 URL: https://issues.apache.org/jira/browse/FLINK-22382 Project: Flink

[jira] [Created] (FLINK-22381) RocksDBStateBackendTests::test_get_set_number_of_transfering_threads fails on azure

2021-04-20 Thread Roman Khachatryan (Jira)
Roman Khachatryan created FLINK-22381: - Summary: RocksDBStateBackendTests::test_get_set_number_of_transfering_threads fails on azure Key: FLINK-22381 URL: https://issues.apache.org/jira/browse/FLINK-22381

[jira] [Created] (FLINK-22380) Pub/Sub Lite Connector for Flink

2021-04-20 Thread Evan Palmer (Jira)
Evan Palmer created FLINK-22380: --- Summary: Pub/Sub Lite Connector for Flink Key: FLINK-22380 URL: https://issues.apache.org/jira/browse/FLINK-22380 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-22379) Introduce a new JobStatus to avoid premature checkpoint triggering

2021-04-20 Thread Anton Kalashnikov (Jira)
Anton Kalashnikov created FLINK-22379: - Summary: Introduce a new JobStatus to avoid premature checkpoint triggering Key: FLINK-22379 URL: https://issues.apache.org/jira/browse/FLINK-22379 Project:

[jira] [Created] (FLINK-22378) Type mismatch when declaring SOURCE_WATERMARK on TIMESTAMP_LTZ column

2021-04-20 Thread Timo Walther (Jira)
Timo Walther created FLINK-22378: Summary: Type mismatch when declaring SOURCE_WATERMARK on TIMESTAMP_LTZ column Key: FLINK-22378 URL: https://issues.apache.org/jira/browse/FLINK-22378 Project: Flink

[jira] [Created] (FLINK-22377) Ignore if writer is stopped when aborting channel state writing

2021-04-20 Thread Roman Khachatryan (Jira)
Roman Khachatryan created FLINK-22377: - Summary: Ignore if writer is stopped when aborting channel state writing Key: FLINK-22377 URL: https://issues.apache.org/jira/browse/FLINK-22377 Project: Fl

[jira] [Created] (FLINK-22376) SequentialChannelStateReaderImpl may recycle buffer twice

2021-04-20 Thread Roman Khachatryan (Jira)
Roman Khachatryan created FLINK-22376: - Summary: SequentialChannelStateReaderImpl may recycle buffer twice Key: FLINK-22376 URL: https://issues.apache.org/jira/browse/FLINK-22376 Project: Flink

[jira] [Created] (FLINK-22375) Disable JDBC XA connection pooling if unnecessary

2021-04-20 Thread Roman Khachatryan (Jira)
Roman Khachatryan created FLINK-22375: - Summary: Disable JDBC XA connection pooling if unnecessary Key: FLINK-22375 URL: https://issues.apache.org/jira/browse/FLINK-22375 Project: Flink I

[jira] [Created] (FLINK-22374) ConfigOptionsDocsCompletenessITCase fails on traivs

2021-04-20 Thread Leonard Xu (Jira)
Leonard Xu created FLINK-22374: -- Summary: ConfigOptionsDocsCompletenessITCase fails on traivs Key: FLINK-22374 URL: https://issues.apache.org/jira/browse/FLINK-22374 Project: Flink Issue Type: B

[jira] [Created] (FLINK-22373) Create release notes for 1.13

2021-04-20 Thread Dawid Wysakowicz (Jira)
Dawid Wysakowicz created FLINK-22373: Summary: Create release notes for 1.13 Key: FLINK-22373 URL: https://issues.apache.org/jira/browse/FLINK-22373 Project: Flink Issue Type: Task

[jira] [Created] (FLINK-22372) Rename LogicalTypeCasts class variables in the castTo method.

2021-04-20 Thread Wong Mulan (Jira)
Wong Mulan created FLINK-22372: -- Summary: Rename LogicalTypeCasts class variables in the castTo method. Key: FLINK-22372 URL: https://issues.apache.org/jira/browse/FLINK-22372 Project: Flink Is

[jira] [Created] (FLINK-22371) Chinese grammatical error

2021-04-20 Thread simenliuxing (Jira)
simenliuxing created FLINK-22371: Summary: Chinese grammatical error Key: FLINK-22371 URL: https://issues.apache.org/jira/browse/FLINK-22371 Project: Flink Issue Type: Improvement C

Re: [DISCUSS] Simplify SQL lookup join (temporal join with latest) syntax

2021-04-20 Thread Gyula Fóra
Thanks for the pointer Jingsong, I don't see how proctime() is ambiguous though as it always refers to the current wall clock time. I think thats much better than adding a magic pseudocolumn. Cheers Gyula On Tue, Apr 20, 2021 at 11:06 AM Jingsong Li wrote: > +1 for simplifying. > > We already

Re: [DISCUSS] Simplify SQL lookup join (temporal join with latest) syntax

2021-04-20 Thread Jingsong Li
+1 for simplifying. We already have a thread of this topic: http://apache-flink-mailing-list-archive.1008284.n3.nabble.com/DISCUSS-Make-Temporal-Join-syntax-easier-to-use-td47296.html FYI. Best, Jingsong On Tue, Apr 20, 2021 at 4:55 PM Gyula Fóra wrote: > Hi All! > > Playing around with the SQ

[DISCUSS] Simplify SQL lookup join (temporal join with latest) syntax

2021-04-20 Thread Gyula Fóra
Hi All! Playing around with the SQL syntax for temporal join with latest table I feel there is some room for optimizing the current syntax to provide a better user experience. The current system for specifying the lookup side is: lookuptable FOR SYSTEM_TIME AS OF probe.proctime_column It feels

Re: [jira] [Created] (FLINK-21986) taskmanager native memory not release timely after restart

2021-04-20 Thread Till Rohrmann
Thanks for raising this issue Feifan. I think it is very important to fix it. I will take a look at your PR. Cheers, Till On Tue, Apr 20, 2021 at 5:35 AM zoltar9264 wrote: > > > Hi community, > I raised this issue about three weeks ago. After several weeks of > investigation, I found th

[jira] [Created] (FLINK-22370) ParquetColumnarRowSplitReader#reachedEnd() returns false after it returns true

2021-04-20 Thread Danny Chen (Jira)
Danny Chen created FLINK-22370: -- Summary: ParquetColumnarRowSplitReader#reachedEnd() returns false after it returns true Key: FLINK-22370 URL: https://issues.apache.org/jira/browse/FLINK-22370 Project: F

[jira] [Created] (FLINK-22369) RocksDB state backend might occur ClassNotFoundException when deserializing on TM side

2021-04-20 Thread Yun Tang (Jira)
Yun Tang created FLINK-22369: Summary: RocksDB state backend might occur ClassNotFoundException when deserializing on TM side Key: FLINK-22369 URL: https://issues.apache.org/jira/browse/FLINK-22369 Projec