[flink] 02/02: [hotfix][streaming] Removed useless calculateThroughput in the test

[pnowojski]

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

pnowojski pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git

commit 233e5d47450e5d5a980e45045d81dc3e26af1c97
Author: Anton Kalashnikov <kaa....@yandex.ru>
AuthorDate: Wed Aug 4 14:05:10 2021 +0200

    [hotfix][streaming] Removed useless calculateThroughput in the test
---
 .../java/org/apache/flink/streaming/runtime/tasks/StreamTaskTest.java    | 1 -
 1 file changed, 1 deletion(-)

diff --git 
a/flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/StreamTaskTest.java
 
b/flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/StreamTaskTest.java
index efb1dea..15c77f8 100644
--- 
a/flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/StreamTaskTest.java
+++ 
b/flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/StreamTaskTest.java
@@ -1563,7 +1563,6 @@ public class StreamTaskTest extends TestLogger {
             SystemClock clock = SystemClock.getInstance();
 
             long startTs = clock.relativeTimeMillis();
-            throughputCalculator.calculateThroughput();
             throughputCalculator.incomingDataSize(incomingDataSize);
             task.invoke();
             long resultThroughput = throughputCalculator.calculateThroughput();