@JingsongLee 把当前的hive sink并发度配置策略加到文档里吧
https://issues.apache.org/jira/browse/FLINK-16448
On Tue, Mar 3, 2020 at 9:31 PM Jun Zhang <825875...@qq.com> wrote:
>
> 嗯嗯，其实我觉得我写的这个示例sql应该是一个使用很广泛的sql，我新建了hive表，并且导入了数据之后，一般都会使用类似的sql来验证一下表建的对不对，数据是否正确。
>
>
>
>
>
>
> 在2020年03月4日 13:25，JingsongLee
I implemented a custom function that throws up a runtime exception.
You can extend from simpler MapFunction or more complicated
RichParallelSourceFunction depending on your use case.
You can add logic to throw a runtime exception on a certain condition in the
map or run method. .
