[jira] [Created] (FLINK-22063) Lookup Join outputs wrong results for some scenario

2021-03-31 Thread Shuo Cheng (Jira)
Shuo Cheng created FLINK-22063: -- Summary: Lookup Join outputs wrong results for some scenario Key: FLINK-22063 URL: https://issues.apache.org/jira/browse/FLINK-22063 Project: Flink Issue Type: N

Re: flink 1.11 class loading question

2021-03-31 Thread Till Rohrmann
Hi Chen, with version 1.10 Flink introduced that RocksDB uses Flink's managed memory [1]. This shall prevent RocksDB from exceeding the memory limits of a process/container. Unfortunately, this is not yet perfect due to a problem in RocksDB [2]. Due to this fact, RocksDB can still exceed the manag

Re: Flink job cannot find recover path after using entropy injection for s3 file systems

2021-03-31 Thread Till Rohrmann
Thanks for creating this PR. I think it would be good to re-open the issue and post your analysis there together with the proposal for the fix. Cheers, Till On Wed, Mar 31, 2021 at 3:41 AM chenqin wrote: > link fix pr here https://github.com/apache/flink/pull/15442 > we might need someone help

[jira] [Created] (FLINK-22064) Don't submit statement set when no insert is added in the sql client

2021-03-31 Thread Shengkai Fang (Jira)
Shengkai Fang created FLINK-22064: - Summary: Don't submit statement set when no insert is added in the sql client Key: FLINK-22064 URL: https://issues.apache.org/jira/browse/FLINK-22064 Project: Flin

[jira] [Created] (FLINK-22065) Beautify the parse error exception when input invalid command in the sql client

2021-03-31 Thread Shengkai Fang (Jira)
Shengkai Fang created FLINK-22065: - Summary: Beautify the parse error exception when input invalid command in the sql client Key: FLINK-22065 URL: https://issues.apache.org/jira/browse/FLINK-22065 Pro

[jira] [Created] (FLINK-22066) Improve Error Message on unknown Ingress Type

2021-03-31 Thread Konstantin Knauf (Jira)
Konstantin Knauf created FLINK-22066: Summary: Improve Error Message on unknown Ingress Type Key: FLINK-22066 URL: https://issues.apache.org/jira/browse/FLINK-22066 Project: Flink Issue T

Re: [DISCUSS] Feature freeze date for 1.13

2021-03-31 Thread Guowei Ma
Hi, community: Friendly reminder that today (3.31) is the last day of feature development. Under normal circumstances, you will not be able to submit new features from tomorrow (4.1). Tomorrow we will create 1.13.0-rc0 for testing, welcome to help test together. After the test is relatively stable

[jira] [Created] (FLINK-22067) SavepointWindowReaderITCase.testApplyEvictorWindowStateReader

2021-03-31 Thread Till Rohrmann (Jira)
Till Rohrmann created FLINK-22067: - Summary: SavepointWindowReaderITCase.testApplyEvictorWindowStateReader Key: FLINK-22067 URL: https://issues.apache.org/jira/browse/FLINK-22067 Project: Flink

[jira] [Created] (FLINK-22068) FlinkKinesisConsumerTest.testPeriodicWatermark fails on azure

2021-03-31 Thread Dawid Wysakowicz (Jira)
Dawid Wysakowicz created FLINK-22068: Summary: FlinkKinesisConsumerTest.testPeriodicWatermark fails on azure Key: FLINK-22068 URL: https://issues.apache.org/jira/browse/FLINK-22068 Project: Flink

[jira] [Created] (FLINK-22069) Check Log Pollution for 1.13 release

2021-03-31 Thread Stephan Ewen (Jira)
Stephan Ewen created FLINK-22069: Summary: Check Log Pollution for 1.13 release Key: FLINK-22069 URL: https://issues.apache.org/jira/browse/FLINK-22069 Project: Flink Issue Type: Bug

[VOTE] Release flink-shaded 13.0, release candidate #0

2021-03-31 Thread Chesnay Schepler
Hi everyone, Please review and vote on the release candidate #1 for the version 13.0, as follows: [ ] +1, Approve the release [ ] -1, Do not approve the release (please provide specific comments) The complete staging area is available for your review, which includes: * JIRA release notes [1],

Re: [VOTE] Release flink-shaded 13.0, release candidate #0

2021-03-31 Thread Dawid Wysakowicz
+1 - Checked diffs between 1.12 and 1.11: https://github.com/apache/flink-shaded/compare/release-12.0...release-13.0-rc1 - reviewed the website PR - verified release notes and that the release contain the changes -

[jira] [Created] (FLINK-22070) Support FileSink in PyFlink DataStream API

2021-03-31 Thread Dian Fu (Jira)
Dian Fu created FLINK-22070: --- Summary: Support FileSink in PyFlink DataStream API Key: FLINK-22070 URL: https://issues.apache.org/jira/browse/FLINK-22070 Project: Flink Issue Type: Sub-task

Re: [VOTE] Apache Flink Stateful Functions 3.0.0, release candidate #1

2021-03-31 Thread Igal Shilman
Thanks Gordon for managing the release! +1 (non binding) from my side: Here are the results of my testing: - verified the signatures - verified that the source distribution doesn't contain any binary files - ran mvn clean install -Prun-e2e-tests with java8 - ran the smoke test that sends 100 mill

[jira] [Created] (FLINK-22071) LookupTableSource.LookupRuntimeProvider customizes parallelism

2021-03-31 Thread Wong Mulan (Jira)
Wong Mulan created FLINK-22071: -- Summary: LookupTableSource.LookupRuntimeProvider customizes parallelism Key: FLINK-22071 URL: https://issues.apache.org/jira/browse/FLINK-22071 Project: Flink I

[jira] [Created] (FLINK-22072) Rethink UnfulfillableSlotRequestException class hierarchy

2021-03-31 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-22072: Summary: Rethink UnfulfillableSlotRequestException class hierarchy Key: FLINK-22072 URL: https://issues.apache.org/jira/browse/FLINK-22072 Project: Flink

[jira] [Created] (FLINK-22073) ParquetFileCompactionITCase fails on Azure

2021-03-31 Thread Dawid Wysakowicz (Jira)
Dawid Wysakowicz created FLINK-22073: Summary: ParquetFileCompactionITCase fails on Azure Key: FLINK-22073 URL: https://issues.apache.org/jira/browse/FLINK-22073 Project: Flink Issue Type

Apply external 3 days for FLINK-20387 after feature freeze

2021-03-31 Thread Leonard Xu
Hi, Dawid & Guowei Sorry to apply the extension, I want to apply 3 days for ticket [FLINK-20387] Support column of TIMESTAMP WITH LOCAL ZONE TIME type as rowtime[1], it is the last ticket of FLIP-162[2] which aims to solve various time zone issues and offer a consistent time function behavio

[jira] [Created] (FLINK-22074) testRequirementCheckOnlyTriggeredOnce(org.apache.flink.runtime.resourcemanager.slotmanager.FineGrainedSlotManagerTest) failed

2021-03-31 Thread Leonard Xu (Jira)
Leonard Xu created FLINK-22074: -- Summary: testRequirementCheckOnlyTriggeredOnce(org.apache.flink.runtime.resourcemanager.slotmanager.FineGrainedSlotManagerTest) failed Key: FLINK-22074 URL: https://issues.apache.org

[jira] [Created] (FLINK-22075) Incorrect null outputs in left join

2021-03-31 Thread Jamie Brandon (Jira)
Jamie Brandon created FLINK-22075: - Summary: Incorrect null outputs in left join Key: FLINK-22075 URL: https://issues.apache.org/jira/browse/FLINK-22075 Project: Flink Issue Type: Bug

Re: Apply external 3 days for FLINK-20387 after feature freeze

2021-03-31 Thread Timo Walther
Hi everyone, I support Leonard's request. It was foreseeable that the changes of FLIP-162 will be massive and will take some time. By looking at PRs such as https://github.com/apache/flink/pull/15280 I would also vote for giving a bit more time for proper reviews and finalizing this story fo

1

2021-03-31 Thread 醉时无梦生
1

Re: Apply external 3 days for FLINK-20387 after feature freeze

2021-03-31 Thread Jark Wu
+1 for more days for this FLIP. Changing data type is a massive work, and supporting windowing on timestamp_ltz is also a very complex job when considering DST. Would be great if we can have more days to finalize this work. Best, Jark On Thu, 1 Apr 2021 at 03:46, Timo Walther wrote: > Hi ever

[jira] [Created] (FLINK-22076) Python Test failed with "OSError: [Errno 12] Cannot allocate memory"

2021-03-31 Thread Huang Xingbo (Jira)
Huang Xingbo created FLINK-22076: Summary: Python Test failed with "OSError: [Errno 12] Cannot allocate memory" Key: FLINK-22076 URL: https://issues.apache.org/jira/browse/FLINK-22076 Project: Flink

[jira] [Created] (FLINK-22077) Wrong way to calculate cross-region ConsumedPartitionGroups in PipelinedRegionSchedulingStrategy

2021-03-31 Thread Zhilong Hong (Jira)
Zhilong Hong created FLINK-22077: Summary: Wrong way to calculate cross-region ConsumedPartitionGroups in PipelinedRegionSchedulingStrategy Key: FLINK-22077 URL: https://issues.apache.org/jira/browse/FLINK-22077

[jira] [Created] (FLINK-22078) Introduce a Printer interface to rederict the output to the desired stream

2021-03-31 Thread Shengkai Fang (Jira)
Shengkai Fang created FLINK-22078: - Summary: Introduce a Printer interface to rederict the output to the desired stream Key: FLINK-22078 URL: https://issues.apache.org/jira/browse/FLINK-22078 Project:

[jira] [Created] (FLINK-22079) ReactiveModeITCase stack with fine grained resource manager.

2021-03-31 Thread Xintong Song (Jira)
Xintong Song created FLINK-22079: Summary: ReactiveModeITCase stack with fine grained resource manager. Key: FLINK-22079 URL: https://issues.apache.org/jira/browse/FLINK-22079 Project: Flink

Re: [DISCUSS] Feature freeze date for 1.13

2021-03-31 Thread Kurt Young
Hi Guowei and Dawid, I want to request the permission to merge this feature [1], it's a useful improvement to sql client and won't affect other components too much. We were plan to merge it yesterday but met some tricky multi-process issue which has a very high possibility hanging the tests. It to

[jira] [Created] (FLINK-22080) Refactor SqlClient for better testing

2021-03-31 Thread Jark Wu (Jira)
Jark Wu created FLINK-22080: --- Summary: Refactor SqlClient for better testing Key: FLINK-22080 URL: https://issues.apache.org/jira/browse/FLINK-22080 Project: Flink Issue Type: Improvement

Re: [VOTE] Apache Flink Stateful Functions 3.0.0, release candidate #1

2021-03-31 Thread Tzu-Li (Gordon) Tai
+1 (binding) - verified signatures and hashes - NOTICE and LICENSE files in statefun-flink-distribution, statefun-protobuf-shaded, and statefun-sdk-java looks sane - maven clean install -Prun-e2e-tests (java 8) from source - ran all examples and tutorials in apache/flink-statefun-playground with t

[jira] [Created] (FLINK-22081) Entropy key not resolved if flink-s3-fs-hadoop is added as a plugin

2021-03-31 Thread Chen Qin (Jira)
Chen Qin created FLINK-22081: Summary: Entropy key not resolved if flink-s3-fs-hadoop is added as a plugin Key: FLINK-22081 URL: https://issues.apache.org/jira/browse/FLINK-22081 Project: Flink

[jira] [Created] (FLINK-22082) Nested projection push down doesn't work for data: row(array(row))

2021-03-31 Thread Dian Fu (Jira)
Dian Fu created FLINK-22082: --- Summary: Nested projection push down doesn't work for data: row(array(row)) Key: FLINK-22082 URL: https://issues.apache.org/jira/browse/FLINK-22082 Project: Flink Iss

Re: [DISCUSS] Feature freeze date for 1.13

2021-03-31 Thread Arvid Heise
Hi Dawid and Guowei, I'd like to merge [FLINK-13550][rest][ui] Vertex Flame Graph [1]. We are pretty much just waiting for AZP to turn green, it's separate from other components, and it's a super useful feature for Flink users. Best, Arvid [1] https://github.com/apache/flink/pull/15054 On Thu,

Re: [DISCUSS] Feature freeze date for 1.13

2021-03-31 Thread Dawid Wysakowicz
Hi all, @Kurt @Arvid I think it's fine to merge those two, as they are pretty much finished. We can wait for those two before creating the RC0. @Leonard Personally I'd be ok with 3 more days for that single PR. I find the request reasonable and I second that it's better to have a proper review ra

退订

2021-03-31 Thread Chouchou Mei
退订