Yun Gao created FLINK-30906:
---
Summary: TwoInputStreamTask passes wrong configuration object when
creating input processor
Key: FLINK-30906
URL: https://issues.apache.org/jira/browse/FLINK-30906
Project: Fli
Yun Gao created FLINK-30877:
---
Summary: Add support for @Before / @After for JUnit 4 and 5
Key: FLINK-30877
URL: https://issues.apache.org/jira/browse/FLINK-30877
Project: Flink
Issue Type: Sub-task
Yun Gao created FLINK-29462:
---
Summary: LookupJoinITCase failed on azure due to classloader
leaking
Key: FLINK-29462
URL: https://issues.apache.org/jira/browse/FLINK-29462
Project: Flink
Issue Type
Yun Gao created FLINK-29459:
---
Summary: Sink v2 has bugs in supporting legacy v1 implementations
with global committer
Key: FLINK-29459
URL: https://issues.apache.org/jira/browse/FLINK-29459
Project: Flink
Yun Gao created FLINK-28871:
---
Summary: Make DPP also works if batch shuffle mode is not
ALL_BLOCKING
Key: FLINK-28871
URL: https://issues.apache.org/jira/browse/FLINK-28871
Project: Flink
Issue Ty
Yun Gao created FLINK-28824:
---
Summary:
StreamingJobGraphGenerator#triggerSerializationAndReturnFuture might swallow
exception
Key: FLINK-28824
URL: https://issues.apache.org/jira/browse/FLINK-28824
Projec
Yun Gao created FLINK-28386:
---
Summary: Trigger an immediate checkpoint after all sources finished
Key: FLINK-28386
URL: https://issues.apache.org/jira/browse/FLINK-28386
Project: Flink
Issue Type:
Yun Gao created FLINK-27910:
---
Summary: FileSink not registered the timer to enforce rolling
policy if started from scratch
Key: FLINK-27910
URL: https://issues.apache.org/jira/browse/FLINK-27910
Project: Fl
Yun Gao created FLINK-27518:
---
Summary: Refactor migration tests to support generate snapshots of
new version automatically
Key: FLINK-27518
URL: https://issues.apache.org/jira/browse/FLINK-27518
Project: Fl
Yun Gao created FLINK-27492:
---
Summary: Flink table / sql scala API is missing in the binary
package
Key: FLINK-27492
URL: https://issues.apache.org/jira/browse/FLINK-27492
Project: Flink
Issue Typ
Yun Gao created FLINK-27413:
---
Summary: Drop scala 2.11 support from the flink-docker
Key: FLINK-27413
URL: https://issues.apache.org/jira/browse/FLINK-27413
Project: Flink
Issue Type: Bug
Yun Gao created FLINK-27341:
---
Summary: TaskManager running together with JobManager are bind to
127.0.0.1
Key: FLINK-27341
URL: https://issues.apache.org/jira/browse/FLINK-27341
Project: Flink
Iss
Yun Gao created FLINK-27285:
---
Summary: CassandraConnectorITCase failed on azure due to
NoHostAvailableException
Key: FLINK-27285
URL: https://issues.apache.org/jira/browse/FLINK-27285
Project: Flink
Yun Gao created FLINK-27284:
---
Summary: KafkaSinkITCase$IntegrationTests.testScaleUp failed on
azures due to failed to create topic
Key: FLINK-27284
URL: https://issues.apache.org/jira/browse/FLINK-27284
Pro
Yun Gao created FLINK-27219:
---
Summary: CliClientITCase.testSqlStatements failed on azure with
jdk11
Key: FLINK-27219
URL: https://issues.apache.org/jira/browse/FLINK-27219
Project: Flink
Issue Typ
Yun Gao created FLINK-27216:
---
Summary: CheckpointCoordinatorTest.testMinCheckpointPause failed
on azure
Key: FLINK-27216
URL: https://issues.apache.org/jira/browse/FLINK-27216
Project: Flink
Issue
Yun Gao created FLINK-27169:
---
Summary: PartiallyFinishedSourcesITCase.test hangs on azure
Key: FLINK-27169
URL: https://issues.apache.org/jira/browse/FLINK-27169
Project: Flink
Issue Type: Bug
Yun Gao created FLINK-27167:
---
Summary: Deploying master snapshot failed due to generating
javadoc failed
Key: FLINK-27167
URL: https://issues.apache.org/jira/browse/FLINK-27167
Project: Flink
Issu
Yun Gao created FLINK-27164:
---
Summary:
ResumeCheckpointManuallyITCase.testExternalizedFSCheckpointsWithLocalRecoveryZookeeper
failed on azure
Key: FLINK-27164
URL: https://issues.apache.org/jira/browse/FLINK-27164
Yun Gao created FLINK-27162:
---
Summary:
RescaleCheckpointManuallyITCase.testCheckpointRescalingInKeyedState failed on
azure
Key: FLINK-27162
URL: https://issues.apache.org/jira/browse/FLINK-27162
Project: F
Yun Gao created FLINK-27131:
---
Summary: CastFunctionITCase.test failed on azure
Key: FLINK-27131
URL: https://issues.apache.org/jira/browse/FLINK-27131
Project: Flink
Issue Type: Bug
Compo
Yun Gao created FLINK-27118:
---
Summary: Flink on Yarned failed with the default flink-conf
Key: FLINK-27118
URL: https://issues.apache.org/jira/browse/FLINK-27118
Project: Flink
Issue Type: Bug
Yun Gao created FLINK-27083:
---
Summary:
SavepointITCase.testStopWithSavepointFailingAfterSnapshotCreation failed on
azure
Key: FLINK-27083
URL: https://issues.apache.org/jira/browse/FLINK-27083
Project: Fli
Yun Gao created FLINK-27073:
---
Summary: HAQueryableStateFsBackendITCase hangs on azure
Key: FLINK-27073
URL: https://issues.apache.org/jira/browse/FLINK-27073
Project: Flink
Issue Type: Bug
Yun Gao created FLINK-26980:
---
Summary: PulsarUnorderedSourceReaderTest hang on azure
Key: FLINK-26980
URL: https://issues.apache.org/jira/browse/FLINK-26980
Project: Flink
Issue Type: Bug
Yun Gao created FLINK-26979:
---
Summary: JsonFunctionsITCase.test failed on azure
Key: FLINK-26979
URL: https://issues.apache.org/jira/browse/FLINK-26979
Project: Flink
Issue Type: Bug
Comp
Yun Gao created FLINK-26977:
---
Summary:
JobMasterStopWithSavepointITCase.throwingExceptionOnCallbackWithRestartsShouldSimplyRestartInTerminate
failed on azure
Key: FLINK-26977
URL: https://issues.apache.org/jira/browse/
Yun Gao created FLINK-26974:
---
Summary: Python EmbeddedThreadDependencyTests.test_add_python_file
failed on azure
Key: FLINK-26974
URL: https://issues.apache.org/jira/browse/FLINK-26974
Project: Flink
Yun Gao created FLINK-26923:
---
Summary: SavepointITCase.testStopWithSavepointFailsOverToSavepoint
failed on azure
Key: FLINK-26923
URL: https://issues.apache.org/jira/browse/FLINK-26923
Project: Flink
Yun Gao created FLINK-26922:
---
Summary:
KafkaSinkITCase.testRecoveryWithExactlyOnceGuaranteeAndConcurrentCheckpoints
failed on azure
Key: FLINK-26922
URL: https://issues.apache.org/jira/browse/FLINK-26922
P
Yun Gao created FLINK-26921:
---
Summary: KafkaSinkE2ECase.testStartFromSavepoint failed on azure
Key: FLINK-26921
URL: https://issues.apache.org/jira/browse/FLINK-26921
Project: Flink
Issue Type: Bug
Yun Gao created FLINK-26907:
---
Summary: RMQSourceITCase failed on azure due to
ContainerLaunchException: Container startup failed
Key: FLINK-26907
URL: https://issues.apache.org/jira/browse/FLINK-26907
Proje
Yun Gao created FLINK-26880:
---
Summary:
PyFlinkStreamUserDefinedFunctionTests.test_udf_in_join_condition failed on azure
Key: FLINK-26880
URL: https://issues.apache.org/jira/browse/FLINK-26880
Project: Flink
Yun Gao created FLINK-26839:
---
Summary:
SessionDispatcherLeaderProcessTest.recoverJobs_withJobIdRecoveryFailure_failsFatally
failed on azures
Key: FLINK-26839
URL: https://issues.apache.org/jira/browse/FLINK-26839
Yun Gao created FLINK-26838:
---
Summary: BatchingStateChangeUploadSchedulerTest.testRetryOnTimeout
failed on azure
Key: FLINK-26838
URL: https://issues.apache.org/jira/browse/FLINK-26838
Project: Flink
Yun Gao created FLINK-26837:
---
Summary: KafkaSinkE2ECase.testMetrics failed on azure
Key: FLINK-26837
URL: https://issues.apache.org/jira/browse/FLINK-26837
Project: Flink
Issue Type: Bug
Yun Gao created FLINK-26835:
---
Summary: WordCountSubclassPOJOITCase failed on azure
Key: FLINK-26835
URL: https://issues.apache.org/jira/browse/FLINK-26835
Project: Flink
Issue Type: Bug
C
Yun Gao created FLINK-26797:
---
Summary:
ZKCheckpointIDCounterMultiServersTest.testRecoveredAfterConnectionLoss failed
on azure
Key: FLINK-26797
URL: https://issues.apache.org/jira/browse/FLINK-26797
Project
Yun Gao created FLINK-26796:
---
Summary:
TaskManagerProcessFailureStreamingRecoveryITCase.testTaskManagerProcessFailure
failed on azure
Key: FLINK-26796
URL: https://issues.apache.org/jira/browse/FLINK-26796
Yun Gao created FLINK-26794:
---
Summary: ChangelogRescalingITCase.test failed on azure due to
java.nio.file.NoSuchFileException
Key: FLINK-26794
URL: https://issues.apache.org/jira/browse/FLINK-26794
Project:
Yun Gao created FLINK-26755:
---
Summary: Cleanup inprogressfileRecoverable for FileSink on
restoring
Key: FLINK-26755
URL: https://issues.apache.org/jira/browse/FLINK-26755
Project: Flink
Issue Type
Yun Gao created FLINK-26724:
---
Summary:
FlinkKafkaProducerMigrationOperatorTest.testRestoreProducer failed on azure due
to Container startup failed
Key: FLINK-26724
URL: https://issues.apache.org/jira/browse/FLINK-26724
Yun Gao created FLINK-26721:
---
Summary: PulsarSourceITCase.testSavepoint failed on azure pipeline
Key: FLINK-26721
URL: https://issues.apache.org/jira/browse/FLINK-26721
Project: Flink
Issue Type: B
Yun Gao created FLINK-26674:
---
Summary: flink-tests module exit with code 137
Key: FLINK-26674
URL: https://issues.apache.org/jira/browse/FLINK-26674
Project: Flink
Issue Type: Bug
Compone
Yun Gao created FLINK-26644:
---
Summary: python
StreamExecutionEnvironmentTests.test_generate_stream_graph_with_dependencies
failed on azure
Key: FLINK-26644
URL: https://issues.apache.org/jira/browse/FLINK-26644
Yun Gao created FLINK-26625:
---
Summary: KinesisFirehoseSinkITCase failed on azure due to Could
not find a valid Docker environment
Key: FLINK-26625
URL: https://issues.apache.org/jira/browse/FLINK-26625
Proj
Yun Gao created FLINK-26624:
---
Summary: Running HA (hashmap, async) end-to-end test failed on
azure due to unable to find master logs
Key: FLINK-26624
URL: https://issues.apache.org/jira/browse/FLINK-26624
P
Yun Gao created FLINK-26623:
---
Summary: BlobsCleanupITCase failed on azure
Key: FLINK-26623
URL: https://issues.apache.org/jira/browse/FLINK-26623
Project: Flink
Issue Type: Bug
Components
Yun Gao created FLINK-26622:
---
Summary: Azure failed due to Connection timed out
Key: FLINK-26622
URL: https://issues.apache.org/jira/browse/FLINK-26622
Project: Flink
Issue Type: Bug
Com
Yun Gao created FLINK-26621:
---
Summary: flink-tests failed on azure due to Error occurred in
starting fork
Key: FLINK-26621
URL: https://issues.apache.org/jira/browse/FLINK-26621
Project: Flink
Iss
Yun Gao created FLINK-26600:
---
Summary: PerJobMiniClusterFactoryTest.testJobClientSavepoint
failed on azure
Key: FLINK-26600
URL: https://issues.apache.org/jira/browse/FLINK-26600
Project: Flink
Is
Yun Gao created FLINK-26599:
---
Summary: CheckpointCoordinatorTest.testMinCheckpointPause failed
on azure
Key: FLINK-26599
URL: https://issues.apache.org/jira/browse/FLINK-26599
Project: Flink
Issue
Yun Gao created FLINK-26598:
---
Summary: OracleTableSinkITCase failed on azure due to container
failed to startup
Key: FLINK-26598
URL: https://issues.apache.org/jira/browse/FLINK-26598
Project: Flink
Yun Gao created FLINK-26597:
---
Summary: OracleTableSinkITCase failed on azure due to container
failed to startup
Key: FLINK-26597
URL: https://issues.apache.org/jira/browse/FLINK-26597
Project: Flink
Yun Gao created FLINK-26596:
---
Summary:
ZooKeeperLeaderRetrievalConnectionHandlingTest.testNewLeaderAfterReconnectTriggersListenerNotification
failed on azure
Key: FLINK-26596
URL: https://issues.apache.org/jira/browse/
Yun Gao created FLINK-26573:
---
Summary:
ChangelogPeriodicMaterializationRescaleITCase.testRescaleIn failed on azure
Key: FLINK-26573
URL: https://issues.apache.org/jira/browse/FLINK-26573
Project: Flink
Yun Gao created FLINK-26566:
---
Summary:
FlinkKafkaProducerITCase.testFailAndRecoverSameCheckpointTwice failed on azure
Key: FLINK-26566
URL: https://issues.apache.org/jira/browse/FLINK-26566
Project: Flink
Yun Gao created FLINK-26563:
---
Summary: HadoopS3RecoverableWriterITCase hang on azure
Key: FLINK-26563
URL: https://issues.apache.org/jira/browse/FLINK-26563
Project: Flink
Issue Type: Bug
Yun Gao created FLINK-26533:
---
Summary: KafkaSinkITCase.testRecoveryWithExactlyOnceGuarantee
failed on azure due to delete topic timeout
Key: FLINK-26533
URL: https://issues.apache.org/jira/browse/FLINK-26533
Yun Gao created FLINK-26532:
---
Summary: SinkMetricsITCase.testMetrics failed on azure
Key: FLINK-26532
URL: https://issues.apache.org/jira/browse/FLINK-26532
Project: Flink
Issue Type: Bug
Yun Gao created FLINK-26531:
---
Summary: KafkaWriterITCase.testMetadataPublisher failed on azure
Key: FLINK-26531
URL: https://issues.apache.org/jira/browse/FLINK-26531
Project: Flink
Issue Type: Bu
Yun Gao created FLINK-26515:
---
Summary: RetryingExecutorTest.testTimeout failed on azure
Key: FLINK-26515
URL: https://issues.apache.org/jira/browse/FLINK-26515
Project: Flink
Issue Type: Bug
Yun Gao created FLINK-26514:
---
Summary: YARNSessionFIFOITCase.testDetachedMode failed on azure
Key: FLINK-26514
URL: https://issues.apache.org/jira/browse/FLINK-26514
Project: Flink
Issue Type: Bug
Yun Gao created FLINK-26501:
---
Summary: Quickstarts Scala nightly end-to-end test failed on azure
due to checkponts failed and logs contains exceptions
Key: FLINK-26501
URL: https://issues.apache.org/jira/browse/FLINK-26
Yun Gao created FLINK-26500:
---
Summary: AdaptiveSchedulerClusterITCase.testAutomaticScaleUp
failed on azure
Key: FLINK-26500
URL: https://issues.apache.org/jira/browse/FLINK-26500
Project: Flink
Is
Yun Gao created FLINK-26499:
---
Summary: Azure hang due to unable to download akka artifact
Key: FLINK-26499
URL: https://issues.apache.org/jira/browse/FLINK-26499
Project: Flink
Issue Type: Bug
Yun Gao created FLINK-26459:
---
Summary: Streaming File Sink s3 end-to-end test failed on azure
due to not enough resource
Key: FLINK-26459
URL: https://issues.apache.org/jira/browse/FLINK-26459
Project: Flin
Yun Gao created FLINK-26407:
---
Summary: MetricsAvailabilityITCase.testReporter failed on azure
Key: FLINK-26407
URL: https://issues.apache.org/jira/browse/FLINK-26407
Project: Flink
Issue Type: Bug
Yun Gao created FLINK-26403:
---
Summary: SinkWriter should emit all the pending committables on
endOfInput
Key: FLINK-26403
URL: https://issues.apache.org/jira/browse/FLINK-26403
Project: Flink
Issu
Yun Gao created FLINK-26402:
---
Summary:
MinioTestContainerTest.testS3EndpointNeedsToBeSpecifiedBeforeInitializingFileSyste
failed due to Container startup failed
Key: FLINK-26402
URL: https://issues.apache.org/jira/brow
Yun Gao created FLINK-26387:
---
Summary: KafkaSourceLegacyITCase.testBrokerFailure hang on azure
Key: FLINK-26387
URL: https://issues.apache.org/jira/browse/FLINK-26387
Project: Flink
Issue Type: Bug
Yun Gao created FLINK-26386:
---
Summary: CassandraConnectorITCase.testCassandraTableSink failed on
azure
Key: FLINK-26386
URL: https://issues.apache.org/jira/browse/FLINK-26386
Project: Flink
Issue
Yun Gao created FLINK-26323:
---
Summary: PerJobMiniClusterFactoryTest.testJobClient failed on azure
Key: FLINK-26323
URL: https://issues.apache.org/jira/browse/FLINK-26323
Project: Flink
Issue Type:
Yun Gao created FLINK-26322:
---
Summary: Test FileSink compaction manually
Key: FLINK-26322
URL: https://issues.apache.org/jira/browse/FLINK-26322
Project: Flink
Issue Type: Sub-task
Compon
Yun Gao created FLINK-26319:
---
Summary: CastFunctionITCase.testFunction failed on azure
Key: FLINK-26319
URL: https://issues.apache.org/jira/browse/FLINK-26319
Project: Flink
Issue Type: Bug
Yun Gao created FLINK-26318:
---
Summary: ChangelogCompatibilityITCase.testRestore failed on azure
Key: FLINK-26318
URL: https://issues.apache.org/jira/browse/FLINK-26318
Project: Flink
Issue Type: Bu
Yun Gao created FLINK-26317:
---
Summary: flink-yarn-tests Exit code 137 returned from process
Key: FLINK-26317
URL: https://issues.apache.org/jira/browse/FLINK-26317
Project: Flink
Issue Type: Bug
Yun Gao created FLINK-26314:
---
Summary: StreamingCompactingFileSinkITCase.testFileSink failed on
azure
Key: FLINK-26314
URL: https://issues.apache.org/jira/browse/FLINK-26314
Project: Flink
Issue T
Yun Gao created FLINK-26292:
---
Summary: FlinkKafkaProducerITCase.testScaleUpAfterScalingDown
failed on azure
Key: FLINK-26292
URL: https://issues.apache.org/jira/browse/FLINK-26292
Project: Flink
I
Yun Gao created FLINK-26291:
---
Summary: KinesisFirehoseSinkITCase failed on azure
Key: FLINK-26291
URL: https://issues.apache.org/jira/browse/FLINK-26291
Project: Flink
Issue Type: Bug
Com
Yun Gao created FLINK-26243:
---
Summary: RoundRobinTopicRouterTest.routeMessagesInRoundRobin
failed on azure due to divide by zero
Key: FLINK-26243
URL: https://issues.apache.org/jira/browse/FLINK-26243
Proje
Yun Gao created FLINK-26242:
---
Summary: Pulsar connector tests fails the JVM with exit code 255
Key: FLINK-26242
URL: https://issues.apache.org/jira/browse/FLINK-26242
Project: Flink
Issue Type: Bug
Yun Gao created FLINK-26239:
---
Summary: EventTimeWindowCheckpointingITCase.testSlidingTimeWindow
failed on azure
Key: FLINK-26239
URL: https://issues.apache.org/jira/browse/FLINK-26239
Project: Flink
Yun Gao created FLINK-26238:
---
Summary: PulsarSinkITCase.writeRecordsToPulsar failed on azure
Key: FLINK-26238
URL: https://issues.apache.org/jira/browse/FLINK-26238
Project: Flink
Issue Type: Bug
Yun Gao created FLINK-26237:
---
Summary: PulsarSourceOrderedE2ECase failed on azure due to timeout
Key: FLINK-26237
URL: https://issues.apache.org/jira/browse/FLINK-26237
Project: Flink
Issue Type: B
Yun Gao created FLINK-26212:
---
Summary:
UnalignedCheckpointRescaleITCase.shouldRescaleUnalignedCheckpoint failed due to
java.nio.file.NoSuchFileException
Key: FLINK-26212
URL: https://issues.apache.org/jira/browse/FLINK
Yun Gao created FLINK-26211:
---
Summary: PulsarSourceUnorderedE2ECase failed on azure due to
multiple causes
Key: FLINK-26211
URL: https://issues.apache.org/jira/browse/FLINK-26211
Project: Flink
Is
Yun Gao created FLINK-26210:
---
Summary: PulsarSourceUnorderedE2ECase failed on azure due to
multiple causes
Key: FLINK-26210
URL: https://issues.apache.org/jira/browse/FLINK-26210
Project: Flink
Is
Yun Gao created FLINK-26174:
---
Summary: KinesisDataStreamsSink.restoreWriter failed due to
Architecture Violation
Key: FLINK-26174
URL: https://issues.apache.org/jira/browse/FLINK-26174
Project: Flink
Yun Gao created FLINK-26121:
---
Summary:
ZooKeeperLeaderRetrievalConnectionHandlingTest.testNewLeaderAfterReconnectTriggersListenerNotification
failed on azure
Key: FLINK-26121
URL: https://issues.apache.org/jira/browse/
Yun Gao created FLINK-26120:
---
Summary:
ZooKeeperCheckpointIDCounterITCase.testConcurrentGetAndIncrement failed on azure
Key: FLINK-26120
URL: https://issues.apache.org/jira/browse/FLINK-26120
Project: Flink
Yun Gao created FLINK-26115:
---
Summary: Multiple Kafka connector tests failed due to The topic
metadata failed to propagate to Kafka broker
Key: FLINK-26115
URL: https://issues.apache.org/jira/browse/FLINK-26115
Yun Gao created FLINK-26113:
---
Summary: (1.16) Follow up tasks and code refactoring for FLIP-147
Key: FLINK-26113
URL: https://issues.apache.org/jira/browse/FLINK-26113
Project: Flink
Issue Type: Bu
Yun Gao created FLINK-26111:
---
Summary: ElasticsearchSinkITCase.testElasticsearchSink failed on
azure
Key: FLINK-26111
URL: https://issues.apache.org/jira/browse/FLINK-26111
Project: Flink
Issue Ty
Yun Gao created FLINK-26110:
---
Summary: AvroStreamingFileSinkITCase failed on azure
Key: FLINK-26110
URL: https://issues.apache.org/jira/browse/FLINK-26110
Project: Flink
Issue Type: Bug
C
Yun Gao created FLINK-26109:
---
Summary: Avro Confluent Schema Registry nightly end-to-end test
failed on azure
Key: FLINK-26109
URL: https://issues.apache.org/jira/browse/FLINK-26109
Project: Flink
Yun Gao created FLINK-26108:
---
Summary: CoordinatedSourceITCase.testEnumeratorCreationFails
failed on azure
Key: FLINK-26108
URL: https://issues.apache.org/jira/browse/FLINK-26108
Project: Flink
Is
Yun Gao created FLINK-26107:
---
Summary: CoordinatorEventsExactlyOnceITCase.test failed on azure
Key: FLINK-26107
URL: https://issues.apache.org/jira/browse/FLINK-26107
Project: Flink
Issue Type: Bug
Yun Gao created FLINK-26106:
---
Summary: BoundedSourceITCase failed due to JVM exits with code 239
Key: FLINK-26106
URL: https://issues.apache.org/jira/browse/FLINK-26106
Project: Flink
Issue Type: B
Yun Gao created FLINK-26105:
---
Summary: Running HA (hashmap, async) end-to-end test failed on
azure
Key: FLINK-26105
URL: https://issues.apache.org/jira/browse/FLINK-26105
Project: Flink
Issue Type
1 - 100 of 306 matches
Mail list logo
