[jira] [Created] (FLINK-6259) Fix a small spelling error

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:

Re: [DISCUSS] FLIP-18: Code Generation for improving sorting performance

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

Flink limitations under Beam

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

[jira] [Created] (FLINK-6258) Deprecate ListCheckpointed interface for managed operator state

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:

Re: Flink streaming job with iterations gets stuck waiting for network buffers

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

Re: [VOTE] Release Apache Flink 1.2.1 (RC1)

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

Re: [DISCUSS] Code style / checkstyle

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

Re: [VOTE] Release Apache Flink 1.2.1 (RC1)

+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,

[jira] [Created] (FLINK-6257) Post-pass OVER windows

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

Re: [VOTE] Release Apache Flink 1.2.1 (RC1)

+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

Re: [VOTE] Release Apache Flink 1.2.1 (RC1)

+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

Re: [VOTE] Release Apache Flink 1.2.1 (RC1)

+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. ;-) > > > >

[jira] [Created] (FLINK-6256) Fix documentation of ProcessFunction.

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

[jira] [Created] (FLINK-6255) Remove PatternStream.getSideOutput()

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:

[jira] [Created] (FLINK-6254) Consolidate late data methods on PatternStream and WindowedStream

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

[jira] [Created] (FLINK-6253) Distinct rowTime with time range boundaries

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

[jira] [Created] (FLINK-6252) Distinct rowTime with Rows boundaries

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:

[jira] [Created] (FLINK-6251) Distinct procTime with time range boundaries

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

[jira] [Created] (FLINK-6250) Distinct procTime with Rows boundaries

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

Re: [VOTE] Release Apache Flink 1.2.1 (RC1)

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

[jira] [Created] (FLINK-6249) Distinct Aggregates for OVER window

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

[jira] [Created] (FLINK-6248) Make the optional() available to all offered patterns.

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

[jira] [Created] (FLINK-6247) Build a jar-with-dependencies for flink-table and put it into ./opt

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

Re: [VOTE] Release Apache Flink 1.2.1 (RC1)

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

Re: Side Outputs - type bounds.

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 >

[jira] [Created] (FLINK-6246) Fix generic type of OutputTag in operator Output

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

Re: Flink streaming job with iterations gets stuck waiting for network buffers

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

Side Outputs - type bounds.

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

[jira] [Created] (FLINK-6244) Emit timeouted Patterns as Side Output

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: