[
https://issues.apache.org/jira/browse/FLINK-23136?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17368675#comment-17368675
]
Shuo Cheng commented on FLINK-23136:
------------------------------------
cc [~dwysakowicz]
> Make `addSource` method with specific boundedness in
> `StreamExecutionEnvironment` public
> ----------------------------------------------------------------------------------------
>
> Key: FLINK-23136
> URL: https://issues.apache.org/jira/browse/FLINK-23136
> Project: Flink
> Issue Type: Improvement
> Components: Runtime / Configuration
> Reporter: Shuo Cheng
> Priority: Major
>
> Currently, when we add a source function by calling
> `addSource(sourceFunction, name, typeinfo)` of `StreamExecutionEnvironment` ,
> the source is set to CONTINUOUS_UNBOUNDED by default (Flink-19392). However,
> for table api / sql job, the batch source is also created by calling the
> above `addSource` method, which is thus set to CONTINUOUS_UNBOUNDED and
> produces unexpected behavior. I think StreamExecutionEnvironment should
> expose an `addSource` method to allow users to pass a boundedness parameter.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
