Re: error in Elasticsearch

[alaa]

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/

Re: error in Elasticsearch

[alaa]

 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 LocalStreamEnvironment

[alaa]

thank for your reply but Unfortunately this solution is not suitable


 



--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/

No field appear in Time Field name in Kibana

[alaa]

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 ?


 



--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/

error in LocalStreamEnvironment

[alaa]

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 ?



 




--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/

Pramaters in eclipse with Flink

[alaa]

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 where i should put the following parameters:

-local (to specify running Flink locally, versus on a real cluster)
-input  (e.g.
/path/to/flink-streaming-kmeans/src/test/resources/citibike-20180801-min.tsv)
-accesstoken 
-clusters  (5 or 10 are good values)
-queryable (to enable calls to the API, on port 8085).

Thank you



--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/

add laplace to k means

[alaa]

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 to data item when calculate a new cluster center
in each iteration .

for j=1 ---> p do 
u' = (sum +Lap(ε))/(num+Laplace(ε))

I have already write Laplace function , but i don't Know how to add it in k
means code and in which line i should write it .

Thank you




--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/

privacy preserving on streaming Kmeans in Flink

[alaa]

*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 anybody know , can you please explain some of the key steps that I have
to follow?*



--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/

Re: Reading csv file

[alaa]

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/

Re: Reading csv file

[alaa]

So , What I should do 



--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/

Re: Reading csv file

[alaa]

So what should i do ?



--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/

Reading csv file

[alaa]

Hi,

I am following the Taxi example provided on
"http://training.data-artisans.com/exercises/taxiData.html;, however, I got
the following error message when I run AreasTotalPerHour.java at my Intellij
IDE.


<http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/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/