Yun Gao created FLINK-13531:
---
Summary: Do not print log and call release if no requests should
be evicted in slot sharing
Key: FLINK-13531
URL: https://issues.apache.org/jira/browse/FLINK-13531
Project: Fli
Yun Gao created FLINK-13752:
---
Summary: TaskDeploymentDescriptor cannot be recycled by GC due to
referenced by an anonymous function
Key: FLINK-13752
URL: https://issues.apache.org/jira/browse/FLINK-13752
Pr
Yun Gao created FLINK-16009:
---
Summary: Native support for the Variable-length and Zig-zag
Variable-length integers
Key: FLINK-16009
URL: https://issues.apache.org/jira/browse/FLINK-16009
Project: Flink
Yun Gao created FLINK-16137:
---
Summary: Translate all DataStream API related pages into Chinese
Key: FLINK-16137
URL: https://issues.apache.org/jira/browse/FLINK-16137
Project: Flink
Issue Type: Im
Yun Gao created FLINK-16138:
---
Summary: Translate "Overview" page of "DataStream API" into Chinese
Key: FLINK-16138
URL: https://issues.apache.org/jira/browse/FLINK-16138
Project: Flink
Issue Type:
Yun Gao created FLINK-16151:
---
Summary: Translate "Event-time/Pre-defined Timestamp Extractors /
Watermark Emitters" into Chinese
Key: FLINK-16151
URL: https://issues.apache.org/jira/browse/FLINK-16151
Proje
Yun Gao created FLINK-16152:
---
Summary: Translate "Operator/index" into Chinese
Key: FLINK-16152
URL: https://issues.apache.org/jira/browse/FLINK-16152
Project: Flink
Issue Type: Sub-task
Yun Gao created FLINK-16153:
---
Summary: Translate "Operator/windows" into Chinese
Key: FLINK-16153
URL: https://issues.apache.org/jira/browse/FLINK-16153
Project: Flink
Issue Type: Sub-task
Yun Gao created FLINK-16155:
---
Summary: Translate "Operator/Process Function" into Chinese
Key: FLINK-16155
URL: https://issues.apache.org/jira/browse/FLINK-16155
Project: Flink
Issue Type: Sub-task
Yun Gao created FLINK-16154:
---
Summary: Translate "Operator/Join" into Chinese
Key: FLINK-16154
URL: https://issues.apache.org/jira/browse/FLINK-16154
Project: Flink
Issue Type: Sub-task
C
Yun Gao created FLINK-16582:
---
Summary: NettyBufferPoolTest may have warns on NettyBuffer leak
Key: FLINK-16582
URL: https://issues.apache.org/jira/browse/FLINK-16582
Project: Flink
Issue Type: Bug
Yun Gao created FLINK-14521:
---
Summary: CoLocationGroup is not set into JobVertex if the stream
node chained with others
Key: FLINK-14521
URL: https://issues.apache.org/jira/browse/FLINK-14521
Project: Flink
Yun Gao created FLINK-15664:
---
Summary: Flink plan visualizer does not show operators information
completely when there are line wrap
Key: FLINK-15664
URL: https://issues.apache.org/jira/browse/FLINK-15664
P
Yun Gao created FLINK-15701:
---
Summary: Allows transfer.sh to retry when fails to uploads logs.
Key: FLINK-15701
URL: https://issues.apache.org/jira/browse/FLINK-15701
Project: Flink
Issue Type: Imp
Yun Gao created FLINK-10469:
---
Summary: FileChannel may not write the whole buffer in a single
call to FileChannel.write(Buffer buffer)
Key: FLINK-10469
URL: https://issues.apache.org/jira/browse/FLINK-10469
Yun Gao created FLINK-10981:
---
Summary: Add or modify metrics to show the maximum usage of
InputBufferPool/OutputBufferPool to help debugging back pressure
Key: FLINK-10981
URL: https://issues.apache.org/jira/browse/FLIN
Yun Gao created FLINK-12171:
---
Summary: The network buffer memory size should not be checked
against the heap size on the TM side
Key: FLINK-12171
URL: https://issues.apache.org/jira/browse/FLINK-12171
Proje
Yun Gao created FLINK-12852:
---
Summary: Deadlock occurs when requiring exclusive buffer for
RemoteInputChannel
Key: FLINK-12852
URL: https://issues.apache.org/jira/browse/FLINK-12852
Project: Flink
Yun Gao created FLINK-12865:
---
Summary: State inconsistency between RM and TM on the slot status
Key: FLINK-12865
URL: https://issues.apache.org/jira/browse/FLINK-12865
Project: Flink
Issue Type: Bu
Yun Gao created FLINK-19653:
---
Summary: HiveCatalogITCase fails on azure
Key: FLINK-19653
URL: https://issues.apache.org/jira/browse/FLINK-19653
Project: Flink
Issue Type: Improvement
Comp
Yun Gao created FLINK-19701:
---
Summary: Unaligned Checkpoint might misuse the number of buffers
to persist from the previous barrier
Key: FLINK-19701
URL: https://issues.apache.org/jira/browse/FLINK-19701
Pr
Yun Gao created FLINK-19758:
---
Summary: Implement a new unified File Sink based on the new Sink
API
Key: FLINK-19758
URL: https://issues.apache.org/jira/browse/FLINK-19758
Project: Flink
Issue Type
Yun Gao created FLINK-19850:
---
Summary: Add E2E tests for the new streaming case of the new
FileSink
Key: FLINK-19850
URL: https://issues.apache.org/jira/browse/FLINK-19850
Project: Flink
Issue Typ
Yun Gao created FLINK-20032:
---
Summary: Make FileSink support processing time
Key: FLINK-20032
URL: https://issues.apache.org/jira/browse/FLINK-20032
Project: Flink
Issue Type: Sub-task
Yun Gao created FLINK-20172:
---
Summary: Unify the behavior for file committers when the source or
dest files are not exists
Key: FLINK-20172
URL: https://issues.apache.org/jira/browse/FLINK-20172
Project: Fl
Yun Gao created FLINK-20180:
---
Summary: Translation the FileSink Document into Chinese
Key: FLINK-20180
URL: https://issues.apache.org/jira/browse/FLINK-20180
Project: Flink
Issue Type: Sub-task
Yun Gao created FLINK-20291:
---
Summary: Optimize the exception message of FileSystemTableSink
when missing format dependencies
Key: FLINK-20291
URL: https://issues.apache.org/jira/browse/FLINK-20291
Project:
Yun Gao created FLINK-20292:
---
Summary: Avro format conflicts with Parquet and Orc
Key: FLINK-20292
URL: https://issues.apache.org/jira/browse/FLINK-20292
Project: Flink
Issue Type: Bug
Yun Gao created FLINK-20295:
---
Summary: File Source lost data when reading from directories
created by FileSystemTableSink with JSON format
Key: FLINK-20295
URL: https://issues.apache.org/jira/browse/FLINK-20295
Yun Gao created FLINK-20315:
---
Summary: Optimize the compaction section for the document of table
filesystem sink.
Key: FLINK-20315
URL: https://issues.apache.org/jira/browse/FLINK-20315
Project: Flink
Yun Gao created FLINK-20888:
---
Summary: ContinuousFileReaderOperator should not close the output
on close()
Key: FLINK-20888
URL: https://issues.apache.org/jira/browse/FLINK-20888
Project: Flink
Is
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-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-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-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-26596:
---
Summary:
ZooKeeperLeaderRetrievalConnectionHandlingTest.testNewLeaderAfterReconnectTriggersListenerNotification
failed on azure
Key: FLINK-26596
URL: https://issues.apache.org/jira/browse/
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-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-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-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-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-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-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-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-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-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-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-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-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-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-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-26796:
---
Summary:
TaskManagerProcessFailureStreamingRecoveryITCase.testTaskManagerProcessFailure
failed on azure
Key: FLINK-26796
URL: https://issues.apache.org/jira/browse/FLINK-26796
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-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-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-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-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-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-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-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-26922:
---
Summary:
KafkaSinkITCase.testRecoveryWithExactlyOnceGuaranteeAndConcurrentCheckpoints
failed on azure
Key: FLINK-26922
URL: https://issues.apache.org/jira/browse/FLINK-26922
P
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-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-26977:
---
Summary:
JobMasterStopWithSavepointITCase.throwingExceptionOnCallbackWithRestartsShouldSimplyRestartInTerminate
failed on azure
Key: FLINK-26977
URL: https://issues.apache.org/jira/browse/
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-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-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-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-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-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-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-27164:
---
Summary:
ResumeCheckpointManuallyITCase.testExternalizedFSCheckpointsWithLocalRecoveryZookeeper
failed on azure
Key: FLINK-27164
URL: https://issues.apache.org/jira/browse/FLINK-27164
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-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-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-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-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-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-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-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-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-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-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-25088:
---
Summary: KafkaSinkITCase failed on azure due to Container did not
start correctly
Key: FLINK-25088
URL: https://issues.apache.org/jira/browse/FLINK-25088
Project: Flink
Yun Gao created FLINK-25089:
---
Summary: KafkaSourceITCase.testBasicRead hangs on azure
Key: FLINK-25089
URL: https://issues.apache.org/jira/browse/FLINK-25089
Project: Flink
Issue Type: Bug
Yun Gao created FLINK-25100:
---
Summary: RMQSourceITCase failed on azure due to
java.io.EOFException
Key: FLINK-25100
URL: https://issues.apache.org/jira/browse/FLINK-25100
Project: Flink
Issue Type
Yun Gao created FLINK-25101:
---
Summary:
FlinkKafkaProducerITCase.testMigrateFromAtLeastOnceToExactlyOnce failed due to
Key: FLINK-25101
URL: https://issues.apache.org/jira/browse/FLINK-25101
Project: Flink
Yun Gao created FLINK-25102:
---
Summary: ParquetFileSystemITCase.testPartialDynamicPartition
failed on azure
Key: FLINK-25102
URL: https://issues.apache.org/jira/browse/FLINK-25102
Project: Flink
I
Yun Gao created FLINK-25105:
---
Summary: Enables final checkpoint by default
Key: FLINK-25105
URL: https://issues.apache.org/jira/browse/FLINK-25105
Project: Flink
Issue Type: Sub-task
Comp
Yun Gao created FLINK-25139:
---
Summary: Shaded Hadoop S3A with credentials provider failed on
azure
Key: FLINK-25139
URL: https://issues.apache.org/jira/browse/FLINK-25139
Project: Flink
Issue Type
Yun Gao created FLINK-25140:
---
Summary: Streaming File Sink s3 end-to-end test failed due to job
has not started within a timeout of 10 sec
Key: FLINK-25140
URL: https://issues.apache.org/jira/browse/FLINK-25140
Yun Gao created FLINK-25150:
---
Summary:
org.apache.flink.connector.file.src.reader.TextLineInputFormat.createReader
failed due to violate ApiAnnotationRules
Key: FLINK-25150
URL: https://issues.apache.org/jira/browse/FL
Yun Gao created FLINK-25165:
---
Summary: CassandraConnectorITCase.testCassandraPojoAtLeastOnceSink
failed on azure
Key: FLINK-25165
URL: https://issues.apache.org/jira/browse/FLINK-25165
Project: Flink
Yun Gao created FLINK-25166:
---
Summary: UpsertKafkaDynamicTableFactoryTest failed on azure
Key: FLINK-25166
URL: https://issues.apache.org/jira/browse/FLINK-25166
Project: Flink
Issue Type: Bug
Yun Gao created FLINK-25168:
---
Summary: Azure failed due to unable to transfer maven artifacts
Key: FLINK-25168
URL: https://issues.apache.org/jira/browse/FLINK-25168
Project: Flink
Issue Type: Bug
Yun Gao created FLINK-25269:
---
Summary: Quickstarts Scala nightly end-to-end test failed on azure
due to could not connect to resource manager
Key: FLINK-25269
URL: https://issues.apache.org/jira/browse/FLINK-25269
Yun Gao created FLINK-25270:
---
Summary: Azure failed due to stopped hearing from agent
AlibabaCI006-agent01
Key: FLINK-25270
URL: https://issues.apache.org/jira/browse/FLINK-25270
Project: Flink
Is
Yun Gao created FLINK-25271:
---
Summary: ApplicationDispatcherBootstrapITCase.
testDispatcherRecoversAfterLosingAndRegainingLeadership failed on azure
Key: FLINK-25271
URL: https://issues.apache.org/jira/browse/FLINK-2527
Yun Gao created FLINK-25278:
---
Summary: Azure failed due to unable to transfer jar from confluent
maven repo
Key: FLINK-25278
URL: https://issues.apache.org/jira/browse/FLINK-25278
Project: Flink
I
Yun Gao created FLINK-25279:
---
Summary: KafkaSourceLegacyITCase.testKeyValueSupport failed on
azure due to topic already exists
Key: FLINK-25279
URL: https://issues.apache.org/jira/browse/FLINK-25279
Project
1 - 100 of 306 matches
Mail list logo
