腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(2886)
视频
沙龙
1
回答
Flink
JDBC
接收器
和
连接池
、
、
我在文档中找不到任何关于
Flink
中JDBCAppendTableSink中的连接重用的信息。我应该使用自己的
连接池
还是
Flink
为我重用连接?这真的是文档中的一个空白,还是我遗漏了什么?
浏览 130
提问于2020-07-14
得票数 0
1
回答
为什么
Flink
不能保证
JDBC
连接器在
JDBC
事务中的精确一次?
、
由于旧系统的原因,我需要将数据从
Flink
输出到MySQL。但我在
flink
找到了这样的文档: 创建的
JDBC
接收器
至少提供了一次保证。我想知道为什么
Flink
不能保证
JDBC
连接器在
JDBC
事务中的确切一次?谢谢。
浏览 3
提问于2021-02-20
得票数 1
1
回答
pyflink使用kafka_source_ddl发生错误
、
、
/bin/
flink
run -m 10.0.24.13:8081 -py /usr/local/project/cdn_
flink
/cdn_demo.py,显示错误:我的envkafka_2.12-3.0.0
浏览 48
提问于2022-01-14
得票数 0
回答已采纳
1
回答
Flink
Oracle
JDBC
接收器
连接器没有加载驱动程序
、
、
、
、
我正在尝试创建到oracle数据库的
Flink
JBDC
接收器
。当在本地运行时(从junit测试
和
minicluster),它可以工作,但是当部署在k8s中时,它会抛出一个异常,说它找不到合适的驱动程序。Classpath是: Classpath: /
flink
/lib/
flink
-cep-scala_2.12-1.13.5-stream1.jar:/
flink
/lib/
flink
-connector-
浏览 16
提问于2022-05-24
得票数 1
回答已采纳
1
回答
如何在Apache中使用BigQuery作为
接收器
?
、
是否可以使用
JDBC
连接器将
Flink
Datastream写入Bigquery或任何其他选项? 对于Apache来说,任何建议/示例都是非常有用的。
浏览 18
提问于2022-03-14
得票数 0
1
回答
Apache能否在表-API/SQL中使用内置连接器实现端到端-准确地一次?
、
我想知道,Apache (v1.11)是否可以通过使用Table/SQL end-to-end-exactly-once 实现内置连接器 (Kafka,
JDBC
,) 我在文档里找不到任何关于这个的东西。
浏览 2
提问于2020-12-02
得票数 1
回答已采纳
1
回答
Flink
Jdbc
接收器
、
、
org.hibernate.dialect.MySQLDialect"); prop.setProperty("hibernate.connection.driver_class", "com.mysql.cj.
jdbc
.Driver
浏览 1
提问于2021-03-05
得票数 0
1
回答
Flink
的
JDBC
接收器
失败,出现不可序列化错误
、
我跟随使用mysql数据库作为
Flink
的
接收器
。org.apache.
flink
.api.java.ClosureCleaner.clean(ClosureCleaner.java:151) org.apache.<e
浏览 2
提问于2020-09-23
得票数 2
1
回答
Flink
表左边的外部联接显示一个错误
、
、
我正在对
flink
中的两个表执行一个左外部联接,下面给出了代码,显示了一个异常,使用相同两个表的内部连接工作良好,能够转换为Datastream。isEqual($("contact_custcode")))例外情况是: org.apache.
flink
.table.api.TableException:表
接收器
'anonymous_datastream_sink$3
浏览 8
提问于2022-08-11
得票数 0
2
回答
Flink
表API ->流槽?
我看到了将
Flink
Table对象转换为DataStream并运行StreamExecutionEnvironment.execute的示例。看来这是可能的,因为否则指定流
接收器
表连接器的目的是什么?我看到
JDBC
表连接器
接收器
支持流,但我没有
浏览 0
提问于2021-04-30
得票数 1
回答已采纳
1
回答
如何在使用RowData时将DynamicTableSink转换成行
、
关于
Flink
中的新sourceSinks接口,我有一个问题。我目前实现了一个新的自定义DynamicTableSinkFactory、DynamicTableSink、SinkFunction
和
OutputFormat。我以
JDBC
连接器为例,使用Scala。 记录必须被接受为org.apache.
flink
.table.data.RowData。该框架提供运行时转换器,以便
接收器
仍然可以在公共数据结构上工作,并在开始时执行转换。
浏览 5
提问于2021-01-15
得票数 0
回答已采纳
1
回答
将事件从Apache
Flink
传输到Apache性能很差
、
我集成了两个工具Apache NiFi
和
Apache
Flink
。NiFi获取事件并将它们发送到
Flink
,之后
Flink
将这些事件经过一些处理返回给相同的NiFi。我在
Flink
中构建了Nifi的源代码
和
接收器
。整个过程可以工作,但是
接收器
的性能非常差(大约每秒10个事件)。 如果我移除
接收器
(仅打印输出),处理速度会快得多。在每个事件
接收器
之后,等待关闭事务,但我不确定,也不知道如何更改它,例如在一个事务中发送数
浏览 3
提问于2018-07-24
得票数 1
2
回答
如何使用
Flink
读取Postgresql中的表
、
我想使用
Flink
对Postgresql中的数据进行一些分析。我应该如何和在哪里给出端口地址,用户名
和
密码。我正在尝试使用链接:中提到的表源。
浏览 0
提问于2018-06-21
得票数 1
回答已采纳
2
回答
如何在
Flink
转换中更新配置?
、
、
、
、
给定一个
Flink
流作业,该作业将map()操作应用于流。在没有重新部署的情况下,在
Flink
万一有关系 check
浏览 13
提问于2022-10-11
得票数 0
2
回答
Apache是否支持使用HTTP请求作为输入
和
输出?
作为一个玩具示例,假设我希望构建一个web应用程序,该应用程序接收带有ID
和
$ payed的HTTP请求,并以ID在24小时窗口中支付的总额返回响应。使用Apache,如果输入
和
输出是Kafka流,当然可以创建该应用程序。 ,但是否支持/可能创建一个
Flink
应用程序,其中输入是HTTP请求,输出是对HTTP请求的响应?如果
Flink
不支持这一点,是否还会有另一个数据流框架支持这一点?(对于上面的玩具示例,我想有比使用
Flink
更简单的解决方案,但我的实际使用是通过HTTP“流”请求的许多多个窗
浏览 4
提问于2020-06-16
得票数 0
回答已采纳
2
回答
有趣的
Flink
问题--如果任务管理器失败了,那么如何恢复
Flink
中的状态以保证只处理一次?
、
、
、
嗨,我是
Flink
的新手,并试图用下面的场景找出一些最佳实践:这将导致输出Kafka主题中的重复消息。
Flink
的检查点函数会有帮助吗?我想不是因为这是一条有钥匙的小溪。需
浏览 3
提问于2022-09-19
得票数 0
1
回答
Flink
SQL:源表太大,无法装入内存
、
、
、
、
我对
Flink
比较陌生,今天我在
Flink
1.11.3会话集群上使用
Flink
SQL时遇到了一个问题。我注册了一个使用
jdbc
驱动程序的源表。我的观察 ts TIMESTAMP, PRIMARY KEY (txid) NOT ENFORC
浏览 7
提问于2020-12-22
得票数 3
回答已采纳
1
回答
Flink
Kafka生产者在发布键流时抛出异常。
我遇到了一些问题,编写从
接收器
子任务到输出kafka主题的关键流。作业的形式是:来源->过滤器-> keyby(id) ->平面映射->
接收器
FlinkKafkaException: Failed to send data我认为这里的问题是,我使用键来确定输出分区,这导致P
接收器
子任务对每个扇出写入N个输出分区。理想情况下,每个子任务只会写入单个分区。2:
接收器
子任务并行性最初将等于输出分区的数量。 3:我将来应该能够在不违反#1的情况下增加并行性。
浏览 2
提问于2019-10-10
得票数 1
1
回答
在一个
flink
作业中使用collect()
和
env.execute()
、
我试图用
Flink
编写一个计算,它需要两个阶段。graph.run( new SingleSourceShortestPaths<String, String>(id, 10)).print();它在本地工作(在IntelliJ IDE
和
使用/bin/
flink
run ...的命令行中),但是当我使用它的WebUI在
Flink
上提交作业时,程序只是执行到collect()方法,并且不运行程序的其余部分(用于语句
和
print())。这是我的代码: import
浏览 6
提问于2017-11-28
得票数 0
回答已采纳
1
回答
PyFlink错误/异常:"Hive不支持使用由节点PythonGroupAggregate生成的更新更改“
、
、
、
、
使用
Flink
1.13.1
和
以Hive表为源
和
接收器
的pyFlink
和
用户定义的表聚合函数(UDTAGG),我遇到了一个错误: Table sink 'myhive.mydb.
flink
_tmp_model' doesn't supportconsuming update
浏览 1
提问于2021-08-05
得票数 1
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
Flink 支持哪些数据源和数据接收器?
如何使用flink-connector-postgres-cdc将Kafka写数据到PostgreSQL数据库动态表中
Flink 的基本概念是什么?
Java开发者必须掌握:数据库连接池技术
“Hibernate”、“HikariCP”
热门
标签
更多标签
云服务器
ICP备案
实时音视频
即时通信 IM
对象存储
活动推荐
运营活动
广告
关闭
领券