Hi
For now we use very old netty version.
Netty 4.0.27.Final released on 02-Apr-15
If we so worry about slice in LengthFieldBasedFrameDecoder we can add custom
LengthFieldBasedCopyFrameDecoder which extend original
LengthFieldBasedFrameDecoder and override extractFrame for keep current
behavio
Hi Shaoxuan and Yuhong,
thanks for your feedbacks.
@Shaoxuan, actually the unbounded inner join is just inspired by your
document and the discussions. I've spent a lot of time arranging the
references, but still put the link at a wrong please. Sorry for that and
had it done now. Go back to work..
Xiaowei Jiang created FLINK-6621:
Summary: Legal check for 1.3.0 RC01 Release
Key: FLINK-6621
URL: https://issues.apache.org/jira/browse/FLINK-6621
Project: Flink
Issue Type: Bug
Co
Jingsong Lee created FLINK-6620:
---
Summary: Add KeyGroupCheckpointedOperator interface that works for
checkpointing key-groups
Key: FLINK-6620
URL: https://issues.apache.org/jira/browse/FLINK-6620
Projec
sunjincheng created FLINK-6619:
--
Summary: Check Table API & SQL support for 1.3.0 RC01 Release
Key: FLINK-6619
URL: https://issues.apache.org/jira/browse/FLINK-6619
Project: Flink
Issue Type: Te
Hi Xingcan,
Thanks for the proposal.
I have glanced at the design document but not detailedly. The semantics of
Record-to-window Join is already in progress in FLINK-5725,.
It would be great if you can share your ideas about the implementions.
Thanks very much.
Yuhong
-邮件原件-
发件人: Shaoxua
sunjincheng created FLINK-6618:
--
Summary: Fix `GroupWindow` JAVA logical plans not consistent with
SCALA logical plans.
Key: FLINK-6618
URL: https://issues.apache.org/jira/browse/FLINK-6618
Project: Flin
sunjincheng created FLINK-6617:
--
Summary: Improve JAVA and SCALA logical plans consistent test
Key: FLINK-6617
URL: https://issues.apache.org/jira/browse/FLINK-6617
Project: Flink
Issue Type: Te
Hi Aljoscha,
Thanks for the clarification. I understand that there might be advantages in
some cases not to have the List-like interface, while in other scenarios (like
the one I described there aren't). Considering this, why not having 2 type of
states: ListState and StreamInListState - users
Hi,
The interface is restrictive on purpose because depending on the state backend
it might not be possible to provide a List-like interface. There might be state
backends that stream in the list from somewhere else or other restrictions. If
we now allowed a more general interface here we would
Robert, please add FLINK-6606 to the list of JIRAs that you're tracking,
thanks.
On Tue, May 16, 2017 at 8:30 AM, Robert Metzger wrote:
> I totally forgot to post a document with testing tasks in the RC0 thread,
> so I'll do it in the RC1 thread.
>
> Please use this document:
> https://docs.goog
Greg Hogan created FLINK-6616:
-
Summary: Clarify provenance of official Docker images
Key: FLINK-6616
URL: https://issues.apache.org/jira/browse/FLINK-6616
Project: Flink
Issue Type: Improvement
We already have a Dockerfile in our source repo as part of simple test:
https://github.com/apache/flink/tree/master/flink-contrib/docker-flink
but it was never automatically build by our build system AFAIK.
- Henry
On Tue, May 16, 2017 at 8:58 AM, Robert Metzger wrote:
> How hard would it be
Hello Xingcan,
Thanks for the proposal. It seems (I may miss something) the proposed
semantics&approach for unbounded inner join is similar as the one proposed
in FLINK-5878.
I did not create the PR for FLINK-5878, as the implementation for inner
join is closely associated with "Retract" (proposed
Andrey created FLINK-6615:
-
Summary: tmp directory not cleaned up on shutdown
Key: FLINK-6615
URL: https://issues.apache.org/jira/browse/FLINK-6615
Project: Flink
Issue Type: Bug
Affects Versions
Hi everyone,
Recently, I drafted a proposal about inner join in Flink (
http://goo.gl/4AdR7h).
This document reviews some related work on the Table/SQL topic and it
provides a relatively complete view about the inner join semantics and
implementation. Besides, I also share my (objective) thoughts
Fabian Hueske created FLINK-6614:
Summary: Applying function on window auxiliary function fails
Key: FLINK-6614
URL: https://issues.apache.org/jira/browse/FLINK-6614
Project: Flink
Issue Type
Andrey created FLINK-6613:
-
Summary: OOM during reading big messages from Kafka
Key: FLINK-6613
URL: https://issues.apache.org/jira/browse/FLINK-6613
Project: Flink
Issue Type: Bug
Affects Versio
Till Rohrmann created FLINK-6612:
Summary: ZooKeeperStateHandleStore does not guard against
concurrent delete operations
Key: FLINK-6612
URL: https://issues.apache.org/jira/browse/FLINK-6612
Project:
Mauro Cortellazzi created FLINK-6611:
Summary: When TaskManager or JobManager crash
Key: FLINK-6611
URL: https://issues.apache.org/jira/browse/FLINK-6611
Project: Flink
Issue Type: Bug
zhihao chen created FLINK-6610:
--
Summary: WebServer could not be created,when set the
"jobmanager.web.submit.enable" to false
Key: FLINK-6610
URL: https://issues.apache.org/jira/browse/FLINK-6610
Project
Dawid Wysakowicz created FLINK-6609:
---
Summary: Wrong version assignment when multiple TAKEs transitions
Key: FLINK-6609
URL: https://issues.apache.org/jira/browse/FLINK-6609
Project: Flink
Tzu-Li (Gordon) Tai created FLINK-6608:
--
Summary: Relax Kerberos login contexts parsing by trimming
whitespaces in contexts list
Key: FLINK-6608
URL: https://issues.apache.org/jira/browse/FLINK-6608
23 matches
Mail list logo
