(flink-connector-http) branch main updated: [hotfix] Fixup test implmentation

[fcsaky]

This is an automated email from the ASF dual-hosted git repository.

fcsaky pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/flink-connector-http.git


The following commit(s) were added to refs/heads/main by this push:
     new 6659115  [hotfix] Fixup test implmentation
6659115 is described below

commit 665911588bb02de53fe7e58251904e78e91e7c3b
Author: David Radley <39792797+davidr...@users.noreply.github.com>
AuthorDate: Mon Jan 12 15:35:00 2026 +0000

    [hotfix] Fixup test implmentation
---
 .../http/table/lookup/JavaNetHttpPollingClient.java   | 19 +------------------
 1 file changed, 1 insertion(+), 18 deletions(-)

diff --git 
a/flink-connector-http/src/main/java/org/apache/flink/connector/http/table/lookup/JavaNetHttpPollingClient.java
 
b/flink-connector-http/src/main/java/org/apache/flink/connector/http/table/lookup/JavaNetHttpPollingClient.java
index 81260ed..84f4192 100644
--- 
a/flink-connector-http/src/main/java/org/apache/flink/connector/http/table/lookup/JavaNetHttpPollingClient.java
+++ 
b/flink-connector-http/src/main/java/org/apache/flink/connector/http/table/lookup/JavaNetHttpPollingClient.java
@@ -18,6 +18,7 @@
 package org.apache.flink.connector.http.table.lookup;
 
 import org.apache.flink.annotation.VisibleForTesting;
+import org.apache.flink.api.common.functions.util.ListCollector;
 import org.apache.flink.api.common.serialization.DeserializationSchema;
 import org.apache.flink.configuration.ReadableConfig;
 import org.apache.flink.connector.http.HttpLogger;
@@ -333,24 +334,6 @@ public class JavaNetHttpPollingClient implements 
PollingClient {
         return Collections.unmodifiableList(result);
     }
 
-    private static class ListCollector implements 
org.apache.flink.util.Collector<RowData> {
-        private final List<RowData> list;
-
-        ListCollector(List<RowData> list) {
-            this.list = list;
-        }
-
-        @Override
-        public void collect(RowData record) {
-            list.add(record);
-        }
-
-        @Override
-        public void close() {
-            // No-op
-        }
-    }
-
     @VisibleForTesting
     List<RowData> deserializeArray(byte[] rawBytes) throws IOException {
         List<JsonNode> rawObjects = objectMapper.readValue(rawBytes, new 
TypeReference<>() {});