[jira] [Created] (FLINK-35384) Expose metrics group to custom Partitioner

2024-05-16 Thread Steven Zhen Wu (Jira)
Steven Zhen Wu created FLINK-35384: -- Summary: Expose metrics group to custom Partitioner Key: FLINK-35384 URL: https://issues.apache.org/jira/browse/FLINK-35384 Project: Flink Issue Type: Im

[jira] [Created] (FLINK-30035) ./bin/sql-client.sh won't import external jar into the session

2022-11-15 Thread Steven Zhen Wu (Jira)
Steven Zhen Wu created FLINK-30035: -- Summary: ./bin/sql-client.sh won't import external jar into the session Key: FLINK-30035 URL: https://issues.apache.org/jira/browse/FLINK-30035 Project: Flink

[jira] [Created] (FLINK-27101) Periodically break the chain of incremental checkpoint

2022-04-06 Thread Steven Zhen Wu (Jira)
Steven Zhen Wu created FLINK-27101: -- Summary: Periodically break the chain of incremental checkpoint Key: FLINK-27101 URL: https://issues.apache.org/jira/browse/FLINK-27101 Project: Flink Is

[jira] [Created] (FLINK-21364) piggyback finishedSplitIds in RequestSplitEvent

2021-02-11 Thread Steven Zhen Wu (Jira)
Steven Zhen Wu created FLINK-21364: -- Summary: piggyback finishedSplitIds in RequestSplitEvent Key: FLINK-21364 URL: https://issues.apache.org/jira/browse/FLINK-21364 Project: Flink Issue Typ

[jira] [Created] (FLINK-21000) set MetricGroup in SourceCoordinatorContext

2021-01-16 Thread Steven Zhen Wu (Jira)
Steven Zhen Wu created FLINK-21000: -- Summary: set MetricGroup in SourceCoordinatorContext Key: FLINK-21000 URL: https://issues.apache.org/jira/browse/FLINK-21000 Project: Flink Issue Type: B

[jira] [Created] (FLINK-20871) Make DataStream#executeAndCollectWithClient public

2021-01-06 Thread Steven Zhen Wu (Jira)
Steven Zhen Wu created FLINK-20871: -- Summary: Make DataStream#executeAndCollectWithClient public Key: FLINK-20871 URL: https://issues.apache.org/jira/browse/FLINK-20871 Project: Flink Issue

[jira] [Created] (FLINK-20174) Make BulkFormat more extensible

2020-11-16 Thread Steven Zhen Wu (Jira)
Steven Zhen Wu created FLINK-20174: -- Summary: Make BulkFormat more extensible Key: FLINK-20174 URL: https://issues.apache.org/jira/browse/FLINK-20174 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-19934) [FLIP-27 source] add new API: SplitEnumeratorContext.execute(Runnable)

2020-11-02 Thread Steven Zhen Wu (Jira)
Steven Zhen Wu created FLINK-19934: -- Summary: [FLIP-27 source] add new API: SplitEnumeratorContext.execute(Runnable) Key: FLINK-19934 URL: https://issues.apache.org/jira/browse/FLINK-19934 Project: F

[jira] [Created] (FLINK-19816) Flink restored from a wrong checkpoint (a very old one and not the last completed one)

2020-10-26 Thread Steven Zhen Wu (Jira)
Steven Zhen Wu created FLINK-19816: -- Summary: Flink restored from a wrong checkpoint (a very old one and not the last completed one) Key: FLINK-19816 URL: https://issues.apache.org/jira/browse/FLINK-19816

[jira] [Created] (FLINK-19401) Job stuck in restart loop due to "Could not find registered job manager"

2020-09-24 Thread Steven Zhen Wu (Jira)
Steven Zhen Wu created FLINK-19401: -- Summary: Job stuck in restart loop due to "Could not find registered job manager" Key: FLINK-19401 URL: https://issues.apache.org/jira/browse/FLINK-19401 Project:

[jira] [Created] (FLINK-18572) Flink web UI doesn't display unaligned checkpoint config

2020-07-12 Thread Steven Zhen Wu (Jira)
Steven Zhen Wu created FLINK-18572: -- Summary: Flink web UI doesn't display unaligned checkpoint config Key: FLINK-18572 URL: https://issues.apache.org/jira/browse/FLINK-18572 Project: Flink

[jira] [Created] (FLINK-18353) [1.11.0] maybe document jobmanager behavior change regarding -XX:MaxDirectMemorySize

2020-06-17 Thread Steven Zhen Wu (Jira)
Steven Zhen Wu created FLINK-18353: -- Summary: [1.11.0] maybe document jobmanager behavior change regarding -XX:MaxDirectMemorySize Key: FLINK-18353 URL: https://issues.apache.org/jira/browse/FLINK-18353

[jira] [Created] (FLINK-18350) [1.11.0] jobmanager complains `taskmanager.memory.process.size` missing

2020-06-17 Thread Steven Zhen Wu (Jira)
Steven Zhen Wu created FLINK-18350: -- Summary: [1.11.0] jobmanager complains `taskmanager.memory.process.size` missing Key: FLINK-18350 URL: https://issues.apache.org/jira/browse/FLINK-18350 Project:

[jira] [Created] (FLINK-17531) Add a new checkpoint Guage metric: elapsedSecondsSinceLastCompletedCheckpoint

2020-05-05 Thread Steven Zhen Wu (Jira)
Steven Zhen Wu created FLINK-17531: -- Summary: Add a new checkpoint Guage metric: elapsedSecondsSinceLastCompletedCheckpoint Key: FLINK-17531 URL: https://issues.apache.org/jira/browse/FLINK-17531 Pro

[jira] [Created] (FLINK-15907) expose private method in Configuration so that user can extend from it

2020-02-04 Thread Steven Zhen Wu (Jira)
Steven Zhen Wu created FLINK-15907: -- Summary: expose private method in Configuration so that user can extend from it Key: FLINK-15907 URL: https://issues.apache.org/jira/browse/FLINK-15907 Project: F

[jira] [Created] (FLINK-15846) TaskExecutorResourceUtils should return config strs with mb as unit for better readability

2020-02-02 Thread Steven Zhen Wu (Jira)
Steven Zhen Wu created FLINK-15846: -- Summary: TaskExecutorResourceUtils should return config strs with mb as unit for better readability Key: FLINK-15846 URL: https://issues.apache.org/jira/browse/FLINK-15846

[jira] [Created] (FLINK-14943) make callback and related members protected so that user can override the callback handling

2019-11-25 Thread Steven Zhen Wu (Jira)
Steven Zhen Wu created FLINK-14943: -- Summary: make callback and related members protected so that user can override the callback handling Key: FLINK-14943 URL: https://issues.apache.org/jira/browse/FLINK-14943

[jira] [Created] (FLINK-14358) [Web UI] configuration tab for jobmanager has improper width for prop key

2019-10-09 Thread Steven Zhen Wu (Jira)
Steven Zhen Wu created FLINK-14358: -- Summary: [Web UI] configuration tab for jobmanager has improper width for prop key Key: FLINK-14358 URL: https://issues.apache.org/jira/browse/FLINK-14358 Project

[jira] [Created] (FLINK-14316) stuck in "Job leader ... lost leadership" error

2019-10-03 Thread Steven Zhen Wu (Jira)
Steven Zhen Wu created FLINK-14316: -- Summary: stuck in "Job leader ... lost leadership" error Key: FLINK-14316 URL: https://issues.apache.org/jira/browse/FLINK-14316 Project: Flink Issue Typ

[jira] [Created] (FLINK-14315) NPE with JobMaster.disconnectTaskManager

2019-10-02 Thread Steven Zhen Wu (Jira)
Steven Zhen Wu created FLINK-14315: -- Summary: NPE with JobMaster.disconnectTaskManager Key: FLINK-14315 URL: https://issues.apache.org/jira/browse/FLINK-14315 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-12781) run job REST api doesn't return complete stack trace for start job failure

2019-06-07 Thread Steven Zhen Wu (JIRA)
Steven Zhen Wu created FLINK-12781: -- Summary: run job REST api doesn't return complete stack trace for start job failure Key: FLINK-12781 URL: https://issues.apache.org/jira/browse/FLINK-12781 Projec

[jira] [Created] (FLINK-12368) add subtask index to FlinkKafkaConsumerBase logging, which can be very useful when debugging problem

2019-04-29 Thread Steven Zhen Wu (JIRA)
Steven Zhen Wu created FLINK-12368: -- Summary: add subtask index to FlinkKafkaConsumerBase logging, which can be very useful when debugging problem Key: FLINK-12368 URL: https://issues.apache.org/jira/browse/FLINK

[jira] [Created] (FLINK-10970) expose metric for total state size in terms of bytes

2018-11-21 Thread Steven Zhen Wu (JIRA)
Steven Zhen Wu created FLINK-10970: -- Summary: expose metric for total state size in terms of bytes Key: FLINK-10970 URL: https://issues.apache.org/jira/browse/FLINK-10970 Project: Flink Issu

[jira] [Created] (FLINK-10969) expose API or metric for total number of keys stored in state backend

2018-11-21 Thread Steven Zhen Wu (JIRA)
Steven Zhen Wu created FLINK-10969: -- Summary: expose API or metric for total number of keys stored in state backend Key: FLINK-10969 URL: https://issues.apache.org/jira/browse/FLINK-10969 Project: Fl

[jira] [Created] (FLINK-10774) connection leak when partition discovery is disabled and open throws exception

2018-11-04 Thread Steven Zhen Wu (JIRA)
Steven Zhen Wu created FLINK-10774: -- Summary: connection leak when partition discovery is disabled and open throws exception Key: FLINK-10774 URL: https://issues.apache.org/jira/browse/FLINK-10774 Pr

[jira] [Created] (FLINK-10360) support timeout in savepoint REST api

2018-09-17 Thread Steven Zhen Wu (JIRA)
Steven Zhen Wu created FLINK-10360: -- Summary: support timeout in savepoint REST api Key: FLINK-10360 URL: https://issues.apache.org/jira/browse/FLINK-10360 Project: Flink Issue Type: Improve

[jira] [Created] (FLINK-9693) possible memory link in jobmanager retaining archived checkpoints

2018-06-29 Thread Steven Zhen Wu (JIRA)
Steven Zhen Wu created FLINK-9693: - Summary: possible memory link in jobmanager retaining archived checkpoints Key: FLINK-9693 URL: https://issues.apache.org/jira/browse/FLINK-9693 Project: Flink

[jira] [Created] (FLINK-8506) fullRestarts Gauge not incremented when jobmanager got killed

2018-01-24 Thread Steven Zhen Wu (JIRA)
Steven Zhen Wu created FLINK-8506: - Summary: fullRestarts Gauge not incremented when jobmanager got killed Key: FLINK-8506 URL: https://issues.apache.org/jira/browse/FLINK-8506 Project: Flink

[jira] [Created] (FLINK-8043) increment job restart metric when fine grained recovery reverted to full job restart

2017-11-09 Thread Steven Zhen Wu (JIRA)
Steven Zhen Wu created FLINK-8043: - Summary: increment job restart metric when fine grained recovery reverted to full job restart Key: FLINK-8043 URL: https://issues.apache.org/jira/browse/FLINK-8043

[jira] [Created] (FLINK-8042) retry individual failover-strategy for some time first before reverting to full job restart

2017-11-09 Thread Steven Zhen Wu (JIRA)
Steven Zhen Wu created FLINK-8042: - Summary: retry individual failover-strategy for some time first before reverting to full job restart Key: FLINK-8042 URL: https://issues.apache.org/jira/browse/FLINK-8042

[jira] [Created] (FLINK-7143) Partition assignment for Kafka consumer is not stable

2017-07-10 Thread Steven Zhen Wu (JIRA)
Steven Zhen Wu created FLINK-7143: - Summary: Partition assignment for Kafka consumer is not stable Key: FLINK-7143 URL: https://issues.apache.org/jira/browse/FLINK-7143 Project: Flink Issue T