[jira] [Commented] (FLINK-5243) Implement an example for BipartiteGraph

2019-05-16 Thread Ivan Mushketyk (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16841927#comment-16841927 ] Ivan Mushketyk commented on FLINK-5243: --- [~jasleenk22] I think a better person to ask this would be

[jira] [Comment Edited] (FLINK-5243) Implement an example for BipartiteGraph

2019-05-14 Thread Ivan Mushketyk (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16839117#comment-16839117 ] Ivan Mushketyk edited comment on FLINK-5243 at 5/14/19 9:08 AM: Sure

[jira] [Commented] (FLINK-5243) Implement an example for BipartiteGraph

2019-05-14 Thread Ivan Mushketyk (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16839117#comment-16839117 ] Ivan Mushketyk commented on FLINK-5243: --- Sure Jasleen. Go ahead. > Implement an example for

[jira] [Created] (FLINK-8315) Use AWSCredentialsProvider to get AWS credentials

2017-12-23 Thread Ivan Mushketyk (JIRA)
Ivan Mushketyk created FLINK-8315: - Summary: Use AWSCredentialsProvider to get AWS credentials Key: FLINK-8315 URL: https://issues.apache.org/jira/browse/FLINK-8315 Project: Flink Issue

[jira] [Created] (FLINK-8314) Add support for Kinesis Firehose

2017-12-23 Thread Ivan Mushketyk (JIRA)
Ivan Mushketyk created FLINK-8314: - Summary: Add support for Kinesis Firehose Key: FLINK-8314 URL: https://issues.apache.org/jira/browse/FLINK-8314 Project: Flink Issue Type: New Feature

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

2017-03-15 Thread Ivan Mushketyk (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15927063#comment-15927063 ] Ivan Mushketyk commented on FLINK-3414: --- Hi [~dawidwys] I don't have time to work on this task now,

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

2017-03-15 Thread Ivan Mushketyk (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3414?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ivan Mushketyk reassigned FLINK-3414: - Assignee: Dawid Wysakowicz (was: Ivan Mushketyk) > Add Scala API for CEP's pattern

[jira] (FLINK-5684) Add MacOS section to flink-runtime-web README

2017-01-29 Thread Ivan Mushketyk (JIRA)
Title: Message Title Ivan Mushketyk created an issue

[jira] [Assigned] (FLINK-5612) GlobPathFilter not-serializable exception

2017-01-23 Thread Ivan Mushketyk (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5612?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ivan Mushketyk reassigned FLINK-5612: - Assignee: Ivan Mushketyk > GlobPathFilter not-serializable exception >

[jira] [Commented] (FLINK-5612) GlobPathFilter not-serializable exception

2017-01-23 Thread Ivan Mushketyk (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5612?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15834483#comment-15834483 ] Ivan Mushketyk commented on FLINK-5612: --- I'll fix it. > GlobPathFilter not-serializable exception >

[jira] [Assigned] (FLINK-3871) Add Kafka TableSource with Avro serialization

2017-01-12 Thread Ivan Mushketyk (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3871?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ivan Mushketyk reassigned FLINK-3871: - Assignee: Ivan Mushketyk > Add Kafka TableSource with Avro serialization >

[jira] [Assigned] (FLINK-5281) Extend KafkaJsonTableSources to support nested data

2017-01-11 Thread Ivan Mushketyk (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5281?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ivan Mushketyk reassigned FLINK-5281: - Assignee: Ivan Mushketyk > Extend KafkaJsonTableSources to support nested data >

[jira] [Closed] (FLINK-5360) Fix arguments names in WindowedStream

2017-01-09 Thread Ivan Mushketyk (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5360?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ivan Mushketyk closed FLINK-5360. - Resolution: Fixed > Fix arguments names in WindowedStream > -

[jira] [Commented] (FLINK-5280) Extend TableSource to support nested data

2016-12-22 Thread Ivan Mushketyk (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15770498#comment-15770498 ] Ivan Mushketyk commented on FLINK-5280: --- Hi guys, I like your idea, Fabian, I'll start working on

[jira] [Commented] (FLINK-5280) Extend TableSource to support nested data

2016-12-22 Thread Ivan Mushketyk (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15769924#comment-15769924 ] Ivan Mushketyk commented on FLINK-5280: --- Hi [~fhueske] {quote} We could have default

[jira] [Commented] (FLINK-5280) Extend TableSource to support nested data

2016-12-22 Thread Ivan Mushketyk (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15769556#comment-15769556 ] Ivan Mushketyk commented on FLINK-5280: --- Hi [~fhueske] Thank you for the great and detailed

[jira] [Commented] (FLINK-5280) Extend TableSource to support nested data

2016-12-20 Thread Ivan Mushketyk (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15765160#comment-15765160 ] Ivan Mushketyk commented on FLINK-5280: --- Hi Fabian, Thank you for your reply. At first a question

[jira] [Assigned] (FLINK-5244) Implement methods for BipartiteGraph transformations

2016-12-20 Thread Ivan Mushketyk (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5244?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ivan Mushketyk reassigned FLINK-5244: - Assignee: Ivan Mushketyk > Implement methods for BipartiteGraph transformations >

[jira] [Created] (FLINK-5362) Implement methods to access BipartiteGraph properties

2016-12-18 Thread Ivan Mushketyk (JIRA)
Ivan Mushketyk created FLINK-5362: - Summary: Implement methods to access BipartiteGraph properties Key: FLINK-5362 URL: https://issues.apache.org/jira/browse/FLINK-5362 Project: Flink Issue

[jira] [Closed] (FLINK-3298) Streaming connector for ActiveMQ

2016-12-18 Thread Ivan Mushketyk (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3298?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ivan Mushketyk closed FLINK-3298. - Resolution: Fixed > Streaming connector for ActiveMQ > > >

[jira] [Commented] (FLINK-3298) Streaming connector for ActiveMQ

2016-12-18 Thread Ivan Mushketyk (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3298?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15758501#comment-15758501 ] Ivan Mushketyk commented on FLINK-3298: --- Bahir PR was accepted. Closing the issue. > Streaming

[jira] [Assigned] (FLINK-3427) Add watermark monitoring to JobManager web frontend

2016-12-18 Thread Ivan Mushketyk (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3427?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ivan Mushketyk reassigned FLINK-3427: - Assignee: (was: Ivan Mushketyk) > Add watermark monitoring to JobManager web

[jira] [Assigned] (FLINK-4029) Multi-field "sum" function just like "keyBy"

2016-12-18 Thread Ivan Mushketyk (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4029?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ivan Mushketyk reassigned FLINK-4029: - Assignee: (was: Ivan Mushketyk) > Multi-field "sum" function just like "keyBy" >

[jira] [Created] (FLINK-5360) Fix arguments names in WindowedStream

2016-12-16 Thread Ivan Mushketyk (JIRA)
Ivan Mushketyk created FLINK-5360: - Summary: Fix arguments names in WindowedStream Key: FLINK-5360 URL: https://issues.apache.org/jira/browse/FLINK-5360 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-5280) Extend TableSource to support nested data

2016-12-16 Thread Ivan Mushketyk (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15754948#comment-15754948 ] Ivan Mushketyk commented on FLINK-5280: --- Thank you for working on it. I'll start working on this

[jira] [Created] (FLINK-5349) Fix code sample for Twitter connector

2016-12-15 Thread Ivan Mushketyk (JIRA)
Ivan Mushketyk created FLINK-5349: - Summary: Fix code sample for Twitter connector Key: FLINK-5349 URL: https://issues.apache.org/jira/browse/FLINK-5349 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-5280) Extend TableSource to support nested data

2016-12-15 Thread Ivan Mushketyk (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15751685#comment-15751685 ] Ivan Mushketyk commented on FLINK-5280: --- Hi [~jark] Your suggestion makes sense to me. >> But

[jira] [Commented] (FLINK-5280) Extend TableSource to support nested data

2016-12-15 Thread Ivan Mushketyk (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15751212#comment-15751212 ] Ivan Mushketyk commented on FLINK-5280: --- Hi [~jark], thank you for your reply. I see that

[jira] [Commented] (FLINK-5280) Extend TableSource to support nested data

2016-12-14 Thread Ivan Mushketyk (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15747806#comment-15747806 ] Ivan Mushketyk commented on FLINK-5280: --- Hi Fabian, Jark, Thank you for all your comments and for

[jira] [Comment Edited] (FLINK-5245) Add support for BipartiteGraph mutations

2016-12-13 Thread Ivan Mushketyk (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15746163#comment-15746163 ] Ivan Mushketyk edited comment on FLINK-5245 at 12/13/16 8:23 PM: - I got it

[jira] [Commented] (FLINK-5245) Add support for BipartiteGraph mutations

2016-12-13 Thread Ivan Mushketyk (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15746163#comment-15746163 ] Ivan Mushketyk commented on FLINK-5245: --- I got it now, sorry for the misunderstanding. In any case,

[jira] [Commented] (FLINK-5245) Add support for BipartiteGraph mutations

2016-12-12 Thread Ivan Mushketyk (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15743127#comment-15743127 ] Ivan Mushketyk commented on FLINK-5245: --- Thank you for your answer, Greg. Do I understand you

[jira] [Commented] (FLINK-5245) Add support for BipartiteGraph mutations

2016-12-12 Thread Ivan Mushketyk (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15742773#comment-15742773 ] Ivan Mushketyk commented on FLINK-5245: --- Are these methods useful for Graph class? Here is a list

[jira] [Assigned] (FLINK-5245) Add support for BipartiteGraph mutations

2016-12-12 Thread Ivan Mushketyk (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5245?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ivan Mushketyk reassigned FLINK-5245: - Assignee: Ivan Mushketyk > Add support for BipartiteGraph mutations >

[jira] [Commented] (FLINK-5280) Extend TableSource to support nested data

2016-12-12 Thread Ivan Mushketyk (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15742507#comment-15742507 ] Ivan Mushketyk commented on FLINK-5280: --- Hi [~fhueske] , Thank you for your comments. It's a much

[jira] [Commented] (FLINK-5280) Extend TableSource to support nested data

2016-12-11 Thread Ivan Mushketyk (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15740517#comment-15740517 ] Ivan Mushketyk commented on FLINK-5280: --- Thank you [~fhueske]. The general idea seems feasible, but

[jira] [Commented] (FLINK-1536) Graph partitioning operators for Gelly

2016-12-10 Thread Ivan Mushketyk (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1536?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15738237#comment-15738237 ] Ivan Mushketyk commented on FLINK-1536: --- Thank you for the explanation. That's what I though, but

[jira] [Created] (FLINK-5311) Write user documentation for BipartiteGraph

2016-12-09 Thread Ivan Mushketyk (JIRA)
Ivan Mushketyk created FLINK-5311: - Summary: Write user documentation for BipartiteGraph Key: FLINK-5311 URL: https://issues.apache.org/jira/browse/FLINK-5311 Project: Flink Issue Type: Bug

[jira] [Assigned] (FLINK-5280) Extend TableSource to support nested data

2016-12-08 Thread Ivan Mushketyk (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5280?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ivan Mushketyk reassigned FLINK-5280: - Assignee: Ivan Mushketyk > Extend TableSource to support nested data >

[jira] [Comment Edited] (FLINK-1536) Graph partitioning operators for Gelly

2016-12-08 Thread Ivan Mushketyk (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1536?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15732898#comment-15732898 ] Ivan Mushketyk edited comment on FLINK-1536 at 12/8/16 6:02 PM: Do I

[jira] [Comment Edited] (FLINK-1536) Graph partitioning operators for Gelly

2016-12-08 Thread Ivan Mushketyk (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1536?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15732898#comment-15732898 ] Ivan Mushketyk edited comment on FLINK-1536 at 12/8/16 6:01 PM: Do I

[jira] [Commented] (FLINK-1536) Graph partitioning operators for Gelly

2016-12-08 Thread Ivan Mushketyk (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1536?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15732898#comment-15732898 ] Ivan Mushketyk commented on FLINK-1536: --- Do I understand correctly that as the result of this issue

[jira] [Commented] (FLINK-5280) Extend TableSource to support nested data

2016-12-08 Thread Ivan Mushketyk (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15732870#comment-15732870 ] Ivan Mushketyk commented on FLINK-5280: --- If this is not urgent and nobody has started working on

[jira] [Created] (FLINK-5245) Add support for BipartiteGraph mutations

2016-12-03 Thread Ivan Mushketyk (JIRA)
Ivan Mushketyk created FLINK-5245: - Summary: Add support for BipartiteGraph mutations Key: FLINK-5245 URL: https://issues.apache.org/jira/browse/FLINK-5245 Project: Flink Issue Type:

[jira] [Created] (FLINK-5244) Implement methods for BipartiteGraph transformations

2016-12-03 Thread Ivan Mushketyk (JIRA)
Ivan Mushketyk created FLINK-5244: - Summary: Implement methods for BipartiteGraph transformations Key: FLINK-5244 URL: https://issues.apache.org/jira/browse/FLINK-5244 Project: Flink Issue

[jira] [Created] (FLINK-5243) Implement an example for BipartiteGraph

2016-12-03 Thread Ivan Mushketyk (JIRA)
Ivan Mushketyk created FLINK-5243: - Summary: Implement an example for BipartiteGraph Key: FLINK-5243 URL: https://issues.apache.org/jira/browse/FLINK-5243 Project: Flink Issue Type: New

[jira] [Created] (FLINK-5242) Implement Scala API for BipartiteGraph

2016-12-03 Thread Ivan Mushketyk (JIRA)
Ivan Mushketyk created FLINK-5242: - Summary: Implement Scala API for BipartiteGraph Key: FLINK-5242 URL: https://issues.apache.org/jira/browse/FLINK-5242 Project: Flink Issue Type: New

[jira] [Assigned] (FLINK-1536) Graph partitioning operators for Gelly

2016-11-24 Thread Ivan Mushketyk (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1536?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ivan Mushketyk reassigned FLINK-1536: - Assignee: Ivan Mushketyk > Graph partitioning operators for Gelly >

[jira] [Commented] (FLINK-4649) Implement bipartite graph metrics

2016-11-24 Thread Ivan Mushketyk (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4649?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15694318#comment-15694318 ] Ivan Mushketyk commented on FLINK-4649: --- Implemented here:

[jira] [Commented] (FLINK-2254) Add Bipartite Graph Support for Gelly

2016-11-24 Thread Ivan Mushketyk (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15693565#comment-15693565 ] Ivan Mushketyk commented on FLINK-2254: --- Hi [~vkalavri] Thank you for your advice I've implemented

[jira] [Comment Edited] (FLINK-2254) Add Bipartite Graph Support for Gelly

2016-11-24 Thread Ivan Mushketyk (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15693565#comment-15693565 ] Ivan Mushketyk edited comment on FLINK-2254 at 11/24/16 3:40 PM: - Hi

[jira] [Comment Edited] (FLINK-1536) Graph partitioning operators for Gelly

2016-11-23 Thread Ivan Mushketyk (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1536?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15691610#comment-15691610 ] Ivan Mushketyk edited comment on FLINK-1536 at 11/23/16 11:11 PM: -- Oh,

[jira] [Commented] (FLINK-1536) Graph partitioning operators for Gelly

2016-11-23 Thread Ivan Mushketyk (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1536?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15691610#comment-15691610 ] Ivan Mushketyk commented on FLINK-1536: --- Oh, sorry, I didn't mean to type "bipartiate" word there :)

[jira] [Commented] (FLINK-1536) Graph partitioning operators for Gelly

2016-11-21 Thread Ivan Mushketyk (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1536?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15683429#comment-15683429 ] Ivan Mushketyk commented on FLINK-1536: --- Good I'll give it a try after I am done with Bipartite

[jira] [Commented] (FLINK-1536) Graph partitioning operators for Gelly

2016-11-20 Thread Ivan Mushketyk (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1536?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15681133#comment-15681133 ] Ivan Mushketyk commented on FLINK-1536: --- Hi [~vkalavri] What is the status of this task? Is anybody

[jira] [Commented] (FLINK-3110) Add support for partition-centric iterations

2016-11-20 Thread Ivan Mushketyk (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3110?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15681110#comment-15681110 ] Ivan Mushketyk commented on FLINK-3110: --- Is anybody working on this? Is there anything that should

[jira] [Commented] (FLINK-2254) Add Bipartite Graph Support for Gelly

2016-11-20 Thread Ivan Mushketyk (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15681106#comment-15681106 ] Ivan Mushketyk commented on FLINK-2254: --- Regarding the metrics that we need for the bipartite graph.

[jira] [Commented] (FLINK-2254) Add Bipartite Graph Support for Gelly

2016-11-20 Thread Ivan Mushketyk (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15681101#comment-15681101 ] Ivan Mushketyk commented on FLINK-2254: --- [~vkalavri] [~greghogan] I've made some progress in this

[jira] [Commented] (FLINK-5104) Implement BipartiteGraph validator

2016-11-20 Thread Ivan Mushketyk (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5104?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15681090#comment-15681090 ] Ivan Mushketyk commented on FLINK-5104: --- Implemented here:

[jira] [Created] (FLINK-5104) Implement BipartiteGraph validator

2016-11-19 Thread Ivan Mushketyk (JIRA)
Ivan Mushketyk created FLINK-5104: - Summary: Implement BipartiteGraph validator Key: FLINK-5104 URL: https://issues.apache.org/jira/browse/FLINK-5104 Project: Flink Issue Type: Sub-task

[jira] [Assigned] (FLINK-4649) Implement bipartite graph metrics

2016-11-12 Thread Ivan Mushketyk (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4649?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ivan Mushketyk reassigned FLINK-4649: - Assignee: Ivan Mushketyk > Implement bipartite graph metrics >

[jira] [Commented] (FLINK-4647) Implement BipartiteGraph reader

2016-11-12 Thread Ivan Mushketyk (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4647?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15659963#comment-15659963 ] Ivan Mushketyk commented on FLINK-4647: --- Implemented here:

[jira] [Assigned] (FLINK-4647) Implement BipartiteGraph reader

2016-11-11 Thread Ivan Mushketyk (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4647?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ivan Mushketyk reassigned FLINK-4647: - Assignee: Ivan Mushketyk > Implement BipartiteGraph reader >

[jira] [Commented] (FLINK-4648) Implement bipartite graph generators

2016-11-11 Thread Ivan Mushketyk (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4648?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15656559#comment-15656559 ] Ivan Mushketyk commented on FLINK-4648: --- Implemented here:

[jira] [Assigned] (FLINK-4648) Implement bipartite graph generators

2016-11-09 Thread Ivan Mushketyk (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4648?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ivan Mushketyk reassigned FLINK-4648: - Assignee: Ivan Mushketyk > Implement bipartite graph generators >

[jira] [Assigned] (FLINK-4646) Add BipartiteGraph class

2016-09-27 Thread Ivan Mushketyk (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ivan Mushketyk reassigned FLINK-4646: - Assignee: Ivan Mushketyk > Add BipartiteGraph class > > >

[jira] [Commented] (FLINK-4641) Support branching CEP patterns

2016-09-22 Thread Ivan Mushketyk (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4641?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15512390#comment-15512390 ] Ivan Mushketyk commented on FLINK-4641: --- Hi [~kervel] I think the method chaining will allow nested

[jira] [Updated] (FLINK-4649) Implement bipartite graph metrics

2016-09-21 Thread Ivan Mushketyk (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4649?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ivan Mushketyk updated FLINK-4649: -- Description: Implement metrics calculation for a bipartite graph. Should be similar to

[jira] [Created] (FLINK-4649) Implement bipartite graph metrics

2016-09-21 Thread Ivan Mushketyk (JIRA)
Ivan Mushketyk created FLINK-4649: - Summary: Implement bipartite graph metrics Key: FLINK-4649 URL: https://issues.apache.org/jira/browse/FLINK-4649 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-4648) Implement bipartite graph generators

2016-09-21 Thread Ivan Mushketyk (JIRA)
Ivan Mushketyk created FLINK-4648: - Summary: Implement bipartite graph generators Key: FLINK-4648 URL: https://issues.apache.org/jira/browse/FLINK-4648 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-4647) Implement BipartiteGraph reader

2016-09-21 Thread Ivan Mushketyk (JIRA)
Ivan Mushketyk created FLINK-4647: - Summary: Implement BipartiteGraph reader Key: FLINK-4647 URL: https://issues.apache.org/jira/browse/FLINK-4647 Project: Flink Issue Type: Sub-task

[jira] [Updated] (FLINK-4646) Add BipartiteGraph class

2016-09-21 Thread Ivan Mushketyk (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ivan Mushketyk updated FLINK-4646: -- Description: Implement a class to represent a bipartite graph in Flink Gelly. Design

[jira] [Created] (FLINK-4646) Add BipartiteGraph class

2016-09-21 Thread Ivan Mushketyk (JIRA)
Ivan Mushketyk created FLINK-4646: - Summary: Add BipartiteGraph class Key: FLINK-4646 URL: https://issues.apache.org/jira/browse/FLINK-4646 Project: Flink Issue Type: Sub-task

[jira] [Commented] (FLINK-4641) Support branching CEP patterns

2016-09-21 Thread Ivan Mushketyk (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4641?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15508942#comment-15508942 ] Ivan Mushketyk commented on FLINK-4641: --- What API should we define for this feature? Should it be

[jira] [Commented] (FLINK-2254) Add Bipartite Graph Support for Gelly

2016-09-12 Thread Ivan Mushketyk (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15483350#comment-15483350 ] Ivan Mushketyk commented on FLINK-2254: --- Hi Vasia, Thank you for reviewing the design doc. I do

[jira] [Commented] (FLINK-4410) Split checkpoint times into synchronous and asynchronous part

2016-09-06 Thread Ivan Mushketyk (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4410?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15468721#comment-15468721 ] Ivan Mushketyk commented on FLINK-4410: --- Hi [~uce]. Just to make sure that I understand correctly

[jira] [Commented] (FLINK-3709) [streaming] Graph event rates over time

2016-09-06 Thread Ivan Mushketyk (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3709?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15468557#comment-15468557 ] Ivan Mushketyk commented on FLINK-3709: --- [~rmetzger] I could work on it, but I wonder where would be

[jira] [Commented] (FLINK-3427) Add watermark monitoring to JobManager web frontend

2016-09-06 Thread Ivan Mushketyk (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15468538#comment-15468538 ] Ivan Mushketyk commented on FLINK-3427: --- [~rmetzger], I not half-way through the task yet, so it's

[jira] [Commented] (FLINK-2254) Add Bipartite Graph Support for Gelly

2016-09-06 Thread Ivan Mushketyk (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15468506#comment-15468506 ] Ivan Mushketyk commented on FLINK-2254: --- Hi Greg. Thank you for your comment. Could you please

[jira] [Commented] (FLINK-3427) Add watermark monitoring to JobManager web frontend

2016-09-06 Thread Ivan Mushketyk (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15467767#comment-15467767 ] Ivan Mushketyk commented on FLINK-3427: --- [~rmetzger] If this will help in the discussing was

[jira] [Commented] (FLINK-3427) Add watermark monitoring to JobManager web frontend

2016-09-06 Thread Ivan Mushketyk (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15467660#comment-15467660 ] Ivan Mushketyk commented on FLINK-3427: --- Hey [~rmetzger], my idea was to record a timestamp of the

[jira] [Commented] (FLINK-2254) Add Bipartite Graph Support for Gelly

2016-09-04 Thread Ivan Mushketyk (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15463394#comment-15463394 ] Ivan Mushketyk commented on FLINK-2254: --- Hi [~vkalavri], I've written a short design doc

[jira] [Commented] (FLINK-3624) Use camelCase naming of JSON attributes generated by the REST API instead of dash

2016-09-02 Thread Ivan Mushketyk (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15459639#comment-15459639 ] Ivan Mushketyk commented on FLINK-3624: --- [~aljoscha] I think another option could be to have to sets

[jira] [Assigned] (FLINK-3427) Add watermark monitoring to JobManager web frontend

2016-09-02 Thread Ivan Mushketyk (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3427?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ivan Mushketyk reassigned FLINK-3427: - Assignee: Ivan Mushketyk > Add watermark monitoring to JobManager web frontend >

[jira] [Commented] (FLINK-3427) Add watermark monitoring to JobManager web frontend

2016-09-02 Thread Ivan Mushketyk (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15459635#comment-15459635 ] Ivan Mushketyk commented on FLINK-3427: --- I'll work on this if no one minds. > Add watermark

[jira] [Assigned] (FLINK-3719) WebInterface: Moving the barrier between graph and stats

2016-09-01 Thread Ivan Mushketyk (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3719?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ivan Mushketyk reassigned FLINK-3719: - Assignee: Ivan Mushketyk > WebInterface: Moving the barrier between graph and stats >

[jira] [Commented] (FLINK-3719) WebInterface: Moving the barrier between graph and stats

2016-09-01 Thread Ivan Mushketyk (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3719?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15456480#comment-15456480 ] Ivan Mushketyk commented on FLINK-3719: --- I'll implement this. > WebInterface: Moving the barrier

[jira] [Assigned] (FLINK-3680) Remove or improve (not set) text in the Job Plan UI

2016-08-31 Thread Ivan Mushketyk (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3680?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ivan Mushketyk reassigned FLINK-3680: - Assignee: Ivan Mushketyk > Remove or improve (not set) text in the Job Plan UI >

[jira] [Commented] (FLINK-3680) Remove or improve (not set) text in the Job Plan UI

2016-08-31 Thread Ivan Mushketyk (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3680?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15453387#comment-15453387 ] Ivan Mushketyk commented on FLINK-3680: --- I'll work on this. > Remove or improve (not set) text in

[jira] [Commented] (FLINK-4527) Drop the "flinkAccumulators" from the Execution

2016-08-29 Thread Ivan Mushketyk (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4527?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15446061#comment-15446061 ] Ivan Mushketyk commented on FLINK-4527: --- Hi [~StephanEwen], Does this mean that accumulators are

[jira] [Commented] (FLINK-2254) Add Bipartite Graph Support for Gelly

2016-08-29 Thread Ivan Mushketyk (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15444965#comment-15444965 ] Ivan Mushketyk commented on FLINK-2254: --- Hi [~vkalavri], Thank you for a detailed reply. This makes

[jira] [Created] (FLINK-4521) Fix "Submit new Job" panel in development mode

2016-08-28 Thread Ivan Mushketyk (JIRA)
Ivan Mushketyk created FLINK-4521: - Summary: Fix "Submit new Job" panel in development mode Key: FLINK-4521 URL: https://issues.apache.org/jira/browse/FLINK-4521 Project: Flink Issue Type:

[jira] [Commented] (FLINK-2254) Add Bipartite Graph Support for Gelly

2016-08-27 Thread Ivan Mushketyk (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15441673#comment-15441673 ] Ivan Mushketyk commented on FLINK-2254: --- [~vkalavri] I went through the paper listed in this issue,

[jira] [Closed] (FLINK-4440) Make API for edge/vertex creation less verbose

2016-08-26 Thread Ivan Mushketyk (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4440?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ivan Mushketyk closed FLINK-4440. - Resolution: Not A Problem > Make API for edge/vertex creation less verbose >

[jira] [Commented] (FLINK-4440) Make API for edge/vertex creation less verbose

2016-08-26 Thread Ivan Mushketyk (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4440?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15439188#comment-15439188 ] Ivan Mushketyk commented on FLINK-4440: --- It's ok with me. I'll close the JIRA issue and the PR. >

[jira] [Commented] (FLINK-3677) FileInputFormat: Allow to specify include/exclude file name patterns

2016-08-26 Thread Ivan Mushketyk (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3677?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15438716#comment-15438716 ] Ivan Mushketyk commented on FLINK-3677: --- Stephan, Aljoscha Thank you for pointing this out. I'll

[jira] [Commented] (FLINK-4440) Make API for edge/vertex creation less verbose

2016-08-23 Thread Ivan Mushketyk (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4440?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15433851#comment-15433851 ] Ivan Mushketyk commented on FLINK-4440: --- I assume that it will be used for instantiating in test

[jira] [Commented] (FLINK-3030) Enhance Dashboard to show Execution Attempts

2016-08-23 Thread Ivan Mushketyk (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3030?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15433685#comment-15433685 ] Ivan Mushketyk commented on FLINK-3030: --- I will works on this. > Enhance Dashboard to show

[jira] [Assigned] (FLINK-3030) Enhance Dashboard to show Execution Attempts

2016-08-23 Thread Ivan Mushketyk (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3030?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ivan Mushketyk reassigned FLINK-3030: - Assignee: Ivan Mushketyk > Enhance Dashboard to show Execution Attempts >

[jira] [Commented] (FLINK-2944) Collect, expose and display operator-specific stats

2016-08-23 Thread Ivan Mushketyk (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2944?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15433683#comment-15433683 ] Ivan Mushketyk commented on FLINK-2944: --- Is this somehow related to this issue:

  1   2   >