kristoffSC
kristoffSC
Adding Table/SQL support for Delta-Flink Sink connector. The Table architecture for Flink connectors is showed on below diagram:  This PR provides Delta specific implementation for: - DynamicTableSinkFactory - DynamitTableSink...
Hi, I have stumble upon an issue during Javadoc generation from sbt-unidoc. Javadoc creation succeeds even though there are Errors during doc generation. I have a reproducer available here under...
Hi all, on one of our instances we detected a deadlock in c3p0. It happens when there is a JMX query for c3p0's pool attributes while this pool is being...
Hi, great library :) Would it be possible to release a new version with all dependencies shaded? Especially those: - org.apache.calcite:calcite-core - org.apache.calcite:calcite-druid - org.apache.calcite:calcite-linq4j - org.apache.calcite:calcite-avatica - - org.apache.parquet",...
Currently http lookup source will forward every lookup query to external system. This can be easily a bottle neck for processing pipeline. A remedy for this would be to implement...
In Flink 1.16 a `[Rate limiting API](https://flink.apache.org/2022/11/25/optimising-the-throughput-of-async-sinks-using-a-custom-ratelimitingstrategy/)` was added to Flink Async Writer. This can help to slow down rate of Http calls in case when HTTP endpoint is overwhelmed...
README and examples still points to deprecated method 'setElementConverter(ElementConverter)' Update README and Examples to include 'setElementConverter(SchemaLifecycleAwareElementConverter)' instead.
#### Description Fix bug where default Java TrustStore was not used when no cert-related properties were used. Resolves [Public certificates should not have to be supplied as they should be...