[jira] [Created] (FLINK-24541) ConfigurationUtils#assembleDynamicConfigsStr should consider special characters

Yangze Guo created FLINK-24541: -- Summary: ConfigurationUtils#assembleDynamicConfigsStr should consider special characters Key: FLINK-24541 URL: https://issues.apache.org/jira/browse/FLINK-24541 Project:

[jira] [Created] (FLINK-24540) Fix Resocue leak due to Files.list

lujie created FLINK-24540: - Summary: Fix Resocue leak due to Files.list Key: FLINK-24540 URL: https://issues.apache.org/jira/browse/FLINK-24540 Project: Flink Issue Type: Improvement Rep

[jira] [Created] (FLINK-24539) ChangelogNormalize operator tooks too long time to INITIALIZING until failed

vmaster.cc created FLINK-24539: -- Summary: ChangelogNormalize operator tooks too long time to INITIALIZING until failed Key: FLINK-24539 URL: https://issues.apache.org/jira/browse/FLINK-24539 Project: Fli

[DISCUSS] Over Aggregation add supports CURRENT_TIMESTAMP as the upper boundary in RANGE intervals .

In our scenario, it is often necessary to calculate the user's aggregated indicators in the most recent period of time. For example, if I need to calculate the user's recharge amount in the most recent day, I can do it through the following SQL code.

[jira] [Created] (FLINK-24538) ZooKeeperLeaderElectionTest.testLeaderShouldBeCorrectedWhenOverwritten fails with NPE

Xintong Song created FLINK-24538: Summary: ZooKeeperLeaderElectionTest.testLeaderShouldBeCorrectedWhenOverwritten fails with NPE Key: FLINK-24538 URL: https://issues.apache.org/jira/browse/FLINK-24538

[jira] [Created] (FLINK-24537) Array of rows containing constant strings of different length and an integer throws AssertionError

Caizhi Weng created FLINK-24537: --- Summary: Array of rows containing constant strings of different length and an integer throws AssertionError Key: FLINK-24537 URL: https://issues.apache.org/jira/browse/FLINK-24537

[jira] [Created] (FLINK-24536) flink sql where condition is not supported != writing

simenliuxing created FLINK-24536: Summary: flink sql where condition is not supported != writing Key: FLINK-24536 URL: https://issues.apache.org/jira/browse/FLINK-24536 Project: Flink Issue

[jira] [Created] (FLINK-24535) Update with the latest AWS Glue Schema Registry version

Linyu Yao created FLINK-24535: - Summary: Update with the latest AWS Glue Schema Registry version Key: FLINK-24535 URL: https://issues.apache.org/jira/browse/FLINK-24535 Project: Flink Issue Type:

[jira] [Created] (FLINK-24534) Set async based transport for remote functions default

Igal Shilman created FLINK-24534: Summary: Set async based transport for remote functions default Key: FLINK-24534 URL: https://issues.apache.org/jira/browse/FLINK-24534 Project: Flink Issue

[jira] [Created] (FLINK-24533) Flink SQL Upsert To Hbase Appear data loss

licp created FLINK-24533: Summary: Flink SQL Upsert To Hbase Appear data loss Key: FLINK-24533 URL: https://issues.apache.org/jira/browse/FLINK-24533 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-24532) Invalid deletions for time-versioned join with ChangelogNormalize

Timo Walther created FLINK-24532: Summary: Invalid deletions for time-versioned join with ChangelogNormalize Key: FLINK-24532 URL: https://issues.apache.org/jira/browse/FLINK-24532 Project: Flink

[jira] [Created] (FLINK-24531) CheckpointingTimeBenchmark can fail with connection timed out

Piotr Nowojski created FLINK-24531: -- Summary: CheckpointingTimeBenchmark can fail with connection timed out Key: FLINK-24531 URL: https://issues.apache.org/jira/browse/FLINK-24531 Project: Flink

[jira] [Created] (FLINK-24530) GlobalCommitter might not commit all records on drain

Fabian Paul created FLINK-24530: --- Summary: GlobalCommitter might not commit all records on drain Key: FLINK-24530 URL: https://issues.apache.org/jira/browse/FLINK-24530 Project: Flink Issue Typ