Fangbin Sun created FLINK-32527:
-----------------------------------

             Summary: 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


 
{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)

Reply via email to