Could not start rest endpoint on any port in port range 8081报错,但是8081未占用啊

2021-11-09 Thread Geoff nie
大佬好! flink ./start-cluster.sh 启动过程中如下错误,但是该端口号未占用啊,请大佬帮看看。谢谢 org.apache.flink.runtime.entrypoint.ClusterEntrypointException: Failed to initialize the cluster entrypoint StandaloneSessionClusterEntrypoint. at

Re:Re: flink消费kafka过程中,发现我的CDH上的kafka异常,请大佬帮忙看看

2021-09-23 Thread Geoff nie
: unknown >21/09/23 18:03:57 INFO clients.Metadata: Cluster ID: vKZ_bka0Qziw5bBCRR3Ftg 1 >2 > 消费者(接受到了无穷个1和2,除非把这个topic删除,否则一直发送,消费): 1 2 1 2 1 2 2 1 2 1 2 1 1 2 1 2 1 2 1 1 2 1 2 1 2 1 1 2 1 2 1 2 在 2021-09-23 18:24:37,"guozhi mang" 写道: >看不到你的图片内容,有尝试过更换消费者组吗?

flink消费kafka过程中,发现我的CDH上的kafka异常,请大佬帮忙看看

2021-09-23 Thread Geoff nie
各位大佬好: 之前CDH集群被重新安装了,服务正常。但是在linux下打开生产者,打开消费者,再在生产者中发送一条消息,消费者一直反复消费消息,但是日志也不报异常。请大佬们帮忙看看,万分感谢! 生产者: 消费者:

Re:Re: 请教下Flink时间戳问题

2021-08-15 Thread Geoff nie
1.13后这个TIMESTAMP_LTZ类型支持才完善的。 > >祝好, >Leonard > > >> 在 2021年8月16日,10:27,Geoff nie 写道: >> >> 问题一:flink timestamp时间戳为何中间多了个T,怎么才能少去中间T呢? >> >

Re:Re: 关于flink时区问题

2021-08-15 Thread Geoff nie
thanks,确实是我flink版本1.12版本,版本较低问题。 在 2021-08-16 12:18:34,"Caizhi Weng" 写道: >Hi! > >TO_TIMESTAMP_LTZ 是 1.13 引入的新函数。请检查一下 Flink 版本。 > >Geoff nie 于2021年8月16日周一 上午11:47写道: > >> >> >> 大佬,请教下,我执行如下语句,发现如下报错,这是lib下面少了什么jar包嘛还是?谢谢 >> Fl

关于flink时区问题

2021-08-15 Thread Geoff nie
大佬,请教下,我执行如下语句,发现如下报错,这是lib下面少了什么jar包嘛还是?谢谢 Flink SQL> SELECT TO_TIMESTAMP_LTZ(4001, 3); [ERROR] Could not execute SQL statement. Reason: org.apache.calcite.sql.validate.SqlValidatorException: No match found for function signature TO_TIMESTAMP_LTZ(, )

请教下Flink时间戳问题

2021-08-15 Thread Geoff nie
各位大佬, 请教下2个问题, 问题一:flink timestamp时间戳为何中间多了个T,怎么才能少去中间T呢? 问题二:本地用TIMESTAMP_WITH_LOCAL_TIME_ZONE数据类型,发现不支持这个类型,咋回事啊? 谢谢! 问题一:flink timestamp时间戳为何中间多了个T,怎么才能少去T呢 问题二:本地用TIMESTAMP_WITH_LOCAL_TIME_ZONE数据类型,发现不支持这个类型,咋回事啊

Re:回复:flinksql写入hive问题

2021-06-28 Thread Geoff nie
T table.sql-dialect=hive; >然后在查询试试。 > > > > > > >| | >杨光跃 >| >| >yangguangyuem...@163.com >| > > >签名由网易邮箱大师定制 >在2021年6月24日 18:00,Geoff nie 写道: >非常感谢!我是在sql-client上提交的,修改配置文件已经成功提交了。hive表下分区文件名如下: >part-f3fa374b-c563-49c8-bd7a-b3bd7a5fb66d-0-2 >

Re:回复:flinksql写入hive问题

2021-06-24 Thread Geoff nie
-defaults.yaml 中加入如下配置: >configuration: > execution.checkpointing.interval: 1000 >| | >杨光跃 >| >| >yangguangyuem...@163.com >| >签名由网易邮箱大师定制 >在2021年6月24日 16:09,Geoff nie 写道: >非常感谢答复,不过我仔细考虑了下也没想明白,能具体说下在哪里配置参数吗。感谢! > > > > > > > > > > &g

Re:回复:flinksql写入hive问题

2021-06-24 Thread Geoff nie
非常感谢答复,不过我仔细考虑了下也没想明白,能具体说下在哪里配置参数吗。感谢! 在 2021-06-24 14:47:24,"杨光跃" 写道: >分区的提交需要开启checkpoint,要配置下 > > >| | >杨光跃 >| >| >yangguangyuem...@163.com >| >签名由网易邮箱大师定制 >在2021年6月24日 14:44,Geoff nie 写道: >您好!我也遇到这个问题了,跟以下问题类似,请问,这个问题解决了吗?非常感谢。

Re:Fw:flinksql写入hive问题

2021-06-24 Thread Geoff nie
您好!我也遇到这个问题了,跟以下问题类似,请问,这个问题解决了吗?非常感谢。 在 2021-02-14 10:43:33,"潘永克" <13311533...@163.com> 写道: 转发邮件信息 发件人:"潘永克" <13311533...@163.com> 发送日期:2021-02-11 11:12:39 收件人:d...@flink.apache.org 主题:flinksql写入hive问题