Yanquan Lv created FLINK-38185:
--
Summary: Failed case:
IcebergWriterTest.testWriteWithAllSupportedTypes
Key: FLINK-38185
URL: https://issues.apache.org/jira/browse/FLINK-38185
Project: Flink
Hongshun Wang created FLINK-38184:
-
Summary: CDC no need to getCopyOfBuffer for each split info.
Key: FLINK-38184
URL: https://issues.apache.org/jira/browse/FLINK-38184
Project: Flink
Issue
LiuZeshan created FLINK-38183:
-
Summary: Data loss when cdc reading mysql that has out of order
GTID
Key: FLINK-38183
URL: https://issues.apache.org/jira/browse/FLINK-38183
Project: Flink
Issue
richard_zhulh created FLINK-38182:
-
Summary: lastCheckpointDuration is not right.
Key: FLINK-38182
URL: https://issues.apache.org/jira/browse/FLINK-38182
Project: Flink
Issue Type: Bug
Ramin Gharib created FLINK-38181:
Summary: Code generation fails for ROW() with CAST to
SMALLINT/TINYINT when input is non-literal
Key: FLINK-38181
URL: https://issues.apache.org/jira/browse/FLINK-38181
Piotr Nowojski created FLINK-38180:
--
Summary: Race condition between failing Task and cancelation
hiding the real exception
Key: FLINK-38180
URL: https://issues.apache.org/jira/browse/FLINK-38180
Gong Xiaofei created FLINK-38179:
Summary: Build Failure Due to os-maven-plugin Missing Support
Key: FLINK-38179
URL: https://issues.apache.org/jira/browse/FLINK-38179
Project: Flink
Issue
Gong Xiaofei created FLINK-38178:
Summary: [RISC-V Support] - Comprehensive Tracking of RISC-V
Architecture Support in Apache Flink
Key: FLINK-38178
URL: https://issues.apache.org/jira/browse/FLINK-38178
Sergey Nuyanzin created FLINK-38177:
---
Summary: ALTER TABLE .. MODIFY WATERMARK might reset current
distribution
Key: FLINK-38177
URL: https://issues.apache.org/jira/browse/FLINK-38177
Project
Fabian Paul created FLINK-38176:
---
Summary: Release kafka connector 4.0.1
Key: FLINK-38176
URL: https://issues.apache.org/jira/browse/FLINK-38176
Project: Flink
Issue Type: New Feature
dalongliu created FLINK-38169:
-
Summary: CLONE - Updates the docs stable version
Key: FLINK-38169
URL: https://issues.apache.org/jira/browse/FLINK-38169
Project: Flink
Issue Type: Sub-task
dalongliu created FLINK-38174:
-
Summary: CLONE - Remove outdated versions
Key: FLINK-38174
URL: https://issues.apache.org/jira/browse/FLINK-38174
Project: Flink
Issue Type: Sub-task
dalongliu created FLINK-38171:
-
Summary: CLONE - Add 2.0 to PreviousDocs list
Key: FLINK-38171
URL: https://issues.apache.org/jira/browse/FLINK-38171
Project: Flink
Issue Type: Sub-task
dalongliu created FLINK-38173:
-
Summary: CLONE - Update reference data for Migration Tests
Key: FLINK-38173
URL: https://issues.apache.org/jira/browse/FLINK-38173
Project: Flink
Issue Type: Sub
dalongliu created FLINK-38170:
-
Summary: CLONE - Build 2.0 docs in GitHub Action and mark 2.0 as
stable in docs
Key: FLINK-38170
URL: https://issues.apache.org/jira/browse/FLINK-38170
Project: Flink
dalongliu created FLINK-38172:
-
Summary: CLONE - Update japicmp configuration
Key: FLINK-38172
URL: https://issues.apache.org/jira/browse/FLINK-38172
Project: Flink
Issue Type: Sub-task
dalongliu created FLINK-38175:
-
Summary: CLONE - Start End of Life discussion thread for now
outdated Flink minor version
Key: FLINK-38175
URL: https://issues.apache.org/jira/browse/FLINK-38175
Project
dalongliu created FLINK-38167:
-
Summary: CLONE - Apache mailing lists announcements
Key: FLINK-38167
URL: https://issues.apache.org/jira/browse/FLINK-38167
Project: Flink
Issue Type: Sub-task
dalongliu created FLINK-38168:
-
Summary: CLONE - Other announcements
Key: FLINK-38168
URL: https://issues.apache.org/jira/browse/FLINK-38168
Project: Flink
Issue Type: Sub-task
dalongliu created FLINK-38166:
-
Summary: CLONE - Merge website pull request
Key: FLINK-38166
URL: https://issues.apache.org/jira/browse/FLINK-38166
Project: Flink
Issue Type: Sub-task
dalongliu created FLINK-38165:
-
Summary: Promote release 2.1
Key: FLINK-38165
URL: https://issues.apache.org/jira/browse/FLINK-38165
Project: Flink
Issue Type: New Feature
Affects Versions
ZhangChao created FLINK-38164:
-
Summary: MySQL connector supportLONG and LONG VARCHAR type
Key: FLINK-38164
URL: https://issues.apache.org/jira/browse/FLINK-38164
Project: Flink
Issue Type
RocMarshal created FLINK-38163:
--
Summary: Adaptive Scheduler: Support record and query rescales
hisotry.
Key: FLINK-38163
URL: https://issues.apache.org/jira/browse/FLINK-38163
Project: Flink
Nic Townsend created FLINK-38162:
Summary: Use of SQL functions with time attributes causes
downstream temporal functions to fail
Key: FLINK-38162
URL: https://issues.apache.org/jira/browse/FLINK-38162
Jaydeep Karia created FLINK-38161:
-
Summary: PyFlink: Unable to find Pemja library in thread mode when
Python dependencies are installed in a separate layer
Key: FLINK-38161
URL: https://issues.apache.org/jira
ZhangChao created FLINK-38160:
-
Summary: StarRocks Pipeline connector supports
TIME/BINARY/VARBINARY type mapping
Key: FLINK-38160
URL: https://issues.apache.org/jira/browse/FLINK-38160
Project: Flink
David Kornel created FLINK-38159:
Summary: Update commons-lang3 to mitigate CVE-2025-48924
Key: FLINK-38159
URL: https://issues.apache.org/jira/browse/FLINK-38159
Project: Flink
Issue Type
Piotr Nowojski created FLINK-38158:
--
Summary: FLIP-484: Add custom metric variables to operators
Key: FLINK-38158
URL: https://issues.apache.org/jira/browse/FLINK-38158
Project: Flink
Issue
ouyangwulin created FLINK-38157:
---
Summary: Postgres cdc pipeline supported @experimental options
like mysql pipeline
Key: FLINK-38157
URL: https://issues.apache.org/jira/browse/FLINK-38157
Project
Yanquan Lv created FLINK-38156:
--
Summary: Pipeline E2E tests are currently bound to fail.
Key: FLINK-38156
URL: https://issues.apache.org/jira/browse/FLINK-38156
Project: Flink
Issue Type
Youssuf created FLINK-38155:
---
Summary: Ability to read webhook keystore password from disk
Key: FLINK-38155
URL: https://issues.apache.org/jira/browse/FLINK-38155
Project: Flink
Issue Type
Kumar Mallikarjuna created FLINK-38154:
--
Summary: Add HTTP support to OpenTelemetry Reporter
Key: FLINK-38154
URL: https://issues.apache.org/jira/browse/FLINK-38154
Project: Flink
Issue
Bao Liu created FLINK-38153:
---
Summary: Documentation has an error
Key: FLINK-38153
URL: https://issues.apache.org/jira/browse/FLINK-38153
Project: Flink
Issue Type: Bug
Components
Xin Gong created FLINK-38152:
Summary: MySQL CDC docs some params are invalid
Key: FLINK-38152
URL: https://issues.apache.org/jira/browse/FLINK-38152
Project: Flink
Issue Type: Bug
felixzh created FLINK-38151:
---
Summary: Class MetricFetcherImpl's method fetchMetrics failed log
level adjustment to error
Key: FLINK-38151
URL: https://issues.apache.org/jira/browse/FLINK-38151
Pr
Sergey Nuyanzin created FLINK-38150:
---
Summary: Fail in planning if window boundary is not
numeric/interval_day_time
Key: FLINK-38150
URL: https://issues.apache.org/jira/browse/FLINK-38150
Project
Ramin Gharib created FLINK-38149:
Summary: Convert COLUMN_LIST to DescriptorType
Key: FLINK-38149
URL: https://issues.apache.org/jira/browse/FLINK-38149
Project: Flink
Issue Type: Bug
Michał Fijołek created FLINK-38148:
--
Summary: Failed serialization of JobExceptionsInfoWithHistory in
flink-kubernetes-operator
Key: FLINK-38148
URL: https://issues.apache.org/jira/browse/FLINK-38148
Gyula Fora created FLINK-38147:
--
Summary: Add Flink 2.1 support to operator
Key: FLINK-38147
URL: https://issues.apache.org/jira/browse/FLINK-38147
Project: Flink
Issue Type: Bug
jonasjc created FLINK-38146:
---
Summary: support config for create filesystem
Key: FLINK-38146
URL: https://issues.apache.org/jira/browse/FLINK-38146
Project: Flink
Issue Type: Improvement
yuanfenghu created FLINK-38145:
--
Summary: Fix ReflectiveDiffBuilder config comparison to properly
handle deleted configuration entries
Key: FLINK-38145
URL: https://issues.apache.org/jira/browse/FLINK-38145
Rui Fan created FLINK-38144:
---
Summary: Change log state backend is not compatible with the case
where the user value of the map state is null
Key: FLINK-38144
URL: https://issues.apache.org/jira/browse/FLINK-38144
Gabor Somogyi created FLINK-38143:
-
Summary: Pyflink flat YAML based config support is broken
Key: FLINK-38143
URL: https://issues.apache.org/jira/browse/FLINK-38143
Project: Flink
Issue
Muhammad created FLINK-38142:
Summary: Bump the version of Paimon flink to 1.2.0
Key: FLINK-38142
URL: https://issues.apache.org/jira/browse/FLINK-38142
Project: Flink
Issue Type: New Feature
ZhangChao created FLINK-38141:
-
Summary: Iceberg sink has an incorrect type conversion
Key: FLINK-38141
URL: https://issues.apache.org/jira/browse/FLINK-38141
Project: Flink
Issue Type: Bug
Alan Sheinberg created FLINK-38140:
--
Summary: Change name from table.exec.async-scalar.buffer-capacity
to max-concurrent-operations
Key: FLINK-38140
URL: https://issues.apache.org/jira/browse/FLINK-38140
Yanquan Lv created FLINK-38139:
--
Summary: Schema changes still caused issues after enabling
scan.parse.online.schema.changes.enabled
Key: FLINK-38139
URL: https://issues.apache.org/jira/browse/FLINK-38139
Voon Hou created FLINK-38138:
Summary: Array OOB error when trying to get a binary from a
non-zero offset from a vector
Key: FLINK-38138
URL: https://issues.apache.org/jira/browse/FLINK-38138
Project
Ramin Gharib created FLINK-38137:
Summary: RocksDB State Backend Null Serialization Causes NPE and
Asymmetric (De)Serialization Logic
Key: FLINK-38137
URL: https://issues.apache.org/jira/browse/FLINK-38137
Ramin Gharib created FLINK-38136:
Summary: Add restore tests for PTFs
Key: FLINK-38136
URL: https://issues.apache.org/jira/browse/FLINK-38136
Project: Flink
Issue Type: Sub-task
dylanhz created FLINK-38135:
---
Summary: Non-existent method for RAW type hashing
Key: FLINK-38135
URL: https://issues.apache.org/jira/browse/FLINK-38135
Project: Flink
Issue Type: Bug
yangyu created FLINK-38134:
--
Summary: Cannot recognize DropColumnEvent in method
SchemaMergingUtils.getSchemaDifference.
Key: FLINK-38134
URL: https://issues.apache.org/jira/browse/FLINK-38134
Project
jeremyMu created FLINK-38133:
Summary: Unable to find checkpoint status analysis during Flink
restart on k8s，jobmanager created by deployment，
Key: FLINK-38133
URL: https://issues.apache.org/jira/browse/FLINK-38133
huyuliang created FLINK-38132:
-
Summary: CLONE - Improve the CSV reading process
Key: FLINK-38132
URL: https://issues.apache.org/jira/browse/FLINK-38132
Project: Flink
Issue Type: Improvement
Renxiang Zhou created FLINK-38131:
-
Summary: Repartition BroadcastState with finished operators
Key: FLINK-38131
URL: https://issues.apache.org/jira/browse/FLINK-38131
Project: Flink
Issue
dalongliu created FLINK-38130:
-
Summary: The python linux wheel package name is duplicated
Key: FLINK-38130
URL: https://issues.apache.org/jira/browse/FLINK-38130
Project: Flink
Issue Type: Bug
dalongliu created FLINK-38126:
-
Summary: CLONE - Deploy Python artifacts to PyPI
Key: FLINK-38126
URL: https://issues.apache.org/jira/browse/FLINK-38126
Project: Flink
Issue Type: Sub-task
dalongliu created FLINK-38129:
-
Summary: CLONE - Publish the Dockerfiles for the new release
Key: FLINK-38129
URL: https://issues.apache.org/jira/browse/FLINK-38129
Project: Flink
Issue Type
dalongliu created FLINK-38127:
-
Summary: CLONE - Deploy artifacts to Maven Central Repository
Key: FLINK-38127
URL: https://issues.apache.org/jira/browse/FLINK-38127
Project: Flink
Issue Type
dalongliu created FLINK-38128:
-
Summary: CLONE - Create Git tag and mark version as released in
Jira
Key: FLINK-38128
URL: https://issues.apache.org/jira/browse/FLINK-38128
Project: Flink
Issue
dalongliu created FLINK-38125:
-
Summary: Finalize release 2.1.0
Key: FLINK-38125
URL: https://issues.apache.org/jira/browse/FLINK-38125
Project: Flink
Issue Type: New Feature
Andrei Kaigorodov created FLINK-38124:
-
Summary: The autoscaling example misses README
Key: FLINK-38124
URL: https://issues.apache.org/jira/browse/FLINK-38124
Project: Flink
Issue Type
Andrei Kaigorodov created FLINK-38123:
-
Summary: The autoscaling example image is based on Flink 1.18
rather than 1.20.1.
Key: FLINK-38123
URL: https://issues.apache.org/jira/browse/FLINK-38123
Ramin Gharib created FLINK-38122:
Summary: Creating structured types with no fully defining
constructor results in wrong results
Key: FLINK-38122
URL: https://issues.apache.org/jira/browse/FLINK-38122
dalongliu created FLINK-38121:
-
Summary: Build python wheel on linux failed
Key: FLINK-38121
URL: https://issues.apache.org/jira/browse/FLINK-38121
Project: Flink
Issue Type: Bug
Ahmed Hamdy created FLINK-38120:
---
Summary: FLIP-536 Add latest checkpoint details endpoint
Key: FLINK-38120
URL: https://issues.apache.org/jira/browse/FLINK-38120
Project: Flink
Issue Type
Yanquan Lv created FLINK-38119:
--
Summary: [Unstable
test]IcebergWriterTest.testWriteWithAllSupportedTypes:344
Key: FLINK-38119
URL: https://issues.apache.org/jira/browse/FLINK-38119
Project: Flink
shilei-ly created FLINK-38118:
-
Summary: The execution.attached=true parameter does not take
effect in application mode
Key: FLINK-38118
URL: https://issues.apache.org/jira/browse/FLINK-38118
Project
Hao Li created FLINK-38117:
--
Summary: Add anonymous ContextResolvedModel
Key: FLINK-38117
URL: https://issues.apache.org/jira/browse/FLINK-38117
Project: Flink
Issue Type: Sub-task
David Ballano created FLINK-38116:
-
Summary: Flink kubernetes operator RequestWatchProgress Error
Key: FLINK-38116
URL: https://issues.apache.org/jira/browse/FLINK-38116
Project: Flink
Issue
Dian Fu created FLINK-38115:
---
Summary: Synchronous the Python JDBC connector with the Java
implementation
Key: FLINK-38115
URL: https://issues.apache.org/jira/browse/FLINK-38115
Project: Flink
Aleksandr Iushmanov created FLINK-38114:
---
Summary: Allow offloading of task restore
Key: FLINK-38114
URL: https://issues.apache.org/jira/browse/FLINK-38114
Project: Flink
Issue Type
Aleksandr Iushmanov created FLINK-38113:
---
Summary: Rethrow fatal or OOM errors from Execution.deploy
Key: FLINK-38113
URL: https://issues.apache.org/jira/browse/FLINK-38113
Project: Flink
yude created FLINK-38112:
Summary: Change default of
yarn.application-attempt-failures-validity-interval to -1
Key: FLINK-38112
URL: https://issues.apache.org/jira/browse/FLINK-38112
Project: Flink
yuan created FLINK-38111:
Summary: Migrate OceanBase CDC Connector from LogProxy to
OceanBase Binlog Service
Key: FLINK-38111
URL: https://issues.apache.org/jira/browse/FLINK-38111
Project: Flink
haiqingchen created FLINK-38110:
---
Summary: PostgreSQL connector reads Chinese columns with garbled
characters
Key: FLINK-38110
URL: https://issues.apache.org/jira/browse/FLINK-38110
Project: Flink
Rosa Seohwa Kang created FLINK-38109:
Summary: BlobServer isn't associated with the correct bind-host
Key: FLINK-38109
URL: https://issues.apache.org/jira/browse/FLINK-38109
Project:
dylanhz created FLINK-38108:
---
Summary: Incorrect conversion from Java BigDecimal to SQL DECIMAL
Key: FLINK-38108
URL: https://issues.apache.org/jira/browse/FLINK-38108
Project: Flink
Issue Type
dalongliu created FLINK-38107:
-
Summary:
JobMasterTest#testJobFailureWhenGracefulTaskExecutorTermination azure ci failed
Key: FLINK-38107
URL: https://issues.apache.org/jira/browse/FLINK-38107
Project
Rasmus Bilgram created FLINK-38106:
--
Summary: Job gets indefinitely stuck with "Job Not Found" events
Key: FLINK-38106
URL: https://issues.apache.org/jira/browse/FLINK-38106
Proj
Dian Fu created FLINK-38105:
---
Summary: AttributeError:
'pyflink.fn_execution.table.window_aggregate_fast.S' object has no attribute
'get_accumulators'
Key: FLINK-38105
URL: https://issues.apache.o
Hao Li created FLINK-38104:
--
Summary: FLIP-526: Model ML_PREDICT, ML_EVALUATE Table API
Key: FLINK-38104
URL: https://issues.apache.org/jira/browse/FLINK-38104
Project: Flink
Issue Type: New
Timo Walther created FLINK-38103:
Summary: DataTypeFactory cannot restore inline structured types
Key: FLINK-38103
URL: https://issues.apache.org/jira/browse/FLINK-38103
Project: Flink
Issue
Robert Metzger created FLINK-38102:
--
Summary: RestApiMetricsCollectorTest is unstable
Key: FLINK-38102
URL: https://issues.apache.org/jira/browse/FLINK-38102
Project: Flink
Issue Type: Bug
Santwana Verma created FLINK-38101:
--
Summary: Support SI Format for CPU resources
Key: FLINK-38101
URL: https://issues.apache.org/jira/browse/FLINK-38101
Project: Flink
Issue Type
Luca Occhipinti created FLINK-38100:
---
Summary: Add BigQuery catalog support for iceberg pipeline sink
connector
Key: FLINK-38100
URL: https://issues.apache.org/jira/browse/FLINK-38100
Project
zm99 created FLINK-38099:
Summary: Greenplum: Distribution column updates in Greenplum
upsert
Key: FLINK-38099
URL: https://issues.apache.org/jira/browse/FLINK-38099
Project: Flink
Issue
shilei created FLINK-38098:
--
Summary: When submitting a task with the flink run command, adding
the -sae parameter will cause the task to be killed
Key: FLINK-38098
URL: https://issues.apache.org/jira/browse/FLINK-38098
Kumar Mallikarjuna created FLINK-38097:
--
Summary: Add finalizer to custom Role example for Cluster Scoped
Flink Operator
Key: FLINK-38097
URL: https://issues.apache.org/jira/browse/FLINK-38097
Michał Misiewicz created FLINK-38096:
Summary: AsyncSinkWriter may hang when configured with a custom
rate limiting strategy
Key: FLINK-38096
URL: https://issues.apache.org/jira/browse/FLINK-38096
Jean-Benoit Hamard created FLINK-38095:
--
Summary: Error in Session Job autoscaler when realizing
parallelism overrides
Key: FLINK-38095
URL: https://issues.apache.org/jira/browse/FLINK-38095
Yun Tang created FLINK-38094:
Summary: Introduce pyflink.__version__
Key: FLINK-38094
URL: https://issues.apache.org/jira/browse/FLINK-38094
Project: Flink
Issue Type: Improvement
Mate Czagany created FLINK-38093:
Summary: Update version of Fabric8 to 7.3.1
Key: FLINK-38093
URL: https://issues.apache.org/jira/browse/FLINK-38093
Project: Flink
Issue Type: Improvement
Ferenc Csaky created FLINK-38091:
Summary: Update japicmp configuration post 1.20.2
Key: FLINK-38091
URL: https://issues.apache.org/jira/browse/FLINK-38091
Project: Flink
Issue Type
Ferenc Csaky created FLINK-38092:
Summary: Update japicmp configuration post 1.19.3
Key: FLINK-38092
URL: https://issues.apache.org/jira/browse/FLINK-38092
Project: Flink
Issue Type
Timo Walther created FLINK-38090:
Summary: TableResult.collect() returns incorrect SQL inline
structured types
Key: FLINK-38090
URL: https://issues.apache.org/jira/browse/FLINK-38090
Project: Flink
Qilong Wang created FLINK-38089:
---
Summary: Avoid pushing down non-deterministic filter in agg, join
and union
Key: FLINK-38089
URL: https://issues.apache.org/jira/browse/FLINK-38089
Project: Flink
ouyangwulin created FLINK-38088:
---
Summary: If source config "scan.startup.mode:snapshot",not create
replicatedconnect.
Key: FLINK-38088
URL: https://issues.apache.org/jira/browse/FLINK-38088
Mingliang Liu created FLINK-38087:
-
Summary: Improve OperationExecutor error messages and Java stream
usage
Key: FLINK-38087
URL: https://issues.apache.org/jira/browse/FLINK-38087
Project: Flink
Sergey Nuyanzin created FLINK-38086:
---
Summary: Make ChangelogNormalize reusable if possible
Key: FLINK-38086
URL: https://issues.apache.org/jira/browse/FLINK-38086
Project: Flink
Issue
1 - 100 of 6791 matches
Mail list logo
