Re: Cassamdra Connector in Scala

Hey Jamie, Here's a simple example that I modeled off of the github example ( https://github.com/apache/flink/blob/master/flink-streaming-connectors/flink-connector-cassandra/src/test/java/org/apache/flink/streaming/connectors/cassandra/example/CassandraTupleSinkExample.java). Let me know if I'm d

Re: Cassamdra Connector in Scala

This looks like a simple type mismatch. It's impossible to help with this without seeing your code, though. Can you post it here? Thanks. -Jamie On Sun, Jun 19, 2016 at 3:17 PM, Eamon Kavanagh wrote: > Hey Mailing List, > > I'm trying to use the Cassandra connector that came out recently (

Re: Caused by: java.lang.IllegalArgumentException: LoggerFactory is not a Logback LoggerContext

I suggest trying as suggested here: http://stackoverflow.com/questions/23984009/disable-logback-in-springboot -Jamie On Mon, Jun 20, 2016 at 1:54 AM, Debaditya Roy wrote: > Hello users, > > I am getting a error while running my flink jar from command line or web > frontend, the error does not

Re: Getting the NumberOfParallelSubtask

Within the mapper you cannot access the parallelism of the following nor preceding operation. On 20.06.2016 15:56, Paschek, Robert wrote: Hi Mailing list, using a RichMapPartitionFunction i can access the total number m of this mapper utilized in my job with int m = getRuntimeContext().getNum

Getting the NumberOfParallelSubtask

Hi Mailing list, using a RichMapPartitionFunction i can access the total number m of this mapper utilized in my job with int m = getRuntimeContext().getNumberOfParallelSubtasks(); I think that would be - in general - the total number of CPU Cores used by Apache Flink among the cluster. Is ther

Re: Yarn batch not working with standalone yarn job manager once a persistent, HA job manager is launched ?

I've created an issue for this here: https://issues.apache.org/jira/browse/FLINK-4095 On Mon, Jun 20, 2016 at 11:09 AM, Maximilian Michels wrote: > +1 for a CLI parameter for loading the config from a custom location > > On Thu, Jun 16, 2016 at 6:01 PM, Till Rohrmann wrote: >> Hi Arnaud, >> >> a

Re: Flink on YARN : Amazon S3 wrongly used instead of HDFS

Hi Charles, sorry for the late response. I put an answer on Stack Overflow. Regards, Robert On Fri, Jun 17, 2016 at 3:11 PM, VALLEE Charles wrote: > Hi everyone, > > I followed Flink on YARN's setup documentation >

Re: Yarn batch not working with standalone yarn job manager once a persistent, HA job manager is launched ?

+1 for a CLI parameter for loading the config from a custom location On Thu, Jun 16, 2016 at 6:01 PM, Till Rohrmann wrote: > Hi Arnaud, > > at the moment the environment variable is the only way to specify a > different config directory for the CLIFrontend. But it totally makes sense > to introdu

Caused by: java.lang.IllegalArgumentException: LoggerFactory is not a Logback LoggerContext

Hello users, I am getting a error while running my flink jar from command line or web frontend, the error does not arises when I run the program from Intellij IDE. I am posting the error below. *org.apache.flink.client.program.ProgramInvocationException: The main meth