Hi,
If you are using a fold you are using none of the new code paths. I will
add support for Fold to the new windowing implementation today, though.
Cheers,
Aljoscha
On Mon, 5 Oct 2015 at 23:49 Márton Balassi wrote:
> Martin, I have looked at your code and you are running a fold in a window,
>
Robert Metzger created FLINK-2821:
-
Summary: Change Akka configuration to allow accessing actors from
different URLs
Key: FLINK-2821
URL: https://issues.apache.org/jira/browse/FLINK-2821
Project: Flin
Hey,
This question is mainly targeted towards Aljoscha but maybe someone can
help me out here:
I think the way feedback partitioning is handled does not work, let me
illustrate with a simple example:
IterativeStream it = ... (parallelism 1)
DataStream mapped = it.map(...) (parallelism 2)
// this
Martin, I have looked at your code and you are running a fold in a window,
that is a very important distinction - the code paths are separate.
Those code paths have been recently touched by Aljoscha if I am not
mistaken.
I have mocked up a simple example and could not reproduce your problem
unfort
Thanks, I am checking it out tomorrow morning.
On Mon, Oct 5, 2015 at 9:59 PM, Martin Neumann wrote:
> Hej,
>
> Sorry it took so long to respond I needed to check if I was actually
> allowed to share the code since it uses internal datasets.
>
> In the appendix of this email you will find the ma
Hej,
Sorry it took so long to respond I needed to check if I was actually
allowed to share the code since it uses internal datasets.
In the appendix of this email you will find the main class of this job
without the supporting classes or the actual dataset. If you want to run it
you need to repla
Greg Hogan created FLINK-2820:
-
Summary: Configuration not passed to JobGraphGenerator
Key: FLINK-2820
URL: https://issues.apache.org/jira/browse/FLINK-2820
Project: Flink
Issue Type: Bug
Yes, FLINK-2785 that's right!
Alright, thanks a lot!
On 5 October 2015 at 18:31, Fabian Hueske wrote:
> Hi Vasia,
>
> I guess you are referring to FLINK-2785. Should be fine, as there is a PR
> already.
> I'll add it to the list.
>
> Would be nice if you could take care of FLINK-2786 (remove Spa
Thank you Max for putting the list together and to whomever added
FLINK-2561 to the list :)
I would also add FLINK-2561 (pending PR #1205). It's a sub-task of
FLINK-2561, so maybe it's covered as is.
If we go for Gelly graduation, I can take care of FLINK-2786 "Remove
Spargel from source code and
Hi Vasia,
I guess you are referring to FLINK-2785. Should be fine, as there is a PR
already.
I'll add it to the list.
Would be nice if you could take care of FLINK-2786 (remove Spargel).
Cheers, Fabian
2015-10-05 18:25 GMT+02:00 Vasiliki Kalavri :
> Thank you Max for putting the list together
Thanks Max.
I extended the list of issues to fix for the release.
2015-10-05 17:10 GMT+02:00 Maximilian Michels :
> Thanks Greg, we have added that to the list of API breaking changes.
>
> On Mon, Oct 5, 2015 at 4:36 PM, Greg Hogan wrote:
>
> > Max,
> >
> > Stephan noted that FLINK-2723 is an AP
Thanks Greg, we have added that to the list of API breaking changes.
On Mon, Oct 5, 2015 at 4:36 PM, Greg Hogan wrote:
> Max,
>
> Stephan noted that FLINK-2723 is an API breaking change. The CopyableValue
> interface has a new method "T copy()". Commit
> e727355e42bd0ad7d403aee703aaf33a68a839d2
Max,
Stephan noted that FLINK-2723 is an API breaking change. The CopyableValue
interface has a new method "T copy()". Commit
e727355e42bd0ad7d403aee703aaf33a68a839d2
Greg
On Mon, Oct 5, 2015 at 10:20 AM, Maximilian Michels wrote:
> Hi Flinksters,
>
> After a lot of development effort in the p
I would like to extend the coding guidelines to make new tests (or
extending existing once) for fixed bugs mandatory; ie, write a test that
fails before the fix, but passes after the fix.
Right now, the guideline dictates that **Tests for new features are
required** which is not broad enough, IMHO
Hi Flinksters,
After a lot of development effort in the past months, it is about time
to move towards the next major release. We decided to move towards
0.10 instead of a milestone release. This release will probably be the
last release before 1.0.
For 0.10 we most noticeably have the new Streami
One comment:
We should ensure that contributors follow discussions on the dev mailing
list. Otherwise, they might miss important discussions regarding their
PR (what happened already). Thus, the contributor was waiting for
feedback on the PR, while the reviewer(s) waited for the PR to be
updated ac
Hi everybody,
Along with our efforts to improve the “How to contribute” guide, I would
like to start a discussion about a setting up a review process for pull
requests.
Right now, I feel that our PR review efforts are often a bit unorganized.
This leads to situation such as:
- PRs which are ling
Hi,
I opened a PR with the discussed changes [1].
Please review, give feedback, and suggest changes.
Cheers, Fabian
[1] https://github.com/apache/flink-web/pull/11
2015-09-28 18:02 GMT+02:00 Fabian Hueske :
> @Chiwan, sure. Will do that. Thanks for pointing it out :-)
>
> 2015-09-28 18:00 GMT
Aljoscha Krettek created FLINK-2819:
---
Summary: Add Windowed Join/CoGroup Operator Based on Tagged Union
Key: FLINK-2819
URL: https://issues.apache.org/jira/browse/FLINK-2819
Project: Flink
19 matches
Mail list logo
