[FLINK-17895][table] Default value of rows-per-second in datagen can …

…be limited This closes apache#12415
spotify · Jun 3, 2020 · c52e579 · c52e579
1 parent d35c33a
commit c52e579
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/...java-bridge/src/main/java/org/apache/flink/table/factories/DataGenTableSourceFactory.java b/...java-bridge/src/main/java/org/apache/flink/table/factories/DataGenTableSourceFactory.java
@@ -56,10 +56,11 @@
 public class DataGenTableSourceFactory implements DynamicTableSourceFactory {
 
  public static final String IDENTIFIER = "datagen";
+ public static final Long ROWS_PER_SECOND_DEFAULT_VALUE = 10000L;
 
  public static final ConfigOption<Long> ROWS_PER_SECOND = key("rows-per-second")
  .longType()
- .defaultValue(Long.MAX_VALUE)
+ .defaultValue(ROWS_PER_SECOND_DEFAULT_VALUE)
  .withDescription("Rows per second to control the emit rate.");
 
  public static final String FIELDS = "fields";