hazelcast-jet
hazelcast-jet copied to clipboard
hazelcast
Distributed Stream and Batch Processing
Using Jet 4.5, and map source, some report as "GET" operations and some as "OTHER" https://github.com/hazelcast/hazelcast-platform-demos/blob/master/banking/credit-value-adjustment/jet-jobs/src/main/java/com/hazelcast/platform/demos/banking/cva/cvastp/CvaStpJob.java#L344 gives "cva_ircurves" but https://github.com/hazelcast/hazelcast-platform-demos/blob/master/banking/credit-value-adjustment/jet-jobs/src/main/java/com/hazelcast/platform/demos/banking/cva/cvastp/CvaStpJob.java#L340 gives "cva_trades"
Fixes #NNNN (point out issues this PR fixes, if any) Breaking changes (list specific methods/types/messages): * API * client protocol format * serialized form * snapshot format Checklist: - [...
Jet uses Snakeyaml `1.15`, `1.16` and `1.17` which includes following vulnerabilities: - CVE-2017-18640 - https://nvd.nist.gov/vuln/detail/CVE-2017-18640 (fixed in 1.26)
_master_ (commit bed77b2d6df579b3e4645472195d69f7905511d9) Failed on Nightly run with Oracle JDK 8: http://jenkins.hazelcast.com/job/jet-oss-master-nightly-oracle-jdk8/461/testReport/junit/com.hazelcast.jet.cdc.mysql/MySqlCdcListenBeforeExistIntegrationTest/listenBeforeTableExists/ Stacktrace: ``` java.lang.AssertionError: expected: but was: at org.junit.Assert.fail(Assert.java:89) at org.junit.Assert.failNotEquals(Assert.java:835) at org.junit.Assert.assertEquals(Assert.java:120) at org.junit.Assert.assertEquals(Assert.java:146) at com.hazelcast.test.HazelcastTestSupport$9.run(HazelcastTestSupport.java:1016) at com.hazelcast.test.HazelcastTestSupport.assertTrueEventually(HazelcastTestSupport.java:1247)...
When the user configures the queue size of the edge to a value that is not a power of 2, we round this value up to the next power of...
The following script: ``` create mapping t type imap options ('keyFormat'='int', 'valueFormat'='varchar'); sink into t select 1, 'a' from table(generate_series(0, 0)); ``` fails with: ``` Type mismatch [expectedClass=java.lang.Integer, actualClass=java.lang.Byte] ```...
On Jet 4.4, if I try ``` SELECT MAX(someField) FROM kafka_topic ``` I get ``` Grouping/aggregations not supported for a streaming query ``` It would be useful to be able...
In Jet 4.4, jobs that are implicitly created (eg. as a result of `jetInstance.getSql().execute("SELECT * FROM something")` have no job name It would be useful to be able to distinguish...
See https://github.com/hazelcast/hazelcast-jet/issues/2940 On Jet 4.4, if an SQL query is cancelled, the job appears as unsuccessful The user may be cancelling because the query is broken or because they have...
When querying a Kafka topic, it would be useful to be able to limit the query based on the current offset, `SELECT * FROM public topicname LIMIT current_offset` So this...