Hi Zou Dan：
可以尝试下立刻语句是否可行
https://ci.apache.org/projects/flink/flink-docs-master/dev/table/sql/create.html#create-table
CREATE TABLE Orders (
user BIGINT,
product STRING,
order_time TIMESTAMP(3)
) WITH (
'connector' = 'kafka',
'scan.startup.mode' = 'earliest-offset'
);
Flink版本：1.11.1
官网文档中定义如下：
:
column_name AS computed_column_expression [COMMENT column_comment]
我看到官方文档中计算列是可以指定column_comment的，但我尝试了一下发现会报错
使用方式和报错信息如下：
create table t1(
data_time STRING,
row1_time AS to_timestamp(data_time) COMMENT 'test'
WATERMARK FOR
大家好
请问目前flink sql是不是不能没有开启全局端到端精确一致性（eos）的方
式，
目前仅有kafka实现了TwoPhaseCommitSinkFunction，但kafka的ddl中也没有属性去设
置Semantic为EXACTLY_ONCE
我们是否可以去支持更多的事务性connector，并可以在flink sql维度支持开启全局的
端到端一致性，并为每个connector是否支持EXACTLY_ONCE进行验证，
当开启全局EXACTLY_ONCE并且所有使用的connector都支持EXACTLY_ONCE，是否整个应
大家好，
目前测试的版本是flink1.11
看jira https://issues.apache.org/jira/browse/FLINK-12130 所示的问题好像并没
有得到解决
flink run -m yarn-cluster -yD security.kerberos.login.keytab = / path / to /
keytab -yD security.kerberos.login.principal = xxx /path/to/test.jar
看源码发现安全认证所用的配置还是只使用了配置文件中的配置，并没有把动态参数里
的配置进行合并，求助~
测试Flink版本：1.11.0
Flink sql支持这种语法插入吗，在插入时指定具体的字段顺序和要插入的列
Insert into tableName(col1[,col2]) select col1[,col2]
目前通过测试发现了以下问题
建表语句：
create table t1(a int,b string,c int) with ();
create table t2(a int,b string,c int) with ();
问题1：测试发现insert into时查询和sink schema的匹配规则是按照定义的顺序进行
测试语句：
1.9的前端ui不是相比于1.8重构了吗，官网的visualizer页面还是1.8的老样式
-邮件原件-
发件人: tison
发送时间: 2020年1月8日 13:14
收件人: user-zh
主题: Re: 问一下Flink Plan Visualizer什么时候会更新成1.9的样式
请问你所说的 1.9 的样式是怎么样的呢？我记得最近有跟 visualizer 相关的讨论，但是没有这个特殊的 issue，你可以直接在 JIRA
上提 issue
Best,
tison.
于2020年1月8日周三 下午12:56写道：
> 有大佬能解答下吗
>
>
有大佬能解答下吗
-邮件原件-
发件人: slle...@aliyun.com.INVALID
发送时间: 2020年1月6日 11:15
收件人: user-zh@flink.apache.org
主题: 问一下Flink Plan Visualizer什么时候会更新成1.9的样式
链接地址：https://flink.apache.org/visualizer/index.html
好的非常感谢，现在确实用的只是1.8,只关注了jira的状态，没有关注相关源码的改动
-邮件原件-
发件人: Terry Wang
发送时间: 2019年12月31日 14:42
收件人: user-zh@flink.apache.org
主题: Re: -yD Kerberos 认证问题
Hi ~
这个问题在最新的代码上已经修复了，在flink 1.9 上应该也是不存在这个问题的，你可以用下看看~
Best,
Terry Wang
> 2019年12月31日 14:18，
> 写道：
>
> 大家好
>
>
大家好
我们这里有通过-yd动态的提交Kerberos认证参数的需求，
想问下这个jira为啥被标记为了won’t fix，谢谢
https://issues.apache.org/jira/browse/FLINK-12130
Thanks
-邮件原件-
发件人: Yun Tang
发送时间: 2019年11月4日 15:26
收件人: user-zh@flink.apache.org
主题: Re: Checkpoint failed all the time
Sure, this feature has been implemented in FLINK-12364 [1], all you need do is
set the tolerable checkpoint failure numbers via like
Checkpoint will fail for some reasons，
Is there a way to make checkpoint fail a certain number of times and then
the job will fail automatically
普通的etl sql是否可以使用窗口
类似于这样：
select * from table_name
where xxx_time = TUMBLE(rowtime, INTERVAL '1' MINUTE)
定时触发一段sql逻辑的执行
看了下官网只有group by的window，这种没有group by的window是否可以这么定义？
可以的话能否给个demo样例
谢谢各位
12 matches
Mail list logo
