Attila Mészáros created FLINK-38208:
---
Summary: Use new Fabric8 client CRD generator in Flink Operator
Key: FLINK-38208
URL: https://issues.apache.org/jira/browse/FLINK-38208
Project: Flink
Attila Mészáros created FLINK-38207:
---
Summary: Update Flink Operator to use JOSDK 5.1.2
Key: FLINK-38207
URL: https://issues.apache.org/jira/browse/FLINK-38207
Project: Flink
Issue Type
Yanquan Lv created FLINK-38206:
--
Summary: Update Paimon Table based on upstream schema to avoid
inconsistent table structures
Key: FLINK-38206
URL: https://issues.apache.org/jira/browse/FLINK-38206
Zhanghao Chen created FLINK-38205:
-
Summary: Discard unknown fields for Protobuf format
Key: FLINK-38205
URL: https://issues.apache.org/jira/browse/FLINK-38205
Project: Flink
Issue Type: Sub
Yanquan Lv created FLINK-38204:
--
Summary: When using route in pipeline, failed to write to
MaxCompute sink
Key: FLINK-38204
URL: https://issues.apache.org/jira/browse/FLINK-38204
Project: Flink
Yanquan Lv created FLINK-38203:
--
Summary: Failed case:
FlussPipelineITCase.testInsertExistTableWithMoreColumns
Key: FLINK-38203
URL: https://issues.apache.org/jira/browse/FLINK-38203
Project: Flink
Sergey Nuyanzin created FLINK-38202:
---
Summary: Allow to customize dynamic.max-pool-size-factor
Key: FLINK-38202
URL: https://issues.apache.org/jira/browse/FLINK-38202
Project: Flink
Issue
Timo Walther created FLINK-38201:
Summary: SinkUpsertMaterializer should not be inserted for retract
sinks
Key: FLINK-38201
URL: https://issues.apache.org/jira/browse/FLINK-38201
Project: Flink
Sergey Nuyanzin created FLINK-38200:
---
Summary: Allow to use LAST_VALUE and FIRST_VALUE for temporal and
other types
Key: FLINK-38200
URL: https://issues.apache.org/jira/browse/FLINK-38200
Project
Roman Khachatryan created FLINK-38199:
-
Summary: Add a benchmark for SinkUpsertMaterializer
Key: FLINK-38199
URL: https://issues.apache.org/jira/browse/FLINK-38199
Project: Flink
Issue
Dawid Wysakowicz created FLINK-38198:
Summary: Support WITH Clause in CREATE FUNCTION Statement in Flink
SQL
Key: FLINK-38198
URL: https://issues.apache.org/jira/browse/FLINK-38198
Project: Flink
JunboWang created FLINK-38197:
-
Summary: Data Errors Caused by Default Added Columns at End
Position
Key: FLINK-38197
URL: https://issues.apache.org/jira/browse/FLINK-38197
Project: Flink
Issue
tchivs created FLINK-38196:
--
Summary: IndexOutOfBoundsException when processing PostgreSQL
tables with numeric(0) fields in Flink CDC
Key: FLINK-38196
URL: https://issues.apache.org/jira/browse/FLINK-38196
cuiyanxiang created FLINK-38195:
---
Summary: Some markdown syntax errors in tableApi page
Key: FLINK-38195
URL: https://issues.apache.org/jira/browse/FLINK-38195
Project: Flink
Issue Type: Bug
ZhangChao created FLINK-38194:
-
Summary: Iceberg connector supports auto-creating namespace
Key: FLINK-38194
URL: https://issues.apache.org/jira/browse/FLINK-38194
Project: Flink
Issue Type
Jakub Stejskal created FLINK-38193:
--
Summary: Upgrade org.apache.commons:commons-lang3 from 3.12.0 to
3.18.0 to mitigate CVE-2025-48924
Key: FLINK-38193
URL: https://issues.apache.org/jira/browse/FLINK-38193
Cai Liuyang created FLINK-38192:
---
Summary: Improve DynamicSourceUtils exception msg
Key: FLINK-38192
URL: https://issues.apache.org/jira/browse/FLINK-38192
Project: Flink
Issue Type
Yanquan Lv created FLINK-38191:
--
Summary: [Document] Add document for Fluss pipeline connector
Key: FLINK-38191
URL: https://issues.apache.org/jira/browse/FLINK-38191
Project: Flink
Issue Type
Dian Fu created FLINK-38190:
---
Summary: Support async function in Python DataStream API
Key: FLINK-38190
URL: https://issues.apache.org/jira/browse/FLINK-38190
Project: Flink
Issue Type: New
Dian Fu created FLINK-38189:
---
Summary: Allow it to sink data to Kafka partitions based on KEY in
PyFlink
Key: FLINK-38189
URL: https://issues.apache.org/jira/browse/FLINK-38189
Project: Flink
tchivs created FLINK-38188:
--
Summary: PostgreSQL connector database name validation logic is
inverted in getValidateDatabaseName method
Key: FLINK-38188
URL: https://issues.apache.org/jira/browse/FLINK-38188
Marton Greber created FLINK-38187:
-
Summary: Add metrics to KuduSource
Key: FLINK-38187
URL: https://issues.apache.org/jira/browse/FLINK-38187
Project: Flink
Issue Type: Improvement
Yanquan Lv created FLINK-38186:
--
Summary: Failed case:
NewlyAddedTableITCase.testJobManagerFailoverForNewlyAddedTableWithAheadBinlog
Key: FLINK-38186
URL: https://issues.apache.org/jira/browse/FLINK-38186
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:
1 - 100 of 6814 matches
Mail list logo