getindata/flink-http-connector
Http Connector for Apache Flink. Provides sources and sinks for Datastream , Table and SQL APIs.
JavaApache-2.0
Issues
- 2
Support Flink 1.20
#103 opened by davidradl - 7
- 2
HTTP connector caching with time out not working
#133 opened by davidradl - 5
Support for API path parameters
#74 opened by AdrianVasiliu - 4
- 0
- 2
- 1
Allow short lived bearer tokens to be used (first implementation being against IBM cloud)
#91 opened by davidradl - 2
Public certificates should not have to be supplied as they should be picked up from the jvm
#119 opened by davidradl - 3
Async lookups return incorrect results because JsonRowDataSerializationSchema is not thread-safe
#121 opened by grzegorz8 - 5
Support Flink 2 (and preview)
#126 opened by davidradl - 0
Implement lookup retry mechanism
#122 opened by grzegorz8 - 0
Implement rate limiting strategy
#67 opened by kristoffSC - 4
Exception: trustAnchors parameter must be non-empty
#107 opened by matanper - 3
http source select exception
#108 opened by 731879846kk - 6
Implement Cache in Lookup Http Source
#63 opened by kristoffSC - 1
- 3
- 9
- 1
Logging code at DEBUG level in JavaNetHttpPollingClient wrongly displays the status code and response body values.
#96 opened by AdrianVasiliu - 0
- 1
how to POST array values?
#89 opened by p-eye - 1
assess whether to build with flink 1.16
#69 opened by davidradl - 7
Check Flink 1.17 compatibility
#64 opened by kristoffSC - 2
junit failures
#73 opened by davidradl - 4
Configuration option to enforce the use of the raw value of the Authorization header.
#76 opened by AdrianVasiliu - 2
- 1
Is there any branch for jdk 8 and flink 1.13?
#75 opened by qiunanx - 1
- 3
HTTP connect timed out error
#66 opened by louiscb - 21
Class loading issues when running Http Connector from SQL Client on Flink 1.16
#54 opened by kristoffSC - 6
- 1
- 7
setElementConverter for HttpSinkRequestEntry is deprecated ,what is alternate method or code we need to use
#61 opened by someshwar1 - 0
Update Readme and Examples to include setElementConverter(SchemaLifecycleAwareElementConverter)
#62 opened by kristoffSC - 11
Sink Writer to write in batches
#42 opened by talsheldon - 4
- 4
Whether to consider support for jdk8
#55 opened by RoronoaZoro1665 - 7
Is there support flink 1.16?
#37 opened by agostop - 0
Lookup Reqeust body/parameters not printed by Slf4JHttpLookupPostRequestCallback
#45 opened by kristoffSC - 0
- 0
LookupSource - Flink's task queue for async mode not clean up after HTTP client timeout
#38 opened by kristoffSC - 0
[HTTP-34] Support Lookup Join on ROW type
#34 opened by kristoffSC - 2
How to run on flink 1.14.5?
#18 opened by yh-rgb - 4
- 0
Could provide performance test?
#33 opened by wellCh4n