我是新的Flink，并试图创建一个原型，可以做一个连续的查询以及按需的查询。第一部分已经起作用了(使用预定义的查询)，但与第二个部分斗争。有可以使用的SQL。我已经看到了Flink木星笔记本集成，这告诉我，这应该工作的方式从一个网页界面。但是，不知道如何做到这一点，每次都不提交一个完整的JAR。见和
对我们还能探索什么有什么建议吗？
浏览 12提问于2022-01-15得票数 0
回答已采纳
{host="flink_jobmanager",instance="",job="flink-sql"} 0
bash-5.0# date && curl -s http://pushgateway.flink-sql"flink_jobmanager",instance="",job="flink-sql<
浏览 8提问于2021-05-24得票数 0
在每一开始，我们都试图了解流入DB和Flink之间的数据传输过程。我们的基本思想是: Flink读取来自influxDB的数据，Flink利用这些数据进行一些基于Flink的ML库的建模。但是，我们只找到一些开源存储库，它们提供了一个接收器，可以将数据从Flink发送到InfluxDB (例如Flink InfluxDB连接器)。因此，如果你知道一些好的例子，如我所描述的，请告诉我。
浏览 0提问于2019-12-12得票数 1
回答已采纳
在Flink SQL上使用带有Kerberos身份验证的Kafka数据源，Flink的本地测试已经通过，但当我将任务推到纱线上时，错误消息提示无法找到Kafka的JAAS文件！(OperatorChain.java:426) ~[byit-flink-sql-engine.jar:4.1.1]
at org.apache.flink.streaming.runtime.tasks.StreamTask.lambda~[byit-flink-sql</em
浏览 23提问于2022-01-24得票数 1
我正在创建一个flink作业，它需要连续查询的动态表，我找到了概念here，但没有找到任何好的示例程序来尝试它。有没有人能帮帮我。谢谢
浏览 13提问于2020-08-17得票数 1
我从apache-flink sql-client提交了一个作业，并创建了一个保存点。问题是元数据不包含jar和类名，更不用说参数了。如何重启？
浏览 4提问于2021-03-19得票数 0
给定来自Kafka的数据流，是否有内置的方法，或者执行SQL查找的最有效方法是什么。 例如，将流对象连接到sql表，并将其与Kafka数据流连接。给定可以在自组织基础上更新的sql表，
浏览 16提问于2020-04-15得票数 0
回答已采纳
我一直试图在Flink中使用SOURCE语句创建一个文件。从医生那里：
/opt/flink# echo "select 'hello';" > test.sql
/opt/flink<
浏览 8提问于2021-06-11得票数 0
回答已采纳
1回答
/maven2/org/apache/flink/flink-json/${FLINK_VERSION}/flink-json-${FLINK_VERSION}.jar; \
wget -P /opt/flink/lib/ https://repo.maven.apache.org/maven2/org/apache&#x
浏览 3提问于2022-06-13得票数 1
回答已采纳
Users\bk73027\Projects\FlinkDemo\flink-1.15.0\flink-connectors\flink-sql-connector-hive-1.2.2\pom.xmlConnectors : SQL : HBase 2.2 [jar]
[INFO] Flink : Connectors : SQL : HiveConnectors : SQL : Hive
浏览 7提问于2022-06-24得票数 1
回答已采纳
我正在跟踪Flink 。打开Flink SQL客户端看起来很好，但是SELECT 'hello world'不能工作。$ /data/apache/flink/flink-1.12.0/bin/sql-client.sh embedded
SLF4J: Class path contains multiple SLF4JSearching for '/data/apache&#x
浏览 14提问于2021-03-26得票数 1
回答已采纳
这些规则是我希望在事件上运行的SQL查询。
我正在学习动态表和Flink SQL的概念。我不知道如何进一步处理。有人能帮帮我吗？
浏览 0提问于2018-02-09得票数 0
(CliClient.java:229) [flink-sql-client-1.15.1.jar:1.15.1] at org.apache.flink.table.client.SqlClient.start(SqlClient.java:187) [<e
浏览 6提问于2022-09-09得票数 0
据我所知，Flink支持本地执行模式(请参考https://nightlies.apache.org/flink/flink-docs-release-1.14/docs/dev/dataset/local_execution但我想使用本地执行CollectionEnvironment在flink中执行批处理sql，以保持与在线服务和离线训练数据集功能工程的一致性。 谁能告诉我如何使用本地模式执行batch sql</
浏览 67提问于2021-11-16得票数 0
2回答
在使用Scala代码将数据从输出NiFi端口传输到Flink方面，我需要一些帮助。import org.apache.flink.streaming.connectors.nifi.NiFiSourceimport org.apache.flink.streaming.api.functions.sourc
浏览 0提问于2017-07-17得票数 0
回答已采纳
当我使用pyflink hive sql read data insert into es时，抛出以下异常:环境: flink 1.11.2 flink-sql-connector-hive-3.1.2(HiveVectorizedOrcSplitReader.java:99) ~[flink-sql-connector-hive-3.1.2_2.11-1.11.2.jar:1.11.2]
at.nextBatch(OrcShimV210.java:35) ~[flink
浏览 338提问于2020-12-17得票数 0
1回答
: /cdc/apache-hive-3.1.2-bin/conf 我启动了flink sql客户端，但报告了以下错误。Searching for '/cdc/flink-1.12.0/conf/sql-client-defaults.yaml'...found./log/flink-root-sql-client-dhf4.log
2021-01-20 10:12:36,24
浏览 0提问于2021-01-18得票数 1
我有一个在本地运行良好的Flink作业，但是当我尝试在集群上flink run作业时失败了。它基本上是读卡夫卡，做一些转换，并写到一个水槽。这是我的pom.xml，包括flink-connector-kafka。 at org.apache.calcite.sql2rel.SqlToRelConverter.conve
浏览 16提问于2021-03-10得票数 0
回答已采纳
我想使用flink sql client创建一个配置单元表。我已经在conf/sql-client-defaults.yaml文件中设置执行类型为batch。 我会问这里有什么问题。谢谢!Flink SQL> use testdb1;
[INFO] Table has been createdFlink SQL&g
浏览 103提问于2020-12-21得票数 0
回答已采纳
云服务器
ICP备案
实时音视频
对象存储
即时通信 IM
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号