Flink SQL客户端如何区分批处理模式和流模式？
众所周知，Flink有两个核心API（数据流/数据集），但当我使用Flink Sql客户端提交作业时，我不需要选择流或批处理模式。所以，Flink SQL客户机是如何决定使用批处理模式和流模式的。我在官方文件中没有找到答案。所以，我想知道Flink SQL客户端如何区分批处理模式和流模式？
共有1个答案
当您启动Flink的SQL客户端时，您可以通过以下方式指定要使用的环境
sql-client.sh embedded -d <default environment file> -e <session environment file>
环境文件是描述目录和表执行环境的YAML文件，包括是使用批处理还是流式处理：
execution:
type: streaming
有关更多详细信息，请参阅留档。
-
一些批处理任务可以使用spring batch现成的组件完全的组装.例如ItemReader和ItemWriter实现可配置覆盖范围广泛的场景,然而,对于大多数情况下,必须编写自定义代码。应用程序开发人员的主要API人口点是Tasklet,ItemReader ItemWriter和各种各样的监听器接口.最简单的批处理任务能够使用Spring BatchItemReader现成的输出,但通常情况下
-
在我开始使用Spring Cloud Stream之前，我使用的是Spring-Kafka及其对批量消费和自定义错误处理的支持。请注意这段代码的最后两行: 然而，对于Spring Cloud Stream，我找不到如何配置它。我只能找到这些配置属性: Spring、响铃、水流、kafka.bindings.inputconsumer。autoCommitOffset，启用Dlq 因此，在Sprin
-
问题内容： 到现在为止，我主要是利用，，用于构建Web应用程序技术堆栈。关键是，提到的堆栈使用服务器端模式。Web浏览器的主要作用仅限于请求/响应周期（+客户端验证）。数据检索，业务逻辑，接线和验证是服务器端的主要职责。 我对 AngularJS 框架有几个疑问，这些疑问是由我阅读过以下引号引起的： 从 AngularJS教程中 ： 对于Angular应用，我们鼓励使用Model-View-Con
-
关于AngularJS框架，我有几个问题是从我读到的以下引用中得到启发的： 从AngularJS教程： 对于有角度的应用程序，我们鼓励使用Model-View-Controller(MVC)设计模式来解耦代码并分离关注点。 我知道我的问题有些奇怪，但我认为原因是，我对传统的服务器端MVC模式有些敏感。我确信有人已经做了同样的转变。
-
11.1 日志项处理和失败 一个常见的用例是需要在一个步骤中特殊处理错误,chunk-oriented步骤(从创建工厂bean的这个步骤)允许用户实现一个简单的ItemReadListener用例,用来监听读入错误,和一个ItemWriteListener,用来监听写出错误.下面的代码片段说明一个监听器监听失败日志的读写: >public class ItemFailureLoggerListen
-
如何在批处理模式的情况下处理反序列化异常？ 我正在使用Spring boot-2.3.8版本的Spring kafka。 尝试过此选项： 但它抛出了一个异常：由java引起。lang.IllegalStateException:错误处理程序必须是ErrorHandler，而不是org。springframework。Kafka。听众。请参阅OcuCurrentBatchErrorHandler 以