Gyula Fora created FLINK-3619:
-
Summary: SavepointCoordinator test failure
Key: FLINK-3619
URL: https://issues.apache.org/jira/browse/FLINK-3619
Project: Flink
Issue Type: Bug
Component
i am glad to do that!
i will do that after my work!
thanks!
发件人: Aljoscha Krettek
发送时间: 2016年3月16日 9:07
收件人: dev@flink.apache.org
主题: Re: a question about CopyingChainOutput
Hi,
you are right. Only the first operator in a chain can be a keyed operator.
Hi,
if you yourself (Gyula) don’t want to maintain it anymore in the Flink codebase
I would vote to move it to an external repository. If you are not using it
anymore I’m afraid no one will really work on it.
On more thing. When using the DB state backend savepoints don’t work.
Cleanup/compact
Martin Junghanns created FLINK-3618:
---
Summary: Rename abstract UDF classes in Scatter-Gather
implementation
Key: FLINK-3618
URL: https://issues.apache.org/jira/browse/FLINK-3618
Project: Flink
Hi,
you are right. Only the first operator in a chain can be a keyed operator.
Therefore, the “setKeyContextElement1” call is currently unnecessary. If you
want you can open an issue for that and work on removing it.
Cheers,
Aljoscha
> On 16 Mar 2016, at 09:24, Ma GuoWei wrote:
>
> hi,all
> T
hi,all
The class CopyingChainOutput always setKeyContextElement1 but the second
operator of "chain" is not keyedstream any more.
I think this is no use to setKeyContextElement1.
do i miss something?
thanks for any help.
[cid:df592875-6061-4929-adf8-837d47dc2afd]
