public static JobExecutionResult tryExecute()

in src/main/java/org/apache/flink/benchmark/functions/TestUtils.java [31:51]

• 18 lines of code
• 5 McCabe index (conditional complexity)

    public static JobExecutionResult tryExecute(StreamExecutionEnvironment see, String name)
            throws Exception {
        try {
            return see.execute(name);
        } catch (ProgramInvocationException | JobExecutionException root) {
            Throwable cause = root.getCause();

            // search for nested SuccessExceptions
            int depth = 0;
            while (!(cause instanceof SuccessException)) {
                if (cause == null || depth++ == 20) {
                    root.printStackTrace();
                    fail("Test failed: " + root.getMessage());
                } else {
                    cause = cause.getCause();
                }
            }
        }

        return null;
    }