[jira] [Created] (FLINK-20063) File Source requests an additional split on every restore.

Stephan Ewen created FLINK-20063: Summary: File Source requests an additional split on every restore. Key: FLINK-20063 URL: https://issues.apache.org/jira/browse/FLINK-20063 Project: Flink

Re: [DISCUSS] FLIP-151: Incremental snapshots for heap-based state backend

Hi, Very happy to see that the incremental checkpoint idea is finally becoming a reality for the heap backend! Overall the proposal looks pretty good to me. Just wanted to point out one possible improvement from what I can still remember from my ideas back then: I think you can avoid doing

[jira] [Created] (FLINK-20068) KafkaSubscriberTest.testTopicPatternSubscriber failed with unexpected results

Dian Fu created FLINK-20068: --- Summary: KafkaSubscriberTest.testTopicPatternSubscriber failed with unexpected results Key: FLINK-20068 URL: https://issues.apache.org/jira/browse/FLINK-20068 Project: Flink

[jira] [Created] (FLINK-20069) docs_404_check doesn't work properly

Dian Fu created FLINK-20069: --- Summary: docs_404_check doesn't work properly Key: FLINK-20069 URL: https://issues.apache.org/jira/browse/FLINK-20069 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-20066) BatchPandasUDAFITTests.test_group_aggregate_with_aux_group unstable

Dian Fu created FLINK-20066: --- Summary: BatchPandasUDAFITTests.test_group_aggregate_with_aux_group unstable Key: FLINK-20066 URL: https://issues.apache.org/jira/browse/FLINK-20066 Project: Flink

[jira] [Created] (FLINK-20067) "Resuming Savepoint (file, sync, scale up) end-to-end test" failed with "Could not stop with a savepoint job"

Dian Fu created FLINK-20067: --- Summary: "Resuming Savepoint (file, sync, scale up) end-to-end test" failed with "Could not stop with a savepoint job" Key: FLINK-20067 URL:

Re: [DISCUSS] Releasing Apache Flink 1.11.3

Hi Xintong, I want to bring one more issue to your attention [1]. The test case UnalignedCheckpointCompatibilityITCase.test failed several times in the last nightly test of release-1.11. We need to figure out if it's just an instable test or caused by recent changes. [1]

[jira] [Created] (FLINK-20064) Broken links in the documentation

Seth Wiesman created FLINK-20064: Summary: Broken links in the documentation Key: FLINK-20064 URL: https://issues.apache.org/jira/browse/FLINK-20064 Project: Flink Issue Type: Bug

Re: [reminder] Build and check the documentation when reviewing

Thanks for the reminder, Seth. The `check_links.sh` script is helpful, and I was not aware of it. Do you think it makes sense to also mention the script in `flink-docs/README.md`? So that future developers could also be aware of it. Or is it already mentioned somewhere that I overlooked? Thank

[jira] [Created] (FLINK-20065) UnalignedCheckpointCompatibilityITCase.test failed with AskTimeoutException

Dian Fu created FLINK-20065: --- Summary: UnalignedCheckpointCompatibilityITCase.test failed with AskTimeoutException Key: FLINK-20065 URL: https://issues.apache.org/jira/browse/FLINK-20065 Project: Flink

Re: [DISCUSS] Releasing Apache Flink 1.11.3

Thanks for the notice, Dian. Thank you~ Xintong Song On Tue, Nov 10, 2020 at 10:19 AM Dian Fu wrote: > Hi Xintong, > > I want to bring one more issue to your attention [1]. The test case > UnalignedCheckpointCompatibilityITCase.test failed several times in the > last nightly test of

Re: [VOTE] Adopt jemalloc as default memory allocator in docker image

Hi all, Currently there were 3 binding approvements, 2 non-binding approvements and there were no disapproving votes. Thus this vote has been accepted and thanks everyone for joining the discussion and giving feedback! Best Yun Tang From: Yun Tang Sent:

Re: [DISCUSS] Releasing Apache Flink 1.11.3

Thanks for the replies. Thank you~ Xintong Song On Tue, Nov 10, 2020 at 1:09 AM Becket Qin wrote: > Hi Xintong, > > Thanks for driving the release. Just want to sync up on the FLIP-27 > backporting. Stephan and I are still trying to backport a bunch of patches > of Source to 1.11.3.

[reminder] Build and check the documentation when reviewing

Hi Devs, First of all, I'd like to thank everyone for being more proactive about writing documentation along with their features. Compared to previous releases there is not so much last-minute documentation writing and that is something to be celebrated! That said, we are still beginning to see

[VOTE] FLIP-145: Support SQL windowing table-valued function (2nd)

Hi all, There is new feedback on the FLIP-145. So I would like to start a new vote for FLIP-145 [1], which has been discussed and reached consensus in the discussion thread [2]. The vote will be open until 15:00 (UTC+8) 13th Nov. (72h), unless there is an objection or not enough votes. Best,

Re: [reminder] Build and check the documentation when reviewing

Thanks @Robert for this info. It seems that there is some problem with the "docs_404_check". From the log we can see that the doc server wasn't started up after 5 minutes and the test just exits. Have created a ticket https://issues.apache.org/jira/browse/FLINK-20069

[jira] [Created] (FLINK-20070) NPE in SourceCoordinatorProviderTest.testCheckpointAndReset

godfrey he created FLINK-20070: -- Summary: NPE in SourceCoordinatorProviderTest.testCheckpointAndReset Key: FLINK-20070 URL: https://issues.apache.org/jira/browse/FLINK-20070 Project: Flink

Re: [reminder] Build and check the documentation when reviewing

Thanks a lot for the reminder, Seth. What about integrating this script in the azure pipeline? There is a "Documentation links check" in travis before: https://travis-ci.org/github/apache/flink/jobs/742553633 Thanks, Dian > 在

Re: [reminder] Build and check the documentation when reviewing

Thank you Seth! @Dian: It is part of the nightly scheduled build: https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=9361=logs=6dc02e5c-5865-5c6a-c6c5-92d598e3fc43 On Tue, Nov 10, 2020 at 2:50 AM Dian Fu wrote: > Thanks a lot for the reminder, Seth. > > What about

Re: [DISCUSS] Releasing Apache Flink 1.11.3

Thanks for the notice, Till. I just checked and found FLINK-20033 is already fixed. Shall we also downgrade FLINK-19816 to `Critical`? Thank you~ Xintong Song On Mon, Nov 9, 2020 at 4:42 PM Till Rohrmann wrote: > I would like to bring one more critical issue to your attention which is >

[jira] [Created] (FLINK-20056) Add collector to KinesisDeserializationSchema

Dawid Wysakowicz created FLINK-20056: Summary: Add collector to KinesisDeserializationSchema Key: FLINK-20056 URL: https://issues.apache.org/jira/browse/FLINK-20056 Project: Flink Issue

Re: [DISCUSS] Releasing Apache Flink 1.11.3

FLINK-20033 has been merged. Cheers, Till On Mon, Nov 9, 2020 at 9:39 AM Till Rohrmann wrote: > I would like to bring one more critical issue to your attention which is > FLINK-20033 [1]. I believe that this issue is actually causing what has > been reported in FLINK-19816 [2]. I hope to have

[jira] [Created] (FLINK-20058) Improve kafka per-partition-watermark tests

Shengkai Fang created FLINK-20058: - Summary: Improve kafka per-partition-watermark tests Key: FLINK-20058 URL: https://issues.apache.org/jira/browse/FLINK-20058 Project: Flink Issue Type:

Re: [VOTE] Adopt jemalloc as default memory allocator in docker image

+ 1 (binding) Best Yun Tang From: Ufuk Celebi Sent: Saturday, November 7, 2020 2:33 To: dev@flink.apache.org Subject: Re: [VOTE] Adopt jemalloc as default memory allocator in docker image +1 (binding) Thanks Yun for debugging and running the benchmarks. –

Re: [DISCUSS] Releasing Apache Flink 1.11.3

I would like to bring one more critical issue to your attention which is FLINK-20033 [1]. I believe that this issue is actually causing what has been reported in FLINK-19816 [2]. I hope to have it fixed by the end of today. Once FLINK-20033 is fixed, I think that we don't have to block the release

[jira] [Created] (FLINK-20060) Add a Collector to KinsesisDeserializationSchema

Timo Walther created FLINK-20060: Summary: Add a Collector to KinsesisDeserializationSchema Key: FLINK-20060 URL: https://issues.apache.org/jira/browse/FLINK-20060 Project: Flink Issue Type:

[jira] [Created] (FLINK-20059) Outdated SQL docs on aggregate functions' merge

Nico Kruber created FLINK-20059: --- Summary: Outdated SQL docs on aggregate functions' merge Key: FLINK-20059 URL: https://issues.apache.org/jira/browse/FLINK-20059 Project: Flink Issue Type:

[jira] [Created] (FLINK-20062) ContinuousHiveSplitEnumerator should be lock-free

Rui Li created FLINK-20062: -- Summary: ContinuousHiveSplitEnumerator should be lock-free Key: FLINK-20062 URL: https://issues.apache.org/jira/browse/FLINK-20062 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-20061) Row constructor unsupported in aggregation function

Nico Kruber created FLINK-20061: --- Summary: Row constructor unsupported in aggregation function Key: FLINK-20061 URL: https://issues.apache.org/jira/browse/FLINK-20061 Project: Flink Issue

[ANNOUNCE] Apache Flink 1.12.0, release candidate #1

Hi all, The RC1 for Apache Flink 1.12.0 has been created. This is still a preview-only release candidate to drive the current testing efforts and so no official votes will take place. It has all the artifacts that we would typically have for a release, except for the release note and the

Re: [DISCUSS] FLIP-145: Support SQL windowing table-valued function

Hi Jark, thanks for the deep investigation and communication with Calcite and Beam folks. Given the new findings, +1 to vote. Regards, Timo On 09.11.20 05:22, Jark Wu wrote: Hi all, After some offline discussion and investigation with Timo and Danny, I have updated the FLIP-145.

Re: [DISCUSS] Releasing Apache Flink 1.11.3

Yes, I've downgraded FLINK-19816 to critical. Cheers, Till On Mon, Nov 9, 2020 at 10:19 AM Xintong Song wrote: > Thanks for the notice, Till. > > I just checked and found FLINK-20033 is already fixed. Shall we also > downgrade FLINK-19816 to `Critical`? > > Thank you~ > > Xintong Song > > > >

Re: [DISCUSS] Planning the 1.12 release testing

Hi all, We've just published the first release candidate for Flink 1.12. This means we can start with the testing efforts! Let's use the Wiki page to coordinate our testing efforts. *As a tester,* please pick a topic from the table, and put your name into the "Tested by" column, including the

Re: [DISCUSS] Releasing Apache Flink 1.11.3

Hi Xintong, Thanks for driving the release. Just want to sync up on the FLIP-27 backporting. Stephan and I are still trying to backport a bunch of patches of Source to 1.11.3. Including: [FLINK-19698][connector/common] Add a close() method to the SplitReader. [FLINK-19717]