You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/05/07 12:49:00 UTC

[jira] [Commented] (FLINK-9073) Resume from savepoint end-to-end tests should be extended for different state backends

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

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

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

    https://github.com/apache/flink/pull/5926#discussion_r186412353
  
    --- Diff: flink-end-to-end-tests/run-nightly-tests.sh ---
    @@ -58,25 +58,97 @@ fi
     
     if [ $EXIT_CODE == 0 ]; then
       printf "\n==============================================================================\n"
    -  printf "Running Resuming Savepoint (no parallelism change) end-to-end test\n"
    +  printf "Running Resuming Savepoint (file, async, no parallelism change) end-to-end test\n"
       printf "==============================================================================\n"
    -  $END_TO_END_DIR/test-scripts/test_resume_savepoint.sh 2 2
    +  STATE_BACKEND_TYPE=file STATE_BACKEND_FILE_ASYNC=true $END_TO_END_DIR/test-scripts/test_resume_savepoint.sh 2 2
       EXIT_CODE=$?
     fi
     
     if [ $EXIT_CODE == 0 ]; then
       printf "\n==============================================================================\n"
    -  printf "Running Resuming Savepoint (scale up) end-to-end test\n"
    +  printf "Running Resuming Savepoint (file, sync, no parallelism change) end-to-end test\n"
       printf "==============================================================================\n"
    -  $END_TO_END_DIR/test-scripts/test_resume_savepoint.sh 2 4
    +  STATE_BACKEND_TYPE=file STATE_BACKEND_FILE_ASYNC=false $END_TO_END_DIR/test-scripts/test_resume_savepoint.sh 2 2
       EXIT_CODE=$?
     fi
     
     if [ $EXIT_CODE == 0 ]; then
       printf "\n==============================================================================\n"
    -  printf "Running Resuming Savepoint (scale down) end-to-end test\n"
    +  printf "Running Resuming Savepoint (file, async, scale up) end-to-end test\n"
       printf "==============================================================================\n"
    -  $END_TO_END_DIR/test-scripts/test_resume_savepoint.sh 4 2
    +  STATE_BACKEND_TYPE=file STATE_BACKEND_FILE_ASYNC=true $END_TO_END_DIR/test-scripts/test_resume_savepoint.sh 2 4
    +  EXIT_CODE=$?
    +fi
    +
    +if [ $EXIT_CODE == 0 ]; then
    +  printf "\n==============================================================================\n"
    +  printf "Running Resuming Savepoint (file, sync, scale up) end-to-end test\n"
    +  printf "==============================================================================\n"
    +  STATE_BACKEND_TYPE=file STATE_BACKEND_FILE_ASYNC=false $END_TO_END_DIR/test-scripts/test_resume_savepoint.sh 2 4
    +  EXIT_CODE=$?
    +fi
    +
    +if [ $EXIT_CODE == 0 ]; then
    +  printf "\n==============================================================================\n"
    +  printf "Running Resuming Savepoint (file, async, scale down) end-to-end test\n"
    +  printf "==============================================================================\n"
    +  STATE_BACKEND_TYPE=file STATE_BACKEND_FILE_ASYNC=true $END_TO_END_DIR/test-scripts/test_resume_savepoint.sh 4 2
    +  EXIT_CODE=$?
    +fi
    +
    +if [ $EXIT_CODE == 0 ]; then
    +  printf "\n==============================================================================\n"
    +  printf "Running Resuming Savepoint (file, sync, scale down) end-to-end test\n"
    +  printf "==============================================================================\n"
    +  STATE_BACKEND_TYPE=file STATE_BACKEND_FILE_ASYNC=false $END_TO_END_DIR/test-scripts/test_resume_savepoint.sh 4 2
    +  EXIT_CODE=$?
    +fi
    +
    +if [ $EXIT_CODE == 0 ]; then
    +  printf "\n==============================================================================\n"
    +  printf "Running Resuming Savepoint (rocks, non-incremental, no parallelism change) end-to-end test\n"
    +  printf "==============================================================================\n"
    +  STATE_BACKEND_TYPE=rocks STATE_BACKEND_ROCKS_INCREMENTAL=false $END_TO_END_DIR/test-scripts/test_resume_savepoint.sh 2 2
    +  EXIT_CODE=$?
    +fi
    +
    +if [ $EXIT_CODE == 0 ]; then
    +  printf "\n==============================================================================\n"
    +  printf "Running Resuming Savepoint (rocks, incremental, no parallelism change) end-to-end test\n"
    +  printf "==============================================================================\n"
    +  STATE_BACKEND_TYPE=rocks STATE_BACKEND_ROCKS_INCREMENTAL=true $END_TO_END_DIR/test-scripts/test_resume_savepoint.sh 2 2
    --- End diff --
    
    Taking savepoints is not different between incremental and non-incremental RocksDB, so all those incremental tests do essentially the same. While it does not hurt to test them in a strict sense, we might save some time by dropping the incremental case. Or maybe we can keep just one (incremental, no resscale) and drop all incremental rescalings because they currently add nothing to the test coverage.


> Resume from savepoint end-to-end tests should be extended for different state backends
> --------------------------------------------------------------------------------------
>
>                 Key: FLINK-9073
>                 URL: https://issues.apache.org/jira/browse/FLINK-9073
>             Project: Flink
>          Issue Type: Sub-task
>            Reporter: Tzu-Li (Gordon) Tai
>            Assignee: Tzu-Li (Gordon) Tai
>            Priority: Blocker
>             Fix For: 1.6.0
>
>
> The resuming from savepoint end-to-end test script, {{test_resume_savepoint}} should be extended for the different state backends.



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