hi,all
??
tableEnv.createTemporaryView("sensor", sensorTable);
val resultSqlTable = tableEnv.sqlQuery("select country, count(order_id) as cnt
from sensor group by country");
tableEnv.toRetractStream[WaterSensorCnt](resultSqlTable).print("result");
hi,all
??
tableEnv.createTemporaryView("sensor", sensorTable);
val resultSqlTable = tableEnv.sqlQuery("select country, count(order_id) as cnt
from sensor group by country");
??socket??
001 usa
002 usa
003 china
002 china
004 usa
hi,all
??
tableEnv.createTemporaryView("sensor",sensorTable);
valresultSqlTable=tableEnv.sqlQuery("selectcountry,count(order_id)ascntfromsensorgroupbycountry");
??socket??
001usa
002usa
003china
002china
004usa
hi,all
??
tableEnv.createTemporaryView("sensor", sensorTable);
val resultSqlTable = tableEnv.sqlQuery("select country, count(order_id)
as cnt from sensor group by country");
??socket??
001 usa
002 usa
003 china
002 china
004
hi Michael,
??
----
??:
"user-zh"
hi Michael,
??flink 1.11
realseflink-runtime-web1.11-SNAPSHOT??
----
??:
"user-zh"
hi Michael,
??flink 1.11
realseflink-runtime-web1.11-SNAPSHOT??
----
??:
"user-zh"
hi??all
Flink1.11flink-runtime-web??cdflink-runtime-web??
Cannot resolve org.apache.flink:flink-test-utils-junit:1.11-SNAPSHOT??
Cannot resolve org.apache.flink:flink-test-utils_2.11:1.11-SNAPSHOT
退订
org.apache.flink.streaming.api.scala.StreamExecutionEnvironment
wch...@163.com
发件人： Natasha
发送时间： 2020-10-30 10:19
收件人： user-zh@flink.apache.org
主题： Flink程序连接Kafka类型不匹配问题
Hi,社区~
我想把Flink连接Kafka封装成通用的方法，但是在使用java时，类型转换上遇到了问题，这个问题网上搜索到的资料很少，刚入门不久所以也不是很明白其中的原理，请各位同行指点我一下，不胜感激。
Best,
Nat
Hi Admin,
你说的没错，我错误地import了scala的DataStream，问题已解决！感谢！
Best,
Nat
在2020年10月30日 11:06，admin<17626017...@163.com> 写道：
Hi，
怀疑你import了scala的包，把import部分也贴出来看看呢
2020年10月30日 上午10:19，Natasha <13631230...@163.com> 写道：
Hi,社区~
我想把Flink连接Kafka封装成通用的方法，但是在使用java时，类型转换上遇到了问题，这个问题网上搜索到的资料很少
hi,社区~
我想把Flink连接Kafka封装成通用的方法，但是在使用java时，类型转换上遇到了问题（附件图），这个问题网上搜索到的资料很少，刚入门不久所以也不是很明白其中的原理，请各位同行指点我一下，不胜感激
谢谢！
谢谢~ 我自已眼拙啦
在2020年10月25日 21:19，Natasha<13631230...@163.com> 写道：
hi 社区，
我想请问下如果我用第二种红色方框内的写法跟第一种红色方框有什么不一样吗？两种方式执行的程序结果是不一样的，但是不明白为什么不同
hi 社区，
我想请问下如果我用第二种红色方框内的写法跟第一种红色方框有什么不一样吗？两种方式执行的程序结果是不一样的，但是不明白为什么不同
hi leiyanrui,
我明白了，非常感谢你！！！
在2020年10月12日 15:05，leiyanrui<1150693...@qq.com> 写道：
进一步KeyedProcessFunction的处理是按照window的end时间，这样就会只有一个key进而将聚合后的数据再次聚合
--
Sent from: http://apache-flink.147419.n8.nabble.com/
HI leiyanrui,
你说的没有错，我改后的代码确实是对应了每种behavior的pv[捂脸]，非常谢谢你的热心解答！
出于对Flink的理解不太熟悉，我还想再请教一个问题，为什么原demo还需要再对聚合后的窗口数据再做一次KeyedProcessFunction的处理？（图1）因为我想在聚合函数这一步就已经可以拿到整个窗口的pv数据了。
在2020年10月12日 14:36，leiyanrui<1150693...@qq.com> 写道：
keyby(_behavior) 你看到的四个结果应该是每种behavior的pv 不是整个窗口的pv
--
Sent from:
HI Sysuke,
在2020年10月12日 14:14，Lee Sysuke 写道：
Hi , 可以粘一下aggregateFuntion和ProcessFunction的代码吗
Natasha <13631230...@163.com> 于2020年10月12日周一 下午2:11写道：
HI ALL，
刚入门Flink的我最近从github上找了几个分析用户行为的Demo，想以此来入门Flink。
1. 但是有一个问题我一直想不通：（图1）
如图，设置用户访问时间为EventTime；我设想的是，如果我设置一小时的滚动时
HI ALL，
刚入门Flink的我最近从github上找了几个分析用户行为的Demo，想以此来入门Flink。
1. 但是有一个问题我一直想不通：（图1）
如图，设置用户访问时间为EventTime；我设想的是，如果我设置一小时的滚动时间，那么按道理我应该得到的结果是，在这一小时内访问的pv总数都应该返回给我，但是为什么console打出来的却是四个相同的时间戳但是却是四个分散的41890,992,1474,2539的pv数量？（图2）
2.
谢谢 tison 和 zilong xiao，将项目的scala版本改为2.11之后可以编译成功！
因为我一开始拉Flink版本是release-0.4，该版本使用的scala是2.10。后切到分支release-1.4后编译成功，确实和scala版本有关。
thx
在2020年9月23日 19:25，zilong xiao 写道：
Hi Natasha,
在mvn命令中加上这两个参数试试看 -Dscala-2.12 -Pscala-2.12
Natasha <13631230...@163.com> 于2020年9月23日周三 下午4:00写道：
Hi
flink-runtime_2.10”，
我尝试了网上的方法，修改pom.xml文件中scala-maven-plugin的版本，或者是让IDEA的Scala版本与Windows的Scala版本保持一致，但是都不起作用！
Best,
Natasha
| |
Natasha
|
|
|
签名由网易邮箱大师定制
20 matches
Mail list logo
