[
https://issues.apache.org/jira/browse/FLINK-5650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15925943#comment-15925943
]
Chesnay Schepler commented on FLINK-5650:
-----------------------------------------
This got very little to do with test design; the python tests are actually
integration tests that simply run jobs like they would normally be run. The
connection must be established synchronously as otherwise you cannot fulfill
the purpose of open(); instantiate all resources that are required to do the
data processing.
We can however add a timeout to prevent it from being active for too long.
Nevertheless i would like to know why the python process doesn't connect, since
it does start up properly.
> Flink-python tests executing cost too long time
> -----------------------------------------------
>
> Key: FLINK-5650
> URL: https://issues.apache.org/jira/browse/FLINK-5650
> Project: Flink
> Issue Type: Bug
> Components: Python API, Tests
> Affects Versions: 1.2.0
> Reporter: shijinkui
> Priority: Critical
> Fix For: 1.2.1
>
>
> When execute `mvn clean test` in flink-python, it will wait more than half
> hour after the console output below:
> -------------------------------------------------------
> T E S T S
> -------------------------------------------------------
> Running org.apache.flink.python.api.PythonPlanBinderTest
> log4j:WARN No appenders could be found for logger
> (org.apache.flink.python.api.PythonPlanBinderTest).
> log4j:WARN Please initialize the log4j system properly.
> log4j:WARN See http://logging.apache.org/log4j/1.2/faq.html#noconfig for more
> info.
> The stack below:
> "main" prio=5 tid=0x00007f8d7780b800 nid=0x1c03 waiting on condition
> [0x0000700009fd8000]
> java.lang.Thread.State: TIMED_WAITING (sleeping)
> at java.lang.Thread.sleep(Native Method)
> at
> org.apache.flink.python.api.streaming.plan.PythonPlanStreamer.startPython(PythonPlanStreamer.java:70)
> at
> org.apache.flink.python.api.streaming.plan.PythonPlanStreamer.open(PythonPlanStreamer.java:50)
> at
> org.apache.flink.python.api.PythonPlanBinder.startPython(PythonPlanBinder.java:211)
> at
> org.apache.flink.python.api.PythonPlanBinder.runPlan(PythonPlanBinder.java:141)
> at
> org.apache.flink.python.api.PythonPlanBinder.main(PythonPlanBinder.java:114)
> at
> org.apache.flink.python.api.PythonPlanBinderTest.testProgram(PythonPlanBinderTest.java:83)
> at
> org.apache.flink.test.util.JavaProgramTestBase.testJobWithoutObjectReuse(JavaProgramTestBase.java:174)
> this is the jstack:
> https://gist.github.com/shijinkui/af47e8bc6c9f748336bf52efd3df94b0
--
This message was sent by Atlassian JIRA
(v6.3.15#6346)
