[jira] [Resolved] (FLINK-4565) Support for SQL IN operator

[ https://issues.apache.org/jira/browse/FLINK-4565?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dmytro Shkvyra resolved FLINK-4565. --- Resolution: Resolved > Support for SQL IN operator > --- > >

[jira] [Assigned] (FLINK-4303) Add CEP examples

[ https://issues.apache.org/jira/browse/FLINK-4303?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dmytro Shkvyra reassigned FLINK-4303: - Assignee: (was: Dmytro Shkvyra) > Add CEP examples > > >

[jira] [Assigned] (FLINK-4303) Add CEP examples

[ https://issues.apache.org/jira/browse/FLINK-4303?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dmytro Shkvyra reassigned FLINK-4303: - Assignee: Dmytro Shkvyra (was: Alexander Chermenin) > Add CEP examples >

[jira] [Comment Edited] (FLINK-6613) OOM during reading big messages from Kafka

[ https://issues.apache.org/jira/browse/FLINK-6613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16015569#comment-16015569 ] Dmytro Shkvyra edited comment on FLINK-6613 at 5/18/17 11:08 AM: - Hi

[jira] [Commented] (FLINK-6613) OOM during reading big messages from Kafka

[ https://issues.apache.org/jira/browse/FLINK-6613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16015569#comment-16015569 ] Dmytro Shkvyra commented on FLINK-6613: --- Hi [~dernasherbrezon], first of all root cause of this

[jira] [Commented] (FLINK-6613) OOM during reading big messages from Kafka

[ https://issues.apache.org/jira/browse/FLINK-6613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16014357#comment-16014357 ] Dmytro Shkvyra commented on FLINK-6613: --- Hi [~dernasherbrezon], I have assumed that you say that you

[jira] [Commented] (FLINK-6613) OOM during reading big messages from Kafka

[ https://issues.apache.org/jira/browse/FLINK-6613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16014155#comment-16014155 ] Dmytro Shkvyra commented on FLINK-6613: --- [~dernasherbrezon] What JVM option and GC do you use? >

[jira] [Comment Edited] (FLINK-3451) NettyServer port is determined via NetUtils.getAvailablePort()

[ https://issues.apache.org/jira/browse/FLINK-3451?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16014134#comment-16014134 ] Dmytro Shkvyra edited comment on FLINK-3451 at 5/17/17 2:44 PM: [~uce]

[jira] [Comment Edited] (FLINK-3451) NettyServer port is determined via NetUtils.getAvailablePort()

[ https://issues.apache.org/jira/browse/FLINK-3451?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16014134#comment-16014134 ] Dmytro Shkvyra edited comment on FLINK-3451 at 5/17/17 2:43 PM: [~uce]

[jira] [Commented] (FLINK-3451) NettyServer port is determined via NetUtils.getAvailablePort()

[ https://issues.apache.org/jira/browse/FLINK-3451?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16014134#comment-16014134 ] Dmytro Shkvyra commented on FLINK-3451: --- [~uce] IMHO the problem is in

[jira] [Resolved] (FLINK-4565) Support for SQL IN operator

[ https://issues.apache.org/jira/browse/FLINK-4565?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dmytro Shkvyra resolved FLINK-4565. --- Resolution: Resolved > Support for SQL IN operator > --- > >

[jira] [Resolved] (FLINK-5256) Extend DataSetSingleRowJoin to support Left and Right joins

[ https://issues.apache.org/jira/browse/FLINK-5256?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dmytro Shkvyra resolved FLINK-5256. --- Resolution: Resolved > Extend DataSetSingleRowJoin to support Left and Right joins >

[jira] [Assigned] (FLINK-5476) Fail fast if trying to submit a job to a non-existing Flink cluster

[ https://issues.apache.org/jira/browse/FLINK-5476?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dmytro Shkvyra reassigned FLINK-5476: - Assignee: Dmytro Shkvyra > Fail fast if trying to submit a job to a non-existing Flink

[jira] [Resolved] (FLINK-5476) Fail fast if trying to submit a job to a non-existing Flink cluster

[ https://issues.apache.org/jira/browse/FLINK-5476?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dmytro Shkvyra resolved FLINK-5476. --- Resolution: Resolved > Fail fast if trying to submit a job to a non-existing Flink cluster >

[jira] [Assigned] (FLINK-5476) Fail fast if trying to submit a job to a non-existing Flink cluster

[ https://issues.apache.org/jira/browse/FLINK-5476?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dmytro Shkvyra reassigned FLINK-5476: - Assignee: Dmytro Shkvyra (was: Dmitrii Kniazev) > Fail fast if trying to submit a job

[jira] [Assigned] (FLINK-5786) Add support GetClusterStatus message for standalong flink cluster

[ https://issues.apache.org/jira/browse/FLINK-5786?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dmytro Shkvyra reassigned FLINK-5786: - Assignee: Dmytro Shkvyra (was: Dmitrii Kniazev) > Add support GetClusterStatus message

[jira] [Closed] (FLINK-6149) add additional flink logical relation nodes

[ https://issues.apache.org/jira/browse/FLINK-6149?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dmytro Shkvyra closed FLINK-6149. - Resolution: Fixed Ok [~ykt836], I will close it. Thanks for clarification. > add additional

[jira] [Reopened] (FLINK-6149) add additional flink logical relation nodes

[ https://issues.apache.org/jira/browse/FLINK-6149?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dmytro Shkvyra reopened FLINK-6149: --- This change make fail SQL statements with null parts: Like this: {code} val sqlQuery =

[jira] [Assigned] (FLINK-4604) Add support for standard deviation/variance

[ https://issues.apache.org/jira/browse/FLINK-4604?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dmytro Shkvyra reassigned FLINK-4604: - Assignee: Dmytro Shkvyra (was: Anton Mushin) > Add support for standard

[jira] [Created] (FLINK-6128) Optimize JVM options for improve test performance

Dmytro Shkvyra created FLINK-6128: - Summary: Optimize JVM options for improve test performance Key: FLINK-6128 URL: https://issues.apache.org/jira/browse/FLINK-6128 Project: Flink Issue

[jira] [Assigned] (FLINK-5256) Extend DataSetSingleRowJoin to support Left and Right joins

[ https://issues.apache.org/jira/browse/FLINK-5256?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dmytro Shkvyra reassigned FLINK-5256: - Assignee: Dmytro Shkvyra (was: Anton Mushin) > Extend DataSetSingleRowJoin to support