[FLINK-2603] Flink hangs before starting execution

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Not A Problem
• Affects Version/s: 0.9.1, 0.10.0
• Component/s: Runtime / Coordination
• Assignee: Unassigned
• Reporter: Greg Hogan
• Created: 01/Sep/15 17:50
• Updated: 02/Oct/19 17:44
• Resolved: 13/Oct/16 16:53

Description

The following simple application created from Flink's Java quickstart will hang before execution if the data size is to large. I have tested this on both 0.9.1 and master (7364ce18) and the threshold occurs with
$ ./bin/flink run /path/to/blocks/target/blocks-1.0-SNAPSHOT.jar 19
running in a few seconds while
$ ./bin/flink run /path/to/blocks/target/blocks-1.0-SNAPSHOT.jar 20
seemingly hangs forever.

I first put this together two months ago so if it is a bug it is not a new bug.

package blocks;

import java.util.ArrayList;
import java.util.List;

import org.apache.flink.api.java.ExecutionEnvironment;
import org.apache.flink.api.java.io.DiscardingOutputFormat;

public class Job {

    public static void main(String[] args) throws Exception {
        // set up the execution environment
        final ExecutionEnvironment env = ExecutionEnvironment.getExecutionEnvironment();

        List<Long> data = new ArrayList<>();

        int count = 1 << Integer.valueOf(args[0]);
        
        for (int i = 0 ; i < count ; i++) {
            data.add(0L);
        }

        env.fromCollection(data).output(new DiscardingOutputFormat());

        System.out.println("Ready to execute ...");
        
        // execute program
        env.execute("Flink Java API Skeleton");
    }
}