Cyrille Chépélov created FLINK-13097:
Summary: Buffer depletion in SimpleCollectingOutputView throws
non-obvious EOFException
Key: FLINK-13097
URL: https://issues.apache.org/jira/browse/FLINK-13097
François Lacombe created FLINK-13536:
Summary: Improve nullability handling in Types
Key: FLINK-13536
URL: https://issues.apache.org/jira/browse/FLINK-13536
Project: Flink
Issue Type
François Lacombe created FLINK-13538:
Summary: Give field names in deserializers thrown exceptions
Key: FLINK-13538
URL: https://issues.apache.org/jira/browse/FLINK-13538
Project: Flink
Gaël Renoux created FLINK-13586:
---
Summary: Method ClosureCleaner.clean broke backward compatibility
between 1.8.0 and 1.8.1
Key: FLINK-13586
URL: https://issues.apache.org/jira/browse/FLINK-13586
Kerem Ulutaş created FLINK-13721:
Summary: BroadcastState should support StateTTL
Key: FLINK-13721
URL: https://issues.apache.org/jira/browse/FLINK-13721
Project: Flink
Issue Type
François Lacombe created FLINK-13836:
Summary: Improve support of java.util.UUID for JDBCTypeUtil
Key: FLINK-13836
URL: https://issues.apache.org/jira/browse/FLINK-13836
Project: Flink
Jan Lukavský created FLINK-13925:
Summary: ClassLoader in BlobLibraryCacheManager is not using
context class loader
Key: FLINK-13925
URL: https://issues.apache.org/jira/browse/FLINK-13925
Project
Elise Ramé created FLINK-13945:
--
Summary: Vendor-repos Maven profile doesn't exist in flink-shaded
Key: FLINK-13945
URL: https://issues.apache.org/jira/browse/FLINK-13945
Project: Flink
David Morávek created FLINK-31935:
-
Summary: The new resource requirements REST API is only available
for session clusters
Key: FLINK-31935
URL: https://issues.apache.org/jira/browse/FLINK-31935
David Morávek created FLINK-31954:
-
Summary: Prevent Mockito for the new code with Checkstyle
Key: FLINK-31954
URL: https://issues.apache.org/jira/browse/FLINK-31954
Project: Flink
Issue
David Morávek created FLINK-31955:
-
Summary: Prevent JUnit 4 usage for the new code with Checkstyle
Key: FLINK-31955
URL: https://issues.apache.org/jira/browse/FLINK-31955
Project: Flink
David Morávek created FLINK-31996:
-
Summary: Chaining operators with different max parallelism
prevents rescaling
Key: FLINK-31996
URL: https://issues.apache.org/jira/browse/FLINK-31996
Project
David Morávek created FLINK-32000:
-
Summary: Expose vertex max parallelism in the WebUI
Key: FLINK-32000
URL: https://issues.apache.org/jira/browse/FLINK-32000
Project: Flink
Issue Type
David Morávek created FLINK-32006:
-
Summary:
AsyncWaitOperatorTest.testProcessingTimeWithTimeoutFunctionOrderedWithRetry
times out on Azure
Key: FLINK-32006
URL: https://issues.apache.org/jira/browse/FLINK-32006
David Morávek created FLINK-32010:
-
Summary: KubernetesLeaderRetrievalDriver always waits for lease
update to resolve leadership
Key: FLINK-32010
URL: https://issues.apache.org/jira/browse/FLINK-32010
Michał Fijołek created FLINK-32160:
--
Summary: CompactOperator cannot continue from checkpoint because
of java.util.NoSuchElementException
Key: FLINK-32160
URL: https://issues.apache.org/jira/browse/FLINK-32160
João Boto created FLINK-32228:
-
Summary: Bump testcontainers
Key: FLINK-32228
URL: https://issues.apache.org/jira/browse/FLINK-32228
Project: Flink
Issue Type: Improvement
Components
Luís Costa created FLINK-32318:
--
Summary: [flink-operator] missing s3 plugin in folder plugins
Key: FLINK-32318
URL: https://issues.apache.org/jira/browse/FLINK-32318
Project: Flink
Issue Type
João Boto created FLINK-32376:
-
Summary: [FLIP-287] Extend Sink#InitContext to expose
TypeSerializer, ObjectReuse and JobID
Key: FLINK-32376
URL: https://issues.apache.org/jira/browse/FLINK-32376
Project
原来你是小幸运001 created FLINK-32540:
--
Summary: The issue of not distributing the last batch of data
Key: FLINK-32540
URL: https://issues.apache.org/jira/browse/FLINK-32540
Project: Flink
Issue Type
宇宙先生 created FLINK-32567:
Summary: when Flink write azure data lake storage,error occur
Key: FLINK-32567
URL: https://issues.apache.org/jira/browse/FLINK-32567
Project: Flink
Issue Type: Bug
张一帆 created FLINK-32627:
---
Summary: Add support for dynamic time window function
Key: FLINK-32627
URL: https://issues.apache.org/jira/browse/FLINK-32627
Project: Flink
Issue Type: Improvement
张一帆 created FLINK-32629:
---
Summary: Add support for dynamic CEP
Key: FLINK-32629
URL: https://issues.apache.org/jira/browse/FLINK-32629
Project: Flink
Issue Type: New Feature
Components
李精卫 created FLINK-32650:
---
Summary: Added the ability to split flink-protobuf codegen code
Key: FLINK-32650
URL: https://issues.apache.org/jira/browse/FLINK-32650
Project: Flink
Issue Type: Improvement
王江洲 created FLINK-32812:
---
Summary: HBaseRowDataLookupFunction HTable instantiation of thread
safety problems
Key: FLINK-32812
URL: https://issues.apache.org/jira/browse/FLINK-32812
Project: Flink
王茂军 created FLINK-32961:
---
Summary: A new FileSystemFactory that support two high available
hdfs
Key: FLINK-32961
URL: https://issues.apache.org/jira/browse/FLINK-32961
Project: Flink
Issue Type
Maciej Bryński created FLINK-33163:
--
Summary: Support Java 21 (LTS)
Key: FLINK-33163
URL: https://issues.apache.org/jira/browse/FLINK-33163
Project: Flink
Issue Type: Bug
Lauri Suurväli created FLINK-33231:
--
Summary: Memory leak in KafkaSourceReader if no data in consumed
topic
Key: FLINK-33231
URL: https://issues.apache.org/jira/browse/FLINK-33231
Project: Flink
蔡灿材 created FLINK-33357:
---
Summary: add Apache Software License 2
Key: FLINK-33357
URL: https://issues.apache.org/jira/browse/FLINK-33357
Project: Flink
Issue Type: Improvement
Components
João Boto created FLINK-33378:
-
Summary: Bump flink version on flink-connectors-jdbc
Key: FLINK-33378
URL: https://issues.apache.org/jira/browse/FLINK-33378
Project: Flink
Issue Type
蔡灿材 created FLINK-33393:
---
Summary: flink document description error
Key: FLINK-33393
URL: https://issues.apache.org/jira/browse/FLINK-33393
Project: Flink
Issue Type: Improvement
Components
Márton Balassi created FLINK-33528:
--
Summary: Externalize Python connector code
Key: FLINK-33528
URL: https://issues.apache.org/jira/browse/FLINK-33528
Project: Flink
Issue Type: Technical
Márton Balassi created FLINK-33556:
--
Summary: Test infrastructure for externalized python code
Key: FLINK-33556
URL: https://issues.apache.org/jira/browse/FLINK-33556
Project: Flink
Issue
Márton Balassi created FLINK-33557:
--
Summary: Externalize Cassandra Python connector code
Key: FLINK-33557
URL: https://issues.apache.org/jira/browse/FLINK-33557
Project: Flink
Issue Type
Márton Balassi created FLINK-33558:
--
Summary: Externalize Elasticsearch Python connector code
Key: FLINK-33558
URL: https://issues.apache.org/jira/browse/FLINK-33558
Project: Flink
Issue
Márton Balassi created FLINK-33559:
--
Summary: Externalize Kafka Python connector code
Key: FLINK-33559
URL: https://issues.apache.org/jira/browse/FLINK-33559
Project: Flink
Issue Type: Sub
Márton Balassi created FLINK-33560:
--
Summary: Externalize Kinesis Python connector code
Key: FLINK-33560
URL: https://issues.apache.org/jira/browse/FLINK-33560
Project: Flink
Issue Type
Márton Balassi created FLINK-33561:
--
Summary: Externalize Pulsar Python connector code
Key: FLINK-33561
URL: https://issues.apache.org/jira/browse/FLINK-33561
Project: Flink
Issue Type: Sub
Márton Balassi created FLINK-33562:
--
Summary: Externalize RabbitMQ Python connector code
Key: FLINK-33562
URL: https://issues.apache.org/jira/browse/FLINK-33562
Project: Flink
Issue Type
Grzegorz Kołakowski created FLINK-33722:
---
Summary: MATCH_RECOGNIZE in batch mode ignores events order
Key: FLINK-33722
URL: https://issues.apache.org/jira/browse/FLINK-33722
Project: Flink
Rafał Trójczak created FLINK-33729:
--
Summary: Events are getting lost when an exception occurs within a
processing function
Key: FLINK-33729
URL: https://issues.apache.org/jira/browse/FLINK-33729
Alek Łańduch created FLINK-33955:
Summary: UnsupportedFileSystemException when trying to save data
to Azure's abfss File System
Key: FLINK-33955
URL: https://issues.apache.org/jira/browse/FLINK-
David Morávek created FLINK-33976:
-
Summary: AdaptiveScheduler cooldown period is taken from a wrong
configuration
Key: FLINK-33976
URL: https://issues.apache.org/jira/browse/FLINK-33976
Project
Ismaël Mejía created FLINK-16260:
Summary: Add Java 11 based version of the docker images
Key: FLINK-16260
URL: https://issues.apache.org/jira/browse/FLINK-16260
Project: Flink
Issue Type
Jürgen Kreileder created FLINK-16262:
Summary: Class loader problem with
FlinkKafkaProducer.Semantic.EXACTLY_ONCE and usrlib directory
Key: FLINK-16262
URL: https://issues.apache.org/jira/browse/FLINK-16262
Benoît Paris created FLINK-16277:
Summary: StreamTableEnvironment.toAppendStream fails with Decimal
types
Key: FLINK-16277
URL: https://issues.apache.org/jira/browse/FLINK-16277
Project: Flink
João Boto created FLINK-16447:
-
Summary: Non serializable field on CompressWriterFactory
Key: FLINK-16447
URL: https://issues.apache.org/jira/browse/FLINK-16447
Project: Flink
Issue Type: Bug
Angel Barragán created FLINK-16544:
--
Summary: Flink FileSystem for web.uploadDir
Key: FLINK-16544
URL: https://issues.apache.org/jira/browse/FLINK-16544
Project: Flink
Issue Type
李开青 created FLINK-16580:
---
Summary: flink-connector-kafka desrializer
Key: FLINK-16580
URL: https://issues.apache.org/jira/browse/FLINK-16580
Project: Flink
Issue Type: Wish
Components
Felix Wollschläger created FLINK-16596:
--
Summary: Support Enum-Values as part of a Key
Key: FLINK-16596
URL: https://issues.apache.org/jira/browse/FLINK-16596
Project: Flink
Issue Type
王太阳 created FLINK-16651:
---
Summary: flink stream SQL INNER JOIN乱序
Key: FLINK-16651
URL: https://issues.apache.org/jira/browse/FLINK-16651
Project: Flink
Issue Type: Bug
Reporter: 王太阳
Ismaël Mejía created FLINK-16846:
Summary: Add docker images with python
Key: FLINK-16846
URL: https://issues.apache.org/jira/browse/FLINK-16846
Project: Flink
Issue Type: Improvement
辛羿彤 created FLINK-16907:
---
Summary: did not react to cancelling signal for 30 seconds, but is
stuck in method:
Key: FLINK-16907
URL: https://issues.apache.org/jira/browse/FLINK-16907
Project: Flink
João Boto created FLINK-17259:
-
Summary: Have scala 2.12 support
Key: FLINK-17259
URL: https://issues.apache.org/jira/browse/FLINK-17259
Project: Flink
Issue Type: Improvement
Ismaël Mejía created FLINK-17324:
Summary: Move the image we use to generate the flink-docker image
into flink-docker
Key: FLINK-17324
URL: https://issues.apache.org/jira/browse/FLINK-17324
Project
Benoît Paris created FLINK-14173:
Summary: ANSI-style JOIN with Temporal Table Function fails
Key: FLINK-14173
URL: https://issues.apache.org/jira/browse/FLINK-14173
Project: Flink
Issue
Benoît Paris created FLINK-14200:
Summary: Temporal Table Function Joins do not work on Tables (only
TableSources) on the query side
Key: FLINK-14200
URL: https://issues.apache.org/jira/browse/FLINK-14200
Benoît Paris created FLINK-14297:
Summary: Temporal Table Function Build Side does not accept a
constant key
Key: FLINK-14297
URL: https://issues.apache.org/jira/browse/FLINK-14297
Project: Flink
Dominik Wosiński created FLINK-14617:
Summary: Dataset Parquet ClassCastException for SpecificRecord
Key: FLINK-14617
URL: https://issues.apache.org/jira/browse/FLINK-14617
Project: Flink
Michaël Melchiore created FLINK-14954:
-
Summary: Consider providing an official OpenAPI specification of
REST Monitoring API
Key: FLINK-14954
URL: https://issues.apache.org/jira/browse/FLINK-14954
César Soto Valero created FLINK-15016:
-
Summary: Remove unused dependency
Key: FLINK-15016
URL: https://issues.apache.org/jira/browse/FLINK-15016
Project: Flink
Issue Type: Improvement
巫旭阳 created FLINK-15357:
---
Summary: schema created by JsonRowSchemaConverter are not suitable
for TableEnv.sqlQuery table schema
Key: FLINK-15357
URL: https://issues.apache.org/jira/browse/FLINK-15357
Project
Jörn Kottmann created FLINK-15438:
-
Summary: Counter metrics are incorrectly reported as total counts
to DataDog
Key: FLINK-15438
URL: https://issues.apache.org/jira/browse/FLINK-15438
Project: Flink
Benoît Paris created FLINK-15584:
Summary: Give nested data type of ROWs in ValidationException
Key: FLINK-15584
URL: https://issues.apache.org/jira/browse/FLINK-15584
Project: Flink
Issue
Jürgen Kreileder created FLINK-15634:
Summary: disableAutoGeneratedUIDs fails with coGroup and join
Key: FLINK-15634
URL: https://issues.apache.org/jira/browse/FLINK-15634
Project: Flink
Benoît Paris created FLINK-15726:
Summary: Fixing error message in StreamExecTableSourceScan
Key: FLINK-15726
URL: https://issues.apache.org/jira/browse/FLINK-15726
Project: Flink
Issue Type
Benoît Paris created FLINK-15775:
Summary: SourceFunctions are instanciated twice when pulled on
from 2 Sinks
Key: FLINK-15775
URL: https://issues.apache.org/jira/browse/FLINK-15775
Project: Flink
Ismaël Mejía created FLINK-15808:
Summary: Upgrade Parquet to version 1.11.0
Key: FLINK-15808
URL: https://issues.apache.org/jira/browse/FLINK-15808
Project: Flink
Issue Type: Improvement
Jörn Kottmann created FLINK-15841:
-
Summary: TimeWindow.intersects return true for consecutive windows
Key: FLINK-15841
URL: https://issues.apache.org/jira/browse/FLINK-15841
Project: Flink
Ismaël Mejía created FLINK-15844:
Summary: Removal of JobWithJars.buildUserCodeClassLoader method
without Configuration breaks backwards compatibility
Key: FLINK-15844
URL: https://issues.apache.org/jira/browse
Benoît Paris created FLINK-15867:
Summary: LAST_VALUE aggregate function does not support
time-related types
Key: FLINK-15867
URL: https://issues.apache.org/jira/browse/FLINK-15867
Project: Flink
Dominik Wosiński created FLINK-9557:
---
Summary: FlinkTypeFactory should support BigInteger type
Key: FLINK-9557
URL: https://issues.apache.org/jira/browse/FLINK-9557
Project: Flink
Issue
Dominik Wosiński created FLINK-9570:
---
Summary: SQL Client merging environments uses AbstractMap
Key: FLINK-9570
URL: https://issues.apache.org/jira/browse/FLINK-9570
Project: Flink
Issue
Dominik Wosiński created FLINK-9575:
---
Summary: Potential race condition when removing JobGraph in HA
Key: FLINK-9575
URL: https://issues.apache.org/jira/browse/FLINK-9575
Project: Flink
Dominik Wosiński created FLINK-9615:
---
Summary: Add
Key: FLINK-9615
URL: https://issues.apache.org/jira/browse/FLINK-9615
Project: Flink
Issue Type: Improvement
Reporter
Dominik Wosiński created FLINK-9627:
---
Summary: Extending
Key: FLINK-9627
URL: https://issues.apache.org/jira/browse/FLINK-9627
Project: Flink
Issue Type: Bug
Reporter: Dominik
Lorenz Bühmann created FLINK-9772:
-
Summary: Documentation of Hadoop API outdated
Key: FLINK-9772
URL: https://issues.apache.org/jira/browse/FLINK-9772
Project: Flink
Issue Type: Bug
陈梓立 created FLINK-9778:
--
Summary: Remove SlotRequest timeout
Key: FLINK-9778
URL: https://issues.apache.org/jira/browse/FLINK-9778
Project: Flink
Issue Type: Improvement
Components
陈梓立 created FLINK-9779:
--
Summary: Remove SlotRequest timeout
Key: FLINK-9779
URL: https://issues.apache.org/jira/browse/FLINK-9779
Project: Flink
Issue Type: Improvement
Components
François Lacombe created FLINK-9813:
---
Summary: Build xTableSource from Avro schemas
Key: FLINK-9813
URL: https://issues.apache.org/jira/browse/FLINK-9813
Project: Flink
Issue Type: Wish
François Lacombe created FLINK-9814:
---
Summary: CsvTableSource lack of column warning
Key: FLINK-9814
URL: https://issues.apache.org/jira/browse/FLINK-9814
Project: Flink
Issue Type: Wish
陈梓立 created FLINK-9859:
--
Summary: Distinguish TM akka config with JM config
Key: FLINK-9859
URL: https://issues.apache.org/jira/browse/FLINK-9859
Project: Flink
Issue Type: Improvement
陈梓立 created FLINK-9869:
--
Summary: Send PartitionInfo in batch to Improve perfornance
Key: FLINK-9869
URL: https://issues.apache.org/jira/browse/FLINK-9869
Project: Flink
Issue Type: Improvement
陈梓立 created FLINK-9875:
--
Summary: Add concurrent creation of execution job vertex
Key: FLINK-9875
URL: https://issues.apache.org/jira/browse/FLINK-9875
Project: Flink
Issue Type: Improvement
陈梓立 created FLINK-9894:
--
Summary: Potential Data Race
Key: FLINK-9894
URL: https://issues.apache.org/jira/browse/FLINK-9894
Project: Flink
Issue Type: Improvement
Components: Local Runtime
陈梓立 created FLINK-10038:
---
Summary: Parallel the creation of InputSplit if necessary
Key: FLINK-10038
URL: https://issues.apache.org/jira/browse/FLINK-10038
Project: Flink
Issue Type: Improvement
陈梓立 created FLINK-10056:
---
Summary: Add testRequestNextInputSplit
Key: FLINK-10056
URL: https://issues.apache.org/jira/browse/FLINK-10056
Project: Flink
Issue Type: Improvement
Components
陈梓立 created FLINK-10099:
---
Summary: Rework YarnResourceManagerTest
Key: FLINK-10099
URL: https://issues.apache.org/jira/browse/FLINK-10099
Project: Flink
Issue Type: Improvement
Components
陈梓立 created FLINK-10256:
---
Summary: Rework JobManagerFailsITCase and JobManagerTest into
JobMasterITCase and JobMasterHAITCase
Key: FLINK-10256
URL: https://issues.apache.org/jira/browse/FLINK-10256
Project
陈梓立 created FLINK-10275:
---
Summary: StreamTask support object reuse
Key: FLINK-10275
URL: https://issues.apache.org/jira/browse/FLINK-10275
Project: Flink
Issue Type: Improvement
Components
陈梓立 created FLINK-10302:
---
Summary: Mark legacy(non-flip 6) code as Deprecated
Key: FLINK-10302
URL: https://issues.apache.org/jira/browse/FLINK-10302
Project: Flink
Issue Type: Improvement
陈梓立 created FLINK-10304:
---
Summary: Remove deprecated AbstractYarnClusterDescriptor field
Key: FLINK-10304
URL: https://issues.apache.org/jira/browse/FLINK-10304
Project: Flink
Issue Type: Improvement
François Lacombe created FLINK-10315:
Summary: Let JDBCAppendTableSink be built with java.sql.Connection
Key: FLINK-10315
URL: https://issues.apache.org/jira/browse/FLINK-10315
Project: Flink
陈梓立 created FLINK-10319:
---
Summary: Avoid requestPartitionState from JM but always try
retrigger
Key: FLINK-10319
URL: https://issues.apache.org/jira/browse/FLINK-10319
Project: Flink
Issue Type
陈梓立 created FLINK-10320:
---
Summary: Introduce JobMaster schedule micro-benchmark
Key: FLINK-10320
URL: https://issues.apache.org/jira/browse/FLINK-10320
Project: Flink
Issue Type: Improvement
陈梓立 created FLINK-10349:
---
Summary: Unify stopActor* utils
Key: FLINK-10349
URL: https://issues.apache.org/jira/browse/FLINK-10349
Project: Flink
Issue Type: Improvement
Components: Core
陈梓立 created FLINK-10378:
---
Summary: Hide/Comment out contribute guide from
PULL_REQUEST_TEMPLATE
Key: FLINK-10378
URL: https://issues.apache.org/jira/browse/FLINK-10378
Project: Flink
Issue Type
陈梓立 created FLINK-10385:
---
Summary: Implement a waitUntilCondition utils
Key: FLINK-10385
URL: https://issues.apache.org/jira/browse/FLINK-10385
Project: Flink
Issue Type: Improvement
陈梓立 created FLINK-10386:
---
Summary: Remove legacy class TaskExecutionStateListener
Key: FLINK-10386
URL: https://issues.apache.org/jira/browse/FLINK-10386
Project: Flink
Issue Type: Improvement
Dominik Wosiński created FLINK-10424:
Summary: Inconsistency between JsonSchemaConveerter and
FlinkTypeFactory
Key: FLINK-10424
URL: https://issues.apache.org/jira/browse/FLINK-10424
Project
1 - 100 of 32170 matches
Mail list logo
