Skip to content
#

hazelcast

Here are 236 public repositories matching this topic...

elR1co
elR1co commented Aug 18, 2020

Today IMap.values() and IMap.values(Predicate) calls are blocking.

I would like to use IMap.values(Predicate) in a Jet Pipeline, which is possible, but I need to declare it as nonCooperative, and will have an impact on the pipeline scalability.

Would it be possible to have an async (non-blocking) version for these calls ?

Thank you very much for all the hard work done !

Streaming reference architecture for ETL with Kafka and Kafka-Connect. You can find more on http://lenses.io on how we provide a unified solution to manage your connectors, most advanced SQL engine for Kafka and Kafka Streams, cluster monitoring and alerting, and more.

  • Updated Sep 3, 2020
  • Scala
davidkarlsen
davidkarlsen commented Mar 26, 2020

We run HZ in WLP for session replication, and are looking at running it in embedded mode. Hence there should not be a need for read to pods/endpoints outside of the target namespace - but the client seems to spit out error-messages if it does not get a clusterrole: view rolebinding. This seems as a bit wide as a default - especially when running in embedded mode.

Also when logging access erro

jerrinot
jerrinot commented Jul 1, 2020
SLF4J: See http://www.slf4j.org/codes.html#StaticLoggerBinder for further details.
Exception in thread "main" java.lang.NoSuchMethodError: 'void com.hazelcast.jet.impl.util.Util.checkSerializable(java.lang.Object, java.lang.String)'
	at com.hazelcast.jet.contrib.redis.RedisSinks.hash(RedisSinks.java:141)
	at com.hazelcast.jet.examples.callhomes.CountDistinctVersionsHomes.main(CountDistinct

Improve this page

Add a description, image, and links to the hazelcast topic page so that developers can more easily learn about it.

Curate this topic

Add this topic to your repo

To associate your repository with the hazelcast topic, visit your repo's landing page and select "manage topics."

Learn more

You can’t perform that action at this time.