[jira] [Created] (FLINK-27150) Improve error reporting in Flink UI

Roman Khachatryan created FLINK-27150: - Summary: Improve error reporting in Flink UI Key: FLINK-27150 URL: https://issues.apache.org/jira/browse/FLINK-27150 Project: Flink Issue Type: Imp

[jira] [Created] (FLINK-27149) KafkaSourceE2ECase.testScaleUp failed on AZP

Roman Khachatryan created FLINK-27149: - Summary: KafkaSourceE2ECase.testScaleUp failed on AZP Key: FLINK-27149 URL: https://issues.apache.org/jira/browse/FLINK-27149 Project: Flink Issue

[jira] [Created] (FLINK-27148) UnalignedCheckpointITCase fails on AZP

Roman Khachatryan created FLINK-27148: - Summary: UnalignedCheckpointITCase fails on AZP Key: FLINK-27148 URL: https://issues.apache.org/jira/browse/FLINK-27148 Project: Flink Issue Type:

[jira] [Created] (FLINK-27147) Move DataStream's RequestReplyFunctionBuilder to use the netty client

Fil Karnicki created FLINK-27147: Summary: Move DataStream's RequestReplyFunctionBuilder to use the netty client Key: FLINK-27147 URL: https://issues.apache.org/jira/browse/FLINK-27147 Project: Flink

[jira] [Created] (FLINK-27146) [JUnit5 Migration] Module: flink-filesystems

Chesnay Schepler created FLINK-27146: Summary: [JUnit5 Migration] Module: flink-filesystems Key: FLINK-27146 URL: https://issues.apache.org/jira/browse/FLINK-27146 Project: Flink Issue Ty

[jira] [Created] (FLINK-27145) The code generated for agg function accepts empty parameters can't be compiled

luoyuxia created FLINK-27145: Summary: The code generated for agg function accepts empty parameters can't be compiled Key: FLINK-27145 URL: https://issues.apache.org/jira/browse/FLINK-27145 Project: Flink

[jira] [Created] (FLINK-27144) Provide timeout details when calling FutureUtils.orTimeout

Roman Khachatryan created FLINK-27144: - Summary: Provide timeout details when calling FutureUtils.orTimeout Key: FLINK-27144 URL: https://issues.apache.org/jira/browse/FLINK-27144 Project: Flink

[jira] [Created] (FLINK-27143) [JUnit5 Migration] Module: flink-docs

RocMarshal created FLINK-27143: -- Summary: [JUnit5 Migration] Module: flink-docs Key: FLINK-27143 URL: https://issues.apache.org/jira/browse/FLINK-27143 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-27142) Remove bash tests dependencies on the Elasticsearch connector.

Alexander Fedulov created FLINK-27142: - Summary: Remove bash tests dependencies on the Elasticsearch connector. Key: FLINK-27142 URL: https://issues.apache.org/jira/browse/FLINK-27142 Project: Fli

Re: Speeding up the test builds

I have checked and it looks like this change (increasing forkCount) gives a small improvement in the `test_ci_build core` module of 5-10 minutes. Let's maybe double check this after FLINK-26995 is merged. Best, Piotrek [1] https://issues.apache.org/jira/browse/FLINK-26995 czw., 31 mar 2022 o 16

[jira] [Created] (FLINK-27141) Improve FlinkService#waitForClusterShutdown logic

Gyula Fora created FLINK-27141: -- Summary: Improve FlinkService#waitForClusterShutdown logic Key: FLINK-27141 URL: https://issues.apache.org/jira/browse/FLINK-27141 Project: Flink Issue Type: Imp

[jira] [Created] (FLINK-27140) Move JobResultStore dirty entry creation into ioExecutor

Matthias Pohl created FLINK-27140: - Summary: Move JobResultStore dirty entry creation into ioExecutor Key: FLINK-27140 URL: https://issues.apache.org/jira/browse/FLINK-27140 Project: Flink Is

[jira] [Created] (FLINK-27139) FileStoreCommitImpl#filterCommitted should exit when faced with expired files

Caizhi Weng created FLINK-27139: --- Summary: FileStoreCommitImpl#filterCommitted should exit when faced with expired files Key: FLINK-27139 URL: https://issues.apache.org/jira/browse/FLINK-27139 Project:

[jira] [Created] (FLINK-27138) flink1.14.0-standalone部署-sql方式提交job-失败报错-提示不支持

yanbiao created FLINK-27138: --- Summary: flink1.14.0-standalone部署-sql方式提交job-失败报错-提示不支持 Key: FLINK-27138 URL: https://issues.apache.org/jira/browse/FLINK-27138 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-27137) Remove usage of AdminClient from KafkaSource logic

Gyula Fora created FLINK-27137: -- Summary: Remove usage of AdminClient from KafkaSource logic Key: FLINK-27137 URL: https://issues.apache.org/jira/browse/FLINK-27137 Project: Flink Issue Type: Im

[jira] [Created] (FLINK-27136) Disable rolling file when writing level 0 sst files

Caizhi Weng created FLINK-27136: --- Summary: Disable rolling file when writing level 0 sst files Key: FLINK-27136 URL: https://issues.apache.org/jira/browse/FLINK-27136 Project: Flink Issue Type:

[jira] [Created] (FLINK-27135) Rename 'file.path' table option in table store to 'path'

Caizhi Weng created FLINK-27135: --- Summary: Rename 'file.path' table option in table store to 'path' Key: FLINK-27135 URL: https://issues.apache.org/jira/browse/FLINK-27135 Project: Flink Issue

[jira] [Created] (FLINK-27134) OSS sink can't get access key id

Alex Z created FLINK-27134: -- Summary: OSS sink can't get access key id Key: FLINK-27134 URL: https://issues.apache.org/jira/browse/FLINK-27134 Project: Flink Issue Type: Bug Components: F

[jira] [Created] (FLINK-27133) Performance regression in serializerHeavyString

Piotr Nowojski created FLINK-27133: -- Summary: Performance regression in serializerHeavyString Key: FLINK-27133 URL: https://issues.apache.org/jira/browse/FLINK-27133 Project: Flink Issue Typ

[jira] [Created] (FLINK-27132) CheckpointResourcesCleanupRunner might discard shared state of the initial checkpoint

Roman Khachatryan created FLINK-27132: - Summary: CheckpointResourcesCleanupRunner might discard shared state of the initial checkpoint Key: FLINK-27132 URL: https://issues.apache.org/jira/browse/FLINK-27132