[jira] [Created] (FLINK-22448) FlinkRexUtil create Sarg String array elemet supplement space

2021-04-25 Thread Junning Liang (Jira)
Junning Liang created FLINK-22448: - Summary: FlinkRexUtil create Sarg String array elemet supplement space Key: FLINK-22448 URL: https://issues.apache.org/jira/browse/FLINK-22448 Project: Flink

[jira] [Created] (FLINK-22449) Casting an invalid constant string to int throws exception from SinkNotNullEnforcer

2021-04-25 Thread Caizhi Weng (Jira)
Caizhi Weng created FLINK-22449: --- Summary: Casting an invalid constant string to int throws exception from SinkNotNullEnforcer Key: FLINK-22449 URL: https://issues.apache.org/jira/browse/FLINK-22449 Pro

[jira] [Created] (FLINK-22450) SQL parser fails to parse subquery containing INTERSECT in a view

2021-04-25 Thread Caizhi Weng (Jira)
Caizhi Weng created FLINK-22450: --- Summary: SQL parser fails to parse subquery containing INTERSECT in a view Key: FLINK-22450 URL: https://issues.apache.org/jira/browse/FLINK-22450 Project: Flink

[jira] [Created] (FLINK-22451) Support (*) as parameter of table UserDefinedFunction

2021-04-25 Thread Yi Tang (Jira)
Yi Tang created FLINK-22451: --- Summary: Support (*) as parameter of table UserDefinedFunction Key: FLINK-22451 URL: https://issues.apache.org/jira/browse/FLINK-22451 Project: Flink Issue Type: Impr

[jira] [Created] (FLINK-22452) Support specifying custom transactional.id prefix in FlinkKafkaProducer

2021-04-25 Thread Wenhao Ji (Jira)
Wenhao Ji created FLINK-22452: - Summary: Support specifying custom transactional.id prefix in FlinkKafkaProducer Key: FLINK-22452 URL: https://issues.apache.org/jira/browse/FLINK-22452 Project: Flink

[jira] [Created] (FLINK-22453) Can not stop job when not ust "-m" option

2021-04-25 Thread Liu (Jira)
Liu created FLINK-22453: --- Summary: Can not stop job when not ust "-m" option Key: FLINK-22453 URL: https://issues.apache.org/jira/browse/FLINK-22453 Project: Flink Issue Type: Bug Components:

[jira] [Created] (FLINK-22454) Ignore CAST condition in temporal join

2021-04-25 Thread Shengkai Fang (Jira)
Shengkai Fang created FLINK-22454: - Summary: Ignore CAST condition in temporal join Key: FLINK-22454 URL: https://issues.apache.org/jira/browse/FLINK-22454 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-22455) FlinkRelBuilder#windowAggregate will throw ClassCastException when function reuse

2021-04-25 Thread tartarus (Jira)
tartarus created FLINK-22455: Summary: FlinkRelBuilder#windowAggregate will throw ClassCastException when function reuse Key: FLINK-22455 URL: https://issues.apache.org/jira/browse/FLINK-22455 Project: Fl

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

2021-04-25 Thread Jark Wu
Hi Rui, Documentation is not a part of the release package. The changes to the documentation will take effect in 24 hours and can be accessed on the web [1] then. Docs can even be updated after 1.13 is released. So we don't need to cancel the RC for this. Best, Jark [1]: https://ci.apache.org/p

Re: [DISCUSS]FLIP-150: Introduce Hybrid Source

2021-04-25 Thread Thomas Weise
Hi Becket, I agree and am not planning to hard wire a specific combination of sources (like S3 + Kafka). That also wouldn't help for the use case I want to address, because there are customized connectors that we need to be able to plug in. Rather, the suggested simplification would be for the fl

Re: [DISCUSS]FLIP-150: Introduce Hybrid Source

2021-04-25 Thread Becket Qin
Thanks for the clarification, Thomas. Yes, that makes sense to me. Cheers, Jiangjie (Becket) Qin On Mon, Apr 26, 2021 at 1:03 AM Thomas Weise wrote: > Hi Becket, > > I agree and am not planning to hard wire a specific combination of > sources (like S3 + Kafka). That also wouldn't help for the

[jira] [Created] (FLINK-22456) Support InitializeOnMaster and FinalizeOnMaster to be used in InputFormat

2021-04-25 Thread Li (Jira)
Li created FLINK-22456: -- Summary: Support InitializeOnMaster and FinalizeOnMaster to be used in InputFormat Key: FLINK-22456 URL: https://issues.apache.org/jira/browse/FLINK-22456 Project: Flink Issue

[jira] [Created] (FLINK-22457) KafkaSourceLegacyITCase.testMultipleSourcesOnePartition fails because of timeout

2021-04-25 Thread Guowei Ma (Jira)
Guowei Ma created FLINK-22457: - Summary: KafkaSourceLegacyITCase.testMultipleSourcesOnePartition fails because of timeout Key: FLINK-22457 URL: https://issues.apache.org/jira/browse/FLINK-22457 Project: F

[jira] [Created] (FLINK-22458) Failed when operating empty catalog table

2021-04-25 Thread Spongebob (Jira)
Spongebob created FLINK-22458: - Summary: Failed when operating empty catalog table Key: FLINK-22458 URL: https://issues.apache.org/jira/browse/FLINK-22458 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-22459) FlinkKafkaProducerITCase testScaleUpAfterScalingDown failed because of Timeout expired after 60000milliseconds while awaiting EndTxn(COMMIT)

2021-04-25 Thread Guowei Ma (Jira)
Guowei Ma created FLINK-22459: - Summary: FlinkKafkaProducerITCase testScaleUpAfterScalingDown failed because of Timeout expired after 6milliseconds while awaiting EndTxn(COMMIT) Key: FLINK-22459 URL: https://issu

[jira] [Created] (FLINK-22460) Conversion to relational algebra failed caused by ''

2021-04-25 Thread Haiwei Zhou (Jira)
Haiwei Zhou created FLINK-22460: --- Summary: Conversion to relational algebra failed caused by '' Key: FLINK-22460 URL: https://issues.apache.org/jira/browse/FLINK-22460 Project: Flink Issue Type

[jira] [Created] (FLINK-22461) Resuming Savepoint (file, async, scale down) end-to-end test failed because of binding port fail

2021-04-25 Thread Guowei Ma (Jira)
Guowei Ma created FLINK-22461: - Summary: Resuming Savepoint (file, async, scale down) end-to-end test failed because of binding port fail Key: FLINK-22461 URL: https://issues.apache.org/jira/browse/FLINK-22461

Re: [VOTE] Release 1.12.3, release candidate #1

2021-04-25 Thread Dian Fu
+1 (binding) - Verified the checksum and signature - Reviewed the website PR and have left a few comments - Installed PyFlink with the source package on Mac OS and everything works well - Ran a PyFlink example which uses both Python Table API and Python DataStream API Regards, Dian > 2021年4月24日

[jira] [Created] (FLINK-22462) JdbcExactlyOnceSinkE2eTest.testInsert failed because of too many clients.

2021-04-25 Thread Guowei Ma (Jira)
Guowei Ma created FLINK-22462: - Summary: JdbcExactlyOnceSinkE2eTest.testInsert failed because of too many clients. Key: FLINK-22462 URL: https://issues.apache.org/jira/browse/FLINK-22462 Project: Flink

[jira] [Created] (FLINK-22463) IllegalArgumentException is thrown in WindowAttachedWindowingStrategy when two phase is enabled for distinct agg

2021-04-25 Thread godfrey he (Jira)
godfrey he created FLINK-22463: -- Summary: IllegalArgumentException is thrown in WindowAttachedWindowingStrategy when two phase is enabled for distinct agg Key: FLINK-22463 URL: https://issues.apache.org/jira/browse/F

[jira] [Created] (FLINK-22464) OperatorEventSendingCheckpointITCase.testOperatorEventLostWithReaderFailure hangs with `AdaptiveScheduler`

2021-04-25 Thread Guowei Ma (Jira)
Guowei Ma created FLINK-22464: - Summary: OperatorEventSendingCheckpointITCase.testOperatorEventLostWithReaderFailure hangs with `AdaptiveScheduler` Key: FLINK-22464 URL: https://issues.apache.org/jira/browse/FLINK-22

[jira] [Created] (FLINK-22465) KafkaSourceITCase.testValueOnlyDeserializer hangs

2021-04-25 Thread Guowei Ma (Jira)
Guowei Ma created FLINK-22465: - Summary: KafkaSourceITCase.testValueOnlyDeserializer hangs Key: FLINK-22465 URL: https://issues.apache.org/jira/browse/FLINK-22465 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-22466) KafkaSourceLegacyITCase.testOneToOneSources fail because the OperatorEvent lost

2021-04-25 Thread Guowei Ma (Jira)
Guowei Ma created FLINK-22466: - Summary: KafkaSourceLegacyITCase.testOneToOneSources fail because the OperatorEvent lost Key: FLINK-22466 URL: https://issues.apache.org/jira/browse/FLINK-22466 Project: Fl

[jira] [Created] (FLINK-22467) OverAggregateITCase.testRowNumberOnOver is unstable

2021-04-25 Thread Jingsong Lee (Jira)
Jingsong Lee created FLINK-22467: Summary: OverAggregateITCase.testRowNumberOnOver is unstable Key: FLINK-22467 URL: https://issues.apache.org/jira/browse/FLINK-22467 Project: Flink Issue Typ

[jira] [Created] (FLINK-22468) Make StateFun build with Java 11

2021-04-25 Thread Tzu-Li (Gordon) Tai (Jira)
Tzu-Li (Gordon) Tai created FLINK-22468: --- Summary: Make StateFun build with Java 11 Key: FLINK-22468 URL: https://issues.apache.org/jira/browse/FLINK-22468 Project: Flink Issue Type: Ta

[jira] [Created] (FLINK-22469) HistoryServer starts with NoSuchFileException

2021-04-25 Thread Gabor Somogyi (Jira)
Gabor Somogyi created FLINK-22469: - Summary: HistoryServer starts with NoSuchFileException Key: FLINK-22469 URL: https://issues.apache.org/jira/browse/FLINK-22469 Project: Flink Issue Type: B

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

2021-04-25 Thread Rui Li
I see. Thanks Jark for the clarification. On Sun, Apr 25, 2021 at 10:36 PM Jark Wu wrote: > Hi Rui, > > Documentation is not a part of the release package. > The changes to the documentation will take effect in 24 hours > and can be accessed on the web [1] then. > Docs can even be updated after

Re: when should `FlinkYarnSessionCli` be included for parsing CLI arguments?

2021-04-25 Thread Yangze Guo
Hi, Tony. What is the version of your flink-dist. AFAIK, this issue should be addressed in FLINK-15852[1]. Could you give the client log of case 2(set the log level to DEBUG would be better). [1] https://issues.apache.org/jira/browse/FLINK-15852 Best, Yangze Guo On Sun, Apr 25, 2021 at 11:33 AM