[ 
https://issues.apache.org/jira/browse/FLINK-22134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17319811#comment-17319811
 ] 

Xintong Song commented on FLINK-22134:
--------------------------------------

Thanks for the quick response, [~rmetzger].
{quote}B1: This is documented as a limitation
{quote}
True. I've only gone through the docs for Reactive Mode but not yet for 
Adaptive Scheduler. It does mention that limitations for the adaptive scheduler 
also apply to the reactive mode.

 
{quote}B2: If you just enable reactive mode, the resource stabilization timeout 
should automatically be set to 0, and you shouldn't see these issues.
{quote}
Good point. I think it's still good to decrease the rescaling downtime when the 
stabilization timeout is set. However, since this is by default 0, maybe it's 
not that critical to fix for this release.
{quote}L1: This should have been fixed by FLINK-21558 already [~chesnay] can 
you take a look? UPDATE: I looked at the code, and the logs and thing are 
behaving as expected: On every resource change, we are logging this statement. 
If we get more feedback on this log message, we need to consider adding a 
toggle for reactive mode to disable this log statement?!
{quote}
I think that fix is included in the snapshot that I tested. Attaching the log 
file. [^flink-xtsong-standalonejob-1-xtsong-mac.log] 

 

> Test the reactive mode
> ----------------------
>
>                 Key: FLINK-22134
>                 URL: https://issues.apache.org/jira/browse/FLINK-22134
>             Project: Flink
>          Issue Type: Test
>          Components: Runtime / Coordination
>    Affects Versions: 1.13.0
>            Reporter: Till Rohrmann
>            Assignee: Xintong Song
>            Priority: Blocker
>              Labels: release-testing
>             Fix For: 1.13.0
>
>         Attachments: flink-xtsong-standalonejob-1-xtsong-mac.log, 
> 截屏2021-04-12 上午10.30.25.png, 截屏2021-04-12 上午10.32.50.png
>
>
> The newly introduced reactive mode (FLINK-10407) allows Flink to make use of 
> newly arriving resources while the job is running. The feature documentation 
> with the current set of limitations can be found here [1].
> In order to test this new feature I recommend to follow the documentation and 
> to try it out wrt the stated limitations. Everything which is not explicitly 
> contained in the set of limitations should work.
> [1] 
> https://ci.apache.org/projects/flink/flink-docs-master/docs/deployment/elastic_scaling/



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

Reply via email to