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 = node.get("metadata").get("topic").asText()
嗨,找到问题了吗?我也遇到了
> 2020年6月1日 下午2:48,阿华田 写道:
>
> //初始化任务参数
> ExecutionEnvironment env = ExecutionEnvironment.getExecutionEnvironment();
> FileInputFormat fileInputFormat = new TextInputFormat(new
> Path("hdfs://arc/success_fid_flow "));
> fileInputFormat.setNestedFileEnumeration(true);
> //过滤掉条件为t
嗨,推荐你使用这个:窗口实用触发器 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 yarn平台,用户之间实现租户/资源隔离,在kerberos环境下运