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:
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
Is
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: Impro
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
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
Yanquan Lv created FLINK-37855:
--
Summary: Reduce the time cost in MySqlSchemaUtils#listTables
Key: FLINK-37855
URL: https://issues.apache.org/jira/browse/FLINK-37855
Project: Flink
Issue Type: I
Yanquan Lv created FLINK-37847:
--
Summary: [umbrella] Unstable test in FlinkCDC project
Key: FLINK-37847
URL: https://issues.apache.org/jira/browse/FLINK-37847
Project: Flink
Issue Type: Improvem
Yanquan Lv created FLINK-37846:
--
Summary: [Unstable test]
MysqlToKafkaE2eITCase.testSyncWholeDatabaseWithDebeziumJson
Key: FLINK-37846
URL: https://issues.apache.org/jira/browse/FLINK-37846
Project: Flin
Yanquan Lv created FLINK-37837:
--
Summary: Always Add create.table to include.schema.changes option
Key: FLINK-37837
URL: https://issues.apache.org/jira/browse/FLINK-37837
Project: Flink
Issue Ty
Yanquan Lv created FLINK-37786:
--
Summary: Infer schema information from the state of Source and
emit it to avoid maintaining state in PreTransform
Key: FLINK-37786
URL: https://issues.apache.org/jira/browse/FLINK-377
Yanquan Lv created FLINK-37743:
--
Summary: Add benchmark test for Flink CDC Pipeline job
Key: FLINK-37743
URL: https://issues.apache.org/jira/browse/FLINK-37743
Project: Flink
Issue Type: Improve
Yanquan Lv created FLINK-37734:
--
Summary: Update version to 3.5-SNAPSHOT and update related docs
Key: FLINK-37734
URL: https://issues.apache.org/jira/browse/FLINK-37734
Project: Flink
Issue Type
Yanquan Lv created FLINK-37731:
--
Summary: Update dependency of Paimon to 1.1 and add support for
Postpone Bucket
Key: FLINK-37731
URL: https://issues.apache.org/jira/browse/FLINK-37731
Project: Flink
Yanquan Lv created FLINK-37726:
--
Summary: Read incremental data for existing tables
Key: FLINK-37726
URL: https://issues.apache.org/jira/browse/FLINK-37726
Project: Flink
Issue Type: Improvement
Yanquan Lv created FLINK-37713:
--
Summary: SchemaManager was recreated in SchemaRegistry after job
failover
Key: FLINK-37713
URL: https://issues.apache.org/jira/browse/FLINK-37713
Project: Flink
Yanquan Lv created FLINK-37712:
--
Summary: Table
Key: FLINK-37712
URL: https://issues.apache.org/jira/browse/FLINK-37712
Project: Flink
Issue Type: Bug
Reporter: Yanquan Lv
--
T
Yanquan Lv created FLINK-37699:
--
Summary: Overwrite the parameters of the created Paimon table
through table options
Key: FLINK-37699
URL: https://issues.apache.org/jira/browse/FLINK-37699
Project: Flink
Yanquan Lv created FLINK-37676:
--
Summary: Add a cache for TableId in Selector to improve performance
Key: FLINK-37676
URL: https://issues.apache.org/jira/browse/FLINK-37676
Project: Flink
Issue
Yanquan Lv created FLINK-37673:
--
Summary: The transformation of table metadata should only be
effective for the first matching rule
Key: FLINK-37673
URL: https://issues.apache.org/jira/browse/FLINK-37673
Yanquan Lv created FLINK-37667:
--
Summary: Make PostTransformOperator always chain with before
Operator
Key: FLINK-37667
URL: https://issues.apache.org/jira/browse/FLINK-37667
Project: Flink
Iss
Yanquan Lv created FLINK-37644:
--
Summary: Include guava dependency to package of Kafka connector
release and shade
Key: FLINK-37644
URL: https://issues.apache.org/jira/browse/FLINK-37644
Project: Flink
Yanquan Lv created FLINK-37636:
--
Summary: Weekly CI failure
Key: FLINK-37636
URL: https://issues.apache.org/jira/browse/FLINK-37636
Project: Flink
Issue Type: Improvement
Components:
Yanquan Lv created FLINK-37590:
--
Summary: Update the code of Python modules to adapt to Flink 2.0's
pyFlink
Key: FLINK-37590
URL: https://issues.apache.org/jira/browse/FLINK-37590
Project: Flink
Yanquan Lv created FLINK-37587:
--
Summary: Fail to add a new column that has the same column name
with source table using transform
Key: FLINK-37587
URL: https://issues.apache.org/jira/browse/FLINK-37587
Yanquan Lv created FLINK-37577:
--
Summary: Wait compaction only when table set
deletion-vectors.enabled to true in PaimonWriter
Key: FLINK-37577
URL: https://issues.apache.org/jira/browse/FLINK-37577
Proj
Yanquan Lv created FLINK-37572:
--
Summary: Shuffle Event by bucket and tableid to avoid data skew
Key: FLINK-37572
URL: https://issues.apache.org/jira/browse/FLINK-37572
Project: Flink
Issue Type
Yanquan Lv created FLINK-37566:
--
Summary: table.exclude was invalid in binlog reading phase when
scan.binlog.newly-added-table.enabled
Key: FLINK-37566
URL: https://issues.apache.org/jira/browse/FLINK-37566
Yanquan Lv created FLINK-37539:
--
Summary: performance optimization in Paimon Sink to reduce
end-to-end checkpoint time
Key: FLINK-37539
URL: https://issues.apache.org/jira/browse/FLINK-37539
Project: Fli
Yanquan Lv created FLINK-37519:
--
Summary: Add clearer logs when fail to write to YAML DataSink.
Key: FLINK-37519
URL: https://issues.apache.org/jira/browse/FLINK-37519
Project: Flink
Issue Type:
Yanquan Lv created FLINK-37462:
--
Summary: Unstable test case in
FlinkParallelizedPipelineITCase.testRegularTablesSourceInMultipleParallelism
Key: FLINK-37462
URL: https://issues.apache.org/jira/browse/FLINK-37462
Yanquan Lv created FLINK-37461:
--
Summary: Unstable test case in
MySqlToPaimonE2eITCase#testSyncWholeDatabase
Key: FLINK-37461
URL: https://issues.apache.org/jira/browse/FLINK-37461
Project: Flink
Yanquan Lv created FLINK-37452:
--
Summary: Add support for writing to Paimon Append only table.
Key: FLINK-37452
URL: https://issues.apache.org/jira/browse/FLINK-37452
Project: Flink
Issue Type:
Yanquan Lv created FLINK-37386:
--
Summary: Avoid sending too much CreateTableEvents when job
failover
Key: FLINK-37386
URL: https://issues.apache.org/jira/browse/FLINK-37386
Project: Flink
Issu
Yanquan Lv created FLINK-37353:
--
Summary: [Doc] Add doc for
scan.incremental.snapshot.chunk.key-column Mysql Data Sink
Key: FLINK-37353
URL: https://issues.apache.org/jira/browse/FLINK-37353
Project: Fl
Yanquan Lv created FLINK-37352:
--
Summary: Write full changelog to Paimon Sink.
Key: FLINK-37352
URL: https://issues.apache.org/jira/browse/FLINK-37352
Project: Flink
Issue Type: Improvement
Yanquan Lv created FLINK-37349:
--
Summary: Add timeout for test case that call waitForSinkSize
method to avoid Infinite waiting
Key: FLINK-37349
URL: https://issues.apache.org/jira/browse/FLINK-37349
Pro
Yanquan Lv created FLINK-37346:
--
Summary: [CI] Unit Tests (mysql) / compile_and_test (8, generic)
(pull_request)Failing after 60m
Key: FLINK-37346
URL: https://issues.apache.org/jira/browse/FLINK-37346
P
Yanquan Lv created FLINK-37285:
--
Summary: Adapt DataSinkTranslator to support new Sink API of
FLIP-372
Key: FLINK-37285
URL: https://issues.apache.org/jira/browse/FLINK-37285
Project: Flink
Iss
Yanquan Lv created FLINK-37277:
--
Summary: Add guidance for configuring different kind of catalog of
Paimon Sink.
Key: FLINK-37277
URL: https://issues.apache.org/jira/browse/FLINK-37277
Project: Flink
Yanquan Lv created FLINK-37252:
--
Summary: Align Chinese document of Postgres CDC Connector with
English document
Key: FLINK-37252
URL: https://issues.apache.org/jira/browse/FLINK-37252
Project: Flink
Yanquan Lv created FLINK-37251:
--
Summary: Add download link for pipeline connector.
Key: FLINK-37251
URL: https://issues.apache.org/jira/browse/FLINK-37251
Project: Flink
Issue Type: Technical
Yanquan Lv created FLINK-37235:
--
Summary: Add e2e test for flink-connector-elasticsearch8
Key: FLINK-37235
URL: https://issues.apache.org/jira/browse/FLINK-37235
Project: Flink
Issue Type: Techn
Yanquan Lv created FLINK-37234:
--
Summary: Add timeout for test case to avoid Infinite waiting
Key: FLINK-37234
URL: https://issues.apache.org/jira/browse/FLINK-37234
Project: Flink
Issue Type:
Yanquan Lv created FLINK-37231:
--
Summary: Add doc for newly added source metric statistics
Key: FLINK-37231
URL: https://issues.apache.org/jira/browse/FLINK-37231
Project: Flink
Issue Type: Tech
Yanquan Lv created FLINK-37224:
--
Summary: Add the missing content of MongoDB CDC to the Chinese
document.
Key: FLINK-37224
URL: https://issues.apache.org/jira/browse/FLINK-37224
Project: Flink
Yanquan Lv created FLINK-37223:
--
Summary: Add the missing content of MySQL CDC to the Chinese
document.
Key: FLINK-37223
URL: https://issues.apache.org/jira/browse/FLINK-37223
Project: Flink
Is
Yanquan Lv created FLINK-37210:
--
Summary: Add flink-cdc-release-3.3.0 module to
flink-cdc-migration-tests.
Key: FLINK-37210
URL: https://issues.apache.org/jira/browse/FLINK-37210
Project: Flink
Yanquan Lv created FLINK-37209:
--
Summary: Add Embedding AI Model for Qwen
Key: FLINK-37209
URL: https://issues.apache.org/jira/browse/FLINK-37209
Project: Flink
Issue Type: Improvement
Yanquan Lv created FLINK-37203:
--
Summary: Support AltertableCommentEvent and
AlterColumnCommentEvent.
Key: FLINK-37203
URL: https://issues.apache.org/jira/browse/FLINK-37203
Project: Flink
Issu
Yanquan Lv created FLINK-37200:
--
Summary: Add e2e test for ElasticSearch Sink.
Key: FLINK-37200
URL: https://issues.apache.org/jira/browse/FLINK-37200
Project: Flink
Issue Type: Improvement
Yanquan Lv created FLINK-37199:
--
Summary: Update document in quickly start to guide user to add
checkpoint configuration
Key: FLINK-37199
URL: https://issues.apache.org/jira/browse/FLINK-37199
Project: F
Yanquan Lv created FLINK-37163:
--
Summary: Add documents for recently merged PRs in FlinkCDC 3.3
Key: FLINK-37163
URL: https://issues.apache.org/jira/browse/FLINK-37163
Project: Flink
Issue Type:
Yanquan Lv created FLINK-37162:
--
Summary: Add Data Sources Documentation
Key: FLINK-37162
URL: https://issues.apache.org/jira/browse/FLINK-37162
Project: Flink
Issue Type: Technical Debt
Yanquan Lv created FLINK-37143:
--
Summary: Update version of flink-connector-kafka to 4.0-SNAPSHOT
Key: FLINK-37143
URL: https://issues.apache.org/jira/browse/FLINK-37143
Project: Flink
Issue Typ
Yanquan Lv created FLINK-37144:
--
Summary: Update flink-connector-kafka version to 3.4-SNAPSHOT
Key: FLINK-37144
URL: https://issues.apache.org/jira/browse/FLINK-37144
Project: Flink
Issue Type:
Yanquan Lv created FLINK-37142:
--
Summary: Update version of flink-connector-kafka to 4.0-SNAPSHOT
Key: FLINK-37142
URL: https://issues.apache.org/jira/browse/FLINK-37142
Project: Flink
Issue Typ
Yanquan Lv created FLINK-37119:
--
Summary: Bump the version of Paimon flink to 1.0.0
Key: FLINK-37119
URL: https://issues.apache.org/jira/browse/FLINK-37119
Project: Flink
Issue Type: New Feature
Yanquan Lv created FLINK-37095:
--
Summary: test case that used AI model may met quota not enough
exception.
Key: FLINK-37095
URL: https://issues.apache.org/jira/browse/FLINK-37095
Project: Flink
Yanquan Lv created FLINK-36982:
--
Summary: Failed to run pipeline if using `DATE_FORMAT(NOW(),
'-MM-dd') as datetime` in
Key: FLINK-36982
URL: https://issues.apache.org/jira/browse/FLINK-36982
Project
Yanquan Lv created FLINK-36964:
--
Summary: Fix potential exception when SchemaChange in parallel
with Paimon Sink.
Key: FLINK-36964
URL: https://issues.apache.org/jira/browse/FLINK-36964
Project: Flink
Yanquan Lv created FLINK-36923:
--
Summary: Bump flink-connector-hbase to Flink 1.19
Key: FLINK-36923
URL: https://issues.apache.org/jira/browse/FLINK-36923
Project: Flink
Issue Type: New Feature
Yanquan Lv created FLINK-36913:
--
Summary: Add an option in Kafka Sink to manual map table to topic
name.
Key: FLINK-36913
URL: https://issues.apache.org/jira/browse/FLINK-36913
Project: Flink
I
Yanquan Lv created FLINK-36907:
--
Summary: Bump flink-connector-aws to 1.20
Key: FLINK-36907
URL: https://issues.apache.org/jira/browse/FLINK-36907
Project: Flink
Issue Type: New Feature
Yanquan Lv created FLINK-36887:
--
Summary: Add support for Flink 1.20 in Flink Hive connector
Key: FLINK-36887
URL: https://issues.apache.org/jira/browse/FLINK-36887
Project: Flink
Issue Type: N
Yanquan Lv created FLINK-36877:
--
Summary: Kafka Sink output canal-json format of deleted record is
incorrect format.
Key: FLINK-36877
URL: https://issues.apache.org/jira/browse/FLINK-36877
Project: Flin
Yanquan Lv created FLINK-36852:
--
Summary: Avoid StackOverflowError in Paimon Pipeline sink
Key: FLINK-36852
URL: https://issues.apache.org/jira/browse/FLINK-36852
Project: Flink
Issue Type: Bug
Yanquan Lv created FLINK-36845:
--
Summary: SourceTestSuiteBase/SinkTestSuiteBase will fail with
`this operator belongs to is not initialized` error
Key: FLINK-36845
URL: https://issues.apache.org/jira/browse/FLINK-368
Yanquan Lv created FLINK-36843:
--
Summary: Remove deprecated method in flink-table-planner
Key: FLINK-36843
URL: https://issues.apache.org/jira/browse/FLINK-36843
Project: Flink
Issue Type: Impro
Yanquan Lv created FLINK-36832:
--
Summary: Remove deprecated class in flink-connector-kafka
Key: FLINK-36832
URL: https://issues.apache.org/jira/browse/FLINK-36832
Project: Flink
Issue Type: Impr
Yanquan Lv created FLINK-36798:
--
Summary: Improve data processing speed during the phase from
snapshot to incremental phase
Key: FLINK-36798
URL: https://issues.apache.org/jira/browse/FLINK-36798
Project
Yanquan Lv created FLINK-36750:
--
Summary: Paimon connector would reuse sequence number when schema
evolution happened
Key: FLINK-36750
URL: https://issues.apache.org/jira/browse/FLINK-36750
Project: Flin
Yanquan Lv created FLINK-36688:
--
Summary: table.optimizer.reuse-source-enabled may cause disordered
metadata columns when reading from Kafka.
Key: FLINK-36688
URL: https://issues.apache.org/jira/browse/FLINK-36688
Yanquan Lv created FLINK-36682:
--
Summary: Add split assign strategy to avoid OOM error in
TaskManager
Key: FLINK-36682
URL: https://issues.apache.org/jira/browse/FLINK-36682
Project: Flink
Issu
74 matches
Mail list logo
