1回答
我对Flink的行为有疑问。下面是我的代码片段。正如您所看到的，一些服务正在提供Flink将逐个执行的sql条件列表(比如大约10k个sql)。我的问题是，每当sql更新时，我如何指示flink与新的sql一起工作？我看到的一种方法是停止和启动flink服务，这是我想要避免的，因为其他sql规范需要一直运行，并且只需要停止/启动/或动态更新正在更新</e
浏览 73提问于2020-11-11得票数 0
我从apache-flink sql-client提交了一个作业，并创建了一个保存点。问题是元数据不包含jar和类名，更不用说参数了。如何重启？
浏览 4提问于2021-03-19得票数 0
我的应用程序支持无需重启即可重新读取配置，但当我轮换新的配置()时，docker总是会重启应用程序。
有没有办法避免在更新(轮换)配置时重新启动？现在我们只是使用绑定挂载的NFS驱动器来保存配置，但如果我们能找到避免重启的方法，我真的很想使用docker swarm配置。
浏览 9提问于2020-06-04得票数 1
回答已采纳
有没有其他方法可以不用在Windows计算机上用mod_wsgi重启Apache就能重新编译Django？
浏览 0提问于2010-09-03得票数 3
回答已采纳
我在一个正在运行的键盘上更新了一些属性文件(一些i18n消息)。但是什么也没发生。我需要重启keycloak才能看到更改吗？这将是奇怪的，因为我立即看到(freemarker)模板文件的变化。
浏览 20提问于2020-05-29得票数 0
(JdbcPollingSource.java:25) at org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:66)
at org.apache.flink.streaming.runtime.t
浏览 9提问于2021-10-04得票数 5
是否可以创建一个默认的Apache Cocoon项目，然后将其作为独立应用程序移动到MyEclipse？不再依赖于pom.xml，无需关机和重启即可热部署依赖的jars，只需单击即可创建打包部署等。
我该怎么做才能做到这一点呢？任何提示/建议都将不胜感激。
浏览 5提问于2012-11-08得票数 0
回答已采纳
我能够在远程hdfs集群中的文件上运行示例wordcount.jar，而无需在flink中声明fs.hdfs.hadoopconf变量。(one,1)
更新：产出：
Caused by: org.apache.flink.runti
浏览 2提问于2016-07-13得票数 3
回答已采纳
我无法在zepplin中运行flink (1.0.3)进程。它处于挂起状态，web ui未记录该过程:在群集模式和本地模式下都是如此。Flink本身在命令行和intellij中运行良好。
浏览 4提问于2016-08-01得票数 1
(sql2).in(ds2).build().result();
env.execute("test");
注意:对于sql1，我在行时使用max函数，它不起作用(OperatorChain.java:533)，org.apache.flink。:657) at org.apache.flink.streaming.api.operators.StreamMap.processElement(StreamMap.java：4
浏览 1提问于2018-09-17得票数 1
正如我们所看到的，我们希望能够频繁地添加用户，我们正在寻找一种方法来做到这一点，而不必执行滚动重启。我们尝试过的内容： 使用动态代理配置接口，为所有代理重新配置listener.name.sasl_plaintext.plain.sasl.jaas.config。
浏览 36提问于2019-01-11得票数 4
回答已采纳
我想从SQL客户端试用Flink SQL中的Match_Recognize操作符。at org.apache.flink.table.client.SqlClient.validateEnvironment(SqlClient.java:147)
at org.apache.flink.table.client.SqlClient.startby: org.apache.flink.table.client.gatew
浏览 1提问于2020-02-13得票数 0
我是flink的新手，想了解如何使用FLINK运行我的用例:应用程序有三个输入数据源a)历史数据b)从kafka获取所有实时事件c)获取将具有触发条件的控制事件 由于应用程序正在处理历史数据，因此我认为我将合并历史数据和实时数据要触发事件，我们必须在控制事件的帮助下编写SQL查询，该事件是输入源，并且包含where子句。我的问题是在数据位于Stream中时构建SQL查询，并且当我执行以下操作时 DataStream<ControlEvent> controlEvent
controlEvent.map(new
浏览 37提问于2020-07-01得票数 1
我试图在我的一个项目中使用Apache的表概念来实时组合来自多个来源的数据。不幸的是，我的团队成员都是Node.JS开发人员。因此，我正在寻找从NodeJS连接到Flink并从它进行查询的可能方法。在SQL的中，有人提到
基于此，是否有任何方法从NodeJS连接到
浏览 15提问于2022-07-19得票数 1
我只找到了Apache Jetspeed，它在2.2.2版本中应该有这个功能，但它似乎没有得到维护。1)无需重启即可使用OSGI规范加载模块Liferay确实在当前版本中支持OSGI，但我必须确保有一种方法可以在不重启的情况下部署
浏览 0提问于2013-02-28得票数 2
workingDir) System.out.println(workingDir);但我需要让用户能够在应用程序运行后更新文件所在的目录如果我使用用户输入的新工作目录路径从浏览器发送GET请求，如何更新注册表？
谢谢。
浏览 1提问于2016-09-21得票数 0
回答已采纳
我希望使用Flink SQL作为多个不同服务上的物化视图。例如，从MySQL & Redis & RPC服务读取数据，将它们连接在一起，然后更新存储在PostgreSQL中的结果表。如果“通知”包含源表中的所有信息，那么我可以只使用动态表。但是，源表中的数据太大，无法将它们全部存储在动态表中，这将是一种浪费。所以最好的方法是：
Flink读取输入中的通知，而不是从内存中更新和查询动态表，Flink查询外部服务以重新计算
浏览 5提问于2020-10-27得票数 1
我使用PipelineOptions.JARS配置在应用程序代码中动态添加包含UDF类的jar文件，但是应用程序无法使用ClassNotFoundException从配置好的jar文件加载UDF类。如果使用“Flink run”和"-C“选项来更新类路径，通过flink CLI提交的应用程序jar工作得很好：
<FLINK_HOME>/bin/flink run --detached -C file问题似乎是表计划器中的编码元使用的ClassLo
浏览 20提问于2021-12-15得票数 0
云服务器
ICP备案
腾讯会议
实时音视频
对象存储
腾讯云开发者
