Till Rohrmann created FLINK-26274:
-
Summary: Test local recovery works across TaskManager process
restarts
Key: FLINK-26274
URL: https://issues.apache.org/jira/browse/FLINK-26274
Project: Flink
Till Rohrmann created FLINK-26271:
-
Summary: TaskTest.testCancelTaskExceptionAfterTaskMarkedFailed
Key: FLINK-26271
URL: https://issues.apache.org/jira/browse/FLINK-26271
Project: Flink
Issue
Till Rohrmann created FLINK-26197:
-
Summary: Allow playground egress to keep connection open and push
messages
Key: FLINK-26197
URL: https://issues.apache.org/jira/browse/FLINK-26197
Project: Flink
Till Rohrmann created FLINK-26158:
-
Summary: Update statefun-playground examples to use playground
ingress/egress
Key: FLINK-26158
URL: https://issues.apache.org/jira/browse/FLINK-26158
Project: Flink
Till Rohrmann created FLINK-26155:
-
Summary: Add playground ingress/egress for cURL interaction
Key: FLINK-26155
URL: https://issues.apache.org/jira/browse/FLINK-26155
Project: Flink
Issue Ty
Till Rohrmann created FLINK-26153:
-
Summary: Add script to update README playground links for Statefun
Key: FLINK-26153
URL: https://issues.apache.org/jira/browse/FLINK-26153
Project: Flink
I
Till Rohrmann created FLINK-26098:
-
Summary: TableAPI does not forward idleness configuration from
DataStream
Key: FLINK-26098
URL: https://issues.apache.org/jira/browse/FLINK-26098
Project: Flink
Till Rohrmann created FLINK-26014:
-
Summary: Document how to use the working directory for faster
local recoveries
Key: FLINK-26014
URL: https://issues.apache.org/jira/browse/FLINK-26014
Project: Flin
Till Rohrmann created FLINK-26005:
-
Summary: TableEnvironment.createTemporarySystemFunction cause NPE
when using leftOuterLateralJoin
Key: FLINK-26005
URL: https://issues.apache.org/jira/browse/FLINK-26005
Till Rohrmann created FLINK-26003:
-
Summary: Use Jackson serialization for persisting TaskExecutor
state to working directory
Key: FLINK-26003
URL: https://issues.apache.org/jira/browse/FLINK-26003
Pr
Till Rohrmann created FLINK-25941:
-
Summary:
KafkaSinkITCase.testAbortTransactionsAfterScaleInBeforeFirstCheckpoint fails on
AZP
Key: FLINK-25941
URL: https://issues.apache.org/jira/browse/FLINK-25941
Till Rohrmann created FLINK-25940:
-
Summary:
pyflink/datastream/tests/test_data_stream.py::StreamingModeDataStreamTests::test_keyed_process_function_with_state
failed on AZP
Key: FLINK-25940
URL: https://issues.a
Till Rohrmann created FLINK-25939:
-
Summary: PyFlink YARN per-job on Docker test fails on AZP because
it could not acquire all required slots
Key: FLINK-25939
URL: https://issues.apache.org/jira/browse/FLINK-25939
Till Rohrmann created FLINK-25938:
-
Summary:
SynchronousCheckpointITCase.taskDispatcherThreadPoolAllowsForSynchronousCheckpoints
fails on AZP
Key: FLINK-25938
URL: https://issues.apache.org/jira/browse/FLINK-2593
Till Rohrmann created FLINK-25937:
-
Summary: SQL Client end-to-end test e2e fails on AZP
Key: FLINK-25937
URL: https://issues.apache.org/jira/browse/FLINK-25937
Project: Flink
Issue Type: Bug
Till Rohrmann created FLINK-25925:
-
Summary:
JobMasterTest.testJobMasterAcceptsExcessSlotsWhenJobIsRestarting
Key: FLINK-25925
URL: https://issues.apache.org/jira/browse/FLINK-25925
Project: Flink
Till Rohrmann created FLINK-25922:
-
Summary: KinesisFirehoseSinkITCase hangs on AZP
Key: FLINK-25922
URL: https://issues.apache.org/jira/browse/FLINK-25922
Project: Flink
Issue Type: Bug
Till Rohrmann created FLINK-25899:
-
Summary: Add Java connected components example to
flink-statefun-playground
Key: FLINK-25899
URL: https://issues.apache.org/jira/browse/FLINK-25899
Project: Flink
Till Rohrmann created FLINK-25898:
-
Summary: Add README.md to flink-statefun/statefun-sdk-js
Key: FLINK-25898
URL: https://issues.apache.org/jira/browse/FLINK-25898
Project: Flink
Issue Type:
Till Rohrmann created FLINK-25893:
-
Summary: ResourceManagerServiceImpl's lifecycle can lead to
exceptions
Key: FLINK-25893
URL: https://issues.apache.org/jira/browse/FLINK-25893
Project: Flink
Till Rohrmann created FLINK-25855:
-
Summary: DefaultDeclarativeSlotPool rejects offered slots when the
job is restarting
Key: FLINK-25855
URL: https://issues.apache.org/jira/browse/FLINK-25855
Project
Till Rohrmann created FLINK-25849:
-
Summary: Differentiate TaskManager sessions
Key: FLINK-25849
URL: https://issues.apache.org/jira/browse/FLINK-25849
Project: Flink
Issue Type: Sub-task
Till Rohrmann created FLINK-25831:
-
Summary: ExecutionVertex.getLatestPriorAllocation fails if there
is an unsuccessful restart attempt
Key: FLINK-25831
URL: https://issues.apache.org/jira/browse/FLINK-25831
Till Rohrmann created FLINK-25829:
-
Summary: Do not deploy empty statefun-sdk-js jar
Key: FLINK-25829
URL: https://issues.apache.org/jira/browse/FLINK-25829
Project: Flink
Issue Type: Improve
Till Rohrmann created FLINK-25828:
-
Summary: build_stateful_functions.sh can fail if target contains
source or javadoc jar
Key: FLINK-25828
URL: https://issues.apache.org/jira/browse/FLINK-25828
Proje
Till Rohrmann created FLINK-25819:
-
Summary:
NetworkBufferPoolTest.testIsAvailableOrNotAfterRequestAndRecycleMultiSegments
fails on AZP
Key: FLINK-25819
URL: https://issues.apache.org/jira/browse/FLINK-25819
Till Rohrmann created FLINK-25817:
-
Summary: FLIP-201: Persist local state in working directory
Key: FLINK-25817
URL: https://issues.apache.org/jira/browse/FLINK-25817
Project: Flink
Issue Ty
Till Rohrmann created FLINK-25806:
-
Summary: Remove legacy high availability services
Key: FLINK-25806
URL: https://issues.apache.org/jira/browse/FLINK-25806
Project: Flink
Issue Type: Improv
Till Rohrmann created FLINK-25775:
-
Summary: Document JavaScript SDK
Key: FLINK-25775
URL: https://issues.apache.org/jira/browse/FLINK-25775
Project: Flink
Issue Type: Improvement
C
Till Rohrmann created FLINK-25772:
-
Summary: GCS filessystem fails license checker
Key: FLINK-25772
URL: https://issues.apache.org/jira/browse/FLINK-25772
Project: Flink
Issue Type: Bug
Till Rohrmann created FLINK-25771:
-
Summary: CassandraConnectorITCase.testRetrialAndDropTables fails
on AZP
Key: FLINK-25771
URL: https://issues.apache.org/jira/browse/FLINK-25771
Project: Flink
Till Rohrmann created FLINK-25753:
-
Summary: KafkaTableITCase.testStartFromGroupOffsetsLatest fails on
AZP
Key: FLINK-25753
URL: https://issues.apache.org/jira/browse/FLINK-25753
Project: Flink
Till Rohrmann created FLINK-25749:
-
Summary: YARNSessionFIFOSecuredITCase.testDetachedMode fails on AZP
Key: FLINK-25749
URL: https://issues.apache.org/jira/browse/FLINK-25749
Project: Flink
Till Rohrmann created FLINK-25747:
-
Summary: UdfStreamOperatorCheckpointingITCase hangs on AZP
Key: FLINK-25747
URL: https://issues.apache.org/jira/browse/FLINK-25747
Project: Flink
Issue Typ
Till Rohrmann created FLINK-25709:
-
Summary: GlueSchemaRegistryAvroKinesisITCase fails on AZP
Key: FLINK-25709
URL: https://issues.apache.org/jira/browse/FLINK-25709
Project: Flink
Issue Type
Till Rohrmann created FLINK-25708:
-
Summary: Upgrade Flink dependency to 1.14.3
Key: FLINK-25708
URL: https://issues.apache.org/jira/browse/FLINK-25708
Project: Flink
Issue Type: Improvement
Till Rohrmann created FLINK-25698:
-
Summary: Elasticsearch7DynamicSinkITCase.testWritingDocuments
fails on AZP
Key: FLINK-25698
URL: https://issues.apache.org/jira/browse/FLINK-25698
Project: Flink
Till Rohrmann created FLINK-25691:
-
Summary: ElasticsearchSinkITCase.testElasticsearchSink fails on AZP
Key: FLINK-25691
URL: https://issues.apache.org/jira/browse/FLINK-25691
Project: Flink
Till Rohrmann created FLINK-25675:
-
Summary: UnalignedCheckpointCompatibilityITCase.test hangs on AZP
Key: FLINK-25675
URL: https://issues.apache.org/jira/browse/FLINK-25675
Project: Flink
Is
Till Rohrmann created FLINK-25674:
-
Summary:
CassandraConnectorITCase.testCassandraPojoNoAnnotatedKeyspaceAtLeastOnceSink
fails on AZP
Key: FLINK-25674
URL: https://issues.apache.org/jira/browse/FLINK-25674
Till Rohrmann created FLINK-25673:
-
Summary:
AdaptiveSchedulerITCase.testStopWithSavepointFailOnFirstSavepointSucceedOnSecond
hangs on AZP
Key: FLINK-25673
URL: https://issues.apache.org/jira/browse/FLINK-25673
Till Rohrmann created FLINK-25633:
-
Summary: CPUResourceTest does not work with German Locale
Key: FLINK-25633
URL: https://issues.apache.org/jira/browse/FLINK-25633
Project: Flink
Issue Type
Till Rohrmann created FLINK-25564:
-
Summary:
TaskManagerProcessFailureStreamingRecoveryITCase>AbstractTaskManagerProcessFailureRecoveryTest.testTaskManagerProcessFailure
fails on AZP
Key: FLINK-25564
URL: https:/
Till Rohrmann created FLINK-25554:
-
Summary:
DistributedCacheDfsTest.testSubmittingJobViaRestClusterClient fails on AZP
Key: FLINK-25554
URL: https://issues.apache.org/jira/browse/FLINK-25554
Project:
Till Rohrmann created FLINK-25533:
-
Summary: Preferred AllocationIDs are not respected when fulfilling
pending slot requests
Key: FLINK-25533
URL: https://issues.apache.org/jira/browse/FLINK-25533
Pro
Till Rohrmann created FLINK-25523:
-
Summary: KafkaSourceITCase$KafkaSpecificTests.testTimestamp fails
on AZP
Key: FLINK-25523
URL: https://issues.apache.org/jira/browse/FLINK-25523
Project: Flink
Till Rohrmann created FLINK-25522:
-
Summary:
KafkaShuffleExactlyOnceITCase.testAssignedToPartitionFailureRecoveryProcessingTime
Key: FLINK-25522
URL: https://issues.apache.org/jira/browse/FLINK-25522
Till Rohrmann created FLINK-25469:
-
Summary: FlinkKafkaProducerITCase.testScaleUpAfterScalingDown
fails on AZP
Key: FLINK-25469
URL: https://issues.apache.org/jira/browse/FLINK-25469
Project: Flink
Till Rohrmann created FLINK-25468:
-
Summary: Local recovery fails if local state storage and RocksDB
working directory are not on the same volume
Key: FLINK-25468
URL: https://issues.apache.org/jira/browse/FLINK-2
Till Rohrmann created FLINK-25457:
-
Summary: Read timeouts when downloading from alicloud-mvn-mirror
Key: FLINK-25457
URL: https://issues.apache.org/jira/browse/FLINK-25457
Project: Flink
Is
Till Rohrmann created FLINK-25456:
-
Summary:
FlinkKafkaProducerITCase.testScaleDownBeforeFirstCheckpoint
Key: FLINK-25456
URL: https://issues.apache.org/jira/browse/FLINK-25456
Project: Flink
Till Rohrmann created FLINK-25455:
-
Summary:
FlinkKafkaInternalProducerITCase.testProducerWhenCommitEmptyPartitionsToOutdatedTxnCoordinator
fails on AZP
Key: FLINK-25455
URL: https://issues.apache.org/jira/browse
Till Rohrmann created FLINK-25436:
-
Summary: Allow BlobServer/BlobCache to clean up unused blobs after
recovering from working directory
Key: FLINK-25436
URL: https://issues.apache.org/jira/browse/FLINK-25436
Till Rohrmann created FLINK-25427:
-
Summary: SavepointITCase.testTriggerSavepointAndResumeWithNoClaim
fails on AZP
Key: FLINK-25427
URL: https://issues.apache.org/jira/browse/FLINK-25427
Project: Flin
Till Rohrmann created FLINK-25426:
-
Summary:
UnalignedCheckpointRescaleITCase.shouldRescaleUnalignedCheckpoint fails on AZP
because it cannot allocate enough network buffers
Key: FLINK-25426
URL: https://issues.a
Till Rohrmann created FLINK-25406:
-
Summary: Make sure that FileSystemBlobStore flushes all writes to
disk to persist stored blobs
Key: FLINK-25406
URL: https://issues.apache.org/jira/browse/FLINK-25406
Till Rohrmann created FLINK-25405:
-
Summary: Let BlobServer/BlobCache detect & delete corrupted blobs
Key: FLINK-25405
URL: https://issues.apache.org/jira/browse/FLINK-25405
Project: Flink
Is
Till Rohrmann created FLINK-25404:
-
Summary: Store blobs in /blobs
Key: FLINK-25404
URL: https://issues.apache.org/jira/browse/FLINK-25404
Project: Flink
Issue Type: Sub-task
Compon
Till Rohrmann created FLINK-25403:
-
Summary: Make BlobServer/BlobCache compatible with local working
directories
Key: FLINK-25403
URL: https://issues.apache.org/jira/browse/FLINK-25403
Project: Flink
Till Rohrmann created FLINK-25402:
-
Summary: FLIP-198: Working directory for Flink processes
Key: FLINK-25402
URL: https://issues.apache.org/jira/browse/FLINK-25402
Project: Flink
Issue Type:
Till Rohrmann created FLINK-25399:
-
Summary: AZP fails with exit code 137 when running checkpointing
test cases
Key: FLINK-25399
URL: https://issues.apache.org/jira/browse/FLINK-25399
Project: Flink
Till Rohrmann created FLINK-25381:
-
Summary: JdbcExactlyOnceSinkE2eTest.testInsert fails on AZP
Key: FLINK-25381
URL: https://issues.apache.org/jira/browse/FLINK-25381
Project: Flink
Issue Ty
Till Rohrmann created FLINK-25354:
-
Summary: Document API graduation process
Key: FLINK-25354
URL: https://issues.apache.org/jira/browse/FLINK-25354
Project: Flink
Issue Type: Sub-task
Till Rohrmann created FLINK-25353:
-
Summary: Add tests to ensure API graduation process is honoured
Key: FLINK-25353
URL: https://issues.apache.org/jira/browse/FLINK-25353
Project: Flink
Issu
Till Rohrmann created FLINK-25352:
-
Summary: Update stability annotations to include the since and
missedGraduations fields
Key: FLINK-25352
URL: https://issues.apache.org/jira/browse/FLINK-25352
Proj
Till Rohrmann created FLINK-25351:
-
Summary: Add FlinkVersion
Key: FLINK-25351
URL: https://issues.apache.org/jira/browse/FLINK-25351
Project: Flink
Issue Type: Sub-task
Affects Versions:
Till Rohrmann created FLINK-25350:
-
Summary: Verify stability guarantees of annotated classes
Key: FLINK-25350
URL: https://issues.apache.org/jira/browse/FLINK-25350
Project: Flink
Issue Type
Till Rohrmann created FLINK-25349:
-
Summary: Add test that ensures that parameter/return types have
the same or stronger stability guarantee than method
Key: FLINK-25349
URL: https://issues.apache.org/jira/browse/
Till Rohrmann created FLINK-25348:
-
Summary: Update release guide to reset japicmp exceptions for
every release
Key: FLINK-25348
URL: https://issues.apache.org/jira/browse/FLINK-25348
Project: Flink
Till Rohrmann created FLINK-25346:
-
Summary: FLIP-197: API stability graduation process
Key: FLINK-25346
URL: https://issues.apache.org/jira/browse/FLINK-25346
Project: Flink
Issue Type: Impr
Till Rohrmann created FLINK-25345:
-
Summary: FLIP-196: Source API stability guarantees
Key: FLINK-25345
URL: https://issues.apache.org/jira/browse/FLINK-25345
Project: Flink
Issue Type: Impro
Till Rohrmann created FLINK-25259:
-
Summary: NO_CALLS_TO_VISIBLE_FOR_TESTING_METHODS should take the
package into consideration
Key: FLINK-25259
URL: https://issues.apache.org/jira/browse/FLINK-25259
Till Rohrmann created FLINK-25257:
-
Summary: Make the TaskExecutor not depend on concrete
BlobServiceCache implementation
Key: FLINK-25257
URL: https://issues.apache.org/jira/browse/FLINK-25257
Projec
Till Rohrmann created FLINK-25243:
-
Summary:
Fabric8FlinkKubeClientITCase.testCheckAndUpdateConfigMapConcurrently
Key: FLINK-25243
URL: https://issues.apache.org/jira/browse/FLINK-25243
Project: Flink
Till Rohrmann created FLINK-25233:
-
Summary: UpsertKafkaTableITCase.testAggregate fails on AZP
Key: FLINK-25233
URL: https://issues.apache.org/jira/browse/FLINK-25233
Project: Flink
Issue Typ
Till Rohrmann created FLINK-25223:
-
Summary: ElasticsearchWriterITCase fails on AZP
Key: FLINK-25223
URL: https://issues.apache.org/jira/browse/FLINK-25223
Project: Flink
Issue Type: Bug
Till Rohrmann created FLINK-25214:
-
Summary:
FlinkKafkaProducerITCase.testMigrateFromAtLeastOnceToExactlyOnce fails on AZP
with incorrect result
Key: FLINK-25214
URL: https://issues.apache.org/jira/browse/FLINK-2
Till Rohrmann created FLINK-25186:
-
Summary: KafkaDynamicTableFactoryTest and
UpsertKafkaDynamicTableFactoryTest fails on AZP
Key: FLINK-25186
URL: https://issues.apache.org/jira/browse/FLINK-25186
P
Till Rohrmann created FLINK-25185:
-
Summary: StreamFaultToleranceTestBase hangs on AZP
Key: FLINK-25185
URL: https://issues.apache.org/jira/browse/FLINK-25185
Project: Flink
Issue Type: Bug
Till Rohrmann created FLINK-25181:
-
Summary: KafkaSourceITCase.testValueOnlyDeserializer fails on AZP
Key: FLINK-25181
URL: https://issues.apache.org/jira/browse/FLINK-25181
Project: Flink
Is
Till Rohrmann created FLINK-25180:
-
Summary: Jepsen test fails while setting up libzip4
Key: FLINK-25180
URL: https://issues.apache.org/jira/browse/FLINK-25180
Project: Flink
Issue Type: Bug
Till Rohrmann created FLINK-25069:
-
Summary:
YARNHighAvailabilityITCase.testJobRecoversAfterKillingTaskManager failed on AZP
Key: FLINK-25069
URL: https://issues.apache.org/jira/browse/FLINK-25069
Pro
Till Rohrmann created FLINK-25053:
-
Summary: Document how to use the usrlib to load code in the user
code class loader
Key: FLINK-25053
URL: https://issues.apache.org/jira/browse/FLINK-25053
Project:
Till Rohrmann created FLINK-25040:
-
Summary: FlinkKafkaInternalProducerITCase.testInitTransactionId
failed on AZP
Key: FLINK-25040
URL: https://issues.apache.org/jira/browse/FLINK-25040
Project: Flink
Till Rohrmann created FLINK-25039:
-
Summary: AZP fails with license check
Key: FLINK-25039
URL: https://issues.apache.org/jira/browse/FLINK-25039
Project: Flink
Issue Type: Bug
Comp
Till Rohrmann created FLINK-25037:
-
Summary: Compilation of compile_cron_python_wheels failed on AZP
Key: FLINK-25037
URL: https://issues.apache.org/jira/browse/FLINK-25037
Project: Flink
Iss
Till Rohrmann created FLINK-25026:
-
Summary:
UnalignedCheckpointRescaleITCase.shouldRescaleUnalignedCheckpoint fails on AZP
Key: FLINK-25026
URL: https://issues.apache.org/jira/browse/FLINK-25026
Proj
Till Rohrmann created FLINK-25025:
-
Summary:
BatchArrowPythonGroupWindowAggregateFunctionOperatorTest.testFinishBundleTriggeredByCount
failed on AZP
Key: FLINK-25025
URL: https://issues.apache.org/jira/browse/FLI
Till Rohrmann created FLINK-24872:
-
Summary: PulsarSourceITCase.testMultipleSplits failed on AZP
Key: FLINK-24872
URL: https://issues.apache.org/jira/browse/FLINK-24872
Project: Flink
Issue T
Till Rohrmann created FLINK-24867:
-
Summary: E2e tests take longer than the maximum 310 minutes on AZP
Key: FLINK-24867
URL: https://issues.apache.org/jira/browse/FLINK-24867
Project: Flink
I
Till Rohrmann created FLINK-24866:
-
Summary: AZP crashed in Post-job: Cache Maven local repo
Key: FLINK-24866
URL: https://issues.apache.org/jira/browse/FLINK-24866
Project: Flink
Issue Type:
Till Rohrmann created FLINK-24844:
-
Summary: CassandraConnectorITCase.testCassandraBatchPojoFormat
fails on AZP
Key: FLINK-24844
URL: https://issues.apache.org/jira/browse/FLINK-24844
Project: Flink
Till Rohrmann created FLINK-24841:
-
Summary: ChainOrderTest.testMigrationAndRestore fails on AZP
Key: FLINK-24841
URL: https://issues.apache.org/jira/browse/FLINK-24841
Project: Flink
Issue T
Till Rohrmann created FLINK-24840:
-
Summary: JobManagerHAProcessFailureRecoveryITCase crashed on AZP
Key: FLINK-24840
URL: https://issues.apache.org/jira/browse/FLINK-24840
Project: Flink
Iss
Till Rohrmann created FLINK-24839:
-
Summary: CsvFilesystemStreamSinkITCase.testPart times out on AZP
Key: FLINK-24839
URL: https://issues.apache.org/jira/browse/FLINK-24839
Project: Flink
Iss
Till Rohrmann created FLINK-24821:
-
Summary:
FlinkKafkaProducerMigrationOperatorTest.testRestoreProducer fails on AZP
Key: FLINK-24821
URL: https://issues.apache.org/jira/browse/FLINK-24821
Project: F
Till Rohrmann created FLINK-24795:
-
Summary: FlinkKafkaProducerITCase.testRunOutOfProducersInThePool
times out on AZP
Key: FLINK-24795
URL: https://issues.apache.org/jira/browse/FLINK-24795
Project: F
Till Rohrmann created FLINK-24794:
-
Summary: pyflink/datastream/tests/test_data_stream.py fails on AZP
Key: FLINK-24794
URL: https://issues.apache.org/jira/browse/FLINK-24794
Project: Flink
I
Till Rohrmann created FLINK-24793:
-
Summary: DefaultSchedulerLocalRecoveryITCase fails on AZP
Key: FLINK-24793
URL: https://issues.apache.org/jira/browse/FLINK-24793
Project: Flink
Issue Type
Till Rohrmann created FLINK-24792:
-
Summary: OperatorCoordinatorSchedulerTest crashed JVM on AZP
Key: FLINK-24792
URL: https://issues.apache.org/jira/browse/FLINK-24792
Project: Flink
Issue T
1 - 100 of 1506 matches
Mail list logo