[jira] [Created] (FLINK-2884) Apply JMH on HashVsSortMiniBenchmark class.

GaoLun created FLINK-2884: - Summary: Apply JMH on HashVsSortMiniBenchmark class. Key: FLINK-2884 URL: https://issues.apache.org/jira/browse/FLINK-2884 Project: Flink Issue Type: Sub-task Co

[GitHub] flink pull request: [FLINK-2869] [tests] Apply JMH on IOManagerPer...

Github user gallenvara commented on the pull request: https://github.com/apache/flink/pull/1270#issuecomment-149765941 Part of the JMH benchmark result : 

[jira] [Commented] (FLINK-2869) Apply JMH on IOManagerPerformanceBenchmark class.

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

[jira] [Commented] (FLINK-1984) Integrate Flink with Apache Mesos

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

[GitHub] flink pull request: [FLINK-1984] Integrate Flink with Apache Mesos

Github user cfmcgrady commented on a diff in the pull request: https://github.com/apache/flink/pull/948#discussion_r42578446 --- Diff: flink-mesos/src/main/scala/org/apache/flink/mesos/scheduler/HttpServer.scala --- @@ -0,0 +1,82 @@ +/* + * Licensed to the Apache Software F

[jira] [Commented] (FLINK-2853) Apply JMH on MutableHashTablePerformanceBenchmark class.

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

[GitHub] flink pull request: [FLINK-2853] [tests] Apply JMH on MutableHashT...

Github user ChengXiangLi commented on the pull request: https://github.com/apache/flink/pull/1267#issuecomment-149763186 LGTM, +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 project does not have this feature

[jira] [Updated] (FLINK-2883) Combinable reduce produces wrong result

[ https://issues.apache.org/jira/browse/FLINK-2883?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-2883: - Description: If one uses a combinable reduce operation which also changes the key value of the un

[jira] [Created] (FLINK-2883) Combinable reduce produces wrong result

Till Rohrmann created FLINK-2883: Summary: Combinable reduce produces wrong result Key: FLINK-2883 URL: https://issues.apache.org/jira/browse/FLINK-2883 Project: Flink Issue Type: Bug Aff

[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=14965847#comment-14965847 ] Saumitra Shahapure commented on FLINK-2254: --- OK [~vkalavri], I will create a des

[jira] [Closed] (FLINK-2872) Update the documentation for Scala part to add readFileOfPrimitives

[ https://issues.apache.org/jira/browse/FLINK-2872?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Henry Saputra closed FLINK-2872. Resolution: Fixed Fix Version/s: 0.10 > Update the documentation for Scala part to add readFi

[GitHub] flink pull request: [FLINK-2872] [Documentation] Update the docume...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/1268 --- 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 feature enabled and wishes so, or if the feature is enab

[jira] [Commented] (FLINK-2872) Update the documentation for Scala part to add readFileOfPrimitives

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

[jira] [Commented] (FLINK-2685) TaskManager deadlock on NetworkBufferPool

[ https://issues.apache.org/jira/browse/FLINK-2685?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14965650#comment-14965650 ] Ufuk Celebi commented on FLINK-2685: Greg, any news on this one? Can you share the pro

[jira] [Commented] (FLINK-2882) Improve performance of string conversions

[ https://issues.apache.org/jira/browse/FLINK-2882?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14965649#comment-14965649 ] Ufuk Celebi commented on FLINK-2882: Regarding {{toShortString}}: This is exclusively

[jira] [Commented] (FLINK-2820) Configuration not passed to JobGraphGenerator

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

[GitHub] flink pull request: [FLINK-2820] Configuration not passed to JobGr...

GitHub user greghogan opened a pull request: https://github.com/apache/flink/pull/1278 [FLINK-2820] Configuration not passed to JobGraphGenerator This was previously reported as FLINK-2625 (commit 8a84937215ea575fa94a00d11c2517902d252756). The Client class was concurrently refac

[jira] [Created] (FLINK-2882) Improve performance of string conversions

Greg Hogan created FLINK-2882: - Summary: Improve performance of string conversions Key: FLINK-2882 URL: https://issues.apache.org/jira/browse/FLINK-2882 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-2877) Move Streaming API out of Staging

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

[GitHub] flink pull request: [FLINK-2877] Move Streaming API out of Staging...

Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/1273#issuecomment-149657090 +1 for `flink-streaming-java` and `flink-streaming-scala` --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well.

[GitHub] flink pull request: [FLINK-2876] Minutiae

GitHub user greghogan opened a pull request: https://github.com/apache/flink/pull/1277 [FLINK-2876] Minutiae A collection of small documentation and grammar updates. You can merge this pull request into a Git repository by running: $ git pull https://github.com/greghogan/flink

[jira] [Commented] (FLINK-2876) Minutiae

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

[jira] [Created] (FLINK-2881) WebRuntimeMonitor overly restrictive file patterns

Greg Hogan created FLINK-2881: - Summary: WebRuntimeMonitor overly restrictive file patterns Key: FLINK-2881 URL: https://issues.apache.org/jira/browse/FLINK-2881 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-2827) Potential resource leak in TwitterSource#loadAuthenticationProperties()

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

[GitHub] flink pull request: [FLINK-2827] Closing FileInputStream in finall...

Github user ssaumitra commented on a diff in the pull request: https://github.com/apache/flink/pull/1276#discussion_r42527314 --- Diff: flink-staging/flink-streaming/flink-streaming-connectors/flink-connector-twitter/src/main/java/org/apache/flink/streaming/connectors/twitter/TwitterSo

[GitHub] flink pull request: [FLINK-2827] Closing FileInputStream in finall...

GitHub user ssaumitra opened a pull request: https://github.com/apache/flink/pull/1276 [FLINK-2827] Closing FileInputStream in finally block to avoid unused open stream. You can merge this pull request into a Git repository by running: $ git pull https://github.com/ssaumitra

[jira] [Commented] (FLINK-2827) Potential resource leak in TwitterSource#loadAuthenticationProperties()

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

[jira] [Commented] (FLINK-2834) Global round-robin for temporary directories

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

[GitHub] flink pull request: [FLINK-2834] Global round-robin for temporary ...

Github user greghogan commented on a diff in the pull request: https://github.com/apache/flink/pull/1272#discussion_r42526400 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/io/disk/iomanager/FileIOChannel.java --- @@ -154,20 +155,25 @@ private static String randomS

[jira] [Commented] (FLINK-2862) FlinkTopologyBuilder should use proper generic types

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

[GitHub] flink pull request: [FLINK-2862] [Storm Compatibility] FlinkTopolo...

Github user mjsax commented on the pull request: https://github.com/apache/flink/pull/1274#issuecomment-149639349 @StephanEwen Please give short review. Should be good to get merged. Will address https://issues.apache.org/jira/browse/FLINK-2861 after this is merged. --- If your proje

[jira] [Commented] (FLINK-2880) Allow DeserializationSchema to throw IOException in deserialization method

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

[GitHub] flink pull request: [FLINK-2880] [streaming] [API-Breaking] Allow ...

GitHub user StephanEwen opened a pull request: https://github.com/apache/flink/pull/1275 [FLINK-2880] [streaming] [API-Breaking] Allow DeserializationSchema to forward exceptions The DeserializationSchema is now allowed to forward exceptions on deserialization. This is useful b

[GitHub] flink pull request: [FLINK-2862] [Storm Compatibility] FlinkTopolo...

GitHub user mjsax opened a pull request: https://github.com/apache/flink/pull/1274 [FLINK-2862] [Storm Compatibility] FlinkTopologyBuilder should use proper generic types You can merge this pull request into a Git repository by running: $ git pull https://github.com/mjsax/fli

[jira] [Commented] (FLINK-2862) FlinkTopologyBuilder should use proper generic types

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

[jira] [Commented] (FLINK-2877) Move Streaming API out of Staging

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

[GitHub] flink pull request: [FLINK-2877] Move Streaming API out of Staging...

Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/1273#issuecomment-149637552 Looks pretty straightforward. Some diffs are displayed probably because of git bugs / limitations. As this was discussed on the mailing list before and all agreed, t

[jira] [Commented] (FLINK-2877) Move Streaming API out of Staging

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

[jira] [Commented] (FLINK-2834) Global round-robin for temporary directories

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

[GitHub] flink pull request: [FLINK-2834] Global round-robin for temporary ...

Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/1272#discussion_r42524229 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/io/disk/iomanager/FileIOChannel.java --- @@ -154,20 +155,25 @@ private static String rando

[GitHub] flink pull request: [FLINK-2877] Move Streaming API out of Staging...

Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/1273#issuecomment-149636785 GitHub sync is lagging behind, so only one commit (the latest) in the PR is relevant, the others are already committed. --- If your project is set up for it, you ca

[GitHub] flink pull request: [FLINK-2834] Global round-robin for temporary ...

Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/1272#issuecomment-149636019 Looks good to me, +1 to merge this! --- 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 d

[jira] [Commented] (FLINK-2834) Global round-robin for temporary directories

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

[jira] [Commented] (FLINK-2877) Move Streaming API out of Staging

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

[GitHub] flink pull request: [FLINK-2877] Move Streaming API out of Staging...

GitHub user aljoscha opened a pull request: https://github.com/apache/flink/pull/1273 [FLINK-2877] Move Streaming API out of Staging package You can merge this pull request into a Git repository by running: $ git pull https://github.com/aljoscha/flink stream-out-of-staging Al

[jira] [Commented] (FLINK-2834) Global round-robin for temporary directories

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

[GitHub] flink pull request: [FLINK-2873] detect & serve the job manager lo...

Github user mxm closed the pull request at: https://github.com/apache/flink/pull/1271 --- 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 feature enabled and wishes so, or if the feature is enabled

[GitHub] flink pull request: [FLINK-2834] Global round-robin for temporary ...

GitHub user greghogan opened a pull request: https://github.com/apache/flink/pull/1272 [FLINK-2834] Global round-robin for temporary directories Multiple TaskManager filesystems can be used by configuring multiple temporary directories. This patch changes the process of spilling

[jira] [Commented] (FLINK-2873) WebRuntimeMonitor does not start when multiple log files are present

[ https://issues.apache.org/jira/browse/FLINK-2873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14965368#comment-14965368 ] ASF GitHub Bot commented on FLINK-2873: --- Github user mxm closed the pull request at:

[jira] [Comment Edited] (FLINK-2873) WebRuntimeMonitor does not start when multiple log files are present

[ https://issues.apache.org/jira/browse/FLINK-2873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14965364#comment-14965364 ] Maximilian Michels edited comment on FLINK-2873 at 10/20/15 4:43 PM: ---

[jira] [Resolved] (FLINK-2873) WebRuntimeMonitor does not start when multiple log files are present

[ https://issues.apache.org/jira/browse/FLINK-2873?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels resolved FLINK-2873. --- Resolution: Fixed Fixed in {{ef1b708}}. > WebRuntimeMonitor does not start when multi

[GitHub] flink pull request: [docs] Fix documentation for building Flink wi...

Github user mxm commented on the pull request: https://github.com/apache/flink/pull/1260#issuecomment-149623979 +1 looks good to merge. --- 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 fe

[jira] [Updated] (FLINK-2880) Allow DeserializationSchema to throw IOException in deserialization method

[ https://issues.apache.org/jira/browse/FLINK-2880?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-2880: Priority: Critical (was: Major) > Allow DeserializationSchema to throw IOException in deserializati

[jira] [Created] (FLINK-2880) Allow DeserializationSchema to throw IOException in deserialization method

Stephan Ewen created FLINK-2880: --- Summary: Allow DeserializationSchema to throw IOException in deserialization method Key: FLINK-2880 URL: https://issues.apache.org/jira/browse/FLINK-2880 Project: Flink

[jira] [Comment Edited] (FLINK-2877) Move Streaming API out of Staging

[ https://issues.apache.org/jira/browse/FLINK-2877?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14965284#comment-14965284 ] Stephan Ewen edited comment on FLINK-2877 at 10/20/15 3:49 PM: -

[jira] [Commented] (FLINK-2877) Move Streaming API out of Staging

[ https://issues.apache.org/jira/browse/FLINK-2877?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14965284#comment-14965284 ] Stephan Ewen commented on FLINK-2877: - +1 for {{flink-streaming-java}}. That makes for

[jira] [Created] (FLINK-2879) Links in documentation are broken

Nikolaas Steenbergen created FLINK-2879: --- Summary: Links in documentation are broken Key: FLINK-2879 URL: https://issues.apache.org/jira/browse/FLINK-2879 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-2873) WebRuntimeMonitor does not start when multiple log files are present

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

[GitHub] flink pull request: [FLINK-2873] detect & serve the job manager lo...

GitHub user mxm opened a pull request: https://github.com/apache/flink/pull/1271 [FLINK-2873] detect & serve the job manager log files correctly When multiple job masters are started or old log files are present, the log file could not be served through the web frontend.

[jira] [Commented] (FLINK-2877) Move Streaming API out of Staging

[ https://issues.apache.org/jira/browse/FLINK-2877?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14965240#comment-14965240 ] Aljoscha Krettek commented on FLINK-2877: - I think I already did it, was not too h

[jira] [Assigned] (FLINK-2877) Move Streaming API out of Staging

[ https://issues.apache.org/jira/browse/FLINK-2877?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-2877: --- Assignee: Aljoscha Krettek > Move Streaming API out of Staging >

[jira] [Created] (FLINK-2878) JobManager warns: Unexpected leader address pattern

Maximilian Michels created FLINK-2878: - Summary: JobManager warns: Unexpected leader address pattern Key: FLINK-2878 URL: https://issues.apache.org/jira/browse/FLINK-2878 Project: Flink I

[GitHub] flink pull request: [FLINK-2872] [Documentation] Update the docume...

Github user hsaputra commented on the pull request: https://github.com/apache/flink/pull/1268#issuecomment-149593562 Will merge this sometime today if no more comments. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If y

[jira] [Commented] (FLINK-2872) Update the documentation for Scala part to add readFileOfPrimitives

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

[jira] [Created] (FLINK-2877) Move Streaming API out of Staging

Aljoscha Krettek created FLINK-2877: --- Summary: Move Streaming API out of Staging Key: FLINK-2877 URL: https://issues.apache.org/jira/browse/FLINK-2877 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-2111) Add "stop" signal to cleanly shutdown streaming jobs

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

[jira] [Created] (FLINK-2876) Minutiae

Greg Hogan created FLINK-2876: - Summary: Minutiae Key: FLINK-2876 URL: https://issues.apache.org/jira/browse/FLINK-2876 Project: Flink Issue Type: Improvement Components: Documentation

[GitHub] flink pull request: [FLINK-2111] Add "stop" signal to cleanly shut...

Github user mjsax commented on the pull request: https://github.com/apache/flink/pull/750#issuecomment-149580271 Is there any news here? --- 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] [Assigned] (FLINK-2862) FlinkTopologyBuilder should use proper generic types

[ https://issues.apache.org/jira/browse/FLINK-2862?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned FLINK-2862: -- Assignee: Matthias J. Sax > FlinkTopologyBuilder should use proper generic types >

[jira] [Commented] (FLINK-2858) Cannot build Flink Scala 2.11 with IntelliJ

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

[GitHub] flink pull request: [docs] Fix documentation for building Flink wi...

Github user tillrohrmann commented on the pull request: https://github.com/apache/flink/pull/1260#issuecomment-149567354 Looks good to me. +1 for merging. Maybe we could also add some documentation for how to change the Scala version with your favourite IDE as described by you in http

[jira] [Commented] (FLINK-2858) Cannot build Flink Scala 2.11 with IntelliJ

[ https://issues.apache.org/jira/browse/FLINK-2858?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14965087#comment-14965087 ] Till Rohrmann commented on FLINK-2858: -- Thanks for your help [~aalexandrov] :-) I did

[jira] [Resolved] (FLINK-2738) StackOverflow in case of unbounded restarts

[ https://issues.apache.org/jira/browse/FLINK-2738?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi resolved FLINK-2738. Resolution: Fixed Fix Version/s: 0.10 Fixed via 73c73e92750ab8fb068d0a3cb37afcb642084fc0 > S

[jira] [Created] (FLINK-2875) Add createRemoveEnvironment variant for HA

Ufuk Celebi created FLINK-2875: -- Summary: Add createRemoveEnvironment variant for HA Key: FLINK-2875 URL: https://issues.apache.org/jira/browse/FLINK-2875 Project: Flink Issue Type: Improvement

[jira] [Resolved] (FLINK-2651) Failing NettyServerLowAndHighWatermarkTest

[ https://issues.apache.org/jira/browse/FLINK-2651?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi resolved FLINK-2651. Resolution: Fixed Fix Version/s: 0.10 Fixed in 371817101848fbb993c02e14a705b5399f75 > Fa

[jira] [Commented] (FLINK-2874) Certain Avro generated getters/setters not recognized

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

[GitHub] flink pull request: [FLINK-2874] Fix Avro getter/setter recognitio...

Github user ukarlsson commented on the pull request: https://github.com/apache/flink/pull/1252#issuecomment-149559944 @fhueske @rmetzger Hello, I have added the Jira issue: https://issues.apache.org/jira/browse/FLINK-2874 I have also added unit tests

[jira] [Updated] (FLINK-2874) Certain Avro generated getters/setters not recognized

[ https://issues.apache.org/jira/browse/FLINK-2874?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ulf Karlsson updated FLINK-2874: Description: For Avro schemas where value null is not allowed, the field is unboxed e.g. int but th

[jira] [Updated] (FLINK-2874) Certain Avro generated getters/setters not recognized

[ https://issues.apache.org/jira/browse/FLINK-2874?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ulf Karlsson updated FLINK-2874: Description: For Avro schemas where value null is not allowed, the field is unboxed e.g. int but th

[jira] [Resolved] (FLINK-2287) Implement JobManager high availability

[ https://issues.apache.org/jira/browse/FLINK-2287?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi resolved FLINK-2287. Resolution: Fixed Fixed in sub tasks > Implement JobManager high availability > ---

[jira] [Closed] (FLINK-2513) Extend state handle provider interface to list all state handles

[ https://issues.apache.org/jira/browse/FLINK-2513?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-2513. -- Resolution: Invalid > Extend state handle provider interface to list all state handles > ---

[jira] [Created] (FLINK-2874) Certain Avro generated getters/setters not recognized

Ulf Karlsson created FLINK-2874: --- Summary: Certain Avro generated getters/setters not recognized Key: FLINK-2874 URL: https://issues.apache.org/jira/browse/FLINK-2874 Project: Flink Issue Type:

[jira] [Commented] (FLINK-2033) Add overloaded methods with explicit TypeInformation parameters to Gelly

[ https://issues.apache.org/jira/browse/FLINK-2033?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14964914#comment-14964914 ] PJ Van Aeken commented on FLINK-2033: - Totally forgot about this one, sorry. Yes it's

[jira] [Resolved] (FLINK-2033) Add overloaded methods with explicit TypeInformation parameters to Gelly

[ https://issues.apache.org/jira/browse/FLINK-2033?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vasia Kalavri resolved FLINK-2033. -- Resolution: Fixed Fix Version/s: 0.10 > Add overloaded methods with explicit TypeInformat

[jira] [Commented] (FLINK-2030) Implement discrete and continuous histograms

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

[GitHub] flink pull request: [FLINK-2030][FLINK-2274][core][utils]Histogram...

Github user tillrohrmann commented on the pull request: https://github.com/apache/flink/pull/861#issuecomment-149494676 Not yet. Just finished my current task. Will take a look now. On Tue, Oct 20, 2015 at 11:25 AM, Sachin Goel wrote: > @tillrohrmann

[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=14964862#comment-14964862 ] Vasia Kalavri commented on FLINK-2254: -- Hi [~ssaumitra], thank you for your interest

[jira] [Commented] (FLINK-2030) Implement discrete and continuous histograms

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

[GitHub] flink pull request: [FLINK-2030][FLINK-2274][core][utils]Histogram...

Github user sachingoel0101 commented on the pull request: https://github.com/apache/flink/pull/861#issuecomment-149491074 @tillrohrmann , any updates regarding this? --- 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

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

[ https://issues.apache.org/jira/browse/FLINK-2254?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vasia Kalavri updated FLINK-2254: - Labels: requires-design-doc (was: ) > Add Bipartite Graph Support for Gelly > ---

[GitHub] flink pull request: [FLINK-2869] [tests] Apply JMH on IOManagerPer...

GitHub user gallenvara opened a pull request: https://github.com/apache/flink/pull/1270 [FLINK-2869] [tests] Apply JMH on IOManagerPerformanceBenchmark class. JMH is a Java harness for building, running, and analysing nano/micro/milli/macro benchmarks.Use JMH to replace the old micr

[jira] [Updated] (FLINK-2873) WebRuntimeMonitor does not start when multiple log files are present

[ https://issues.apache.org/jira/browse/FLINK-2873?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-2873: -- Component/s: JobManager > WebRuntimeMonitor does not start when multiple log files are p

[jira] [Assigned] (FLINK-2873) WebRuntimeMonitor does not start when multiple log files are present

[ https://issues.apache.org/jira/browse/FLINK-2873?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels reassigned FLINK-2873: - Assignee: Maximilian Michels > WebRuntimeMonitor does not start when multiple log

[jira] [Commented] (FLINK-2869) Apply JMH on IOManagerPerformanceBenchmark class.

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

[jira] [Commented] (FLINK-2827) Potential resource leak in TwitterSource#loadAuthenticationProperties()

[ https://issues.apache.org/jira/browse/FLINK-2827?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14964778#comment-14964778 ] Maximilian Michels commented on FLINK-2827: --- Yes, please go ahead. > Potential

[jira] [Created] (FLINK-2873) WebRuntimeMonitor does not start when multiple log files are present

Till Rohrmann created FLINK-2873: Summary: WebRuntimeMonitor does not start when multiple log files are present Key: FLINK-2873 URL: https://issues.apache.org/jira/browse/FLINK-2873 Project: Flink

[jira] [Resolved] (FLINK-2793) Redirect to leading JobManager web fronted in non-standalone mode

[ https://issues.apache.org/jira/browse/FLINK-2793?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-2793. -- Resolution: Fixed Added in e3ad962 > Redirect to leading JobManager web fronted in non-standalo

[jira] [Resolved] (FLINK-2805) Make user jars available for all job managers to recover

[ https://issues.apache.org/jira/browse/FLINK-2805?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-2805. -- Resolution: Fixed Fixed in c3a4d1d > Make user jars available for all job managers to recover >

[jira] [Closed] (FLINK-2804) Support blocking job submission with Job Manager recovery

[ https://issues.apache.org/jira/browse/FLINK-2804?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-2804. Resolution: Fixed Added in d18f580 > Support blocking job submission with Job Manager recovery > --

[jira] [Resolved] (FLINK-2792) Set log level of actor messages to TRACE

[ https://issues.apache.org/jira/browse/FLINK-2792?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-2792. -- Resolution: Fixed Fixed in 3aaee1e > Set log level of actor messages to TRACE > ---

  1   2   >