[jira] [Created] (FLINK-32115) json_value support cache

xiaogang zhou created FLINK-32115: - Summary: json_value support cache Key: FLINK-32115 URL: https://issues.apache.org/jira/browse/FLINK-32115 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-32132) Cast function CODEGEN does not work as expected when nullOnFailure enabled

xiaogang zhou created FLINK-32132: - Summary: Cast function CODEGEN does not work as expected when nullOnFailure enabled Key: FLINK-32132 URL: https://issues.apache.org/jira/browse/FLINK-32132 Project:

[jira] [Created] (FLINK-32732) auto offset reset should be exposed to user

xiaogang zhou created FLINK-32732: - Summary: auto offset reset should be exposed to user Key: FLINK-32732 URL: https://issues.apache.org/jira/browse/FLINK-32732 Project: Flink Issue Type: Imp

[jira] [Created] (FLINK-32738) PROTOBUF format supports projection push down

xiaogang zhou created FLINK-32738: - Summary: PROTOBUF format supports projection push down Key: FLINK-32738 URL: https://issues.apache.org/jira/browse/FLINK-32738 Project: Flink Issue Type: S

[jira] [Created] (FLINK-32765) create view should reuse calcite tree

xiaogang zhou created FLINK-32765: - Summary: create view should reuse calcite tree Key: FLINK-32765 URL: https://issues.apache.org/jira/browse/FLINK-32765 Project: Flink Issue Type: Improveme

[jira] [Created] (FLINK-33038) remove getMinRetentionTime in StreamExecDeduplicate

xiaogang zhou created FLINK-33038: - Summary: remove getMinRetentionTime in StreamExecDeduplicate Key: FLINK-33038 URL: https://issues.apache.org/jira/browse/FLINK-33038 Project: Flink Issue T

[jira] [Created] (FLINK-33162) seperate the executor in DefaultDispatcherResourceManagerComponentFactory for MetricFetcher and webMonitorEndpoint

xiaogang zhou created FLINK-33162: - Summary: seperate the executor in DefaultDispatcherResourceManagerComponentFactory for MetricFetcher and webMonitorEndpoint Key: FLINK-33162 URL: https://issues.apache.org/jira

[jira] [Created] (FLINK-33174) enabling tablesample bernoulli in flink

xiaogang zhou created FLINK-33174: - Summary: enabling tablesample bernoulli in flink Key: FLINK-33174 URL: https://issues.apache.org/jira/browse/FLINK-33174 Project: Flink Issue Type: Improve

[jira] [Created] (FLINK-33249) comment should be parsed by StringLiteral() instead of SqlCharStringLiteral to avoid parsing failure

xiaogang zhou created FLINK-33249: - Summary: comment should be parsed by StringLiteral() instead of SqlCharStringLiteral to avoid parsing failure Key: FLINK-33249 URL: https://issues.apache.org/jira/browse/FLINK-3

[jira] [Created] (FLINK-33728) do not rewatch when KubernetesResourceManagerDriver watch fail

xiaogang zhou created FLINK-33728: - Summary: do not rewatch when KubernetesResourceManagerDriver watch fail Key: FLINK-33728 URL: https://issues.apache.org/jira/browse/FLINK-33728 Project: Flink

[jira] [Created] (FLINK-33741) introduce stat dump period and statsLevel configuration

xiaogang zhou created FLINK-33741: - Summary: introduce stat dump period and statsLevel configuration Key: FLINK-33741 URL: https://issues.apache.org/jira/browse/FLINK-33741 Project: Flink Iss

[jira] [Created] (FLINK-16721) getProcessCpuLoad seems to report a wrong cpu load

xiaogang zhou created FLINK-16721: - Summary: getProcessCpuLoad seems to report a wrong cpu load Key: FLINK-16721 URL: https://issues.apache.org/jira/browse/FLINK-16721 Project: Flink Issue T

[jira] [Created] (FLINK-15264) Job Manager TASK_SLOTS_TOTAL metrics does not shows the Job ID

xiaogang zhou created FLINK-15264: - Summary: Job Manager TASK_SLOTS_TOTAL metrics does not shows the Job ID Key: FLINK-15264 URL: https://issues.apache.org/jira/browse/FLINK-15264 Project: Flink

[jira] [Created] (FLINK-19757) TimeStampData can cause time inconsistent problem

xiaogang zhou created FLINK-19757: - Summary: TimeStampData can cause time inconsistent problem Key: FLINK-19757 URL: https://issues.apache.org/jira/browse/FLINK-19757 Project: Flink Issue Typ

[jira] [Created] (FLINK-19847) Can we create a fast support on the Nested table join?

xiaogang zhou created FLINK-19847: - Summary: Can we create a fast support on the Nested table join? Key: FLINK-19847 URL: https://issues.apache.org/jira/browse/FLINK-19847 Project: Flink Issu

[jira] [Created] (FLINK-30256) LogalWindowAgg can set the chaining Strategy to always

xiaogang zhou created FLINK-30256: - Summary: LogalWindowAgg can set the chaining Strategy to always Key: FLINK-30256 URL: https://issues.apache.org/jira/browse/FLINK-30256 Project: Flink Issu

[jira] [Created] (FLINK-31089) pin L0 index in memory can lead to slow memory grow finally lead to memory beyond limit

xiaogang zhou created FLINK-31089: - Summary: pin L0 index in memory can lead to slow memory grow finally lead to memory beyond limit Key: FLINK-31089 URL: https://issues.apache.org/jira/browse/FLINK-31089

[jira] [Created] (FLINK-31225) rocksdb max open file can lead to oom

xiaogang zhou created FLINK-31225: - Summary: rocksdb max open file can lead to oom Key: FLINK-31225 URL: https://issues.apache.org/jira/browse/FLINK-31225 Project: Flink Issue Type: Improvem

[jira] [Created] (FLINK-34976) LD_PRELOAD environment may not be effective after su to flink user

xiaogang zhou created FLINK-34976: - Summary: LD_PRELOAD environment may not be effective after su to flink user Key: FLINK-34976 URL: https://issues.apache.org/jira/browse/FLINK-34976 Project: Flink

[jira] [Created] (FLINK-21543) when using FIFO compaction, I found sst being deleted on the first checkpoint

xiaogang zhou created FLINK-21543: - Summary: when using FIFO compaction, I found sst being deleted on the first checkpoint Key: FLINK-21543 URL: https://issues.apache.org/jira/browse/FLINK-21543 Proje

[jira] [Created] (FLINK-21688) we use setIncreaseParallelism function, can cause slow flush in restore

xiaogang zhou created FLINK-21688: - Summary: we use setIncreaseParallelism function, can cause slow flush in restore Key: FLINK-21688 URL: https://issues.apache.org/jira/browse/FLINK-21688 Project: Fl

[jira] [Created] (FLINK-22008) writing metadata is not an atomic operation, we should add a commit logic

xiaogang zhou created FLINK-22008: - Summary: writing metadata is not an atomic operation, we should add a commit logic Key: FLINK-22008 URL: https://issues.apache.org/jira/browse/FLINK-22008 Project:

[jira] [Created] (FLINK-22059) add a new option is rocksdb statebackend to enable job threads setting

xiaogang zhou created FLINK-22059: - Summary: add a new option is rocksdb statebackend to enable job threads setting Key: FLINK-22059 URL: https://issues.apache.org/jira/browse/FLINK-22059 Project: Fli

[jira] [Created] (FLINK-29545) kafka consuming stop when trigger first checkpoint

xiaogang zhou created FLINK-29545: - Summary: kafka consuming stop when trigger first checkpoint Key: FLINK-29545 URL: https://issues.apache.org/jira/browse/FLINK-29545 Project: Flink Issue Ty

[jira] [Created] (FLINK-17878) StreamingFileWriter watermark attribute is transient, this might be different with origin value

xiaogang zhou created FLINK-17878: - Summary: StreamingFileWriter watermark attribute is transient, this might be different with origin value Key: FLINK-17878 URL: https://issues.apache.org/jira/browse/FLINK-17878