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

ASF GitHub Bot commented on FLINK-5004:
---------------------------------------

Github user StephanEwen commented on a diff in the pull request:

    https://github.com/apache/flink/pull/2748#discussion_r86535530
  
    --- Diff: 
flink-tests/src/test/java/org/apache/flink/test/query/QueryableStateITCase.java 
---
    @@ -115,8 +115,9 @@ public static void setup() {
                        
config.setInteger(ConfigConstants.TASK_MANAGER_MEMORY_SIZE_KEY, 4);
                        
config.setInteger(ConfigConstants.LOCAL_NUMBER_TASK_MANAGER, NUM_TMS);
                        
config.setInteger(ConfigConstants.TASK_MANAGER_NUM_TASK_SLOTS, 
NUM_SLOTS_PER_TM);
    -                   
config.setInteger(ConfigConstants.QUERYABLE_STATE_CLIENT_NETWORK_THREADS, 1);
    -                   
config.setInteger(ConfigConstants.QUERYABLE_STATE_SERVER_NETWORK_THREADS, 1);
    +                   
config.setInteger(QueryableStateOptions.CLIENT_NETWORK_THREADS.key(), 1);
    --- End diff --
    
    You can drop the `key()` part and directly use the option.


> Add task manager option to disable queryable state server
> ---------------------------------------------------------
>
>                 Key: FLINK-5004
>                 URL: https://issues.apache.org/jira/browse/FLINK-5004
>             Project: Flink
>          Issue Type: Improvement
>          Components: State Backends, Checkpointing
>            Reporter: Ufuk Celebi
>            Assignee: Ufuk Celebi
>
> Add a task manager option to disable starting up the queryable state server. 
> By default it is enabled. The testing cluster should disable it.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

Reply via email to