Re: Support for Java records in cache

We have faced the same yesterday, I’m also curious if that will be supported in the future. Humphrey > On 11 Apr 2024, at 20:12, Victor wrote: > > Hi > > Using Ignite 2.16, it seems that it's unsupported yet to have a cache of > record classes. If so, two questions: &

Re: Failed to process selector key

your culprit. > > On Tue, Nov 14, 2023 at 4:57 AM Humphrey Lopez wrote: > >> We have several server nodes and thick client nodes, we have Ignite >> embedded in spring boot. The IP address of the remote node is indeed of our >> client. And as we have deployed everything in one n

Re: Failed to process selector key

https://lists.apache.org/thread/jgf2jrp231jd5rhdbh7f5sb8gnclocl8 My guess maybe it has to do with the datastreamer somehow? Humphrey Op ma 13 nov 2023 om 21:10 schreef Jeremy McMillan < jeremy.mcmil...@gridgain.com>: > These errors look like something which does not speak Ignite bi

Re: Failed to process selector key

ternal(GridNioServer.java:2281) at o.a.i.i.u.n.GridNioServer$AbstractNioClientWorker.body(GridNioServer.java:1910) at o.a.i.i.u.w.GridWorker.run(GridWorker.java:125) at java.lang.Thread.run(Thread.java:833) Op ma 13 nov 2023 om 14:33 schreef Humphrey Lopez : > Hello Ignite community. > >

Failed to process selector key

--add-opens=java.base/java.lang.invoke=ALL-UNNAMED" Is there anything I'm missing? The error is happening on a server node, but looks like the remote address is a client node? I see isClient = true in the message. What does it mean and what can we do to fix it? Humphrey

Ignite website shows downloading version 2.11 as latest version

If you narrow the page (or you are on your phone) you get a menu, when clicking on the menu it shows below an older version of apache ignite to download. See screenshot below. [image: image.png]

Kubernetes liveness and readiness probes

the kubernetes IpFinder. Used version 2.15 of ignite (Java/Kotlin) and spring boot. Humphrey

ignite-http-rest

When running ignite http rest with spring boot 3, i'm getting the following error: java.lang.AbstractMethodError: Receiver class org.apache.ignite.internal.processors.rest.protocols.http.jetty.GridJettyRestHandler does not define or inherit an implementation of the resolved method 'abstract void

Query produced big result set.

old in Ignite to a higher value so we don't get those warnings any longer? - if we increase the number of nodes, will it help (less data on one node)? Thanks. Humphrey

Re: Spring (Boot) version

I'm sure it works well with 2.x versions. I'm wondering with 3.x? Or is Ignite only using generic Spring API that will not change with new versions? I'm sure I can try it out myself (doing so with example projects) but not sure if the developers have tested it. Humphrey Op do 13 apr 2023 om 09

Spring (Boot) version

Currently we are running Ignite with spring boot 2.x version. Is any version of Spring (Boot) supported? Can we for example want to upgrade to spring boot 3.x ? Humphrey

Re: Key1 equals Key2 but not found in cache

2023, at 14:44, Humphrey Lopez wrote: > > We have FAT keys that contain information about the Values we store. > KEY > - Object A > - Object B > > VALUE > - Object Y > > The KEY we are using contains several (small) objects as fields. We have > added to Object A a new

Re: Key1 equals Key2 but not found in cache

loud. We don't want to be deserializing unnecessarily values (Object.Y). Maybe with QuerySqlFields on the key? Humphrey Op wo 22 mrt 2023 om 15:18 schreef Rick Lee : > > Why don’t u put the type to value and leave the id as the key? > 「Humphrey Lopez 」在 2023年3月22日 週三，下午10:16 寫道：

Re: Key1 equals Key2 but not found in cache

Okay transient is also not the way to go, cause we want to be able to filter sometimes on that field, so it should be there in the cache. But thanks for clarifying that the Equals and HashCode is not being used on BinaryObjects. Op wo 22 mrt 2023 om 14:51 schreef Humphrey Lopez : > I see mark

Re: Key1 equals Key2 but not found in cache

I see marking the field as Transient Ignite won't serialize it to BinaryObject, is that the way to go? Humphrey Op wo 22 mrt 2023 om 14:37 schreef Humphrey Lopez : > Thanks for clarifying that. Is there a way to mark a property/field to be > excluded when storing? > > Humphrey >

Re: Key1 equals Key2 but not found in cache

Thanks for clarifying that. Is there a way to mark a property/field to be excluded when storing? Humphrey Op wo 22 mrt 2023 om 14:20 schreef Stephen Darlington < stephen.darling...@gridgain.com>: > Ignite doesn’t use your equals or hashCode implementation. Data is stored > as a

Re: Key1 equals Key2 but not found in cache

2, 2023 at 8:02 AM Humphrey Lopez wrote: > >> Hello, when having a key which equals another key, when trying to >> retrieve from cache it does not return the expected value. Is this a bug? >> >> I have a reproducible below in kotlin but in java we get the same result >

Key1 equals Key2 but not found in cache

Hello, when having a key which equals another key, when trying to retrieve from cache it does not return the expected value. Is this a bug? I have a reproducible below in kotlin but in java we get the same result (test with Ignite 2.10 and 2.14) and java 11 and 19. import

Re: Create a Blog with Example code

Rednirus/apache-ignite-masterclass > > Cheers ! > > > On Mon, 6 Mar 2023, 13:47 Humphrey Lopez, wrote: > >> What I need is a nice example where I can demonstrate Affinity >> Collocation. Would like to populate data (maybe stream) from a Rest Api >> outside kubern

Re: Create a Blog with Example code

input or reference to other examples that covers the first part (in memory grid, affinity collocation). I need an example of a use case (Company with Employee, or Cars) or something like that. Humphrey Op za 4 mrt 2023 om 18:02 schreef Kseniya Romanova : > Humphrey as an inspiration you can a

Re: Create a Blog with Example code

the cashes with grafana. Humphrey On 3 Mar 2023, at 10:57, Kseniya Romanova wrote:Hi Humphrey! Good idea! If you need a review before publishing, please let me know and I'll find a comitter who could help with this. Where do you plan to publish your blog? I know that many igniters prefer dzone or dev.to

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: H2database dependency in Apache Ignite

As of version 2.13 I think you can use Apache-Calcite instead of H2, and get rid of H2 from your dependency list. https://ignite.apache.org/docs/latest/SQL/sql-calcite Regards. Op vrijdag 20 januari 2023 schreef Andrey Mashenkov < andrey.mashen...@gmail.com>: > Hi, > > Ignite uses H2 as one of

Re: DataRegion not releasing memory back to OS

hope when clearing the data that memory becomes available for new data. Humphrey Op vr 23 dec. 2022 om 09:56 schreef Ivan Daschinsky : > Hi, but Ignite doesn't and never did release memory back to the OS, except > only on deactivation or shutting down. > > пт, 23 дек. 2022 г. в 10:

DataRegion not releasing memory back to OS

Persistence is Enabled and not when Persistence is disabled, I was hoping to see the same effect. I can create a reproducer for this, but maybe it's a known thing. Humphrey

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/

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

Re: Inserting date into ignite with spark jdbc

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 be

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/

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

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/

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 (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 (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

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

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/

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/

Force backup on different physical machine

)? 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: [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: Server Nodes Stopped Unexpectedly

/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: 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: Cannot Run Spatial Query Example

#binaries 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

ou 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

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

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

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

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

Re: Managing apache-ignite under Kubernetes

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: Ignite-spring-data_2.0 not working

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

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

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 :

Ignite-spring-data_2.0 not working

gniteConfiguration); } } Thanks Humphrey -- Sent from: http://apache-ignite-users.70518.x6.nabble.com/

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/

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

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

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/

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

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

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.70518.x6

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

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: 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/

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

Re: Agent not able to connect

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: 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

Re: Agent not able to connect

efused 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: 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

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.

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

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:

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/

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

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

Documentation Ignite 2.3.0

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

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

Native persistence

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 -- Sent from: http://apache-ignite-users.70518.x6

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:

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

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

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/

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/

Re: Async messaging

Hello, I bumped into the same error. Was not clear to me that you shouldn't call the future after doing the send: IgniteMessaging message = ignite.message().withAsync(); message.send("destination", "hello world"); IgniteFuture future = message.future(); log.info("Keeps on throwing exception")

Re: How to manage sequence with legacy database having auto increment id

Look here [1] on how to use the IgniteAtomicSequence. You can set a value for which you want to start counting. I'm not sure what you are trying to achive? Why not pass the Id to the query? cache.query(new SqlFieldsQuery("INSERT INTO CUSTOMER (id, login, email, age) VALUES (?,?,?,?)")

Re: How to manage sequence with legacy database having auto increment id

Did you look at IgniteAtomicSequence to generate a sequence number for you? -- View this message in context: http://apache-ignite-users.70518.x6.nabble.com/How-to-manage-sequence-with-legacy-database-having-auto-increment-id-tp15857p15878.html Sent from the Apache Ignite Users mailing list

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.

How to start up H2 Console

-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: 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

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:

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

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

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:

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

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

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

Re: How to solve SinkRecord cannot be cast exception?

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?

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 Users mailing

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 archive

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:

  1   2   >