[jira] [Created] (FLINK-24182) Tasks canceler should not immediately interrupt

2021-09-07 Thread Arvid Heise (Jira)
Arvid Heise created FLINK-24182: --- Summary: Tasks canceler should not immediately interrupt Key: FLINK-24182 URL: https://issues.apache.org/jira/browse/FLINK-24182 Project: Flink Issue Type: Imp

[jira] [Created] (FLINK-24184) Potential race condition leading to incorrectly issued interruptions

2021-09-07 Thread Piotr Nowojski (Jira)
Piotr Nowojski created FLINK-24184: -- Summary: Potential race condition leading to incorrectly issued interruptions Key: FLINK-24184 URL: https://issues.apache.org/jira/browse/FLINK-24184 Project: Fli

[jira] [Created] (FLINK-24185) flink-s3-fs-presto bundled dependencies not listed in NOTICE file

2021-09-07 Thread Xintong Song (Jira)
Xintong Song created FLINK-24185: Summary: flink-s3-fs-presto bundled dependencies not listed in NOTICE file Key: FLINK-24185 URL: https://issues.apache.org/jira/browse/FLINK-24185 Project: Flink

[jira] [Created] (FLINK-24186) Disable single rowtime column check for collect/print

2021-09-07 Thread Timo Walther (Jira)
Timo Walther created FLINK-24186: Summary: Disable single rowtime column check for collect/print Key: FLINK-24186 URL: https://issues.apache.org/jira/browse/FLINK-24186 Project: Flink Issue T

[jira] [Created] (FLINK-24187) Could not commit s3 file after JM restart during state initialization

2021-09-07 Thread Youjun Yuan (Jira)
Youjun Yuan created FLINK-24187: --- Summary: Could not commit s3 file after JM restart during state initialization Key: FLINK-24187 URL: https://issues.apache.org/jira/browse/FLINK-24187 Project: Flink

[jira] [Created] (FLINK-24188) flink-python NOTICE file contains unnecessary dependencies

2021-09-07 Thread Xintong Song (Jira)
Xintong Song created FLINK-24188: Summary: flink-python NOTICE file contains unnecessary dependencies Key: FLINK-24188 URL: https://issues.apache.org/jira/browse/FLINK-24188 Project: Flink Is

[jira] [Created] (FLINK-24189) Debloating buffer for multiply gates

2021-09-07 Thread Anton Kalashnikov (Jira)
Anton Kalashnikov created FLINK-24189: - Summary: Debloating buffer for multiply gates Key: FLINK-24189 URL: https://issues.apache.org/jira/browse/FLINK-24189 Project: Flink Issue Type: Su

[jira] [Created] (FLINK-24190) Handling large record with buffer debloat

2021-09-07 Thread Anton Kalashnikov (Jira)
Anton Kalashnikov created FLINK-24190: - Summary: Handling large record with buffer debloat Key: FLINK-24190 URL: https://issues.apache.org/jira/browse/FLINK-24190 Project: Flink Issue Typ

[jira] [Created] (FLINK-24191) Adjusting number of buffers besides buffer size

2021-09-07 Thread Anton Kalashnikov (Jira)
Anton Kalashnikov created FLINK-24191: - Summary: Adjusting number of buffers besides buffer size Key: FLINK-24191 URL: https://issues.apache.org/jira/browse/FLINK-24191 Project: Flink Iss

Flink 1.14 Weekly 2021-09-07

2021-09-07 Thread Dawid Wysakowicz
Dear Apache Flink community, Today was another update and we are making a good progress towards finally having the release. *Blockers, critical issues, cross-team testing and documentation* All of the release blockers are assigned and are making a good progress. Similarly the cross-team testing i

[jira] [Created] (FLINK-24192) Sql get plan failed. All the inputs have relevant nodes, however the cost is still infinite

2021-09-07 Thread xiaojin.wy (Jira)
xiaojin.wy created FLINK-24192: -- Summary: Sql get plan failed. All the inputs have relevant nodes, however the cost is still infinite Key: FLINK-24192 URL: https://issues.apache.org/jira/browse/FLINK-24192

[jira] [Created] (FLINK-24193) Test service entries cause noise in other tests

2021-09-07 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-24193: Summary: Test service entries cause noise in other tests Key: FLINK-24193 URL: https://issues.apache.org/jira/browse/FLINK-24193 Project: Flink Issue

Re: [DISCUSS] Automated architectural tests

2021-09-07 Thread Ingo Bürk
Thanks, Chesnay. I updated the PR to use a separate module now, and ran it on a few modules (some Table API modules and a couple connectors). The CI seemed to take ~2.5min for executing the tests; that's certainly not negligible. On the other hand, even the few tests implemented already found sever

[jira] [Created] (FLINK-24194) resource-providers yarn documentation has Chinese useless characters

2021-09-07 Thread qingbo jiao (Jira)
qingbo jiao created FLINK-24194: --- Summary: resource-providers yarn documentation has Chinese useless characters Key: FLINK-24194 URL: https://issues.apache.org/jira/browse/FLINK-24194 Project: Flink

Re: [DISCUSS] Automated architectural tests

2021-09-07 Thread Chesnay Schepler
I would say that's fine time-wise. On 07/09/2021 15:29, Ingo Bürk wrote: Thanks, Chesnay. I updated the PR to use a separate module now, and ran it on a few modules (some Table API modules and a couple connectors). The CI seemed to take ~2.5min for executing the tests; that's certainly not negli

[jira] [Created] (FLINK-24195) Translate "DESCRIBE Statements" page of "SQL" into Chinese

2021-09-07 Thread wuguihu (Jira)
wuguihu created FLINK-24195: --- Summary: Translate "DESCRIBE Statements" page of "SQL" into Chinese Key: FLINK-24195 URL: https://issues.apache.org/jira/browse/FLINK-24195 Project: Flink Issue Type:

[jira] [Created] (FLINK-24196) Translate "EXPLAIN Statements" page of "SQL" into Chinese

2021-09-07 Thread wuguihu (Jira)
wuguihu created FLINK-24196: --- Summary: Translate "EXPLAIN Statements" page of "SQL" into Chinese Key: FLINK-24196 URL: https://issues.apache.org/jira/browse/FLINK-24196 Project: Flink Issue Type: S

[jira] [Created] (FLINK-24197) Streaming File Sink end-to-end test fails with : "RestClientException: [File upload failed.]"

2021-09-07 Thread Dawid Wysakowicz (Jira)
Dawid Wysakowicz created FLINK-24197: Summary: Streaming File Sink end-to-end test fails with : "RestClientException: [File upload failed.]" Key: FLINK-24197 URL: https://issues.apache.org/jira/browse/FLINK-24

[jira] [Created] (FLINK-24198) KafkaTableITCase#testKafkaTemporalJoinChangelog fail with FlinkJobNotFoundException: Could not find Flink job

2021-09-07 Thread Dawid Wysakowicz (Jira)
Dawid Wysakowicz created FLINK-24198: Summary: KafkaTableITCase#testKafkaTemporalJoinChangelog fail with FlinkJobNotFoundException: Could not find Flink job Key: FLINK-24198 URL: https://issues.apache.org/jira

[jira] [Created] (FLINK-24199) Expose StreamExecutionEnvironment#configure in Python API

2021-09-07 Thread Dawid Wysakowicz (Jira)
Dawid Wysakowicz created FLINK-24199: Summary: Expose StreamExecutionEnvironment#configure in Python API Key: FLINK-24199 URL: https://issues.apache.org/jira/browse/FLINK-24199 Project: Flink

Re: [DISCUSS] FLIP-182: Watermark alignment

2021-09-07 Thread Thomas Weise
Hi, I wanted to check if there is active development on FLIP-182 and what the target release for it might be? [1] still shows as under discussion. Regarding the per-subtask vs. per-split limitation: I think it will be important that this eventually works per split, since in some cases it won't be

Re: [DISCUSS] FLIP-182: Watermark alignment

2021-09-07 Thread Piotr Nowojski
Hi Thomas, Unfortunately me/Arvid didn't have enough time to finish this off for 1.14.0 as we were firefighting other efforts and we have re-focused on other more advanced FLIPs. We want to deliver it for 1.15 though. I'm not sure, but I remember Arvid saying something that he would like to actual

[jira] [Created] (FLINK-24200) CheckpointBarrierTrackerTest.testTwoLastBarriersOneByOne fails on azure

2021-09-07 Thread Xintong Song (Jira)
Xintong Song created FLINK-24200: Summary: CheckpointBarrierTrackerTest.testTwoLastBarriersOneByOne fails on azure Key: FLINK-24200 URL: https://issues.apache.org/jira/browse/FLINK-24200 Project: Flin

[jira] [Created] (FLINK-24201) HistoryServer didn't contain TaskManager Logs

2021-09-07 Thread zlzhang0122 (Jira)
zlzhang0122 created FLINK-24201: --- Summary: HistoryServer didn't contain TaskManager Logs Key: FLINK-24201 URL: https://issues.apache.org/jira/browse/FLINK-24201 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-24202) BoundedSourceITCase hangs on azure

2021-09-07 Thread Xintong Song (Jira)
Xintong Song created FLINK-24202: Summary: BoundedSourceITCase hangs on azure Key: FLINK-24202 URL: https://issues.apache.org/jira/browse/FLINK-24202 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-24203) AbstractServerTest fails due to port conflict

2021-09-07 Thread Xintong Song (Jira)
Xintong Song created FLINK-24203: Summary: AbstractServerTest fails due to port conflict Key: FLINK-24203 URL: https://issues.apache.org/jira/browse/FLINK-24203 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-24204) Failed to insert nested types using value constructed functions

2021-09-07 Thread Jark Wu (Jira)
Jark Wu created FLINK-24204: --- Summary: Failed to insert nested types using value constructed functions Key: FLINK-24204 URL: https://issues.apache.org/jira/browse/FLINK-24204 Project: Flink Issue

[jira] [Created] (FLINK-24205) AggregateReduceGroupingITCase hangs on azure

2021-09-07 Thread Xintong Song (Jira)
Xintong Song created FLINK-24205: Summary: AggregateReduceGroupingITCase hangs on azure Key: FLINK-24205 URL: https://issues.apache.org/jira/browse/FLINK-24205 Project: Flink Issue Type: Bug

Re: [DISCUSS] FLIP-182: Watermark alignment

2021-09-07 Thread Arvid Heise
Just to clarify: I specifically asked Piotr to not persue the FLIP if the current state wouldn't make it in 1.14, such that someone else can take it over and expand it towards per-split alignment. Having a minimalistic version in 1.14 + amendment FLIP in 1.15 would have been fine but now I rather w

[jira] [Created] (FLINK-24206) PulsarSourceITCase fails with "Consumer not found"

2021-09-07 Thread Dawid Wysakowicz (Jira)
Dawid Wysakowicz created FLINK-24206: Summary: PulsarSourceITCase fails with "Consumer not found" Key: FLINK-24206 URL: https://issues.apache.org/jira/browse/FLINK-24206 Project: Flink Is