[
https://issues.apache.org/jira/browse/FLINK-20633?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17458936#comment-17458936
]
Huang Xingbo commented on FLINK-20633:
--------------------------------------
[~gaoyunhaii] The existing python tests will mvn download the avro package when
it starts, and the reason for the error is that the download failed due to
occasional network reasons. The reason for the need to download the avro
package is recorded in https://issues.apache.org/jira/browse/FLINK-17417.
In view of the very low frequency of download failures, I think this is not a
serious problem.
> test_configuration.test_add_all test failed in py35
> ---------------------------------------------------
>
> Key: FLINK-20633
> URL: https://issues.apache.org/jira/browse/FLINK-20633
> Project: Flink
> Issue Type: Bug
> Components: API / Python
> Affects Versions: 1.13.0, 1.14.0, 1.12.5
> Reporter: Huang Xingbo
> Assignee: Huang Xingbo
> Priority: Critical
> Labels: test-stability
> Fix For: 1.15.0, 1.13.5, 1.14.2
>
>
> [https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=10946&view=logs&j=821b528f-1eed-5598-a3b4-7f748b13f261&t=4fad9527-b9a5-5015-1b70-8356e5c91490]
> {code:java}
> 2020-12-17T01:07:04.9062839Z _______________________
> ConfigurationTests.test_add_all ________________________
> 2020-12-17T01:07:04.9063107Z
> 2020-12-17T01:07:04.9063436Z self =
> <pyflink.common.tests.test_configuration.ConfigurationTests
> testMethod=test_add_all>
> 2020-12-17T01:07:04.9063719Z
> 2020-12-17T01:07:04.9063951Z def test_add_all(self):
> 2020-12-17T01:07:04.9064224Z > conf = Configuration()
> 2020-12-17T01:07:04.9064411Z
> 2020-12-17T01:07:04.9064665Z pyflink/common/tests/test_configuration.py:85:
> 2020-12-17T01:07:04.9065074Z _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
> _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
> 2020-12-17T01:07:04.9065474Z pyflink/common/configuration.py:43: in __init__
> 2020-12-17T01:07:04.9065765Z gateway = get_gateway()
> 2020-12-17T01:07:04.9066065Z pyflink/java_gateway.py:62: in get_gateway
> 2020-12-17T01:07:04.9066352Z _gateway = launch_gateway()
> 2020-12-17T01:07:04.9066671Z pyflink/java_gateway.py:104: in launch_gateway
> 2020-12-17T01:07:04.9076442Z p = launch_gateway_server_process(env, args)
> 2020-12-17T01:07:04.9076987Z pyflink/pyflink_gateway_server.py:197: in
> launch_gateway_server_process
> 2020-12-17T01:07:04.9079207Z download_apache_avro()
> 2020-12-17T01:07:04.9079558Z pyflink/pyflink_gateway_server.py:129: in
> download_apache_avro
> 2020-12-17T01:07:04.9163662Z cwd=flink_source_root).decode("utf-8")
> 2020-12-17T01:07:04.9164205Z
> dev/.conda/envs/3.5/lib/python3.5/subprocess.py:316: in check_output
> 2020-12-17T01:07:04.9164558Z **kwargs).stdout
> 2020-12-17T01:07:04.9164887Z _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
> _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
> 2020-12-17T01:07:04.9165168Z
> 2020-12-17T01:07:04.9165396Z input = None, timeout = None, check = True
> 2020-12-17T01:07:04.9166036Z popenargs = (['mvn', 'help:evaluate',
> '-Dexpression=avro.version'],)
> 2020-12-17T01:07:04.9166615Z kwargs = {'cwd': '/__w/1/s', 'stdout': -1}
> 2020-12-17T01:07:04.9166959Z process = <subprocess.Popen object at
> 0x7f0ff8a7a320>
> 2020-12-17T01:07:04.9168169Z stdout = b"[INFO] Scanning for
> projects...\nDownloading:
> https://repo.maven.apache.org/maven2/org/apache/apache/20/apache-20.po...R]
> After correcting the problems, you can resume the build with the
> command\n[ERROR] mvn <goals> -rf :flink-parent\n"
> 2020-12-17T01:07:04.9169079Z stderr = None, retcode = 1
> 2020-12-17T01:07:04.9169259Z
> 2020-12-17T01:07:04.9169600Z def run(*popenargs, input=None,
> timeout=None, check=False, **kwargs):
> 2020-12-17T01:07:04.9170061Z """Run command with arguments and return
> a CompletedProcess instance.
> 2020-12-17T01:07:04.9170373Z
> 2020-12-17T01:07:04.9170683Z The returned instance will have
> attributes args, returncode, stdout and
> 2020-12-17T01:07:04.9171117Z stderr. By default, stdout and stderr
> are not captured, and those attributes
> 2020-12-17T01:07:04.9171577Z will be None. Pass stdout=PIPE and/or
> stderr=PIPE in order to capture them.
> 2020-12-17T01:07:04.9171895Z
> 2020-12-17T01:07:04.9172409Z If check is True and the exit code was
> non-zero, it raises a
> 2020-12-17T01:07:04.9172852Z CalledProcessError. The
> CalledProcessError object will have the return code
> 2020-12-17T01:07:04.9173305Z in the returncode attribute, and output
> & stderr attributes if those streams
> 2020-12-17T01:07:04.9173662Z were captured.
> 2020-12-17T01:07:04.9173879Z
> 2020-12-17T01:07:04.9174175Z If timeout is given, and the process
> takes too long, a TimeoutExpired
> 2020-12-17T01:07:04.9174537Z exception will be raised.
> 2020-12-17T01:07:04.9174773Z
> 2020-12-17T01:07:04.9175040Z There is an optional argument "input",
> allowing you to
> 2020-12-17T01:07:04.9175663Z pass a string to the subprocess's stdin.
> If you use this argument
> 2020-12-17T01:07:04.9176301Z you may not also use the Popen
> constructor's "stdin" argument, as
> 2020-12-17T01:07:04.9176645Z it will be used internally.
> 2020-12-17T01:07:04.9176884Z
> 2020-12-17T01:07:04.9177163Z The other arguments are the same as for
> the Popen constructor.
> 2020-12-17T01:07:04.9177469Z
> 2020-12-17T01:07:04.9177777Z If universal_newlines=True is passed,
> the "input" argument must be a
> 2020-12-17T01:07:04.9178337Z string and stdout/stderr in the returned
> object will be strings rather than
> 2020-12-17T01:07:04.9178779Z bytes.
> 2020-12-17T01:07:04.9178981Z """
> 2020-12-17T01:07:04.9179206Z if input is not None:
> 2020-12-17T01:07:04.9179677Z if 'stdin' in kwargs:
> 2020-12-17T01:07:04.9180236Z raise ValueError('stdin and
> input arguments may not both be used.')
> 2020-12-17T01:07:04.9180719Z kwargs['stdin'] = PIPE
> 2020-12-17T01:07:04.9180942Z
> 2020-12-17T01:07:04.9181203Z with Popen(*popenargs, **kwargs) as
> process:
> 2020-12-17T01:07:04.9181505Z try:
> 2020-12-17T01:07:04.9181820Z stdout, stderr =
> process.communicate(input, timeout=timeout)
> 2020-12-17T01:07:04.9182159Z except TimeoutExpired:
> 2020-12-17T01:07:04.9182636Z process.kill()
> 2020-12-17T01:07:04.9182936Z stdout, stderr =
> process.communicate()
> 2020-12-17T01:07:04.9183280Z raise
> TimeoutExpired(process.args, timeout, output=stdout,
> 2020-12-17T01:07:04.9183718Z
> stderr=stderr)
> 2020-12-17T01:07:04.9183997Z except:
> 2020-12-17T01:07:04.9184232Z process.kill()
> 2020-12-17T01:07:04.9184491Z process.wait()
> 2020-12-17T01:07:04.9184716Z raise
> 2020-12-17T01:07:04.9184967Z retcode = process.poll()
> 2020-12-17T01:07:04.9185256Z if check and retcode:
> 2020-12-17T01:07:04.9185573Z raise
> CalledProcessError(retcode, process.args,
> 2020-12-17T01:07:04.9185943Z >
> output=stdout, stderr=stderr)
> 2020-12-17T01:07:04.9186749Z E subprocess.CalledProcessError:
> Command '['mvn', 'help:evaluate', '-Dexpression=avro.version']' returned
> non-zero exit status 1
> {code}
>
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
