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

[ https://issues.apache.org/jira/browse/FLINK-5243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16841927#comment-16841927 ] Ivan Mushketyk commented on FLINK-5243: --- [~jasleenk22] I think a better person to a

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

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

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

[ https://issues.apache.org/jira/browse/FLINK-5243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16839117#comment-16839117 ] Ivan Mushketyk commented on FLINK-5243: --- Sure Jasleen. Go ahead. > Implement an

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

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 Type:

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

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

[ https://issues.apache.org/jira/browse/FLINK-3414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15927063#comment-15927063 ] Ivan Mushketyk commented on FLINK-3414: --- Hi [~dawidwys] I don't have time to work o

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

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

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

Title: Message Title Ivan Mushketyk created an issue

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

[ 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

[ https://issues.apache.org/jira/browse/FLINK-5612?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15834483#comment-15834483 ] Ivan Mushketyk commented on FLINK-5612: --- I'll fix it. > GlobPathFilter not-serializ

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

[ 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

[ 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

[ 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

[ https://issues.apache.org/jira/browse/FLINK-5280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15770498#comment-15770498 ] Ivan Mushketyk commented on FLINK-5280: --- Hi guys, I like your idea, Fabian, I'll st

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

[ https://issues.apache.org/jira/browse/FLINK-5280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15769924#comment-15769924 ] Ivan Mushketyk commented on FLINK-5280: --- Hi [~fhueske] {quote} We could have defaul

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

[ https://issues.apache.org/jira/browse/FLINK-5280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15769556#comment-15769556 ] Ivan Mushketyk commented on FLINK-5280: --- Hi [~fhueske] Thank you for the great and

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

[ https://issues.apache.org/jira/browse/FLINK-5280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15765160#comment-15765160 ] Ivan Mushketyk commented on FLINK-5280: --- Hi Fabian, Thank you for your reply. At f

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

[ 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

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 T

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

[ 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

[ https://issues.apache.org/jira/browse/FLINK-3298?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15758501#comment-15758501 ] Ivan Mushketyk commented on FLINK-3298: --- Bahir PR was accepted. Closing the issue.

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

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

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

[ 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

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

[ https://issues.apache.org/jira/browse/FLINK-5280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15754948#comment-15754948 ] Ivan Mushketyk commented on FLINK-5280: --- Thank you for working on it. I'll start wor

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

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

[ https://issues.apache.org/jira/browse/FLINK-5280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15751685#comment-15751685 ] Ivan Mushketyk commented on FLINK-5280: --- Hi [~jark] Your suggestion makes sense to

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

[ https://issues.apache.org/jira/browse/FLINK-5280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15751212#comment-15751212 ] Ivan Mushketyk commented on FLINK-5280: --- Hi [~jark], thank you for your reply. I se

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

[ https://issues.apache.org/jira/browse/FLINK-5280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15747806#comment-15747806 ] Ivan Mushketyk commented on FLINK-5280: --- Hi Fabian, Jark, Thank you for all your co

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

[ https://issues.apache.org/jira/browse/FLINK-5245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15746163#comment-15746163 ] Ivan Mushketyk edited comment on FLINK-5245 at 12/13/16 8:23 PM: ---

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

[ https://issues.apache.org/jira/browse/FLINK-5245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15746163#comment-15746163 ] Ivan Mushketyk commented on FLINK-5245: --- I got it now, sorry for the misunderstandin

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

[ https://issues.apache.org/jira/browse/FLINK-5245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15743127#comment-15743127 ] Ivan Mushketyk commented on FLINK-5245: --- Thank you for your answer, Greg. Do I under

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

[ https://issues.apache.org/jira/browse/FLINK-5245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15742773#comment-15742773 ] Ivan Mushketyk commented on FLINK-5245: --- Are these methods useful for Graph class?

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

[ 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

[ https://issues.apache.org/jira/browse/FLINK-5280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15742507#comment-15742507 ] Ivan Mushketyk commented on FLINK-5280: --- Hi [~fhueske] , Thank you for your comment

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

[ https://issues.apache.org/jira/browse/FLINK-5280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15740517#comment-15740517 ] Ivan Mushketyk commented on FLINK-5280: --- Thank you [~fhueske]. The general idea see

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

[ https://issues.apache.org/jira/browse/FLINK-1536?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15738237#comment-15738237 ] Ivan Mushketyk commented on FLINK-1536: --- Thank you for the explanation. That's what

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

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

[ 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

[ https://issues.apache.org/jira/browse/FLINK-1536?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15732898#comment-15732898 ] Ivan Mushketyk edited comment on FLINK-1536 at 12/8/16 6:02 PM:

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

[ https://issues.apache.org/jira/browse/FLINK-1536?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15732898#comment-15732898 ] Ivan Mushketyk edited comment on FLINK-1536 at 12/8/16 6:01 PM:

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

[ https://issues.apache.org/jira/browse/FLINK-1536?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15732898#comment-15732898 ] Ivan Mushketyk commented on FLINK-1536: --- Do I understand correctly that as the resul

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

[ https://issues.apache.org/jira/browse/FLINK-5280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15732870#comment-15732870 ] Ivan Mushketyk commented on FLINK-5280: --- If this is not urgent and nobody has starte

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

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: Improvem

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

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 Ty

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

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 Featu

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

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 Featur

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

[ 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

[ https://issues.apache.org/jira/browse/FLINK-4649?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15694318#comment-15694318 ] Ivan Mushketyk commented on FLINK-4649: --- Implemented here: https://github.com/mushke

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

[ https://issues.apache.org/jira/browse/FLINK-2254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15693565#comment-15693565 ] Ivan Mushketyk commented on FLINK-2254: --- Hi [~vkalavri] Thank you for your advice I'

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

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

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

[ https://issues.apache.org/jira/browse/FLINK-1536?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15691610#comment-15691610 ] Ivan Mushketyk edited comment on FLINK-1536 at 11/23/16 11:11 PM: --

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

[ https://issues.apache.org/jira/browse/FLINK-1536?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15691610#comment-15691610 ] Ivan Mushketyk commented on FLINK-1536: --- Oh, sorry, I didn't mean to type "bipartiat

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

[ https://issues.apache.org/jira/browse/FLINK-1536?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15683429#comment-15683429 ] Ivan Mushketyk commented on FLINK-1536: --- Good I'll give it a try after I am done wi

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

[ https://issues.apache.org/jira/browse/FLINK-1536?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15681133#comment-15681133 ] Ivan Mushketyk commented on FLINK-1536: --- Hi [~vkalavri] What is the status of this

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

[ https://issues.apache.org/jira/browse/FLINK-3110?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15681110#comment-15681110 ] Ivan Mushketyk commented on FLINK-3110: --- Is anybody working on this? Is there anythi

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

[ https://issues.apache.org/jira/browse/FLINK-2254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15681106#comment-15681106 ] Ivan Mushketyk commented on FLINK-2254: --- Regarding the metrics that we need for the

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

[ https://issues.apache.org/jira/browse/FLINK-2254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15681101#comment-15681101 ] Ivan Mushketyk commented on FLINK-2254: --- [~vkalavri] [~greghogan] I've made some pro

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

[ https://issues.apache.org/jira/browse/FLINK-5104?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15681090#comment-15681090 ] Ivan Mushketyk commented on FLINK-5104: --- Implemented here: https://github.com/mushk

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

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

[ 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

[ https://issues.apache.org/jira/browse/FLINK-4647?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15659963#comment-15659963 ] Ivan Mushketyk commented on FLINK-4647: --- Implemented here: https://github.com/mushke

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

[ 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

[ https://issues.apache.org/jira/browse/FLINK-4648?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15656559#comment-15656559 ] Ivan Mushketyk commented on FLINK-4648: --- Implemented here: https://github.com/mushke

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

[ 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

[ 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

[ https://issues.apache.org/jira/browse/FLINK-4641?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15512390#comment-15512390 ] Ivan Mushketyk commented on FLINK-4641: --- Hi [~kervel] I think the method chaining w

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

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

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

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

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

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

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

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

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 Rep

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

[ https://issues.apache.org/jira/browse/FLINK-4641?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15508942#comment-15508942 ] Ivan Mushketyk commented on FLINK-4641: --- What API should we define for this feature?

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

[ https://issues.apache.org/jira/browse/FLINK-2254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15483350#comment-15483350 ] Ivan Mushketyk commented on FLINK-2254: --- Hi Vasia, Thank you for reviewing the desi

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

[ https://issues.apache.org/jira/browse/FLINK-4410?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15468721#comment-15468721 ] Ivan Mushketyk commented on FLINK-4410: --- Hi [~uce]. Just to make sure that I unders

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

[ https://issues.apache.org/jira/browse/FLINK-3709?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15468557#comment-15468557 ] Ivan Mushketyk commented on FLINK-3709: --- [~rmetzger] I could work on it, but I wonde

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

[ https://issues.apache.org/jira/browse/FLINK-3427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15468538#comment-15468538 ] Ivan Mushketyk commented on FLINK-3427: --- [~rmetzger], I not half-way through the tas

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

[ https://issues.apache.org/jira/browse/FLINK-2254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15468506#comment-15468506 ] Ivan Mushketyk commented on FLINK-2254: --- Hi Greg. Thank you for your comment. Could

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

[ https://issues.apache.org/jira/browse/FLINK-3427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15467767#comment-15467767 ] Ivan Mushketyk commented on FLINK-3427: --- [~rmetzger] If this will help in the discus

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

[ https://issues.apache.org/jira/browse/FLINK-3427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15467660#comment-15467660 ] Ivan Mushketyk commented on FLINK-3427: --- Hey [~rmetzger], my idea was to record a ti

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

[ https://issues.apache.org/jira/browse/FLINK-2254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15463394#comment-15463394 ] Ivan Mushketyk commented on FLINK-2254: --- Hi [~vkalavri], I've written a short desig

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

[ https://issues.apache.org/jira/browse/FLINK-3624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15459639#comment-15459639 ] Ivan Mushketyk commented on FLINK-3624: --- [~aljoscha] I think another option could be

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

[ 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

[ https://issues.apache.org/jira/browse/FLINK-3427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15459635#comment-15459635 ] Ivan Mushketyk commented on FLINK-3427: --- I'll work on this if no one minds. > Add w

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

[ 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

[ https://issues.apache.org/jira/browse/FLINK-3719?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15456480#comment-15456480 ] Ivan Mushketyk commented on FLINK-3719: --- I'll implement this. > WebInterface: Movin

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

[ 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

[ https://issues.apache.org/jira/browse/FLINK-3680?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15453387#comment-15453387 ] Ivan Mushketyk commented on FLINK-3680: --- I'll work on this. > Remove or improve (no

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

[ https://issues.apache.org/jira/browse/FLINK-4527?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15446061#comment-15446061 ] Ivan Mushketyk commented on FLINK-4527: --- Hi [~StephanEwen], Does this mean that acc

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

[ https://issues.apache.org/jira/browse/FLINK-2254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15444965#comment-15444965 ] Ivan Mushketyk commented on FLINK-2254: --- Hi [~vkalavri], Thank you for a detailed r

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

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: Bu

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

[ https://issues.apache.org/jira/browse/FLINK-2254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15441673#comment-15441673 ] Ivan Mushketyk commented on FLINK-2254: --- [~vkalavri] I went through the paper listed

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

[ 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

[ https://issues.apache.org/jira/browse/FLINK-4440?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15439188#comment-15439188 ] Ivan Mushketyk commented on FLINK-4440: --- It's ok with me. I'll close the JIRA issue

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

[ https://issues.apache.org/jira/browse/FLINK-3677?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15438716#comment-15438716 ] Ivan Mushketyk commented on FLINK-3677: --- Stephan, Aljoscha Thank you for pointing t

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

[ https://issues.apache.org/jira/browse/FLINK-4440?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15433851#comment-15433851 ] Ivan Mushketyk commented on FLINK-4440: --- I assume that it will be used for instantia

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

[ https://issues.apache.org/jira/browse/FLINK-3030?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15433685#comment-15433685 ] Ivan Mushketyk commented on FLINK-3030: --- I will works on this. > Enhance Dashboard

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

[ 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

[ https://issues.apache.org/jira/browse/FLINK-2944?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15433683#comment-15433683 ] Ivan Mushketyk commented on FLINK-2944: --- Is this somehow related to this issue: ht

  1   2   >