Oh, sorry for wrong information. I have misunderstood about `jarFiles` parameter.
Regards, Chiwan Park > On Sep 25, 2015, at 5:27 PM, Fabian Hueske <fhue...@gmail.com> wrote: > > Hi Deng Jie, > > your Flink program needs to be packaged into a JAR file. > The Flink quickstart Maven archetypes for Java [1] and Scala [2] help to > setup a Maven project that packages your program correctly into a JAR file. > > Best, Fabian > > [1] > https://ci.apache.org/projects/flink/flink-docs-release-0.9/quickstart/java_api_quickstart.html > [2] > https://ci.apache.org/projects/flink/flink-docs-release-0.9/quickstart/scala_api_quickstart.html > > 2015-09-25 10:15 GMT+02:00 Deng Jie <smartdeng...@gmail.com>: > Dear Chiwan, > However, 'createRemoteEnvironment' method must specify this parameter. > > -- Best wishes for you > 邓杰 > 15994846535 > > 2015-09-25 13:42 GMT+08:00 Chiwan Park <chiwanp...@apache.org>: > Hi Deng, > > The jarFiles parameter of `createRemoteEnvironment` means that the path of > your custom library jar. If you don’t need custom library, you can omit the > parameter. > > Regards, > Chiwan Park > > > On Sep 25, 2015, at 10:48 AM, Deng Jie <smartdeng...@gmail.com> wrote: > > > > Dear Flink org,i have same question,like: > > public static void main(String[] args) throws Exception { > > > > ExecutionEnvironment env > > = > > ExecutionEnvironment > > > > .createRemoteEnvironment("flink-master", 6123, "/home/user/udfs.jar"); > > > > > > DataSet > > <String> data = env.readTextFile("hdfs://path/to/file"); > > > > > > data > > > > .filter(new FilterFunction<String>() { > > > > > > public boolean filter(String value) { > > > > > > return value.startsWith("http://";); > > > > > > } > > > > > > }) > > > > > > .writeAsText("hdfs://path/to/result"); > > > > > > env > > .execute(); > > } > > > > How to write the file(udfs.jar),can you give me an example?In addition,can > > this parameter as an option? > > > > -- Best wishes for you > > > > >
