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

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

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

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:

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

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

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

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:

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

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-22462) JdbcExactlyOnceSinkE2eTest.testInsert failed because of too many clients.

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-22458) Failed when operating empty catalog table

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-22457) KafkaSourceLegacyITCase.testMultipleSourcesOnePartition fails because of timeout

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:

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

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

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

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

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

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

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

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-22453) Can not stop job when not ust "-m" option

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

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

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-22451) Support (*) as parameter of table UserDefinedFunction

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:

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

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-22449) Casting an invalid constant string to int throws exception from SinkNotNullEnforcer

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

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

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-22447) when job failed and restore from rocksdb, it produced a exception "Could not load the native RocksDB library"

zlzhang0122 created FLINK-22447: --- Summary: when job failed and restore from rocksdb, it produced a exception "Could not load the native RocksDB library" Key: FLINK-22447 URL:

[jira] [Created] (FLINK-22446) Relocate dependencies in hive connector uber jar

Rui Li created FLINK-22446: -- Summary: Relocate dependencies in hive connector uber jar Key: FLINK-22446 URL: https://issues.apache.org/jira/browse/FLINK-22446 Project: Flink Issue Type: Task