[jira] [Created] (FLINK-32367) lead function second param leat to ClassCastException

zhou created FLINK-32367: Summary: lead function second param leat to ClassCastException Key: FLINK-32367 URL: https://issues.apache.org/jira/browse/FLINK-32367 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-32998) if function result not correct

zhou created FLINK-32998: Summary: if function result not correct Key: FLINK-32998 URL: https://issues.apache.org/jira/browse/FLINK-32998 Project: Flink Issue Type: Bug Components: API / Co

[jira] [Created] (FLINK-22010) when flink executed union all opeators,exception occured

zhou created FLINK-22010: Summary: when flink executed union all opeators,exception occured Key: FLINK-22010 URL: https://issues.apache.org/jira/browse/FLINK-22010 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-23799) application mode not support pyflink

zhou created FLINK-23799: Summary: application mode not support pyflink Key: FLINK-23799 URL: https://issues.apache.org/jira/browse/FLINK-23799 Project: Flink Issue Type: Improvement Affects Vers

[jira] [Created] (FLINK-28455) pyflink tableResult collect to local timeout

zhou created FLINK-28455: Summary: pyflink tableResult collect to local timeout Key: FLINK-28455 URL: https://issues.apache.org/jira/browse/FLINK-28455 Project: Flink Issue Type: Bug Compo

[jira] [Created] (FLINK-13787) PrometheusPushGatewayReporter does not cleanup TM metrics when run on kubernetes

Kaibo Zhou created FLINK-13787: -- Summary: PrometheusPushGatewayReporter does not cleanup TM metrics when run on kubernetes Key: FLINK-13787 URL: https://issues.apache.org/jira/browse/FLINK-13787 Project:

[jira] [Created] (FLINK-14095) Add Pravega in Flink ecosystem page

Yumin Zhou created FLINK-14095: -- Summary: Add Pravega in Flink ecosystem page Key: FLINK-14095 URL: https://issues.apache.org/jira/browse/FLINK-14095 Project: Flink Issue Type: Improvement

[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-32464) AssertionError when converting between Table and SQL with selection and type cast

Yunfeng Zhou created FLINK-32464: Summary: AssertionError when converting between Table and SQL with selection and type cast Key: FLINK-32464 URL: https://issues.apache.org/jira/browse/FLINK-32464 Pro

[jira] [Created] (FLINK-32494) Cannot convert list literal to Table with PyFlink

Yunfeng Zhou created FLINK-32494: Summary: Cannot convert list literal to Table with PyFlink Key: FLINK-32494 URL: https://issues.apache.org/jira/browse/FLINK-32494 Project: Flink Issue Type:

[jira] [Created] (FLINK-32514) FLIP-309: Support using larger checkpointing interval when source is processing backlog

Yunfeng Zhou created FLINK-32514: Summary: FLIP-309: Support using larger checkpointing interval when source is processing backlog Key: FLINK-32514 URL: https://issues.apache.org/jira/browse/FLINK-32514

[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-32881) Client supports making savepoints in detach mode

Renxiang Zhou created FLINK-32881: - Summary: Client supports making savepoints in detach mode Key: FLINK-32881 URL: https://issues.apache.org/jira/browse/FLINK-32881 Project: Flink Issue Type

[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-34015) execution.savepoint.ignore-unclaimed-state is invalid when passing this parameter by dynamic properties

Renxiang Zhou created FLINK-34015: - Summary: execution.savepoint.ignore-unclaimed-state is invalid when passing this parameter by dynamic properties Key: FLINK-34015 URL: https://issues.apache.org/jira/browse/FLIN

[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-14538) Metrics of TaskManager Status.JVM.Memory.NonHeap.Max is always -1

Shuwen Zhou created FLINK-14538: --- Summary: Metrics of TaskManager Status.JVM.Memory.NonHeap.Max is always -1 Key: FLINK-14538 URL: https://issues.apache.org/jira/browse/FLINK-14538 Project: Flink

[jira] [Created] (FLINK-14884) User defined function for checkpoint trigger time and interval behavior

Shuwen Zhou created FLINK-14884: --- Summary: User defined function for checkpoint trigger time and interval behavior Key: FLINK-14884 URL: https://issues.apache.org/jira/browse/FLINK-14884 Project: Flink

[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-15419) Validate SQL syntax not need to depend on connector jar

Kaibo Zhou created FLINK-15419: -- Summary: Validate SQL syntax not need to depend on connector jar Key: FLINK-15419 URL: https://issues.apache.org/jira/browse/FLINK-15419 Project: Flink Issue Typ

[jira] [Created] (FLINK-9263) Kafka010ITCase failed on travis flaky

Sihua Zhou created FLINK-9263: - Summary: Kafka010ITCase failed on travis flaky Key: FLINK-9263 URL: https://issues.apache.org/jira/browse/FLINK-9263 Project: Flink Issue Type: Bug Compo

[jira] [Created] (FLINK-9269) Concurrency problem in HeapKeyedStateBackend when performing checkpoint async

Sihua Zhou created FLINK-9269: - Summary: Concurrency problem in HeapKeyedStateBackend when performing checkpoint async Key: FLINK-9269 URL: https://issues.apache.org/jira/browse/FLINK-9269 Project: Flink

[jira] [Created] (FLINK-9325) generate the _meta file only when the writing is totally successful

Sihua Zhou created FLINK-9325: - Summary: generate the _meta file only when the writing is totally successful Key: FLINK-9325 URL: https://issues.apache.org/jira/browse/FLINK-9325 Project: Flink

[jira] [Created] (FLINK-9351) RM stop assigning slot to Job because the TM killed before connecting to JM successfully

Sihua Zhou created FLINK-9351: - Summary: RM stop assigning slot to Job because the TM killed before connecting to JM successfully Key: FLINK-9351 URL: https://issues.apache.org/jira/browse/FLINK-9351 Proj

[jira] [Created] (FLINK-9364) Add doc for the memory usage in flink

Sihua Zhou created FLINK-9364: - Summary: Add doc for the memory usage in flink Key: FLINK-9364 URL: https://issues.apache.org/jira/browse/FLINK-9364 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-9373) Always call RocksIterator.status() to check the internal error of RocksDB

Sihua Zhou created FLINK-9373: - Summary: Always call RocksIterator.status() to check the internal error of RocksDB Key: FLINK-9373 URL: https://issues.apache.org/jira/browse/FLINK-9373 Project: Flink

[jira] [Created] (FLINK-9401) Data lost when rescaling the job from incremental checkpoint

Sihua Zhou created FLINK-9401: - Summary: Data lost when rescaling the job from incremental checkpoint Key: FLINK-9401 URL: https://issues.apache.org/jira/browse/FLINK-9401 Project: Flink Issue T

[jira] [Created] (FLINK-9426) Harden RocksDBWriteBatchPerformanceTest.benchMark()

Sihua Zhou created FLINK-9426: - Summary: Harden RocksDBWriteBatchPerformanceTest.benchMark() Key: FLINK-9426 URL: https://issues.apache.org/jira/browse/FLINK-9426 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-9468) get outputLimit of LimitedConnectionsFileSystem incorrectly

Sihua Zhou created FLINK-9468: - Summary: get outputLimit of LimitedConnectionsFileSystem incorrectly Key: FLINK-9468 URL: https://issues.apache.org/jira/browse/FLINK-9468 Project: Flink Issue Ty

[jira] [Created] (FLINK-9474) Introduce an approximate version of "count distinct"

Sihua Zhou created FLINK-9474: - Summary: Introduce an approximate version of "count distinct" Key: FLINK-9474 URL: https://issues.apache.org/jira/browse/FLINK-9474 Project: Flink Issue Type: New

[jira] [Created] (FLINK-9475) introduce an approximate version of "select distinct"

Sihua Zhou created FLINK-9475: - Summary: introduce an approximate version of "select distinct" Key: FLINK-9475 URL: https://issues.apache.org/jira/browse/FLINK-9475 Project: Flink Issue Type: New

[jira] [Created] (FLINK-9479) Let the rescale API to use local recovery

Sihua Zhou created FLINK-9479: - Summary: Let the rescale API to use local recovery Key: FLINK-9479 URL: https://issues.apache.org/jira/browse/FLINK-9479 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-9480) Let local recovery support rescaling

Sihua Zhou created FLINK-9480: - Summary: Let local recovery support rescaling Key: FLINK-9480 URL: https://issues.apache.org/jira/browse/FLINK-9480 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-9498) Disable dependency convergence for "flink-end-to-end-tests"

Hai Zhou created FLINK-9498: --- Summary: Disable dependency convergence for "flink-end-to-end-tests" Key: FLINK-9498 URL: https://issues.apache.org/jira/browse/FLINK-9498 Project: Flink Issue Type:

[jira] [Created] (FLINK-9524) NPE from ProcTimeBoundedRangeOver.scala

yan zhou created FLINK-9524: --- Summary: NPE from ProcTimeBoundedRangeOver.scala Key: FLINK-9524 URL: https://issues.apache.org/jira/browse/FLINK-9524 Project: Flink Issue Type: Bug Compone

[jira] [Created] (FLINK-9525) Missing META-INF/services/*FileSystemFactory in flink-hadoop-fs module

Hai Zhou created FLINK-9525: --- Summary: Missing META-INF/services/*FileSystemFactory in flink-hadoop-fs module Key: FLINK-9525 URL: https://issues.apache.org/jira/browse/FLINK-9525 Project: Flink I

[jira] [Created] (FLINK-9546) The heartbeatTimeoutIntervalMs of HeartbeatMonitor should be larger than 0

Sihua Zhou created FLINK-9546: - Summary: The heartbeatTimeoutIntervalMs of HeartbeatMonitor should be larger than 0 Key: FLINK-9546 URL: https://issues.apache.org/jira/browse/FLINK-9546 Project: Flink

[jira] [Created] (FLINK-9601) Snapshot of CopyOnWriteStateTable will failed, when the amount of record is more than MAXIMUM_CAPACITY

Sihua Zhou created FLINK-9601: - Summary: Snapshot of CopyOnWriteStateTable will failed, when the amount of record is more than MAXIMUM_CAPACITY Key: FLINK-9601 URL: https://issues.apache.org/jira/browse/FLINK-9601

[jira] [Created] (FLINK-9613) YARNSessionCapacitySchedulerITCase failed because YarnTestBase.checkClusterEmpty()

Sihua Zhou created FLINK-9613: - Summary: YARNSessionCapacitySchedulerITCase failed because YarnTestBase.checkClusterEmpty() Key: FLINK-9613 URL: https://issues.apache.org/jira/browse/FLINK-9613 Project: F

[jira] [Created] (FLINK-9619) Always close the task manager connection when the container is completed in YarnResourceManager

Sihua Zhou created FLINK-9619: - Summary: Always close the task manager connection when the container is completed in YarnResourceManager Key: FLINK-9619 URL: https://issues.apache.org/jira/browse/FLINK-9619

[jira] [Created] (FLINK-9622) DistributedCacheDfsTest failed on travis

Sihua Zhou created FLINK-9622: - Summary: DistributedCacheDfsTest failed on travis Key: FLINK-9622 URL: https://issues.apache.org/jira/browse/FLINK-9622 Project: Flink Issue Type: Bug Co

[jira] [Created] (FLINK-9633) Flink doesn't use the Savepoint path's filesystem to create the OuptutStream on Task.

Sihua Zhou created FLINK-9633: - Summary: Flink doesn't use the Savepoint path's filesystem to create the OuptutStream on Task. Key: FLINK-9633 URL: https://issues.apache.org/jira/browse/FLINK-9633 Project

[jira] [Created] (FLINK-9640) Checkpointing is aways aborted if any task has been finished

Hai Zhou created FLINK-9640: --- Summary: Checkpointing is aways aborted if any task has been finished Key: FLINK-9640 URL: https://issues.apache.org/jira/browse/FLINK-9640 Project: Flink Issue Type:

[jira] [Created] (FLINK-9661) TTL state should support to do time shift after restoring from checkpoint( savepoint).

Sihua Zhou created FLINK-9661: - Summary: TTL state should support to do time shift after restoring from checkpoint( savepoint). Key: FLINK-9661 URL: https://issues.apache.org/jira/browse/FLINK-9661 Projec

[jira] [Created] (FLINK-11976) PyFlink vectorized python udf with Pandas support

Yurui Zhou created FLINK-11976: -- Summary: PyFlink vectorized python udf with Pandas support Key: FLINK-11976 URL: https://issues.apache.org/jira/browse/FLINK-11976 Project: Flink Issue Type: New

[jira] [Created] (FLINK-11977) Enable PyFlink to interact with Pandas

Yurui Zhou created FLINK-11977: -- Summary: Enable PyFlink to interact with Pandas Key: FLINK-11977 URL: https://issues.apache.org/jira/browse/FLINK-11977 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-11979) Using Apache Arrow as the serialization format between Java runtime and Python worker

Yurui Zhou created FLINK-11979: -- Summary: Using Apache Arrow as the serialization format between Java runtime and Python worker Key: FLINK-11979 URL: https://issues.apache.org/jira/browse/FLINK-11979 Pro

[jira] [Created] (FLINK-11978) Enable vectorized Python UDF with Pandas api

Yurui Zhou created FLINK-11978: -- Summary: Enable vectorized Python UDF with Pandas api Key: FLINK-11978 URL: https://issues.apache.org/jira/browse/FLINK-11978 Project: Flink Issue Type: Sub-task

[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-20797) can flink on k8s use pv using NFS and pvc as the hight avalibility storagedir

hayden zhou created FLINK-20797: --- Summary: can flink on k8s use pv using NFS and pvc as the hight avalibility storagedir Key: FLINK-20797 URL: https://issues.apache.org/jira/browse/FLINK-20797 Project:

[jira] [Created] (FLINK-20798) Service temporarily unavailable due to an ongoing leader election. Please refresh.

hayden zhou created FLINK-20798: --- Summary: Service temporarily unavailable due to an ongoing leader election. Please refresh. Key: FLINK-20798 URL: https://issues.apache.org/jira/browse/FLINK-20798 Proj

[jira] [Created] (FLINK-20938) Implement Flink's own tencent COS filesystem

hayden zhou created FLINK-20938: --- Summary: Implement Flink's own tencent COS filesystem Key: FLINK-20938 URL: https://issues.apache.org/jira/browse/FLINK-20938 Project: Flink Issue Type: New Fe

[jira] [Created] (FLINK-30241) Flink ML Iteration ConcurrentModificationException

Yunfeng Zhou created FLINK-30241: Summary: Flink ML Iteration ConcurrentModificationException Key: FLINK-30241 URL: https://issues.apache.org/jira/browse/FLINK-30241 Project: Flink Issue Type

[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-30292) Better support for conversion between DataType and TypeInformation

Yunfeng Zhou created FLINK-30292: Summary: Better support for conversion between DataType and TypeInformation Key: FLINK-30292 URL: https://issues.apache.org/jira/browse/FLINK-30292 Project: Flink

[jira] [Created] (FLINK-30532) Add benchmark for DCT, SQLTransformer and StopWordsRemover algorithm

Yunfeng Zhou created FLINK-30532: Summary: Add benchmark for DCT, SQLTransformer and StopWordsRemover algorithm Key: FLINK-30532 URL: https://issues.apache.org/jira/browse/FLINK-30532 Project: Flink

[jira] [Created] (FLINK-30753) Py4J cannot acquire Table.explain() method

Yunfeng Zhou created FLINK-30753: Summary: Py4J cannot acquire Table.explain() method Key: FLINK-30753 URL: https://issues.apache.org/jira/browse/FLINK-30753 Project: Flink Issue Type: Improv

[jira] [Created] (FLINK-30959) UNIX_TIMESTAMP's return value does not meet expected

Yunfeng Zhou created FLINK-30959: Summary: UNIX_TIMESTAMP's return value does not meet expected Key: FLINK-30959 URL: https://issues.apache.org/jira/browse/FLINK-30959 Project: Flink Issue Ty

[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-31249) Checkpoint Timer failed to process timeout events when it blocked at writing _metadata to DFS

renxiang zhou created FLINK-31249: - Summary: Checkpoint Timer failed to process timeout events when it blocked at writing _metadata to DFS Key: FLINK-31249 URL: https://issues.apache.org/jira/browse/FLINK-31249

[jira] [Created] (FLINK-31605) Table#to_pandas check table boundedness

Yunfeng Zhou created FLINK-31605: Summary: Table#to_pandas check table boundedness Key: FLINK-31605 URL: https://issues.apache.org/jira/browse/FLINK-31605 Project: Flink Issue Type: Improveme

[jira] [Created] (FLINK-34077) Sphinx version needs upgrade

Yunfeng Zhou created FLINK-34077: Summary: Sphinx version needs upgrade Key: FLINK-34077 URL: https://issues.apache.org/jira/browse/FLINK-34077 Project: Flink Issue Type: Bug Compon

[jira] [Created] (FLINK-34371) FLIP-331: Support EndOfStreamTrigger and isOutputOnlyAfterEndOfStream operator attribute to optimize task deployment

Yunfeng Zhou created FLINK-34371: Summary: FLIP-331: Support EndOfStreamTrigger and isOutputOnlyAfterEndOfStream operator attribute to optimize task deployment Key: FLINK-34371 URL: https://issues.apache.org/jira/

[jira] [Created] (FLINK-34402) Class loading conflicts when using PowerMock in ITcase.

yisha zhou created FLINK-34402: -- Summary: Class loading conflicts when using PowerMock in ITcase. Key: FLINK-34402 URL: https://issues.apache.org/jira/browse/FLINK-34402 Project: Flink Issue Ty

[jira] [Created] (FLINK-34406) Expose more RuntimeContext functionalities in FunctionContext

yisha zhou created FLINK-34406: -- Summary: Expose more RuntimeContext functionalities in FunctionContext Key: FLINK-34406 URL: https://issues.apache.org/jira/browse/FLINK-34406 Project: Flink Is

[jira] [Created] (FLINK-34519) Refine checkpoint scheduling and canceling logic

Yunfeng Zhou created FLINK-34519: Summary: Refine checkpoint scheduling and canceling logic Key: FLINK-34519 URL: https://issues.apache.org/jira/browse/FLINK-34519 Project: Flink Issue Type:

[jira] [Created] (FLINK-34529) Projection cannot be pushed down through rank operator.

yisha zhou created FLINK-34529: -- Summary: Projection cannot be pushed down through rank operator. Key: FLINK-34529 URL: https://issues.apache.org/jira/browse/FLINK-34529 Project: Flink Issue Typ

[jira] [Created] (FLINK-34536) Support reading long value as Timestamp column in JSON format

yisha zhou created FLINK-34536: -- Summary: Support reading long value as Timestamp column in JSON format Key: FLINK-34536 URL: https://issues.apache.org/jira/browse/FLINK-34536 Project: Flink Is

[jira] [Created] (FLINK-34656) Generated code for `ITEM` operator should return null when getting element of a null map/array/row

yisha zhou created FLINK-34656: -- Summary: Generated code for `ITEM` operator should return null when getting element of a null map/array/row Key: FLINK-34656 URL: https://issues.apache.org/jira/browse/FLINK-34656

[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-35037) Optimize uniqueKeys and upsertKeys inference of windows with ROW_NUMBER

yisha zhou created FLINK-35037: -- Summary: Optimize uniqueKeys and upsertKeys inference of windows with ROW_NUMBER Key: FLINK-35037 URL: https://issues.apache.org/jira/browse/FLINK-35037 Project: Flink

[jira] [Created] (FLINK-35066) TwoInputOperator in IterationBody cannot use keyBy

Yunfeng Zhou created FLINK-35066: Summary: TwoInputOperator in IterationBody cannot use keyBy Key: FLINK-35066 URL: https://issues.apache.org/jira/browse/FLINK-35066 Project: Flink Issue Type

[jira] [Created] (FLINK-35357) Add "kubernetes.operator.plugins.listeners" parameter description to the Operator configuration document

Yang Zhou created FLINK-35357: - Summary: Add "kubernetes.operator.plugins.listeners" parameter description to the Operator configuration document Key: FLINK-35357 URL: https://issues.apache.org/jira/browse/FLINK-35357

[jira] [Created] (FLINK-26705) use threadlocal to decrease ObjectSizeCalculator memory use

hd zhou created FLINK-26705: --- Summary: use threadlocal to decrease ObjectSizeCalculator memory use Key: FLINK-26705 URL: https://issues.apache.org/jira/browse/FLINK-26705 Project: Flink Issue Type

[jira] [Created] (FLINK-27084) Perround mode recreating operator fails

Yunfeng Zhou created FLINK-27084: Summary: Perround mode recreating operator fails Key: FLINK-27084 URL: https://issues.apache.org/jira/browse/FLINK-27084 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-27352) [JUnit5 Migration] Module: flink-json

EMing Zhou created FLINK-27352: -- Summary: [JUnit5 Migration] Module: flink-json Key: FLINK-27352 URL: https://issues.apache.org/jira/browse/FLINK-27352 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-27742) Fix Compatibility Issues Between Flink ML Operators.

Yunfeng Zhou created FLINK-27742: Summary: Fix Compatibility Issues Between Flink ML Operators. Key: FLINK-27742 URL: https://issues.apache.org/jira/browse/FLINK-27742 Project: Flink Issue Ty

[jira] [Created] (FLINK-27797) PythonTableUtils.getCollectionInputFormat cannot correctly handle None values

Yunfeng Zhou created FLINK-27797: Summary: PythonTableUtils.getCollectionInputFormat cannot correctly handle None values Key: FLINK-27797 URL: https://issues.apache.org/jira/browse/FLINK-27797 Project

[jira] [Created] (FLINK-27798) Migrate Flink ML to Flink 1.15.0

Yunfeng Zhou created FLINK-27798: Summary: Migrate Flink ML to Flink 1.15.0 Key: FLINK-27798 URL: https://issues.apache.org/jira/browse/FLINK-27798 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-25444) ExecutionConfig can not be Serializable due to TextElement used in side

Wen Zhou created FLINK-25444: Summary: ExecutionConfig can not be Serializable due to TextElement used in side Key: FLINK-25444 URL: https://issues.apache.org/jira/browse/FLINK-25444 Project: Flink

[jira] [Created] (FLINK-26100) Set up Flink ML Document Website

Yunfeng Zhou created FLINK-26100: Summary: Set up Flink ML Document Website Key: FLINK-26100 URL: https://issues.apache.org/jira/browse/FLINK-26100 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-26263) Check data size in LogisticRegression

Yunfeng Zhou created FLINK-26263: Summary: Check data size in LogisticRegression Key: FLINK-26263 URL: https://issues.apache.org/jira/browse/FLINK-26263 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-26313) Support Online KMeans in Flink ML

Yunfeng Zhou created FLINK-26313: Summary: Support Online KMeans in Flink ML Key: FLINK-26313 URL: https://issues.apache.org/jira/browse/FLINK-26313 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-21178) Task failure will not trigger master hook's reset()

Brian Zhou created FLINK-21178: -- Summary: Task failure will not trigger master hook's reset() Key: FLINK-21178 URL: https://issues.apache.org/jira/browse/FLINK-21178 Project: Flink Issue Type: B

[jira] [Created] (FLINK-21325) NoResourceAvailableException while cancel then resubmit jobs

hayden zhou created FLINK-21325: --- Summary: NoResourceAvailableException while cancel then resubmit jobs Key: FLINK-21325 URL: https://issues.apache.org/jira/browse/FLINK-21325 Project: Flink

[jira] [Created] (FLINK-21472) encingTokenException: Fencing token mismatch

hayden zhou created FLINK-21472: --- Summary: encingTokenException: Fencing token mismatch Key: FLINK-21472 URL: https://issues.apache.org/jira/browse/FLINK-21472 Project: Flink Issue Type: Bug

[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-21840) can't submit flink k8s session job with kubernetes.rest-service.exposed.type=NodePort

hayden zhou created FLINK-21840: --- Summary: can't submit flink k8s session job with kubernetes.rest-service.exposed.type=NodePort Key: FLINK-21840 URL: https://issues.apache.org/jira/browse/FLINK-21840 P

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

  1   2   3   >