This is an automated email from the ASF dual-hosted git repository.
hansva pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/hop.git
The following commit(s) were added to refs/heads/master by this push:
new fe422d3cb3 fix for HOP-4644
new 7a64b9bcc3 Merge pull request #1898 from dodok1/bugfix/rest-buffered
fe422d3cb3 is described below
commit fe422d3cb3f06a069ddbabbc63848b963ec5a59a
Author: Jozef Kotlar <[email protected]>
AuthorDate: Thu Dec 1 17:21:15 2022 +0100
fix for HOP-4644
ApacheConnector in REST client is set to BUFFERED mode
---
.../src/main/java/org/apache/hop/pipeline/transforms/rest/Rest.java | 2 ++
1 file changed, 2 insertions(+)
diff --git
a/plugins/transforms/rest/src/main/java/org/apache/hop/pipeline/transforms/rest/Rest.java
b/plugins/transforms/rest/src/main/java/org/apache/hop/pipeline/transforms/rest/Rest.java
index bf0bbdd637..f225df839a 100644
---
a/plugins/transforms/rest/src/main/java/org/apache/hop/pipeline/transforms/rest/Rest.java
+++
b/plugins/transforms/rest/src/main/java/org/apache/hop/pipeline/transforms/rest/Rest.java
@@ -32,6 +32,7 @@ import
org.glassfish.jersey.apache.connector.ApacheConnectorProvider;
import org.glassfish.jersey.client.ClientConfig;
import org.glassfish.jersey.client.ClientProperties;
import org.glassfish.jersey.client.HttpUrlConnectorProvider;
+import org.glassfish.jersey.client.RequestEntityProcessing;
import org.glassfish.jersey.client.authentication.HttpAuthenticationFeature;
import org.glassfish.jersey.uri.UriComponent;
import org.json.simple.JSONObject;
@@ -293,6 +294,7 @@ public class Rest extends BaseTransform<RestMeta, RestData>
{
// Use ApacheHttpClient for supporting proxy authentication.
data.config = new ClientConfig();
data.config.connectorProvider(new ApacheConnectorProvider());
+ data.config.property(ClientProperties.REQUEST_ENTITY_PROCESSING,
RequestEntityProcessing.BUFFERED);
if (!Utils.isEmpty(data.realProxyHost)) {
// PROXY CONFIGURATION
data.config.property(ClientProperties.PROXY_URI,"http://"+
data.realProxyHost + ":" + data.realProxyPort);