[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-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

[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-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

[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

[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] [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

[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

[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

[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

[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-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

Re: [DISCUSS] FLIP-310:use VARINT and ZIGZAG to encode ROWDATA in state

:useVARINTandZIGZAGtoencodeROWDATAinstate-TestPlan [image: image.png] Zakelly Lan 于2023年5月10日周三 02:03写道： > Hi Xiaogang Zhou, > > Thanks for driving this! > > I'm pretty interested in your verification test, could you please > provide more details? AFAIK, the performance is related to th

Re: [DISCUSS] FLIP-310:use VARINT and ZIGZAG to encode ROWDATA in state

Hi Masters, This FLIP is mainly related to the flink-table module, Can you please let me know who can help me review this feature? regards! Xiaogang Zhou 于2023年5月5日周五 15:41写道： > Hi Guys, > > I have created a FLIP WIKI FLIP-310 > <https://cwiki.apache.org/confluence/display/FLIN

[DISCUSS] FLIP-310:use VARINT and ZIGZAG to encode ROWDATA in state

Hi Guys, I have created a FLIP WIKI FLIP-310 , and documented my thinking about using the varint format in FLINK state to improve the FLINK state performance. Would you please

[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

[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-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

[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

[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

[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-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

[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

[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

[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

[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

[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

[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