František Hartman
František Hartman
This PR adds a new connector for JDBC to Hazelcast SQL, which allows connecting to any database supporting the JDBC interface. This is a prerequisite for HZ-1261. ## Changes to...
In `WriteJdbcP#process` we check for `SQLNonTransientException`, but there can be a chain of exceptions via `getNextException()`, where a SQLNonTransientException can be present. Also in `WriteJdbcP#connectAndPrepareStatement` we call `javax.sql.DataSource#getConnection` which can...
When there is a SQL exception in `ReadJdbcP` the job always fails. For certain kinds of transient exceptions, we could retry the operation, e.g. `java.sql.ResultSet#next`. It would be especially useful...
When the input file is large it is split into multiple FileSplits. Previously the CsvInputFormat wasn't respecting the split boundaries and read whole file. Causing duplicates when file had multiple...
When the input file is large it is split into multiple FileSplits. Previously the CsvInputFormat wasn't respecting the split boundaries and read whole file. Causing duplicates when file had multiple...
We need to backport the following to Jet 4.5 - update HZ to latest - backport https://github.com/hazelcast/hazelcast-enterprise/pull/5295 (HZ-1475) - update 3rd party dependencies to fix high and critical issues
PR to master (commit ab5317f) Failed on Jenkins: http://jenkins.hazelcast.com/job/Hazelcast-pr-builder/19404/testReport/junit/com.hazelcast.jet.kinesis/KinesisIntegrationTest/dynamicStream_1Shard_splitsDuringData/ Stacktrace: ``` java.lang.AssertionError: Messages for key 230 differ! expected: 10 actual: 610 expected: 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 com.hazelcast.jet.kinesis.AbstractKinesisTest.lambda$assertMessages$3(AbstractKinesisTest.java:180)...
The following test case fails for client: ``` public class JobFailureTest extends TestInClusterSupport { @Test public void name() { BatchSource source = SourceBuilder.batch("test", (context) -> new HashSet()) .fillBufferFn((strings, sourceBuffer) ->...
We have a mismatch in behavior in types of mappings and data connections. All values provided by the user are case-insensitive, but: - mapping type is kept as provided by...