[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] [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&focusedCommentId=15927836#comment-15927836 ] Dawid Wysakowicz commented on FLINK-6063: - Hi Razvan, I've had a look at your lo

[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: Improveme

[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 NFA#seriali

[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 AP

[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 T

[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 patte

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

2017-03-23 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6165?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz reassigned FLINK-6165: --- Assignee: Dawid Wysakowicz > Implement internal continuity for looping states. >

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

2017-03-23 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: Affects Version/s: 1.2.0 > Implement internal continuity for looping states. > -

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

2017-03-23 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: Affects Version/s: (was: 1.2.0) > Implement internal continuity for looping states. > --

[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-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 F

[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] [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: Improv

[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&focusedCommentId=15953621#comment-15953621 ] Dawid Wysakowicz commented on FLINK-6244: - I think it is a good way to proceed. An

[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 testCleari

[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 testCleari

[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] [Commented] (FLINK-6410) build fails after changing Scala to 2.11

2017-04-28 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6410?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15988714#comment-15988714 ] Dawid Wysakowicz commented on FLINK-6410: - There are multiple JIRAs already referr

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

2017-04-28 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6208?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz resolved FLINK-6208. - Resolution: Fixed > Implement skip till next match strategy >

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

2017-04-28 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3870?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz reassigned FLINK-3870: --- Assignee: (was: Dawid Wysakowicz) > Add IntelliJ code style file > --

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

2017-05-05 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: Dawid Wysakowicz > Support NOT patterns with preceding OPTIONALS >

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

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

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

2017-05-11 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5853?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16006272#comment-16006272 ] Dawid Wysakowicz commented on FLINK-5853: - Hi [~kkl0u], Yes it is. I agree [FLINK-

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

2017-05-11 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5853?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-5853. --- Resolution: Duplicate > Add consecutive event based filters >

[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&focusedCommentId=15871428#comment-15871428 ] Dawid Wysakowicz commented on FLINK-5824: - I would be glad to help with this issue

[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&focusedCommentId=15871737#comment-15871737 ] Dawid Wysakowicz commented on FLINK-5824: - [~StephanEwen] Sure, will do it. We don

[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&focusedCommentId=15871840#comment-15871840 ] Dawid Wysakowicz commented on FLINK-5389: - Same reason for failing those tests. >

[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&focusedCommentId=15871840#comment-15871840 ] Dawid Wysakowicz edited comment on FLINK-5389 at 2/17/17 1:21 PM: --

[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&focusedCommentId=15871846#comment-15871846 ] Dawid Wysakowicz commented on FLINK-5402: - It is very macOS specific case. It is d

[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&focusedCommentId=15871846#comment-15871846 ] Dawid Wysakowicz edited comment on FLINK-5402 at 2/17/17 1:41 PM: --

[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 Iss

[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 seri

[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 argu

[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 CE

[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 Featu

[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 Quer

[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 KvStateLoca

[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&focusedCommentId=15875649#comment-15875649 ] Dawid Wysakowicz commented on FLINK-5824: - Just two more questions. First I tried

[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 {{a

[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&focusedCommentId=15876215#comment-15876215 ] Dawid Wysakowicz commented on FLINK-5824: - Right now such a regex will match also

[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&focusedCommentId=15876695#comment-15876695 ] Dawid Wysakowicz commented on FLINK-5824: - I've fixed all direct String <> bytes c

[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-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&focusedCommentId=15897272#comment-15897272 ] Dawid Wysakowicz commented on FLINK-3414: - Hi [~ivan.mushketyk] Do you still want

[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&focusedCommentId=15901005#comment-15901005 ] Dawid Wysakowicz commented on FLINK-5779: - If nobody is currently working on this

[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] [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 Type

[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&focusedCommentId=15848732#comment-15848732 ] Dawid Wysakowicz commented on FLINK-5603: - I think this is a duplicate of [FLINK-5

[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 QueryableStateC

[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&focusedCommentId=15848733#comment-15848733 ] Dawid Wysakowicz commented on FLINK-5510: - Hi I would be glad to work on that. >

[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&focusedCommentId=15848778#comment-15848778 ] Dawid Wysakowicz commented on FLINK-5510: - Just had a look into the code and been

[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 KvStateLocationLookupS

[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&focusedCommentId=15851287#comment-15851287 ] Dawid Wysakowicz commented on FLINK-5607: - I will be eager to work on this issue.

[jira] [Resolved] (FLINK-7563) Fix watermark semantics in CEP operators

2017-09-17 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7563?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz resolved FLINK-7563. - Resolution: Fixed > Fix watermark semantics in CEP operators > ---

[jira] [Commented] (FLINK-7563) Fix watermark semantics in CEP operators

2017-09-17 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7563?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16169341#comment-16169341 ] Dawid Wysakowicz commented on FLINK-7563: - Fixed for 1.3.3 with b63955ed90d12afd32

[jira] [Updated] (FLINK-10436) Example config uses deprecated key jobmanager.rpc.address

2018-10-09 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10436?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-10436: - Issue Type: Sub-task (was: Bug) Parent: FLINK-10392 > Example config uses depre

[jira] [Assigned] (FLINK-10310) Cassandra Sink - Handling failing requests

2018-10-09 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10310?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz reassigned FLINK-10310: Assignee: Dawid Wysakowicz > Cassandra Sink - Handling failing requests > ---

[jira] [Assigned] (FLINK-10310) Cassandra Sink - Handling failing requests

2018-10-09 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10310?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz reassigned FLINK-10310: Assignee: (was: Dawid Wysakowicz) > Cassandra Sink - Handling failing request

[jira] [Resolved] (FLINK-10310) Cassandra Sink - Handling failing requests

2018-10-09 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10310?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz resolved FLINK-10310. -- Resolution: Fixed Fix Version/s: 1.7.0 > Cassandra Sink - Handling failing requ

[jira] [Resolved] (FLINK-10227) Remove usage of javax.xml.bind.DatatypeConverter

2018-10-09 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10227?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz resolved FLINK-10227. -- Resolution: Fixed > Remove usage of javax.xml.bind.DatatypeConverter > ---

[jira] [Reopened] (FLINK-10354) Savepoints should be counted as retained checkpoints

2018-10-17 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10354?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz reopened FLINK-10354: -- > Savepoints should be counted as retained checkpoints > -

[jira] [Closed] (FLINK-10354) Savepoints should be counted as retained checkpoints

2018-10-17 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10354?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-10354. Resolution: Fixed Release Note: Savepoints are now used while recovering. Previously

[jira] [Updated] (FLINK-8159) Pattern(Flat)SelectFunctions should support RichFunction interface

2018-10-18 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8159?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-8159: Summary: Pattern(Flat)SelectFunctions should support RichFunction interface (was: Add rich

[jira] [Updated] (FLINK-7601) Add support for CLASSIFIER() function in MatchRecognize

2018-10-18 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7601?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-7601: Summary: Add support for CLASSIFIER() function in MatchRecognize (was: Support classifier

[jira] [Closed] (FLINK-7591) Support partition by and order by of MATCH_RECOGNIZE

2018-10-18 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7591?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-7591. --- Resolution: Duplicate > Support partition by and order by of MATCH_RECOGNIZE > --

[jira] [Updated] (FLINK-7603) Support time constraint in MatchRecognize

2018-10-18 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7603?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-7603: Summary: Support time constraint in MatchRecognize (was: Support within clause in MatchRec

[jira] [Updated] (FLINK-7479) Support physical offset in MATCH_RECOGNIZE (PREV)

2018-10-18 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7479?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-7479: Summary: Support physical offset in MATCH_RECOGNIZE (PREV) (was: Support to retrieve the

[jira] [Updated] (FLINK-7603) Support time constraint in MatchRecognize

2018-10-18 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7603?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-7603: Description: It is a common use case to search for patterns within some time limit. This a

[jira] [Created] (FLINK-10587) Improve support of greedy/reluctant quantifiers

2018-10-18 Thread Dawid Wysakowicz (JIRA)
Dawid Wysakowicz created FLINK-10587: Summary: Improve support of greedy/reluctant quantifiers Key: FLINK-10587 URL: https://issues.apache.org/jira/browse/FLINK-10587 Project: Flink Issue

[jira] [Created] (FLINK-10588) Support reusing same variable in Pattern

2018-10-18 Thread Dawid Wysakowicz (JIRA)
Dawid Wysakowicz created FLINK-10588: Summary: Support reusing same variable in Pattern Key: FLINK-10588 URL: https://issues.apache.org/jira/browse/FLINK-10588 Project: Flink Issue Type:

[jira] [Updated] (FLINK-4641) Support alterations CEP patterns

2018-10-18 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4641?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-4641: Summary: Support alterations CEP patterns (was: Support branching CEP patterns ) > Suppo

[jira] [Updated] (FLINK-4641) Support alterations in patterns

2018-10-18 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4641?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-4641: Summary: Support alterations in patterns (was: Support alterations CEP patterns ) > Supp

[jira] [Created] (FLINK-10589) Group patterns should support greedy quantifiers

2018-10-18 Thread Dawid Wysakowicz (JIRA)
Dawid Wysakowicz created FLINK-10589: Summary: Group patterns should support greedy quantifiers Key: FLINK-10589 URL: https://issues.apache.org/jira/browse/FLINK-10589 Project: Flink Issu

[jira] [Created] (FLINK-10590) Optional quantifier is discarded from first element of group pattern

2018-10-18 Thread Dawid Wysakowicz (JIRA)
Dawid Wysakowicz created FLINK-10590: Summary: Optional quantifier is discarded from first element of group pattern Key: FLINK-10590 URL: https://issues.apache.org/jira/browse/FLINK-10590 Project:

[jira] [Created] (FLINK-10591) Add functions to return TimeIndicators from MATCH_RECOGNIZE

2018-10-18 Thread Dawid Wysakowicz (JIRA)
Dawid Wysakowicz created FLINK-10591: Summary: Add functions to return TimeIndicators from MATCH_RECOGNIZE Key: FLINK-10591 URL: https://issues.apache.org/jira/browse/FLINK-10591 Project: Flink

[jira] [Created] (FLINK-10592) Support exclusions in patterns

2018-10-18 Thread Dawid Wysakowicz (JIRA)
Dawid Wysakowicz created FLINK-10592: Summary: Support exclusions in patterns Key: FLINK-10592 URL: https://issues.apache.org/jira/browse/FLINK-10592 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-10593) Add support for ALL ROWS PER MATCH

2018-10-18 Thread Dawid Wysakowicz (JIRA)
Dawid Wysakowicz created FLINK-10593: Summary: Add support for ALL ROWS PER MATCH Key: FLINK-10593 URL: https://issues.apache.org/jira/browse/FLINK-10593 Project: Flink Issue Type: Sub-ta

[jira] [Updated] (FLINK-10587) Improve support for greedy/reluctant quantifiers

2018-10-18 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10587?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-10587: - Summary: Improve support for greedy/reluctant quantifiers (was: Improve support of gree

[jira] [Updated] (FLINK-10592) Support exclusions in patterns

2018-10-18 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10592?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-10592: - Description: We should support exclusions like {{(A {- B -} C)}} which means that rows w

[jira] [Updated] (FLINK-10587) Improve support for greedy/reluctant quantifiers

2018-10-18 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10587?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-10587: - Description: Right now there are limitations where greedy/reluctant quantifier can be a

[jira] [Created] (FLINK-10594) Support SUBSETS

2018-10-18 Thread Dawid Wysakowicz (JIRA)
Dawid Wysakowicz created FLINK-10594: Summary: Support SUBSETS Key: FLINK-10594 URL: https://issues.apache.org/jira/browse/FLINK-10594 Project: Flink Issue Type: Sub-task Compon

[jira] [Created] (FLINK-10595) Support patterns that can produce empty matches

2018-10-18 Thread Dawid Wysakowicz (JIRA)
Dawid Wysakowicz created FLINK-10595: Summary: Support patterns that can produce empty matches Key: FLINK-10595 URL: https://issues.apache.org/jira/browse/FLINK-10595 Project: Flink Issue

[jira] [Created] (FLINK-10596) Add access to timerService in IterativeCondition and Pattern(Flat)SelectFunction

2018-10-18 Thread Dawid Wysakowicz (JIRA)
Dawid Wysakowicz created FLINK-10596: Summary: Add access to timerService in IterativeCondition and Pattern(Flat)SelectFunction Key: FLINK-10596 URL: https://issues.apache.org/jira/browse/FLINK-10596

[jira] [Created] (FLINK-10597) Enable UDFs support in MATCH_RECOGNIZE

2018-10-18 Thread Dawid Wysakowicz (JIRA)
Dawid Wysakowicz created FLINK-10597: Summary: Enable UDFs support in MATCH_RECOGNIZE Key: FLINK-10597 URL: https://issues.apache.org/jira/browse/FLINK-10597 Project: Flink Issue Type: Su

[jira] [Updated] (FLINK-10593) Add support for ALL ROWS PER MATCH

2018-10-18 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10593?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-10593: - Description: We should properly support it in both {{FINAL}} and {{RUNNING}} modes > Ad

[jira] [Updated] (FLINK-8159) Pattern(Flat)SelectFunctions should support RichFunction interface

2018-10-19 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8159?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-8159: Description: {{SelectWrapper}} and {{FlatSelectWrapper}} should extends {{AbstractRichFucn

[jira] [Updated] (FLINK-6938) IterativeCondition should support RichFunction interface

2018-10-19 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6938?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-6938: Description: In FLIP-20, we need IterativeCondition to support an {{open()}} method to com

[jira] [Assigned] (FLINK-10570) State grows unbounded when "within" constraint not applied

2018-10-22 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10570?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz reassigned FLINK-10570: Assignee: Dawid Wysakowicz > State grows unbounded when "within" constraint not a

[jira] [Commented] (FLINK-10570) State grows unbounded when "within" constraint not applied

2018-10-22 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10570?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16658902#comment-16658902 ] Dawid Wysakowicz commented on FLINK-10570: -- Hi [~Jamalarm], thank you for the r

[jira] [Commented] (FLINK-8159) Pattern(Flat)SelectFunctions should support RichFunction interface

2018-10-24 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16661863#comment-16661863 ] Dawid Wysakowicz commented on FLINK-8159: - Hi [~dian.fu], I would like to see a b

[jira] [Commented] (FLINK-10596) Add access to timerService in IterativeCondition and Pattern(Flat)SelectFunction

2018-10-24 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10596?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16661870#comment-16661870 ] Dawid Wysakowicz commented on FLINK-10596: -- Actually the main reason that we wa

[jira] [Updated] (FLINK-10596) Add access to timerService in Pattern(Flat)SelectFunction

2018-10-24 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10596?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-10596: - Summary: Add access to timerService in Pattern(Flat)SelectFunction (was: Add access to

[jira] [Created] (FLINK-10669) Exceptions & errors are not properly checked in logs

2018-10-24 Thread Dawid Wysakowicz (JIRA)
Dawid Wysakowicz created FLINK-10669: Summary: Exceptions & errors are not properly checked in logs Key: FLINK-10669 URL: https://issues.apache.org/jira/browse/FLINK-10669 Project: Flink

[jira] [Updated] (FLINK-10669) Exceptions & errors are not properly checked in logs in e2e tests

2018-10-24 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10669?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-10669: - Summary: Exceptions & errors are not properly checked in logs in e2e tests (was: Except

[jira] [Resolved] (FLINK-10220) StreamSQL E2E test fails on travis

2018-10-24 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10220?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz resolved FLINK-10220. -- Resolution: Fixed > StreamSQL E2E test fails on travis > -

  1   2   3   4   5   6   7   8   9   10   >