Gyula Fora created FLINK-38421:
--
Summary: BlueGreen Deployment Documentation
Key: FLINK-38421
URL: https://issues.apache.org/jira/browse/FLINK-38421
Project: Flink
Issue Type: Sub-task
Derek Chen-Becker created FLINK-38419:
-
Summary: Update official Flink docker images
Key: FLINK-38419
URL: https://issues.apache.org/jira/browse/FLINK-38419
Project: Flink
Issue Type
Gustavo de Morais created FLINK-38417:
-
Summary: Ensure attribute ordering when managing join attributes
in JoinKeyExtractor
Key: FLINK-38417
URL: https://issues.apache.org/jira/browse/FLINK-38417
Muhammad created FLINK-38413:
Summary: Support Append Only table from MySQL Pipeline Connectors
Key: FLINK-38413
URL: https://issues.apache.org/jira/browse/FLINK-38413
Project: Flink
Issue Type
Simon Frei created FLINK-38411:
--
Summary: Array index overflow in enumerator with continuous file
source
Key: FLINK-38411
URL: https://issues.apache.org/jira/browse/FLINK-38411
Project: Flink
Attila Mészáros created FLINK-38409:
---
Summary: Showcase in Helm chart values.yaml that config.yaml can
be used
Key: FLINK-38409
URL: https://issues.apache.org/jira/browse/FLINK-38409
Project: Flink
Ruan Hang created FLINK-38405:
-
Summary: ChangelogNormalizeRestoreTest failed in test_cron_azure
table
Key: FLINK-38405
URL: https://issues.apache.org/jira/browse/FLINK-38405
Project: Flink
Ruan Hang created FLINK-38408:
-
Summary: MapStateNullValueCheckpointingITCase failed in
test_cron_azure tests
Key: FLINK-38408
URL: https://issues.apache.org/jira/browse/FLINK-38408
Project: Flink
Ruan Hang created FLINK-38407:
-
Summary: GroupAggregateRestoreTest failed in test_cron_azure table
Key: FLINK-38407
URL: https://issues.apache.org/jira/browse/FLINK-38407
Project: Flink
Issue
Ruan Hang created FLINK-38406:
-
Summary: DefaultSchedulerCheckpointCoordinatorTest failed in
test_ci core
Key: FLINK-38406
URL: https://issues.apache.org/jira/browse/FLINK-38406
Project: Flink
Ruan Hang created FLINK-38404:
-
Summary: JobMasterTest failed in test_cron_adaptive_scheduler core
Key: FLINK-38404
URL: https://issues.apache.org/jira/browse/FLINK-38404
Project: Flink
Issue
Ruan Hang created FLINK-38403:
-
Summary: UnalignedCheckpointITCase failed in test_cron_hadoop313
tests
Key: FLINK-38403
URL: https://issues.apache.org/jira/browse/FLINK-38403
Project: Flink
Ruan Hang created FLINK-38402:
-
Summary: EventTimeWindowCheckpointingITCase failed in
test_cron_azure tests
Key: FLINK-38402
URL: https://issues.apache.org/jira/browse/FLINK-38402
Project: Flink
Gustavo de Morais created FLINK-38401:
-
Summary: Add MultiJoin MetadataHandler for FlinkRelMdUpsertKeys
Key: FLINK-38401
URL: https://issues.apache.org/jira/browse/FLINK-38401
Project: Flink
ouyangwulin created FLINK-38398:
---
Summary: Improve postgresSQL field Type supported ‘Temporal types
Mapping’
Key: FLINK-38398
URL: https://issues.apache.org/jira/browse/FLINK-38398
Project: Flink
lincoln lee created FLINK-38400:
---
Summary: STDDEV/VAR function with FILTER condition may cause wrong
result
Key: FLINK-38400
URL: https://issues.apache.org/jira/browse/FLINK-38400
Project: Flink
Xuyang Zhong created FLINK-38399:
Summary: As long as the join key includes one of the indexes from
the source, the join can be converted into a delta join
Key: FLINK-38399
URL: https://issues.apache.org/jira
Ahmad Humayun created FLINK-38397:
-
Summary: Runtime Exception in Planner
Key: FLINK-38397
URL: https://issues.apache.org/jira/browse/FLINK-38397
Project: Flink
Issue Type: Bug
Sergey Nuyanzin created FLINK-38396:
---
Summary: DefaultKubernetesArtifactUploaderTest fails locally
Key: FLINK-38396
URL: https://issues.apache.org/jira/browse/FLINK-38396
Project: Flink
RocMarshal created FLINK-38344:
--
Summary: The local files of the HistoryServer may risk never being
deleted.
Key: FLINK-38344
URL: https://issues.apache.org/jira/browse/FLINK-38344
Project: Flink
Ahmad Humayun created FLINK-38366:
-
Summary: Pyflink planner throws exception in batch mode when there
is no limit on order_by()
Key: FLINK-38366
URL: https://issues.apache.org/jira/browse/FLINK-38366
RocMarshal created FLINK-38341:
--
Summary: Introduce the rescale history configuration option.
Key: FLINK-38341
URL: https://issues.apache.org/jira/browse/FLINK-38341
Project: Flink
Issue Type
Sergio Chong created FLINK-38395:
Summary: Enable/fix the Flink Operator e2e tests for Blue/Green
Deployments
Key: FLINK-38395
URL: https://issues.apache.org/jira/browse/FLINK-38395
Project: Flink
Mohsen Rezaei created FLINK-38394:
-
Summary: Upgrade Flink CDC to Flink 2
Key: FLINK-38394
URL: https://issues.apache.org/jira/browse/FLINK-38394
Project: Flink
Issue Type: Improvement
Xiqian Yu created FLINK-38393:
-
Summary: Pipeline transform schema consistency check should be
loosen for unreachable rules
Key: FLINK-38393
URL: https://issues.apache.org/jira/browse/FLINK-38393
Project
Sergey Nuyanzin created FLINK-38378:
---
Summary: Use ValidationException in CatalogManager in case of user
error
Key: FLINK-38378
URL: https://issues.apache.org/jira/browse/FLINK-38378
Project: Flink
Samrat Deb created FLINK-38392:
--
Summary: StreamPandasConversionTests failing
Key: FLINK-38392
URL: https://issues.apache.org/jira/browse/FLINK-38392
Project: Flink
Issue Type: Bug
Sergey Nuyanzin created FLINK-38391:
---
Summary: Error creating shaded jar: Problem shading JAR
Unsupported class file major version 69
Key: FLINK-38391
URL: https://issues.apache.org/jira/browse/FLINK-38391
Sergey Nuyanzin created FLINK-38390:
---
Summary: Compiliation of flink-core and flink-table-planner fails
because of annotation processors
Key: FLINK-38390
URL: https://issues.apache.org/jira/browse/FLINK-38390
Zander Matheson created FLINK-38389:
---
Summary: Add .show(), .head() and .tail() method to PyFlink Table
API
Key: FLINK-38389
URL: https://issues.apache.org/jira/browse/FLINK-38389
Project: Flink
Zander Matheson created FLINK-38388:
---
Summary: FLIP-541 Umbrella Issue
Key: FLINK-38388
URL: https://issues.apache.org/jira/browse/FLINK-38388
Project: Flink
Issue Type: New Feature
Gustavo de Morais created FLINK-38379:
-
Summary: Adjust visitMultiJoin in RelTimeIndicatorConverter to use
fields and not rows
Key: FLINK-38379
URL: https://issues.apache.org/jira/browse/FLINK-38379
nicolas paris created FLINK-38382:
-
Summary: Confluent Schema Registry to support primitive types
Key: FLINK-38382
URL: https://issues.apache.org/jira/browse/FLINK-38382
Project: Flink
Issue
Sergey Nuyanzin created FLINK-38387:
---
Summary: Bump spotless
Key: FLINK-38387
URL: https://issues.apache.org/jira/browse/FLINK-38387
Project: Flink
Issue Type: Sub-task
Sergey Nuyanzin created FLINK-38385:
---
Summary: Bump byte-buddy to 1.17.6
Key: FLINK-38385
URL: https://issues.apache.org/jira/browse/FLINK-38385
Project: Flink
Issue Type: Sub-task
Sergey Nuyanzin created FLINK-38386:
---
Summary: Cannot attach type annotations
@org.checkerframework.checker.nullness.qual.Nullable
Key: FLINK-38386
URL: https://issues.apache.org/jira/browse/FLINK-38386
Roman Khachatryan created FLINK-38376:
-
Summary: AsyncStateStreamingJoinOperator should not OOM due to
collecting all matching records in memory
Key: FLINK-38376
URL: https://issues.apache.org/jira/browse
Yanquan Lv created FLINK-38380:
--
Summary: MySQL cdc may skip data in the GTID disordered scenario
even after GTID merged
Key: FLINK-38380
URL: https://issues.apache.org/jira/browse/FLINK-38380
Project
Sergey Nuyanzin created FLINK-38384:
---
Summary: Bump lombok to 1.18.40
Key: FLINK-38384
URL: https://issues.apache.org/jira/browse/FLINK-38384
Project: Flink
Issue Type: Sub-task
Jaydeep Karia created FLINK-38383:
-
Summary: Automatically republish Flink Kubernetes Operator image
when base image receives security patches
Key: FLINK-38383
URL: https://issues.apache.org/jira/browse/FLINK
Maximilian Michels created FLINK-38381:
--
Summary: Autoscaler does not enumerate partitions across kafka
clusters
Key: FLINK-38381
URL: https://issues.apache.org/jira/browse/FLINK-38381
Project
yuanfenghu created FLINK-38377:
--
Summary: SQL Job Submission in the Flink Kubernetes Operator via
SQL Gateway
Key: FLINK-38377
URL: https://issues.apache.org/jira/browse/FLINK-38377
Project: Flink
Shangshu Qian created FLINK-38368:
-
Summary: Potential Feedback Loop Involving a Heavy User Defined
Aggregation Task
Key: FLINK-38368
URL: https://issues.apache.org/jira/browse/FLINK-38368
Project
xiaolong3817 created FLINK-38375:
Summary: Flink Resouce leak on Flink k8s
Key: FLINK-38375
URL: https://issues.apache.org/jira/browse/FLINK-38375
Project: Flink
Issue Type: Bug
Xuannan Su created FLINK-38332:
--
Summary: Upgrade pemja to 0.6.1
Key: FLINK-38332
URL: https://issues.apache.org/jira/browse/FLINK-38332
Project: Flink
Issue Type: Bug
Components: API
Zander Matheson created FLINK-38374:
---
Summary: Add Artifact keyword as an option to create function
syntax
Key: FLINK-38374
URL: https://issues.apache.org/jira/browse/FLINK-38374
Project: Flink
RocMarshal created FLINK-38338:
--
Summary: Introduce the abstraction to describe a rescale event.
Key: FLINK-38338
URL: https://issues.apache.org/jira/browse/FLINK-38338
Project: Flink
Issue
Hongshun Wang created FLINK-38335:
-
Summary: SplitEnumeratorContext supports fixed delay async call.
Key: FLINK-38335
URL: https://issues.apache.org/jira/browse/FLINK-38335
Project: Flink
Maximilian Michels created FLINK-38370:
--
Summary: CommitterOperator does not checkpoint all pending
committables
Key: FLINK-38370
URL: https://issues.apache.org/jira/browse/FLINK-38370
Project
Liu created FLINK-38373:
---
Summary: Support dynamic index generation with field value suffix
Key: FLINK-38373
URL: https://issues.apache.org/jira/browse/FLINK-38373
Project: Flink
Issue Type
Liu created FLINK-38372:
---
Summary: Introduces whitelist to the flink-metrics-prometheus
Key: FLINK-38372
URL: https://issues.apache.org/jira/browse/FLINK-38372
Project: Flink
Issue Type: Improvement
Liu created FLINK-38371:
---
Summary: Add `sink.retry-on-conflicts` option to Elasticsearch Sink
Key: FLINK-38371
URL: https://issues.apache.org/jira/browse/FLINK-38371
Project: Flink
Issue Type
Ruan Hang created FLINK-38369:
-
Summary: RestClientTest failed in test_cron_hadoop313 core
Key: FLINK-38369
URL: https://issues.apache.org/jira/browse/FLINK-38369
Project: Flink
Issue Type: Bug
Shangshu Qian created FLINK-38367:
-
Summary: Potential Feedback Loop Between IterationHeadTask and
SynchronizationSinkTask
Key: FLINK-38367
URL: https://issues.apache.org/jira/browse/FLINK-38367
Zakelly Lan created FLINK-38364:
---
Summary: Converter from `ProcessingTimeoutTrigger` with any
nested timer to the async version
Key: FLINK-38364
URL: https://issues.apache.org/jira/browse/FLINK-38364
Sergey Nuyanzin created FLINK-38365:
---
Summary: ClassCastException while different operations with
MATERIALIZED TABLE
Key: FLINK-38365
URL: https://issues.apache.org/jira/browse/FLINK-38365
Project
Zakelly Lan created FLINK-38363:
---
Summary: WindowedStream.trigger supports trigger with async state
Key: FLINK-38363
URL: https://issues.apache.org/jira/browse/FLINK-38363
Project: Flink
Issue
Yanquan Lv created FLINK-38362:
--
Summary: Reduce the time cost in checkpoint when writing many
tables to StarRocks sink
Key: FLINK-38362
URL: https://issues.apache.org/jira/browse/FLINK-38362
Project
Ruan Hang created FLINK-38361:
-
Summary: ChangelogRecoverySwitchStateBackendITCase failed in
test_ci tests
Key: FLINK-38361
URL: https://issues.apache.org/jira/browse/FLINK-38361
Project: Flink
Ruan Hang created FLINK-38360:
-
Summary: HadoopRecoverableWriterTest failed in
test_cron_adaptive_scheduler connect
Key: FLINK-38360
URL: https://issues.apache.org/jira/browse/FLINK-38360
Project: Flink
Yanquan Lv created FLINK-38359:
--
Summary: Avoid writing Record with update before/delete rowKind to
Paimon append only table.
Key: FLINK-38359
URL: https://issues.apache.org/jira/browse/FLINK-38359
Yanquan Lv created FLINK-38358:
--
Summary: Ignore trailing spaces in table capturing rules
Key: FLINK-38358
URL: https://issues.apache.org/jira/browse/FLINK-38358
Project: Flink
Issue Type
Xinglong Wang created FLINK-38357:
-
Summary: ResultSubpartitionRecoveredStateHandler.getSubpartition
ArrayIndexOutOfBoundException 0
Key: FLINK-38357
URL: https://issues.apache.org/jira/browse/FLINK-38357
Dawid Wysakowicz created FLINK-38356:
Summary: Regenerating files for
WATERMARK_ASSIGNER_PUSHDOWN_METADATA hangs
Key: FLINK-38356
URL: https://issues.apache.org/jira/browse/FLINK-38356
Project
Ramin Gharib created FLINK-38355:
Summary: [FLIP-546] Introduce CREATE OR ALTER Syntax for
Materialized Tables
Key: FLINK-38355
URL: https://issues.apache.org/jira/browse/FLINK-38355
Project: Flink
hunter created FLINK-38354:
--
Summary: ClassCastException occurs when submitting a task to flink
cdc
Key: FLINK-38354
URL: https://issues.apache.org/jira/browse/FLINK-38354
Project: Flink
Issue
Piotr Nowojski created FLINK-38353:
--
Summary: FLIP-483: Add support for children Spans
Key: FLINK-38353
URL: https://issues.apache.org/jira/browse/FLINK-38353
Project: Flink
Issue Type: New
Timo Walther created FLINK-38352:
Summary: Expose timestamp used in DefaultWatermarkGenerator
Key: FLINK-38352
URL: https://issues.apache.org/jira/browse/FLINK-38352
Project: Flink
Issue
melin created FLINK-38351:
-
Summary: Docker images support OpenJDK
Key: FLINK-38351
URL: https://issues.apache.org/jira/browse/FLINK-38351
Project: Flink
Issue Type: Improvement
Components
Zakelly Lan created FLINK-38336:
---
Summary: Unexpected data copy during failover for ForSt
statebackend
Key: FLINK-38336
URL: https://issues.apache.org/jira/browse/FLINK-38336
Project: Flink
RocMarshal created FLINK-38340:
--
Summary: Introduce the rescale timeline related abstraction for
performing rescale operations
Key: FLINK-38340
URL: https://issues.apache.org/jira/browse/FLINK-38340
Paul Ashley created FLINK-38350:
---
Summary: Update Hadoop Library to 3.4.2
Key: FLINK-38350
URL: https://issues.apache.org/jira/browse/FLINK-38350
Project: Flink
Issue Type: Improvement
Huny created FLINK-38349:
Summary: Bugs caused by floating-point operations
Key: FLINK-38349
URL: https://issues.apache.org/jira/browse/FLINK-38349
Project: Flink
Issue Type: Bug
Shuo Cheng created FLINK-38348:
--
Summary: Fix flushing issue for append write with buffer sort and
bounded source
Key: FLINK-38348
URL: https://issues.apache.org/jira/browse/FLINK-38348
Project: Flink
Zakelly Lan created FLINK-38347:
---
Summary: Checkpoint file-merging manager may delete the directory
unexpectedly when some RPC messages lost
Key: FLINK-38347
URL: https://issues.apache.org/jira/browse/FLINK-38347
dylanhz created FLINK-38346:
---
Summary: JSON_QUERY returns ARRAY
Key: FLINK-38346
URL: https://issues.apache.org/jira/browse/FLINK-38346
Project: Flink
Issue Type: Bug
Reporter: dylanhz
Matt Cuento created FLINK-38345:
---
Summary: HybridSource checkpoint recovery results in NPE if
addSource depends on previousEnumerator from SourceSwitchContext
Key: FLINK-38345
URL: https://issues.apache.org/jira
RocMarshal created FLINK-38343:
--
Summary: Support store rescale history by ExecutionGraphInfoStore
and query the rescale history with statistics.
Key: FLINK-38343
URL: https://issues.apache.org/jira/browse/FLINK
RocMarshal created FLINK-38342:
--
Summary: Support record rescale information
Key: FLINK-38342
URL: https://issues.apache.org/jira/browse/FLINK-38342
Project: Flink
Issue Type: Sub-task
RocMarshal created FLINK-38339:
--
Summary: Adjust the statistics-related classes for reusing in the
statistical calculations of the rescale history
Key: FLINK-38339
URL: https://issues.apache.org/jira/browse/FLINK
Scott Fauerbach created FLINK-38337:
---
Summary: Chinese translation for document PR
Key: FLINK-38337
URL: https://issues.apache.org/jira/browse/FLINK-38337
Project: Flink
Issue Type
Sergei Morozov created FLINK-38334:
--
Summary: MySQL CDC source may get stuck in the INITIAL_ASSIGNING
state
Key: FLINK-38334
URL: https://issues.apache.org/jira/browse/FLINK-38334
Project: Flink
RocMarshal created FLINK-38333:
--
Summary: UMBRELLA: FLIP-495: Support AdaptiveScheduler record and
query the rescale history
Key: FLINK-38333
URL: https://issues.apache.org/jira/browse/FLINK-38333
yisha zhou created FLINK-38331:
--
Summary: Support displaying the hash keys on edges in web ui
Key: FLINK-38331
URL: https://issues.apache.org/jira/browse/FLINK-38331
Project: Flink
Issue Type
Sergey Nuyanzin created FLINK-38318:
---
Summary: Add python autoformatter to pyflink
Key: FLINK-38318
URL: https://issues.apache.org/jira/browse/FLINK-38318
Project: Flink
Issue Type: Bug
david radley created FLINK-38329:
Summary: Add labels to PRs showing the targeted version
Key: FLINK-38329
URL: https://issues.apache.org/jira/browse/FLINK-38329
Project: Flink
Issue Type
Zakelly Lan created FLINK-38327:
---
Summary: NPE during recovery from file-merged checkpoint after FO
Key: FLINK-38327
URL: https://issues.apache.org/jira/browse/FLINK-38327
Project: Flink
Issue
vikasap created FLINK-38330:
---
Summary: Updating state-size in status increases the number of
409's to K8s
Key: FLINK-38330
URL: https://issues.apache.org/jira/browse/FLINK-38330
Project:
david radley created FLINK-38328:
Summary: Community review acting strangely messages in PRs should
adding and removing labels
Key: FLINK-38328
URL: https://issues.apache.org/jira/browse/FLINK-38328
melin created FLINK-38326:
-
Summary: Kubernetes support oAuthToken authentication
Key: FLINK-38326
URL: https://issues.apache.org/jira/browse/FLINK-38326
Project: Flink
Issue Type: Improvement
Thomas Cooper created FLINK-38322:
-
Summary: Update to Kafka Client 4.1.0
Key: FLINK-38322
URL: https://issues.apache.org/jira/browse/FLINK-38322
Project: Flink
Issue Type: Improvement
Jacky Lau created FLINK-38321:
-
Summary: Optimize the timer registration logic n window early/late
firing scenarios
Key: FLINK-38321
URL: https://issues.apache.org/jira/browse/FLINK-38321
Project: Flink
Lucas Borges created FLINK-38325:
Summary: Checkpoints are hanging and timing out frequently
Key: FLINK-38325
URL: https://issues.apache.org/jira/browse/FLINK-38325
Project: Flink
Issue Type
Lucas Borges created FLINK-38324:
Summary: Job fails to restore keyed state backend when using Forst
state backend on S3
Key: FLINK-38324
URL: https://issues.apache.org/jira/browse/FLINK-38324
Salva created FLINK-38323:
-
Summary: Global Scale Factor Mode
Key: FLINK-38323
URL: https://issues.apache.org/jira/browse/FLINK-38323
Project: Flink
Issue Type: New Feature
Components
Mate Czagany created FLINK-38320:
Summary: Upgrade Pekko to 1.2.0
Key: FLINK-38320
URL: https://issues.apache.org/jira/browse/FLINK-38320
Project: Flink
Issue Type: Technical Debt
Dian Fu created FLINK-38319:
---
Summary: TO_TIMESTAMP_LTZ only accepts literal values in PyFlink
Key: FLINK-38319
URL: https://issues.apache.org/jira/browse/FLINK-38319
Project: Flink
Issue Type
Sergey Nuyanzin created FLINK-38317:
---
Summary: PushCalcPastChangelogNormalizeRule fails in case of
partial push down and trimmed fields
Key: FLINK-38317
URL: https://issues.apache.org/jira/browse/FLINK-38317
Marton Greber created FLINK-38316:
-
Summary: Clarify on some of the names in the source
Key: FLINK-38316
URL: https://issues.apache.org/jira/browse/FLINK-38316
Project: Flink
Issue Type
Ruan Hang created FLINK-38315:
-
Summary: Performance regression since August 21
Key: FLINK-38315
URL: https://issues.apache.org/jira/browse/FLINK-38315
Project: Flink
Issue Type: Bug
1 - 100 of 6793 matches
Mail list logo
