error in LocalStreamEnvironment

Hallo I try to run this example from GitHub https://github.com/dataArtisans/flink-streaming-demo but there was a problem when I try to run it on Flink to see the result on web dashboard Although the code working properly on my Intellj So, how can I solve this problem ?

No field appear in Time Field name in Kibana

I try to run this application but there was problem when Configure an index pattern . There was No field appear in Time Field name in Kibana when i set index name. How can i solve this problem ?

Re: error in LocalStreamEnvironment

thank for your reply but Unfortunately this solution is not suitable -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/

error in Elasticsearch

*Hallo I try to implement this example to write the results of Popular Places into an Elasticsearch index. But when I run a code .. there was some Error appear * * and w

Re: error in Elasticsearch

Hallo I put arguments but the same error appear .. what should i do ? -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/

Re: error in Elasticsearch

Thank for your reply >> I run it >> and I think it run correctly now -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/

Reading csv file

om/file/t1965/Screenshot_from_2019-04-01_08-18-03.png> i just inset the path for csv file in line: System.err.println("/home/alaa/Downloads/sorted_data.csv"); Should i change anything in utils package ?? -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/

Re: Reading csv file

So what should i do ? -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/

Re: Reading csv file

So , What I should do -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/

Re: Reading csv file

Thank you . I have chosen the second option and i think it run correctly now . -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/

privacy preserving on streaming Kmeans in Flink

*I try to make a research in privacy preserving data on streaming k-means clustering and to develop an implementation on Flink. My questions are : If there a library for K means in Flink? Because I didn't see it on FlinkML? How we can I implement streaming kmeans clustering on Flink? If

add laplace to k means

Hallo I have used this k means code on Flink https://github.com/apache/flink/blob/master/flink-examples/flink-examples-batch/src/main/java/org/apache/flink/examples/java/clustering/KMeans.java and I would to add noise that follows Laplace distribution to the sum of data item and to the number

Pramaters in eclipse with Flink

Hallo I run this example form GitHub https://github.com/ScaleUnlimited/flink-streaming-kmeans but I am not familiar with eclipse and i got this error I dont know how and