[jira] [Created] (FLINK-14827) Add thread dump feature for jobmanager

lamber-ken created FLINK-14827: -- Summary: Add thread dump feature for jobmanager Key: FLINK-14827 URL: https://issues.apache.org/jira/browse/FLINK-14827 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-14816) Add thread dump feature for taskmanager

lamber-ken created FLINK-14816: -- Summary: Add thread dump feature for taskmanager Key: FLINK-14816 URL: https://issues.apache.org/jira/browse/FLINK-14816 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-14614) add annotation location javastyle rule

lamber-ken created FLINK-14614: -- Summary: add annotation location javastyle rule Key: FLINK-14614 URL: https://issues.apache.org/jira/browse/FLINK-14614 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-14177) Bump Curator to 3.5.5

lamber-ken created FLINK-14177: -- Summary: Bump Curator to 3.5.5 Key: FLINK-14177 URL: https://issues.apache.org/jira/browse/FLINK-14177 Project: Flink Issue Type: Improvement Reporte

[jira] [Created] (FLINK-13189) Fix the impact of zookeeper network disconnect temporarily on flink long running jobs

lamber-ken created FLINK-13189: -- Summary: Fix the impact of zookeeper network disconnect temporarily on flink long running jobs Key: FLINK-13189 URL: https://issues.apache.org/jira/browse/FLINK-13189 Pro

[jira] [Created] (FLINK-12558) Yarn application can't stop when flink job finished

lamber-ken created FLINK-12558: -- Summary: Yarn application can't stop when flink job finished Key: FLINK-12558 URL: https://issues.apache.org/jira/browse/FLINK-12558 Project: Flink Issue Type: B

[jira] [Created] (FLINK-12302) fix the finalStatus of application when job not finished

lamber-ken created FLINK-12302: -- Summary: fix the finalStatus of application when job not finished Key: FLINK-12302 URL: https://issues.apache.org/jira/browse/FLINK-12302 Project: Flink Issue T

[jira] [Created] (FLINK-12247) fix NPE when writing an archive file to a FileSystem

lamber-ken created FLINK-12247: -- Summary: fix NPE when writing an archive file to a FileSystem Key: FLINK-12247 URL: https://issues.apache.org/jira/browse/FLINK-12247 Project: Flink Issue Type:

[jira] [Created] (FLINK-12246) can't get any option from the jobConfiguration of JobGraph

lamber-ken created FLINK-12246: -- Summary: can't get any option from the jobConfiguration of JobGraph Key: FLINK-12246 URL: https://issues.apache.org/jira/browse/FLINK-12246 Project: Flink Issue

[jira] [Created] (FLINK-12219) Yarn application can't stop when flink job failed in per-job yarn cluste mode

lamber-ken created FLINK-12219: -- Summary: Yarn application can't stop when flink job failed in per-job yarn cluste mode Key: FLINK-12219 URL: https://issues.apache.org/jira/browse/FLINK-12219 Project: Fl

[jira] [Created] (FLINK-11821) fix the error package location of KafkaDeserializationSchemaWrapper.java file

lamber-ken created FLINK-11821: -- Summary: fix the error package location of KafkaDeserializationSchemaWrapper.java file Key: FLINK-11821 URL: https://issues.apache.org/jira/browse/FLINK-11821 Project: F

[jira] [Created] (FLINK-11820) KafkaDeserializationSchemaWrapper should filter record which value is null

lamber-ken created FLINK-11820: -- Summary: KafkaDeserializationSchemaWrapper should filter record which value is null Key: FLINK-11820 URL: https://issues.apache.org/jira/browse/FLINK-11820 Project: Flink

[jira] [Created] (FLINK-11250) fix thread lack when StreamTask switched from DEPLOYING to CANCELING

lamber-ken created FLINK-11250: -- Summary: fix thread lack when StreamTask switched from DEPLOYING to CANCELING Key: FLINK-11250 URL: https://issues.apache.org/jira/browse/FLINK-11250 Project: Flink

[jira] [Created] (FLINK-11235) fix thread lack when elasticsearch transport client init failed

lamber-ken created FLINK-11235: -- Summary: fix thread lack when elasticsearch transport client init failed Key: FLINK-11235 URL: https://issues.apache.org/jira/browse/FLINK-11235 Project: Flink

[jira] [Created] (FLINK-11218) fix the default restart delay value

lamber-ken created FLINK-11218: -- Summary: fix the default restart delay value Key: FLINK-11218 URL: https://issues.apache.org/jira/browse/FLINK-11218 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-11010) Flink SQL timestamp is inconsistent with currentProcessingTime()

lamber-ken created FLINK-11010: -- Summary: Flink SQL timestamp is inconsistent with currentProcessingTime() Key: FLINK-11010 URL: https://issues.apache.org/jira/browse/FLINK-11010 Project: Flink

[jira] [Created] (FLINK-9829) The wrapper classes should be compared by equals method rather than by symbol of '==' directly in BigDecSerializer.java

lamber-ken created FLINK-9829: - Summary: The wrapper classes should be compared by equals method rather than by symbol of '==' directly in BigDecSerializer.java Key: FLINK-9829 URL: https://issues.apache.org/jira/brow

[jira] [Created] (FLINK-9759) give an irrelevant answer about the savepoint restore when stateless operators be added etc

lamber-ken created FLINK-9759: - Summary: give an irrelevant answer about the savepoint restore when stateless operators be added etc Key: FLINK-9759 URL: https://issues.apache.org/jira/browse/FLINK-9759 P

[jira] [Created] (FLINK-9730) avoid access static via class reference

lamber-ken created FLINK-9730: - Summary: avoid access static via class reference Key: FLINK-9730 URL: https://issues.apache.org/jira/browse/FLINK-9730 Project: Flink Issue Type: Improvement A

[jira] [Created] (FLINK-9666) short-circuit logic should be used in boolean contexts

lamber-ken created FLINK-9666: - Summary: short-circuit logic should be used in boolean contexts Key: FLINK-9666 URL: https://issues.apache.org/jira/browse/FLINK-9666 Project: Flink Issue Type: Im

[jira] [Created] (FLINK-9187) add prometheus pushgateway reporter

lamber-ken created FLINK-9187: - Summary: add prometheus pushgateway reporter Key: FLINK-9187 URL: https://issues.apache.org/jira/browse/FLINK-9187 Project: Flink Issue Type: New Feature