hazelcast-jet

I trying to join 2 data sources using Hazelcast Jet and once I start Hazelcast Jet instance I do not

Dear Sir/ma Our investors are privately seeking means of expanding their investment portfolio and

Hi, How can we avoid using JetClassLoader? I can see that some of our processors occasionally cause

>The flame graph looks as if your processors don't have much work to do. A big part is spent

Thanks Can and Villiam. I suppose we have to mount a persistent volume to our containers then. We do

Hi, so you want use Jet to join tables extracted from Postgres as change streams? If so, please

Hi all I run a Quarkus application with the Hazelcast (IMDG) extension (quarkus-hazelcast-client). I

Currently, we support co-grouping into windows: timestamped events from multiple streams will be

Jet jobs can use any of these classes: - available on member's classpath (eg through adding a jar

I wrote you also on Slack, but this is almost certainly due to the partition idle timeout which is 60

If you measure the time from the point tryEmit(item) succeeds, at that point Jet already placed the

I'm happy to announce Jet 4.1 is released. See the notes below and thanks to all the contributors

Possibly, but not sure. That's why I am trying to find out here (from the Jet perspective) what

Yes you are right. In further versions (I think it was 3.1) we also introduced "jet.job.results.

Hi, We have now published a migration guide for Jet 3.x users to 4.x: https://jet-start.sh/blog/2020/

Hi, We've now started putting design documents some of our upcoming 4.1 features as design

Slightly delayed announcement, but I'm happy to announce that Hazelcast Jet 4.0 is released. You

And more to Marko's point: you can also use Edge queue length. A processor gets all the data that

Hi Lukáš, Please see this PR: https://github.com/hazelcast/hazelcast-jet/pull/1377 Previously the

You're right, the capacity of map journal is distributed evenly among partitions and if one

Question was answered on StackOverflow, please continue there. Viliam On Thu, 2 May 2019 at 15:55,

Hi Lukas, Yes this is in progress, currently only Jet is using this convention but the plan is to

Yes, you shouldn't use paging predicate but do it yourself using the iterator. Something like (

Hi Patrick, Any mapping / flatMapping stages after a source will cause items to be reordered in the

Hi Ben, You can't have SimpleDateFormat and have only one instance as it's not thread-safe.

Hi Vilian, Yes You are right, Thank You for explaining out that math. Its alot better to capture

Ok, I did it by using ContextFactory. Sorry Le jeudi 6 décembre 2018 14:23:18 UTC+1, yann.b...@gmail.

Hello, Jet's built-in sinks don't clean up the external structures in case of failure. If

I 'm may be an idiot... After refactoring test code, ok, Jet is faster whatever the system.

Thanks a lot !! it has worked : .groupingKey(fd->"INV"+(fd.getLineNumber() % 50000)) .