Force backup on different physical machine

le the pod)? Background: If kubernetes_node1 goes down, then there won't be any data loss. Humphrey -- Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Re: How do I know the cache rebalance is finished?

Rebouncing this topic, the ticket is still open (almost 4 years). Any progress / priority to this ticket or work around? https://issues.apache.org/jira/browse/IGNITE-3362. -- Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Re: How to do address resolution?

Not sure if this will help, I've also had issues with Visor keeps hanging the cluster. When I changed the configuration to ClientMode (default is ServerMode) it solved my problem. Might be good to give it a try. Humphrey -- Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Ignite Queue (Documentation or Code defect)?

When creating an ignite queue without an CollectionConfiguration (null) I'm not getting the expected Queue or Exception as documented in the JavaDoc. But i'm getting a cache that is null. The documentation: -- Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Ignite Queue

According to the documentation (java doc) of ignite.queue(): Will get a named queue from cache and create one if it has not been created yet and cfg is not null. If queue is present already, queue properties will not be changed. Use collocation for CacheMode.PARTITIONED caches if you have lots of r

Re: Ignite Queue (Documentation or Code defect)?

Great I see something went missing: Ignite ignite = Ignition.start(); IgniteQueue queue = ignite.queue("Queue", 0, null); ignite.close(); In the queue created above I expect it to throw an exception if the queue can not be fetched, instead it is giving me a queue that is "null". Check the JavaDo

Re: Ignite Queue (Documentation or Code defect)?

Hope someone pics this up. That the code is not behaving as the documentation is saying. (Not throwing exception when queue can not be fetched). -- Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Re: Ignite Queue

Yes the common pattern is not documented. So was expecting if no exception is thrown that I'm getting a queue and can put something on it. But then if I don't check for null I'll get a NullpointerException. -- Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Re: Ignite Queue

I see it's already being picked up in another thread: http://apache-ignite-users.70518.x6.nabble.com/Ignite-Queue-Documentation-or-Code-defect-td33703.html I can't delete this thread. -- Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Inserting date into ignite with spark jdbc

Hello guys this question has been asked on Stack Overflow but yet no answer is a provided. I'm facing the same issue (trying to insert data in ignite using spark.jdbc): Ex

Re: Inserting date into ignite with spark jdbc

Yes I don't want to supply an Ignite Configuration XML I would like to connect through JDBC like any other database. And there is no way to supply the primary key. -- Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Re: Inserting date into ignite with spark jdbc

Y KEY defined for CREATE TABLE* even when supplying the option *OPTION_CREATE_TABLE_PRIMARY_KEY_FIELDS*. Do you want me to make a reproducible example? Or is there already a ticket? Humphrey aealexsandrov wrote > Denis, > > I can check it out soon. The mentioned problem can probably only

Re: Inserting date into ignite with spark jdbc

Hello, I made a reproducer here Can 2 classes to run, * nl/hlopez/ignitesparkjdbc/server/ServerApplication.kt * nl/hlopez/ignitesparkjdbc/spark/SparkApplication.kt ServerApplication starts a Ignite Server Node SparkApplication starts the spark a

Re: Inserting date into ignite with spark jdbc

Did anyone had a chance to look at the code? Should I make a Java one, or is Kotlin good enough? -- Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Create a Blog with Example code

Hi, I would like to create a blog with code and share experience of Apache Ignite. What’s the best way to do that? Greetings Humphrey

Re: Rolling Update

w version. This prevents downtime when performing software upgrades."https://www.gridgain.com/docs/latest/installation-guide/rolling-upgradesCheersGianluca BonettiOn Tue, 3 Sept 2024 at 18:15, Humphrey Lopez <hmmlo...@gmail.com> wrote:Hello, we have several pods with ignite caches running

Re: Rolling Update

finished.There is a race condition if the pod does not immediately join the cluster, but checks to see if the cluster is balanced and THEN joins the cluster, triggering another rebalance after it's already reported that it is ready.Try to control for that.On Tue, Sep 10, 2024 at 3:01 AM Humphrey

Re: Rolling Update

it's already reported that it is ready.Try to control for that.On Tue, Sep 10, 2024 at 3:01 AM Humphrey Lopez <hmmlo...@gmail.com> wrote:Thanks, seems a bit complicated. When I have more time I'll try that approach.For now we still going to (mis) use the Readiness probe to wait for

Ignite-spring-data_2.0 not working

gnition.start(igniteConfiguration); } } Thanks Humphrey -- Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Re: Ignite-spring-data_2.0 not working

I see that some text went missing after the post: Here the stack trace log: Error starting ApplicationContext. To display the conditions report re-run your application with 'debug' enabled. 2019-11-02 13:16:56.482 ERROR 13627 --- [ main] o.s.boot.SpringApplication : Applic

Re: Ignite-spring-data_2.0 not working

Thanks, I've tried it with version 2.0.14 and it works, but version 2.1.0 it doesn't. org.springframework.data spring-data-commons 2.0.14.RELEASE Humphrey -- Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Re: Ignite-spring-data_2.0 not working

accomplish that with spring-data? Humphrey -- Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Re: Managing apache-ignite under Kubernetes

t. We have packaged all the dependend jars and put it in a lib folder. When the container starts it needs to keep running and then we enter the console and start up visor from there. When we done we can close visor and stop the pod. Humphrey -- Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Re: Cannot Run Spatial Query Example

Do you have a link to the file or the example? -- Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Re: Cannot Run Spatial Query Example

Looks like this project is based on a very old version of Ignite. 1.7.0 -- Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Re: Cannot Run Spatial Query Example

I have a working example for you with latest version of Ignite. Had to take off the index=true from the MapPoint. I used Lombok, so make sure you have lombok plugin installed in your IDE. Hope this helps you. geo-ignite-example-working.zip

Re: Cannot Run Spatial Query Example

I have a working example for you with latest version of Ignite. Had to take off the index=true from the MapPoint. I used Lombok, so make sure you have lombok plugin installed in your IDE. Hope this helps you. geo-ignite-example-working.zip

Re: Cannot Run Spatial Query Example

If I have time tomorrow I’ll try with more nodes in cluster. Do you have a small reproducible project? -- Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Re: Cannot Run Spatial Query Example

oblem. Can you try it out on multiple machines to see if you can reproduce your error? Humphrey -- Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Re: Cannot Run Spatial Query Example

I've added the server node to a docker instance. (https://github.com/hmmlopez/geo-ignite-example) 1) change directory to the server project and run: mvn package dockerfile:build 2) start docker exposing the necessary ports: docker run -p 47500:47500 -p 47100:47100 -t springio/server 3) Run the

Re: Cannot Run Spatial Query Example

#binaries Humphrey -- Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Re: Unable to connect to a remote apache ignite node.

Somehow one of the nodes are starting with encryption? Joining node doesn't have encryption data Are they both using the same example-cache.xml file? Humphrey -- Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Re: Server Nodes Stopped Unexpectedly

tAddrs=[qagmsweb01.p05.eng.sjc01.xyx.com/10.44.81.30, /127.0.0.1], rmtNode=ClusterNode [id=312d096e-6ba7-4038-b877-ce237e5227df, order=42, addr=[10.44.81.30, 127.0.0.1], daemon=false]] Humphrey -- Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Re: [Webinar] How to Migrate Your Data Schema to Apache Ignite

Having trouble registering. Link to apply for the webinar not active/working. -- Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Re: How to filter ip interfaces in TcpDiscoveryJdbcIpFinder

Have you tried the following: Setting the property IGNITE_LOCAL_HOST should choose one interface. https://ignite.apache.org/releases/latest/javadoc/org/apache/ignite/IgniteSystemProperties.html#IGNITE_LOCAL_HOST -- Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Re: Prevent automatic Ignite server node start for Spring Boot

Did you rebuild your project? Or update your maven dependencies? Should not happen if you removed the dependency of ignite. It also should only start a node if you have in your spring configuration something (bean) of ignite. -- Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Re: SQL query on nested objects?

Yes, check the documentation here. https://apacheignite-sql.readme.io/docs/schema-and-indexes#annotation-based-configuration -- Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Blocked system-critical thread has been detected. This can lead to cluster-wide undefined behaviour

dling events of the continuous query of one cache on multiple server nodes. I have a reproducer attached here. striped-pool-starvation.zip <http://apache-ignite-users.70518.x6.nabble.com/file/t1004/striped-pool-starvation.zip> Humphrey -- Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Re: Blocked system-critical thread has been detected. This can lead to cluster-wide undefined behaviour

Thanks Ilya, It works with runAsync. (Question) Can you clarify why does it work on a single node well and when going on two nodes it doesn't, and we get the exceptions? I was expecting it also to be happening on one server node. Humphrey -- Sent from: http://apache-ignite-users.705

Re: Blocked system-critical thread has been detected. This can lead to cluster-wide undefined behaviour

And can you also clarify which thread pool is used for cache.put() / cache.putAsync ? I'm getting a lock whit two nodes when putting data into the cache with map.forEach((key, value) -> cache.putAsync(key, value)); I could also try putAllAsync() but don't know if that is better than putAsync.

Re: Blocked system-critical thread has been detected. This can lead to cluster-wide undefined behaviour

Thread [name="sys-stripe-1-#2", id=17, state=WAITING, blockCnt=8, waitCnt=8] Lock [object=java.util.concurrent.Semaphore$NonfairSync@6915e1ad, ownerName=null, ownerId=-1] at sun.misc.Unsafe.park(Native Method) at java.util.concurrent.locks.LockSupport.park(LockSupport.java:175)

Re: Blocked system-critical thread has been detected. This can lead to cluster-wide undefined behaviour

er doing the put in the callback method. 3) Which of these is the best approach? Humphrey [1] https://apacheignite.readme.io/docs/thread-pools -- Sent from: http://apache-ignite-users.70518.x6.nabble.com/

DataRegionConfiguration is a FINAL class but prefer it not be

Is there a very good reason why the DataRegionConfiguration is a *FINAL* class? I would like to be able to extend the DataRegionConfiguration. In my extended class I would like to add a new method for the *setMaxSize()* and *setInitialSize()* for example where the input is of the type *org.spring

Re: DataRegionConfiguration is a FINAL class but prefer it not be

Thanks, I'll post the same message there. Humphrey -- Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Re: Threads waiting on cache reads

Could you put the cache configuration and the sample code? -- Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Ignite in docker (Native Persistence)

Has anyone use Ignite Native Persistence with Docker? Is there a solution on how to map the Volume dynamically? And how about when you restart the whole cluster, how does it maps all volumes? -- Sent from: http://apache-ignite-users.70518.x6.nabble.com/

fabric8 ignite-service.yaml

Has anyone used fabric8 in combination with Ignite to deploy ignite services and discovery using the TcpDiscoveryKubernetesIpFinder? I'm looking for a way to define my ignite-service.yaml file in my project so and configure it with the fabric8-maven-plugin so it will automatically be deployed (and

Test Ignite Client

Hello, I have the following question, I want to test my IgniteClient, which has it's own @Configuration file which has an igniteBean: Now I created a separate AppConfig for the testing (which Imports the AppConfig above from the client), and I want to start first a server node so the client can

Re: How to use BinaryObject from existing data

Is it possible to create a table by SQL and then add the QueryEntity (probably when creating the table) so later we are able to search with SqlFieldsQuery property? I mean without creating first a POJO first and defined in the cache configuration. -- Sent from: http://apache-ignite-users.70518.

Native persistence

hat will happen with the data it finds in the existing directory (and probably are old), how does it handle this? - What happens in the situation that I shutdown my cluster and restart it with 2 replica's. How does ignite know which two of the four directories to re-use? Humphrey

Re: Using 3rd party DB together with native persistence (WAS: GettingInvalid state exception when Persistance is enabled.)

I think he means when *write-through* and *read-through* modes are enabled on the 3rd party store, data might be written/read to/from one of those persistence storage (not on both). So if you save data "A" it might be stored in the 3rd party persistence, and not in the native. When data "A" is not

Documentation Ignite 2.3.0

-wide configuration. Humphrey -- Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Re: Error with ignite-rest-http

Hi I had the same issue when using SpringBoot 1.5.10.RELEASE with apache ignite 2.4.0. Was fixed when using telling spring boot to use other (older) version by specifying the following: 9.2.11.v20150529 Humphrey -- Sent from: http://apache-ignite-users.70518

Agent not able

Hi, I'm trying to deploy Ignite in minikube. I've started in a separate container WebConsole (and separate Pod). I when I start my other Pod that contains my ServerNode and WebAgent, I get the error below. How can I solve that? I suppose that it is able to connect to the rest server on the same m

Re: Agent not able to connect

Web agent I used was apacheignite/web-console-standalone from docker hub. Am able to login and see the corresponding token used in the agent from the profile. -- Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Re: Agent not able to connect

Looks like it can't connect to the webconsole as the webconsole is only listening to localhost: Start listening on 127.0.0.1:3000 How can we change this so that the agents (which have different IP) in the cluster are able to communicate with the webconsole? -- Sent from: http://apache-ignite-u

Re: Agent not able to connect

How do I do a pull from that repository? Currently my docker is only looking at dockerhub. -- Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Re: Agent not able to connect

I've done the steps you noted but it seems to do the same as the other 2.4 version. web-console-standalone: 09:55:33 0|index | All Ignite migrations finished successfully. 09:55:33 0|index | Running Ignite Modules migrations... 09:55:33 0|index | There are no Ignite Modules migrations to run. 09:

Re: Ignite Spring Integration seems broken with 2.4 (upgrading from 2.3)

You can also try to lazy initialize the bean. Or set default-lazy-init="true" in the xml beans definition. http://www.javarticles.com/2015/05/spring-lazy-init-examples.html Had the same issue before and I added @Lazy to my bean. Humphrey -- Sent from: http://apache-ignite-user

Re: Agent not able to connect

sed cause it has a different IP address then the webconsole. Do we need 1 agent talking to the whole cluster, or 1 agent per Ignite Node (Pod). If we only need one agent, then I will move the agent to the same Pod as the WebConsole. Humphrey -- Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Re: Agent not able to connect

Okay I got it running, I think the agent is really using the 80 port instead of the 3000 or 3001. Can you explain what the 3000 or 3001 port is for? [2018-05-31 12:27:44,882][INFO ][main][AgentLauncher] Starting Apache Ignite Web Console Agent... [2018-05-31 12:27:45,498][WARN ][main][AgentLaunche

Re: Agent not able to connect

he agent docker container: wget -qO- ${NODE_URI}/ignite?cmd=version *{"successStatus":0,"sessionToken":null,"error":null,"response":"2.5.0"}* Humphrey -- Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Re: Apache Flink Sink + Ignite: Ouch! Argument is invalid

It is working fine here. Tweaked the main method a bit: public static void main(String[] args) throws Exception { System.setProperty("IGNITE_QUIET", "false"); final StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment(); env.s

Ignite .NET vs Java

ction) is in the .NET examples of ignite. I'm trying to find out the equivalent lambda way in C#. Humphrey -- View this message in context: http://apache-ignite-users.70518.x6.nabble.com/Ignite-NET-vs-Java-tp12354.html Sent from the Apache Ignite Users mailing list archive at Nabble.com.

Resource Injection in .NET

ld do it in C#. In Java: @IgniteInstanceResource private Ignite ignite; I'm just upgraded everything to ignite 2.0.0 with NUGET. Humphrey -- View this message in context: http://apache-ignite-users.70518.x6.nabble.com/Resource-Injection-in-NET-tp12420.html Sent from the Apache Ignite Use

Re: getting a basic error while running ignite

g/apache/ignite/configuration/IgniteConfiguration.html#setPeerClassLoadingEnabled(boolean) Humphrey -- View this message in context: http://apache-ignite-users.70518.x6.nabble.com/getting-a-basic-error-while-running-ignite-tp12418p12421.html Sent from the Apache Ignite Users mailing list archive at Nabble.com.

Re: Resource Injection in .NET

Thanks. I can't seem to find the PeerClassLoading method in IgniteConfiguration. Is there one? Humphrey -- View this message in context: http://apache-ignite-users.70518.x6.nabble.com/Resource-Injection-in-NET-tp12420p12424.html Sent from the Apache Ignite Users mailing list archi

Re: Kindly tell me where to find these jar files.

I've done the same thing, but just with Ignite 1.9.1 and all on one Linux machine, but that wouldn't matter. I used maven repository to get the jar files for me. I can share my dependencies of pom.xml with you. The jars are only needed on the machine where you start Ignite. Change the ignite.versi

Re: Kindly tell me where to find these jar files.

CacheConfiguration cfg = new CacheConfiguration(); cfg.setName(CACHE_NAME); cfg.setBackups(1); return cfg; } } I hope this helps. Humphrey -- View this message in context: http://apache-ignite-users.70518.x6.nabble.com/Kindly-tell-me-where-to-find

Re: Ignite 2.0: CacheWriteSynchronizationMode = FULL_ASYNC when using cache.putAsync

Hi Gordon, FULL_ASYNC: Do not wait for any server node to acknowledge So it will fire and forget, and will not wait for all nodes in cluster to be updated. That will happen in the background. Humphrey -- View this message in context: http://apache-ignite-users.70518.x6.nabble.com/Ignite-2-0

Re: Kindly tell me where to find these jar files.

Seems like you need to start first with the basics. This is not the correct place to learn java. Google online and do more research. Here are some links explaining maven. https://youtu.be/JK9oZfScQgg https://youtu.be/uEYjXpMDJiU There are more out there. Play a little around with maven and java

Re: How to set cache name in Kafka connect?

Take a look here. http://apache-ignite-users.70518.x6.nabble.com/Kindly-tell-me-where-to-find-these-jar-files-td12649.html Here I posted some code. Humphrey -- View this message in context: http://apache-ignite-users.70518.x6.nabble.com/How-to-set-cache-name-in-Kafka-connect-tp12959p12969

Re: Kindly tell me where to find these jar files.

I think it's not hard to do and once you start implement the interface you will figure out by yourself. - May I ask *what tool do you use* to parse the Schema that converts the object to this json? Here is what I did: I created an object, called TulpeBus which would be the kind of messages (obje

Re: How to configure Ignite sink connector to use key-value?

See answers in the following post. http://apache-ignite-users.70518.x6.nabble.com/Kindly-tell-me-where-to-find-these-jar-files-td12649.html I think in the last step you need to convert the data you getting to an cache object, for example Annotation Based Configuration [1] so you can use it to que

Re: How to implement StreamSingleTupleExtractor in Kafka connect Ignite sink?

See answers in the following thread. http://apache-ignite-users.70518.x6.nabble.com/Kindly-tell-me-where-to-find-these-jar-files-td12649.html -- View this message in context: http://apache-ignite-users.70518.x6.nabble.com/How-to-implement-StreamSingleTupleExtractor-in-Kafka-connect-Ignite-si

Re: How to solve SinkRecord cannot be cast exception?

You need to extract the values you want from the SinkRecord and map them to your Domain class you want to store in Ignite. Don't just cast the SinkRecord. -- View this message in context: http://apache-ignite-users.70518.x6.nabble.com/How-to-solve-SinkRecord-cannot-be-cast-exception-tp13221p132

Re: Kindly tell me where to find these jar files.

I replied in the new thread you made above. Look in Kafka how to extract the values you want from the SinkRecord you are getting and map those to your Object you want to store in Ignite. So for example you extract the BUS_ID from the SinkRecord (look in the kafka api how to do that) and you map tha

Re: How to solve SinkRecord cannot be cast exception?

Ignite is using the following to extract the records from Kafka: StreamSingleTupleExtractor extractor; In my Example I gave you I made my own version of Object (TupleBus) to show you how to use the extractor. In your case you need to use SinkRecord. StreamSingleTupleExtractor extractor; Example

Re: How to solve SinkRecord cannot be cast exception?

You need to create your own class you want to store in Ignite, if you want to query the objects later using annotation look at [1]. Mine was just an example to show, and not to use. As input you getting SinkRecord, which you need to convert to Entry where Integer would be the BUS_ID and YourClass

Re: How to create custom SinkRecord extractor?

Can you keep everything in one thread, not creating new threads for each question you have? Makes easy to follow the whole conversation. You almost there, you just need to extract the values from the SinkRecord and add them to your Bus object. See the Kafka API how to do extract values from SinkRe

Re: How to solve SinkRecord cannot be cast exception?

you create new AbstractMap.SimpleEntry(id, bus); where id is the bus_id you got from the the object and the bus object you created in the step above. -- Humphrey -- View this message in context: http://apache-ignite-users.70518.x6.nabble.com/How-to-solve-SinkRecord-cannot-be-cast-exception

Re: How to solve SinkRecord cannot be cast exception?

) First do step 2 and make sure you have the values so you can map them to the Integer and the Bus required for the output. The SinkRecord contains your data for "BUS_ID", "BUS_NUMBER", "BUS_DATE", etc. Use the Kafka API to get the values out of the SinkRecord

Re: How to solve SinkRecord cannot be cast exception?

from a SinkRecord? There the Kafka API is coming in for help. Look at it and try to use it to get your values out of the SinkRecord. -- Humphrey -- View this message in context: http://apache-ignite-users.70518.x6.nabble.com/How-to-solve-SinkRecord-cannot-be-cast-exception-unsolved-tp13221p

Re: How to solve SinkRecord cannot be cast exception?

I'm not sure what are you trying to achive by this? -- View this message in context: http://apache-ignite-users.70518.x6.nabble.com/How-to-solve-SinkRecord-cannot-be-cast-exception-unsolved-tp13221p13285.html Sent from the Apache Ignite Users mailing list archive at Nabble.com.

Re: How to solve SinkRecord cannot be cast exception?

The only thing you doing now is creating a new SinkRecord manually. And pass it to your method. Instead of getting the values out of your Kafka SinkRecord you are creating a different one. I'm not sure how this will help you. -- View this message in context: http://apache-ignite-users.70518.x6.

Re: How to solve SinkRecord cannot be cast exception?

u are just casting the record (SinkRecord) you are receiving to Bus, which if it's not an instance of Bus it won't work. -- Humphrey -- View this message in context: http://apache-ignite-users.70518.x6.nabble.com/How-to-solve-SinkRecord-cannot-be-cast-exception-unsolved-tp13221p1329

Re: How to solve SinkRecord cannot be cast exception?

not willing to follow the steps I give you then I'm not able to help you. -- Humphrey -- View this message in context: http://apache-ignite-users.70518.x6.nabble.com/How-to-solve-SinkRecord-cannot-be-cast-exception-unsolved-tp13221p13293.html Sent from the Apache Ignite Users mailing list ar

Re: How to solve SinkRecord cannot be cast exception?

Kafka documentation and the Kafka API. It's good for you to do that so you learn how to do things. -- Humphrey -- View this message in context: http://apache-ignite-users.70518.x6.nabble.com/How-to-solve-SinkRecord-cannot-be-cast-exception-unsolved-tp13221p13297.html Sent from the Apache Ignite Use

Re: How to solve SinkRecord cannot be cast exception?

na) object like you are doing now with your test method. -- Humphrey -- View this message in context: http://apache-ignite-users.70518.x6.nabble.com/How-to-solve-SinkRecord-cannot-be-cast-exception-unsolved-tp13221p13305.html Sent from the Apache Ignite Users mailing list archive at Nabble.com.

Re: How to solve SinkRecord cannot be cast exception?

I hope to try something next week. Maybe you can help me out setup a database and extraction from it with kafka to reproduce the extraction in to Kafka and getting it into ignite. I will be using SQLite. Humphrey > On 5 Jun 2017, at 07:59, ignitedFox [via Apache Ignite Users] >

Re: How to solve SinkRecord cannot be cast exception?

Since you were using the in your worker it's converting the value to a Json format. What you need to do is convert it back and map it to an object. This is working for me. For this to compile you need to put the following dependency on your project with the correct kafka version, the jar is alreay

Re: Web-Console query on Oracle database cache return empty resultset

The key you can query with _key see [1] [1] https://apacheignite.readme.io/docs/indexes#section-registering-indexed-types -- View this message in context: http://apache-ignite-users.70518.x6.nabble.com/Web-Console-query-on-Oracle-database-cache-return-empty-resultset-tp13546p13552.html Sent

Using AbstractAnnotationConfigDispatcherServletInitializer

Hello, Here [1] there is an explanation how to startup Ignite in an WAR (Spring MVC) file using the web.xml. I managed to get it started with the following code: I would like to have Ignite started programmatically, without having a spring based configuration file "config/default-config.xml"

Re: Data not loading with Ignite DataStreamer

Have you tried to set the flush frequency? stmr.autoFlushFrequency(1000); Sets automatic flush frequency. Essentially, this is the time after which the streamer will make an attempt to submit all data added so far to remote nodes. -- View this message in context: http://apache-ignite-users.7

Re: Using AbstractAnnotationConfigDispatcherServletInitializer

Thanks for the reply: I tried the following and was not succesfull. Should it be added somewhere else? Is there an example of this? -- View this message in context: http://apache-ignite-users.70518.x6.nabble.com/Using-AbstractAnnotationConfigDispatcherServletInitializer-tp14592p14596.html S

Re: Using AbstractAnnotationConfigDispatcherServletInitializer

Thanks, actually I got both ways working. But I prefer to use the IgniteSpringBean. In my DAO where Ignite is being used, I implemented the interfaces InitializingBean and DisposableBean and used the IgniteSpringBean to get my Cache. Now when my DAO is being initialized it initializes the IgniteS

Re: How to start up H2 Console

Hi did you look here? https://apacheignite.readme.io/docs/sql-performance-and-debugging You can also use the web console to have it explain. https://ignite.apache.org/addons.html#web-console -- View this message in context: http://apache-ignite-users.70518.x6.nabble.com/How-to-start-up-H2-Co

Re: Re:Re: How to start up H2 Console

Hi Lucky, You can start the console by first executing the following command: And then in the same console It will open automatically a browser for you. Cheers, Humphrey -- View this message in context: http://apache-ignite-users.70518.x6.nabble.com/How-to-start-up-H2-Console

How to start up H2 Console

arting-H2-Debug-Console-On-Remote-Server-td6063.html Humphrey -- View this message in context: http://apache-ignite-users.70518.x6.nabble.com/How-to-start-up-H2-Console-tp14617p14707.html Sent from the Apache Ignite Users mailing list archive at Nabble.com.

Re: Requested array size exceeds VM limit

You can modify the ignite.sh script and increase the Xms and Xmx values -- View this message in context: http://apache-ignite-users.70518.x6.nabble.com/Requested-array-size-exceeds-VM-limit-tp14708p14710.html Sent from the Apache Ignite Users mailing list archive at Nabble.com.

  1   2   >