Re: 订阅邮件

2019-09-26 文章 Dian Fu
To subscribe to the mailing list, you need send email to the following address dev-subscr...@flink.apache.org , user-subscr...@flink.apache.org and user-zh-subscr...@flink.apache.org

Re: 向社区提交代码怎么自己验证

2019-09-26 文章 Dian Fu
1)build失败的话,可以看一下失败原因,如果和这个PR没有关系,可以通过“@flinkbot run travis”重新触发travis 2)本地可以通过“mvn clean verify”验证一下,详细可以看一下[1],我看你这个改动是doc相关的,一般来说,不会导致build失败 [1] https://flink.apache.org/contributing/contribute-code.html > 在 2019年9月26日,下午9:56,高飞龙

Re: 向社区提交代码怎么自己验证

2019-09-26 文章 Zili Chen
看了下你的 PR,应该是因为不稳定测试导致的。文档相关的改动应该跟 CI 无关。 Best, tison. Zili Chen 于2019年9月26日周四 下午10:21写道: > mvn verify 可以跑单元测试和做编译期检查(如 checkstyle) > > Best, > tison. > > > 高飞龙 于2019年9月26日周四 下午9:56写道: > >> hi,我在向社区提交PR时,提示build失败( >> https://github.com/apache/flink/pull/9749#issuecomment-534149758) >> >> >>

Re: 向社区提交代码怎么自己验证

2019-09-26 文章 Zili Chen
mvn verify 可以跑单元测试和做编译期检查(如 checkstyle) Best, tison. 高飞龙 于2019年9月26日周四 下午9:56写道: > hi,我在向社区提交PR时,提示build失败( > https://github.com/apache/flink/pull/9749#issuecomment-534149758) > > > 我应该怎么做?在提交PR之前我可以执行什么脚本先在本地进行build测试吗? > > > > > > -- > > > > gaofeilong198...@163.com

向社区提交代码怎么自己验证

2019-09-26 文章 高飞龙
hi,我在向社区提交PR时,提示build失败(https://github.com/apache/flink/pull/9749#issuecomment-534149758) 我应该怎么做?在提交PR之前我可以执行什么脚本先在本地进行build测试吗? -- gaofeilong198...@163.com

回复: 关于1.9使用hive中的udf

2019-09-26 文章 like
非常感谢,但是我试过的 hive.xx_db.xx_udf 这种方式是找不到这个udf的,必须使用 tableEnv.useCatalog("hive") 、tableEnv.useDatabase("default") 在2019年9月26日 16:43,Terry Wang 写道: 问题1: default关键词报错是否试过 hive.`default`.xx_udf 方式, 这样转义应该能解决关键词报错的问题。 问题2: flink 1.10 中会支持modular plugin的方式,使用起来会更方便 Best, Terry Wang 在

Re: 关于1.9使用hive中的udf

2019-09-26 文章 Terry Wang
问题1: default关键词报错是否试过 hive.`default`.xx_udf 方式, 这样转义应该能解决关键词报错的问题。 问题2: flink 1.10 中会支持modular plugin的方式,使用起来会更方便 Best, Terry Wang > 在 2019年9月25日,下午7:21,like 写道: > > 各位大佬好: >目前我在使用1.9版本中hive的udf碰到如下问题: >

????????org.apache.flink.streaming.api.operators.TimerHeapInternalTimer ???????????????? ??????????????????

2019-09-26 文章 ??????
,: StreamQueryConfig queryConfig = tabEnv.queryConfig(); queryConfig.withIdleStateRetentionTime(Time.seconds(20), Time.minutes(6)); DataStream source = env.socketTextStream("localhost", 10028) .map(new MapFunction() {