Re: Flink Streamer Compatibility.

Hi Here is the working example https://github.com/samaitra/streamers Let me know if you have any questions. Regards, Saikat On Tue, Sep 25, 2018 at 2:22 PM, Anand Vijai wrote: > Is there a working example of how the integration works to sink Flink data > into an Ignite Cache? > > > > -- >

Re: Flink Streamer Compatibility.

Is there a working example of how the integration works to sink Flink data into an Ignite Cache? -- Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Re: java.lang.IllegalArgumentException: Can not set final

Thanks for the responses. Ilya - I did try your suggestion: removing the final modifier, deleting the constructor and only using getters and setters. I even went as far as to make the fields public. All these changes resulted in the an IllegalArgumentException. If it helps, I was able to write

ignite .net programatically access cluster config (not working)

hi I have a single node cluster started with the following config when i launch a client and do Iignite.GetCluster().Configuration here is the screenshot of the config the client gets - the data storage config is null 2018-09-25_18-22-15.png

Re: java.lang.IllegalArgumentException: Can not set final

Probably that's the issue :) In any case, Java serialization successfully deserializes such objects, so I think it's a bug. -Val -- Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Re: java.lang.IllegalArgumentException: Can not set final

Hello! I can see that java.lang.reflect.Field is used. Why would it set final fields? Regards, -- Ilya Kasnacheev вт, 25 сент. 2018 г. в 19:22, vkulichenko : > Ilya, > > Do you know what is the reason for such limitation? It doesn't sounds right > to me, I believe any other marshaller would

Re: Is there a way to use Ignite optimization and Spark optimization together when using Spark Dataframe API?

Ray, This sounds suspicious. Please show your configuration and the execution plan for the query. -Val -- Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Re: java.lang.IllegalArgumentException: Can not set final

Ilya, Do you know what is the reason for such limitation? It doesn't sounds right to me, I believe any other marshaller would work just fine with final fields. -Val -- Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Re: kafka.common.KafkaException: Failed to parse the broker info from zookeeper

Hello! >From the thread dumps looks like it's more of a Kafka issue than Apache Ignite. Have you tried newer releases BTW? Regards, -- Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Re: Failed to wait for initial partition map exchange

Hello! Regarding PME problems. OOM will cause this. High GC could cause this under some circumstances. High CPU or Disk usage should not cause this. Network inavailability (such as closed communication port) could also cause it. But the prime cause is programming errors. Either those are errors

Re: Map C# class to Cassandra persistence settings

Hello! Be the first to try! Note that you should probably a) enable simple binary name mapping[1] (i.e. use class="Person"), b) use Java types for primitives[2] (or their Java wrapper classes). 1. https://apacheignite-net.readme.io/docs/platform-interoperability#section-default-behavior 2.

Re: Is there a way to use Ignite optimization and Spark optimization together when using Spark Dataframe API?

Hello! Can you show the index that you are creating here? Regards, -- Ilya Kasnacheev вт, 25 сент. 2018 г. в 8:23, Ray : > Let's say I have two tables I want to join together. > Table a has around 10 millions of rows and it's primary key is x and y. > I have created index on field x and y

Re: java.lang.NullPointerException in GridDhtPartitionsExchangeFuture

Hello! It's hard to say without reviewing logs, but it seems that there's some inconsistency with regards to cache metadata on nodes. Regards, -- Ilya Kasnacheev вт, 25 сент. 2018 г. в 0:13, HEWA WIDANA GAMAGE, SUBASH < subash.hewawidanagam...@fmr.com>: > Hi all, > > We use Ignite 1.9. > > >

Re: java.lang.IllegalArgumentException: Can not set final

Hello! You can't set final fields when deserializing binary objects. Consider changing them to non-final fields with getter-setter. Regards, -- Ilya Kasnacheev вт, 25 сент. 2018 г. в 1:31, smurphy : > Hmm pasting the stack trace into the page didn't work. > Here it is as an attachment..: >

Re: Nullpointer exception in IgniteHadoopIgfsSecondaryFileSystem

Hello! You should put IgniteHadoopIgfsSecondaryFileSystem into IgniteConfiguration, then you should start Ignite instance, then it will be initialized properly. See https://apacheignite-fs.readme.io/docs/secondary-file-system Regards, -- Ilya Kasnacheev вт, 25 сент. 2018 г. в 14:00, Divya

kafka.common.KafkaException: Failed to parse the broker info from zookeeper

*I have deployed kafka in kubernetes using https://github.com/Yolean/kubernetes-kafka. But while consuming using kafka consumer, I get following error : * SEVERE: Failed to resolve default logging config file: config/java.util.logging.properties [10:23:00]__

Re: Is ID generator split brain compliant?

Denis, As far as I understand, question is about IgniteAtomicSequence? We fixed IgniteSet to be persisted and recovered properly. Pavel Pereslegin, Could you please check whether we have the same issue with IgniteAtomicSequence? сб, 22 сент. 2018 г. в 4:17, Denis Magda : > So far, it looks

Nullpointer exception in IgniteHadoopIgfsSecondaryFileSystem

Hi Team, I am exploring Ignite for my use case (explained in the later section of this email). Currently I am trying to create a directory in HDFS (stand-alone) with Java code but I am getting Null pointer exception. Could you please help me out. Necessary information is as under. Please let me