[flink] 02/10: [hotfix][fs-connector] Fix the typo in the FileSinkITCase

[aljoscha]

This is an automated email from the ASF dual-hosted git repository.

aljoscha pushed a commit to branch release-1.12
in repository https://gitbox.apache.org/repos/asf/flink.git

commit 4bd4e76a2d55aafec960dae326ab0e326463620c
Author: Yun Gao <gaoyunhen...@gmail.com>
AuthorDate: Fri Nov 27 18:14:26 2020 +0800

    [hotfix][fs-connector] Fix the typo in the FileSinkITCase
---
 .../flink/connector/file/sink/StreamingExecutionFileSinkITCase.java     | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/flink-connectors/flink-connector-files/src/test/java/org/apache/flink/connector/file/sink/StreamingExecutionFileSinkITCase.java
 
b/flink-connectors/flink-connector-files/src/test/java/org/apache/flink/connector/file/sink/StreamingExecutionFileSinkITCase.java
index 0c10291..4fefde1 100644
--- 
a/flink-connectors/flink-connector-files/src/test/java/org/apache/flink/connector/file/sink/StreamingExecutionFileSinkITCase.java
+++ 
b/flink-connectors/flink-connector-files/src/test/java/org/apache/flink/connector/file/sink/StreamingExecutionFileSinkITCase.java
@@ -92,7 +92,7 @@ public class StreamingExecutionFileSinkITCase extends 
FileSinkITBase {
                }
 
                env.addSource(new StreamingExecutionTestSource(latchId, 
NUM_RECORDS, triggerFailover))
-                               .setParallelism(NUM_BUCKETS)
+                               .setParallelism(NUM_SOURCES)
                                .sinkTo(createFileSink(path))
                                .setParallelism(NUM_SINKS);