Leonidas Fegaras created MRQL-47: ------------------------------------ Summary: Fix various bugs for the Flink evaluation mode Key: MRQL-47 URL: https://issues.apache.org/jira/browse/MRQL-47 Project: MRQL Issue Type: Bug Reporter: Leonidas Fegaras Priority: Critical Attachments: MRQL-47.patch
The following patch fixes the Flink backend for evaluating MRQL in distributed mode: 1) it sets the default parallelism to the requested # of nodes 2) it uses HDFS as the default file system for relative paths and the /user/#{user.name} on HDFS as the default root 3) it changes the 'dump to binary file operation' to work with FlinkOutputFormat files directly, without executing a plan -- This message was sent by Atlassian JIRA (v6.2#6252)