Igor Basov created FLINK-35477:
--
Summary: Pulsar connector resets existing subscription
Key: FLINK-35477
URL: https://issues.apache.org/jira/browse/FLINK-35477
Project: Flink
Issue Type: Bug
jianhao.Li created FLINK-35476:
--
Summary: The IF built-in function returns an exception when
returning a string
Key: FLINK-35476
URL: https://issues.apache.org/jira/browse/FLINK-35476
Project: Flink
Xuannan Su created FLINK-35475:
--
Summary: Introduce isInternalSorterSupport to OperatorAttributes
Key: FLINK-35475
URL: https://issues.apache.org/jira/browse/FLINK-35475
Project: Flink
Issue
stevedengzhi created FLINK-35474:
Summary: During the process of catching up after a restart, Flink
CDC uses the latest table information to parse old binlogs.
Key: FLINK-35474
URL: https://issues.apache.org/jira
Jane Chan created FLINK-35473:
-
Summary: FLIP-457: Improve Table/SQL Configuration for Flink 2.0
Key: FLINK-35473
URL: https://issues.apache.org/jira/browse/FLINK-35473
Project: Flink
Issue Type
Mingliang Liu created FLINK-35472:
-
Summary: Improve tests for Elasticsearch 8 connector
Key: FLINK-35472
URL: https://issues.apache.org/jira/browse/FLINK-35472
Project: Flink
Issue Type
Rui Fan created FLINK-35471:
---
Summary: Kubernetes operator bumps the flink version to 1.19
Key: FLINK-35471
URL: https://issues.apache.org/jira/browse/FLINK-35471
Project: Flink
Issue Type
Rajat Pratap Singh created FLINK-35470:
--
Summary: Flink 1.18.1 and 1.19.0 having build jdk 1.8 and causing
incompatibilities with Java 17
Key: FLINK-35470
URL: https://issues.apache.org/jira/browse/FLINK
RocMarshal created FLINK-35469:
--
Summary: Unstable test case 'testProject' of
JdbcDynamicTableSourceITCase
Key: FLINK-35469
URL: https://issues.apache.org/jira/browse/FLINK-35469
Project: Flink
zhou zhuohan created FLINK-35468:
Summary: [Connectors/Pulsar] update isEnableAutoAcknowledgeMessage
config comment
Key: FLINK-35468
URL: https://issues.apache.org/jira/browse/FLINK-35468
Project
: FLINK-35467
URL: https://issues.apache.org/jira/browse/FLINK-35467
Project: Flink
Issue Type: Improvement
Components: Flink CDC
Affects Versions: cdc-3.1.0
Environment: Environment Information:
flink-1.17.1
flink-cdc-3.1.0
Gyula Fora created FLINK-35466:
--
Summary: Cannot pass all columns to SQL UDFs using `*`
Key: FLINK-35466
URL: https://issues.apache.org/jira/browse/FLINK-35466
Project: Flink
Issue Type: Bug
Junrui Li created FLINK-35465:
-
Summary: Introduce BatchJobRecoveryHandler for recovery of batch
jobs from JobMaster failures.
Key: FLINK-35465
URL: https://issues.apache.org/jira/browse/FLINK-35465
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
hk__lrzy created FLINK-35463:
Summary: CDC job failed when restored from checkpoint when route
rule changed.
Key: FLINK-35463
URL: https://issues.apache.org/jira/browse/FLINK-35463
Project: Flink
/jira/browse/FLINK-35462
Project: Flink
Issue Type: Improvement
Components: Table SQL / Planner
Reporter: yuanfenghu
When using the flinksql connector, we can set the parallelism of the sink.
However, when we modify the parallelism of the sink
Xuannan Su created FLINK-35461:
--
Summary: Improve Runtime Configuration for Flink 2.0
Key: FLINK-35461
URL: https://issues.apache.org/jira/browse/FLINK-35461
Project: Flink
Issue Type
Hangxiang Yu created FLINK-35460:
Summary: Check file size when position read for ForSt
Key: FLINK-35460
URL: https://issues.apache.org/jira/browse/FLINK-35460
Project: Flink
Issue Type: Bug
ouyangwulin created FLINK-35459:
---
Summary: Use Incremental Source Framework in Flink CDC TiKV Source
Connector
Key: FLINK-35459
URL: https://issues.apache.org/jira/browse/FLINK-35459
Project: Flink
Zhanghao Chen created FLINK-35458:
-
Summary: Add serializer upgrade test for set serializer
Key: FLINK-35458
URL: https://issues.apache.org/jira/browse/FLINK-35458
Project: Flink
Issue Type
Weijie Guo created FLINK-35457:
--
Summary: EventTimeWindowCheckpointingITCase fails on AZP as NPE
Key: FLINK-35457
URL: https://issues.apache.org/jira/browse/FLINK-35457
Project: Flink
Issue
Weijie Guo created FLINK-35456:
--
Summary: WindowAggregateITCase.testEventTimeHopWindow fails on AZP
as NPE
Key: FLINK-35456
URL: https://issues.apache.org/jira/browse/FLINK-35456
Project: Flink
Kaiyao Ke created FLINK-35455:
-
Summary: Non-idempotent unit tests
Key: FLINK-35455
URL: https://issues.apache.org/jira/browse/FLINK-35455
Project: Flink
Issue Type: Bug
Reporter
Ahmed Hamdy created FLINK-35454:
---
Summary: Connector ArchTests fails due to dependency on
fink.util.Preconditions
Key: FLINK-35454
URL: https://issues.apache.org/jira/browse/FLINK-35454
Project: Flink
xy created FLINK-35453:
--
Summary: StreamReader Charset fix with UTF8 in core files
Key: FLINK-35453
URL: https://issues.apache.org/jira/browse/FLINK-35453
Project: Flink
Issue Type: Improvement
Sharon Xie created FLINK-35452:
--
Summary: MySQL CDC not tracking newly added tables after snapshot
Key: FLINK-35452
URL: https://issues.apache.org/jira/browse/FLINK-35452
Project: Flink
Issue
Yubin Li created FLINK-35451:
Summary: Support `ALTER CATALOG COMMENT` syntax
Key: FLINK-35451
URL: https://issues.apache.org/jira/browse/FLINK-35451
Project: Flink
Issue Type: Sub-task
ouyangwulin created FLINK-35450:
---
Summary: Introduce Tikv pipeline DataSource
Key: FLINK-35450
URL: https://issues.apache.org/jira/browse/FLINK-35450
Project: Flink
Issue Type: New Feature
linweijiang created FLINK-35449:
---
Summary: MySQL CDC Flink SQL column names are case-sensitive
Key: FLINK-35449
URL: https://issues.apache.org/jira/browse/FLINK-35449
Project: Flink
Issue Type
Caican Cai created FLINK-35448:
--
Summary: Translate pod templates documentation into Chinese
Key: FLINK-35448
URL: https://issues.apache.org/jira/browse/FLINK-35448
Project: Flink
Issue Type
Zhongqiang Gong created FLINK-35447:
---
Summary: Flink CDC Document document file had removed but website
can access
Key: FLINK-35447
URL: https://issues.apache.org/jira/browse/FLINK-35447
Project
Ryan Skraba created FLINK-35446:
---
Summary: FileMergingSnapshotManagerBase throws a
NullPointerException
Key: FLINK-35446
URL: https://issues.apache.org/jira/browse/FLINK-35446
Project: Flink
Ahmed Hamdy created FLINK-35445:
---
Summary: Update Async Sink documentation for Timeout configuration
Key: FLINK-35445
URL: https://issues.apache.org/jira/browse/FLINK-35445
Project: Flink
LvYanquan created FLINK-35444:
-
Summary: Paimon Pipeline Connector support changing column names
to lowercase for Hive metastore
Key: FLINK-35444
URL: https://issues.apache.org/jira/browse/FLINK-35444
Weijie Guo created FLINK-35443:
--
Summary: ChangelogLocalRecoveryITCase failed fatally with 239 exit
code
Key: FLINK-35443
URL: https://issues.apache.org/jira/browse/FLINK-35443
Project: Flink
LvYanquan created FLINK-35442:
-
Summary: Kafka Pipeline Sink may distribute the same key to
different partitions after modify parallelism
Key: FLINK-35442
URL: https://issues.apache.org/jira/browse/FLINK-35442
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
Zach created FLINK-35440:
Summary: unable to connect tableau to jdbc flink url using flink
sql driver
Key: FLINK-35440
URL: https://issues.apache.org/jira/browse/FLINK-35440
Project: Flink
Issue
Greg Wills created FLINK-35439:
--
Summary: Python Support for AvroSchemaConverter
Key: FLINK-35439
URL: https://issues.apache.org/jira/browse/FLINK-35439
Project: Flink
Issue Type: Improvement
Ryan Skraba created FLINK-35438:
---
Summary: SourceCoordinatorTest.testErrorThrownFromSplitEnumerator
fails on wrong error
Key: FLINK-35438
URL: https://issues.apache.org/jira/browse/FLINK-35438
Project
Dawid Wysakowicz created FLINK-35437:
Summary: BlockStatementGrouper uses lots of memory
Key: FLINK-35437
URL: https://issues.apache.org/jira/browse/FLINK-35437
Project: Flink
Issue Type
hk__lrzy created FLINK-35436:
Summary: Job can't launch when setting the option
schema.change.behavior to IGNORE
Key: FLINK-35436
URL: https://issues.apache.org/jira/browse/FLINK-35436
Project: Flink
Ahmed Hamdy created FLINK-35435:
---
Summary: [FLIP-451] Introduce timeout configuration to AsyncSink
Key: FLINK-35435
URL: https://issues.apache.org/jira/browse/FLINK-35435
Project: Flink
Issue
Feifan Wang created FLINK-35434:
---
Summary: Support pass exception in StateExecutor to runtime
Key: FLINK-35434
URL: https://issues.apache.org/jira/browse/FLINK-35434
Project: Flink
Issue Type
Pavel created FLINK-35433:
-
Summary: Provide a config parameter to set
{{publishNotReadyAddresses}} option for the jobmanager's RPC Kubernetes service
Key: FLINK-35433
URL: https://issues.apache.org/jira/browse/FLINK
hk__lrzy created FLINK-35432:
Summary: Support catch modify-event for mysql-cdc
Key: FLINK-35432
URL: https://issues.apache.org/jira/browse/FLINK-35432
Project: Flink
Issue Type: Improvement
Zhongqiang Gong created FLINK-35431:
---
Summary: Migrate references in Flink CDC documentation from
Debezium 1.9 to 2.0
Key: FLINK-35431
URL: https://issues.apache.org/jira/browse/FLINK-35431
Project
LvYanquan created FLINK-35430:
-
Summary: ZoneId is not passed to DebeziumJsonSerializationSchema
Key: FLINK-35430
URL: https://issues.apache.org/jira/browse/FLINK-35430
Project: Flink
Issue Type
Weijie Guo created FLINK-35429:
--
Summary: We don't need introduce getFlinkConfigurationOptions for
SqlGatewayRestEndpointFactory#Context
Key: FLINK-35429
URL: https://issues.apache.org/jira/browse/FLINK-35429
Weijie Guo created FLINK-35428:
--
Summary: WindowJoinITCase#testInnerJoin failed on AZP as NPE
Key: FLINK-35428
URL: https://issues.apache.org/jira/browse/FLINK-35428
Project: Flink
Issue Type
huhuan created FLINK-35427:
--
Summary: Support fail-on-unknown-field config in json format
Key: FLINK-35427
URL: https://issues.apache.org/jira/browse/FLINK-35427
Project: Flink
Issue Type
xingbe created FLINK-35426:
--
Summary: Change the distribution of DynamicFilteringDataCollector
to Broadcast
Key: FLINK-35426
URL: https://issues.apache.org/jira/browse/FLINK-35426
Project: Flink
dalongliu created FLINK-35425:
-
Summary: Support convert Freshness to cron expression for full
refresh mode
Key: FLINK-35425
URL: https://issues.apache.org/jira/browse/FLINK-35425
Project: Flink
Mingliang Liu created FLINK-35424:
-
Summary: Elasticsearch connector 8 supports SSL context
Key: FLINK-35424
URL: https://issues.apache.org/jira/browse/FLINK-35424
Project: Flink
Issue Type
Sergey Nuyanzin created FLINK-35423:
---
Summary: ARRAY_EXCEPT should support set semantics
Key: FLINK-35423
URL: https://issues.apache.org/jira/browse/FLINK-35423
Project: Flink
Issue Type
尹博星 created FLINK-35422:
---
Summary: Flink dynamically adjusts operator-level resource usage
without stopping the job
Key: FLINK-35422
URL: https://issues.apache.org/jira/browse/FLINK-35422
Project: Flink
hk__lrzy created FLINK-35421:
Summary: Schema Operator blocking forever when Akka Rpc timeout
Key: FLINK-35421
URL: https://issues.apache.org/jira/browse/FLINK-35421
Project: Flink
Issue Type
Piotr Nowojski created FLINK-35420:
--
Summary: WordCountMapredITCase fails to compile in IntelliJ
Key: FLINK-35420
URL: https://issues.apache.org/jira/browse/FLINK-35420
Project: Flink
Issue
Fabian Paul created FLINK-35419:
---
Summary: scan.bounded.latest-offset makes queries never finish if
the latest message is a EndTxn Kafka marker
Key: FLINK-35419
URL: https://issues.apache.org/jira/browse/FLINK
Ryan Skraba created FLINK-35418:
---
Summary: EventTimeWindowCheckpointingITCase fails with an NPE
Key: FLINK-35418
URL: https://issues.apache.org/jira/browse/FLINK-35418
Project: Flink
Issue
melin created FLINK-35417:
-
Summary: JobManager and TaskManager support merging and run in a
single process
Key: FLINK-35417
URL: https://issues.apache.org/jira/browse/FLINK-35417
Project: Flink
Weijie Guo created FLINK-35416:
--
Summary: Weekly CI for ElasticSearch connector failed to compile
Key: FLINK-35416
URL: https://issues.apache.org/jira/browse/FLINK-35416
Project: Flink
Issue
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
Gyula Fora created FLINK-35414:
--
Summary: Cancel jobs through rest api for last-state upgrades
Key: FLINK-35414
URL: https://issues.apache.org/jira/browse/FLINK-35414
Project: Flink
Issue Type
Ryan Skraba created FLINK-35413:
---
Summary: VertexFinishedStateCheckerTest causes exit 239
Key: FLINK-35413
URL: https://issues.apache.org/jira/browse/FLINK-35413
Project: Flink
Issue Type: Bug
Zakelly Lan created FLINK-35412:
---
Summary: Batch execution of async state request callback
Key: FLINK-35412
URL: https://issues.apache.org/jira/browse/FLINK-35412
Project: Flink
Issue Type
Zakelly Lan created FLINK-35411:
---
Summary: Optimize wait logic in draining of async state requests
Key: FLINK-35411
URL: https://issues.apache.org/jira/browse/FLINK-35411
Project: Flink
Issue
Zakelly Lan created FLINK-35410:
---
Summary: Avoid sync waiting in coordinator thread of ForSt executor
Key: FLINK-35410
URL: https://issues.apache.org/jira/browse/FLINK-35410
Project: Flink
Xiao Huang created FLINK-35409:
--
Summary: Request more splits if all splits are filtered from
addSplits method
Key: FLINK-35409
URL: https://issues.apache.org/jira/browse/FLINK-35409
Project: Flink
Xiao Huang created FLINK-35408:
--
Summary: Add 30 min tolerance value when validating the time-zone
setting
Key: FLINK-35408
URL: https://issues.apache.org/jira/browse/FLINK-35408
Project: Flink
xiaotouming created FLINK-35407:
---
Summary: ensure orderly transactions during the full consumption
stage of MySQL CDC
Key: FLINK-35407
URL: https://issues.apache.org/jira/browse/FLINK-35407
Project
Zhenghua Gao created FLINK-35406:
Summary: Use inner serializer when casting RAW type to BINARY or
STRING in cast rules
Key: FLINK-35406
URL: https://issues.apache.org/jira/browse/FLINK-35406
Project
Yanfei Lei created FLINK-35405:
--
Summary: Add buffer size/in-flight records metrics for
AsyncExecutionController
Key: FLINK-35405
URL: https://issues.apache.org/jira/browse/FLINK-35405
Project: Flink
Harshit Mittal created FLINK-35404:
--
Summary: Report metrics of KafkaConsumer in new Kafka source
Key: FLINK-35404
URL: https://issues.apache.org/jira/browse/FLINK-35404
Project: Flink
Alan Sheinberg created FLINK-35403:
--
Summary: FLIP-452: Allow Skipping Invocation of Function Calls
While Constant-folding
Key: FLINK-35403
URL: https://issues.apache.org/jira/browse/FLINK-35403
Luís Costa created FLINK-35402:
--
Summary: [flink-operator][Deployment] add labels to metadata
Key: FLINK-35402
URL: https://issues.apache.org/jira/browse/FLINK-35402
Project: Flink
Issue Type
Ahmed Hamdy created FLINK-35401:
---
Summary: Add SQS Table API support
Key: FLINK-35401
URL: https://issues.apache.org/jira/browse/FLINK-35401
Project: Flink
Issue Type: New Feature
Zakelly Lan created FLINK-35400:
---
Summary: Rebuild FileMergingSnapshotManager in failover
Key: FLINK-35400
URL: https://issues.apache.org/jira/browse/FLINK-35400
Project: Flink
Issue Type: Sub
Zhu Zhu created FLINK-35399:
---
Summary: Add documents for batch job master failure recovery
Key: FLINK-35399
URL: https://issues.apache.org/jira/browse/FLINK-35399
Project: Flink
Issue Type: Sub
Weijie Guo created FLINK-35398:
--
Summary: SqlGatewayE2ECase failed to pull image
Key: FLINK-35398
URL: https://issues.apache.org/jira/browse/FLINK-35398
Project: Flink
Issue Type: Bug
Caican Cai created FLINK-35397:
--
Summary: Translate Controller Flow documentation into Chinese
Key: FLINK-35397
URL: https://issues.apache.org/jira/browse/FLINK-35397
Project: Flink
Issue Type
Suxing Lee created FLINK-35396:
--
Summary: DynamoDB Streams Consumer consumption data is out of order
Key: FLINK-35396
URL: https://issues.apache.org/jira/browse/FLINK-35396
Project: Flink
Issue
bradley created FLINK-35395:
---
Summary: Fix KeyedStateStore class annotation error
Key: FLINK-35395
URL: https://issues.apache.org/jira/browse/FLINK-35395
Project: Flink
Issue Type: Improvement
melin created FLINK-35394:
-
Summary: paimon pipeline support dynamic bucket
Key: FLINK-35394
URL: https://issues.apache.org/jira/browse/FLINK-35394
Project: Flink
Issue Type: New Feature
melin created FLINK-35393:
-
Summary: Support flink kafka catalog
Key: FLINK-35393
URL: https://issues.apache.org/jira/browse/FLINK-35393
Project: Flink
Issue Type: New Feature
Components
Glauber M Dantas created FLINK-35392:
Summary: SQL Lookup Join on external database failing when using
'FOR SYSTEM_TIME AS OF' statement
Key: FLINK-35392
URL: https://issues.apache.org/jira/browse/FLINK-35392
LvYanquan created FLINK-35391:
-
Summary: Bump dependency of Paimon Pipeline connector to 0.8.0
Key: FLINK-35391
URL: https://issues.apache.org/jira/browse/FLINK-35391
Project: Flink
Issue Type
段志民 created FLINK-35390:
---
Summary: Error reporting in SQL Server connection table structure
table in Flink CDC-3.0 version
Key: FLINK-35390
URL: https://issues.apache.org/jira/browse/FLINK-35390
Project: Flink
Hangxiang Yu created FLINK-35389:
Summary: Implement List Async State API for ForStStateBackend
Key: FLINK-35389
URL: https://issues.apache.org/jira/browse/FLINK-35389
Project: Flink
Issue
Pedro Mázala created FLINK-35388:
Summary: Flink 1.18.1 get stuck after creating highly available
job result storage directory
Key: FLINK-35388
URL: https://issues.apache.org/jira/browse/FLINK-35388
Hongshun Wang created FLINK-35387:
-
Summary: PG CDC source support heart beat
Key: FLINK-35387
URL: https://issues.apache.org/jira/browse/FLINK-35387
Project: Flink
Issue Type: Bug
Qingsheng Ren created FLINK-35386:
-
Summary: Build Flink CDC 3.1 Documentation and mark it as stable
Key: FLINK-35386
URL: https://issues.apache.org/jira/browse/FLINK-35386
Project: Flink
Hongshun Wang created FLINK-35385:
-
Summary: upgrader flink dependency version to 1.19
Key: FLINK-35385
URL: https://issues.apache.org/jira/browse/FLINK-35385
Project: Flink
Issue Type
Steven Zhen Wu created FLINK-35384:
--
Summary: Expose metrics group to custom Partitioner
Key: FLINK-35384
URL: https://issues.apache.org/jira/browse/FLINK-35384
Project: Flink
Issue Type
Aleksandr Pilipenko created FLINK-35383:
---
Summary: Update compatibility matrix to include 1.19 release
Key: FLINK-35383
URL: https://issues.apache.org/jira/browse/FLINK-35383
Project: Flink
Ryan Skraba created FLINK-35382:
---
Summary: ChangelogCompatibilityITCase.testRestore fails with an NPE
Key: FLINK-35382
URL: https://issues.apache.org/jira/browse/FLINK-35382
Project: Flink
Ryan Skraba created FLINK-35381:
---
Summary: LocalRecoveryITCase failure on deleting directory
Key: FLINK-35381
URL: https://issues.apache.org/jira/browse/FLINK-35381
Project: Flink
Issue Type
Ryan Skraba created FLINK-35380:
---
Summary: ResumeCheckpointManuallyITCase hanging on tests
Key: FLINK-35380
URL: https://issues.apache.org/jira/browse/FLINK-35380
Project: Flink
Issue Type
Zakelly Lan created FLINK-35379:
---
Summary: File merging manager is not properly notified about
checkpoint
Key: FLINK-35379
URL: https://issues.apache.org/jira/browse/FLINK-35379
Project: Flink
Martijn Visser created FLINK-35378:
--
Summary: [FLIP-453] Promote Unified Sink API V2 to Public and
Deprecate SinkFunc
Key: FLINK-35378
URL: https://issues.apache.org/jira/browse/FLINK-35378
Project
501 - 600 of 33142 matches
Mail list logo