clear query| facets| time Search criteria: .   Results from 1 to 10 from 61 (0.0s).
Loading phrases to help you
refine your search...
[VOTE] FLIP-27 - Refactor Source Interface - Flink - [mail # dev]
...+1 (non-binding), thanks for driving.Best,GuoweiJingsong Li  于2020年2月4日周二 上午11:20写道:> +1 (non-binding), thanks for driving.> FLIP-27 is the basis of a lot of follow-up work.>&g...
   Author: Guowei Ma , 2020-02-04, 04:34
[expand - 1 more] - Reinterpreting a pre-partitioned data stream as keyed stream - Flink - [mail # user]
...Hi,1. Is the key that is used by the keyBy after point 1 precisely the same asthe key used by the 4a and 4b? If yes, I think you could usethe reinterpretAsKeyedStream to avoid the shuffle.2....
   Author: Guowei Ma , 2020-02-02, 10:38
DisableGenericTypes is not compatible with Kafka - Flink - [mail # user]
...Hi,I think there could be two workaround ways to 'disableGenericType' in caseof KafkaSource :1. adding the TypeInfo annotation [1] to the KafaTopicPartition.2. using the reflection to call t...
   Author: Guowei Ma , 2020-02-01, 08:44
[FLINK-15786] Load connector code with separate classloader - Flink - [issue]
...Currently, connector code can be seen as part of user code. Usually, users only need to add the corresponding connector as a dependency and package it in the user jar. This is convenient eno...    Author: Guowei Ma , 2020-01-28, 11:26
[FLINK-15784] Show the Watermark metrics of source node in the web UI. - Flink - [issue]
...Currently, the web UI only shows the watermark of the non-source node. It might mislead some users that the source could not “receive” the watermark.[1]So it would be more consistent...    Author: Guowei Ma , 2020-01-28, 11:17
[ANNOUNCE] Yu Li became a Flink committer - Flink - [mail # dev]
...CongratulationsBest,Guowei刘建刚  于2020年1月24日周五 下午5:56写道:> Congratulations!>> > 2020年1月23日 下午4:59,Stephan Ewen  写道:> >> > Hi all!> >> > We are anno...
   Author: Guowei Ma , 2020-01-24, 11:29
[expand - 1 more] - Understanding watermark - Flink - [mail # user]
...>>What I understand from you, one operator has two watermarks? If so, oneoperator's output watermark would be an input watermark of the nextoperator? Does it sounds redundant?There are...
   Author: Guowei Ma , 2020-01-20, 03:46
[FLINK-15032] Remove the eager serialization from `RemoteRpcInvocation` - Flink - [issue]
...    Currently, the constructor of `RemoteRpcInvocation` serializes the `parameterTypes` and `arg` of an RPC call. This could lead to a problem:Consider a job that has 1k parallelism and has ...    Author: Guowei Ma , 2020-01-06, 08:20
[ANNOUNCE] Zhu Zhu becomes a Flink committer - Flink - [mail # dev]
...Congrats Zhuzhu!Best,GuoweiZhenghua Gao  于2019年12月16日周一 上午10:47写道:> Congrats!>> *Best Regards,*> *Zhenghua Gao*>>> On Mon, Dec 16, 2019 at 10:36 AM Biao Liu  w...
   Author: Guowei Ma , 2019-12-16, 03:16
[FLINK-13993] Using FlinkUserCodeClassLoaders to load the user class in the perjob mode - Flink - [issue]
...Currently, Flink has the FlinkUserCodeClassLoader, which is using to load user’s class. However, the user class and the system class are all loaded by the system classloader in the perjob mo...    Author: Guowei Ma , 2019-12-09, 07:01