[jira] [Commented] (FLINK-2926) Add a Strongly Connected Components Library Method

[ https://issues.apache.org/jira/browse/FLINK-2926?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14983860#comment-14983860 ] Martin Liesenberg commented on FLINK-2926: -- Thanks for the pointers. :) > Add a

[jira] [Commented] (FLINK-2918) Add a method to be able to read SequenceFileInputFormat

[ https://issues.apache.org/jira/browse/FLINK-2918?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14983808#comment-14983808 ] ASF GitHub Bot commented on FLINK-2918: --- Github user smarthi commented on the pull r

[GitHub] flink pull request: [FLINK-2918] Add method to read a file of type...

Github user smarthi commented on the pull request: https://github.com/apache/flink/pull/1299#issuecomment-152691666 @chiwanpark Fixed it --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this f

[jira] [Closed] (FLINK-2948) Cannot compile example code in SVM quickstart guide

[ https://issues.apache.org/jira/browse/FLINK-2948?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chiwan Park closed FLINK-2948. -- Resolution: Not A Problem > Cannot compile example code in SVM quickstart guide > --

[jira] [Created] (FLINK-2950) Markdown presentation problem in SVM documentation

Chiwan Park created FLINK-2950: -- Summary: Markdown presentation problem in SVM documentation Key: FLINK-2950 URL: https://issues.apache.org/jira/browse/FLINK-2950 Project: Flink Issue Type: Bug

[jira] [Comment Edited] (FLINK-2948) Cannot compile example code in SVM quickstart guide

[ https://issues.apache.org/jira/browse/FLINK-2948?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14983803#comment-14983803 ] Chiwan Park edited comment on FLINK-2948 at 10/31/15 4:19 AM: --

[jira] [Commented] (FLINK-2948) Cannot compile example code in SVM quickstart guide

[ https://issues.apache.org/jira/browse/FLINK-2948?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14983803#comment-14983803 ] Chiwan Park commented on FLINK-2948: BTW, The documentation for master branch have a s

[jira] [Commented] (FLINK-2948) Cannot compile example code in SVM quickstart guide

[ https://issues.apache.org/jira/browse/FLINK-2948?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14983802#comment-14983802 ] Chiwan Park commented on FLINK-2948: Hi [~lequocdo], thanks for reporting the problem.

[jira] [Commented] (FLINK-2918) Add a method to be able to read SequenceFileInputFormat

[ https://issues.apache.org/jira/browse/FLINK-2918?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14983796#comment-14983796 ] ASF GitHub Bot commented on FLINK-2918: --- Github user chiwanpark commented on the pul

[GitHub] flink pull request: [FLINK-2918] Add method to read a file of type...

Github user chiwanpark commented on the pull request: https://github.com/apache/flink/pull/1299#issuecomment-152690793 LGTM except one minor cosmetic issue. :+1: --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your pro

[jira] [Commented] (FLINK-2918) Add a method to be able to read SequenceFileInputFormat

[ https://issues.apache.org/jira/browse/FLINK-2918?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14983795#comment-14983795 ] ASF GitHub Bot commented on FLINK-2918: --- Github user chiwanpark commented on a diff

[GitHub] flink pull request: [FLINK-2918] Add method to read a file of type...

Github user chiwanpark commented on a diff in the pull request: https://github.com/apache/flink/pull/1299#discussion_r43567824 --- Diff: flink-scala/src/main/scala/org/apache/flink/api/scala/hadoop/mapred/HadoopInputFormat.scala --- @@ -27,6 +27,10 @@ class HadoopInputFormat[K, V]

[jira] [Commented] (FLINK-2949) Add method 'writeSequencefile' to DataSet

[ https://issues.apache.org/jira/browse/FLINK-2949?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14983730#comment-14983730 ] ASF GitHub Bot commented on FLINK-2949: --- GitHub user smarthi opened a pull request:

[GitHub] flink pull request: FLINK-2949 [WIP]: Add method 'writeSequencefil...

GitHub user smarthi opened a pull request: https://github.com/apache/flink/pull/1311 FLINK-2949 [WIP]: Add method 'writeSequencefile' to DataSet You can merge this pull request into a Git repository by running: $ git pull https://github.com/smarthi/flink Flink-2949 Alternativ

[jira] [Created] (FLINK-2949) Add method 'writeSequencefile' to DataSet

Suneel Marthi created FLINK-2949: Summary: Add method 'writeSequencefile' to DataSet Key: FLINK-2949 URL: https://issues.apache.org/jira/browse/FLINK-2949 Project: Flink Issue Type: Improvem

[jira] [Resolved] (FLINK-2918) Add a method to be able to read SequenceFileInputFormat

[ https://issues.apache.org/jira/browse/FLINK-2918?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Suneel Marthi resolved FLINK-2918. -- Resolution: Fixed > Add a method to be able to read SequenceFileInputFormat > --

[GitHub] flink pull request: [FLINK-2918] Add method to read a file of type...

Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/1299#issuecomment-152670781 Thanks for the quick updates @smarthi! Looks good to merge, IMO. --- If your project is set up for it, you can reply to this email and have your reply appear on GitH

[jira] [Commented] (FLINK-2918) Add a method to be able to read SequenceFileInputFormat

[ https://issues.apache.org/jira/browse/FLINK-2918?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14983572#comment-14983572 ] ASF GitHub Bot commented on FLINK-2918: --- Github user fhueske commented on the pull r

[jira] [Commented] (FLINK-2918) Add a method to be able to read SequenceFileInputFormat

[ https://issues.apache.org/jira/browse/FLINK-2918?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14983550#comment-14983550 ] ASF GitHub Bot commented on FLINK-2918: --- Github user fhueske commented on a diff in

[GitHub] flink pull request: [FLINK-2918] Add method to read a file of type...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/1299#discussion_r43560498 --- Diff: docs/apis/programming_guide.md --- @@ -1923,6 +1943,12 @@ val values = env.fromElements("Foo", "bar", "foobar", "fubar") val numbers = env.gene

[jira] [Commented] (FLINK-2918) Add a method to be able to read SequenceFileInputFormat

[ https://issues.apache.org/jira/browse/FLINK-2918?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14983549#comment-14983549 ] ASF GitHub Bot commented on FLINK-2918: --- Github user fhueske commented on a diff in

[GitHub] flink pull request: [FLINK-2918] Add method to read a file of type...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/1299#discussion_r43560441 --- Diff: docs/apis/programming_guide.md --- @@ -1772,9 +1779,16 @@ DataSet> csvInput = env.readCsvFile("hdfs:///the/CSV/file // read a CSV file wi

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

[ https://issues.apache.org/jira/browse/FLINK-2946?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14983506#comment-14983506 ] Timo Walther commented on FLINK-2946: - I haven't seen that finally someone is working

[jira] [Commented] (FLINK-2918) Add a method to be able to read SequenceFileInputFormat

[ https://issues.apache.org/jira/browse/FLINK-2918?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14983468#comment-14983468 ] ASF GitHub Bot commented on FLINK-2918: --- Github user fhueske commented on the pull r

[GitHub] flink pull request: [FLINK-2918] Add method to read a file of type...

Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/1299#issuecomment-152662660 Thanks for the fast update :-) You only updated the Java part of the documentation. The Scala part follows the Java part around line 1858 in programming_guide.md. Can

[jira] [Commented] (FLINK-2918) Add a method to be able to read SequenceFileInputFormat

[ https://issues.apache.org/jira/browse/FLINK-2918?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14983453#comment-14983453 ] ASF GitHub Bot commented on FLINK-2918: --- Github user fhueske commented on a diff in

[GitHub] flink pull request: [FLINK-2918] Add method to read a file of type...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/1299#discussion_r43557922 --- Diff: docs/apis/programming_guide.md --- @@ -1726,6 +1726,13 @@ File-based: - `readFileOfPrimitives(path, delimiter, Class)` / `PrimitiveInpu

[GitHub] flink pull request: [FLINK-2918] Add method to read a file of type...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/1299#discussion_r43557898 --- Diff: docs/apis/programming_guide.md --- @@ -1726,6 +1726,13 @@ File-based: - `readFileOfPrimitives(path, delimiter, Class)` / `PrimitiveInpu

[jira] [Commented] (FLINK-2918) Add a method to be able to read SequenceFileInputFormat

[ https://issues.apache.org/jira/browse/FLINK-2918?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14983451#comment-14983451 ] ASF GitHub Bot commented on FLINK-2918: --- Github user fhueske commented on a diff in

[jira] [Commented] (FLINK-2918) Add a method to be able to read SequenceFileInputFormat

[ https://issues.apache.org/jira/browse/FLINK-2918?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14983450#comment-14983450 ] ASF GitHub Bot commented on FLINK-2918: --- Github user fhueske commented on a diff in

[GitHub] flink pull request: [FLINK-2918] Add method to read a file of type...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/1299#discussion_r43557845 --- Diff: flink-scala/src/main/scala/org/apache/flink/api/scala/ExecutionEnvironment.scala --- @@ -440,6 +438,19 @@ class ExecutionEnvironment(javaEnv: JavaE

[jira] [Commented] (FLINK-2918) Add a method to be able to read SequenceFileInputFormat

[ https://issues.apache.org/jira/browse/FLINK-2918?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14983448#comment-14983448 ] ASF GitHub Bot commented on FLINK-2918: --- Github user fhueske commented on a diff in

[GitHub] flink pull request: [FLINK-2918] Add method to read a file of type...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/1299#discussion_r43557662 --- Diff: flink-java/src/main/java/org/apache/flink/api/java/ExecutionEnvironment.java --- @@ -580,6 +580,14 @@ public CsvReader readCsvFile(String filePath)

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

[ https://issues.apache.org/jira/browse/FLINK-2946?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14983283#comment-14983283 ] Fabian Hueske commented on FLINK-2946: -- At the moment, {{sortPartition()}} with paral

[GitHub] flink pull request: [FLINK-2828] [table] Add interfaces for Table ...

Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/1237#discussion_r43542701 --- Diff: flink-staging/flink-table/src/main/scala/org/apache/flink/api/table/expressions/analysis/FieldBacktracker.scala --- @@ -0,0 +1,75 @@ +/* +

[jira] [Commented] (FLINK-2828) Add interfaces for Table API input formats

[ https://issues.apache.org/jira/browse/FLINK-2828?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14983128#comment-14983128 ] ASF GitHub Bot commented on FLINK-2828: --- Github user twalthr commented on a diff in

[jira] [Created] (FLINK-2948) Cannot compile example code in SVM quickstart guide

Do Le Quoc created FLINK-2948: - Summary: Cannot compile example code in SVM quickstart guide Key: FLINK-2948 URL: https://issues.apache.org/jira/browse/FLINK-2948 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-2828) Add interfaces for Table API input formats

[ https://issues.apache.org/jira/browse/FLINK-2828?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14983109#comment-14983109 ] ASF GitHub Bot commented on FLINK-2828: --- Github user twalthr commented on a diff in

[GitHub] flink pull request: [FLINK-2828] [table] Add interfaces for Table ...

Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/1237#discussion_r43541584 --- Diff: flink-staging/flink-table/src/main/scala/org/apache/flink/api/table/expressions/analysis/FieldBacktracker.scala --- @@ -0,0 +1,75 @@ +/* +

[jira] [Commented] (FLINK-2828) Add interfaces for Table API input formats

[ https://issues.apache.org/jira/browse/FLINK-2828?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14983100#comment-14983100 ] ASF GitHub Bot commented on FLINK-2828: --- Github user twalthr commented on a diff in

[GitHub] flink pull request: [FLINK-2828] [table] Add interfaces for Table ...

Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/1237#discussion_r43541130 --- Diff: flink-staging/flink-table/src/main/scala/org/apache/flink/api/java/table/JavaBatchTranslator.scala --- @@ -39,7 +40,7 @@ import org.apache.flink.ap

[jira] [Commented] (FLINK-2947) Coloured Scala Shell

[ https://issues.apache.org/jira/browse/FLINK-2947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14983065#comment-14983065 ] Chiwan Park commented on FLINK-2947: You can find the screenshot of this feature in fo

[jira] [Created] (FLINK-2947) Coloured Scala Shell

Chiwan Park created FLINK-2947: -- Summary: Coloured Scala Shell Key: FLINK-2947 URL: https://issues.apache.org/jira/browse/FLINK-2947 Project: Flink Issue Type: Improvement Components:

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

Timo Walther created FLINK-2946: --- Summary: Add orderBy() to Table API Key: FLINK-2946 URL: https://issues.apache.org/jira/browse/FLINK-2946 Project: Flink Issue Type: New Feature Comp

[GitHub] flink pull request: [FLINK-2692] Untangle CsvInputFormat

Github user zentol commented on the pull request: https://github.com/apache/flink/pull/1266#issuecomment-152592464 yes, the user facing API is unchanged; it's only a problem for those that uses the CsvInputFormat directly for a createInput() call or whatever. --- If your project is s

[jira] [Commented] (FLINK-2692) Untangle CsvInputFormat into PojoTypeCsvInputFormat and TupleTypeCsvInputFormat

[ https://issues.apache.org/jira/browse/FLINK-2692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14982910#comment-14982910 ] ASF GitHub Bot commented on FLINK-2692: --- Github user zentol commented on the pull re

[jira] [Commented] (FLINK-2692) Untangle CsvInputFormat into PojoTypeCsvInputFormat and TupleTypeCsvInputFormat

[ https://issues.apache.org/jira/browse/FLINK-2692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14982871#comment-14982871 ] ASF GitHub Bot commented on FLINK-2692: --- Github user aljoscha commented on the pull

[GitHub] flink pull request: [FLINK-2692] Untangle CsvInputFormat

Github user aljoscha commented on the pull request: https://github.com/apache/flink/pull/1266#issuecomment-152585852 Could, yes, but I'm fine with both, it is already cleaner than what we had before. The user facing API is not changed, right? So I think this is good to merge.

[jira] [Commented] (FLINK-2692) Untangle CsvInputFormat into PojoTypeCsvInputFormat and TupleTypeCsvInputFormat

[ https://issues.apache.org/jira/browse/FLINK-2692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14982859#comment-14982859 ] ASF GitHub Bot commented on FLINK-2692: --- Github user zentol commented on the pull re

[GitHub] flink pull request: [FLINK-2692] Untangle CsvInputFormat

Github user zentol commented on the pull request: https://github.com/apache/flink/pull/1266#issuecomment-152584371 We could move the differing lines (Csv:L114 Pojo:L218->L225) into separate methods that is called from a generic readRecord() method. something like fillRecord(OUT reuse,

[jira] [Commented] (FLINK-2935) Allow scala shell to read yarn properties

[ https://issues.apache.org/jira/browse/FLINK-2935?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14982770#comment-14982770 ] Chiwan Park commented on FLINK-2935: I'm working on this now. For this issue, I sugge

[jira] [Commented] (FLINK-2943) Confusing Bytes/Records "read" and "write" labels in WebUI job view

[ https://issues.apache.org/jira/browse/FLINK-2943?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14982735#comment-14982735 ] Maximilian Michels commented on FLINK-2943: --- +1 Good idea to make this informati

[jira] [Commented] (FLINK-2942) Dangling operators in web UI's program visualization (non-deterministic)

[ https://issues.apache.org/jira/browse/FLINK-2942?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14982730#comment-14982730 ] Maximilian Michels commented on FLINK-2942: --- Thanks for for reporting this with

[jira] [Commented] (FLINK-2935) Allow scala shell to read yarn properties

[ https://issues.apache.org/jira/browse/FLINK-2935?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14982728#comment-14982728 ] Maximilian Michels commented on FLINK-2935: --- +1 > Allow scala shell to read yar

[jira] [Commented] (FLINK-2692) Untangle CsvInputFormat into PojoTypeCsvInputFormat and TupleTypeCsvInputFormat

[ https://issues.apache.org/jira/browse/FLINK-2692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14982647#comment-14982647 ] ASF GitHub Bot commented on FLINK-2692: --- Github user aljoscha commented on the pull

[GitHub] flink pull request: [FLINK-2692] Untangle CsvInputFormat

Github user aljoscha commented on the pull request: https://github.com/apache/flink/pull/1266#issuecomment-152544715 Looks good to me. Is there maybe a way to also make `readRecord()` common to tuples and POJOs, because there we duplicate all the code and only the call that creates th

[jira] [Created] (FLINK-2945) Shutting down a local Flink instance on Windows doesn't clean up blob cache

Fabian Hueske created FLINK-2945: Summary: Shutting down a local Flink instance on Windows doesn't clean up blob cache Key: FLINK-2945 URL: https://issues.apache.org/jira/browse/FLINK-2945 Project: Fl

[jira] [Commented] (FLINK-2926) Add a Strongly Connected Components Library Method

[ https://issues.apache.org/jira/browse/FLINK-2926?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14982523#comment-14982523 ] Vasia Kalavri commented on FLINK-2926: -- Hi [~mliesenberg], what kind of iteration ar

[jira] [Commented] (FLINK-2797) CLI: Missing option to submit jobs in detached mode

[ https://issues.apache.org/jira/browse/FLINK-2797?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14982519#comment-14982519 ] ASF GitHub Bot commented on FLINK-2797: --- Github user mxm commented on a diff in the

[GitHub] flink pull request: [FLINK-2797][cli] Add support for running jobs...

Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/1214#discussion_r43498784 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment/StreamContextEnvironment.java --- @@ -75,29 +62,31 @@ public JobExecution

[jira] [Commented] (FLINK-2942) Dangling operators in web UI's program visualization (non-deterministic)

[ https://issues.apache.org/jira/browse/FLINK-2942?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14982508#comment-14982508 ] Fabian Hueske commented on FLINK-2942: -- The problem is also present when visualizing

[jira] [Commented] (FLINK-2926) Add a Strongly Connected Components Library Method

[ https://issues.apache.org/jira/browse/FLINK-2926?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14982493#comment-14982493 ] Martin Liesenberg commented on FLINK-2926: -- https://docs.google.com/document/d/10

[jira] [Commented] (FLINK-2910) Combine tests for binary graph operators

[ https://issues.apache.org/jira/browse/FLINK-2910?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14982293#comment-14982293 ] Vasia Kalavri commented on FLINK-2910: -- +1 We could actually make a larger effort to

[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=14982284#comment-14982284 ] Vasia Kalavri commented on FLINK-2254: -- Hi [~ssaumitra], the tests for the graph met

[jira] [Commented] (FLINK-2571) Add task hooks support in Storm-compatibility

[ https://issues.apache.org/jira/browse/FLINK-2571?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14982244#comment-14982244 ] Matthias J. Sax commented on FLINK-2571: Are you working on this? Or is anything b

[GitHub] flink pull request: [FLINK-2720][storm-compatibility]Add Storm-Cou...

Github user mjsax commented on the pull request: https://github.com/apache/flink/pull/1157#issuecomment-152474074 Hi. Are you still working on this? It's a couple of weeks since the last update. --- If your project is set up for it, you can reply to this email and have your reply app

[jira] [Commented] (FLINK-2720) Add Storm-CountMetric in flink-stormcompatibility

[ https://issues.apache.org/jira/browse/FLINK-2720?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14982242#comment-14982242 ] ASF GitHub Bot commented on FLINK-2720: --- Github user mjsax commented on the pull req

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

Fabian Hueske created FLINK-2944: Summary: Collect, expose and display operator-specific stats Key: FLINK-2944 URL: https://issues.apache.org/jira/browse/FLINK-2944 Project: Flink Issue Type: