How to start a TaskManager and the Flink Query Interface from Scala IDE (local run configuration)

classic Classic list List threaded Threaded
2 messages Options
Reply | Threaded
Open this post in threaded view
|

How to start a TaskManager and the Flink Query Interface from Scala IDE (local run configuration)

Mihail Vieru
Hi all,

I want to start Flink from the Scala IDE by using a local run configuration similar to one I've used for Stratosphere 0.4.

The entry point for the Scala application is: org.apache.flink.runtime.jobmanager.JobManager
With the program arguments:

--configDir /home/vieru/dev/flink-from-src/flink/flink-dist/target/flink-0.9-SNAPSHOT-bin/flink-0.9-SNAPSHOT/conf --executionMode LOCAL

and JVM arguments:

-Dlog4j.configuration=<a class="moz-txt-link-freetext" href="cid:part1.09060702.08050808@informatik.hu-berlin.de">file:///home/vieru/dev/flink-from-src/flink/flink-dist/target/flink-0.9-SNAPSHOT-bin/flink-0.9-SNAPSHOT/conf/log4j.properties3

The problem is that the TaskManager and the Flink Query Interface don't start with this configuration.
How do I get them running?

Best,
Mihail

################################################################################
#  Licensed to the Apache Software Foundation (ASF) under one
#  or more contributor license agreements.  See the NOTICE file
#  distributed with this work for additional information
#  regarding copyright ownership.  The ASF licenses this file
#  to you under the Apache License, Version 2.0 (the
#  "License"); you may not use this file except in compliance
#  with the License.  You may obtain a copy of the License at
#
#      http://www.apache.org/licenses/LICENSE-2.0
#
#  Unless required by applicable law or agreed to in writing, software
#  distributed under the License is distributed on an "AS IS" BASIS,
#  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
#  See the License for the specific language governing permissions and
# limitations under the License.
################################################################################

# Root logger option
log4j.rootLogger=INFO, stdout
 
# Direct log messages to stdout
log4j.appender.stdout=org.apache.log4j.ConsoleAppender
log4j.appender.stdout.Target=System.out
log4j.appender.stdout.layout=org.apache.log4j.PatternLayout
log4j.appender.stdout.layout.ConversionPattern=%d{yyyy-MM-dd HH:mm:ss} %-5p %c{1}:%L - %m%n
Reply | Threaded
Open this post in threaded view
|

Re: How to start a TaskManager and the Flink Query Interface from Scala IDE (local run configuration)

rmetzger0
Hey,

I think that looks correct. Are you getting any error messages?
Whats the logging level you've configured?


Robert

On Thu, Mar 5, 2015 at 10:35 PM, Mihail Vieru <[hidden email]> wrote:
Hi all,

I want to start Flink from the Scala IDE by using a local run configuration similar to one I've used for Stratosphere 0.4.

The entry point for the Scala application is: org.apache.flink.runtime.jobmanager.JobManager
With the program arguments:

--configDir /home/vieru/dev/flink-from-src/flink/flink-dist/target/flink-0.9-SNAPSHOT-bin/flink-0.9-SNAPSHOT/conf --executionMode LOCAL

and JVM arguments:

-Dlog4j.configuration=file:///home/vieru/dev/flink-from-src/flink/flink-dist/target/flink-0.9-SNAPSHOT-bin/flink-0.9-SNAPSHOT/conf/log4j.properties3

The problem is that the TaskManager and the Flink Query Interface don't start with this configuration.
How do I get them running?

Best,
Mihail