Chesnay Schepler created FLINK-36511:
Summary: FlinkSecurityManager#checkExit StackOverFlow if
haltOnSystemExit is enabled
Key: FLINK-36511
URL: https://issues.apache.org/jira/browse/FLINK-36511
Grace Grimwood created FLINK-36510:
--
Summary: Upgrade Pekko from 1.0.1 to 1.1.2
Key: FLINK-36510
URL: https://issues.apache.org/jira/browse/FLINK-36510
Project: Flink
Issue Type: Technical
LvYanquan created FLINK-36509:
-
Summary: Fix 'Unsupported bucket mode: GLOBAL_DYNAMIC' error in
Paimon Pipeline Sink.
Key: FLINK-36509
URL: https://issues.apache.org/jira/browse/FLINK-36509
xuyang created FLINK-36508:
--
Summary: Remove all deprecated methods in `SymbolType `
Key: FLINK-36508
URL: https://issues.apache.org/jira/browse/FLINK-36508
Project: Flink
Issue Type: Sub-task
xuyang created FLINK-36506:
--
Summary: Remove all deprecated methods in `ColumnStats`
Key: FLINK-36506
URL: https://issues.apache.org/jira/browse/FLINK-36506
Project: Flink
Issue Type: Sub-task
xuyang created FLINK-36507:
--
Summary: Remove deprecated method `LogicalTypeParser#parse`
Key: FLINK-36507
URL: https://issues.apache.org/jira/browse/FLINK-36507
Project: Flink
Issue Type: Sub-task
xuyang created FLINK-36505:
--
Summary: Remove all deprecated methods in
`ImperativeAggregateFunction`
Key: FLINK-36505
URL: https://issues.apache.org/jira/browse/FLINK-36505
Project: Flink
Issue
xuyang created FLINK-36503:
--
Summary: Remove deprecated method
`FunctionDefinitionFactory#createFunctionDefinition`
Key: FLINK-36503
URL: https://issues.apache.org/jira/browse/FLINK-36503
Project: Flink
xuyang created FLINK-36504:
--
Summary: Remove all deprecated methods `ModuleFactory`
Key: FLINK-36504
URL: https://issues.apache.org/jira/browse/FLINK-36504
Project: Flink
Issue Type: Sub-task
xuyang created FLINK-36501:
--
Summary: Remove all deprecated methods in `CatalogFactory`
Key: FLINK-36501
URL: https://issues.apache.org/jira/browse/FLINK-36501
Project: Flink
Issue Type: Sub-task
xuyang created FLINK-36502:
--
Summary: Remove all deprecated methods in `FactoryUtil`
Key: FLINK-36502
URL: https://issues.apache.org/jira/browse/FLINK-36502
Project: Flink
Issue Type: Sub-task
xuyang created FLINK-36500:
--
Summary: Remove all deprecated methods in `CallExpression`
Key: FLINK-36500
URL: https://issues.apache.org/jira/browse/FLINK-36500
Project: Flink
Issue Type: Sub-task
xuyang created FLINK-36499:
--
Summary: Remove deprecated method
`SupportsProjectionPushDown#applyProjection`
Key: FLINK-36499
URL: https://issues.apache.org/jira/browse/FLINK-36499
Project: Flink
xuyang created FLINK-36497:
--
Summary: Remove all deprecated methods in `CatalogTable`
Key: FLINK-36497
URL: https://issues.apache.org/jira/browse/FLINK-36497
Project: Flink
Issue Type: Sub-task
xuyang created FLINK-36498:
--
Summary: Remove deprecated method
`ResolvedCatalogBaseTable#getSchema`
Key: FLINK-36498
URL: https://issues.apache.org/jira/browse/FLINK-36498
Project: Flink
Issue
xuyang created FLINK-36496:
--
Summary: Remove deprecated method `CatalogFunction#isGeneric `
Key: FLINK-36496
URL: https://issues.apache.org/jira/browse/FLINK-36496
Project: Flink
Issue Type: Sub
xuyang created FLINK-36495:
--
Summary: Remove deprecated method `CatalogBaseTable#getSchema`
Key: FLINK-36495
URL: https://issues.apache.org/jira/browse/FLINK-36495
Project: Flink
Issue Type: Sub
xuyang created FLINK-36493:
--
Summary: Remove all deprecated methods in `MapView`
Key: FLINK-36493
URL: https://issues.apache.org/jira/browse/FLINK-36493
Project: Flink
Issue Type: Sub-task
xuyang created FLINK-36494:
--
Summary: Remove deprecated methods `Catalog#getTableFactory` and
`Catalog#supportsManagedTable`
Key: FLINK-36494
URL: https://issues.apache.org/jira/browse/FLINK-36494
Project
xuyang created FLINK-36492:
--
Summary: Remove all deprecated methods in `ListView`
Key: FLINK-36492
URL: https://issues.apache.org/jira/browse/FLINK-36492
Project: Flink
Issue Type: Sub-task
xuyang created FLINK-36489:
--
Summary: Remove deprecated method
`StreamTableEnvironment#toRetractStream`
Key: FLINK-36489
URL: https://issues.apache.org/jira/browse/FLINK-36489
Project: Flink
Issue
xuyang created FLINK-36491:
--
Summary: Remove deprecated method
`DataStreamSinkProvider#consumeDataStream`
Key: FLINK-36491
URL: https://issues.apache.org/jira/browse/FLINK-36491
Project: Flink
xuyang created FLINK-36490:
--
Summary: Remove deprecated method
`DataStreamScanProvider#produceDataStream`
Key: FLINK-36490
URL: https://issues.apache.org/jira/browse/FLINK-36490
Project: Flink
xuyang created FLINK-36486:
--
Summary: Remove deprecated method
`StreamTableEnvironment#registerDataStream`
Key: FLINK-36486
URL: https://issues.apache.org/jira/browse/FLINK-36486
Project: Flink
xuyang created FLINK-36488:
--
Summary: Remove deprecated method
`StreamTableEnvironment#toAppendStream`
Key: FLINK-36488
URL: https://issues.apache.org/jira/browse/FLINK-36488
Project: Flink
Issue
xuyang created FLINK-36485:
--
Summary: Remove deprecated method
`StreamTableEnvironment#fromDataStream`
Key: FLINK-36485
URL: https://issues.apache.org/jira/browse/FLINK-36485
Project: Flink
Issue
xuyang created FLINK-36487:
--
Summary: Remove deprecated method
`StreamTableEnvironment#createTemporaryView`
Key: FLINK-36487
URL: https://issues.apache.org/jira/browse/FLINK-36487
Project: Flink
xuyang created FLINK-36484:
--
Summary: Remove deprecated method
`StreamTableEnvironment#registerFunction`
Key: FLINK-36484
URL: https://issues.apache.org/jira/browse/FLINK-36484
Project: Flink
xuyang created FLINK-36482:
--
Summary: Remove all deprecated methods in `TableEnvironment`
Key: FLINK-36482
URL: https://issues.apache.org/jira/browse/FLINK-36482
Project: Flink
Issue Type: Sub-task
xuyang created FLINK-36483:
--
Summary: Remove deprecated method `TableResult#getTableSchema`
Key: FLINK-36483
URL: https://issues.apache.org/jira/browse/FLINK-36483
Project: Flink
Issue Type: Sub
xuyang created FLINK-36481:
--
Summary: Remove deprecated method `TableDescriptor#forManaged`
Key: FLINK-36481
URL: https://issues.apache.org/jira/browse/FLINK-36481
Project: Flink
Issue Type: Sub
xuyang created FLINK-36480:
--
Summary: Remove all deprecated methods in `TableConfig`
Key: FLINK-36480
URL: https://issues.apache.org/jira/browse/FLINK-36480
Project: Flink
Issue Type: Sub-task
xuyang created FLINK-36479:
--
Summary: Remove deprecated methods `Table#getSchema` and `Table#as`
Key: FLINK-36479
URL: https://issues.apache.org/jira/browse/FLINK-36479
Project: Flink
Issue Type
xuyang created FLINK-36478:
--
Summary: Remove deprecated methods
`EnvironmentSettings#fromConfiguration` and
`EnvironmentSettings#toConfiguration`
Key: FLINK-36478
URL: https://issues.apache.org/jira/browse/FLINK-36478
xuyang created FLINK-36477:
--
Summary: Remove deprecated method `BaseExpressions#cast` in
table-api-java
Key: FLINK-36477
URL: https://issues.apache.org/jira/browse/FLINK-36477
Project: Flink
Issue
xuyang created FLINK-36476:
--
Summary: Remove all deprecated methods under public APIs in table
modules
Key: FLINK-36476
URL: https://issues.apache.org/jira/browse/FLINK-36476
Project: Flink
Issue
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
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
Sam Barker created FLINK-36473:
--
Summary: Operator metrics tests fail intermittently
Key: FLINK-36473
URL: https://issues.apache.org/jira/browse/FLINK-36473
Project: Flink
Issue Type: Bug
Alan Sheinberg created FLINK-36472:
--
Summary: Correlates with UDTF don't handle right-side conditions
or projections
Key: FLINK-36472
URL: https://issues.apache.org/jira/browse/FLINK-36472
Pr
Sam Barker created FLINK-36471:
--
Summary: Flink Operator uses out of date Docker actions.
Key: FLINK-36471
URL: https://issues.apache.org/jira/browse/FLINK-36471
Project: Flink
Issue Type
Sergey Nuyanzin created FLINK-36470:
---
Summary: Bump checkstyle to 10+
Key: FLINK-36470
URL: https://issues.apache.org/jira/browse/FLINK-36470
Project: Flink
Issue Type: Technical Debt
Siddharth R created FLINK-36469:
---
Summary: Bump commons-io from 2.11.0 to 2.17.0
Key: FLINK-36469
URL: https://issues.apache.org/jira/browse/FLINK-36469
Project: Flink
Issue Type: Improvement
Ferenc Csaky created FLINK-36468:
Summary: Use Flink Precondition utils instead of Parquet
Key: FLINK-36468
URL: https://issues.apache.org/jira/browse/FLINK-36468
Project: Flink
Issue Type
Mate Czagany created FLINK-36467:
Summary: Bump google-java-format and spotless
Key: FLINK-36467
URL: https://issues.apache.org/jira/browse/FLINK-36467
Project: Flink
Issue Type: Improvement
Wenjun Ruan created FLINK-36466:
---
Summary: Change default value of execution.runtime-mode from
STREAMING to AUTOMATIC
Key: FLINK-36466
URL: https://issues.apache.org/jira/browse/FLINK-36466
Project
Siddharth R created FLINK-36465:
---
Summary: Bump okhttp from 3.14.9 to 4.12.0
Key: FLINK-36465
URL: https://issues.apache.org/jira/browse/FLINK-36465
Project: Flink
Issue Type: Improvement
Fabian Paul created FLINK-36464:
---
Summary: Local artifact fetcher should not require base directory
Key: FLINK-36464
URL: https://issues.apache.org/jira/browse/FLINK-36464
Project: Flink
Issue
Xiao Huang created FLINK-36463:
--
Summary: Disable some debezium options which do not take effect
Key: FLINK-36463
URL: https://issues.apache.org/jira/browse/FLINK-36463
Project: Flink
Issue
xuhuang created FLINK-36462:
---
Summary: Revert "remove per-job"
Key: FLINK-36462
URL: https://issues.apache.org/jira/browse/FLINK-36462
Project: Flink
Issue Type: Bug
Reporte
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
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
1 - 100 of 5677 matches
Mail list logo
