You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@helix.apache.org by al...@apache.org on 2020/09/23 21:40:21 UTC

[helix] branch master updated: Stabilize the TestJobTimeout (#1398)

This is an automated email from the ASF dual-hosted git repository.

alizamus pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/helix.git


The following commit(s) were added to refs/heads/master by this push:
     new e38799d  Stabilize the TestJobTimeout (#1398)
e38799d is described below

commit e38799da00a60523cc94cc8d8841f6b23024dc1d
Author: Ali Reza Zamani Zadeh Najari <an...@linkedin.com>
AuthorDate: Wed Sep 23 14:40:09 2020 -0700

    Stabilize the TestJobTimeout (#1398)
    
    In this commit, TestJobTimeout has been stabilized by increasing
    the job's timeout. The tasks will get ABORTED if the job is TIMING_OUT
    and the tasks have already been started. Since 10ms is very short, it is
    possible that the job goes to the TIMED_OUT state without tasks being even
    started on the participants. Hence, a longer timeout time will stabilize
    the test.
---
 .../src/test/java/org/apache/helix/integration/task/TestJobTimeout.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/helix-core/src/test/java/org/apache/helix/integration/task/TestJobTimeout.java b/helix-core/src/test/java/org/apache/helix/integration/task/TestJobTimeout.java
index dff26f4..a4d3d18 100644
--- a/helix-core/src/test/java/org/apache/helix/integration/task/TestJobTimeout.java
+++ b/helix-core/src/test/java/org/apache/helix/integration/task/TestJobTimeout.java
@@ -74,7 +74,7 @@ public final class TestJobTimeout extends TaskSynchronizedTestBase {
             .setTargetPartitionStates(Sets.newHashSet(MasterSlaveSMD.States.MASTER.name()))
             .setCommand(MockTask.TASK_COMMAND)
             .setJobCommandConfigMap(ImmutableMap.of(MockTask.JOB_DELAY, "99999999")) // task stuck
-            .setTimeout(10);
+            .setTimeout(2000L);
 
     JobConfig.Builder secondJobBuilder =
         new JobConfig.Builder().setWorkflow(WORKFLOW_NAME).setTargetResource(DB_NAME)