[
https://issues.apache.org/jira/browse/FLINK-32527?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora closed FLINK-32527.
------------------------------
Resolution: Fixed
merged to main f21426201842b5df3c9a4f13ce41973d2ae67430
> Build failure on Windows
> ------------------------
>
> Key: FLINK-32527
> URL: https://issues.apache.org/jira/browse/FLINK-32527
> Project: Flink
> Issue Type: Bug
> Components: Kubernetes Operator
> Reporter: Fangbin Sun
> Assignee: Fangbin Sun
> Priority: Minor
> Labels: pull-request-available
>
>
> {code:java}
> [INFO] --- maven-antrun-plugin:1.8:run (deployment-crd-compatibility-check) @
> flink-kubernetes-operator-api ---
> [INFO] Executing tasksmain:
> [java] 2023-07-04 16:07:45,348 o.a.f.k.o.a.v.CrdCompatibilityChecker
> [INFO ] [.] New schema:
> file://E:\project\open\flink-operator-main\flink-kubernetes-operator/helm/flink-kubernetes-operator/crds/flinkdeployments.flink.apache.org-v1.yml
> [java] 2023-07-04 16:07:45,350 o.a.f.k.o.a.v.CrdCompatibilityChecker
> [INFO ] [.] Old schema:
> https://raw.githubusercontent.com/apache/flink-kubernetes-operator/release-1.4.0/helm/flink-kubernetes-operator/crds/flinkdeployments.flink.apache.org-v1.yml
> [java] Exception in thread "main" java.net.UnknownHostException: E
> [java] at
> java.base/java.net.AbstractPlainSocketImpl.connect(AbstractPlainSocketImpl.java:220)
> [java] at java.base/java.net.Socket.connect(Socket.java:609)
> [java] at
> java.base/sun.net.ftp.impl.FtpClient.doConnect(FtpClient.java:1062)
> [java] at
> java.base/sun.net.ftp.impl.FtpClient.tryConnect(FtpClient.java:1024)
> [java] at
> java.base/sun.net.ftp.impl.FtpClient.connect(FtpClient.java:1119)
> [java] at
> java.base/sun.net.ftp.impl.FtpClient.connect(FtpClient.java:1105)
> [java] at
> java.base/sun.net.www.protocol.ftp.FtpURLConnection.connect(FtpURLConnection.java:312)
> [java] at
> java.base/sun.net.www.protocol.ftp.FtpURLConnection.getInputStream(FtpURLConnection.java:418)
> [java] at java.base/java.net.URL.openStream(URL.java:1165)
> [java] at
> com.fasterxml.jackson.core.TokenStreamFactory._optimizedStreamFromURL(TokenStreamFactory.java:262)
> [java] at
> com.fasterxml.jackson.dataformat.yaml.YAMLFactory.createParser(YAMLFactory.java:400)
> [java] at
> com.fasterxml.jackson.dataformat.yaml.YAMLFactory.createParser(YAMLFactory.java:15)
> [java] at
> com.fasterxml.jackson.databind.ObjectMapper.readTree(ObjectMapper.java:3268)
> [java] at
> org.apache.flink.kubernetes.operator.api.validation.CrdCompatibilityChecker.getSchema(CrdCompatibilityChecker.java:66)
> [java] at
> org.apache.flink.kubernetes.operator.api.validation.CrdCompatibilityChecker.main(CrdCompatibilityChecker.java:60)
> [INFO]
> ------------------------------------------------------------------------
> [INFO] Reactor Summary for Flink Kubernetes: 1.6-SNAPSHOT:
> [INFO]
> [INFO] Flink Kubernetes: .................................. SUCCESS [ 4.028
> s]
> [INFO] Flink Kubernetes Standalone ........................ SUCCESS [ 8.140
> s]
> [INFO] Flink Kubernetes Operator Api ...................... FAILURE [ 31.335
> s]
> [INFO] Flink Kubernetes Operator .......................... SKIPPED
> [INFO] Flink Kubernetes Operator Autoscaler ............... SKIPPED
> [INFO] Flink Kubernetes Webhook ........................... SKIPPED
> [INFO] Flink Kubernetes Docs .............................. SKIPPED
> [INFO] Flink SQL Runner Example ........................... SKIPPED
> [INFO] Flink Beam Example ................................. SKIPPED
> [INFO] Flink Kubernetes Client Code Example ............... SKIPPED
> [INFO] Flink Autoscaler Test Job .......................... SKIPPED
> [INFO]
> ------------------------------------------------------------------------
> [INFO] BUILD FAILURE
> [INFO]
> ------------------------------------------------------------------------
> {code}
> This is due to `JsonNode readTree(URL source)` can not handle the file schema
> on windows as below:
>
> {code:java}
> protected InputStream _optimizedStreamFromURL(URL url) throws IOException {
> if ("file".equals(url.getProtocol())) {
> String host = url.getHost();
> if (host == null || host.length() == 0) {
> String path = url.getPath();
> if (path.indexOf(37) < 0) {
> return new FileInputStream(url.getPath());
> }
> }
> }
> return url.openStream();
> } {code}
> we should use `JsonNode readTree(File file)` instead.
>
>
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
