Note that sortPartition is implemented in 0.9. Following link shows the example
of sortPartition.
http://ci.apache.org/projects/flink/flink-docs-master/apis/dataset_transformations.html#sort-partition
Regards,
Chiwan Park
> On Jun 2, 2015, at 5:51 PM, hagersaleh wrote:
>
> I want example for
I run flink program in ubuntu x64 Single Node Cluster
I want run flink program in ubuntu x64 Mult Node Cluster
what is configuration for run program in Mult Node?
--
View this message in context:
http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/I-want-run-flink-program-in-u
I would recommend using HDFS.
For that, you need to specify the paths like this: hdfs:///path/to/data.
On Tue, Jun 2, 2015 at 2:48 PM, Pa Rö
wrote:
> nice,
>
> which file system i must use for the cluster? java.io or hadoop.fs or
> flink?
>
> 2015-06-02 14:29 GMT+02:00 Robert Metzger :
>
>> Hi,
nice,
which file system i must use for the cluster? java.io or hadoop.fs or flink?
2015-06-02 14:29 GMT+02:00 Robert Metzger :
> Hi,
> you can start Flink on YARN on the Cloudera distribution.
>
> See here for more:
> http://ci.apache.org/projects/flink/flink-docs-master/setup/yarn_setup.html
>
Hi,
you can start Flink on YARN on the Cloudera distribution.
See here for more:
http://ci.apache.org/projects/flink/flink-docs-master/setup/yarn_setup.html
These are the commands you need to execute
wget
http://stratosphere-bin.s3-website-us-east-1.amazonaws.com/flink-0.9-SNAPSHOT-bin-hadoop2.
hi community,
i want test my flink k-means on a hadoop cluster. i use the cloudera live
distribution. how i can run flink on this cluster? maybe only the java
dependencies are engouth?
best regards,
paul
I want example for use sortPartition()
--
View this message in context:
http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/why-when-use-groupBy-2-sortGroup-0-Order-DESCENDING-not-group-by-and-not-sort-tp1436p1439.html
Sent from the Apache Flink User Mailing List archive. maili
