下面是我使用flink创建的表的create语句。现在，我想通过添加一个新列来修改这个表。以下是我尝试从flink作业运行的ALTER命令： 1.ALTER TABLE event_kafkaTable ADD test6 string; 这两个命令都抛出了Flink SQL解析器异常。Flink的官方网站https://ci.apache.org/projects/f
浏览 184提问于2020-11-25得票数 0
回答已采纳
我想知道是否有一种方法可以在Flink (Java API)中将具有常量值的列添加到表中，就像Spark DF/DS中的.withColumn函数一样？
问候你，巴斯蒂安
浏览 7提问于2018-08-08得票数 0
回答已采纳
我有一台Flink服务器运行在一台计算机上。我想创建一个java web应用程序，它可以部署SQL(源代码创建SQL.，Sink创建SQL.)。然后插入Sink选择field1，.从源表)如何使用Table . flink-table-common-1.15.2.jar) 对远程Flink服务器执行上述SQL，应用
浏览 3提问于2022-10-14得票数 0
我想使用flink sql client创建一个配置单元表。我可以成功创建表t2，但是当我查询t2时，它会报错 Table options do not contain an option key 'connector' for discovering a connector我已经在conf/sql-client-defaults.yaml文件中设置执行类型为batch。 我会问这里有什么问题。谢谢!Flink S
浏览 103提问于2020-12-21得票数 0
回答已采纳
当多个表中至少有一个表具有时间属性列时，我在使用Flink中的SQL语法连接多个表时遇到了一些问题。我有一个表Table1，它使用模式(id，value1，rowtime)，当rowtime用作flink rowtime时。
我想把这个表和一个使用模式(id，value2)的表Table2连接起来。Please check the documen
浏览 9提问于2019-11-12得票数 0
我想知道一般对查询和表使用了多少状态。首先，我使用Flink SQL处理来自Kafka主题的消息： country STRING,) WITH (状态管理的是这样说的：
那么，我是否正确地理解Flink没有从purchases连接器中保存
浏览 8提问于2021-12-11得票数 0
回答已采纳
tenant, message");
并得到以下错误：
线程“主”org.apache.flink.table.api.ValidationException: SQL验证中的异常失败。从第1行，第64列到第1行，第70栏:在org.apache.flink.table.calcite.FlinkPlannerImpl.validat
浏览 0提问于2017-12-22得票数 0
回答已采纳
为了探索Flink表API在当前项目中使用的可能性和局限性，我试图将Flink SQL语句转换为其等效的Flink表API版本。Flink SQL (工作) " T.COLUMN_A"
浏览 13提问于2022-08-16得票数 0
回答已采纳
Flink /SQL有很多关于DataType系统的包，包括：
org.apache.flink.table.api.DataTypesorg.apache.flink.table.api.Typesorg.apache.flink.table.types.DataTypeorg.apache.flink.table.data我对软件包之间的关系相当困惑，有人能给我一些提
浏览 1提问于2021-03-07得票数 0
回答已采纳
我已经编写了一个简单的示例来接收表，但是即使在实现了AppendTableSink接口之后，也可以在Apache中获得这个异常。; import org.apache.flink.table.api.Table;
import org.apache.flink.table</e
浏览 1提问于2017-08-24得票数 0
1回答
在Flink表中添加列
、、、
我试图在Java的flink表中添加一个新列table = table.addColumns($("NewColumn"));org.apache.flink.table.api.ValidationExcept
浏览 22提问于2022-11-24得票数 0
回答已采纳
我在1.1快照版本上使用Apache的Table来评估流上的SQL查询。at org.apache.flink.api.table.TableEnvironment$$anonfun$4.apply(TableEnvironment.scala:299) at org.apache.<em
浏览 1提问于2016-06-15得票数 0
回答已采纳
1回答
我正在使用Flink 1.11。
我的应用程序从Kafka读取数据，因此在Kafka分区中消息已经按顺序排列。在使用了卡夫卡的信息之后，我想应用TumblingWindow。根据Flink文档，keyBy需要使用TumblingWindow。使用keyby，意味着它将触发数据的洗牌，这是我想要避免的。
浏览 5提问于2022-04-09得票数 1
我正尝试在我的POM.xml文件中添加Flink Table依赖项，下面是依赖项。<dependency> <artifactId>flink-table</artifactId></dependen
浏览 38提问于2020-06-28得票数 0
回答已采纳
我尝试使用flink的表和sql作为一个简单的示例，在这个示例中，我从文件中读取字符串，将其转换为Tuple2，并尝试将其插入表中。这是我的密码。import org.apache.flink.api.common.functions.FlatMapFunction;
import org.apache.flink.api.java.table.StreamTableEnviron
浏览 1提问于2016-12-21得票数 2
1回答
为此目的，我使用的是Flink_2.10-1.1.3.jar(表api)，但是我得到了以下错误： at org.apache.flink.api.table.plan.logical.Project.con
浏览 1提问于2016-12-21得票数 2
我试图连接卡夫卡与Flink和运行通过sql-client.sh。(SqlClient.java:161)
Caused by: org.apache.flink.table.api.ValidationException: Unable to create catalogby: org.apache.flink.table.api.ValidationException: Could not find any factory for identifi
浏览 46提问于2021-11-30得票数 0
回答已采纳
我得到了一个使用dataset api的项目，比如dataset.output(outputFormat)。outputFormat是userDefined(向neo4j写入批处理数据)，因此我希望保留它，但在flink use OutputFormat中找不到最新版本的表/sql。谢谢你的帮助。
浏览 38提问于2022-09-08得票数 0
回答已采纳
2回答
我正在尝试将Flink 1.14.4与HBase版本2.2.14连接；我添加了Hbase连接器jar flink-SQL连接器-HBASE-2.2-1.15.2.jar，但是对于2.2.x版本，这是jar(PlannerBase.scala:182)
浏览 73提问于2022-10-21得票数 0
回答已采纳
闪烁:1.13.1 配置单元:2.1.1-cdh6.2.1 flink/lib目录中的jar包如下所示。enter image description here当我执行sql-client.sh时，我得到以下错误，这要求我向Apache Flink社区提交评论。Exception in thread "main" org.apache.flink.table.client.SqlClientException: Unexpected exc
浏览 229提问于2021-10-27得票数 0
云服务器
ICP备案
云直播
实时音视频
即时通信 IM
腾讯云开发者
