Guowei Ma created FLINK-22419:
-
Summary: testScheduleRunAsync fail
Key: FLINK-22419
URL: https://issues.apache.org/jira/browse/FLINK-22419
Project: Flink
Issue Type: Bug
Components
Congratulations, Rui!
Best,
Guowei
On Fri, Apr 23, 2021 at 10:38 AM Yun Tang wrote:
> Congratulations, Rui!
>
> Best,
> Yun Tang
>
> From: Xuannan Su
> Sent: Friday, April 23, 2021 10:01
> To: dev@flink.apache.org ; matth...@ververica.com <
> matth...@ververica
Guowei Ma created FLINK-22363:
-
Summary: Python test pipeline failed because of failure of
downloading deps.
Key: FLINK-22363
URL: https://issues.apache.org/jira/browse/FLINK-22363
Project: Flink
Hi everyone,
Currently there are still some on-going efforts for 1.13.0. However we
think the current state is stable enough for the community to test. The
earlier the test, the more time we can fix unexpected issues if there is
any.
We also cut out the release-1.13 branch, so any fix needs to be
Guowei Ma created FLINK-22333:
-
Summary: Elasticsearch7DynamicSinkITCase.testWritingDocuments fail
due to deploy task timeout.
Key: FLINK-22333
URL: https://issues.apache.org/jira/browse/FLINK-22333
Guowei Ma created FLINK-22332:
-
Summary:
ConnectedComponentsWithObjectMapITCase.testJobWithoutObjectReuse due to NPE
when calling "notifyDataAvailable"
Key: FLINK-22332
URL: https://issues.apache.org/j
Guowei Ma created FLINK-22312:
-
Summary:
YARNSessionFIFOSecuredITCase>YARNSessionFIFOITCase.checkForProhibitedLogContents
due to the heartbeat exception with Yarn RM
Key: FLINK-22312
URL: https://issues.apache.
+1
Thanks for driving this, Arvid.
Best,
Guowei
On Fri, Apr 16, 2021 at 5:58 PM Till Rohrmann wrote:
> +1.
>
> Thanks for volunteering Arvid.
>
> Cheers,
> Till
>
> On Fri, Apr 16, 2021 at 9:50 AM Stephan Ewen wrote:
>
> > +1
> >
> > Thanks for pushing this, Arvid, let's get this fix out asap
Guowei Ma created FLINK-22285:
-
Summary: org.apache.flink.yarn.YARNHighAvailabilityITCase Hang
Key: FLINK-22285
URL: https://issues.apache.org/jira/browse/FLINK-22285
Project: Flink
Issue Type
Guowei Ma created FLINK-22270:
-
Summary: Python test pipeline no output for 900 seconds
Key: FLINK-22270
URL: https://issues.apache.org/jira/browse/FLINK-22270
Project: Flink
Issue Type: Bug
Guowei Ma created FLINK-22269:
-
Summary:
JobMasterStopWithSavepointITCase.throwingExceptionOnCallbackWithRestartsShouldSimplyRestartInSuspend
failed.
Key: FLINK-22269
URL: https://issues.apache.org/jira/browse/FLINK
Guowei Ma created FLINK-22268:
-
Summary:
JobMasterStopWithSavepointITCase.testRestartCheckpointCoordinatorIfStopWithSavepointFails
fail because of "Not all required tasks are currently running."
Key: FLINK-22268
Guowei Ma created FLINK-22266:
-
Summary:
JobMasterStopWithSavepointITCase.throwingExceptionOnCallbackWithoutRestartsHelper
fail
Key: FLINK-22266
URL: https://issues.apache.org/jira/browse/FLINK-22266
Guowei Ma created FLINK-22251:
-
Summary: PrometheusReporterEndToEndITCase.testReporter fail
because Dispatcher REST endpoint did not start in time.
Key: FLINK-22251
URL: https://issues.apache.org/jira/browse/FLINK
Guowei Ma created FLINK-22249:
-
Summary: JobMasterStopWithSavepointITCase failed due to status is
FAILING
Key: FLINK-22249
URL: https://issues.apache.org/jira/browse/FLINK-22249
Project: Flink
Guowei Ma created FLINK-22248:
-
Summary:
JobMasterStopWithSavepointITCase.suspendWithSavepointWithoutComplicationsShouldSucceedAndLeadJobToFinished
fail because of TestTimedOutException
Key: FLINK-22248
URL: https
Guowei Ma created FLINK-22203:
-
Summary: KafkaChangelogTableITCase.testKafkaCanalChangelogSource
fail due to ConcurrentModificationException
Key: FLINK-22203
URL: https://issues.apache.org/jira/browse/FLINK-22203
Guowei Ma created FLINK-22198:
-
Summary:
org.apache.flink.streaming.connectors.kafka.table.KafkaTableITCase hang.
Key: FLINK-22198
URL: https://issues.apache.org/jira/browse/FLINK-22198
Project: Flink
Guowei Ma created FLINK-22197:
-
Summary:
UnalignedCheckpointRescaleITCase.shouldRescaleUnalignedCheckpoint fail due to
NoSuchFileException
Key: FLINK-22197
URL: https://issues.apache.org/jira/browse/FLINK-22197
Guowei Ma created FLINK-22195:
-
Summary: YARNHighAvailabilityITCase.testClusterClientRetrieval
because of TestTimedOutException
Key: FLINK-22195
URL: https://issues.apache.org/jira/browse/FLINK-22195
Guowei Ma created FLINK-22194:
-
Summary:
KafkaSourceReaderTest.testCommitOffsetsWithoutAliveFetchers fail due to commit
timeout
Key: FLINK-22194
URL: https://issues.apache.org/jira/browse/FLINK-22194
Guowei Ma created FLINK-22193:
-
Summary: HiveTableSinkITCase.testNonPartStreamingMrWrite fail
Key: FLINK-22193
URL: https://issues.apache.org/jira/browse/FLINK-22193
Project: Flink
Issue Type
Guowei Ma created FLINK-22192:
-
Summary: HiveTableSinkITCase.testDefaultSerPartStreamingWrite fail
Key: FLINK-22192
URL: https://issues.apache.org/jira/browse/FLINK-22192
Project: Flink
Issue
Guowei Ma created FLINK-22191:
-
Summary:
PyFlinkStreamUserDefinedFunctionTests.test_udf_in_join_condition_2 fail due to
NPE
Key: FLINK-22191
URL: https://issues.apache.org/jira/browse/FLINK-22191
Guowei Ma created FLINK-22122:
-
Summary: StreamingKafkaITCase Fail due to TestTimedOutException
Key: FLINK-22122
URL: https://issues.apache.org/jira/browse/FLINK-22122
Project: Flink
Issue Type
Guowei Ma created FLINK-22114:
-
Summary: Streaming File Sink s3 end-to-end test fail because the
test did not finish after 900 seconds.
Key: FLINK-22114
URL: https://issues.apache.org/jira/browse/FLINK-22114
Guowei Ma created FLINK-22112:
-
Summary: EmulatedPubSubSinkTest fail due to pull docker image
failure
Key: FLINK-22112
URL: https://issues.apache.org/jira/browse/FLINK-22112
Project: Flink
Guowei Ma created FLINK-22111:
-
Summary: ClientTest.testSimpleRequests fail
Key: FLINK-22111
URL: https://issues.apache.org/jira/browse/FLINK-22111
Project: Flink
Issue Type: Bug
Guowei Ma created FLINK-22110:
-
Summary: KinesisTableApiITCase.testTableApiSourceAndSink failed
due to download docker image throw IOException
Key: FLINK-22110
URL: https://issues.apache.org/jira/browse/FLINK-22110
Guowei Ma created FLINK-22104:
-
Summary: SqlClientTest.testExecuteSqlFile fail
Key: FLINK-22104
URL: https://issues.apache.org/jira/browse/FLINK-22104
Project: Flink
Issue Type: Bug
Guowei Ma created FLINK-22103:
-
Summary: testNumberOfBuiltinFunctions fail
Key: FLINK-22103
URL: https://issues.apache.org/jira/browse/FLINK-22103
Project: Flink
Issue Type: Bug
Guowei Ma created FLINK-22101:
-
Summary: PyFlinkBatchUserDefinedTableFunctionTests fail
Key: FLINK-22101
URL: https://issues.apache.org/jira/browse/FLINK-22101
Project: Flink
Issue Type: Bug
Guowei Ma created FLINK-22100:
-
Summary: BatchFileSystemITCaseBase.testPartialDynamicPartition
fail because of no output for 900 seconds
Key: FLINK-22100
URL: https://issues.apache.org/jira/browse/FLINK-22100
Guowei Ma created FLINK-22097:
-
Summary: testChangelogResultViewClearEmptyResult fail.
Key: FLINK-22097
URL: https://issues.apache.org/jira/browse/FLINK-22097
Project: Flink
Issue Type: Bug
he permission to merge this feature [1], it's a
>>>> useful improvement to sql client and won't affect
>>>> other components too much. We were plan to merge it yesterday but met
>>>> some tricky multi-process issue which
>>>> has a very high
Guowei Ma created FLINK-22096:
-
Summary: ServerTransportErrorHandlingTest.testRemoteClose fail
Key: FLINK-22096
URL: https://issues.apache.org/jira/browse/FLINK-22096
Project: Flink
Issue Type
Hi, community:
Friendly reminder that today (3.31) is the last day of feature development.
Under normal circumstances, you will not be able to submit new features
from tomorrow (4.1). Tomorrow we will create 1.13.0-rc0 for testing,
welcome to help test together.
After the test is relatively stable
Guowei Ma created FLINK-22056:
-
Summary: FlinkKafkaProducerITCase failed because of "producer
leak".
Key: FLINK-22056
URL: https://issues.apache.org/jira/browse/FLINK-22056
Project: Flink
Guowei Ma created FLINK-22005:
-
Summary: SQL Client end-to-end test (Old planner) Elasticsearch
(v7.5.1)
Key: FLINK-22005
URL: https://issues.apache.org/jira/browse/FLINK-22005
Project: Flink
Guowei Ma created FLINK-22003:
-
Summary: UnalignedCheckpointITCase fail
Key: FLINK-22003
URL: https://issues.apache.org/jira/browse/FLINK-22003
Project: Flink
Issue Type: Bug
Guowei Ma created FLINK-22002:
-
Summary:
AggregateReduceGroupingITCase.testSingleAggOnTable_HashAgg_WithLocalAgg fail
because of submitting task time-out.
Key: FLINK-22002
URL: https://issues.apache.org/jira/browse
Guowei Ma created FLINK-21988:
-
Summary: testRequestKvStateWithIrrelevantRegistration fail
Key: FLINK-21988
URL: https://issues.apache.org/jira/browse/FLINK-21988
Project: Flink
Issue Type: Bug
Guowei Ma created FLINK-21987:
-
Summary: testRequestKvStateOfWrongJob failed
Key: FLINK-21987
URL: https://issues.apache.org/jira/browse/FLINK-21987
Project: Flink
Issue Type: Bug
Guowei Ma created FLINK-21983:
-
Summary: Test failed because "mvn-${sys/mvn.forkNumber}" is not
updated on time.
Key: FLINK-21983
URL: https://issues.apache.org/jira/browse/FLINK-21983
Proj
Hi Robin
Thank you for bringing up this discussion. AFAIK there are many same
requirements.But it might lead to a deadlock if we depend on pausing one
input of two to align the watermark.
After the FLIP-27 Flink would introduce some new mechanism for aligning the
watermark of different sources .Ma
Guowei Ma created FLINK-21941:
-
Summary: testSavepointRescalingOutPartitionedOperatorStateList fail
Key: FLINK-21941
URL: https://issues.apache.org/jira/browse/FLINK-21941
Project: Flink
Issue
I am
>> temporarily using taskmanager.memory.network.batch-shuffle-read.size in
>> my PR now. Any suggestions about that?
>>
>> Best,
>> Yingjie (Kevin)
>>
>> --
>> 发件人：Guowei Ma
>> 日 期：2021年03月09日 17:28:35
&g
Guowei Ma created FLINK-21900:
-
Summary: flink-statebackend-rocksdb test core dump
Key: FLINK-21900
URL: https://issues.apache.org/jira/browse/FLINK-21900
Project: Flink
Issue Type: Bug
Guowei Ma created FLINK-21898:
-
Summary: JobRetrievalITCase crash
Key: FLINK-21898
URL: https://issues.apache.org/jira/browse/FLINK-21898
Project: Flink
Issue Type: Bug
Components
Guowei Ma created FLINK-21897:
-
Summary: CalcITCase.testPrimitiveMapType[StateBackend=HEAP] fail
because of "Not enough resources available for scheduling"
Key: FLINK-21897
URL: https://issues.apache.org/j
Guowei Ma created FLINK-21896:
-
Summary: GroupAggregateJsonPlanTest.testDistinctAggCalls fail
Key: FLINK-21896
URL: https://issues.apache.org/jira/browse/FLINK-21896
Project: Flink
Issue Type
Guowei Ma created FLINK-21895:
-
Summary: IncrementalAggregateJsonPlanTest.testIncrementalAggregate
fail
Key: FLINK-21895
URL: https://issues.apache.org/jira/browse/FLINK-21895
Project: Flink
Guowei Ma created FLINK-21853:
-
Summary: Running HA per-job cluster (rocks, non-incremental)
end-to-end test could not finished in 900 seconds
Key: FLINK-21853
URL: https://issues.apache.org/jira/browse/FLINK-21853
Guowei Ma created FLINK-21835:
-
Summary: RocksDBStateBackendReaderKeyedStateITCase fail
Key: FLINK-21835
URL: https://issues.apache.org/jira/browse/FLINK-21835
Project: Flink
Issue Type: Bug
Guowei Ma created FLINK-21834:
-
Summary:
org.apache.flink.core.fs.AbstractRecoverableWriterTest.testResumeWithWrongOffset
fail
Key: FLINK-21834
URL: https://issues.apache.org/jira/browse/FLINK-21834
Guowei Ma created FLINK-21832:
-
Summary: Avro Confluent Schema Registry nightly end-to-end fail
Key: FLINK-21832
URL: https://issues.apache.org/jira/browse/FLINK-21832
Project: Flink
Issue
Guowei Ma created FLINK-21809:
-
Summary: PyFlink end-to-end test fail
Key: FLINK-21809
URL: https://issues.apache.org/jira/browse/FLINK-21809
Project: Flink
Issue Type: Bug
Components
Guowei Ma created FLINK-21780:
-
Summary: SourceStreamTaskTest hangs (no output for 900 seconds)
Key: FLINK-21780
URL: https://issues.apache.org/jira/browse/FLINK-21780
Project: Flink
Issue Type
Guowei Ma created FLINK-21779:
-
Summary:
testResourceCanBeAllocatedForDifferentJobWithDeclarationBeforeSlotFree fail
because of timeout
Key: FLINK-21779
URL: https://issues.apache.org/jira/browse/FLINK-21779
Guowei Ma created FLINK-21740:
-
Summary: CliTableauResultViewTest.testCancelBatchResult fails
Key: FLINK-21740
URL: https://issues.apache.org/jira/browse/FLINK-21740
Project: Flink
Issue Type
Guowei Ma created FLINK-21729:
-
Summary: SimpleRecoveryFailureRateStrategyITBase fail
Key: FLINK-21729
URL: https://issues.apache.org/jira/browse/FLINK-21729
Project: Flink
Issue Type: Bug
Guowei Ma created FLINK-21728:
-
Summary: DegreesWithExceptionITCase crash
Key: FLINK-21728
URL: https://issues.apache.org/jira/browse/FLINK-21728
Project: Flink
Issue Type: Bug
han Ewen
> 抄 送：dev; user; Xintong Song<
> tonysong...@gmail.com>; 曹英杰(北牧); Guowei Ma<
> guowei@gmail.com>
> 主 题：Re: [DISCUSSION] Introduce a separated memory pool for the TM merge
> shuffle
>
> Thanks for this proposal Guowei. +1 for it.
>
> Concerning the defaul
Guowei Ma created FLINK-21677:
-
Summary:
org.apache.flink.test.state.operator.restore.unkeyed.ChainBreakTest hangs
Key: FLINK-21677
URL: https://issues.apache.org/jira/browse/FLINK-21677
Project: Flink
Guowei Ma created FLINK-21659:
-
Summary: Running HA per-job cluster (rocks, incremental)
end-to-end test fails
Key: FLINK-21659
URL: https://issues.apache.org/jira/browse/FLINK-21659
Project: Flink
Guowei Ma created FLINK-21654:
-
Summary:
YARNSessionCapacitySchedulerITCase.testStartYarnSessionClusterInQaTeamQueue
fail because of NullPointerException
Key: FLINK-21654
URL: https://issues.apache.org/jira/browse
Guowei Ma created FLINK-21653:
-
Summary:
org.apache.flink.streaming.scala.api.TextOutputFormatITCase.testPath failed
because of "Not enough resources available for scheduling."
Key: FLINK-21653
Guowei Ma created FLINK-21652:
-
Summary:
Elasticsearch6DynamicSinkITCase.testWritingDocumentsFromTableApi failed because
of throwing SocketTimeOut Exception during closing stage.
Key: FLINK-21652
URL: https
Guowei Ma created FLINK-21644:
-
Summary: Resuming Savepoint (rocks, scale up, heap timers)
end-to-end test failed
Key: FLINK-21644
URL: https://issues.apache.org/jira/browse/FLINK-21644
Project: Flink
Hi, all
In the Flink 1.12 we introduce the TM merge shuffle. But the out-of-the-box
experience of using TM merge shuffle is not very good. The main reason is
that the default configuration always makes users encounter OOM [1]. So we
hope to introduce a managed memory pool for TM merge shuffle to
Guowei Ma created FLINK-21600:
-
Summary: Resuming Savepoint (rocks, no parallelism change, heap
timers) end-to-end test failed
Key: FLINK-21600
URL: https://issues.apache.org/jira/browse/FLINK-21600
Guowei Ma created FLINK-21599:
-
Summary: execute[Parallel union, p =
10](org.apache.flink.test.checkpointing.UnalignedCheckpointITCase) failed
because of oom.
Key: FLINK-21599
URL: https://issues.apache.org/jira
Guowei Ma created FLINK-21598:
-
Summary: testDetachedModeSecureWithPreInstallKeytab fail
Key: FLINK-21598
URL: https://issues.apache.org/jira/browse/FLINK-21598
Project: Flink
Issue Type: Bug
Guowei Ma created FLINK-21597:
-
Summary: testMapAfterRepartitionHasCorrectParallelism2 Fail
because of "NoResourceAvailableException"
Key: FLINK-21597
URL: https://issues.apache.org/jira/browse/F
Guowei Ma created FLINK-21596:
-
Summary:
CheckpointFailureManagerITCase.testAsyncCheckpointFailureTriggerJobFailed fail
Key: FLINK-21596
URL: https://issues.apache.org/jira/browse/FLINK-21596
Project
Guowei Ma created FLINK-21595:
-
Summary: DispatcherResourceManagerComponent.deregisterApplication
time-out
Key: FLINK-21595
URL: https://issues.apache.org/jira/browse/FLINK-21595
Project: Flink
Guowei Ma created FLINK-21593:
-
Summary: RocksDBListStatePerformanceTest.testRocksDbListStateAPI
fail because of timeout
Key: FLINK-21593
URL: https://issues.apache.org/jira/browse/FLINK-21593
Project
Guowei Ma created FLINK-21574:
-
Summary:
WindowDistinctAggregateITCase.testCumulateWindow_GroupingSets unstable
Key: FLINK-21574
URL: https://issues.apache.org/jira/browse/FLINK-21574
Project: Flink
Guowei Ma created FLINK-21551:
-
Summary: FlinkKafkaProducerITCase.testHappyPath fail
Key: FLINK-21551
URL: https://issues.apache.org/jira/browse/FLINK-21551
Project: Flink
Issue Type: Bug
Guowei Ma created FLINK-21550:
-
Summary: ZooKeeperHaServicesTest.testSimpleClose fail
Key: FLINK-21550
URL: https://issues.apache.org/jira/browse/FLINK-21550
Project: Flink
Issue Type: Bug
Guowei Ma created FLINK-21508:
-
Summary: CollectITCase hangs
Key: FLINK-21508
URL: https://issues.apache.org/jira/browse/FLINK-21508
Project: Flink
Issue Type: Bug
Components: API
Guowei Ma created FLINK-21497:
-
Summary:
FileSourceTextLinesITCase.testBoundedTextFileSourceWithJobManagerFailover fail
Key: FLINK-21497
URL: https://issues.apache.org/jira/browse/FLINK-21497
Project
on a shut down model
> which has not been fully understood/agreed upon.
>
> [1] https://issues.apache.org/jira/browse/FLINK-21133
>
> Cheers,
> Till
>
> On Tue, Feb 16, 2021 at 9:45 AM Guowei Ma wrote:
>
> > Thanks Yun for the detailed explanation.
> >
Congratulations Wei and Xingbo!
Best,
Guowei
On Wed, Feb 24, 2021 at 9:21 AM Zhu Zhu wrote:
> Congratulations Wei and Xingbo!
>
> Thanks,
> Zhu
>
> Zhijiang 于2021年2月23日周二 上午10:59写道：
>
> > Congratulations Wei and Xingbo!
> >
> >
> > Best,
> > Zhijiang
> >
> >
> > --
Guowei Ma created FLINK-21470:
-
Summary: testSafetyNetClose fail
Key: FLINK-21470
URL: https://issues.apache.org/jira/browse/FLINK-21470
Project: Flink
Issue Type: Bug
Components: API
Guowei Ma created FLINK-21447:
-
Summary: Resuming Savepoint (file, async, scale up) end-to-end
test Fail
Key: FLINK-21447
URL: https://issues.apache.org/jira/browse/FLINK-21447
Project: Flink
Guowei Ma created FLINK-21446:
-
Summary: KafkaProducerTestBase.testExactlyOnce Fail
Key: FLINK-21446
URL: https://issues.apache.org/jira/browse/FLINK-21446
Project: Flink
Issue Type: Bug
Guowei Ma created FLINK-21431:
-
Summary: UpsertKafkaTableITCase.testTemporalJoin hang
Key: FLINK-21431
URL: https://issues.apache.org/jira/browse/FLINK-21431
Project: Flink
Issue Type: Bug
Guowei Ma created FLINK-21429:
-
Summary:
JsonFileCompactionITCase>CompactionITCaseBase.testNonPartition
Key: FLINK-21429
URL: https://issues.apache.org/jira/browse/FLINK-21429
Project: Fl
Guowei Ma created FLINK-21428:
-
Summary:
DeclarativeSchedulerSlotSharingITCase.testSchedulingOfJobRequiringSlotSharing
fail
Key: FLINK-21428
URL: https://issues.apache.org/jira/browse/FLINK-21428
Congratulations Roman!
Best,
Guowei
On Thu, Feb 11, 2021 at 3:37 PM Yun Tang wrote:
> Congratulations, Roman!
>
> Today is also the beginning of Chinese Spring Festival holiday, at which
> we Chinese celebrate across the world for the next lunar new year, and also
> very happy to have you on bo
Thanks Yun for the detailed explanation.
A simple supplementary explanation about the sink case: Maybe we could use
`OperatorCoordinator` to avoid sending the element to the downstream
operator.
But I agree we could not limit the users not to emit records in the
`notiyCheckpointComplete`.
Best,
Gu
Guowei Ma created FLINK-21318:
-
Summary: ExecutionContextTest.testCatalogs fail
Key: FLINK-21318
URL: https://issues.apache.org/jira/browse/FLINK-21318
Project: Flink
Issue Type: Bug
Guowei Ma created FLINK-21316:
-
Summary: E2E tests exceed 250 minutes.
Key: FLINK-21316
URL: https://issues.apache.org/jira/browse/FLINK-21316
Project: Flink
Issue Type: Bug
Components
Guowei Ma created FLINK-21275:
-
Summary: DataStreamTests::test_key_by_on_connect_stream Fail
Key: FLINK-21275
URL: https://issues.apache.org/jira/browse/FLINK-21275
Project: Flink
Issue Type
Guowei Ma created FLINK-21272:
-
Summary: Resuming Savepoint (rocks, scale down, rocks timers)
end-to-end test' Fail
Key: FLINK-21272
URL: https://issues.apache.org/jira/browse/FLINK-21272
Project:
Guowei Ma created FLINK-21244:
-
Summary: shouldPerformUnalignedCheckpointOnLocalAndRemoteChannel
Fail
Key: FLINK-21244
URL: https://issues.apache.org/jira/browse/FLINK-21244
Project: Flink
Thanks to ZhiLong for improving the scheduler's performance.
I think many users would benefit from your work!
Best,
Guowei
On Wed, Feb 3, 2021 at 2:04 AM Till Rohrmann wrote:
> Thanks for making the community aware of these performance improvements,
> Zhilong. I like them and I am looking forwa
Guowei Ma created FLINK-21235:
-
Summary:
leaderChange_withBlockingJobManagerTermination_doesNotAffectNewLeader hang
Key: FLINK-21235
URL: https://issues.apache.org/jira/browse/FLINK-21235
Project: Flink
Guowei Ma created FLINK-21234:
-
Summary: testKafkaSourceSinkWithKeyAndPartialValue[legacy = false,
format = csv] hang
Key: FLINK-21234
URL: https://issues.apache.org/jira/browse/FLINK-21234
Project
101 - 200 of 344 matches
Mail list logo
