[jira] [Commented] (FLINK-2156) Scala modules cannot create logging file

2015-10-06 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2156?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14945531#comment-14945531 ] Dawid Wysakowicz commented on FLINK-2156: - Hi, This can be my first open-source contribution

[jira] [Comment Edited] (FLINK-2156) Scala modules cannot create logging file

2015-10-06 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2156?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14945531#comment-14945531 ] Dawid Wysakowicz edited comment on FLINK-2156 at 10/6/15 6:34 PM: -- Hi,

[jira] [Commented] (FLINK-2946) Add orderBy() to Table API

2016-03-22 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2946?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15206731#comment-15206731 ] Dawid Wysakowicz commented on FLINK-2946: - Hi, I have started working on this issue and would be

[jira] [Commented] (FLINK-3574) Implement math functions for Table API

2016-03-08 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3574?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15184889#comment-15184889 ] Dawid Wysakowicz commented on FLINK-3574: - I thought about a logic as described by you in

[jira] [Commented] (FLINK-3574) Implement math functions for Table API

2016-03-08 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3574?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15184935#comment-15184935 ] Dawid Wysakowicz commented on FLINK-3574: - Ok, I understand now. I am gonna implement it that way

[jira] [Comment Edited] (FLINK-3574) Implement math functions for Table API

2016-03-08 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3574?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15184889#comment-15184889 ] Dawid Wysakowicz edited comment on FLINK-3574 at 3/8/16 1:11 PM: - I

[jira] [Commented] (FLINK-3152) Support all comparisons for Date type

2016-03-03 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3152?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15177953#comment-15177953 ] Dawid Wysakowicz commented on FLINK-3152: - Great, thanks a lot. I will take it. > Support all

[jira] [Commented] (FLINK-3574) Implement math functions for Table API

2016-03-05 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3574?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15181658#comment-15181658 ] Dawid Wysakowicz commented on FLINK-3574: - I have some conceptual problem cause all of those

[jira] [Commented] (FLINK-3152) Support all comparisons for Date type

2016-03-02 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3152?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15175590#comment-15175590 ] Dawid Wysakowicz commented on FLINK-3152: - Thanks Timo, Sure, I will happily work on it as well as

[jira] [Commented] (FLINK-3152) Support all comparisons for Date type

2016-03-02 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3152?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15175564#comment-15175564 ] Dawid Wysakowicz commented on FLINK-3152: - Hi, I would happily try to work on this issue if nobody

[jira] [Commented] (FLINK-2946) Add orderBy() to Table API

2016-04-05 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2946?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15225963#comment-15225963 ] Dawid Wysakowicz commented on FLINK-2946: - Hi, Could someone have a look at [FLINK-3665] as it is

[jira] [Commented] (FLINK-2946) Add orderBy() to Table API

2016-04-01 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2946?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15221567#comment-15221567 ] Dawid Wysakowicz commented on FLINK-2946: - I still have some problems with range partitioning and

[jira] [Commented] (FLINK-3665) Range partitioning lacks support to define sort orders

2016-04-01 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3665?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15221572#comment-15221572 ] Dawid Wysakowicz commented on FLINK-3665: - Hi as I am working on [FLINK-2946] that needs those

[jira] [Commented] (FLINK-3842) Fix handling null record/row in generated code

2016-04-28 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3842?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15261828#comment-15261828 ] Dawid Wysakowicz commented on FLINK-3842: - Sure. Bear in mind though the {{DataSetJoin}} in the

[jira] [Commented] (FLINK-3842) Fix handling null record/row in generated code

2016-04-28 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3842?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15262136#comment-15262136 ] Dawid Wysakowicz commented on FLINK-3842: - Thanks a lot. I will gladly test it. Unfortunately I

[jira] [Commented] (FLINK-2971) Add outer joins to the Table API

2016-04-27 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2971?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15260493#comment-15260493 ] Dawid Wysakowicz commented on FLINK-2971: - I encounted another problem. Regarding null handling.

[jira] [Commented] (FLINK-2971) Add outer joins to the Table API

2016-04-27 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2971?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15260294#comment-15260294 ] Dawid Wysakowicz commented on FLINK-2971: - I started with that idea, just one small disadvantage I

[jira] [Commented] (FLINK-2971) Add outer joins to the Table API

2016-04-27 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2971?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15259992#comment-15259992 ] Dawid Wysakowicz commented on FLINK-2971: - Thanks for assigning me to this issue. I've started

[jira] [Commented] (FLINK-2971) Add outer joins to the Table API

2016-04-27 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2971?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15260305#comment-15260305 ] Dawid Wysakowicz commented on FLINK-2971: - Yes, you're right. 9 methods. > Add outer joins to the

[jira] [Commented] (FLINK-2169) Add ParquetTableSource

2016-05-11 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2169?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15279922#comment-15279922 ] Dawid Wysakowicz commented on FLINK-2169: - Thanks for you answer [~fhueske]. I would be eager to

[jira] [Commented] (FLINK-3848) Add ProjectableTableSource interface and translation rule

2016-05-11 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15280018#comment-15280018 ] Dawid Wysakowicz commented on FLINK-3848: - Sure I will have a look into current state and wait for

[jira] [Commented] (FLINK-2169) Add ParquetTableSource

2016-05-11 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2169?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15279765#comment-15279765 ] Dawid Wysakowicz commented on FLINK-2169: - I don't think anybody is working on this one right now.

[jira] [Created] (FLINK-3870) Add IntelliJ code style file

2016-05-04 Thread Dawid Wysakowicz (JIRA)
Dawid Wysakowicz created FLINK-3870: --- Summary: Add IntelliJ code style file Key: FLINK-3870 URL: https://issues.apache.org/jira/browse/FLINK-3870 Project: Flink Issue Type: New Feature

[jira] [Commented] (FLINK-3842) Fix handling null record/row in generated code

2016-05-04 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3842?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15270971#comment-15270971 ] Dawid Wysakowicz commented on FLINK-3842: - I checked your changes with my changes and it does

[jira] [Commented] (FLINK-2971) Add outer joins to the Table API

2016-05-05 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2971?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15272553#comment-15272553 ] Dawid Wysakowicz commented on FLINK-2971: - Hi, I think i finished working on that issue. Just need

[jira] [Created] (FLINK-3842) Fix handling null record/row in generated code

2016-04-28 Thread Dawid Wysakowicz (JIRA)
Dawid Wysakowicz created FLINK-3842: --- Summary: Fix handling null record/row in generated code Key: FLINK-3842 URL: https://issues.apache.org/jira/browse/FLINK-3842 Project: Flink Issue

[jira] [Commented] (FLINK-2971) Add outer joins to the Table API

2016-04-28 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2971?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15261777#comment-15261777 ] Dawid Wysakowicz commented on FLINK-2971: - That's right [~twalthr], it is a case with null row. I

[jira] [Assigned] (FLINK-5606) Remove magic number in key and namespace serialization

2017-02-02 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5606?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz reassigned FLINK-5606: --- Assignee: Dawid Wysakowicz > Remove magic number in key and namespace serialization

[jira] [Assigned] (FLINK-5509) Replace QueryableStateClient keyHashCode argument

2017-02-02 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5509?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz reassigned FLINK-5509: --- Assignee: Dawid Wysakowicz > Replace QueryableStateClient keyHashCode argument >

[jira] [Assigned] (FLINK-5607) Move location lookup retry out of KvStateLocationLookupService

2017-02-03 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5607?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz reassigned FLINK-5607: --- Assignee: Dawid Wysakowicz > Move location lookup retry out of

[jira] [Commented] (FLINK-5607) Move location lookup retry out of KvStateLocationLookupService

2017-02-03 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5607?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15851287#comment-15851287 ] Dawid Wysakowicz commented on FLINK-5607: - I will be eager to work on this issue. > Move location

[jira] [Commented] (FLINK-5603) Use Flink's futures in QueryableStateClient

2017-02-01 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5603?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15848732#comment-15848732 ] Dawid Wysakowicz commented on FLINK-5603: - I think this is a duplicate of [FLINK-5510] > Use

[jira] [Assigned] (FLINK-5510) Replace Scala Future with FlinkFuture in QueryableStateClient

2017-02-01 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5510?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz reassigned FLINK-5510: --- Assignee: Dawid Wysakowicz > Replace Scala Future with FlinkFuture in

[jira] [Commented] (FLINK-5510) Replace Scala Future with FlinkFuture in QueryableStateClient

2017-02-01 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15848733#comment-15848733 ] Dawid Wysakowicz commented on FLINK-5510: - Hi I would be glad to work on that. > Replace Scala

[jira] [Commented] (FLINK-5510) Replace Scala Future with FlinkFuture in QueryableStateClient

2017-02-01 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15848778#comment-15848778 ] Dawid Wysakowicz commented on FLINK-5510: - Just had a look into the code and been wondering how

[jira] [Assigned] (FLINK-5607) Move location lookup retry out of KvStateLocationLookupService

2017-02-21 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5607?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz reassigned FLINK-5607: --- Assignee: (was: Dawid Wysakowicz) > Move location lookup retry out of

[jira] [Commented] (FLINK-5824) Fix String/byte conversions without explicit encoding

2017-02-21 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5824?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15875649#comment-15875649 ] Dawid Wysakowicz commented on FLINK-5824: - Just two more questions. First I tried to investigate

[jira] [Updated] (FLINK-5864) CEP: fix duplicate output patterns problem.

2017-02-21 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5864?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-5864: Description: Currently when searching for a pattern {{a,b,c}} and we have input elements

[jira] [Assigned] (FLINK-5510) Replace Scala Future with FlinkFuture in QueryableStateClient

2017-02-21 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5510?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz reassigned FLINK-5510: --- Assignee: (was: Dawid Wysakowicz) > Replace Scala Future with FlinkFuture in

[jira] [Assigned] (FLINK-5509) Replace QueryableStateClient keyHashCode argument

2017-02-20 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5509?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz reassigned FLINK-5509: --- Assignee: (was: Dawid Wysakowicz) > Replace QueryableStateClient keyHashCode

[jira] [Assigned] (FLINK-5606) Remove magic number in key and namespace serialization

2017-02-20 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5606?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz reassigned FLINK-5606: --- Assignee: (was: Dawid Wysakowicz) > Remove magic number in key and namespace

[jira] [Assigned] (FLINK-3318) Add support for quantifiers to CEP's pattern API

2017-02-20 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3318?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz reassigned FLINK-3318: --- Assignee: Dawid Wysakowicz (was: Ivan Mushketyk) > Add support for quantifiers to

[jira] [Created] (FLINK-5853) Add consecutive event based filters

2017-02-20 Thread Dawid Wysakowicz (JIRA)
Dawid Wysakowicz created FLINK-5853: --- Summary: Add consecutive event based filters Key: FLINK-5853 URL: https://issues.apache.org/jira/browse/FLINK-5853 Project: Flink Issue Type: New

[jira] [Created] (FLINK-5842) Wrong 'since' version for ElasticSearch 5.x connector

2017-02-19 Thread Dawid Wysakowicz (JIRA)
Dawid Wysakowicz created FLINK-5842: --- Summary: Wrong 'since' version for ElasticSearch 5.x connector Key: FLINK-5842 URL: https://issues.apache.org/jira/browse/FLINK-5842 Project: Flink

[jira] [Commented] (FLINK-5824) Fix String/byte conversions without explicit encoding

2017-02-21 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5824?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15876695#comment-15876695 ] Dawid Wysakowicz commented on FLINK-5824: - I've fixed all direct String <> bytes conversions as

[jira] [Commented] (FLINK-5824) Fix String/byte conversions without explicit encoding

2017-02-21 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5824?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15876215#comment-15876215 ] Dawid Wysakowicz commented on FLINK-5824: - Right now such a regex will match also for

[jira] [Commented] (FLINK-5824) Fix String/byte conversions without explicit encoding

2017-02-17 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5824?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15871428#comment-15871428 ] Dawid Wysakowicz commented on FLINK-5824: - I would be glad to help with this issue, if it is ok

[jira] [Commented] (FLINK-5824) Fix String/byte conversions without explicit encoding

2017-02-17 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5824?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15871737#comment-15871737 ] Dawid Wysakowicz commented on FLINK-5824: - [~StephanEwen] Sure, will do it. We don't want it to be

[jira] [Commented] (FLINK-5389) Fails #testAnswerFailureWhenSavepointReadFails

2017-02-17 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5389?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15871840#comment-15871840 ] Dawid Wysakowicz commented on FLINK-5389: - Same reason for failing those tests. > Fails

[jira] [Comment Edited] (FLINK-5389) Fails #testAnswerFailureWhenSavepointReadFails

2017-02-17 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5389?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15871840#comment-15871840 ] Dawid Wysakowicz edited comment on FLINK-5389 at 2/17/17 1:21 PM: -- It is

[jira] [Commented] (FLINK-5402) Fails AkkaRpcServiceTest#testTerminationFuture

2017-02-17 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5402?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15871846#comment-15871846 ] Dawid Wysakowicz commented on FLINK-5402: - It is very macOS specific case. It is due to very slow

[jira] [Comment Edited] (FLINK-5402) Fails AkkaRpcServiceTest#testTerminationFuture

2017-02-17 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5402?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15871846#comment-15871846 ] Dawid Wysakowicz edited comment on FLINK-5402 at 2/17/17 1:41 PM: -- It is

[jira] [Created] (FLINK-6165) Implement internal continuity for looping states.

2017-03-22 Thread Dawid Wysakowicz (JIRA)
Dawid Wysakowicz created FLINK-6165: --- Summary: Implement internal continuity for looping states. Key: FLINK-6165 URL: https://issues.apache.org/jira/browse/FLINK-6165 Project: Flink Issue

[jira] [Created] (FLINK-6208) Implement skip till next match strategy

2017-03-28 Thread Dawid Wysakowicz (JIRA)
Dawid Wysakowicz created FLINK-6208: --- Summary: Implement skip till next match strategy Key: FLINK-6208 URL: https://issues.apache.org/jira/browse/FLINK-6208 Project: Flink Issue Type: New

[jira] [Resolved] (FLINK-6165) Implement internal continuity for looping states.

2017-03-30 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6165?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz resolved FLINK-6165. - Resolution: Fixed Fix Version/s: 1.3.0 > Implement internal continuity for looping

[jira] [Resolved] (FLINK-3318) Add support for quantifiers to CEP's pattern API

2017-03-23 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3318?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz resolved FLINK-3318. - Resolution: Fixed Fix Version/s: 1.3.0 > Add support for quantifiers to CEP's

[jira] [Assigned] (FLINK-3320) Add not operator to CEP's pattern API

2017-03-27 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3320?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz reassigned FLINK-3320: --- Assignee: Dawid Wysakowicz > Add not operator to CEP's pattern API >

[jira] [Created] (FLINK-6137) Add custom checkstyle for flink-cep

2017-03-20 Thread Dawid Wysakowicz (JIRA)
Dawid Wysakowicz created FLINK-6137: --- Summary: Add custom checkstyle for flink-cep Key: FLINK-6137 URL: https://issues.apache.org/jira/browse/FLINK-6137 Project: Flink Issue Type:

[jira] [Resolved] (FLINK-6080) Unclosed ObjectOutputStream in NFA#serialize()

2017-03-22 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6080?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz resolved FLINK-6080. - Resolution: Fixed Fix Version/s: 1.3.0 > Unclosed ObjectOutputStream in

[jira] [Updated] (FLINK-6165) Implement internal continuity for looping states.

2017-03-22 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6165?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-6165: Description: We should be able to specify an internal continuity for a looping state. The

[jira] [Commented] (FLINK-6063) HA Configuration doesn't work with Flink 1.2

2017-03-16 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6063?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15927836#comment-15927836 ] Dawid Wysakowicz commented on FLINK-6063: - Hi Razvan, I've had a look at your logs and I think

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

2017-04-03 Thread Dawid Wysakowicz (JIRA)
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:

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

2017-04-03 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6244?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15953621#comment-15953621 ] Dawid Wysakowicz commented on FLINK-6244: - I think it is a good way to proceed. Another way I was

[jira] [Updated] (FLINK-6290) SharedBuffer is improperly released when multiple edges between entries

2017-04-10 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6290?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-6290: Description: Below test right now fails: {code} @Test public void

[jira] [Created] (FLINK-6290) SharedBuffer is improperly released when multiple edges between entries

2017-04-10 Thread Dawid Wysakowicz (JIRA)
Dawid Wysakowicz created FLINK-6290: --- Summary: SharedBuffer is improperly released when multiple edges between entries Key: FLINK-6290 URL: https://issues.apache.org/jira/browse/FLINK-6290 Project:

[jira] [Updated] (FLINK-6290) SharedBuffer is improperly released when multiple edges between entries

2017-04-10 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6290?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-6290: Description: Below test right now fails: {code} @Test public void

[jira] [Assigned] (FLINK-6290) SharedBuffer is improperly released when multiple edges between entries

2017-04-10 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6290?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz reassigned FLINK-6290: --- Assignee: Dawid Wysakowicz > SharedBuffer is improperly released when multiple edges

[jira] [Assigned] (FLINK-6000) Can not start HA cluster with start-cluster.sh

2017-03-10 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6000?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz reassigned FLINK-6000: --- Assignee: Dawid Wysakowicz > Can not start HA cluster with start-cluster.sh >

[jira] [Created] (FLINK-6000) Can not start HA cluster with start-cluster.sh

2017-03-08 Thread Dawid Wysakowicz (JIRA)
Dawid Wysakowicz created FLINK-6000: --- Summary: Can not start HA cluster with start-cluster.sh Key: FLINK-6000 URL: https://issues.apache.org/jira/browse/FLINK-6000 Project: Flink Issue

[jira] [Commented] (FLINK-3414) Add Scala API for CEP's pattern definition

2017-03-06 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15897272#comment-15897272 ] Dawid Wysakowicz commented on FLINK-3414: - Hi [~ivan.mushketyk] Do you still want to work on it

[jira] [Resolved] (FLINK-5864) CEP: fix duplicate output patterns problem.

2017-03-03 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5864?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz resolved FLINK-5864. - Resolution: Fixed > CEP: fix duplicate output patterns problem. >

[jira] [Commented] (FLINK-5779) Auto generate configuration docs

2017-03-08 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5779?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15901005#comment-15901005 ] Dawid Wysakowicz commented on FLINK-5779: - If nobody is currently working on this one, I will take

[jira] [Assigned] (FLINK-5781) Generation HTML from ConfigOption

2017-03-08 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5781?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz reassigned FLINK-5781: --- Assignee: Dawid Wysakowicz > Generation HTML from ConfigOption >

[jira] [Assigned] (FLINK-5779) Auto generate configuration docs

2017-03-08 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5779?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz reassigned FLINK-5779: --- Assignee: Dawid Wysakowicz > Auto generate configuration docs >

[jira] [Assigned] (FLINK-5780) Extend ConfigOption with descriptions

2017-03-08 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5780?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz reassigned FLINK-5780: --- Assignee: Dawid Wysakowicz > Extend ConfigOption with descriptions >

[jira] [Commented] (FLINK-7293) Support custom order by in PatternStream

2017-07-31 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7293?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16106931#comment-16106931 ] Dawid Wysakowicz commented on FLINK-7293: - I had another look at the sorting strategy and I

[jira] [Commented] (FLINK-7169) Support AFTER MATCH SKIP function in CEP library API

2017-07-31 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7169?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16107012#comment-16107012 ] Dawid Wysakowicz commented on FLINK-7169: - Hi [~ychen] I've tried to put some of my ideas

[jira] [Comment Edited] (FLINK-7292) Fix EMPTY MATCH bug in CEP.

2017-07-28 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16104917#comment-16104917 ] Dawid Wysakowicz edited comment on FLINK-7292 at 7/28/17 1:05 PM: -- I

[jira] [Commented] (FLINK-7292) Fix EMPTY MATCH bug in CEP.

2017-07-28 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16104917#comment-16104917 ] Dawid Wysakowicz commented on FLINK-7292: - I would not say it is a bug. It is a architectural

[jira] [Updated] (FLINK-7292) Fix EMPTY MATCH bug in CEP.

2017-07-28 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7292?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-7292: Issue Type: New Feature (was: Bug) > Fix EMPTY MATCH bug in CEP. >

[jira] [Commented] (FLINK-7293) Support custom order by in PatternStream

2017-07-28 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7293?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16104922#comment-16104922 ] Dawid Wysakowicz commented on FLINK-7293: - Hmm, I can't see a way to sort an unbounded stream of

[jira] [Updated] (FLINK-7306) function notFollowedBy in CEP dont return a Pattern object

2017-07-31 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7306?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-7306: Docs Text: was: in the source code ,the function in scala is below : {code} def

[jira] [Updated] (FLINK-7306) function notFollowedBy in CEP dont return a Pattern object

2017-07-31 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7306?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-7306: Docs Text: in the source code ,the function in scala is below : {code} def

[jira] [Updated] (FLINK-7306) function notFollowedBy in CEP dont return a Pattern object

2017-07-31 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7306?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-7306: Description: i want to use CEP library to do something with scala. when use

[jira] [Updated] (FLINK-7306) function notFollowedBy in CEP dont return a Pattern object

2017-07-31 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7306?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-7306: Docs Text: (was: ) > function notFollowedBy in CEP dont return a Pattern object >

[jira] [Assigned] (FLINK-7306) function notFollowedBy in CEP dont return a Pattern object

2017-07-31 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7306?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz reassigned FLINK-7306: --- Assignee: Dawid Wysakowicz > function notFollowedBy in CEP dont return a Pattern

[jira] [Commented] (FLINK-7306) function notFollowedBy in CEP dont return a Pattern object

2017-07-31 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7306?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16107225#comment-16107225 ] Dawid Wysakowicz commented on FLINK-7306: - You are absolutely right. I've already opened a PR for

[jira] [Comment Edited] (FLINK-7306) function notFollowedBy in CEP dont return a Pattern object

2017-07-31 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7306?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16107225#comment-16107225 ] Dawid Wysakowicz edited comment on FLINK-7306 at 7/31/17 12:18 PM: --- You

[jira] [Assigned] (FLINK-6458) Support NOT patterns with preceding OPTIONALS

2017-08-01 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6458?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz reassigned FLINK-6458: --- Assignee: (was: Dawid Wysakowicz) > Support NOT patterns with preceding

[jira] [Resolved] (FLINK-7306) function notFollowedBy in CEP dont return a Pattern object

2017-08-03 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7306?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz resolved FLINK-7306. - Resolution: Fixed Fix Version/s: 1.4.0 > function notFollowedBy in CEP dont

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

2017-07-12 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6244?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz reassigned FLINK-6244: --- Assignee: Dawid Wysakowicz > Emit timeouted Patterns as Side Output >

[jira] [Created] (FLINK-7182) Activate checkstyle flink-java/functions

2017-07-14 Thread Dawid Wysakowicz (JIRA)
Dawid Wysakowicz created FLINK-7182: --- Summary: Activate checkstyle flink-java/functions Key: FLINK-7182 URL: https://issues.apache.org/jira/browse/FLINK-7182 Project: Flink Issue Type:

[jira] [Created] (FLINK-7189) Activate checkstyle flink-java/utils

2017-07-14 Thread Dawid Wysakowicz (JIRA)
Dawid Wysakowicz created FLINK-7189: --- Summary: Activate checkstyle flink-java/utils Key: FLINK-7189 URL: https://issues.apache.org/jira/browse/FLINK-7189 Project: Flink Issue Type:

[jira] [Created] (FLINK-7192) Activate checkstyle flink-java/test/operator

2017-07-14 Thread Dawid Wysakowicz (JIRA)
Dawid Wysakowicz created FLINK-7192: --- Summary: Activate checkstyle flink-java/test/operator Key: FLINK-7192 URL: https://issues.apache.org/jira/browse/FLINK-7192 Project: Flink Issue Type:

[jira] [Created] (FLINK-7191) Activate checkstyle flink-java/operators/translation

2017-07-14 Thread Dawid Wysakowicz (JIRA)
Dawid Wysakowicz created FLINK-7191: --- Summary: Activate checkstyle flink-java/operators/translation Key: FLINK-7191 URL: https://issues.apache.org/jira/browse/FLINK-7191 Project: Flink

[jira] [Created] (FLINK-7183) Activate checkstyle flink-java/aggregation

2017-07-14 Thread Dawid Wysakowicz (JIRA)
Dawid Wysakowicz created FLINK-7183: --- Summary: Activate checkstyle flink-java/aggregation Key: FLINK-7183 URL: https://issues.apache.org/jira/browse/FLINK-7183 Project: Flink Issue Type:

[jira] [Created] (FLINK-7184) Activate checkstyle flink-java/hadoop

2017-07-14 Thread Dawid Wysakowicz (JIRA)
Dawid Wysakowicz created FLINK-7184: --- Summary: Activate checkstyle flink-java/hadoop Key: FLINK-7184 URL: https://issues.apache.org/jira/browse/FLINK-7184 Project: Flink Issue Type:

[jira] [Created] (FLINK-7187) Activate checkstyle flink-java/sca

2017-07-14 Thread Dawid Wysakowicz (JIRA)
Dawid Wysakowicz created FLINK-7187: --- Summary: Activate checkstyle flink-java/sca Key: FLINK-7187 URL: https://issues.apache.org/jira/browse/FLINK-7187 Project: Flink Issue Type:

[jira] [Created] (FLINK-7188) Activate checkstyle flink-java/summarize

2017-07-14 Thread Dawid Wysakowicz (JIRA)
Dawid Wysakowicz created FLINK-7188: --- Summary: Activate checkstyle flink-java/summarize Key: FLINK-7188 URL: https://issues.apache.org/jira/browse/FLINK-7188 Project: Flink Issue Type:

[jira] [Created] (FLINK-7185) Activate checkstyle flink-java/io

2017-07-14 Thread Dawid Wysakowicz (JIRA)
Dawid Wysakowicz created FLINK-7185: --- Summary: Activate checkstyle flink-java/io Key: FLINK-7185 URL: https://issues.apache.org/jira/browse/FLINK-7185 Project: Flink Issue Type:

  1   2   3   4   5   6   7   8   9   10   >