[jira] [Created] (FLINK-20436) Simplify type parameter of ExecNod

2020-12-01 Thread godfrey he (Jira)
godfrey he created FLINK-20436: -- Summary: Simplify type parameter of ExecNod Key: FLINK-20436 URL: https://issues.apache.org/jira/browse/FLINK-20436 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-20437) Port ExecNode to Java

2020-12-01 Thread godfrey he (Jira)
godfrey he created FLINK-20437: -- Summary: Port ExecNode to Java Key: FLINK-20437 URL: https://issues.apache.org/jira/browse/FLINK-20437 Project: Flink Issue Type: Sub-task Reporter:

[jira] [Created] (FLINK-20438) org.apache.flink.streaming.runtime.tasks.SystemProcessingTimeServiceTest fails due to missing output

2020-12-01 Thread Matthias (Jira)
Matthias created FLINK-20438: Summary: org.apache.flink.streaming.runtime.tasks.SystemProcessingTimeServiceTest fails due to missing output Key: FLINK-20438 URL: https://issues.apache.org/jira/browse/FLINK-20438

Re: [DISCUSS] Moving to JUnit5

2020-12-01 Thread Khachatryan Roman
+1 for the migration (I agree with Dawid, for me the most important benefit is better support of parameterized tests). Regards, Roman On Mon, Nov 30, 2020 at 9:42 PM Arvid Heise wrote: > Hi Till, > > immediate benefit would be mostly nested tests for a better test structure > and new paramete

[jira] [Created] (FLINK-20439) Consider simplifying or removing mechanism to scheduleOrUpdateConsumers

2020-12-01 Thread Zhu Zhu (Jira)
Zhu Zhu created FLINK-20439: --- Summary: Consider simplifying or removing mechanism to scheduleOrUpdateConsumers Key: FLINK-20439 URL: https://issues.apache.org/jira/browse/FLINK-20439 Project: Flink

[jira] [Created] (FLINK-20440) `LAST_VALUE` aggregate function can not be used in Hop window

2020-12-01 Thread zouyunhe (Jira)
zouyunhe created FLINK-20440: Summary: `LAST_VALUE` aggregate function can not be used in Hop window Key: FLINK-20440 URL: https://issues.apache.org/jira/browse/FLINK-20440 Project: Flink Issue

[jira] [Created] (FLINK-20441) Deprecate CheckpointConfig.setPreferCheckpointForRecovery

2020-12-01 Thread Till Rohrmann (Jira)
Till Rohrmann created FLINK-20441: - Summary: Deprecate CheckpointConfig.setPreferCheckpointForRecovery Key: FLINK-20441 URL: https://issues.apache.org/jira/browse/FLINK-20441 Project: Flink I

Re: [VOTE] Release 1.12.0, release candidate #2

2020-12-01 Thread Chesnay Schepler
-1 -The flink-python jar contains 2 license files in the root directory and another 2 in the META-INF directory. This should be reduced down to 1 under META-INF. I'm inclined to block the release on this because the root license is BSD. - The flink-python jar appears to bundle lz4 (native libr

[CANCELLED][VOTE] Release 1.12.0, release candidate #2

2020-12-01 Thread Robert Metzger
Thanks a lot for checking the release candidate so quickly. I agree that the BSD License file in the root of the jar is a red flag. I filed a ticket for addressing the issues Chesnay found: https://issues.apache.org/jira/browse/FLINK-20442 I'm hereby officially cancelling this release candidate.

[jira] [Created] (FLINK-20442) Fix license documentation mistakes in flink-python.jar

2020-12-01 Thread Robert Metzger (Jira)
Robert Metzger created FLINK-20442: -- Summary: Fix license documentation mistakes in flink-python.jar Key: FLINK-20442 URL: https://issues.apache.org/jira/browse/FLINK-20442 Project: Flink Is

[jira] [Created] (FLINK-20443) ContinuousProcessingTimeTrigger lost data in last interval in per window

2020-12-01 Thread Gee (Jira)
Gee created FLINK-20443: --- Summary: ContinuousProcessingTimeTrigger lost data in last interval in per window Key: FLINK-20443 URL: https://issues.apache.org/jira/browse/FLINK-20443 Project: Flink Issue

[jira] [Created] (FLINK-20444) Chain AsyncWaitOperator to new sources

2020-12-01 Thread Arvid Heise (Jira)
Arvid Heise created FLINK-20444: --- Summary: Chain AsyncWaitOperator to new sources Key: FLINK-20444 URL: https://issues.apache.org/jira/browse/FLINK-20444 Project: Flink Issue Type: Improvement

State Processor API SQL State

2020-12-01 Thread Dominik WosiƄski
Hey, Is it currently possible to obtain the state that was created by SQL query via the State Processor API? I am able to load the checkpoint via the State Processor API, but I wasn't able to think of a way to access the internal state of my JOIN Query. Best Regards, Dom.

[jira] [Created] (FLINK-20445) NoMatchingTableFactoryException

2020-12-01 Thread Ke Li (Jira)
Ke Li created FLINK-20445: - Summary: NoMatchingTableFactoryException Key: FLINK-20445 URL: https://issues.apache.org/jira/browse/FLINK-20445 Project: Flink Issue Type: Bug Components: Table

[jira] [Created] (FLINK-20446) NoMatchingTableFactoryException

2020-12-01 Thread Ke Li (Jira)
Ke Li created FLINK-20446: - Summary: NoMatchingTableFactoryException Key: FLINK-20446 URL: https://issues.apache.org/jira/browse/FLINK-20446 Project: Flink Issue Type: Bug Components: Table

[DISCUSS]Select Chinese words from table union all get java.lang.OutOfMemoryError: Java heap space on Flink 1.9.x with Blink planner

2020-12-01 Thread Smile
When using Flink 1.9.3 with Blink Planner, I tried to union some tables with Chinese constants and get an OutOfMemoryError of Java heap space. Here are the code and the error message. I turned to the old planner and it works. Then I upgraded Flink to 1.11.2 and it also works. Also, it does work wh

Re: [DISCUSS]Select Chinese words from table union all get java.lang.OutOfMemoryError: Java heap space on Flink 1.9.x with Blink planner

2020-12-01 Thread Smile
*Code in Flink 1.9.3:* import org.apache.flink.streaming.api.datastream.DataStream; import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment; import org.apache.flink.table.api.EnvironmentSettings; import org.apache.flink.table.api.Table; import org.apache.flink.table.api.java.St

[jira] [Created] (FLINK-20447) Querying grouy by PK does not work

2020-12-01 Thread Zhenwei Feng (Jira)
Zhenwei Feng created FLINK-20447: Summary: Querying grouy by PK does not work Key: FLINK-20447 URL: https://issues.apache.org/jira/browse/FLINK-20447 Project: Flink Issue Type: Improvement

Re: State Processor API SQL State

2020-12-01 Thread Yun Tang
Hi Dom, + user mail list Once you got to know the state descriptor, I think you could query the join state. The state name is easy to get via [1], it should be "left-records" and "right-records", and you could check what kind of join and whether has unique key to decide what kind of state (val

[jira] [Created] (FLINK-20448) Obsolete generated avro classes

2020-12-01 Thread Rui Li (Jira)
Rui Li created FLINK-20448: -- Summary: Obsolete generated avro classes Key: FLINK-20448 URL: https://issues.apache.org/jira/browse/FLINK-20448 Project: Flink Issue Type: Test Components: Fo

[jira] [Created] (FLINK-20449) UnalignedCheckpointITCase times out

2020-12-01 Thread Robert Metzger (Jira)
Robert Metzger created FLINK-20449: -- Summary: UnalignedCheckpointITCase times out Key: FLINK-20449 URL: https://issues.apache.org/jira/browse/FLINK-20449 Project: Flink Issue Type: Bug