[ 
https://issues.apache.org/jira/browse/FLINK-12800?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

leesf updated FLINK-12800:
--------------------------
    Description: 
Some tests failed when Runtime.getRuntime().availableProcessors() is 1. The 
source vertex and other vertex may chained, thus make test failed. such as 

AsyncWaitOperatorTest#testOperatorChainWithProcessingTime

StreamingJobGraphGeneratorTest#testChainStartEndSetting

StreamOperatorChainingTest#testMultiChainingWithObjectReuse

StreamOperatorChainingTest#testMultiChainingWithoutObjectReuse

DataExchangeModeClosedBranchingTest

 

So we would specify parallelism of vertex directly to let its not chained with 
source .

  was:
Some tests failed when Runtime.getRuntime().availableProcessors() is 1. The 
source vertex and other vertex may chained, thus make test failed. such as 

AsyncWaitOperatorTest#testOperatorChainWithProcessingTime

StreamingJobGraphGeneratorTest#testChainStartEndSetting

StreamOperatorChainingTest#testMultiChainingWithObjectReuse

StreamOperatorChainingTest#testMultiChainingWithoutObjectReuse

 

So we would specify parallelism of vertex directly to let its not chained with 
source .


> Harden Tests when availableProcessors is 1
> ------------------------------------------
>
>                 Key: FLINK-12800
>                 URL: https://issues.apache.org/jira/browse/FLINK-12800
>             Project: Flink
>          Issue Type: Bug
>          Components: Tests
>    Affects Versions: 1.8.0
>            Reporter: leesf
>            Assignee: leesf
>            Priority: Major
>              Labels: pull-request-available
>             Fix For: 1.9.0
>
>          Time Spent: 10m
>  Remaining Estimate: 0h
>
> Some tests failed when Runtime.getRuntime().availableProcessors() is 1. The 
> source vertex and other vertex may chained, thus make test failed. such as 
> AsyncWaitOperatorTest#testOperatorChainWithProcessingTime
> StreamingJobGraphGeneratorTest#testChainStartEndSetting
> StreamOperatorChainingTest#testMultiChainingWithObjectReuse
> StreamOperatorChainingTest#testMultiChainingWithoutObjectReuse
> DataExchangeModeClosedBranchingTest
>  
> So we would specify parallelism of vertex directly to let its not chained 
> with source .



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)

Reply via email to