How to unsubscribe the Apache projects and jira issues notification

Hi Following blogs want to unsubscribe kindly guide. I tried from google..still mails receiving Also should unubscribe.. j...@apache.org u...@flink.apache.org dev@flink.apache.org d...@beam.apache.org u...@beamho.apache.org Thanks

"Unable to find registrar for hdfs" on Flink cluster

Hi All, build jar file from the beam quickstart. while run the jar on Flinkcluster got below error.? anybody got this error? Could you please help how to resolve this? root1@master:~/NAI/Tools/flink-1.3.0$ *bin/flink run -c org.apache.beam.examples.WordCount /home/root1/NAI/Tools/word-count-beam

Re: Not able to run beam appliction on Flink cluster environment

gt; > do you have the logs of the Flink master running at 192.168.56.1:6123? > > Cheers, > Till > > On Tue, Aug 22, 2017 at 2:43 PM, P. Ramanjaneya Reddy < > ramanji...@gmail.com> > wrote: > > > Hi All, > > > > We followed the steps mentinoned in

Not able to run beam appliction on Flink cluster environment

Hi All, We followed the steps mentinoned in below link to setup flink cluster (Standalone) *https://ci.apache.org/projects/flink/flink-docs-release-1.2/setup/cluster_setup.html * In the same cluster we are able

How to access HDFS file from flink

Hi All, As I'm running worcount program in flink cluster. and i have created HDFS cluster env to access file sytem. but can you please help how to access the file system from HDFS. root1@master:~/NAI/Tools/BEAM/Flink_Cluster/rama/flink$ bin/flink run ./examples/streaming/WordCount.jar *--input hd

Re: How to run wordcount program on Multi-node Cluster.

at 3:48 PM, P. Ramanjaneya Reddy wrote: > Yes Felix, > > I have created input and output files in HDFS. > http://localhost:50070/explorer.html#/user > > > But how we can access it ? > > bin/flink run ./examples/streaming/WordCount.jar --input > *hdfs:///user/wordcou

Re: How to run wordcount program on Multi-node Cluster.

:55 PM, Felix Neutatz wrote: > Hi, > > like Timo said e.g. you need a distributed filesystem like HDFS. > > Best regards, > Felix > > On Aug 8, 2017 09:01, "P. Ramanjaneya Reddy" wrote: > > Hi Timo, > > How to make access the files across TM? >

Re: How to run wordcount program on Multi-node Cluster.

ssed from all nodes. > > Each TM has a log directory where the execution logs are stored. > > You can set additional properties to your output format by importing the > code in your IDE. > > Am 07.08.17 um 16:03 schrieb P. Ramanjaneya Reddy: > > Hi Timo, >> Problem

Re: How to run wordcount program on Multi-node Cluster.

run(Thread.java:745) On Mon, Aug 7, 2017 at 6:49 PM, Timo Walther wrote: > Make sure that the file exists and is accessible from all Flink tasks > managers. > > > Am 07.08.17 um 14:35 schrieb P. Ramanjaneya Reddy: > >> Thank you Timo. >> >> >> root1@root1-HP-

Re: How to run wordcount program on Multi-node Cluster.

er questions. > > Regards, > Timo > > > Am 07.08.17 um 14:00 schrieb P. Ramanjaneya Reddy: > > Hello Everyone, >> >> I have followed the steps specified below link to Install & Run Apache >> Flink on Multi-node Cluster. >> >> http://

How to run wordcount program on Multi-node Cluster.

Hello Everyone, I have followed the steps specified below link to Install & Run Apache Flink on Multi-node Cluster. http://data-flair.training/blogs/install-run-deploy-flink-multi-node-cluster/ used flink-1.3.2-bin-hadoop27-scala_2.10.tgz for install using the command " bin/flink run /home/roo

Issue adding new IO(InfluxDB) with coder in Apache flink

Hi Dev, We have developed our own sdk io functions for read/write InfluxDBIO operations in apache BEAM. it is works with default coder, which is StringUtf8Coder.of(). PCollection output = pipeline.apply( InfluxDbIO.read() .withUri("http://localhost:8086";)