[jira] [Created] (FLINK-33765) Flink SQL to support COLLECTLIST

2023-12-06 Thread Zhenzhong Xu (Jira)
Zhenzhong Xu created FLINK-33765: Summary: Flink SQL to support COLLECTLIST Key: FLINK-33765 URL: https://issues.apache.org/jira/browse/FLINK-33765 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-7894) Improve metrics around fine-grained recovery and associated checkpointing behaviors

2017-10-20 Thread Zhenzhong Xu (JIRA)
Zhenzhong Xu created FLINK-7894: --- Summary: Improve metrics around fine-grained recovery and associated checkpointing behaviors Key: FLINK-7894 URL: https://issues.apache.org/jira/browse/FLINK-7894

[jira] [Created] (FLINK-7844) Fine Grained Recovery triggers checkpoint timeout failure

2017-10-15 Thread Zhenzhong Xu (JIRA)
Zhenzhong Xu created FLINK-7844: --- Summary: Fine Grained Recovery triggers checkpoint timeout failure Key: FLINK-7844 URL: https://issues.apache.org/jira/browse/FLINK-7844 Project: Flink Issue

[jira] [Created] (FLINK-7278) Flink job can stuck while ZK leader reelected during ZK cluster migration

2017-07-26 Thread Zhenzhong Xu (JIRA)
Zhenzhong Xu created FLINK-7278: --- Summary: Flink job can stuck while ZK leader reelected during ZK cluster migration Key: FLINK-7278 URL: https://issues.apache.org/jira/browse/FLINK-7278 Project:

[jira] [Created] (FLINK-6998) Kafka connector needs to expose metrics for failed/successful offset commits in the Kafka Consumer callback

2017-06-23 Thread Zhenzhong Xu (JIRA)
Zhenzhong Xu created FLINK-6998: --- Summary: Kafka connector needs to expose metrics for failed/successful offset commits in the Kafka Consumer callback Key: FLINK-6998 URL:

[jira] [Created] (FLINK-6923) Kafka connector needs to expose information about in-flight record in AbstractFetcher base class

2017-06-14 Thread Zhenzhong Xu (JIRA)
Zhenzhong Xu created FLINK-6923: --- Summary: Kafka connector needs to expose information about in-flight record in AbstractFetcher base class Key: FLINK-6923 URL: https://issues.apache.org/jira/browse/FLINK-6923

[jira] [Created] (FLINK-4820) Slf4j / log4j version upgrade to support dynamic change of log levels.

2016-10-12 Thread Zhenzhong Xu (JIRA)
Zhenzhong Xu created FLINK-4820: --- Summary: Slf4j / log4j version upgrade to support dynamic change of log levels. Key: FLINK-4820 URL: https://issues.apache.org/jira/browse/FLINK-4820 Project: Flink

[jira] [Created] (FLINK-4819) Checkpoint metadata+data inspection tool (view / update)

2016-10-12 Thread Zhenzhong Xu (JIRA)
Zhenzhong Xu created FLINK-4819: --- Summary: Checkpoint metadata+data inspection tool (view / update) Key: FLINK-4819 URL: https://issues.apache.org/jira/browse/FLINK-4819 Project: Flink Issue

[jira] [Created] (FLINK-4760) Kafka 09 Consumer failed to initialize state causing job to restart

2016-10-06 Thread Zhenzhong Xu (JIRA)
Zhenzhong Xu created FLINK-4760: --- Summary: Kafka 09 Consumer failed to initialize state causing job to restart Key: FLINK-4760 URL: https://issues.apache.org/jira/browse/FLINK-4760 Project: Flink

[jira] [Created] (FLINK-4660) HadoopFileSystem (with S3A) may leak connections, which cause job to stuck in a restarting loop

2016-09-21 Thread Zhenzhong Xu (JIRA)
Zhenzhong Xu created FLINK-4660: --- Summary: HadoopFileSystem (with S3A) may leak connections, which cause job to stuck in a restarting loop Key: FLINK-4660 URL: https://issues.apache.org/jira/browse/FLINK-4660

[jira] [Created] (FLINK-4545) Flink automatically manages TM network buffer

2016-08-31 Thread Zhenzhong Xu (JIRA)
Zhenzhong Xu created FLINK-4545: --- Summary: Flink automatically manages TM network buffer Key: FLINK-4545 URL: https://issues.apache.org/jira/browse/FLINK-4545 Project: Flink Issue Type: Wish

[jira] [Created] (FLINK-4372) Add ability to take savepoints from job manager web UI

2016-08-10 Thread Zhenzhong Xu (JIRA)
Zhenzhong Xu created FLINK-4372: --- Summary: Add ability to take savepoints from job manager web UI Key: FLINK-4372 URL: https://issues.apache.org/jira/browse/FLINK-4372 Project: Flink Issue

[jira] [Created] (FLINK-4371) Add ability to take savepoints from job manager RESTful API

2016-08-10 Thread Zhenzhong Xu (JIRA)
Zhenzhong Xu created FLINK-4371: --- Summary: Add ability to take savepoints from job manager RESTful API Key: FLINK-4371 URL: https://issues.apache.org/jira/browse/FLINK-4371 Project: Flink

[jira] [Created] (FLINK-4336) Expose ability to take a savepoint from job manager rest api

2016-08-08 Thread Zhenzhong Xu (JIRA)
Zhenzhong Xu created FLINK-4336: --- Summary: Expose ability to take a savepoint from job manager rest api Key: FLINK-4336 URL: https://issues.apache.org/jira/browse/FLINK-4336 Project: Flink

[jira] [Created] (FLINK-4335) Add jar id, and job parameters information to job status rest call

2016-08-08 Thread Zhenzhong Xu (JIRA)
Zhenzhong Xu created FLINK-4335: --- Summary: Add jar id, and job parameters information to job status rest call Key: FLINK-4335 URL: https://issues.apache.org/jira/browse/FLINK-4335 Project: Flink

[jira] [Created] (FLINK-4308) Allow uploaded jar directory to be configurable

2016-08-02 Thread Zhenzhong Xu (JIRA)
Zhenzhong Xu created FLINK-4308: --- Summary: Allow uploaded jar directory to be configurable Key: FLINK-4308 URL: https://issues.apache.org/jira/browse/FLINK-4308 Project: Flink Issue Type: