Re: Submitting job via Flink web interface giving Null pointer exception

the web interface with the values used for > submission. > You are running Flink standalone or over Yarn ? > > Best, > Abhi > > From: Ritesh Kumar Singh > Reply-To: "user@flink.apache.org" > Date: Wednesday, June 1, 2016 at 11:11 AM > To: "user@flink.apa

Submitting job via Flink web interface giving Null pointer exception

d line and from an eclipse environment. Is it some sort of bug that is already known or are there some adjustments that need to be done before uploading the jar? Thanks, -- Ritesh Kumar Singh https://riteshtoday.wordpress.com/

Re: Performing Reduce on a group of datasets

signature. And so is that line supposed to mean something else? Or is it a feature not supported by flink 0.8 but works with future releases? Thanks, -- Ritesh Kumar Singh https://riteshtoday.wordpress.com/

Performing Reduce on a group of datasets

rks on a single dataset at a time and I can't find any other methods that take multiple datasets as an input parameter. Thanks, -- Ritesh Kumar Singh https://riteshtoday.wordpress.com/

Access Flink UI for jobs submitted using Eclipse

Hi, Just a basic question, I am using flink via eclipse but when I execute my jobs, I can't access it via the web dashboard. It's basically a maven project and so I've added all the flink jars in my pom file and I'm executing my code by getting the execution environment as follows: ExecutionEnvir

Re: Accessing RDF triples using Flink

regarding this will be helpful. Regards, Ritesh Ritesh Kumar Singh [image: https://]about.me/riteshoneinamillion <https://about.me/riteshoneinamillion?promo=email_sig&utm_source=email_sig&utm_medium=email_sig&utm_campaign=external_links> On Wed, Apr 6, 2016 at 2:45 PM, Flavio

Accessing RDF triples using Flink

Hi, I need some suggestions regarding accessing RDF triples from flink. I'm trying to integrate flink in a pipeline where the input for flink comes from SPARQL query on a Jena model. And after modification of triples using flink, I will be performing SPARQL update using Jena to save my changes.

Re: Task Manager metrics per job on Flink 0.9.1

I didn't know these stats were collected. Thanks for telling :) In that case, it should definitely be a feature which can be enabled via config files. *Ritesh Kumar Singh,* *https://riteshtoday.wordpress.com/* <https://riteshtoday.wordpress.com/> On Tue, Jan 26, 2016 at 8:22 PM, Pie

Re: Task Manager metrics per job on Flink 0.9.1

ing to store these metrics will degrade the performance of jobs too. And so its basically a trade off between performance and computation cost. For me, the web ui hangs even for the current set of parameters :( *Ritesh Kumar Singh,* *https://riteshtoday.wordpress.com/* <https://riteshtoday.word

Re: Compile fails with scala 2.11.4

Thanks for the update Robert, I tried it out and it works fine for scala_2.11.4 version. I've made a docker image <https://hub.docker.com/r/gonephishing/flink_0.10.1-scala-2.11.4/> of the same and put it up on the hub just in case anyone else needs it. Thanks, *Ritesh Kumar Sin

Re: Actual byte-streams in multiple-node pipelines

I think with sufficient processing power flink can do the above mentioned task using the stream api <https://ci.apache.org/projects/flink/flink-docs-master/apis/streaming/index.html> . Thanks, *Ritesh Kumar Singh,* *https://riteshtoday.wordpress.com/* <https://riteshtoday.wordpress.com/

Re: Compile fails with scala 2.11.4

$mvn clean install -DskipTests -Dscala.version=2.11.4 I hope I'm doing it right ? Thanks, *Ritesh Kumar Singh,* *https://riteshtoday.wordpress.com/* <https://riteshtoday.wordpress.com/> On Mon, Jan 18, 2016 at 12:03 PM, Robert Metzger wrote: > How did start the Flink for Sca

Compile fails with scala 2.11.4

-java . SUCCESS [ 10.224 s] [INFO] flink-runtime .. FAILURE [01:23 min] [INFO] flink-optimizer SKIPPED Any workaround for scala_2.11.4 or do I have to switch back to scala_2.10.4 ? Thanks, *Ritesh Kumar Singh,* *