flink-http-connector
flink-http-connector copied to clipboard
getindata
Http Connector for Apache Flink. Provides sources and sinks for Datastream , Table and SQL APIs.
In some use cases, apis require batched data to be submitted as a raw string rather than wrapped in a JSON array. Currently the only way to send batched raw...
We are looking to ignore parse error in the json format, so we can ignore json response parse errors. There does not seem to be a way to define this....
#### Description The target of this PR is to fix the below issue, you can check the detail following the link. The root cause is the mapper is null, the...
### Description I use this repo as **sink connector** for flink sql, but I found that the job can't restore from checkpoint and throw NullPointerException when the job crash. Except...
#193 changes add new custom format options for responses, the naming of the config options for `lookup-response` follows the standard Flink Kafka connector. The existing `lookup-request` does not follow the...
#### Description Allo config to control the level of HTTP request, response and header logging. Resolves `HTTP187` ##### PR Checklist - [y] Tests added - [y] [Changelog](CHANGELOG.md) updated
Since `flink-runtime` includes a `org.apache.flink:flink-shaded-jackson` dependency, [`JavaNetHttpPollingClient`](https://github.com/getindata/flink-http-connector/blob/0.23.0/src/main/java/com/getindata/connectors/http/internal/table/lookup/JavaNetHttpPollingClient.java#L18) introduces and use the original Jackson dependency (in `com.fasterxml.jackson`). Is this necessary? Introducing original version may cause class loading issues in some situations....
After feedback on [https://github.com/apache/flink-connector-http/pull/5](https://github.com/apache/flink-connector-http/pull/5) and further thinking in IBM and in response to the Flink feedback, we are suggesting default no sensitive data but allow more tracing to be enabled....
#### Description Attempting to re-vitalize the http sink updates. Branch ended up getting bigger than I hoped, but please provide any feedback you have! Resolves `` ##### PR Checklist -...
#### Description `consolidate http configuration between sink and lookup` Resolves `183` ##### PR Checklist - [x] Tests added - [x] [Changelog](CHANGELOG.md) updated