[jira] [Created] (FLINK-32711) Type mismatch when proctime function used as parameter

Aitozi created FLINK-32711: -- Summary: Type mismatch when proctime function used as parameter Key: FLINK-32711 URL: https://issues.apache.org/jira/browse/FLINK-32711 Project: Flink Issue Type: Improv

[jira] [Created] (FLINK-32659) DB connection may leak if exception is thrown in JdbcOutputFormat#close

Aitozi created FLINK-32659: -- Summary: DB connection may leak if exception is thrown in JdbcOutputFormat#close Key: FLINK-32659 URL: https://issues.apache.org/jira/browse/FLINK-32659 Project: Flink

[jira] [Created] (FLINK-32320) Same correlate can not be reused due to the different correlationId

Aitozi created FLINK-32320: -- Summary: Same correlate can not be reused due to the different correlationId Key: FLINK-32320 URL: https://issues.apache.org/jira/browse/FLINK-32320 Project: Flink Issu

[jira] [Created] (FLINK-31790) Filesystem batch sink should also respect to the PartitionCommitPolicy

Aitozi created FLINK-31790: -- Summary: Filesystem batch sink should also respect to the PartitionCommitPolicy Key: FLINK-31790 URL: https://issues.apache.org/jira/browse/FLINK-31790 Project: Flink I

[jira] [Created] (FLINK-31787) Add the explicit ROW constructor to the system function doc

Aitozi created FLINK-31787: -- Summary: Add the explicit ROW constructor to the system function doc Key: FLINK-31787 URL: https://issues.apache.org/jira/browse/FLINK-31787 Project: Flink Issue Type:

[jira] [Created] (FLINK-31774) Add document for delete and update statement

Aitozi created FLINK-31774: -- Summary: Add document for delete and update statement Key: FLINK-31774 URL: https://issues.apache.org/jira/browse/FLINK-31774 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-31755) ROW function can not work with RewriteIntersectAllRule

Aitozi created FLINK-31755: -- Summary: ROW function can not work with RewriteIntersectAllRule Key: FLINK-31755 URL: https://issues.apache.org/jira/browse/FLINK-31755 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-31497) Drop the deprecated CatalogViewImpl

Aitozi created FLINK-31497: -- Summary: Drop the deprecated CatalogViewImpl Key: FLINK-31497 URL: https://issues.apache.org/jira/browse/FLINK-31497 Project: Flink Issue Type: Technical Debt

[jira] [Created] (FLINK-31426) Upgrade the deprecated UniqueConstraint to the new one

Aitozi created FLINK-31426: -- Summary: Upgrade the deprecated UniqueConstraint to the new one Key: FLINK-31426 URL: https://issues.apache.org/jira/browse/FLINK-31426 Project: Flink Issue Type: Techn

[jira] [Created] (FLINK-31390) Optimize the FlinkChangelogModeInferenceProgram by avoiding unnecessary traversals.

Aitozi created FLINK-31390: -- Summary: Optimize the FlinkChangelogModeInferenceProgram by avoiding unnecessary traversals. Key: FLINK-31390 URL: https://issues.apache.org/jira/browse/FLINK-31390 Project: Flin

[jira] [Created] (FLINK-31362) Add document about how to use C-style escape strings

Aitozi created FLINK-31362: -- Summary: Add document about how to use C-style escape strings Key: FLINK-31362 URL: https://issues.apache.org/jira/browse/FLINK-31362 Project: Flink Issue Type: Improvem

[jira] [Created] (FLINK-31296) Add JoinConditionEqualityTransferRule to stream optimizer

Aitozi created FLINK-31296: -- Summary: Add JoinConditionEqualityTransferRule to stream optimizer Key: FLINK-31296 URL: https://issues.apache.org/jira/browse/FLINK-31296 Project: Flink Issue Type: Imp

[jira] [Created] (FLINK-31260) PushLocalHashAggIntoScanRule should also work with union RelNode

Aitozi created FLINK-31260: -- Summary: PushLocalHashAggIntoScanRule should also work with union RelNode Key: FLINK-31260 URL: https://issues.apache.org/jira/browse/FLINK-31260 Project: Flink Issue T

[jira] [Created] (FLINK-31205) do optimize for multi sink in a single relNode tree

Aitozi created FLINK-31205: -- Summary: do optimize for multi sink in a single relNode tree Key: FLINK-31205 URL: https://issues.apache.org/jira/browse/FLINK-31205 Project: Flink Issue Type: Improvem

[jira] [Created] (FLINK-30570) RexNodeExtractor#isSupportedPartitionPredicate generates unexpected partition predicates

Aitozi created FLINK-30570: -- Summary: RexNodeExtractor#isSupportedPartitionPredicate generates unexpected partition predicates Key: FLINK-30570 URL: https://issues.apache.org/jira/browse/FLINK-30570 Project:

[jira] [Created] (FLINK-30551) Add open method to PartitionCommitPolicy

Aitozi created FLINK-30551: -- Summary: Add open method to PartitionCommitPolicy Key: FLINK-30551 URL: https://issues.apache.org/jira/browse/FLINK-30551 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-30242) Push localHashAggregate pass the union node

Aitozi created FLINK-30242: -- Summary: Push localHashAggregate pass the union node Key: FLINK-30242 URL: https://issues.apache.org/jira/browse/FLINK-30242 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-30198) Support AdaptiveBatchScheduler to set per-task size for reducer task

Aitozi created FLINK-30198: -- Summary: Support AdaptiveBatchScheduler to set per-task size for reducer task Key: FLINK-30198 URL: https://issues.apache.org/jira/browse/FLINK-30198 Project: Flink Is

[jira] [Created] (FLINK-30019) Remove the unused HiveTableFileInputFormat in hive connector

Aitozi created FLINK-30019: -- Summary: Remove the unused HiveTableFileInputFormat in hive connector Key: FLINK-30019 URL: https://issues.apache.org/jira/browse/FLINK-30019 Project: Flink Issue Type:

[jira] [Created] (FLINK-29980) Wrap the HiveSource's bulkFormat to handle the partition keys

Aitozi created FLINK-29980: -- Summary: Wrap the HiveSource's bulkFormat to handle the partition keys Key: FLINK-29980 URL: https://issues.apache.org/jira/browse/FLINK-29980 Project: Flink Issue Type

[jira] [Created] (FLINK-29800) Continuous failover will leak the inprogress output file

Aitozi created FLINK-29800: -- Summary: Continuous failover will leak the inprogress output file Key: FLINK-29800 URL: https://issues.apache.org/jira/browse/FLINK-29800 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-29795) The source.file.stream.io-fetch-size can not be set by with properties

Aitozi created FLINK-29795: -- Summary: The source.file.stream.io-fetch-size can not be set by with properties Key: FLINK-29795 URL: https://issues.apache.org/jira/browse/FLINK-29795 Project: Flink I

[jira] [Created] (FLINK-29748) Expose the optimize phase in the connector context

Aitozi created FLINK-29748: -- Summary: Expose the optimize phase in the connector context Key: FLINK-29748 URL: https://issues.apache.org/jira/browse/FLINK-29748 Project: Flink Issue Type: Improvemen

[jira] [Created] (FLINK-29557) The SinkOperator's OutputFormat function is not recognized

Aitozi created FLINK-29557: -- Summary: The SinkOperator's OutputFormat function is not recognized Key: FLINK-29557 URL: https://issues.apache.org/jira/browse/FLINK-29557 Project: Flink Issue Type: Bu

[jira] [Created] (FLINK-29308) NoResourceAvailableException fails the batch job

Aitozi created FLINK-29308: -- Summary: NoResourceAvailableException fails the batch job Key: FLINK-29308 URL: https://issues.apache.org/jira/browse/FLINK-29308 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-29200) Provide the way to delay the pod deletion for debugging purpose

Aitozi created FLINK-29200: -- Summary: Provide the way to delay the pod deletion for debugging purpose Key: FLINK-29200 URL: https://issues.apache.org/jira/browse/FLINK-29200 Project: Flink Issue Ty

[jira] [Created] (FLINK-29088) Project push down cause the source reuse can not work

Aitozi created FLINK-29088: -- Summary: Project push down cause the source reuse can not work Key: FLINK-29088 URL: https://issues.apache.org/jira/browse/FLINK-29088 Project: Flink Issue Type: Improve

[jira] [Created] (FLINK-29085) Add the name for test as hint for BuiltInFunctionTestBase

Aitozi created FLINK-29085: -- Summary: Add the name for test as hint for BuiltInFunctionTestBase Key: FLINK-29085 URL: https://issues.apache.org/jira/browse/FLINK-29085 Project: Flink Issue Type: Imp

[jira] [Created] (FLINK-29066) Reconsider the runtime property of the BuiltInFunctionDefinition

Aitozi created FLINK-29066: -- Summary: Reconsider the runtime property of the BuiltInFunctionDefinition Key: FLINK-29066 URL: https://issues.apache.org/jira/browse/FLINK-29066 Project: Flink Issue T

[jira] [Created] (FLINK-29061) Cleanup dead code in StringCallGen

Aitozi created FLINK-29061: -- Summary: Cleanup dead code in StringCallGen Key: FLINK-29061 URL: https://issues.apache.org/jira/browse/FLINK-29061 Project: Flink Issue Type: Improvement Comp

[jira] [Created] (FLINK-28838) Avoid to notify the elementQueue consumer when the fetch result is empty

Aitozi created FLINK-28838: -- Summary: Avoid to notify the elementQueue consumer when the fetch result is empty Key: FLINK-28838 URL: https://issues.apache.org/jira/browse/FLINK-28838 Project: Flink

[jira] [Created] (FLINK-28822) Avoid create VectorizedColumnBatch for each read in ArrowReader

Aitozi created FLINK-28822: -- Summary: Avoid create VectorizedColumnBatch for each read in ArrowReader Key: FLINK-28822 URL: https://issues.apache.org/jira/browse/FLINK-28822 Project: Flink Issue Ty

[jira] [Created] (FLINK-28816) Include some metrics for the pod created in operator

Aitozi created FLINK-28816: -- Summary: Include some metrics for the pod created in operator Key: FLINK-28816 URL: https://issues.apache.org/jira/browse/FLINK-28816 Project: Flink Issue Type: Improvem

[jira] [Created] (FLINK-28751) Poor performance of the built in json_value function

Aitozi created FLINK-28751: -- Summary: Poor performance of the built in json_value function Key: FLINK-28751 URL: https://issues.apache.org/jira/browse/FLINK-28751 Project: Flink Issue Type: Improvem

[jira] [Created] (FLINK-28531) Shutdown cluster after history server archive finished

Aitozi created FLINK-28531: -- Summary: Shutdown cluster after history server archive finished Key: FLINK-28531 URL: https://issues.apache.org/jira/browse/FLINK-28531 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-28478) Session Cluster will lost if it failed between status recorded and deploy

Aitozi created FLINK-28478: -- Summary: Session Cluster will lost if it failed between status recorded and deploy Key: FLINK-28478 URL: https://issues.apache.org/jira/browse/FLINK-28478 Project: Flink

[jira] [Created] (FLINK-28477) Support to scan the history server dir with max depth

Aitozi created FLINK-28477: -- Summary: Support to scan the history server dir with max depth Key: FLINK-28477 URL: https://issues.apache.org/jira/browse/FLINK-28477 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-28008) Can not get secondary resource from after operator restart

Aitozi created FLINK-28008: -- Summary: Can not get secondary resource from after operator restart Key: FLINK-28008 URL: https://issues.apache.org/jira/browse/FLINK-28008 Project: Flink Issue Type: Bu

[jira] [Created] (FLINK-27979) Support to upgrade session cluster in a more fine grained way

Aitozi created FLINK-27979: -- Summary: Support to upgrade session cluster in a more fine grained way Key: FLINK-27979 URL: https://issues.apache.org/jira/browse/FLINK-27979 Project: Flink Issue Type

[jira] [Created] (FLINK-27961) The EventUtils generate event name should take the resource's uid into account

Aitozi created FLINK-27961: -- Summary: The EventUtils generate event name should take the resource's uid into account Key: FLINK-27961 URL: https://issues.apache.org/jira/browse/FLINK-27961 Project: Flink

[jira] [Created] (FLINK-27960) Make the apt-get updating optional

Aitozi created FLINK-27960: -- Summary: Make the apt-get updating optional Key: FLINK-27960 URL: https://issues.apache.org/jira/browse/FLINK-27960 Project: Flink Issue Type: Improvement Com

[jira] [Created] (FLINK-27930) Format the timestamp in status to make it explicit

Aitozi created FLINK-27930: -- Summary: Format the timestamp in status to make it explicit Key: FLINK-27930 URL: https://issues.apache.org/jira/browse/FLINK-27930 Project: Flink Issue Type: Improveme

[jira] [Created] (FLINK-27925) Avoid to create watcher without the resourceVersion

Aitozi created FLINK-27925: -- Summary: Avoid to create watcher without the resourceVersion Key: FLINK-27925 URL: https://issues.apache.org/jira/browse/FLINK-27925 Project: Flink Issue Type: Improveme

[jira] [Created] (FLINK-27921) Introduce the checkResourceRequirementsWithDelay in DeclarativeSlotManager

Aitozi created FLINK-27921: -- Summary: Introduce the checkResourceRequirementsWithDelay in DeclarativeSlotManager Key: FLINK-27921 URL: https://issues.apache.org/jira/browse/FLINK-27921 Project: Flink

[jira] [Created] (FLINK-27737) Clean the outdated comments and unfencedMainExecutor

Aitozi created FLINK-27737: -- Summary: Clean the outdated comments and unfencedMainExecutor Key: FLINK-27737 URL: https://issues.apache.org/jira/browse/FLINK-27737 Project: Flink Issue Type: Technica

[jira] [Created] (FLINK-27614) Use informer in webhook to avoid query apiserver at each update

Aitozi created FLINK-27614: -- Summary: Use informer in webhook to avoid query apiserver at each update Key: FLINK-27614 URL: https://issues.apache.org/jira/browse/FLINK-27614 Project: Flink Issue Ty

[jira] [Created] (FLINK-27613) Add label for the session job to help list the session jobs in the same session cluster

Aitozi created FLINK-27613: -- Summary: Add label for the session job to help list the session jobs in the same session cluster Key: FLINK-27613 URL: https://issues.apache.org/jira/browse/FLINK-27613 Project:

[jira] [Created] (FLINK-27612) Generate waring events when deleting the session cluster

Aitozi created FLINK-27612: -- Summary: Generate waring events when deleting the session cluster Key: FLINK-27612 URL: https://issues.apache.org/jira/browse/FLINK-27612 Project: Flink Issue Type: Impr

[jira] [Created] (FLINK-27461) Add a convenient way to set userAgent for the kubeclient

Aitozi created FLINK-27461: -- Summary: Add a convenient way to set userAgent for the kubeclient Key: FLINK-27461 URL: https://issues.apache.org/jira/browse/FLINK-27461 Project: Flink Issue Type: Impr

[jira] [Created] (FLINK-27451) Enable the validator plugin in webhook

Aitozi created FLINK-27451: -- Summary: Enable the validator plugin in webhook Key: FLINK-27451 URL: https://issues.apache.org/jira/browse/FLINK-27451 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-27397) Improve the CrdReferenceDoclet generator to handle the abstract class

Aitozi created FLINK-27397: -- Summary: Improve the CrdReferenceDoclet generator to handle the abstract class Key: FLINK-27397 URL: https://issues.apache.org/jira/browse/FLINK-27397 Project: Flink Is

[jira] [Created] (FLINK-27362) Support restartNonce semantics in session job

Aitozi created FLINK-27362: -- Summary: Support restartNonce semantics in session job Key: FLINK-27362 URL: https://issues.apache.org/jira/browse/FLINK-27362 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-27334) Support auto generate the doc for the KubernetesOperatorConfigOptions

Aitozi created FLINK-27334: -- Summary: Support auto generate the doc for the KubernetesOperatorConfigOptions Key: FLINK-27334 URL: https://issues.apache.org/jira/browse/FLINK-27334 Project: Flink Is

[jira] [Created] (FLINK-27273) Support both configMap and zookeeper based HA data clean up

Aitozi created FLINK-27273: -- Summary: Support both configMap and zookeeper based HA data clean up Key: FLINK-27273 URL: https://issues.apache.org/jira/browse/FLINK-27273 Project: Flink Issue Type:

[jira] [Created] (FLINK-27270) Add document of session job operations

Aitozi created FLINK-27270: -- Summary: Add document of session job operations Key: FLINK-27270 URL: https://issues.apache.org/jira/browse/FLINK-27270 Project: Flink Issue Type: Sub-task Com

[jira] [Created] (FLINK-27269) Clean up the jar file after submitting the job

Aitozi created FLINK-27269: -- Summary: Clean up the jar file after submitting the job Key: FLINK-27269 URL: https://issues.apache.org/jira/browse/FLINK-27269 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-27161) Support user jar from different type of filesystems

Aitozi created FLINK-27161: -- Summary: Support user jar from different type of filesystems Key: FLINK-27161 URL: https://issues.apache.org/jira/browse/FLINK-27161 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-27160) Add e2e tests for FlinkSessionJob type

Aitozi created FLINK-27160: -- Summary: Add e2e tests for FlinkSessionJob type Key: FLINK-27160 URL: https://issues.apache.org/jira/browse/FLINK-27160 Project: Flink Issue Type: Sub-task Com

[jira] [Created] (FLINK-27028) Support to upload jar and run jar in RestClusterClient

Aitozi created FLINK-27028: -- Summary: Support to upload jar and run jar in RestClusterClient Key: FLINK-27028 URL: https://issues.apache.org/jira/browse/FLINK-27028 Project: Flink Issue Type: Improv

[jira] [Created] (FLINK-27001) Support to specify the resource of the operator

Aitozi created FLINK-27001: -- Summary: Support to specify the resource of the operator Key: FLINK-27001 URL: https://issues.apache.org/jira/browse/FLINK-27001 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-27000) Support to set JVM args for operator

Aitozi created FLINK-27000: -- Summary: Support to set JVM args for operator Key: FLINK-27000 URL: https://issues.apache.org/jira/browse/FLINK-27000 Project: Flink Issue Type: Improvement Co

[jira] [Created] (FLINK-26996) Break the reconcile after first create session cluster

Aitozi created FLINK-26996: -- Summary: Break the reconcile after first create session cluster Key: FLINK-26996 URL: https://issues.apache.org/jira/browse/FLINK-26996 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-26989) Fix the potential lost of secondary resource when watching a namespace

Aitozi created FLINK-26989: -- Summary: Fix the potential lost of secondary resource when watching a namespace Key: FLINK-26989 URL: https://issues.apache.org/jira/browse/FLINK-26989 Project: Flink I

[jira] [Created] (FLINK-26915) Extend the Reconciler and Observer interface

Aitozi created FLINK-26915: -- Summary: Extend the Reconciler and Observer interface Key: FLINK-26915 URL: https://issues.apache.org/jira/browse/FLINK-26915 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-26889) Eliminate the duplicated construct for FlinkOperatorConfiguration in test

Aitozi created FLINK-26889: -- Summary: Eliminate the duplicated construct for FlinkOperatorConfiguration in test Key: FLINK-26889 URL: https://issues.apache.org/jira/browse/FLINK-26889 Project: Flink

[jira] [Created] (FLINK-26873) Align the helm chart version with the flink operator

Aitozi created FLINK-26873: -- Summary: Align the helm chart version with the flink operator Key: FLINK-26873 URL: https://issues.apache.org/jira/browse/FLINK-26873 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-26871) Handle Session job spec change

Aitozi created FLINK-26871: -- Summary: Handle Session job spec change Key: FLINK-26871 URL: https://issues.apache.org/jira/browse/FLINK-26871 Project: Flink Issue Type: Sub-task Reporter

[jira] [Created] (FLINK-26870) Implement session job observer

Aitozi created FLINK-26870: -- Summary: Implement session job observer Key: FLINK-26870 URL: https://issues.apache.org/jira/browse/FLINK-26870 Project: Flink Issue Type: Sub-task Reporter:

[jira] [Created] (FLINK-26807) The batch job not work well with Operator

Aitozi created FLINK-26807: -- Summary: The batch job not work well with Operator Key: FLINK-26807 URL: https://issues.apache.org/jira/browse/FLINK-26807 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-26795) Fix the CI not fail fast after build failed

Aitozi created FLINK-26795: -- Summary: Fix the CI not fail fast after build failed Key: FLINK-26795 URL: https://issues.apache.org/jira/browse/FLINK-26795 Project: Flink Issue Type: Bug Co

[jira] [Created] (FLINK-26787) Implement FlinkSessionJobController and Reconciler

Aitozi created FLINK-26787: -- Summary: Implement FlinkSessionJobController and Reconciler Key: FLINK-26787 URL: https://issues.apache.org/jira/browse/FLINK-26787 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-26785) Add FlinkSessionJob CRD

Aitozi created FLINK-26785: -- Summary: Add FlinkSessionJob CRD Key: FLINK-26785 URL: https://issues.apache.org/jira/browse/FLINK-26785 Project: Flink Issue Type: Sub-task Components: Kubern

[jira] [Created] (FLINK-26784) FLIP-215: Introduce FlinkSessionJob CRD in the kubernetes operator

Aitozi created FLINK-26784: -- Summary: FLIP-215: Introduce FlinkSessionJob CRD in the kubernetes operator Key: FLINK-26784 URL: https://issues.apache.org/jira/browse/FLINK-26784 Project: Flink Issue

[jira] [Created] (FLINK-26776) The LocalBufferPoolDestroyTest#isInBlockingBufferRequest is fragile in different JDK environment

Aitozi created FLINK-26776: -- Summary: The LocalBufferPoolDestroyTest#isInBlockingBufferRequest is fragile in different JDK environment Key: FLINK-26776 URL: https://issues.apache.org/jira/browse/FLINK-26776

[jira] [Created] (FLINK-26754) KafkaCommitterTest#testRetryCommittableOnRetriableError stuck

Aitozi created FLINK-26754: -- Summary: KafkaCommitterTest#testRetryCommittableOnRetriableError stuck Key: FLINK-26754 URL: https://issues.apache.org/jira/browse/FLINK-26754 Project: Flink Issue Type

[jira] [Created] (FLINK-26737) Add CRD management in development doc

Aitozi created FLINK-26737: -- Summary: Add CRD management in development doc Key: FLINK-26737 URL: https://issues.apache.org/jira/browse/FLINK-26737 Project: Flink Issue Type: Sub-task Com

[jira] [Created] (FLINK-26719) Rethink the default reschedule reconcile loop

Aitozi created FLINK-26719: -- Summary: Rethink the default reschedule reconcile loop Key: FLINK-26719 URL: https://issues.apache.org/jira/browse/FLINK-26719 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-26528) Trigger the updateControl when the FlinkDeployment have changed

Aitozi created FLINK-26528: -- Summary: Trigger the updateControl when the FlinkDeployment have changed Key: FLINK-26528 URL: https://issues.apache.org/jira/browse/FLINK-26528 Project: Flink Issue Ty

[jira] [Created] (FLINK-26493) Use state machine based mechanism to simply the reconciler

Aitozi created FLINK-26493: -- Summary: Use state machine based mechanism to simply the reconciler Key: FLINK-26493 URL: https://issues.apache.org/jira/browse/FLINK-26493 Project: Flink Issue Type: Su

[jira] [Created] (FLINK-26435) Provide the container name for CI debug log

Aitozi created FLINK-26435: -- Summary: Provide the container name for CI debug log Key: FLINK-26435 URL: https://issues.apache.org/jira/browse/FLINK-26435 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-26399) Make some option of operator configurable

Aitozi created FLINK-26399: -- Summary: Make some option of operator configurable Key: FLINK-26399 URL: https://issues.apache.org/jira/browse/FLINK-26399 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-26356) Revisit the create of RestClusterClient

Aitozi created FLINK-26356: -- Summary: Revisit the create of RestClusterClient Key: FLINK-26356 URL: https://issues.apache.org/jira/browse/FLINK-26356 Project: Flink Issue Type: Sub-task Co

[jira] [Created] (FLINK-26339) Introduce the webhook config to free the environment options

Aitozi created FLINK-26339: -- Summary: Introduce the webhook config to free the environment options Key: FLINK-26339 URL: https://issues.apache.org/jira/browse/FLINK-26339 Project: Flink Issue Type:

[jira] [Created] (FLINK-26337) Avoid load flink conf each reconcile loop

Aitozi created FLINK-26337: -- Summary: Avoid load flink conf each reconcile loop Key: FLINK-26337 URL: https://issues.apache.org/jira/browse/FLINK-26337 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-26332) Move the Operator Env to the common Utils

Aitozi created FLINK-26332: -- Summary: Move the Operator Env to the common Utils Key: FLINK-26332 URL: https://issues.apache.org/jira/browse/FLINK-26332 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-26112) Port getEndpoint method to the specific service type subclass

Aitozi created FLINK-26112: -- Summary: Port getEndpoint method to the specific service type subclass Key: FLINK-26112 URL: https://issues.apache.org/jira/browse/FLINK-26112 Project: Flink Issue Type

[jira] [Created] (FLINK-25660) Failed to build flink-runtime-web

Aitozi created FLINK-25660: -- Summary: Failed to build flink-runtime-web Key: FLINK-25660 URL: https://issues.apache.org/jira/browse/FLINK-25660 Project: Flink Issue Type: Bug Reporter: A

[jira] [Created] (FLINK-25580) Minor improvements for RocksDBIncrementalCheckpointUtils

Aitozi created FLINK-25580: -- Summary: Minor improvements for RocksDBIncrementalCheckpointUtils Key: FLINK-25580 URL: https://issues.apache.org/jira/browse/FLINK-25580 Project: Flink Issue Type: Impr

[jira] [Created] (FLINK-24967) Make the IO pattern configureable in state benchmarks

Aitozi created FLINK-24967: -- Summary: Make the IO pattern configureable in state benchmarks Key: FLINK-24967 URL: https://issues.apache.org/jira/browse/FLINK-24967 Project: Flink Issue Type: Improve

[jira] [Created] (FLINK-24918) Support to specify the data dir for state benchmark

Aitozi created FLINK-24918: -- Summary: Support to specify the data dir for state benchmark Key: FLINK-24918 URL: https://issues.apache.org/jira/browse/FLINK-24918 Project: Flink Issue Type: Improvem

[jira] [Created] (FLINK-24755) sun.misc doesn't exist

Aitozi created FLINK-24755: -- Summary: sun.misc doesn't exist Key: FLINK-24755 URL: https://issues.apache.org/jira/browse/FLINK-24755 Project: Flink Issue Type: Bug Components: Build System

[jira] [Created] (FLINK-24713) Postpone resourceManager serving after the recovery phase has finished

Aitozi created FLINK-24713: -- Summary: Postpone resourceManager serving after the recovery phase has finished Key: FLINK-24713 URL: https://issues.apache.org/jira/browse/FLINK-24713 Project: Flink I

[jira] [Created] (FLINK-24633) JobManager pod may stuck in containerCreating status during failover

Aitozi created FLINK-24633: -- Summary: JobManager pod may stuck in containerCreating status during failover Key: FLINK-24633 URL: https://issues.apache.org/jira/browse/FLINK-24633 Project: Flink Iss

[jira] [Created] (FLINK-24631) Avoiding directly use the labels as selector for deployment and service

Aitozi created FLINK-24631: -- Summary: Avoiding directly use the labels as selector for deployment and service Key: FLINK-24631 URL: https://issues.apache.org/jira/browse/FLINK-24631 Project: Flink

[jira] [Created] (FLINK-24625) Expose the required kubernetes permission from the shell command

Aitozi created FLINK-24625: -- Summary: Expose the required kubernetes permission from the shell command Key: FLINK-24625 URL: https://issues.apache.org/jira/browse/FLINK-24625 Project: Flink Issue T

[jira] [Created] (FLINK-24624) Add clean up phase when kubernetes session start failed

Aitozi created FLINK-24624: -- Summary: Add clean up phase when kubernetes session start failed Key: FLINK-24624 URL: https://issues.apache.org/jira/browse/FLINK-24624 Project: Flink Issue Type: Impro

[jira] [Created] (FLINK-24455) FallbackAkkaRpcSystemLoader can't run through with

Aitozi created FLINK-24455: -- Summary: FallbackAkkaRpcSystemLoader can't run through with Key: FLINK-24455 URL: https://issues.apache.org/jira/browse/FLINK-24455 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-24451) Replace the scattered objects with encapsulated LeaderInformation in DefaultLeaderElectionService

Aitozi created FLINK-24451: -- Summary: Replace the scattered objects with encapsulated LeaderInformation in DefaultLeaderElectionService Key: FLINK-24451 URL: https://issues.apache.org/jira/browse/FLINK-24451

[jira] [Created] (FLINK-24167) Split HeartbeatTarget to HeartbeatReceiver and HeartbeatSender

Aitozi created FLINK-24167: -- Summary: Split HeartbeatTarget to HeartbeatReceiver and HeartbeatSender Key: FLINK-24167 URL: https://issues.apache.org/jira/browse/FLINK-24167 Project: Flink Issue Ty

[jira] [Created] (FLINK-24124) Use explicit pool size to construct thread pool instead of Hardware.getNumberCPUCores()

Aitozi created FLINK-24124: -- Summary: Use explicit pool size to construct thread pool instead of Hardware.getNumberCPUCores() Key: FLINK-24124 URL: https://issues.apache.org/jira/browse/FLINK-24124 Project:

  1   2   >