Thank you for all your efforts!
Thanks
John
On Sun, Jun 5, 2022 at 10:33 PM Aitozi wrote:
> Thanks Yang and Nice to see it happen.
>
> Best,
> Aitozi.
>
> Yang Wang 于2022年6月5日周日 16:14写道：
>
>> The Apache Flink community is very happy to announce the release of
= TableEnvironment.create(settings);
String name = "myhive"; // Catalog名称，定义一个唯一的名称表示
String defaultDatabase = "vr_shopping_test"; // 默认数据库名称
String hiveConfDir =
"/Users/john/IdeaProjects/flink-hive-x/src/main/resources"; // hive-site.xml路径
Mark一下，我现在也有这样的需求
> 2020年7月4日 下午12:35，zhisheng 写道：
>
> 我猜你是想要将 table name 作为一个标签方便后期分组查询过滤？
>
> wangl...@geekplus.com.cn 于2020年7月3日周五 上午10:24写道：
>
>> public void invoke(ObjectNode node, Context context) throws Exception {
>>
>>String tableName =
嗨，找到问题了吗？我也遇到了
> 2020年6月1日 下午2:48，阿华田 写道：
>
> //初始化任务参数
> ExecutionEnvironment env = ExecutionEnvironment.getExecutionEnvironment();
> FileInputFormat fileInputFormat = new TextInputFormat(new
> Path("hdfs://arc/success_fid_flow "));
> fileInputFormat.setNestedFileEnumeration(true);
>
嗨，推荐你使用这个：窗口实用触发器 ContinuousEventTimeTrigger
> 2020年6月3日 下午10:29，Sun.Zhu <17626017...@163.com> 写道：
>
> hi
> 你是要每条数据都计算当前5分钟内的聚合值吗？如果是这样的话可以考虑使用over window
>
>
> | |
> Sun.Zhu
> |
> |
> 17626017...@163.com
> |
> 签名由网易邮箱大师定制
>
>
> 在2020年06月3日 02:56，steven chen 写道：
> hi ：
>
不必写在配置文件里，在提交的时候使用 -yD 动态指定参数。-yD use value for given
property。这个参数可以多个。
另外在提交的时候，可以使用klist命令看下默认的principal是哪个。
使用：kinit -kt .keytab 可以更改default principal 也就是切换用户。你可以试下。
> 2020年6月12日 上午11:36，zhangjunjie1...@163.com 写道：
>
>Flink1.9环境下，搭建Flink on
