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;)

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

output files can be > accessed 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

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

:55 PM, Felix Neutatz <neut...@googlemail.com> 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" <ramanji...@gmail.com> wrote: > >

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

at 3:48 PM, P. Ramanjaneya Reddy <ramanji...@gmail.com> 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/Word

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

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

is helps. Feel free to ask further 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. >&g

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 <twal...@apache.org> 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. >> >> &

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

e: > Hi Ramanji, > > 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

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

"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

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