hazelcast-jet
hazelcast-jet copied to clipboard
hazelcast
Distributed Stream and Batch Processing
On Jet 4.4, I can define the following ``` CREATE MAPPING IF NOT EXISTS neil TYPE IMap OPTIONS ( 'keyFormat' = 'java', 'keyJavaClass' = 'java.lang.String', 'valueFormat' = 'java', 'valueJavaClass' =...
I started the hazelcast jet instance and added multiple jobs in it and verify that while the data is streaming into the pipeline it's delayed by 40-60 mins. I am...
See https://stackoverflow.com/questions/66386877/why-is-hazelcast-imap-journal-not-producing-all-expected-events
In https://jet-start.sh/docs/api/sources-sinks#map-sink coalescing is not mentioned for `mapWithMerging` and `mapWithUpdating`
Parallelism for the event journal defaults to 2 for local maps without explaining why this is the correct value https://github.com/hazelcast/hazelcast-jet/blob/master/hazelcast-jet-core/src/main/java/com/hazelcast/jet/impl/connector/StreamEventJournalP.java#L367 ``` public int preferredLocalParallelism() { return clientXml != null ?...
when I build the latest master and unzip the tar.gz distribution then the `lib` directory contains `hazelcast-download.properties`. Is this expected? I guess it should not be there.
looks like the blog page isn't indexed by docsearch This config needs tweaking: https://github.com/algolia/docsearch-configs/blob/master/configs/hazelcast-jet.json
Apparently protobuf does not have ARM 32 build in Maven. This means Jet does not build on e.g. Raspberry Pi. A quick workaround is not avoid building the gRPC sample...
In a cluster composed of 100 jet instances, a vertex of my pipeline needs 5 threads for parallel processing. How to set it? The distributed method of sourcebuilder sets the...
Hi, Does a c++ client API which can access a jet member exist at the moment? I have a very performance centric project and the data insertion stage has to...
