大佬好！
flink ./start-cluster.sh 启动过程中如下错误，但是该端口号未占用啊，请大佬帮看看。谢谢
org.apache.flink.runtime.entrypoint.ClusterEntrypointException: Failed to
initialize the cluster entrypoint StandaloneSessionClusterEntrypoint.
at
org.apache.flink.runtime.entrypoint.ClusterEntrypoint.startCluster(ClusterEntry
: 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" 写道：
>看不到你的图片内容，有尝试过更换消费者组吗？
各位大佬好：
之前CDH集群被重新安装了，服务正常。但是在linux下打开生产者，打开消费者，再在生产者中发送一条消息，消费者一直反复消费消息，但是日志也不报异常。请大佬们帮忙看看，万分感谢！
生产者：
消费者：
你flink的版本，1.13后这个TIMESTAMP_LTZ类型支持才完善的。
>
>祝好，
>Leonard
>
>
>> 在 2021年8月16日，10:27，Geoff nie 写道：
>>
>> 问题一：flink timestamp时间戳为何中间多了个T，怎么才能少去中间T呢？
>>
>
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
大佬，请教下，我执行如下语句，发现如下报错，这是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(, )
各位大佬，
请教下2个问题，
问题一：flink timestamp时间戳为何中间多了个T，怎么才能少去中间T呢？
问题二：本地用TIMESTAMP_WITH_LOCAL_TIME_ZONE数据类型，发现不支持这个类型，咋回事啊？
谢谢！
问题一：flink timestamp时间戳为何中间多了个T，怎么才能少去T呢
问题二：本地用TIMESTAMP_WITH_LOCAL_TIME_ZONE数据类型，发现不支持这个类型，咋回事啊
能是在跑着写入任务，没有资源跑读取任务？
>
>
>你可以设置把写入任务停了，或者设置方言问 ： SET table.sql-dialect=hive;
>然后在查询试试。
>
>
>
>
>
>
>| |
>杨光跃
>|
>|
>yangguangyuem...@163.com
>|
>
>
>签名由网易邮箱大师定制
>在2021年6月24日 18:00，Geoff nie 写道：
>非常感谢！我是在sql-client上提交的，修改配置文件已经成功提交了。hive表下分区文件
在 2021-06-24 16:12:35，"杨光跃" 写道：
>
>
>检查点，checkpoint ，如果是jar包发布，直接在代码里写就可以。 如果用的sql-client提交sql ，可以在配置文件：
>sql-client-defaults.yaml 中加入如下配置：
>configuration:
> execution.checkpointing.interval: 1000
>| |
>杨光跃
>|
>|
>yangguangyuem...@163.com
>
非常感谢答复，不过我仔细考虑了下也没想明白，能具体说下在哪里配置参数吗。感谢！
在 2021-06-24 14:47:24，"杨光跃" 写道：
>分区的提交需要开启checkpoint，要配置下
>
>
>| |
>杨光跃
>|
>|
>yangguangyuem...@163.com
>|
>签名由网易邮箱大师定制
>在2021年6月24日 14:44，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问题
咨询一个flink问题。flinsql，能写入数据到hive表。但是hive表中的数
11 matches
Mail list logo
