[jira] [Created] (FLINK-24678) Correct the metric name of map state contains latency

2021-10-27 Thread Yun Tang (Jira)
Yun Tang created FLINK-24678: Summary: Correct the metric name of map state contains latency Key: FLINK-24678 URL: https://issues.apache.org/jira/browse/FLINK-24678 Project: Flink Issue Type: Bug

Re: [DISCUSS] FLIP-188: Introduce Built-in Dynamic Table Storage

2021-10-27 Thread Jingsong Li
Hi all, I updated FLIP based on your feedback: 1. Introduce interfaces: GenericCatalog, ManagedTableFactory, TableDescriptor.forManaged 2. Introduce log.scan.startup.mode (default initial) to Hybrid source. 3. Add description to miss dropped table. Best, Jingsong On Mon, Oct 25, 2021 at 3:39

Re: [Discuss] Planning Flink 1.15

2021-10-27 Thread Guowei Ma
Thanks for volunteering as our release managers Till, Yun and Joe! +1 for feature freeze on 2.6 ,which is more convenient for us to plan 1.15 related work. Best, Guowei On Thu, Oct 28, 2021 at 12:01 PM Xintong Song wrote: > Thanks for kicking this off, Joe. > > +1 for Till, Yun and Joe as the

Re: [Discuss] Planning Flink 1.15

2021-10-27 Thread Xintong Song
Thanks for kicking this off, Joe. +1 for Till, Yun and Joe as the release managers. Also +1 for feature freeze on 2.6, which would make it easier for folks from China to dedicate to the release testing. Thank you~ Xintong Song On Wed, Oct 27, 2021 at 11:04 PM Yun Gao wrote: > Hi all, > > V

[jira] [Created] (FLINK-24677) JdbcBatchingOutputFormat should not generate circulate chaining of exceptions when flushing fails in timer thread

2021-10-27 Thread Caizhi Weng (Jira)
Caizhi Weng created FLINK-24677: --- Summary: JdbcBatchingOutputFormat should not generate circulate chaining of exceptions when flushing fails in timer thread Key: FLINK-24677 URL: https://issues.apache.org/jira/brows

[jira] [Created] (FLINK-24676) Schema does not match if explain insert statement with partial column

2021-10-27 Thread godfrey he (Jira)
godfrey he created FLINK-24676: -- Summary: Schema does not match if explain insert statement with partial column Key: FLINK-24676 URL: https://issues.apache.org/jira/browse/FLINK-24676 Project: Flink

[jira] [Created] (FLINK-24675) org.apache.flink.formats.parquet.ParquetMapInputFormat the Constructor has no MessageType will throw an exception.

2021-10-27 Thread Hadiiiiiiiii (Jira)
Hadi created FLINK-24675: Summary: org.apache.flink.formats.parquet.ParquetMapInputFormat the Constructor has no MessageType will throw an exception. Key: FLINK-24675 URL: https://issues.apache.org/jira/

[jira] [Created] (FLINK-24674) Create corresponding resouces for task manager Pods

2021-10-27 Thread L. C. Hsieh (Jira)
L. C. Hsieh created FLINK-24674: --- Summary: Create corresponding resouces for task manager Pods Key: FLINK-24674 URL: https://issues.apache.org/jira/browse/FLINK-24674 Project: Flink Issue Type:

Re: [DISCUSS] Should we drop Row SerializationSchema/DeserializationSchema?

2021-10-27 Thread Francesco Guardiani
Created https://issues.apache.org/jira/browse/FLINK-24673 On Mon, Oct 25, 2021 at 9:57 AM Francesco Guardiani wrote: > Last remainder: unless there are any objections, I will proceed with > deprecating these by the end of the week. > > On Thu, Oct 21, 2021 at 4:28 PM Konstantin Knauf > wrote: >

[jira] [Created] (FLINK-24673) Deprecate old Row SerializationSchema/DeserializationSchema

2021-10-27 Thread Francesco Guardiani (Jira)
Francesco Guardiani created FLINK-24673: --- Summary: Deprecate old Row SerializationSchema/DeserializationSchema Key: FLINK-24673 URL: https://issues.apache.org/jira/browse/FLINK-24673 Project: Fl

[jira] [Created] (FLINK-24672) [ WARN ] javax.management.InstanceAlreadyExistsException

2021-10-27 Thread qinghuan wang (Jira)
qinghuan wang created FLINK-24672: - Summary: [ WARN ] javax.management.InstanceAlreadyExistsException Key: FLINK-24672 URL: https://issues.apache.org/jira/browse/FLINK-24672 Project: Flink Is

[jira] [Created] (FLINK-24671) Possible NPE in LocalInputChannel#getBuffersInUseCount before initialization of subpartitionView

2021-10-27 Thread Anton Kalashnikov (Jira)
Anton Kalashnikov created FLINK-24671: - Summary: Possible NPE in LocalInputChannel#getBuffersInUseCount before initialization of subpartitionView Key: FLINK-24671 URL: https://issues.apache.org/jira/browse/FL

Re: [NOTICE] flink-streaming-java no longer depends on Scala and lost it's suffix

2021-10-27 Thread Till Rohrmann
Thanks a lot for your efforts Chesnay. The Scala beast will soon be tamed :-) On Tue, Oct 26, 2021 at 2:29 PM Martijn Visser wrote: > This is an awesome accomplishment, many thanks! > Ideally we also manage to complete > https://issues.apache.org/jira/browse/FLINK-24427 for 1.15 to get Flink in

Re: [Discuss] Planning Flink 1.15

2021-10-27 Thread Yun Gao
Hi all, Very thanks @Joe for starting the discussion! And it is really honorable to be the release manager of 1.15~ And for the releasing date, there might be some concerns since Jan. 17th is closed to the Spring Festival Holiday (1.31 to 2.6) and many people might also start the holiday furt

Re: Flink sql client usability improvements

2021-10-27 Thread Jark Wu
I have granted permission to you Sergey. Best, jark On Wed, 27 Oct 2021 at 18:35, Sergey Nuyanzin wrote: > Hi Jark, > > Thank you for your response. > > It seems I do not have enough grants to create a page there. > Could you please give the necessary grants? > My confluence login is snuyanzin

[jira] [Created] (FLINK-24670) Restructure unaligned checkpoints documentation page to "Checkpointing under back pressure"

2021-10-27 Thread Piotr Nowojski (Jira)
Piotr Nowojski created FLINK-24670: -- Summary: Restructure unaligned checkpoints documentation page to "Checkpointing under back pressure" Key: FLINK-24670 URL: https://issues.apache.org/jira/browse/FLINK-24670

Re: Flink sql client usability improvements

2021-10-27 Thread Sergey Nuyanzin
Hi Jark, Thank you for your response. It seems I do not have enough grants to create a page there. Could you please give the necessary grants? My confluence login is snuyanzin On Tue, Oct 26, 2021 at 4:48 PM Jark Wu wrote: > Hi Sergey, > > Welcome contributions! You can read the FLIP introduct

[jira] [Created] (FLINK-24669) Can't import all release-signing keys

2021-10-27 Thread Bob (Jira)
Bob created FLINK-24669: --- Summary: Can't import all release-signing keys Key: FLINK-24669 URL: https://issues.apache.org/jira/browse/FLINK-24669 Project: Flink Issue Type: Improvement Repor

[jira] [Created] (FLINK-24668) Pulsar consumption data repeated output

2021-10-27 Thread jiayue.yu (Jira)
jiayue.yu created FLINK-24668: - Summary: Pulsar consumption data repeated output Key: FLINK-24668 URL: https://issues.apache.org/jira/browse/FLINK-24668 Project: Flink Issue Type: Bug C

[jira] [Created] (FLINK-24667) Channel state writer would fail the task directly if meeting exception previously

2021-10-27 Thread Yun Tang (Jira)
Yun Tang created FLINK-24667: Summary: Channel state writer would fail the task directly if meeting exception previously Key: FLINK-24667 URL: https://issues.apache.org/jira/browse/FLINK-24667 Project: Fl

[jira] [Created] (FLINK-24666) The lenient option was not exposed to users on RetractableTopNFunction

2021-10-27 Thread lincoln lee (Jira)
lincoln lee created FLINK-24666: --- Summary: The lenient option was not exposed to users on RetractableTopNFunction Key: FLINK-24666 URL: https://issues.apache.org/jira/browse/FLINK-24666 Project: Flink

[jira] [Created] (FLINK-24665) Update Presto Hadoop dependency to latest version

2021-10-27 Thread Martijn Visser (Jira)
Martijn Visser created FLINK-24665: -- Summary: Update Presto Hadoop dependency to latest version Key: FLINK-24665 URL: https://issues.apache.org/jira/browse/FLINK-24665 Project: Flink Issue T