Groups
Conversations
All groups and messages
Send feedback to Google
Help
Training
Sign in
Groups
hazelcast-jet
Conversations
About
hazelcast-jet
Contact owners and managers
1–30 of 83
Welcome to the
Hazelcast Jet
mailing list. Please post project ideas and general discussions here. For questions, please use
StackOverflow
with the
hazelcast-jet
tag. For Hazelcast IMDG questions, use
Hazelcast group
.
Mark all as read
Report group
0 selected
Parth Bhatt
6/5/23
Hazelcast Jet not removing Jobs/resources after completion
I trying to join 2 data sources using Hazelcast Jet and once I start Hazelcast Jet instance I do not
unread,
Hazelcast Jet not removing Jobs/resources after completion
I trying to join 2 data sources using Hazelcast Jet and once I start Hazelcast Jet instance I do not
6/5/23
Martin
9/30/22
Investment proposal
Dear Sir/ma Our investors are privately seeking means of expanding their investment portfolio and
unread,
Investment proposal
Dear Sir/ma Our investors are privately seeking means of expanding their investment portfolio and
9/30/22
Martin Krc
3/9/22
Avoiding JetClassLoader
Hi, How can we avoid using JetClassLoader? I can see that some of our processors occasionally cause
unread,
Avoiding JetClassLoader
Hi, How can we avoid using JetClassLoader? I can see that some of our processors occasionally cause
3/9/22
hern...@gmail.com
, …
Marko Topolnik
9
3/11/21
Jet profiling tips
>The flame graph looks as if your processors don't have much work to do. A big part is spent
unread,
Jet profiling tips
>The flame graph looks as if your processors don't have much work to do. A big part is spent
3/11/21
Fatih Arslan
, …
Can Gencer
27
3/8/21
snapshots in hazelcast jet
Thanks Can and Villiam. I suppose we have to mount a persistent volume to our containers then. We do
unread,
snapshots in hazelcast jet
Thanks Can and Villiam. I suppose we have to mount a persistent volume to our containers then. We do
3/8/21
huu toan
,
Vladimir Schreiner
2
11/24/20
Does jet support enrich infinite stream like ktable join ktable in kafka?
Hi, so you want use Jet to join tables extracted from Postgres as change streams? If so, please
unread,
Does jet support enrich infinite stream like ktable join ktable in kafka?
Hi, so you want use Jet to join tables extracted from Postgres as change streams? If so, please
11/24/20
Evyatar Kafkafi
10/22/20
Hazelcast Jet client in a Quarkus application
Hi all I run a Quarkus application with the Hazelcast (IMDG) extension (quarkus-hazelcast-client). I
unread,
Hazelcast Jet client in a Quarkus application
Hi all I run a Quarkus application with the Hazelcast (IMDG) extension (quarkus-hazelcast-client). I
10/22/20
Pranas Baliuka
,
Viliam Durina
2
9/16/20
Real multiple IMap stream Joins
Currently, we support co-grouping into windows: timestamped events from multiple streams will be
unread,
Real multiple IMap stream Joins
Currently, we support co-grouping into windows: timestamped events from multiple streams will be
9/16/20
Pranas Baliuka
,
Viliam Durina
2
9/16/20
Serializable and not serializable lambdas
Jet jobs can use any of these classes: - available on member's classpath (eg through adding a jar
unread,
Serializable and not serializable lambdas
Jet jobs can use any of these classes: - available on member's classpath (eg through adding a jar
9/16/20
fatih.ar...@gmail.com
, …
Can Gencer
35
8/31/20
Cluster sizing
I wrote you also on Slack, but this is almost certainly due to the partition idle timeout which is 60
unread,
Cluster sizing
I wrote you also on Slack, but this is almost certainly due to the partition idle timeout which is 60
8/31/20
Martin Krc
,
Marko Topolnik
2
8/24/20
Performance of distributed edges
If you measure the time from the point tryEmit(item) succeeds, at that point Jet already placed the
unread,
Performance of distributed edges
If you measure the time from the point tryEmit(item) succeeds, at that point Jet already placed the
8/24/20
Can Gencer
4/29/20
Hazelcast Jet 4.1 is released
I'm happy to announce Jet 4.1 is released. See the notes below and thanks to all the contributors
unread,
Hazelcast Jet 4.1 is released
I'm happy to announce Jet 4.1 is released. See the notes below and thanks to all the contributors
4/29/20
vladc...@gmail.com
,
Can Gencer
5
4/9/20
Slow operation within ReadWithPartitionIteratorP
Possibly, but not sure. That's why I am trying to find out here (from the Jet perspective) what
unread,
Slow operation within ReadWithPartitionIteratorP
Possibly, but not sure. That's why I am trying to find out here (from the Jet perspective) what
4/9/20
vladc...@gmail.com
,
Can Gencer
3
4/2/20
Completed jobs vanishing
Yes you are right. In further versions (I think it was 3.1) we also introduced "jet.job.results.
unread,
Completed jobs vanishing
Yes you are right. In further versions (I think it was 3.1) we also introduced "jet.job.results.
4/2/20
Can Gencer
4/1/20
Jet 3.x to 4.x migration guide
Hi, We have now published a migration guide for Jet 3.x users to 4.x: https://jet-start.sh/blog/2020/
unread,
Jet 3.x to 4.x migration guide
Hi, We have now published a migration guide for Jet 3.x users to 4.x: https://jet-start.sh/blog/2020/
4/1/20
Can Gencer
3/30/20
New design documents
Hi, We've now started putting design documents some of our upcoming 4.1 features as design
unread,
New design documents
Hi, We've now started putting design documents some of our upcoming 4.1 features as design
3/30/20
Can Gencer
3/20/20
Hazelcast Jet 4.0 is released!
Slightly delayed announcement, but I'm happy to announce that Hazelcast Jet 4.0 is released. You
unread,
Hazelcast Jet 4.0 is released!
Slightly delayed announcement, but I'm happy to announce that Hazelcast Jet 4.0 is released. You
3/20/20
vladc...@gmail.com
, …
Viliam Durina
8
1/28/20
Job priority
And more to Marko's point: you can also use Edge queue length. A processor gets all the data that
unread,
Job priority
And more to Marko's point: you can also use Edge queue length. A processor gets all the data that
1/28/20
Lukáš Herman
,
Can Gencer
2
8/6/19
StartExecutionOperation invocation failed to complete due to operation-heartbeat-timeout.
Hi Lukáš, Please see this PR: https://github.com/hazelcast/hazelcast-jet/pull/1377 Previously the
unread,
StartExecutionOperation invocation failed to complete due to operation-heartbeat-timeout.
Hi Lukáš, Please see this PR: https://github.com/hazelcast/hazelcast-jet/pull/1377 Previously the
8/6/19
vladc...@gmail.com
,
Viliam Durina
2
7/12/19
Replacing StreamEventJournalP with a custom solution
You're right, the capacity of map journal is distributed evenly among partitions and if one
unread,
Replacing StreamEventJournalP with a custom solution
You're right, the capacity of map journal is distributed evenly among partitions and if one
7/12/19
srikan...@gmail.com
,
Viliam Durina
2
5/2/19
Does Hazelcast Jet support rolling number as IMap key, with Kafka as a source?
Question was answered on StackOverflow, please continue there. Viliam On Thu, 2 May 2019 at 15:55,
unread,
Does Hazelcast Jet support rolling number as IMap key, with Kafka as a source?
Question was answered on StackOverflow, please continue there. Viliam On Thu, 2 May 2019 at 15:55,
5/2/19
Lukáš Herman
,
Can Gencer
8
3/18/19
Disable Jet diagnostics module
Hi Lukas, Yes this is in progress, currently only Jet is using this convention but the plan is to
unread,
Disable Jet diagnostics module
Hi Lukas, Yes this is in progress, currently only Jet is using this convention but the plan is to
3/18/19
Lukáš Herman
,
Can Gencer
6
2/28/19
Batch job limit
Yes, you shouldn't use paging predicate but do it yourself using the iterator. Something like (
unread,
Batch job limit
Yes, you shouldn't use paging predicate but do it yourself using the iterator. Something like (
2/28/19
pdu...@gmail.com
,
c...@hazelcast.com
2
1/18/19
Alerting / state machine use case with Hazelcast Jet
Hi Patrick, Any mapping / flatMapping stages after a source will cause items to be reordered in the
unread,
Alerting / state machine use case with Hazelcast Jet
Hi Patrick, Any mapping / flatMapping stages after a source will cause items to be reordered in the
1/18/19
Benjamin E.Ndugga
, …
Can Gencer
17
1/3/19
Does Hazelcast Jet read/process multiple Files???
Hi Ben, You can't have SimpleDateFormat and have only one instance as it's not thread-safe.
unread,
Does Hazelcast Jet read/process multiple Files???
Hi Ben, You can't have SimpleDateFormat and have only one instance as it's not thread-safe.
1/3/19
Benjamin E.Ndugga
, …
vil...@hazelcast.com
11
12/14/18
How to make Use of the Linear Trend function!!!
Hi Vilian, Yes You are right, Thank You for explaining out that math. Its alot better to capture
unread,
How to make Use of the Linear Trend function!!!
Hi Vilian, Yes You are right, Thank You for explaining out that math. Its alot better to capture
12/14/18
yann.b...@gmail.com
,
c...@hazelcast.com
4
12/7/18
Jet and CDI
Ok, I did it by using ContextFactory. Sorry Le jeudi 6 décembre 2018 14:23:18 UTC+1, yann.b...@gmail.
unread,
Jet and CDI
Ok, I did it by using ContextFactory. Sorry Le jeudi 6 décembre 2018 14:23:18 UTC+1, yann.b...@gmail.
12/7/18
yann.b...@gmail.com
,
vil...@hazelcast.com
2
12/4/18
Clean resources used by a Job
Hello, Jet's built-in sinks don't clean up the external structures in case of failure. If
unread,
Clean resources used by a Job
Hello, Jet's built-in sinks don't clean up the external structures in case of failure. If
12/4/18
yann.b...@gmail.com
, …
Can Gencer
14
12/3/18
Jet performances vs simple job
I 'm may be an idiot... After refactoring test code, ok, Jet is faster whatever the system.
unread,
Jet performances vs simple job
I 'm may be an idiot... After refactoring test code, ok, Jet is faster whatever the system.
12/3/18
yann.b...@gmail.com
,
Can Gencer
5
11/28/18
Job Running only on one node ???
Thanks a lot !! it has worked : .groupingKey(fd->"INV"+(fd.getLineNumber() % 50000)) .
unread,
Job Running only on one node ???
Thanks a lot !! it has worked : .groupingKey(fd->"INV"+(fd.getLineNumber() % 50000)) .
11/28/18