You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "SteNicholas (via GitHub)" <gi...@apache.org> on 2023/02/15 04:53:11 UTC

[GitHub] [flink-table-store] SteNicholas commented on a diff in pull request #538: [FLINK-31072] Introduce streaming-read-atomic to ensure UB and UA cannot be split

SteNicholas commented on code in PR #538:
URL: https://github.com/apache/flink-table-store/pull/538#discussion_r1106647853


##########
flink-table-store-connector/src/main/java/org/apache/flink/table/store/connector/FlinkConnectorOptions.java:
##########
@@ -78,6 +78,14 @@ public class FlinkConnectorOptions {
                                     + "By default, if this option is not defined, the planner will derive the parallelism "
                                     + "for each statement individually by also considering the global configuration.");
 
+    public static final ConfigOption<Boolean> STREAMING_READ_ATOMIC =
+            ConfigOptions.key("streaming-read-atomic")
+                    .booleanType()
+                    .defaultValue(false)
+                    .withDescription(
+                            "The option to enable return per iterator instead of per record in streaming read."

Review Comment:
   Could this add the usage scenarios of this config in the description?



-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: issues-unsubscribe@flink.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org