[jira] [Created] (FLINK-38415) IndexOutOfBoundsException occasionally occursIndexOutOfBoundsException in rocksdb.use-ingest-db-restore-mode after rocksdb.use-ingest-db-restore-mode is enabled

URL: https://issues.apache.org/jira/browse/FLINK-38415 Project: Flink Issue Type: Bug Affects Versions: 2.1.0, 2.0.0, 1.20.3 Reporter: Rui Fan Assignee: Rui Fan Following is the exception stack: {code:java} java.lang.IndexOutOfBoundsException

[jira] [Created] (FLINK-38471) flink-end-to-end-tests-common-kafka depends implicitely on kafka-sql-connector

Fabian Paul created FLINK-38471: --- Summary: flink-end-to-end-tests-common-kafka depends implicitely on kafka-sql-connector Key: FLINK-38471 URL: https://issues.apache.org/jira/browse/FLINK-38471 Project

[jira] [Created] (FLINK-38470) Make CreateMaterializedTableOperation return ResolvedCatalogMaterializedTable

Ramin Gharib created FLINK-38470: Summary: Make CreateMaterializedTableOperation return ResolvedCatalogMaterializedTable Key: FLINK-38470 URL: https://issues.apache.org/jira/browse/FLINK-38470

[jira] [Created] (FLINK-38469) Bump apache-beam for PyFlink to >= 2.66 to address CVE-2024-52338 for pyarrow

Wren created FLINK-38469: Summary: Bump apache-beam for PyFlink to >= 2.66 to address CVE-2024-52338 for pyarrow Key: FLINK-38469 URL: https://issues.apache.org/jira/browse/FLINK-38469 Project: Fl

[jira] [Created] (FLINK-38463) Support TTL in SinkUpsertMaterializerV2

Roman Khachatryan created FLINK-38463: - Summary: Support TTL in SinkUpsertMaterializerV2 Key: FLINK-38463 URL: https://issues.apache.org/jira/browse/FLINK-38463 Project: Flink Issue Type

[jira] [Created] (FLINK-38458) Extract SchemaConverter and ReferenceManager to make them reusable

Sergey Nuyanzin created FLINK-38458: --- Summary: Extract SchemaConverter and ReferenceManager to make them reusable Key: FLINK-38458 URL: https://issues.apache.org/jira/browse/FLINK-38458 Project

[jira] [Created] (FLINK-38455) MySQL CDC to ES8 pipeline connector cannot work

li yong created FLINK-38455: --- Summary: MySQL CDC to ES8 pipeline connector cannot work Key: FLINK-38455 URL: https://issues.apache.org/jira/browse/FLINK-38455 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-38450) flink-cdc sink to iceberg table record duplication

ChaoFang created FLINK-38450: Summary: flink-cdc sink to iceberg table record duplication Key: FLINK-38450 URL: https://issues.apache.org/jira/browse/FLINK-38450 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-38423) Add vector search connector API

Shengkai Fang created FLINK-38423: - Summary: Add vector search connector API Key: FLINK-38423 URL: https://issues.apache.org/jira/browse/FLINK-38423 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-38448) Fix doc CI rsync logic

Ferenc Csaky created FLINK-38448: Summary: Fix doc CI rsync logic Key: FLINK-38448 URL: https://issues.apache.org/jira/browse/FLINK-38448 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-38449) Makes error message for fractional values for MemorySize explicit

Navin Viswanath created FLINK-38449: --- Summary: Makes error message for fractional values for MemorySize explicit Key: FLINK-38449 URL: https://issues.apache.org/jira/browse/FLINK-38449 Project

[jira] [Created] (FLINK-38447) Add table sink support for Elasticsearch 8 connector

lwn created FLINK-38447: --- Summary: Add table sink support for Elasticsearch 8 connector Key: FLINK-38447 URL: https://issues.apache.org/jira/browse/FLINK-38447 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-38446) Pyflink explain() crashes with Index Out Of Bounds

Ahmad Humayun created FLINK-38446: - Summary: Pyflink explain() crashes with Index Out Of Bounds Key: FLINK-38446 URL: https://issues.apache.org/jira/browse/FLINK-38446 Project: Flink Issue

[jira] [Created] (FLINK-38428) Support to call vector search with literal value

Shengkai Fang created FLINK-38428: - Summary: Support to call vector search with literal value Key: FLINK-38428 URL: https://issues.apache.org/jira/browse/FLINK-38428 Project: Flink Issue

[jira] [Created] (FLINK-38443) Adapt TIDB CDC Connector to FLIP-27 API

Yanquan Lv created FLINK-38443: -- Summary: Adapt TIDB CDC Connector to FLIP-27 API Key: FLINK-38443 URL: https://issues.apache.org/jira/browse/FLINK-38443 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-38442) ProfilingServiceTest.testRollingDeletion is unstable

Sergey Nuyanzin created FLINK-38442: --- Summary: ProfilingServiceTest.testRollingDeletion is unstable Key: FLINK-38442 URL: https://issues.apache.org/jira/browse/FLINK-38442 Project: Flink

[jira] [Created] (FLINK-38412) Refactor MultiJoin test with state ttl to avoid state expiration

Gustavo de Morais created FLINK-38412: - Summary: Refactor MultiJoin test with state ttl to avoid state expiration Key: FLINK-38412 URL: https://issues.apache.org/jira/browse/FLINK-38412 Project

[jira] [Created] (FLINK-38441) ExecutionGraphCoLocationRestartTest failed in test_ci core

Ruan Hang created FLINK-38441: - Summary: ExecutionGraphCoLocationRestartTest failed in test_ci core Key: FLINK-38441 URL: https://issues.apache.org/jira/browse/FLINK-38441 Project: Flink Issue

[jira] [Created] (FLINK-38440) flink-cdc sink iceberg write SMALLINT/TINYINT data wrong

ChaoFang created FLINK-38440: Summary: flink-cdc sink iceberg write SMALLINT/TINYINT data wrong Key: FLINK-38440 URL: https://issues.apache.org/jira/browse/FLINK-38440 Project: Flink Issue Type

[jira] [Created] (FLINK-38439) SqlGatewayServiceITCase failed in test_cron_azure table

Ruan Hang created FLINK-38439: - Summary: SqlGatewayServiceITCase failed in test_cron_azure table Key: FLINK-38439 URL: https://issues.apache.org/jira/browse/FLINK-38439 Project: Flink Issue Type

[jira] [Created] (FLINK-38438) Support session mini cluster when use local executor.

Weijun Wang created FLINK-38438: --- Summary: Support session mini cluster when use local executor. Key: FLINK-38438 URL: https://issues.apache.org/jira/browse/FLINK-38438 Project: Flink Issue

[jira] [Created] (FLINK-38420) Initial BlueGreenDeployment code contribution

Gyula Fora created FLINK-38420: -- Summary: Initial BlueGreenDeployment code contribution Key: FLINK-38420 URL: https://issues.apache.org/jira/browse/FLINK-38420 Project: Flink Issue Type: Sub

[jira] [Created] (FLINK-38436) Add document for VECTOR_SEARCH function

Shengkai Fang created FLINK-38436: - Summary: Add document for VECTOR_SEARCH function Key: FLINK-38436 URL: https://issues.apache.org/jira/browse/FLINK-38436 Project: Flink Issue Type: Sub

[jira] [Created] (FLINK-38433) Avoid delete ForSt's directory when there happened to be an existing one

Zakelly Lan created FLINK-38433: --- Summary: Avoid delete ForSt's directory when there happened to be an existing one Key: FLINK-38433 URL: https://issues.apache.org/jira/browse/FLINK-38433 Pr

[jira] [Created] (FLINK-38434) Avoid delete ForSt's directory when there happened to be an existing one

Zakelly Lan created FLINK-38434: --- Summary: Avoid delete ForSt's directory when there happened to be an existing one Key: FLINK-38434 URL: https://issues.apache.org/jira/browse/FLINK-38434 Pr

[jira] [Created] (FLINK-38432) Missing finish/reset for keyWriter/valueWriter in ArrowMapWriter

Frank Wong created FLINK-38432: -- Summary: Missing finish/reset for keyWriter/valueWriter in ArrowMapWriter Key: FLINK-38432 URL: https://issues.apache.org/jira/browse/FLINK-38432 Project: Flink

[jira] [Created] (FLINK-38429) Improve perf for Elasticsearch 8 connector

Jiaan Geng created FLINK-38429: -- Summary: Improve perf for Elasticsearch 8 connector Key: FLINK-38429 URL: https://issues.apache.org/jira/browse/FLINK-38429 Project: Flink Issue Type

[jira] [Created] (FLINK-38431) Support VECTOR_SEARCH in batch mode

Shengkai Fang created FLINK-38431: - Summary: Support VECTOR_SEARCH in batch mode Key: FLINK-38431 URL: https://issues.apache.org/jira/browse/FLINK-38431 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-38430) Support runtime config for VECTOR_SEARCH

Shengkai Fang created FLINK-38430: - Summary: Support runtime config for VECTOR_SEARCH Key: FLINK-38430 URL: https://issues.apache.org/jira/browse/FLINK-38430 Project: Flink Issue Type: Sub

[jira] [Created] (FLINK-38422) FLIP-540: Support VECTOR_SEARCH in Flink SQL

Shengkai Fang created FLINK-38422: - Summary: FLIP-540: Support VECTOR_SEARCH in Flink SQL Key: FLINK-38422 URL: https://issues.apache.org/jira/browse/FLINK-38422 Project: Flink Issue Type

[jira] [Created] (FLINK-38418) Collecting TIMESTAMP_LTZ values in PyFlink fails with pickling error

Mika Naylor created FLINK-38418: --- Summary: Collecting TIMESTAMP_LTZ values in PyFlink fails with pickling error Key: FLINK-38418 URL: https://issues.apache.org/jira/browse/FLINK-38418 Project: Flink

[jira] [Created] (FLINK-38426) Reuse Lookup Join operator to build search operator

Shengkai Fang created FLINK-38426: - Summary: Reuse Lookup Join operator to build search operator Key: FLINK-38426 URL: https://issues.apache.org/jira/browse/FLINK-38426 Project: Flink Issue

[jira] [Created] (FLINK-38425) Add rule to convert correlate node to vector search node in physical phase

Shengkai Fang created FLINK-38425: - Summary: Add rule to convert correlate node to vector search node in physical phase Key: FLINK-38425 URL: https://issues.apache.org/jira/browse/FLINK-38425 Project

[jira] [Created] (FLINK-38427) Support to serde vector search execnode

Shengkai Fang created FLINK-38427: - Summary: Support to serde vector search execnode Key: FLINK-38427 URL: https://issues.apache.org/jira/browse/FLINK-38427 Project: Flink Issue Type: Sub

[jira] [Created] (FLINK-38421) BlueGreen Deployment Documentation

Gyula Fora created FLINK-38421: -- Summary: BlueGreen Deployment Documentation Key: FLINK-38421 URL: https://issues.apache.org/jira/browse/FLINK-38421 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-38419) Update official Flink docker images

Derek Chen-Becker created FLINK-38419: - Summary: Update official Flink docker images Key: FLINK-38419 URL: https://issues.apache.org/jira/browse/FLINK-38419 Project: Flink Issue Type

[jira] [Created] (FLINK-38417) Ensure attribute ordering when managing join attributes in JoinKeyExtractor

Gustavo de Morais created FLINK-38417: - Summary: Ensure attribute ordering when managing join attributes in JoinKeyExtractor Key: FLINK-38417 URL: https://issues.apache.org/jira/browse/FLINK-38417

[jira] [Created] (FLINK-38413) Support Append Only table from MySQL Pipeline Connectors

Muhammad created FLINK-38413: Summary: Support Append Only table from MySQL Pipeline Connectors Key: FLINK-38413 URL: https://issues.apache.org/jira/browse/FLINK-38413 Project: Flink Issue Type

[jira] [Created] (FLINK-38411) Array index overflow in enumerator with continuous file source

Simon Frei created FLINK-38411: -- Summary: Array index overflow in enumerator with continuous file source Key: FLINK-38411 URL: https://issues.apache.org/jira/browse/FLINK-38411 Project: Flink

[jira] [Created] (FLINK-38409) Showcase in Helm chart values.yaml that config.yaml can be used

Attila Mészáros created FLINK-38409: --- Summary: Showcase in Helm chart values.yaml that config.yaml can be used Key: FLINK-38409 URL: https://issues.apache.org/jira/browse/FLINK-38409 Project: Flink

[jira] [Created] (FLINK-38405) ChangelogNormalizeRestoreTest failed in test_cron_azure table

Ruan Hang created FLINK-38405: - Summary: ChangelogNormalizeRestoreTest failed in test_cron_azure table Key: FLINK-38405 URL: https://issues.apache.org/jira/browse/FLINK-38405 Project: Flink

[jira] [Created] (FLINK-38408) MapStateNullValueCheckpointingITCase failed in test_cron_azure tests

Ruan Hang created FLINK-38408: - Summary: MapStateNullValueCheckpointingITCase failed in test_cron_azure tests Key: FLINK-38408 URL: https://issues.apache.org/jira/browse/FLINK-38408 Project: Flink

[jira] [Created] (FLINK-38407) GroupAggregateRestoreTest failed in test_cron_azure table

Ruan Hang created FLINK-38407: - Summary: GroupAggregateRestoreTest failed in test_cron_azure table Key: FLINK-38407 URL: https://issues.apache.org/jira/browse/FLINK-38407 Project: Flink Issue

[jira] [Created] (FLINK-38406) DefaultSchedulerCheckpointCoordinatorTest failed in test_ci core

Ruan Hang created FLINK-38406: - Summary: DefaultSchedulerCheckpointCoordinatorTest failed in test_ci core Key: FLINK-38406 URL: https://issues.apache.org/jira/browse/FLINK-38406 Project: Flink

[jira] [Created] (FLINK-38404) JobMasterTest failed in test_cron_adaptive_scheduler core

Ruan Hang created FLINK-38404: - Summary: JobMasterTest failed in test_cron_adaptive_scheduler core Key: FLINK-38404 URL: https://issues.apache.org/jira/browse/FLINK-38404 Project: Flink Issue

[jira] [Created] (FLINK-38403) UnalignedCheckpointITCase failed in test_cron_hadoop313 tests

Ruan Hang created FLINK-38403: - Summary: UnalignedCheckpointITCase failed in test_cron_hadoop313 tests Key: FLINK-38403 URL: https://issues.apache.org/jira/browse/FLINK-38403 Project: Flink

[jira] [Created] (FLINK-38402) EventTimeWindowCheckpointingITCase failed in test_cron_azure tests

Ruan Hang created FLINK-38402: - Summary: EventTimeWindowCheckpointingITCase failed in test_cron_azure tests Key: FLINK-38402 URL: https://issues.apache.org/jira/browse/FLINK-38402 Project: Flink

[jira] [Created] (FLINK-38401) Add MultiJoin MetadataHandler for FlinkRelMdUpsertKeys

Gustavo de Morais created FLINK-38401: - Summary: Add MultiJoin MetadataHandler for FlinkRelMdUpsertKeys Key: FLINK-38401 URL: https://issues.apache.org/jira/browse/FLINK-38401 Project: Flink

[jira] [Created] (FLINK-38398) Improve postgresSQL field Type supported ‘Temporal types Mapping’

ouyangwulin created FLINK-38398: --- Summary: Improve postgresSQL field Type supported ‘Temporal types Mapping’ Key: FLINK-38398 URL: https://issues.apache.org/jira/browse/FLINK-38398 Project: Flink

[jira] [Created] (FLINK-38400) STDDEV/VAR function with FILTER condition may cause wrong result

lincoln lee created FLINK-38400: --- Summary: STDDEV/VAR function with FILTER condition may cause wrong result Key: FLINK-38400 URL: https://issues.apache.org/jira/browse/FLINK-38400 Project: Flink

[jira] [Created] (FLINK-38399) As long as the join key includes one of the indexes from the source, the join can be converted into a delta join

Xuyang Zhong created FLINK-38399: Summary: As long as the join key includes one of the indexes from the source, the join can be converted into a delta join Key: FLINK-38399 URL: https://issues.apache.org/jira

[jira] [Created] (FLINK-38397) Runtime Exception in Planner

Ahmad Humayun created FLINK-38397: - Summary: Runtime Exception in Planner Key: FLINK-38397 URL: https://issues.apache.org/jira/browse/FLINK-38397 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-38396) DefaultKubernetesArtifactUploaderTest fails locally

Sergey Nuyanzin created FLINK-38396: --- Summary: DefaultKubernetesArtifactUploaderTest fails locally Key: FLINK-38396 URL: https://issues.apache.org/jira/browse/FLINK-38396 Project: Flink

[jira] [Created] (FLINK-38344) The local files of the HistoryServer may risk never being deleted.

RocMarshal created FLINK-38344: -- Summary: The local files of the HistoryServer may risk never being deleted. Key: FLINK-38344 URL: https://issues.apache.org/jira/browse/FLINK-38344 Project: Flink

[jira] [Created] (FLINK-38366) Pyflink planner throws exception in batch mode when there is no limit on order_by()

Ahmad Humayun created FLINK-38366: - Summary: Pyflink planner throws exception in batch mode when there is no limit on order_by() Key: FLINK-38366 URL: https://issues.apache.org/jira/browse/FLINK-38366

[jira] [Created] (FLINK-38341) Introduce the rescale history configuration option.

RocMarshal created FLINK-38341: -- Summary: Introduce the rescale history configuration option. Key: FLINK-38341 URL: https://issues.apache.org/jira/browse/FLINK-38341 Project: Flink Issue Type

[jira] [Created] (FLINK-38395) Enable/fix the Flink Operator e2e tests for Blue/Green Deployments

Sergio Chong created FLINK-38395: Summary: Enable/fix the Flink Operator e2e tests for Blue/Green Deployments Key: FLINK-38395 URL: https://issues.apache.org/jira/browse/FLINK-38395 Project: Flink

[jira] [Created] (FLINK-38394) Upgrade Flink CDC to Flink 2

Mohsen Rezaei created FLINK-38394: - Summary: Upgrade Flink CDC to Flink 2 Key: FLINK-38394 URL: https://issues.apache.org/jira/browse/FLINK-38394 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-38393) Pipeline transform schema consistency check should be loosen for unreachable rules

Xiqian Yu created FLINK-38393: - Summary: Pipeline transform schema consistency check should be loosen for unreachable rules Key: FLINK-38393 URL: https://issues.apache.org/jira/browse/FLINK-38393 Project

[jira] [Created] (FLINK-38378) Use ValidationException in CatalogManager in case of user error

Sergey Nuyanzin created FLINK-38378: --- Summary: Use ValidationException in CatalogManager in case of user error Key: FLINK-38378 URL: https://issues.apache.org/jira/browse/FLINK-38378 Project: Flink

[jira] [Created] (FLINK-38392) StreamPandasConversionTests failing

Samrat Deb created FLINK-38392: -- Summary: StreamPandasConversionTests failing Key: FLINK-38392 URL: https://issues.apache.org/jira/browse/FLINK-38392 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-38391) Error creating shaded jar: Problem shading JAR Unsupported class file major version 69

Sergey Nuyanzin created FLINK-38391: --- Summary: Error creating shaded jar: Problem shading JAR Unsupported class file major version 69 Key: FLINK-38391 URL: https://issues.apache.org/jira/browse/FLINK-38391

[jira] [Created] (FLINK-38390) Compiliation of flink-core and flink-table-planner fails because of annotation processors

Sergey Nuyanzin created FLINK-38390: --- Summary: Compiliation of flink-core and flink-table-planner fails because of annotation processors Key: FLINK-38390 URL: https://issues.apache.org/jira/browse/FLINK-38390

[jira] [Created] (FLINK-38389) Add .show(), .head() and .tail() method to PyFlink Table API

Zander Matheson created FLINK-38389: --- Summary: Add .show(), .head() and .tail() method to PyFlink Table API Key: FLINK-38389 URL: https://issues.apache.org/jira/browse/FLINK-38389 Project: Flink

[jira] [Created] (FLINK-38388) FLIP-541 Umbrella Issue

Zander Matheson created FLINK-38388: --- Summary: FLIP-541 Umbrella Issue Key: FLINK-38388 URL: https://issues.apache.org/jira/browse/FLINK-38388 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-38379) Adjust visitMultiJoin in RelTimeIndicatorConverter to use fields and not rows

Gustavo de Morais created FLINK-38379: - Summary: Adjust visitMultiJoin in RelTimeIndicatorConverter to use fields and not rows Key: FLINK-38379 URL: https://issues.apache.org/jira/browse/FLINK-38379

[jira] [Created] (FLINK-38382) Confluent Schema Registry to support primitive types

nicolas paris created FLINK-38382: - Summary: Confluent Schema Registry to support primitive types Key: FLINK-38382 URL: https://issues.apache.org/jira/browse/FLINK-38382 Project: Flink Issue

[jira] [Created] (FLINK-38387) Bump spotless

Sergey Nuyanzin created FLINK-38387: --- Summary: Bump spotless Key: FLINK-38387 URL: https://issues.apache.org/jira/browse/FLINK-38387 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-38385) Bump byte-buddy to 1.17.6

Sergey Nuyanzin created FLINK-38385: --- Summary: Bump byte-buddy to 1.17.6 Key: FLINK-38385 URL: https://issues.apache.org/jira/browse/FLINK-38385 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-38386) Cannot attach type annotations @org.checkerframework.checker.nullness.qual.Nullable

Sergey Nuyanzin created FLINK-38386: --- Summary: Cannot attach type annotations @org.checkerframework.checker.nullness.qual.Nullable Key: FLINK-38386 URL: https://issues.apache.org/jira/browse/FLINK-38386

[jira] [Created] (FLINK-38376) AsyncStateStreamingJoinOperator should not OOM due to collecting all matching records in memory

Roman Khachatryan created FLINK-38376: - Summary: AsyncStateStreamingJoinOperator should not OOM due to collecting all matching records in memory Key: FLINK-38376 URL: https://issues.apache.org/jira/browse

[jira] [Created] (FLINK-38380) MySQL cdc may skip data in the GTID disordered scenario even after GTID merged

Yanquan Lv created FLINK-38380: -- Summary: MySQL cdc may skip data in the GTID disordered scenario even after GTID merged Key: FLINK-38380 URL: https://issues.apache.org/jira/browse/FLINK-38380 Project

[jira] [Created] (FLINK-38384) Bump lombok to 1.18.40

Sergey Nuyanzin created FLINK-38384: --- Summary: Bump lombok to 1.18.40 Key: FLINK-38384 URL: https://issues.apache.org/jira/browse/FLINK-38384 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-38383) Automatically republish Flink Kubernetes Operator image when base image receives security patches

Jaydeep Karia created FLINK-38383: - Summary: Automatically republish Flink Kubernetes Operator image when base image receives security patches Key: FLINK-38383 URL: https://issues.apache.org/jira/browse/FLINK

[jira] [Created] (FLINK-38381) Autoscaler does not enumerate partitions across kafka clusters

Maximilian Michels created FLINK-38381: -- Summary: Autoscaler does not enumerate partitions across kafka clusters Key: FLINK-38381 URL: https://issues.apache.org/jira/browse/FLINK-38381 Project

[jira] [Created] (FLINK-38377) SQL Job Submission in the Flink Kubernetes Operator via SQL Gateway

yuanfenghu created FLINK-38377: -- Summary: SQL Job Submission in the Flink Kubernetes Operator via SQL Gateway Key: FLINK-38377 URL: https://issues.apache.org/jira/browse/FLINK-38377 Project: Flink

[jira] [Created] (FLINK-38368) Potential Feedback Loop Involving a Heavy User Defined Aggregation Task

Shangshu Qian created FLINK-38368: - Summary: Potential Feedback Loop Involving a Heavy User Defined Aggregation Task Key: FLINK-38368 URL: https://issues.apache.org/jira/browse/FLINK-38368 Project

[jira] [Created] (FLINK-38375) Flink Resouce leak on Flink k8s

xiaolong3817 created FLINK-38375: Summary: Flink Resouce leak on Flink k8s Key: FLINK-38375 URL: https://issues.apache.org/jira/browse/FLINK-38375 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-38332) Upgrade pemja to 0.6.1

Xuannan Su created FLINK-38332: -- Summary: Upgrade pemja to 0.6.1 Key: FLINK-38332 URL: https://issues.apache.org/jira/browse/FLINK-38332 Project: Flink Issue Type: Bug Components: API

[jira] [Created] (FLINK-38374) Add Artifact keyword as an option to create function syntax

Zander Matheson created FLINK-38374: --- Summary: Add Artifact keyword as an option to create function syntax Key: FLINK-38374 URL: https://issues.apache.org/jira/browse/FLINK-38374 Project: Flink

[jira] [Created] (FLINK-38338) Introduce the abstraction to describe a rescale event.

RocMarshal created FLINK-38338: -- Summary: Introduce the abstraction to describe a rescale event. Key: FLINK-38338 URL: https://issues.apache.org/jira/browse/FLINK-38338 Project: Flink Issue

[jira] [Created] (FLINK-38335) SplitEnumeratorContext supports fixed delay async call.

Hongshun Wang created FLINK-38335: - Summary: SplitEnumeratorContext supports fixed delay async call. Key: FLINK-38335 URL: https://issues.apache.org/jira/browse/FLINK-38335 Project: Flink

[jira] [Created] (FLINK-38370) CommitterOperator does not checkpoint all pending committables

Maximilian Michels created FLINK-38370: -- Summary: CommitterOperator does not checkpoint all pending committables Key: FLINK-38370 URL: https://issues.apache.org/jira/browse/FLINK-38370 Project

[jira] [Created] (FLINK-38373) Support dynamic index generation with field value suffix

Liu created FLINK-38373: --- Summary: Support dynamic index generation with field value suffix Key: FLINK-38373 URL: https://issues.apache.org/jira/browse/FLINK-38373 Project: Flink Issue Type

[jira] [Created] (FLINK-38372) Introduces whitelist to the flink-metrics-prometheus

Liu created FLINK-38372: --- Summary: Introduces whitelist to the flink-metrics-prometheus Key: FLINK-38372 URL: https://issues.apache.org/jira/browse/FLINK-38372 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-38371) Add `sink.retry-on-conflicts` option to Elasticsearch Sink

Liu created FLINK-38371: --- Summary: Add `sink.retry-on-conflicts` option to Elasticsearch Sink Key: FLINK-38371 URL: https://issues.apache.org/jira/browse/FLINK-38371 Project: Flink Issue Type

[jira] [Created] (FLINK-38369) RestClientTest failed in test_cron_hadoop313 core

Ruan Hang created FLINK-38369: - Summary: RestClientTest failed in test_cron_hadoop313 core Key: FLINK-38369 URL: https://issues.apache.org/jira/browse/FLINK-38369 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-38367) Potential Feedback Loop Between IterationHeadTask and SynchronizationSinkTask

Shangshu Qian created FLINK-38367: - Summary: Potential Feedback Loop Between IterationHeadTask and SynchronizationSinkTask Key: FLINK-38367 URL: https://issues.apache.org/jira/browse/FLINK-38367

[jira] [Created] (FLINK-38364) Converter from `ProcessingTimeoutTrigger` with any nested timer to the async version

Zakelly Lan created FLINK-38364: --- Summary: Converter from `ProcessingTimeoutTrigger` with any nested timer to the async version Key: FLINK-38364 URL: https://issues.apache.org/jira/browse/FLINK-38364

[jira] [Created] (FLINK-38365) ClassCastException while different operations with MATERIALIZED TABLE

Sergey Nuyanzin created FLINK-38365: --- Summary: ClassCastException while different operations with MATERIALIZED TABLE Key: FLINK-38365 URL: https://issues.apache.org/jira/browse/FLINK-38365 Project

[jira] [Created] (FLINK-38363) WindowedStream.trigger supports trigger with async state

Zakelly Lan created FLINK-38363: --- Summary: WindowedStream.trigger supports trigger with async state Key: FLINK-38363 URL: https://issues.apache.org/jira/browse/FLINK-38363 Project: Flink Issue

[jira] [Created] (FLINK-38362) Reduce the time cost in checkpoint when writing many tables to StarRocks sink

Yanquan Lv created FLINK-38362: -- Summary: Reduce the time cost in checkpoint when writing many tables to StarRocks sink Key: FLINK-38362 URL: https://issues.apache.org/jira/browse/FLINK-38362 Project

[jira] [Created] (FLINK-38361) ChangelogRecoverySwitchStateBackendITCase failed in test_ci tests

Ruan Hang created FLINK-38361: - Summary: ChangelogRecoverySwitchStateBackendITCase failed in test_ci tests Key: FLINK-38361 URL: https://issues.apache.org/jira/browse/FLINK-38361 Project: Flink

[jira] [Created] (FLINK-38360) HadoopRecoverableWriterTest failed in test_cron_adaptive_scheduler connect

Ruan Hang created FLINK-38360: - Summary: HadoopRecoverableWriterTest failed in test_cron_adaptive_scheduler connect Key: FLINK-38360 URL: https://issues.apache.org/jira/browse/FLINK-38360 Project: Flink

[jira] [Created] (FLINK-38359) Avoid writing Record with update before/delete rowKind to Paimon append only table.

Yanquan Lv created FLINK-38359: -- Summary: Avoid writing Record with update before/delete rowKind to Paimon append only table. Key: FLINK-38359 URL: https://issues.apache.org/jira/browse/FLINK-38359

[jira] [Created] (FLINK-38358) Ignore trailing spaces in table capturing rules

Yanquan Lv created FLINK-38358: -- Summary: Ignore trailing spaces in table capturing rules Key: FLINK-38358 URL: https://issues.apache.org/jira/browse/FLINK-38358 Project: Flink Issue Type

[jira] [Created] (FLINK-38357) ResultSubpartitionRecoveredStateHandler.getSubpartition ArrayIndexOutOfBoundException 0

Xinglong Wang created FLINK-38357: - Summary: ResultSubpartitionRecoveredStateHandler.getSubpartition ArrayIndexOutOfBoundException 0 Key: FLINK-38357 URL: https://issues.apache.org/jira/browse/FLINK-38357

[jira] [Created] (FLINK-38356) Regenerating files for WATERMARK_ASSIGNER_PUSHDOWN_METADATA hangs

Dawid Wysakowicz created FLINK-38356: Summary: Regenerating files for WATERMARK_ASSIGNER_PUSHDOWN_METADATA hangs Key: FLINK-38356 URL: https://issues.apache.org/jira/browse/FLINK-38356 Project

[jira] [Created] (FLINK-38355) [FLIP-546] Introduce CREATE OR ALTER Syntax for Materialized Tables

Ramin Gharib created FLINK-38355: Summary: [FLIP-546] Introduce CREATE OR ALTER Syntax for Materialized Tables Key: FLINK-38355 URL: https://issues.apache.org/jira/browse/FLINK-38355 Project: Flink

[jira] [Created] (FLINK-38354) ClassCastException occurs when submitting a task to flink cdc

hunter created FLINK-38354: -- Summary: ClassCastException occurs when submitting a task to flink cdc Key: FLINK-38354 URL: https://issues.apache.org/jira/browse/FLINK-38354 Project: Flink Issue

  1   2   3   4   5   6   7   8   9   10   >