[
https://issues.apache.org/jira/browse/FLINK-18369?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17140355#comment-17140355
]
Dawid Wysakowicz commented on FLINK-18369:
------------------------------------------
Hi, [~godfreyhe]
I did a small investigation on it. I think the problem is the usage of
{{writeAsText}} /{{TextOutputFormat}} writing twice to the same path from a
single {{Job}}.
After we switched in https://issues.apache.org/jira/browse/FLINK-17383 from a
Collection to Cluster execution mode, the job is executed truly parallelized
(before every operation was effectively sequential).
I am not 100% sure what is the purpose of this test, but I see that we do not
care about the actual results. Maybe it would be ok to use a different sink, if
the purpose is to check the sinks will get suffixed with an id?
> TableEnvironmentITCase.testStatementSetWithSameSinkTableNames failed on azure
> -----------------------------------------------------------------------------
>
> Key: FLINK-18369
> URL: https://issues.apache.org/jira/browse/FLINK-18369
> Project: Flink
> Issue Type: Bug
> Components: Table SQL / Legacy Planner
> Affects Versions: 1.12.0
> Reporter: Piotr Nowojski
> Priority: Critical
> Labels: test-stability
> Fix For: 1.12.0
>
>
> https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=3778&view=logs&j=b2f046ab-ae17-5406-acdc-240be7e870e4&t=93e5ae06-d194-513d-ba8d-150ef6da1d7c
> {noformat}
> Caused by: java.io.IOException: Output path
> '/tmp/junit6162277837132243514/junit3149129531927352947.tmp' could not be
> initialized. Canceling task...
> at
> org.apache.flink.api.common.io.FileOutputFormat.open(FileOutputFormat.java:229)
> at
> org.apache.flink.api.java.io.TextOutputFormat.open(TextOutputFormat.java:88)
> at
> org.apache.flink.runtime.operators.DataSinkTask.invoke(DataSinkTask.java:205)
> at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:721)
> at org.apache.flink.runtime.taskmanager.Task.run(Task.java:546)
> at java.lang.Thread.run(Thread.java:748)
> {noformat}
> {noformat}
> [ERROR] Errors:
> [ERROR] TableEnvironmentITCase.testStatementSetWithSameSinkTableNames:557 ยป
> Execution ...
> [INFO]
> [ERROR] Tests run: 810, Failures: 0, Errors: 1, Skipped: 13
> {noformat}
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
