Great to hear :-)
On Thu, Jan 21, 2016 at 4:55 PM, HungChang
wrote:
> After adding the dependency it totally works! Thank you a lot!
>
>
>
> --
> View this message in context:
> http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Cannot-start-FlinkMiniCluster-WebServer-using-diff
After adding the dependency it totally works! Thank you a lot!
--
View this message in context:
http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Cannot-start-FlinkMiniCluster-WebServer-using-different-port-in-FlinkMiniCluster-tp4414p4455.html
Sent from the Apache Flink User M
Could you add flink-runtime-web to your dependencies of your project? It
seems as if it is missing in your project.
Cheers,
Till
On Thu, Jan 21, 2016 at 4:45 PM, HungChang
wrote:
> The following message is obtained after putting
> BasicConfigurator.configure()
> in main();
> But I don't under
The following message is obtained after putting BasicConfigurator.configure()
in main();
But I don't understand the reason `flink-runtime-web is not in the
classpath`.
For me the strange part is using the scala version works well whereas my
java version throws exception.
1413 [main] ERROR org.apa
Thanks for your reply.
Yea I'm not sure how to use WebMonitor. For me it's about to write the log
into a file in disk that should go to the job manager originally at
localhost:8081.
Could you please give an brief example how to use it?
Best,
Sendoh
--
View this message in context:
http://
leaderRetrievalService will retrieve the leading JobManager. Take a look at
LeaderRetrievalUtils in order to see how it is created and what options are
supported. actorSystem is the ActorSystem which is used to resolve the
leader’s Akka URL into an ActorRef. You can simply create one or use an
exis
Thanks for your suggestion. I have some questions to start WebRuntimeMonitor.
In startWebRuntimeMonitor what should be called for
- leaderRetrievalService: LeaderRetrievalService,
- actorSystem: ActorSystem ?
My ref:
(https://ci.apache.org/projects/flink/flink-docs-master/api/java/org/
I think this null pointer comes when the log files are not found (bug in
0.10).
You can double check by either trying 1.0-SNAPSHOT or putting for test an
absolute path of a file that exists for the log file.
Greetings,
Stephan
On Wed, Jan 20, 2016 at 6:33 PM, Till Rohrmann wrote:
> I guess it’
I guess it’s easiest to simply enable logging and see what the problem is.
If you run it from the IDE then you can also set a breakpoint in
WebMonitorUtils.startWebRuntimeMonitor and see what the exception is.
Cheers,
Till
On Wed, Jan 20, 2016 at 6:04 PM, HungChang
wrote:
> Yea I'm wondering
Yea I'm wondering why the web server cannot be instantiated because changing
the port 8081 to works well in the following demo sample of Flink.
https://github.com/dataArtisans/flink-streaming-demo/blob/master/src/main/scala/com/dataartisans/flink_demo/utils/DemoStreamEnvironment.scala
so is t
It seems that the web server could not been instantiated. The reason for
this problem should be in your logs. Could you look it up and post the
reason here?
Additionally, we should build in a sanity check to avoid the NPE.
Cheers,
Till
On Wed, Jan 20, 2016 at 5:06 PM, HungChang
wrote:
> The or
The original port is used so I'm changing the web port but it fails to. Can I
ask which part I made a mistake?
The error:
Exception in thread "main" java.lang.NullPointerException
at
org.apache.flink.runtime.minicluster.FlinkMiniCluster.startWebServer(FlinkMiniCluster.scala:295)
at
org.ap
12 matches
Mail list logo
