flink-http-connector

flink-http-connector copied to clipboard

Currently, when HTTP request fails, `Optional.empty()` is returned. Instead, we should retry the request configurable number of times. In addition, we should distinguish retryable errors from non-retryable ones (e.g. 400...

grzegorz8

Public certificates should not have to be supplied as they should be picked up from the jvm

1

During https://github.com/getindata/flink-http-connector/issues/91 I was testing against a rest end point. The rest call was successful if issued with curl, but failed the ssl handshake in this connector. The reason it...

davidradl

#### Description We currently have the issue that we cannot query an API from within our Kubernetes cluster due to some security concerns. This PR adds an optional parameter "proxy"...

buenzlidominik

#### Description This PR resolves issue with missing permissions in github workflows. ``` remote: Permission to getindata/flink-http-connector.git denied to github-actions[bot]. fatal: unable to access 'https://github.com/getindata/flink-http-connector/': The requested URL returned error:...

grzegorz8

We currently have the issue that we cannot query an API from within our Kubernetes cluster due to some security concerns . Therefore, we need the option to use a...

buenzlidominik

Query params not replaced, can you provide any SQL example ?

8

Hi, I am facing a bit of an issue and I am not sure what I am missing: CREATE OR REPLACE TABLE api_driver_safety_records ( driverId BIGINT, crashCount INT, harshAccelCount INT,...

giulio1979

Regression using Flink 1.20 relating to timestamp precision

5

I have a test case ``` CREATE TABLE `source_1` ( `customerId` STRING, `param_string_date_time` TIMESTAMP_LTZ(9), `ts` TIMESTAMP(3), WATERMARK FOR `ts` AS `ts` - INTERVAL '1' MINUTE ) WITH ( 'connector' =...

davidradl

davidradl

Feature Request: Support for Consuming Update Changes in Table Sink

2

Currently, Flink throws a `TableException` when attempting to consume update changes from an aggregation operation in the query (like LISTAGG). The specific error occurs when trying to create a table...

nchen07

HTTP connector caching with time out not working

2

A colleague found that HTTP connector caching with timeout not working. Maxrows worked. This issue is to investigate, add a fix and junit if required.

davidradl