Retry product tests on MapRedTask ClosedByInterruptException failures

trinodb · Jan 30, 2023 · d53634d · d53634d
1 parent bd3edaa
commit d53634d
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/testing/trino-product-tests/src/main/java/io/trino/tests/product/utils/HadoopTestUtils.java b/testing/trino-product-tests/src/main/java/io/trino/tests/product/utils/HadoopTestUtils.java
@@ -37,16 +37,19 @@ private HadoopTestUtils() {}
      * Link to issues:
      * <ul>
      *     <ol><a href="https://github.com/trinodb/trino/issues/4936">#4936</a></ol>
+     *     <ol><a href="https://github.com/trinodb/trino/issues/5427">#5427</a></ol>
      * </ul>
      */
-    public static final String RETRYABLE_FAILURES_ISSUES = "https://github.com/trinodb/trino/issues?q=is%3Aissue+issue%3A+4936";
+    public static final String RETRYABLE_FAILURES_ISSUES = "https://github.com/trinodb/trino/issues?q=is%3Aissue+issue%3A+4936+5427";
     @Language("RegExp")
     public static final String RETRYABLE_FAILURES_MATCH =
             // "Error committing write to Hive" is present depending on when the exception is thrown.
             // It may be absent when the underlying problem manifest earlier (e.g. during RecordFileWriter.appendRow vs RecordFileWriter.commit).
             "(could only be replicated to 0 nodes instead of minReplication" +
                     // "could only be written to 0 of the 1 minReplication" is the error wording used by e.g. HDP 3
                     "|could only be written to 0 of the 1 minReplication" +
+                    // "Error while processing statement: FAILED: Execution Error, return code 1 from org.apache.hadoop.hive.ql.exec.mr.MapRedTask. Error caching map.xml: java.nio.channels.ClosedByInterruptException"
+                    "|return code 1 from \\Qorg.apache.hadoop.hive.ql.exec.mr.MapRedTask.\\E Error caching \\S*: \\Qjava.nio.channels.ClosedByInterruptException\\E" +
                     ")";
 
     public static final RetryPolicy<QueryResult> ERROR_COMMITTING_WRITE_TO_HIVE_RETRY_POLICY = new RetryPolicy<QueryResult>()