sunjincheng created FLINK-6259:
--
Summary: Fix a small spelling error
Key: FLINK-6259
URL: https://issues.apache.org/jira/browse/FLINK-6259
Project: Flink
Issue Type: Bug
Components: Ge
Hi guys,
I have made an additional optimization[1] related to megamorphic call issue
that Greg mentioned earlier. The optimization[2] improves execution time
around ~13%, while the original code from FLINK-5734 is ~11%.
IMHO, the improvement from metamorphic call optimization is very small
compar
Hi colleagues, been a long time. New project.What feature(s)/capabilities of
Flink would become unavailable/limited if the pipeline app is written in Beam
sdk using FlinkRunner?
Thanks+regards
Tzu-Li (Gordon) Tai created FLINK-6258:
--
Summary: Deprecate ListCheckpointed interface for managed operator
state
Key: FLINK-6258
URL: https://issues.apache.org/jira/browse/FLINK-6258
Project: Fl
Hi Andrey,
As Paris has explained it, this is a known issue and there are ongoing
efforts to solve it.
I can suggest a workaround: limit the amount of messages sent into the
iteration manually. You can do this with a e.g. a Map operator that
limits records per seconds and simply sends what i
I created a PR for the revert: https://github.com/apache/flink/pull/3664
> On 3. Apr 2017, at 18:32, Stephan Ewen wrote:
>
> +1 for options (1), but also invest the time to fix it properly for 1.2.2
>
>
> On Mon, Apr 3, 2017 at 9:10 AM, Kostas Kloudas
> wrote:
>
>> +1 for 1
>>
>>> On Apr 3,
I think enough people did already look at the checkstyle rules proposed in the
PR.
On most of the rules reaching consensus is easy so I propose to enable all
rules except those regarding placement of curly braces and control flow
formatting. The two styles in the Flink code base are:
1)
if ()
+1 for options (1), but also invest the time to fix it properly for 1.2.2
On Mon, Apr 3, 2017 at 9:10 AM, Kostas Kloudas
wrote:
> +1 for 1
>
> > On Apr 3, 2017, at 5:52 PM, Till Rohrmann wrote:
> >
> > +1 for option 1)
> >
> > On Mon, Apr 3, 2017 at 5:48 PM, Fabian Hueske wrote:
> >
> >> +1 t
Fabian Hueske created FLINK-6257:
Summary: Post-pass OVER windows
Key: FLINK-6257
URL: https://issues.apache.org/jira/browse/FLINK-6257
Project: Flink
Issue Type: Improvement
Compon
+1 for 1
> On Apr 3, 2017, at 5:52 PM, Till Rohrmann wrote:
>
> +1 for option 1)
>
> On Mon, Apr 3, 2017 at 5:48 PM, Fabian Hueske wrote:
>
>> +1 to option 1)
>>
>> 2017-04-03 16:57 GMT+02:00 Ted Yu :
>>
>>> Looks like #1 is better - 1.2.1 would be at least as stable as 1.2.0
>>>
>>> Cheer
+1 for option 1)
On Mon, Apr 3, 2017 at 5:48 PM, Fabian Hueske wrote:
> +1 to option 1)
>
> 2017-04-03 16:57 GMT+02:00 Ted Yu :
>
> > Looks like #1 is better - 1.2.1 would be at least as stable as 1.2.0
> >
> > Cheers
> >
> > On Mon, Apr 3, 2017 at 7:39 AM, Aljoscha Krettek
> > wrote:
> >
> > >
+1 to option 1)
2017-04-03 16:57 GMT+02:00 Ted Yu :
> Looks like #1 is better - 1.2.1 would be at least as stable as 1.2.0
>
> Cheers
>
> On Mon, Apr 3, 2017 at 7:39 AM, Aljoscha Krettek
> wrote:
>
> > Just so we’re all on the same page. ;-)
> >
> > There was https://issues.apache.org/jira/brows
Kostas Kloudas created FLINK-6256:
-
Summary: Fix documentation of ProcessFunction.
Key: FLINK-6256
URL: https://issues.apache.org/jira/browse/FLINK-6256
Project: Flink
Issue Type: Bug
Aljoscha Krettek created FLINK-6255:
---
Summary: Remove PatternStream.getSideOutput()
Key: FLINK-6255
URL: https://issues.apache.org/jira/browse/FLINK-6255
Project: Flink
Issue Type: Improvem
Aljoscha Krettek created FLINK-6254:
---
Summary: Consolidate late data methods on PatternStream and
WindowedStream
Key: FLINK-6254
URL: https://issues.apache.org/jira/browse/FLINK-6254
Project: Flink
radu created FLINK-6253:
---
Summary: Distinct rowTime with time range boundaries
Key: FLINK-6253
URL: https://issues.apache.org/jira/browse/FLINK-6253
Project: Flink
Issue Type: Sub-task
Repo
radu created FLINK-6252:
---
Summary: Distinct rowTime with Rows boundaries
Key: FLINK-6252
URL: https://issues.apache.org/jira/browse/FLINK-6252
Project: Flink
Issue Type: Sub-task
Reporter:
radu created FLINK-6251:
---
Summary: Distinct procTime with time range boundaries
Key: FLINK-6251
URL: https://issues.apache.org/jira/browse/FLINK-6251
Project: Flink
Issue Type: Sub-task
Rep
radu created FLINK-6250:
---
Summary: Distinct procTime with Rows boundaries
Key: FLINK-6250
URL: https://issues.apache.org/jira/browse/FLINK-6250
Project: Flink
Issue Type: Sub-task
Reporter:
Looks like #1 is better - 1.2.1 would be at least as stable as 1.2.0
Cheers
On Mon, Apr 3, 2017 at 7:39 AM, Aljoscha Krettek
wrote:
> Just so we’re all on the same page. ;-)
>
> There was https://issues.apache.org/jira/browse/FLINK-5808 which was a
> bug that we initially discovered in Flink 1.
radu created FLINK-6249:
---
Summary: Distinct Aggregates for OVER window
Key: FLINK-6249
URL: https://issues.apache.org/jira/browse/FLINK-6249
Project: Flink
Issue Type: New Feature
Components:
Kostas Kloudas created FLINK-6248:
-
Summary: Make the optional() available to all offered patterns.
Key: FLINK-6248
URL: https://issues.apache.org/jira/browse/FLINK-6248
Project: Flink
Issue
Fabian Hueske created FLINK-6247:
Summary: Build a jar-with-dependencies for flink-table and put it
into ./opt
Key: FLINK-6247
URL: https://issues.apache.org/jira/browse/FLINK-6247
Project: Flink
Just so we’re all on the same page. ;-)
There was https://issues.apache.org/jira/browse/FLINK-5808 which was a bug that
we initially discovered in Flink 1.2 which was/is about missing verification
for the correctness of the combination of parallelism and max-parallelism. Due
to lacking test cov
Hi,
You’re absolutely right. I created an Issue for this:
https://issues.apache.org/jira/browse/FLINK-6246
Best,
Aljoscha
> On 3. Apr 2017, at 10:22, Dawid Wysakowicz wrote:
>
> Hi,
> I am implementing emitting discarded patterns in CEP library through Side
> Outputs and I have a question about
Aljoscha Krettek created FLINK-6246:
---
Summary: Fix generic type of OutputTag in operator Output
Key: FLINK-6246
URL: https://issues.apache.org/jira/browse/FLINK-6246
Project: Flink
Issue Ty
Hi Andrey,
If I am not mistaken this sounds like a known deadlock case and can be caused
by the combination of Flink's backpressure mechanism with iterations (more
likely when there is heavy feedback load).
Keep in mind that, currently, iterations are (perhaps the only) not stable
feature to us
Kostas Kloudas created FLINK-6245:
-
Summary: Fix late side output documentation in Window documents.
Key: FLINK-6245
URL: https://issues.apache.org/jira/browse/FLINK-6245
Project: Flink
Issue
Hi,
I am implementing emitting discarded patterns in CEP library through Side
Outputs and I have a question about the Output::collect method which is:
void collect(OutputTag outputTag, StreamRecord record);
Why the type of the outputTag is not also X? Or at least T extends X?
Thanks in advance
Dawid Wysakowicz created FLINK-6244:
---
Summary: Emit timeouted Patterns as Side Output
Key: FLINK-6244
URL: https://issues.apache.org/jira/browse/FLINK-6244
Project: Flink
Issue Type: Improv
30 matches
Mail list logo
