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-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-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-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-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-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-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-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-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-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-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-21066:
---
Summary: Refactor the CheckpointCoordinator to compute the tasks
to trigger/wait/commit dynamically
Key: FLINK-21066
URL: https://issues.apache.org/jira/browse/FLINK-21066
Proj
Yun Gao created FLINK-21067:
---
Summary: Modify the logic of computing tasks to
trigger/wait/commit to consider finished tasks
Key: FLINK-21067
URL: https://issues.apache.org/jira/browse/FLINK-21067
Project:
Yun Gao created FLINK-21080:
---
Summary: Identify JobVertex containing legacy source operators and
abort checkpoint with legacy source operators partially finished
Key: FLINK-21080
URL: https://issues.apache.org/jira/brow
Yun Gao created FLINK-21081:
---
Summary: Re-compute tasks to trigger when tasks get triggered
before finished
Key: FLINK-21081
URL: https://issues.apache.org/jira/browse/FLINK-21081
Project: Flink
I
Yun Gao created FLINK-21084:
---
Summary: Allows tasks to report operator subtask finish state
Key: FLINK-21084
URL: https://issues.apache.org/jira/browse/FLINK-21084
Project: Flink
Issue Type: Sub-ta
Yun Gao created FLINK-21085:
---
Summary: Refactor StreamTask hierarchy to support triggering
checkpoint via RPC for non-source tasks
Key: FLINK-21085
URL: https://issues.apache.org/jira/browse/FLINK-21085
Pr
Yun Gao created FLINK-21086:
---
Summary: CheckpointBarrierHandler Insert barriers into channels
received EndOfPartition
Key: FLINK-21086
URL: https://issues.apache.org/jira/browse/FLINK-21086
Project: Flink
Yun Gao created FLINK-21087:
---
Summary: StreamTask waits for all the asynchronous step of pending
checkpoint to finish
Key: FLINK-21087
URL: https://issues.apache.org/jira/browse/FLINK-21087
Project: Flink
Yun Gao created FLINK-21088:
---
Summary: CheckpointCoordinator pass the flag about whether a
operator is fully finished on recovery
Key: FLINK-21088
URL: https://issues.apache.org/jira/browse/FLINK-21088
Proj
Yun Gao created FLINK-21089:
---
Summary: Skip the execution of the fully finished operators after
recovery
Key: FLINK-21089
URL: https://issues.apache.org/jira/browse/FLINK-21089
Project: Flink
Issu
Yun Gao created FLINK-21090:
---
Summary: Enable Checkpoints after tasks finished
Key: FLINK-21090
URL: https://issues.apache.org/jira/browse/FLINK-21090
Project: Flink
Issue Type: Sub-task
Yun Gao created FLINK-21127:
---
Summary: Stores finished status for fully finished operators
Key: FLINK-21127
URL: https://issues.apache.org/jira/browse/FLINK-21127
Project: Flink
Issue Type: Sub-tas
Yun Gao created FLINK-21246:
---
Summary: Decline Checkpoint if some tasks finished before get
triggered
Key: FLINK-21246
URL: https://issues.apache.org/jira/browse/FLINK-21246
Project: Flink
Issue T
Yun Gao created FLINK-21952:
---
Summary: Make all the "Connection reset by peer" exception wrapped
as RemoteTransportException
Key: FLINK-21952
URL: https://issues.apache.org/jira/browse/FLINK-21952
Project:
Yun Gao created FLINK-21967:
---
Summary: Add document on the operation of blocking result partition
Key: FLINK-21967
URL: https://issues.apache.org/jira/browse/FLINK-21967
Project: Flink
Issue Type:
Yun Gao created FLINK-22087:
---
Summary: CheckpointPlanCalculator should abort checkpoint if tasks
is in canceling/canceled and so on
Key: FLINK-22087
URL: https://issues.apache.org/jira/browse/FLINK-22087
Pr
Yun Gao created FLINK-22088:
---
Summary: CheckpointCoordinator might not be able to abort
triggering checkpoint if failover happens during triggering
Key: FLINK-22088
URL: https://issues.apache.org/jira/browse/FLINK-22088
Yun Gao created FLINK-22117:
---
Summary: Not print stack trace for checkpoint trigger failure if
not all tasks are started.
Key: FLINK-22117
URL: https://issues.apache.org/jira/browse/FLINK-22117
Project: Fli
Yun Gao created FLINK-22301:
---
Summary: Statebackend and CheckpointStorage type is not shown in
the Web UI
Key: FLINK-22301
URL: https://issues.apache.org/jira/browse/FLINK-22301
Project: Flink
Iss
Yun Gao created FLINK-22928:
---
Summary: Unexpected exception happens in RecordWriter when
stopping-with-savepoint
Key: FLINK-22928
URL: https://issues.apache.org/jira/browse/FLINK-22928
Project: Flink
Yun Gao created FLINK-22929:
---
Summary: Change the default failover strategy to
FixDelayRestartStrategy
Key: FLINK-22929
URL: https://issues.apache.org/jira/browse/FLINK-22929
Project: Flink
Issue
Yun Gao created FLINK-23021:
---
Summary: Check if the restarted job topology is consistent on
restart
Key: FLINK-23021
URL: https://issues.apache.org/jira/browse/FLINK-23021
Project: Flink
Issue Typ
Yun Gao created FLINK-23158:
---
Summary: Source transformation is not added to the
StreamExecutionEnvironment explicitly
Key: FLINK-23158
URL: https://issues.apache.org/jira/browse/FLINK-23158
Project: Flink
Yun Gao created FLINK-23159:
---
Summary: Correlated sql subquery on the source created via
fromValues() failed to compile
Key: FLINK-23159
URL: https://issues.apache.org/jira/browse/FLINK-23159
Project: Flink
Yun Gao created FLINK-23223:
---
Summary: When flushAlways is enabled the subpartition may lose
notification of data availability
Key: FLINK-23223
URL: https://issues.apache.org/jira/browse/FLINK-23223
Project
Yun Gao created FLINK-23366:
---
Summary: AkkaRpcActorTest.
testOnStopFutureCompletionDirectlyTerminatesAkkaRpcActor fails on azure
Key: FLINK-23366
URL: https://issues.apache.org/jira/browse/FLINK-23366
Proje
Yun Gao created FLINK-23512:
---
Summary: Check for illegal modifications of JobGraph with
partially finished operators
Key: FLINK-23512
URL: https://issues.apache.org/jira/browse/FLINK-23512
Project: Flink
Yun Gao created FLINK-23681:
---
Summary: Rename the field name of OperatorIDPair to avoid the
confusion
Key: FLINK-23681
URL: https://issues.apache.org/jira/browse/FLINK-23681
Project: Flink
Issue T
Yun Gao created FLINK-23808:
---
Summary: Bypass operators when advanceToEndOfEventTime for both
legacy and new source tasks
Key: FLINK-23808
URL: https://issues.apache.org/jira/browse/FLINK-23808
Project: Fli
Yun Gao created FLINK-23809:
---
Summary: Respect the finished flag when extracting operator states
due to skip in-flight data
Key: FLINK-23809
URL: https://issues.apache.org/jira/browse/FLINK-23809
Project: F
Yun Gao created FLINK-23815:
---
Summary: Follow-up code improvement regarding final checkpoint.
Key: FLINK-23815
URL: https://issues.apache.org/jira/browse/FLINK-23815
Project: Flink
Issue Type: Sub-
Yun Gao created FLINK-23831:
---
Summary: Verify the final checkpoint and stop-with-savepoint
--drain
Key: FLINK-23831
URL: https://issues.apache.org/jira/browse/FLINK-23831
Project: Flink
Issue Type
Yun Gao created FLINK-23883:
---
Summary: Following bug fix and code improvement for FLIP-147
Key: FLINK-23883
URL: https://issues.apache.org/jira/browse/FLINK-23883
Project: Flink
Issue Type: Improve
Yun Gao created FLINK-23884:
---
Summary: Fix the concurrent problem between triggering savepoint
with drain and finish
Key: FLINK-23884
URL: https://issues.apache.org/jira/browse/FLINK-23884
Project: Flink
Yun Gao created FLINK-23938:
---
Summary: Do not resume channels if the barrier is received via RPC
Key: FLINK-23938
URL: https://issues.apache.org/jira/browse/FLINK-23938
Project: Flink
Issue Type: S
Yun Gao created FLINK-23970:
---
Summary: Future refactoring for the behavior of the tasks marked
as finished on recovery
Key: FLINK-23970
URL: https://issues.apache.org/jira/browse/FLINK-23970
Project: Flink
Yun Gao created FLINK-24065:
---
Summary: Upgrade the TwoPhaseCommitSink to support empty
transaction after finished
Key: FLINK-24065
URL: https://issues.apache.org/jira/browse/FLINK-24065
Project: Flink
Yun Gao created FLINK-24067:
---
Summary: CheckpointBarrierHandler may skip the markAlignmentStart
for alignment -with-timeout checkpoint
Key: FLINK-24067
URL: https://issues.apache.org/jira/browse/FLINK-24067
Yun Gao created FLINK-24068:
---
Summary: CheckpointBarrierHandler may skip the markAlignmentStart
for alignment -with-timeout checkpoint
Key: FLINK-24068
URL: https://issues.apache.org/jira/browse/FLINK-24068
Yun Gao created FLINK-24140:
---
Summary: Enhance the ITCase for FLIP-147
Key: FLINK-24140
URL: https://issues.apache.org/jira/browse/FLINK-24140
Project: Flink
Issue Type: Sub-task
Componen
Yun Gao created FLINK-24216:
---
Summary:
org.apache.flink.test.scheduling.AdaptiveSchedulerITCase#testStopWithSavepointFailOnFirstSavepointSucceedOnSecond
blocked on azure
Key: FLINK-24216
URL: https://issues.apache.org/
Yun Gao created FLINK-24266:
---
Summary: Log improvement for aborting checkpoint due to tasks are
finishing
Key: FLINK-24266
URL: https://issues.apache.org/jira/browse/FLINK-24266
Project: Flink
Iss
Yun Gao created FLINK-24572:
---
Summary: Properly set the context ClassLoader when calling
OperatorCoordinator on JM side
Key: FLINK-24572
URL: https://issues.apache.org/jira/browse/FLINK-24572
Project: Flink
Yun Gao created FLINK-24642:
---
Summary: Implements unified iteration to support algorithms in
flink-ml
Key: FLINK-24642
URL: https://issues.apache.org/jira/browse/FLINK-24642
Project: Flink
Issue T
Yun Gao created FLINK-24643:
---
Summary: Introduce the flink-ml-iteration module and iteration api
Key: FLINK-24643
URL: https://issues.apache.org/jira/browse/FLINK-24643
Project: Flink
Issue Type: S
Yun Gao created FLINK-24644:
---
Summary: Introduce Add broadcast output to broadcast events to all
the downstream tasks
Key: FLINK-24644
URL: https://issues.apache.org/jira/browse/FLINK-24644
Project: Flink
Yun Gao created FLINK-24645:
---
Summary: Implements the feedback mechanism and the controller
operators
Key: FLINK-24645
URL: https://issues.apache.org/jira/browse/FLINK-24645
Project: Flink
Issue T
Yun Gao created FLINK-24646:
---
Summary: Add operator wrapper for all-round iterations
Key: FLINK-24646
URL: https://issues.apache.org/jira/browse/FLINK-24646
Project: Flink
Issue Type: Sub-task
Yun Gao created FLINK-24649:
---
Summary: Add DraftExecutionEnvironment to support wrapping
operators during compile time
Key: FLINK-24649
URL: https://issues.apache.org/jira/browse/FLINK-24649
Project: Flink
Yun Gao created FLINK-24650:
---
Summary: Support unbounded iteration.
Key: FLINK-24650
URL: https://issues.apache.org/jira/browse/FLINK-24650
Project: Flink
Issue Type: Sub-task
Components:
Yun Gao created FLINK-24651:
---
Summary: Support bounded all-round iteration
Key: FLINK-24651
URL: https://issues.apache.org/jira/browse/FLINK-24651
Project: Flink
Issue Type: Sub-task
Com
Yun Gao created FLINK-24652:
---
Summary: Add operator wrapper for per-round operators
Key: FLINK-24652
URL: https://issues.apache.org/jira/browse/FLINK-24652
Project: Flink
Issue Type: Sub-task
Yun Gao created FLINK-24653:
---
Summary: Support per-round operators inside the iteration.
Key: FLINK-24653
URL: https://issues.apache.org/jira/browse/FLINK-24653
Project: Flink
Issue Type: Sub-task
Yun Gao created FLINK-24655:
---
Summary: Support checkpoint for jobs using iteration
Key: FLINK-24655
URL: https://issues.apache.org/jira/browse/FLINK-24655
Project: Flink
Issue Type: Sub-task
Yun Gao created FLINK-24722:
---
Summary: Only set keyContext for the normal records
Key: FLINK-24722
URL: https://issues.apache.org/jira/browse/FLINK-24722
Project: Flink
Issue Type: Sub-task
Yun Gao created FLINK-24729:
---
Summary: Support IterationBody with mixed per-round and all-round
operators
Key: FLINK-24729
URL: https://issues.apache.org/jira/browse/FLINK-24729
Project: Flink
Iss
Yun Gao created FLINK-24799:
---
Summary:
KafkaDynamicTableFactoryTest.testTableSourceWithKeyValueAndMetadata fails on
Azure
Key: FLINK-24799
URL: https://issues.apache.org/jira/browse/FLINK-24799
Project: Fl
Yun Gao created FLINK-24801:
---
Summary: "Post-job: Cache Maven local repo" failed on Azure
Key: FLINK-24801
URL: https://issues.apache.org/jira/browse/FLINK-24801
Project: Flink
Issue Type: Bug
Yun Gao created FLINK-24800:
---
Summary: BufferTimeoutITCase.testDisablingBufferTimeout failed on
Azure
Key: FLINK-24800
URL: https://issues.apache.org/jira/browse/FLINK-24800
Project: Flink
Issue T
Yun Gao created FLINK-24806:
---
Summary: RMQSourceITCase.testStopWithSavepoint failed on azure due
to connection error
Key: FLINK-24806
URL: https://issues.apache.org/jira/browse/FLINK-24806
Project: Flink
Yun Gao created FLINK-24807:
---
Summary: Fix the issues in checkpoints with iteration
Key: FLINK-24807
URL: https://issues.apache.org/jira/browse/FLINK-24807
Project: Flink
Issue Type: Sub-task
Yun Gao created FLINK-24808:
---
Summary: Support IterationListener for per-round operators
Key: FLINK-24808
URL: https://issues.apache.org/jira/browse/FLINK-24808
Project: Flink
Issue Type: Sub-task
Yun Gao created FLINK-24811:
---
Summary: KafkaSourceITCase#testRedundantParallelism and
testBasicRead failed on azure
Key: FLINK-24811
URL: https://issues.apache.org/jira/browse/FLINK-24811
Project: Flink
Yun Gao created FLINK-24812:
---
Summary: compile_cron_python_wheels failed to execute on azure
Key: FLINK-24812
URL: https://issues.apache.org/jira/browse/FLINK-24812
Project: Flink
Issue Type: Bug
Yun Gao created FLINK-24842:
---
Summary: Make outputs depends on tails for the iteration body
Key: FLINK-24842
URL: https://issues.apache.org/jira/browse/FLINK-24842
Project: Flink
Issue Type: Sub-ta
Yun Gao created FLINK-24853:
---
Summary: Report errors if jobs using iteration has runtime mode
set to BATCH
Key: FLINK-24853
URL: https://issues.apache.org/jira/browse/FLINK-24853
Project: Flink
I
Yun Gao created FLINK-24896:
---
Summary: Failed to execute goal
com.github.siom79.japicmp:japicmp-maven-plugin:0.11.0:cmp (default) on project
flink-metrics-core
Key: FLINK-24896
URL: https://issues.apache.org/jira/brows
Yun Gao created FLINK-24916:
---
Summary: AvroExternalJarProgramITCase JVM crash on Azure
Key: FLINK-24916
URL: https://issues.apache.org/jira/browse/FLINK-24916
Project: Flink
Issue Type: Bug
Yun Gao created FLINK-24917:
---
Summary: YARNSessionFIFOSecuredITCase hangs on azure
Key: FLINK-24917
URL: https://issues.apache.org/jira/browse/FLINK-24917
Project: Flink
Issue Type: Bug
C
Yun Gao created FLINK-24935:
---
Summary: Python module failed to compile due to "Could not create
local repository"
Key: FLINK-24935
URL: https://issues.apache.org/jira/browse/FLINK-24935
Project: Flink
Yun Gao created FLINK-24936:
---
Summary: Python test_data_stream.py hangs on azure
Key: FLINK-24936
URL: https://issues.apache.org/jira/browse/FLINK-24936
Project: Flink
Issue Type: Bug
Com
Yun Gao created FLINK-24937:
---
Summary: "kubernetes application HA test" hangs on azure
Key: FLINK-24937
URL: https://issues.apache.org/jira/browse/FLINK-24937
Project: Flink
Issue Type: Bug
Yun Gao created FLINK-24946:
---
Summary: KafkaSourceLegacyITCase.testBigRecordJob fails on azure
Key: FLINK-24946
URL: https://issues.apache.org/jira/browse/FLINK-24946
Project: Flink
Issue Type: Bug
Yun Gao created FLINK-24949:
---
Summary: KafkaITCase.testBigRecordJob fails on azure
Key: FLINK-24949
URL: https://issues.apache.org/jira/browse/FLINK-24949
Project: Flink
Issue Type: Bug
C
Yun Gao created FLINK-24960:
---
Summary:
YARNSessionCapacitySchedulerITCase.testVCoresAreSetCorrectlyAndJobManagerHostnameAreShownInWebInterfaceAndDynamicPropertiesAndYarnApplicationNameAndTaskManagerSlots
hangs on azure
Key: FLINK-24960
Yun Gao created FLINK-24968:
---
Summary: "Flink over NAT end-to-end test" failed on azure
Key: FLINK-24968
URL: https://issues.apache.org/jira/browse/FLINK-24968
Project: Flink
Issue Type: Bug
Yun Gao created FLINK-24969:
---
Summary: pyflink/table/tests/test_pandas_udf.py hangs on azure
Key: FLINK-24969
URL: https://issues.apache.org/jira/browse/FLINK-24969
Project: Flink
Issue Type: Bug
Yun Gao created FLINK-24970:
---
Summary: FlinkKafkaProducerITCase testScaleUpAfterScalingDown
Timeout expired after 6 milliseconds while awaiting InitProducerId
Key: FLINK-24970
URL: https://issues.apache.org/jira/bro
Yun Gao created FLINK-24971:
---
Summary: Streaming File Sink s3 end-to-end test stalled on azure
Key: FLINK-24971
URL: https://issues.apache.org/jira/browse/FLINK-24971
Project: Flink
Issue Type: Bug
Yun Gao created FLINK-24972:
---
Summary: FlinkKafkaProducerITCase testScaleUpAfterScalingDown
Timeout due to failed to complete checkpoint
Key: FLINK-24972
URL: https://issues.apache.org/jira/browse/FLINK-24972
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-28824:
---
Summary:
StreamingJobGraphGenerator#triggerSerializationAndReturnFuture might swallow
exception
Key: FLINK-28824
URL: https://issues.apache.org/jira/browse/FLINK-28824
Projec
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-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-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-17589:
---
Summary: Extend StreamingFileSink to Support Streaming Hive
Connector
Key: FLINK-17589
URL: https://issues.apache.org/jira/browse/FLINK-17589
Project: Flink
Issue Typ
Yun Gao created FLINK-17590:
---
Summary: Add Bucket lifecycle listener to support acquiring bucket
state
Key: FLINK-17590
URL: https://issues.apache.org/jira/browse/FLINK-17590
Project: Flink
Issue
Yun Gao created FLINK-17593:
---
Summary: Support arbitrary recovery mechanism for PartFileWriter
Key: FLINK-17593
URL: https://issues.apache.org/jira/browse/FLINK-17593
Project: Flink
Issue Type: New
Yun Gao created FLINK-17594:
---
Summary: Support path-based PartFileWriter
Key: FLINK-17594
URL: https://issues.apache.org/jira/browse/FLINK-17594
Project: Flink
Issue Type: Sub-task
Compon
201 - 300 of 306 matches
Mail list logo
