Sam Barker created FLINK-36460:
--
Summary: Refactor Kubernetes Operator Edge to Edge test setup
Key: FLINK-36460
URL: https://issues.apache.org/jira/browse/FLINK-36460
Project: Flink
Issue Type
LvYanquan created FLINK-36459:
-
Summary: Add document to guide user to configure debezium
properties
Key: FLINK-36459
URL: https://issues.apache.org/jira/browse/FLINK-36459
Project: Flink
Issue
He Wang created FLINK-36458:
---
Summary: Use original 'OceanBaseCEContainer' of testcontainers in
testing
Key: FLINK-36458
URL: https://issues.apache.org/jira/browse/FLINK-36458
Proj
Aleksandr Pilipenko created FLINK-36457:
---
Summary: Python DataStream API: calling add_jars or add_classpaths
results in corrupted execution config
Key: FLINK-36457
URL: https://issues.apache.org/jira/browse
Raul Garcia created FLINK-36456:
---
Summary: Improve Security in DatadogHttpReporterFactory by
providing ENV alternative to retrieve API key
Key: FLINK-36456
URL: https://issues.apache.org/jira/browse/FLINK-36456
Arvid Heise created FLINK-36455:
---
Summary: Sink should commit everything on notifyCheckpointCompleted
Key: FLINK-36455
URL: https://issues.apache.org/jira/browse/FLINK-36455
Project: Flink
Arvid Heise created FLINK-36454:
---
Summary: FlinkContainer always overwrites default config
Key: FLINK-36454
URL: https://issues.apache.org/jira/browse/FLINK-36454
Project: Flink
Issue Type
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
LvYanquan created FLINK-36452:
-
Summary: Avoid EOFException when reading binlog after a large
table has just completed snapshot reading
Key: FLINK-36452
URL: https://issues.apache.org/jira/browse/FLINK-36452
xiechenling created FLINK-36451:
---
Summary: Kubernetes Application JobManager Potential Deadlock and
TaskManager Pod Residuals
Key: FLINK-36451
URL: https://issues.apache.org/jira/browse/FLINK-36451
Siddharth R created FLINK-36450:
---
Summary: Exclude log4j from curator-test
Key: FLINK-36450
URL: https://issues.apache.org/jira/browse/FLINK-36450
Project: Flink
Issue Type: Improvement
Siddharth R created FLINK-36449:
---
Summary: Bump apache-rat-plugin from 0.12 to 0.16.1
Key: FLINK-36449
URL: https://issues.apache.org/jira/browse/FLINK-36449
Project: Flink
Issue Type
Kumar Mallikarjuna created FLINK-36448:
--
Summary: Compilation fails in IntelliJ
Key: FLINK-36448
URL: https://issues.apache.org/jira/browse/FLINK-36448
Project: Flink
Issue Type: Bug
Weijie Guo created FLINK-36447:
--
Summary: Add .java-version(generated by jenv) to git igonre
Key: FLINK-36447
URL: https://issues.apache.org/jira/browse/FLINK-36447
Project: Flink
Issue Type
Junrui Li created FLINK-36446:
-
Summary: Refactor Job Submission Process to Use ExecutionPlan
Instead of JobGraph
Key: FLINK-36446
URL: https://issues.apache.org/jira/browse/FLINK-36446
Project: Flink
Junrui Li created FLINK-36445:
-
Summary: Introducing an ExecutionPlan interface
Key: FLINK-36445
URL: https://issues.apache.org/jira/browse/FLINK-36445
Project: Flink
Issue Type: Sub-task
xuhuang created FLINK-36444:
---
Summary: unstable test case
SimpleRecoveryITCaseBase#testFailedRunThenSuccessfulRun
Key: FLINK-36444
URL: https://issues.apache.org/jira/browse/FLINK-36444
Project: Flink
William Lin created FLINK-36443:
---
Summary: Flaky Test: assertEquals in
PushPartitionIntoTableSourceScanRuleTest.testWithUdf
Key: FLINK-36443
URL: https://issues.apache.org/jira/browse/FLINK-36443
Nandor Soma Abonyi created FLINK-36442:
--
Summary: Add option to handle insert-only changeless in Postgres
CDC connector
Key: FLINK-36442
URL: https://issues.apache.org/jira/browse/FLINK-36442
Arvid Heise created FLINK-36441:
---
Summary: Resource leaks in Kafka Tests
Key: FLINK-36441
URL: https://issues.apache.org/jira/browse/FLINK-36441
Project: Flink
Issue Type: Bug
Affects
Siddharth R created FLINK-36440:
---
Summary: Bump log4j from 2.17.1 to 2.23.1
Key: FLINK-36440
URL: https://issues.apache.org/jira/browse/FLINK-36440
Project: Flink
Issue Type: Improvement
Zakelly Lan created FLINK-36439:
---
Summary: Documentation for Disaggregated State Storage and
Management
Key: FLINK-36439
URL: https://issues.apache.org/jira/browse/FLINK-36439
Project: Flink
Siddharth R created FLINK-36438:
---
Summary: Bump assertj from 3.23.1 to 3.26.3
Key: FLINK-36438
URL: https://issues.apache.org/jira/browse/FLINK-36438
Project: Flink
Issue Type: Improvement
Xuannan Su created FLINK-36437:
--
Summary: Hive connector failed to compile with JDK 11
Key: FLINK-36437
URL: https://issues.apache.org/jira/browse/FLINK-36437
Project: Flink
Issue Type: Bug
xuyang created FLINK-36436:
--
Summary: Remove legacy APIs with `legacy` package in table modules
Key: FLINK-36436
URL: https://issues.apache.org/jira/browse/FLINK-36436
Project: Flink
Issue Type
Weijie Guo created FLINK-36435:
--
Summary: Shaded Hadoop S3A with credentials provider end-to-end
test failed
Key: FLINK-36435
URL: https://issues.apache.org/jira/browse/FLINK-36435
Project: Flink
xuhuang created FLINK-36433:
---
Summary: non-keyed fullWindowPartition#reduce may throw NPE
Key: FLINK-36433
URL: https://issues.apache.org/jira/browse/FLINK-36433
Project: Flink
Issue Type: Bug
Arvid Heise created FLINK-36434:
---
Summary: Revise threading model of (KafkaPartition)SplitReader
Key: FLINK-36434
URL: https://issues.apache.org/jira/browse/FLINK-36434
Project: Flink
Issue
Saurabh created FLINK-36432:
---
Summary: FLIP-438: Amazon SQS Source Connector
Key: FLINK-36432
URL: https://issues.apache.org/jira/browse/FLINK-36432
Project: Flink
Issue Type: New Feature
Xiaowen Sun created FLINK-36431:
---
Summary: Enhancing Flink History Server File Storage and Retrieval
with RocksDB
Key: FLINK-36431
URL: https://issues.apache.org/jira/browse/FLINK-36431
Project: Flink
Xiaowen Sun created FLINK-36429:
---
Summary: Enhancing Flink History Server File Storage and Retrieval
with RocksDB
Key: FLINK-36429
URL: https://issues.apache.org/jira/browse/FLINK-36429
Project: Flink
Xiaowen Sun created FLINK-36430:
---
Summary: Enhancing Flink History Server File Storage and Retrieval
with RocksDB
Key: FLINK-36430
URL: https://issues.apache.org/jira/browse/FLINK-36430
Project: Flink
maoxingda created FLINK-36428:
-
Summary: DynamoDb Table API Sink fails when null value in the
RowData
Key: FLINK-36428
URL: https://issues.apache.org/jira/browse/FLINK-36428
Project: Flink
Elphas Toringepi created FLINK-36427:
Summary: Additional Integration Test cases for KDS source
Key: FLINK-36427
URL: https://issues.apache.org/jira/browse/FLINK-36427
Project: Flink
URL: https://issues.apache.org/jira/browse/FLINK-36426
Project: Flink
Issue Type: Improvement
Components: Runtime / Coordination
Reporter: RocMarshal
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
Gyula Fora created FLINK-36425:
--
Summary: Use JobStatus enum for status.job.state
Key: FLINK-36425
URL: https://issues.apache.org/jira/browse/FLINK-36425
Project: Flink
Issue Type: Improvement
Ferenc Csaky created FLINK-36424:
Summary: Update deprecated YARN RM/NM callback handlers
Key: FLINK-36424
URL: https://issues.apache.org/jira/browse/FLINK-36424
Project: Flink
Issue Type
xuhuang created FLINK-36423:
---
Summary: Support RichMapPartitionFunction on
KyedPartitionWindowedStream
Key: FLINK-36423
URL: https://issues.apache.org/jira/browse/FLINK-36423
Project: Flink
Issue
Aleksandr Pilipenko created FLINK-36422:
---
Summary: Broken PyFlink jar download link for Kafka connector
Key: FLINK-36422
URL: https://issues.apache.org/jira/browse/FLINK-36422
Project: Flink
Marc Aurel Fritz created FLINK-36421:
Summary: Missing fsync in FsCheckpointStreamFactory
Key: FLINK-36421
URL: https://issues.apache.org/jira/browse/FLINK-36421
Project: Flink
Issue
Danny Cranmer created FLINK-36420:
-
Summary: Upgrade org.apache.avro:avro to 1.11.4
Key: FLINK-36420
URL: https://issues.apache.org/jira/browse/FLINK-36420
Project: Flink
Issue Type
Sergey Kononov created FLINK-36419:
--
Summary: Consider scaling in case of no input records on a source
operator with long running job
Key: FLINK-36419
URL: https://issues.apache.org/jira/browse/FLINK-36419
Gyula Fora created FLINK-36418:
--
Summary: Update Control Flow page with latest developments
Key: FLINK-36418
URL: https://issues.apache.org/jira/browse/FLINK-36418
Project: Flink
Issue Type
Sergey Nuyanzin created FLINK-36417:
---
Summary: STATE_TTL doesn't work with WatermarkAssigner
Key: FLINK-36417
URL: https://issues.apache.org/jira/browse/FLINK-36417
Project: Flink
Piotr Nowojski created FLINK-36416:
--
Summary: Enable splittable timers for temporal join, temporal sort
and windowed aggregation in SQL/Table API
Key: FLINK-36416
URL: https://issues.apache.org/jira/browse/FLINK
Sergey Nuyanzin created FLINK-36415:
---
Summary: ProjectWatermarkAssignerTransposeRule can generate extra
casts which do not make sense
Key: FLINK-36415
URL: https://issues.apache.org/jira/browse/FLINK-36415
Yang Hua Jie created FLINK-36414:
Summary: NoSuchMethodError while trying flink cdc
Key: FLINK-36414
URL: https://issues.apache.org/jira/browse/FLINK-36414
Project: Flink
Issue Type: Bug
LvYanquan created FLINK-36413:
-
Summary: Reenable the test case that related to Source/Sink APi
deprecated.
Key: FLINK-36413
URL: https://issues.apache.org/jira/browse/FLINK-36413
Project: Flink
Ed Berezitsky created FLINK-36412:
-
Summary: Retry strategies on Kinesis Sink
Key: FLINK-36412
URL: https://issues.apache.org/jira/browse/FLINK-36412
Project: Flink
Issue Type: Improvement
Sai Sharath Dandi created FLINK-36411:
-
Summary: Allow configuring job vertex throughput limits for auto
scaler
Key: FLINK-36411
URL: https://issues.apache.org/jira/browse/FLINK-36411
Project
Zhenqiu Huang created FLINK-36410:
-
Summary: Improve Lineage Info Collection for flink app
Key: FLINK-36410
URL: https://issues.apache.org/jira/browse/FLINK-36410
Project: Flink
Issue Type
Gyula Fora created FLINK-36409:
--
Summary: Publish some autoscaler metrics during stabilisation
period
Key: FLINK-36409
URL: https://issues.apache.org/jira/browse/FLINK-36409
Project: Flink
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
Sergei Morozov created FLINK-36407:
--
Summary: SchemaRegistry doesn't shutdown its underlying
ExecutorService upon closing
Key: FLINK-36407
URL: https://issues.apache.org/jira/browse/FLINK-
Sergei Morozov created FLINK-36406:
--
Summary: MetadataApplier should be closed when the job stop
Key: FLINK-36406
URL: https://issues.apache.org/jira/browse/FLINK-36406
Project: Flink
Issue
Chenyu Zheng created FLINK-36405:
Summary: Fix startup issues on kerberos clusters
Key: FLINK-36405
URL: https://issues.apache.org/jira/browse/FLINK-36405
Project: Flink
Issue Type: Bug
Lorenzo Nicora created FLINK-36404:
--
Summary: PrometheusSinkWriteException thrown by the response
callback may not cause job to fail
Key: FLINK-36404
URL: https://issues.apache.org/jira/browse/FLINK-36404
gaoyan created FLINK-36403:
--
Summary: K8s native mode Use ConfigMap to get a better experience
Key: FLINK-36403
URL: https://issues.apache.org/jira/browse/FLINK-36403
Project: Flink
Issue Type
altenchen created FLINK-36402:
-
Summary: Improper variable naming
Key: FLINK-36402
URL: https://issues.apache.org/jira/browse/FLINK-36402
Project: Flink
Issue Type: Improvement
xuhuang created FLINK-36401:
---
Summary: PR ci failed
Key: FLINK-36401
URL: https://issues.apache.org/jira/browse/FLINK-36401
Project: Flink
Issue Type: Bug
Reporter: xuhuang
The PR CI
Lorenzo Nicora created FLINK-36400:
--
Summary: 403 and 404 responses should be fatal
Key: FLINK-36400
URL: https://issues.apache.org/jira/browse/FLINK-36400
Project: Flink
Issue Type: Sub
Jacky Lau created FLINK-36399:
-
Summary: cast result is incorrect
Key: FLINK-36399
URL: https://issues.apache.org/jira/browse/FLINK-36399
Project: Flink
Issue Type: Bug
Components
JunboWang created FLINK-36398:
-
Summary: Provide tools for users to obtain Schema mapping
Key: FLINK-36398
URL: https://issues.apache.org/jira/browse/FLINK-36398
Project: Flink
Issue Type
Zhongmin Qiao created FLINK-36397:
-
Summary: Using the offset obtained after a query transaction as a
high watermark cannot ensure exactly-once semantics.
Key: FLINK-36397
URL: https://issues.apache.org/jira
xuyang created FLINK-36396:
--
Summary: Remove dependency flink-java in all flink-table-api-xxx
module
Key: FLINK-36396
URL: https://issues.apache.org/jira/browse/FLINK-36396
Project: Flink
Issue
JieTan created FLINK-36394:
--
Summary: Configure Init Metaspace size by default
Key: FLINK-36394
URL: https://issues.apache.org/jira/browse/FLINK-36394
Project: Flink
Issue Type: Bug
Sam Barker created FLINK-36393:
--
Summary: Flink Operator uses out of date GitHub actions.
Key: FLINK-36393
URL: https://issues.apache.org/jira/browse/FLINK-36393
Project: Flink
Issue Type
Sam Barker created FLINK-36392:
--
Summary: Varying the Java version in the Operator CI has no effect
Key: FLINK-36392
URL: https://issues.apache.org/jira/browse/FLINK-36392
Project: Flink
Issue
xuyang created FLINK-36391:
--
Summary: Remove dependency flink-java in flink-table-runtime module
Key: FLINK-36391
URL: https://issues.apache.org/jira/browse/FLINK-36391
Project: Flink
Issue Type
Weijie Guo created FLINK-36390:
--
Summary: Remove deprecate RichFunction#open(Configuration)
Key: FLINK-36390
URL: https://issues.apache.org/jira/browse/FLINK-36390
Project: Flink
Issue Type
Archit Goyal created FLINK-36389:
Summary: Fix DelegationTokenReceiverRepository to check if
Delegation Token is enabled
Key: FLINK-36389
URL: https://issues.apache.org/jira/browse/FLINK-36389
Panagiotis Garefalakis created FLINK-36388:
--
Summary: Truncate failure labels on web interface
Key: FLINK-36388
URL: https://issues.apache.org/jira/browse/FLINK-36388
Project: Flink
xuyang created FLINK-36387:
--
Summary: Remove dependency flink-java in flink-table-planner module
Key: FLINK-36387
URL: https://issues.apache.org/jira/browse/FLINK-36387
Project: Flink
Issue Type
xuyang created FLINK-36386:
--
Summary: Remove dependency flink-java in
flink-table-planner-loader and flink-table-planner-loader-bundle module
Key: FLINK-36386
URL: https://issues.apache.org/jira/browse/FLINK-36386
xuyang created FLINK-36385:
--
Summary: Remove dependency flink-java in flink-sql-gateway module
Key: FLINK-36385
URL: https://issues.apache.org/jira/browse/FLINK-36385
Project: Flink
Issue Type: Sub
xuyang created FLINK-36384:
--
Summary: Remove dependency flink-java in flink-sql-client module
Key: FLINK-36384
URL: https://issues.apache.org/jira/browse/FLINK-36384
Project: Flink
Issue Type: Sub
xuyang created FLINK-36383:
--
Summary: Remove dependency flink-java in flink-sql-jdbc-driver and
flink-sql-jdbc-driver-bundle module
Key: FLINK-36383
URL: https://issues.apache.org/jira/browse/FLINK-36383
xuyang created FLINK-36382:
--
Summary: Remove dependency flink-java in flink-table-test-utils
module
Key: FLINK-36382
URL: https://issues.apache.org/jira/browse/FLINK-36382
Project: Flink
Issue
xuyang created FLINK-36381:
--
Summary: Remove skip tag in python module caused by deprecating
legacy csv source
Key: FLINK-36381
URL: https://issues.apache.org/jira/browse/FLINK-36381
Project: Flink
mumu created FLINK-36380:
Summary: Cannot determine simple type name "org"
Key: FLINK-36380
URL: https://issues.apache.org/jira/browse/FLINK-36380
Project: Flink
Issue Type: Bug
Arvid Heise created FLINK-36379:
---
Summary: Improve (Global)Committer with UC disabled
Key: FLINK-36379
URL: https://issues.apache.org/jira/browse/FLINK-36379
Project: Flink
Issue Type: Bug
Jacky Lau created FLINK-36378:
-
Summary: type extraction problem between java BigDecimal and sql
decimal
Key: FLINK-36378
URL: https://issues.apache.org/jira/browse/FLINK-36378
Project: Flink
Yang Li created FLINK-36377:
---
Summary: Support the use of the LAST_VALUE aggregate function on
ROW type data
Key: FLINK-36377
URL: https://issues.apache.org/jira/browse/FLINK-36377
Project: Flink
Zakelly Lan created FLINK-36376:
---
Summary: More friendly error or warn message for misconfigured
statebackend with async state processing
Key: FLINK-36376
URL: https://issues.apache.org/jira/browse/FLINK-36376
linqigeng created FLINK-36375:
-
Summary: Missing default value in AddColumnEvent
Key: FLINK-36375
URL: https://issues.apache.org/jira/browse/FLINK-36375
Project: Flink
Issue Type: Bug
Zakelly Lan created FLINK-36374:
---
Summary: Bundle forst statebackend in flink-dist and provide
shortcut to enable
Key: FLINK-36374
URL: https://issues.apache.org/jira/browse/FLINK-36374
Project: Flink
Yanfei Lei created FLINK-36373:
--
Summary: Support distribute state requests in task thread
Key: FLINK-36373
URL: https://issues.apache.org/jira/browse/FLINK-36373
Project: Flink
Issue Type: Sub
Tan Nguyen created FLINK-36372:
--
Summary: Can not insert data to sink with reserved keywords column
name
Key: FLINK-36372
URL: https://issues.apache.org/jira/browse/FLINK-36372
Project: Flink
Eason Ye created FLINK-36371:
Summary: Field BinaryStringData as keySelector would lead the same
records hash shuffle into different tumble windows
Key: FLINK-36371
URL: https://issues.apache.org/jira/browse/FLINK
Aniruddh J created FLINK-36370:
--
Summary: Flink 1.18 fails with Empty server certificate chain when
High Availability and mTLS both enabled
Key: FLINK-36370
URL: https://issues.apache.org/jira/browse/FLINK-36370
xuyang created FLINK-36369:
--
Summary: Move deprecated user-visible classes in table modules to
the legacy package to make it easier to delete them later
Key: FLINK-36369
URL: https://issues.apache.org/jira/browse/FLINK
Arvid Heise created FLINK-36368:
---
Summary: Fix subtask management in CommittableCollector
Key: FLINK-36368
URL: https://issues.apache.org/jira/browse/FLINK-36368
Project: Flink
Issue Type
Sergey Nuyanzin created FLINK-36367:
---
Summary: Use RexNormalize in EquivalentExprShuttle
Key: FLINK-36367
URL: https://issues.apache.org/jira/browse/FLINK-36367
Project: Flink
Issue Type
Weijie Guo created FLINK-36366:
--
Summary: Remove deprecate API in flink-core exclude connector and
state part
Key: FLINK-36366
URL: https://issues.apache.org/jira/browse/FLINK-36366
Project: Flink
zhanghuaibei created FLINK-36365:
Summary: The fetchsize parameter of
flink-sql-connector-mysql-cdc-3.2.0 does not take effect
Key: FLINK-36365
URL: https://issues.apache.org/jira/browse/FLINK-36365
Zakelly Lan created FLINK-36364:
---
Summary: Do not reuse serialized key in Forst map state and/or
other namespaces
Key: FLINK-36364
URL: https://issues.apache.org/jira/browse/FLINK-36364
Project: Flink
xuyang created FLINK-36363:
--
Summary: Remove references to scala-relate api in tests among
table modules
Key: FLINK-36363
URL: https://issues.apache.org/jira/browse/FLINK-36363
Project: Flink
xuyang created FLINK-36362:
--
Summary: Remove dependency about `flink-java` in table module
Key: FLINK-36362
URL: https://issues.apache.org/jira/browse/FLINK-36362
Project: Flink
Issue Type
Sergey Nuyanzin created FLINK-36361:
---
Summary: Do not use StringBuilder for EquivalentExprShuttle
Key: FLINK-36361
URL: https://issues.apache.org/jira/browse/FLINK-36361
Project: Flink
Xintong Song created FLINK-36360:
Summary: Prepare release process and Scripts for the preview
release
Key: FLINK-36360
URL: https://issues.apache.org/jira/browse/FLINK-36360
Project: Flink
1 - 100 of 5690 matches
Mail list logo