??
??
-- --
??:
gt;>; ??
>>>
>>>
>>> HI
>>>
????HELP
>>>
>>>
>>> -- --
>>> ??: "" <11
HI,
>> ??
>>
>>
>>> ?? 2020??7??2216:27?? <1129656...@qq.com
<mailto:1129656...@qq.com>>; ??
>>>
>>>
>>> HI
>>>
????HELP
>>> ?
flinksql1.11hiveidea??Caused by:
java.lang.ClassNotFoundException:
org.apache.hadoop.fs.PathHandle_(:??)_
flink1.11??org.apache.flink.table.catalog.hive.HiveCatalog#HiveCatalog(java.lang.String,
java.lang.String
-- --
??:
"Presley"
??
flinkv1.11phoneix 1.14.1
CREATE TABLE pe_login_kafka (
id INT,
region_id INT,
ts TIMESTAMP(3),
proc_time AS PROCTIME()
) WITH (
'connector' = 'kafka',
'topic' = 't-region,
'properties.bootstrap.servers' = '',
'properties.group.id' = gid');
CR
??bug
?? 2021-01-05 20:20
user-zh
?? flinksql1.11 phoenixCaused by:
org.apache.calcite.avatica.NoSuchStatementException
??
flinkv1.11phoneix 1.14.1
CREATE TABLE
hi:
我在使用pyflink1.11过程中,使用flinksql维表时声明了主键primary key
但是还是会报错说我没有用声明主键,另外,当我使用inner join代替left join就不会有这个问题,请问这是什么问题
下面我附录了报错信息和代码。谢谢!
报错附录
Traceback (most recent call last):
File "/usr/local/lib/python3.7/site-packages/pyflink/util/exceptions.py",
line 147, in deco
return f(*a, **
Hi,all:
flinksql1.11hiveUDAFUDAFbug??_(:??)_
>
-
pub
Hi,
你这还是connector的with参数里不是新 connector的写法[1],会走到老代码,老代码不支持声明PK的。
在老代码里,PK是通过query推导的,你用inner join替换left join后,应该是能够推断出PK了,所以没有报错。
我理解你把connector的with参数更新成新的就解决问题了。
Best
Leonard Xu
[1]
https://ci.apache.org/projects/flink/flink-docs-release-1.11/dev/table/connectors/jdbc.html#connector-options
Hello
你说的输出结果更新,是指之前关联的维表时老数据,过了一段时间,这个数据变,之前输出的历史也希望更新吗?维表join的实现,只有事实表中才会有retract消息才会更新,才会传递到下游,维表的数据是事实表
去look up该表时的数据,维表的更新是不会retract之前的历史记录的。
祝好
Leonard Xu
> 在 2020年7月22日,14:13,1129656...@qq.com 写道:
>
> 输出结果仍然没有被更新
--- 原始邮件 --
> 发件人:
> "user-zh"
>
> 发送时间: 2020年7月22日(星期三) 下午2:42
> 收件人: "
err 20200723084500
> 100 err 20200723084501
>
> 然后我断开了流输入,间隔时间大于缓存刷新时间,然后重新输入流,但是我的新输出结果仅仅是更新了与流有关的时间字段,与维表相关的字段仍没有得到更新。
>
> 请问我的使用过程哪里不对么,请帮我指出来,万分感谢!
>
>
> 谢谢!
>
>
>>>
>>>
>
>
> -- 原始邮件 --
name' = '',
'password' = '',
'lookup.cache.max-rows' = '5000',
'lookup.cache.ttl' = '1s',
'lookup.max-retries' = '3'
)
"""
st_env.sql_update(source_dd
ssword' = '***',
'lookup.cache.max-rows' = '5000',
'lookup.cache.ttl' = '1s',
'lookup.max-retries' = '3'
)
"""
st_env.sql_update(source_ddl)
def register_rides_sink(st_env):
sink_ddl
hello
我在使用flinksql1.11写出数据到jdbc是遇到了field type类型不匹配的问题,是我类型设置有问题吗?
下面是我的异常日志以及sql文件
SET stream.enableCheckpointing=1000*60;
SET stream.setParallelism=3;
-- Kafka cdbp zdao source 表
create TABLE cloud_behavior_source(
operation STRING,
operation_channel STRING,
`time` STRING,
ip
:
> hello
> 我在使用flinksql1.11写出数据到jdbc是遇到了field type类型不匹配的问题,是我类型设置有问题吗?
> 下面是我的异常日志以及sql文件
>
> SET stream.enableCheckpointing=1000*60;
> SET stream.setParallelism=3;
>
> -- Kafka cdbp zdao source 表
> create TABLE cloud_behavior_source(
> operation STRING,
> oper
@chengyanan1...@foxmail.com 你那里也遇过吗,这个要是bug,也不会修复呀
--
Sent from: http://apache-flink.147419.n8.nabble.com/
使用flinksql 1.11版本,运行计算好的指标落入mysql,长时间没有数据会报错,导致任务会失败。
针对:https://issues.apache.org/jira/browse/FLINK-16681,已经修复此问题,但是我们使用1.11最新版本,运行一段时间后,发现还是会有此问题,如何解决
--
Sent from: http://apache-flink.147419.n8.nabble.com/
Hi,yanzi
可以贴下完整的报错信息吗?
祝好,
Leonard Xu
> 在 2020年12月3日,10:36,yanzi 写道:
>
> 使用flinksql 1.11版本,运行计算好的指标落入mysql,长时间没有数据会报错,导致任务会失败。
> 针对:https://issues.apache.org/jira/browse/FLINK-16681,已经修复此问题,但是我们使用1.11最新版本,运行一段时间后,发现还是会有此问题,如何解决
>
>
>
> --
> Sent from: http://apache-flink.147419.n8.nabble.co
hi Leonard:
报错信息如下:
[2020-12-02 22:01:03.403] [ERROR] [jdbc-upsert-output-format-thread-1]
[org.apache.flink.connector.jdbc.internal.JdbcBatchingOutputFormat] >>> JDBC
executeBatch error, retry times = 3
java.sql.SQLException: No operations allowed after statement closed.
at com.mysql.jdbc
这个应该只是个 error 的日志,方便也发下retry times = 1 和 retry times = 2 的日志看下吗
在 2020-12-03 16:17:27,"yanzi" 写道:
>hi Leonard:
>
>报错信息如下:
>[2020-12-02 22:01:03.403] [ERROR] [jdbc-upsert-output-format-thread-1]
>[org.apache.flink.connector.jdbc.internal.JdbcBatchingOutputFormat] >>> JDBC
>executeBatch error,
1、retry times =1报错日志:
[2020-12-02 22:01:00.800] [ERROR] [jdbc-upsert-output-format-thread-1]
[org.apache.flink.connector.jdbc.internal.JdbcBatchingOutputFormat] >>> JDBC
executeBatch error, retry times = 1
java.sql.SQLException: No operations allowed after statement closed.
at com.mysql.jdb
大佬好,我在1.11版本测试flink sql时发现一个问题,用streaming api
消费kafka,使用eventtime,再把stream转table,进行sql聚合,发现当kafka topic是多个分区时,flink webui
watermarks 显示No Watermark,聚合计算也迟迟不触发计算,但当kafka
topic只有一个分区时却能这个正常触发计算,watermarks也显示正常下面是测试代码:package com.test.opsimport
java.util.Propertiesimport com.fasterxml.jackson.databin
字体太小,代码也都被格式化了,不方便看。不过按照问题描述,猜测是kafka某个分区没数据,flink的watermark机制有多输入取小机制。如果某个分区没数据,可能导致watermark一直无法生成。
在 2020/8/9 下午9:38,“zhanglachun” 写入:
大佬好,我在1.11版本测试flink sql时发现一个问题,用streaming api
消费kafka,使用eventtime,再把stream转table,进行sql聚合,发现当kafka topic是多个分区时,flink webui
watermarks 显示No Waterma
@flink.apache.org
主题: Re: flinksql1.11 使用eventime消费kafka多分区时,没有水位线信息,聚合计算也不出结果
字体太小,代码也都被格式化了,不方便看。不过按照问题描述,猜测是kafka某个分区没数据,flink的watermark机制有多输入取小机制。如果某个分区没数据,可能导致watermark一直无法生成。
在 2020/8/9 下午9:38,“zhanglachun” 写入:
大佬好,我在1.11版本测试flink sql时发现一个问题,用streaming api
消费kafka,使用eventtime,再把stream转
26 matches
Mail list logo