[GitHub] [flink] stevenzwu commented on a diff in pull request #20757: [FLINK-27919] Add FLIP-27-based source for data generation (FLIP-238)

2022-09-19 Thread GitBox
stevenzwu commented on code in PR #20757: URL: https://github.com/apache/flink/pull/20757#discussion_r974416546 ## flink-tests/src/test/java/org/apache/flink/api/connector/source/lib/util/RateLimitedSourceReaderITCase.java: ## @@ -0,0 +1,138 @@ +/* + * Licensed to the Apache Sof

[GitHub] [flink] stevenzwu commented on a diff in pull request #20757: [FLINK-27919] Add FLIP-27-based source for data generation (FLIP-238)

2022-09-19 Thread GitBox
stevenzwu commented on code in PR #20757: URL: https://github.com/apache/flink/pull/20757#discussion_r974416546 ## flink-tests/src/test/java/org/apache/flink/api/connector/source/lib/util/RateLimitedSourceReaderITCase.java: ## @@ -0,0 +1,138 @@ +/* + * Licensed to the Apache Sof

[GitHub] [flink] stevenzwu commented on a diff in pull request #20757: [FLINK-27919] Add FLIP-27-based source for data generation (FLIP-238)

2022-09-09 Thread GitBox
stevenzwu commented on code in PR #20757: URL: https://github.com/apache/flink/pull/20757#discussion_r967254247 ## flink-core/src/main/java/org/apache/flink/api/connector/source/lib/util/RateLimiter.java: ## @@ -22,8 +22,14 @@ import java.util.concurrent.CompletionStage; /**

[GitHub] [flink] stevenzwu commented on a diff in pull request #20757: [FLINK-27919] Add FLIP-27-based source for data generation (FLIP-238)

2022-09-09 Thread GitBox
stevenzwu commented on code in PR #20757: URL: https://github.com/apache/flink/pull/20757#discussion_r967254247 ## flink-core/src/main/java/org/apache/flink/api/connector/source/lib/util/RateLimiter.java: ## @@ -22,8 +22,14 @@ import java.util.concurrent.CompletionStage; /**

[GitHub] [flink] stevenzwu commented on a diff in pull request #20757: [FLINK-27919] Add FLIP-27-based source for data generation (FLIP-238)

2022-09-09 Thread GitBox
stevenzwu commented on code in PR #20757: URL: https://github.com/apache/flink/pull/20757#discussion_r967254247 ## flink-core/src/main/java/org/apache/flink/api/connector/source/lib/util/RateLimiter.java: ## @@ -22,8 +22,14 @@ import java.util.concurrent.CompletionStage; /**

[GitHub] [flink] stevenzwu commented on a diff in pull request #20757: [FLINK-27919] Add FLIP-27-based source for data generation (FLIP-238)

2022-09-08 Thread GitBox
stevenzwu commented on code in PR #20757: URL: https://github.com/apache/flink/pull/20757#discussion_r966164935 ## flink-core/src/main/java/org/apache/flink/api/connector/source/lib/DataGeneratorSource.java: ## @@ -0,0 +1,211 @@ +/* + * Licensed to the Apache Software Foundation

[GitHub] [flink] stevenzwu commented on a diff in pull request #20757: [FLINK-27919] Add FLIP-27-based source for data generation (FLIP-238)

2022-09-07 Thread GitBox
stevenzwu commented on code in PR #20757: URL: https://github.com/apache/flink/pull/20757#discussion_r965058470 ## flink-core/src/main/java/org/apache/flink/api/connector/source/lib/DataGeneratorSource.java: ## @@ -0,0 +1,211 @@ +/* + * Licensed to the Apache Software Foundation

[GitHub] [flink] stevenzwu commented on a diff in pull request #20757: [FLINK-27919] Add FLIP-27-based source for data generation (FLIP-238)

2022-09-07 Thread GitBox
stevenzwu commented on code in PR #20757: URL: https://github.com/apache/flink/pull/20757#discussion_r964946446 ## flink-core/src/main/java/org/apache/flink/api/connector/source/lib/DataGeneratorSource.java: ## @@ -0,0 +1,211 @@ +/* + * Licensed to the Apache Software Foundation