yux created FLINK-37963:
---
Summary: Unstable MongoDB unit test cases that triggers JM failover
Key: FLINK-37963
URL: https://issues.apache.org/jira/browse/FLINK-37963
Project: Flink
Issue Type: Sub-task
yux created FLINK-37835:
---
Summary: MySQL CDC BinlogOffset compareTo method throws NPE
Key: FLINK-37835
URL: https://issues.apache.org/jira/browse/FLINK-37835
Project: Flink
Issue Type: Bug
Co
yux created FLINK-37741:
---
Summary: Severe performance regression of transform operator node
Key: FLINK-37741
URL: https://issues.apache.org/jira/browse/FLINK-37741
Project: Flink
Issue Type: Bug
yux created FLINK-37704:
---
Summary: Add restoring from state E2e cases for CDC YAML
Key: FLINK-37704
URL: https://issues.apache.org/jira/browse/FLINK-37704
Project: Flink
Issue Type: Improvement
yux created FLINK-37653:
---
Summary: Incremental snapshot framework supports assigning
multiple StreamSplit
Key: FLINK-37653
URL: https://issues.apache.org/jira/browse/FLINK-37653
Project: Flink
Issue T
yux created FLINK-37586:
---
Summary: YAML pipeline supports passing extra options to UDFs
Key: FLINK-37586
URL: https://issues.apache.org/jira/browse/FLINK-37586
Project: Flink
Issue Type: Improvement
yux created FLINK-37578:
---
Summary: CDC Pipeline distributed schema evolution topology with
bad internal state
Key: FLINK-37578
URL: https://issues.apache.org/jira/browse/FLINK-37578
Project: Flink
Iss
yux created FLINK-37574:
---
Summary: Add UDTF support in YAML pipeline transform expressions
Key: FLINK-37574
URL: https://issues.apache.org/jira/browse/FLINK-37574
Project: Flink
Issue Type: New Feature
yux created FLINK-37507:
---
Summary: MySQL CDC captures common-prefix database accidentally
when scan.binlog.newly-added-table option is enabled
Key: FLINK-37507
URL: https://issues.apache.org/jira/browse/FLINK-37507
yux created FLINK-37506:
---
Summary: Print detailed exception stack when pipeline transform
fails
Key: FLINK-37506
URL: https://issues.apache.org/jira/browse/FLINK-37506
Project: Flink
Issue Type: Impro
yux created FLINK-37485:
---
Summary: StarRocks Pipeline connector supports TIME type mapping
Key: FLINK-37485
URL: https://issues.apache.org/jira/browse/FLINK-37485
Project: Flink
Issue Type: Improvement
yux created FLINK-37368:
---
Summary: MySQL Pipeline job failed to checkpoint after closing
idle readers
Key: FLINK-37368
URL: https://issues.apache.org/jira/browse/FLINK-37368
Project: Flink
Issue Type:
yux created FLINK-37278:
---
Summary: Regular schema evolution process is too slow when
starting from specific offset
Key: FLINK-37278
URL: https://issues.apache.org/jira/browse/FLINK-37278
Project: Flink
yux created FLINK-37262:
---
Summary: MySQL CDC connector could not configure the
`scan.parse.online.schema.changes.enabled` option
Key: FLINK-37262
URL: https://issues.apache.org/jira/browse/FLINK-37262
Project:
yux created FLINK-37195:
---
Summary: TimestampAdd / TimestampDiff series function not
available in cluster
Key: FLINK-37195
URL: https://issues.apache.org/jira/browse/FLINK-37195
Project: Flink
Issue Ty
yux created FLINK-37111:
---
Summary: Allow setting `sink.version` for StarRocks Pipeline
connector
Key: FLINK-37111
URL: https://issues.apache.org/jira/browse/FLINK-37111
Project: Flink
Issue Type: Im
yux created FLINK-37000:
---
Summary: MySQL CDC could not handle date and time data prior to
unix epoch
Key: FLINK-37000
URL: https://issues.apache.org/jira/browse/FLINK-37000
Project: Flink
Issue Type:
yux created FLINK-36956:
---
Summary: Pipeline transform should deduce PK column types to be
NOT NULL
Key: FLINK-36956
URL: https://issues.apache.org/jira/browse/FLINK-36956
Project: Flink
Issue Type: Bu
yux created FLINK-36866:
---
Summary: Support more CDC YAML numeric casting paths
Key: FLINK-36866
URL: https://issues.apache.org/jira/browse/FLINK-36866
Project: Flink
Issue Type: Bug
Component
yux created FLINK-36865:
---
Summary: Provide UNIX_TIMESTAMP series functions in YAML pipeline
Key: FLINK-36865
URL: https://issues.apache.org/jira/browse/FLINK-36865
Project: Flink
Issue Type: New Featur
yux created FLINK-36864:
---
Summary: YAML Pipeline could not write number literals that
exceeds Int32 range
Key: FLINK-36864
URL: https://issues.apache.org/jira/browse/FLINK-36864
Project: Flink
Issue T
yux created FLINK-36854:
---
Summary: Column comments and default expressions gone after being
transformed
Key: FLINK-36854
URL: https://issues.apache.org/jira/browse/FLINK-36854
Project: Flink
Issue Typ
yux created FLINK-36763:
---
Summary: Support schema inference and evolution with
single-table-mutliple-partition sources
Key: FLINK-36763
URL: https://issues.apache.org/jira/browse/FLINK-36763
Project: Flink
yux created FLINK-36697:
---
Summary: Quickly evolving schema change in Doris fails
Key: FLINK-36697
URL: https://issues.apache.org/jira/browse/FLINK-36697
Project: Flink
Issue Type: Bug
Compone
yux created FLINK-36690:
---
Summary: Pipeline occasionally blocks when handling schema change
events in parallel
Key: FLINK-36690
URL: https://issues.apache.org/jira/browse/FLINK-36690
Project: Flink
Is
yux created FLINK-36610:
---
Summary: MySQL CDC supports parsing gh-ost generated schema changes
Key: FLINK-36610
URL: https://issues.apache.org/jira/browse/FLINK-36610
Project: Flink
Issue Type: Improvem
yux created FLINK-36596:
---
Summary: YAML Pipeline fails to schema change with no projection
fields specified
Key: FLINK-36596
URL: https://issues.apache.org/jira/browse/FLINK-36596
Project: Flink
Issue
yux created FLINK-36590:
---
Summary: Flink CDC does not Support MySQL > 8.0.x
Key: FLINK-36590
URL: https://issues.apache.org/jira/browse/FLINK-36590
Project: Flink
Issue Type: Improvement
Comp
yux created FLINK-36565:
---
Summary: Pipeline YAML should allow merging decimal with different
precisions
Key: FLINK-36565
URL: https://issues.apache.org/jira/browse/FLINK-36565
Project: Flink
Issue Typ
yux created FLINK-36558:
---
Summary: MySQL CDC Fails to parse array-typed key index binlog
created between 8.0.17 and 8.0.18
Key: FLINK-36558
URL: https://issues.apache.org/jira/browse/FLINK-36558
Project: Flink
yux created FLINK-36515:
---
Summary: Adds high-precision TIME type support in YAML pipeline
Key: FLINK-36515
URL: https://issues.apache.org/jira/browse/FLINK-36515
Project: Flink
Issue Type: Improvement
yux created FLINK-36514:
---
Summary: Unable to override include/exclude schema types in
lenient mode
Key: FLINK-36514
URL: https://issues.apache.org/jira/browse/FLINK-36514
Project: Flink
Issue Type: Bu
yux created FLINK-36475:
---
Summary: YAML Transform supports case-insensitive column names
conversion
Key: FLINK-36475
URL: https://issues.apache.org/jira/browse/FLINK-36475
Project: Flink
Issue Type: I
yux created FLINK-36474:
---
Summary: YAML Table-merging route should accept more type widening
cases
Key: FLINK-36474
URL: https://issues.apache.org/jira/browse/FLINK-36474
Project: Flink
Issue Type: Bu
yux created FLINK-36461:
---
Summary: YAML job failed to schema evolve with unmatched transform
tables
Key: FLINK-36461
URL: https://issues.apache.org/jira/browse/FLINK-36461
Project: Flink
Issue Type: B
yux created FLINK-36453:
---
Summary: Backport DBZ-6502 patch to fix Oracle 23.x JDBC driver
compatbility
Key: FLINK-36453
URL: https://issues.apache.org/jira/browse/FLINK-36453
Project: Flink
Issue Type
yux created FLINK-36408:
---
Summary: MySQL pipeline connector could not work with FLOAT type
with precision
Key: FLINK-36408
URL: https://issues.apache.org/jira/browse/FLINK-36408
Project: Flink
Issue T
yux created FLINK-36221:
---
Summary: Add specification about CAST ... AS ... built-in functions
Key: FLINK-36221
URL: https://issues.apache.org/jira/browse/FLINK-36221
Project: Flink
Issue Type: Sub-task
yux created FLINK-36218:
---
Summary: Documentations clean up before CDC 3.2.0 release
Key: FLINK-36218
URL: https://issues.apache.org/jira/browse/FLINK-36218
Project: Flink
Issue Type: Improvement
yux created FLINK-36193:
---
Summary: Allow applying new SchemaChangeEvents to sink connectors
Key: FLINK-36193
URL: https://issues.apache.org/jira/browse/FLINK-36193
Project: Flink
Issue Type: Improvemen
yux created FLINK-36184:
---
Summary: Transform Operator swallows schema changes from tables
not present in transform rules
Key: FLINK-36184
URL: https://issues.apache.org/jira/browse/FLINK-36184
Project: Flink
yux created FLINK-36183:
---
Summary: Lenient mode doesn't work with route blocks
Key: FLINK-36183
URL: https://issues.apache.org/jira/browse/FLINK-36183
Project: Flink
Issue Type: Bug
Component
yux created FLINK-36153:
---
Summary: MySQL fails to handle schema change events In Timestamp
or Earliest Offset startup mode
Key: FLINK-36153
URL: https://issues.apache.org/jira/browse/FLINK-36153
Project: Flink
yux created FLINK-36151:
---
Summary: Add documentations for Schema Evolution related options
Key: FLINK-36151
URL: https://issues.apache.org/jira/browse/FLINK-36151
Project: Flink
Issue Type: Improvement
yux created FLINK-36128:
---
Summary: Promote LENIENT mode as the default schema evolution
behavior
Key: FLINK-36128
URL: https://issues.apache.org/jira/browse/FLINK-36128
Project: Flink
Issue Type: Impr
yux created FLINK-36114:
---
Summary: Schema registry should block when handling existing
requests
Key: FLINK-36114
URL: https://issues.apache.org/jira/browse/FLINK-36114
Project: Flink
Issue Type: Impro
yux created FLINK-36105:
---
Summary: CDC pipeline job could not restore from state in Flink
1.20
Key: FLINK-36105
URL: https://issues.apache.org/jira/browse/FLINK-36105
Project: Flink
Issue Type: Improv
yux created FLINK-36093:
---
Summary: PreTransform operator wrongly filters out columns when
multiple transform rules were defined
Key: FLINK-36093
URL: https://issues.apache.org/jira/browse/FLINK-36093
Project: F
yux created FLINK-36092:
---
Summary: Transform doesn't fully support with schema evolution
Key: FLINK-36092
URL: https://issues.apache.org/jira/browse/FLINK-36092
Project: Flink
Issue Type: Improvement
yux created FLINK-36060:
---
Summary: Transform built-in functions could not handle NULL values
as arguments
Key: FLINK-36060
URL: https://issues.apache.org/jira/browse/FLINK-36060
Project: Flink
Issue T
yux created FLINK-36041:
---
Summary: Eliminate Calcite dependency during runtime
Key: FLINK-36041
URL: https://issues.apache.org/jira/browse/FLINK-36041
Project: Flink
Issue Type: Improvement
C
yux created FLINK-36034:
---
Summary: Remove dependencies of Flink table planner in Transform
module
Key: FLINK-36034
URL: https://issues.apache.org/jira/browse/FLINK-36034
Project: Flink
Issue Type: Bug
yux created FLINK-36006:
---
Summary: Add documentations for Flink CDC CLI
Key: FLINK-36006
URL: https://issues.apache.org/jira/browse/FLINK-36006
Project: Flink
Issue Type: Bug
Components: Flin
yux created FLINK-35991:
---
Summary: Resolve conflicting definitions in transform
SqlFunctionTable definition
Key: FLINK-35991
URL: https://issues.apache.org/jira/browse/FLINK-35991
Project: Flink
Issue
yux created FLINK-35986:
---
Summary: NULL literal is not supported in Transform rules
Key: FLINK-35986
URL: https://issues.apache.org/jira/browse/FLINK-35986
Project: Flink
Issue Type: Bug
Comp
yux created FLINK-35985:
---
Summary: SUBSTRING function not available in transform rules
Key: FLINK-35985
URL: https://issues.apache.org/jira/browse/FLINK-35985
Project: Flink
Issue Type: Bug
C
yux created FLINK-35984:
---
Summary: Job crashes when metadata column names present in
transform rules
Key: FLINK-35984
URL: https://issues.apache.org/jira/browse/FLINK-35984
Project: Flink
Issue Type:
yux created FLINK-35983:
---
Summary: Job crashes when using wildcard (*) match with metadata
column
Key: FLINK-35983
URL: https://issues.apache.org/jira/browse/FLINK-35983
Project: Flink
Issue Type: Bug
yux created FLINK-35982:
---
Summary: Transform metadata config doesn't work if no projection
block was provided
Key: FLINK-35982
URL: https://issues.apache.org/jira/browse/FLINK-35982
Project: Flink
Iss
yux created FLINK-35981:
---
Summary: Transform rule doesn't support referencing one column
more than once
Key: FLINK-35981
URL: https://issues.apache.org/jira/browse/FLINK-35981
Project: Flink
Issue Typ
yux created FLINK-35980:
---
Summary: Add transform test coverage in Integrated / E2e tests
Key: FLINK-35980
URL: https://issues.apache.org/jira/browse/FLINK-35980
Project: Flink
Issue Type: Bug
yux created FLINK-35967:
---
Summary: Shade other Flink connectors in CDC Pipeline connectors
Key: FLINK-35967
URL: https://issues.apache.org/jira/browse/FLINK-35967
Project: Flink
Issue Type: Bug
yux created FLINK-35912:
---
Summary: SqlServer CDC doesn't chunk UUID-typed columns correctly
Key: FLINK-35912
URL: https://issues.apache.org/jira/browse/FLINK-35912
Project: Flink
Issue Type: Bug
yux created FLINK-35883:
---
Summary: Wildcard projection inserts column at wrong place
Key: FLINK-35883
URL: https://issues.apache.org/jira/browse/FLINK-35883
Project: Flink
Issue Type: Bug
Com
yux created FLINK-35868:
---
Summary: Bump Mongo driver version to support Mongo 7.0+
Key: FLINK-35868
URL: https://issues.apache.org/jira/browse/FLINK-35868
Project: Flink
Issue Type: Improvement
yux created FLINK-35813:
---
Summary: Transform schema operator failed to trigger checkpoint
with bounded source
Key: FLINK-35813
URL: https://issues.apache.org/jira/browse/FLINK-35813
Project: Flink
Iss
yux created FLINK-35805:
---
Summary: Add "OpType" metadata column in transform
Key: FLINK-35805
URL: https://issues.apache.org/jira/browse/FLINK-35805
Project: Flink
Issue Type: Improvement
Com
yux created FLINK-35781:
---
Summary: Make pipeline parallelism config optional
Key: FLINK-35781
URL: https://issues.apache.org/jira/browse/FLINK-35781
Project: Flink
Issue Type: Improvement
Com
yux created FLINK-35762:
---
Summary: Cache hashCode for immutable map key classes
Key: FLINK-35762
URL: https://issues.apache.org/jira/browse/FLINK-35762
Project: Flink
Issue Type: Improvement
yux created FLINK-35736:
---
Summary: Add E2e migration scripts for Flink CDC
Key: FLINK-35736
URL: https://issues.apache.org/jira/browse/FLINK-35736
Project: Flink
Issue Type: Improvement
Compo
yux created FLINK-35700:
---
Summary: Loosen CDC pipeline options validation
Key: FLINK-35700
URL: https://issues.apache.org/jira/browse/FLINK-35700
Project: Flink
Issue Type: Bug
Components: Fl
yux created FLINK-35654:
---
Summary: Add Flink CDC verification guide in docs
Key: FLINK-35654
URL: https://issues.apache.org/jira/browse/FLINK-35654
Project: Flink
Issue Type: Bug
Components:
yux created FLINK-35651:
---
Summary: Unable to call argument-less built-in functions with
parentheses
Key: FLINK-35651
URL: https://issues.apache.org/jira/browse/FLINK-35651
Project: Flink
Issue Type: B
yux created FLINK-35648:
---
Summary: Pipeline job doesn't support multiple routing
Key: FLINK-35648
URL: https://issues.apache.org/jira/browse/FLINK-35648
Project: Flink
Issue Type: Improvement
yux created FLINK-35647:
---
Summary: Pipeline route rule supports placeholder replacement
Key: FLINK-35647
URL: https://issues.apache.org/jira/browse/FLINK-35647
Project: Flink
Issue Type: Improvement
yux created FLINK-35634:
---
Summary: Add a CDC quickstart utility
Key: FLINK-35634
URL: https://issues.apache.org/jira/browse/FLINK-35634
Project: Flink
Issue Type: New Feature
Components: Flin
yux created FLINK-35633:
---
Summary: Early verification and clearer error message of pipeline
YAML definition
Key: FLINK-35633
URL: https://issues.apache.org/jira/browse/FLINK-35633
Project: Flink
Issu
yux created FLINK-35527:
---
Summary: Polish quickstart guide & clean stale links in docs
Key: FLINK-35527
URL: https://issues.apache.org/jira/browse/FLINK-35527
Project: Flink
Issue Type: Bug
C
yux created FLINK-35464:
---
Summary: Flink CDC 3.1 breaks operator state compatiblity
Key: FLINK-35464
URL: https://issues.apache.org/jira/browse/FLINK-35464
Project: Flink
Issue Type: Bug
Comp
yux created FLINK-35441:
---
Summary: Add CDC upgrade compatibility tests
Key: FLINK-35441
URL: https://issues.apache.org/jira/browse/FLINK-35441
Project: Flink
Issue Type: Bug
Components: Flink
yux created FLINK-35415:
---
Summary: CDC Fails to create sink with Flink 1.19
Key: FLINK-35415
URL: https://issues.apache.org/jira/browse/FLINK-35415
Project: Flink
Issue Type: Bug
Components:
yux created FLINK-35317:
---
Summary: Flink CDC CLI Supports submitting multiple YAML job at
once
Key: FLINK-35317
URL: https://issues.apache.org/jira/browse/FLINK-35317
Project: Flink
Issue Type: Improv
yux created FLINK-35316:
---
Summary: Add CDC e2e test case for on Flink 1.19
Key: FLINK-35316
URL: https://issues.apache.org/jira/browse/FLINK-35316
Project: Flink
Issue Type: Bug
Components: F
yux created FLINK-35312:
---
Summary: Insufficient number of arguments were supplied for the
procedure or function cdc.fn_cdc_get_all_changes_
Key: FLINK-35312
URL: https://issues.apache.org/jira/browse/FLINK-35312
yux created FLINK-35308:
---
Summary: StarRocks sink maps TINYINT type to BOOLEAN incorrectly
Key: FLINK-35308
URL: https://issues.apache.org/jira/browse/FLINK-35308
Project: Flink
Issue Type: Bug
yux created FLINK-35304:
---
Summary: Mongo ITCase fails due to duplicate records after resuming
Key: FLINK-35304
URL: https://issues.apache.org/jira/browse/FLINK-35304
Project: Flink
Issue Type: Bug
yux created FLINK-35272:
---
Summary: Pipeline Transform job supports omitting / renaming
calculation column
Key: FLINK-35272
URL: https://issues.apache.org/jira/browse/FLINK-35272
Project: Flink
Issue T
yux created FLINK-35264:
---
Summary: Flink CDC Pipeline transform rules do not take effect
Key: FLINK-35264
URL: https://issues.apache.org/jira/browse/FLINK-35264
Project: Flink
Issue Type: Bug
yux created FLINK-35261:
---
Summary: Flink CDC pipeline transform doesn't support decimal
comparison
Key: FLINK-35261
URL: https://issues.apache.org/jira/browse/FLINK-35261
Project: Flink
Issue Type: Im
yux created FLINK-35256:
---
Summary: Pipeline transform ignores column type nullability
Key: FLINK-35256
URL: https://issues.apache.org/jira/browse/FLINK-35256
Project: Flink
Issue Type: Improvement
yux created FLINK-35243:
---
Summary: Carry pre-schema payload with SchemaChangeEvents
Key: FLINK-35243
URL: https://issues.apache.org/jira/browse/FLINK-35243
Project: Flink
Issue Type: Improvement
yux created FLINK-35242:
---
Summary: Add fine-grained schema evolution strategy
Key: FLINK-35242
URL: https://issues.apache.org/jira/browse/FLINK-35242
Project: Flink
Issue Type: Improvement
Co
92 matches
Mail list logo
