[jira] [Commented] (FLINK-3097) Add support for custom functions in Table API

2016-07-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3097?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15383450#comment-15383450 ] ASF GitHub Bot commented on FLINK-3097: --- Github user wuchong commented on the issue:

[GitHub] flink issue #2265: [FLINK-3097] [table] Add support for custom functions in ...

2016-07-18 Thread wuchong
Github user wuchong commented on the issue: https://github.com/apache/flink/pull/2265 Do we have any google docs or FLIP talking about this design ? I think the `ScalarFunction` has too many internal functions, and should not be exposed to users. Maybe we can create a new

[GitHub] flink issue #2109: [FLINK-3677] FileInputFormat: Allow to specify include/ex...

2016-07-18 Thread mushketyk
Github user mushketyk commented on the issue: https://github.com/apache/flink/pull/2109 Could someone please review this again? --- 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] [Commented] (FLINK-3677) FileInputFormat: Allow to specify include/exclude file name patterns

2016-07-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3677?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15382654#comment-15382654 ] ASF GitHub Bot commented on FLINK-3677: --- Github user mushketyk commented on the issue:

[jira] [Commented] (FLINK-4205) Implement stratified sampling for DataSet

2016-07-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4205?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15382615#comment-15382615 ] ASF GitHub Bot commented on FLINK-4205: --- GitHub user doflink opened a pull request:

[GitHub] flink pull request #2267: [FLINK-4205] Create a simple stratified sampling f...

2016-07-18 Thread doflink
GitHub user doflink opened a pull request: https://github.com/apache/flink/pull/2267 [FLINK-4205] Create a simple stratified sampling function for DataSet Thanks for contributing to Apache Flink. Before you open your pull request, please take the following check list into

[jira] [Commented] (FLINK-4229) Do not start Metrics Reporter by default

2016-07-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15382533#comment-15382533 ] ASF GitHub Bot commented on FLINK-4229: --- Github user aljoscha commented on the issue:

[GitHub] flink issue #2266: [FLINK-4229] Do not start any Metrics Reporter by default

2016-07-18 Thread aljoscha
Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/2266 @zentol I thought about that as well but wanted to keep the change to one issue. 😃 I'll change it now. --- If your project is set up for it, you can reply to this email and have your

[jira] [Commented] (FLINK-4166) Generate automatic different namespaces in Zookeeper for Flink applications

2016-07-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4166?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15382529#comment-15382529 ] ASF GitHub Bot commented on FLINK-4166: --- Github user mxm commented on the issue:

[GitHub] flink issue #2249: [FLINK-4166] [CLI] Generate different namespaces for Zook...

2016-07-18 Thread mxm
Github user mxm commented on the issue: https://github.com/apache/flink/pull/2249 The changes look good to me. Just had some comments about the default namespace name and an idea to generate a default namespace value in standalone mode. --- If your project is set up for it, you can

[GitHub] flink issue #2266: [FLINK-4229] Do not start any Metrics Reporter by default

2016-07-18 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/2266 This PR is a good time to make a slight change in `JMXReporter#open()`; making it use the `metrics.reporter.arguments` property instead of `metrics.jmx.port`. Since the special port property is not

[jira] [Commented] (FLINK-4166) Generate automatic different namespaces in Zookeeper for Flink applications

2016-07-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4166?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15382528#comment-15382528 ] ASF GitHub Bot commented on FLINK-4166: --- Github user mxm commented on a diff in the pull request:

[GitHub] flink pull request #2249: [FLINK-4166] [CLI] Generate different namespaces f...

2016-07-18 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/2249#discussion_r71178603 --- Diff: docs/setup/config.md --- @@ -272,7 +272,9 @@ For example when running Flink on YARN on an environment with a restrictive fire -

[jira] [Commented] (FLINK-4166) Generate automatic different namespaces in Zookeeper for Flink applications

2016-07-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4166?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15382526#comment-15382526 ] ASF GitHub Bot commented on FLINK-4166: --- Github user StefanRRichter commented on a diff in the pull

[GitHub] flink pull request #2249: [FLINK-4166] [CLI] Generate different namespaces f...

2016-07-18 Thread StefanRRichter
Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/2249#discussion_r71178429 --- Diff: flink-core/src/main/java/org/apache/flink/configuration/ConfigConstants.java --- @@ -969,6 +971,8 @@ public static final

[jira] [Commented] (FLINK-4173) Replace maven-assembly-plugin by maven-shade-plugin in flink-metrics

2016-07-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15382522#comment-15382522 ] ASF GitHub Bot commented on FLINK-4173: --- Github user zentol commented on a diff in the pull request:

[GitHub] flink pull request #2216: [FLINK-4173] Use shade-plugin in flink-metrics

2016-07-18 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/2216#discussion_r71177650 --- Diff: flink-metrics/flink-metrics-statsd/pom.xml --- @@ -49,4 +49,31 @@ under the License. test +

[jira] [Commented] (FLINK-4229) Do not start Metrics Reporter by default

2016-07-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15382517#comment-15382517 ] ASF GitHub Bot commented on FLINK-4229: --- Github user zentol commented on the issue:

[jira] [Commented] (FLINK-4166) Generate automatic different namespaces in Zookeeper for Flink applications

2016-07-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4166?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15382514#comment-15382514 ] ASF GitHub Bot commented on FLINK-4166: --- Github user mxm commented on a diff in the pull request:

[jira] [Commented] (FLINK-4229) Do not start Metrics Reporter by default

2016-07-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15382485#comment-15382485 ] ASF GitHub Bot commented on FLINK-4229: --- GitHub user aljoscha opened a pull request:

[jira] [Commented] (FLINK-4152) TaskManager registration exponential backoff doesn't work

2016-07-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4152?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15382487#comment-15382487 ] ASF GitHub Bot commented on FLINK-4152: --- Github user mxm commented on the issue:

[GitHub] flink pull request #2249: [FLINK-4166] [CLI] Generate different namespaces f...

2016-07-18 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/2249#discussion_r71176801 --- Diff: flink-core/src/main/java/org/apache/flink/configuration/ConfigConstants.java --- @@ -969,6 +971,8 @@ public static final String

[jira] [Commented] (FLINK-4228) RocksDB semi-async snapshot to S3AFileSystem fails

2016-07-18 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4228?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15382512#comment-15382512 ] Ufuk Celebi commented on FLINK-4228: Yeah, maybe. Can you create a separate issue for it to discuss it

[jira] [Commented] (FLINK-4228) RocksDB semi-async snapshot to S3AFileSystem fails

2016-07-18 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4228?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15382502#comment-15382502 ] Aljoscha Krettek commented on FLINK-4228: - Maybe we should move to only allow the fully async

[jira] [Commented] (FLINK-4152) TaskManager registration exponential backoff doesn't work

2016-07-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4152?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15382486#comment-15382486 ] ASF GitHub Bot commented on FLINK-4152: --- Github user mxm commented on a diff in the pull request:

[GitHub] flink pull request #2257: [FLINK-4152] Allow re-registration of TMs at resou...

2016-07-18 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/2257#discussion_r71173613 --- Diff: flink-yarn/src/main/java/org/apache/flink/yarn/YarnFlinkResourceManager.java --- @@ -78,6 +79,9 @@ /** The containers where a TaskManager is

[GitHub] flink issue #2257: [FLINK-4152] Allow re-registration of TMs at resource man...

2016-07-18 Thread mxm
Github user mxm commented on the issue: https://github.com/apache/flink/pull/2257 It was just a surprise to me that we're breaking the original ResourceManager role. If the ResourceManager doesn't get eventually notified about new TaskManagers, then it is not guaranteed anymore that

[jira] [Commented] (FLINK-4152) TaskManager registration exponential backoff doesn't work

2016-07-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4152?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15382493#comment-15382493 ] ASF GitHub Bot commented on FLINK-4152: --- Github user mxm commented on a diff in the pull request:

[GitHub] flink pull request #2266: [FLINK-4229] Do not start any Metrics Reporter by ...

2016-07-18 Thread aljoscha
GitHub user aljoscha opened a pull request: https://github.com/apache/flink/pull/2266 [FLINK-4229] Do not start any Metrics Reporter by default @rmetzger Is this what you had in mind when you mentioned that the JMXReporter should not be active by default because it starts a lot of

[GitHub] flink pull request #2257: [FLINK-4152] Allow re-registration of TMs at resou...

2016-07-18 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/2257#discussion_r71174483 --- Diff: flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala --- @@ -405,36 +374,13 @@ class JobManager(

[jira] [Updated] (FLINK-4231) Switch DistinctOperator from GroupReduce to Reduce

2016-07-18 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4231?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan updated FLINK-4231: -- Summary: Switch DistinctOperator from GroupReduce to Reduce (was: Switch DistinctOperator from

[jira] [Created] (FLINK-4231) Switch DistinctOperator from GroupReduceFunction to ReduceFunction

2016-07-18 Thread Greg Hogan (JIRA)
Greg Hogan created FLINK-4231: - Summary: Switch DistinctOperator from GroupReduceFunction to ReduceFunction Key: FLINK-4231 URL: https://issues.apache.org/jira/browse/FLINK-4231 Project: Flink

[jira] [Commented] (FLINK-3097) Add support for custom functions in Table API

2016-07-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3097?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15382483#comment-15382483 ] ASF GitHub Bot commented on FLINK-3097: --- GitHub user twalthr opened a pull request:

[GitHub] flink pull request #2265: [FLINK-3097] [table] Add support for custom functi...

2016-07-18 Thread twalthr
GitHub user twalthr opened a pull request: https://github.com/apache/flink/pull/2265 [FLINK-3097] [table] Add support for custom functions in Table API Thanks for contributing to Apache Flink. Before you open your pull request, please take the following check list into

[GitHub] flink pull request #2083: [FLINK-3713] [clients, runtime] Use user code clas...

2016-07-18 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2083 --- 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

[jira] [Commented] (FLINK-4173) Replace maven-assembly-plugin by maven-shade-plugin in flink-metrics

2016-07-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15382461#comment-15382461 ] ASF GitHub Bot commented on FLINK-4173: --- Github user tillrohrmann commented on the issue:

[GitHub] flink issue #2216: [FLINK-4173] Use shade-plugin in flink-metrics

2016-07-18 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/2216 Thanks for your contribution @zentol. I've looked at your changes and they look good modulo some minor comments. Have you tried your changes out on a cluster? I think we should do this

[jira] [Commented] (FLINK-4173) Replace maven-assembly-plugin by maven-shade-plugin in flink-metrics

2016-07-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15382459#comment-15382459 ] ASF GitHub Bot commented on FLINK-4173: --- Github user tillrohrmann commented on a diff in the pull

[GitHub] flink pull request #2216: [FLINK-4173] Use shade-plugin in flink-metrics

2016-07-18 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/2216#discussion_r71169047 --- Diff: flink-metrics/flink-metrics-ganglia/pom.xml --- @@ -68,20 +68,27 @@ under the License. -

[jira] [Commented] (FLINK-4199) Misleading messages by CLI upon job submission

2016-07-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4199?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15382457#comment-15382457 ] ASF GitHub Bot commented on FLINK-4199: --- GitHub user mxm opened a pull request:

[GitHub] flink pull request #2264: [FLINK-4199] Fix misleading CLI messages and retur...

2016-07-18 Thread mxm
GitHub user mxm opened a pull request: https://github.com/apache/flink/pull/2264 [FLINK-4199] Fix misleading CLI messages and return execution result for interactive blocking execution **OLD** ``` Cluster retrieved: Standalone cluster with JobManager at

[jira] [Commented] (FLINK-4230) Session Windowing IT Case

2016-07-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4230?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15382448#comment-15382448 ] ASF GitHub Bot commented on FLINK-4230: --- GitHub user StefanRRichter opened a pull request:

[jira] [Commented] (FLINK-4173) Replace maven-assembly-plugin by maven-shade-plugin in flink-metrics

2016-07-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15382453#comment-15382453 ] ASF GitHub Bot commented on FLINK-4173: --- Github user tillrohrmann commented on a diff in the pull

[GitHub] flink pull request #2216: [FLINK-4173] Use shade-plugin in flink-metrics

2016-07-18 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/2216#discussion_r71168279 --- Diff: flink-metrics/flink-metrics-ganglia/pom.xml --- @@ -68,20 +68,27 @@ under the License. -

[jira] [Created] (FLINK-4229) Do not start Metrics Reporter by default

2016-07-18 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-4229: --- Summary: Do not start Metrics Reporter by default Key: FLINK-4229 URL: https://issues.apache.org/jira/browse/FLINK-4229 Project: Flink Issue Type:

[jira] [Commented] (FLINK-4150) Problem with Blobstore in Yarn HA setting on recovery after cluster shutdown

2016-07-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4150?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15382419#comment-15382419 ] ASF GitHub Bot commented on FLINK-4150: --- Github user tillrohrmann commented on the issue:

[jira] [Commented] (FLINK-3713) DisposeSavepoint message uses system classloader to discard state

2016-07-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15382418#comment-15382418 ] ASF GitHub Bot commented on FLINK-3713: --- Github user asfgit closed the pull request at:

[GitHub] flink pull request #2263: [FLINK-4230] [DataStreamAPI] Add Session Windowing...

2016-07-18 Thread StefanRRichter
GitHub user StefanRRichter opened a pull request: https://github.com/apache/flink/pull/2263 [FLINK-4230] [DataStreamAPI] Add Session Windowing ITCase This PR contains an exhaustive integration test for Session Windows. You can merge this pull request into a Git repository by

[jira] [Commented] (FLINK-4173) Replace maven-assembly-plugin by maven-shade-plugin in flink-metrics

2016-07-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15382443#comment-15382443 ] ASF GitHub Bot commented on FLINK-4173: --- Github user tillrohrmann commented on a diff in the pull

[GitHub] flink pull request #2216: [FLINK-4173] Use shade-plugin in flink-metrics

2016-07-18 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/2216#discussion_r71167293 --- Diff: flink-metrics/flink-metrics-graphite/pom.xml --- @@ -62,20 +62,26 @@ under the License.

[GitHub] flink pull request #2262: [ITCase] Session windowing

2016-07-18 Thread StefanRRichter
Github user StefanRRichter closed the pull request at: https://github.com/apache/flink/pull/2262 --- 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

[GitHub] flink pull request #2216: [FLINK-4173] Use shade-plugin in flink-metrics

2016-07-18 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/2216#discussion_r71166435 --- Diff: flink-metrics/flink-metrics-statsd/pom.xml --- @@ -49,4 +49,31 @@ under the License. test

[jira] [Commented] (FLINK-4173) Replace maven-assembly-plugin by maven-shade-plugin in flink-metrics

2016-07-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15382435#comment-15382435 ] ASF GitHub Bot commented on FLINK-4173: --- Github user tillrohrmann commented on a diff in the pull

[jira] [Created] (FLINK-4230) Session Windowing IT Case

2016-07-18 Thread Stefan Richter (JIRA)
Stefan Richter created FLINK-4230: - Summary: Session Windowing IT Case Key: FLINK-4230 URL: https://issues.apache.org/jira/browse/FLINK-4230 Project: Flink Issue Type: Test

[jira] [Commented] (FLINK-4199) Misleading messages by CLI upon job submission

2016-07-18 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4199?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15382423#comment-15382423 ] Maximilian Michels commented on FLINK-4199: --- This is how it looks now for successful

[jira] [Closed] (FLINK-3713) DisposeSavepoint message uses system classloader to discard state

2016-07-18 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3713?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-3713. -- Resolution: Fixed Fix Version/s: 1.1.0 Fixed in b67e508 (master). > DisposeSavepoint message

[GitHub] flink issue #2256: [FLINK-4150] [runtime] Don't clean up BlobStore on BlobSe...

2016-07-18 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/2256 In general, I think it would be helpful for users to be able to retrieve checkpoints of a failed job. I could imagine a scenario where a job is faulty but one only runs into after some time.

[jira] [Commented] (FLINK-4199) Misleading messages by CLI upon job submission

2016-07-18 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4199?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15382416#comment-15382416 ] Maximilian Michels commented on FLINK-4199: --- Thanks for reporting! {quote} 1) Cluster

[jira] [Updated] (FLINK-4199) Misleading messages by CLI upon job submission

2016-07-18 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4199?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-4199: -- Summary: Misleading messages by CLI upon job submission (was: Wrong client behavior

[jira] [Updated] (FLINK-4199) Wrong client behavior when submitting job to non-existing cluster

2016-07-18 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4199?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-4199: -- Fix Version/s: 1.1.0 > Wrong client behavior when submitting job to non-existing

[jira] [Updated] (FLINK-4199) Wrong client behavior when submitting job to non-existing cluster

2016-07-18 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4199?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-4199: -- Affects Version/s: 1.1.0 > Wrong client behavior when submitting job to non-existing

[jira] [Commented] (FLINK-3985) A metric with the name * was already registered

2016-07-18 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3985?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15382388#comment-15382388 ] Aljoscha Krettek commented on FLINK-3985: - On current master it only reports this one line: {code}

[GitHub] flink issue #2245: [hotfix] Fix Redis Sink to fail at opening if Redis is no...

2016-07-18 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/2245 Thanks for your contribution @kl0u. I had some inline 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 your project

[GitHub] flink pull request #2245: [hotfix] Fix Redis Sink to fail at opening if Redi...

2016-07-18 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/2245#discussion_r71159044 --- Diff: flink-streaming-connectors/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/container/RedisContainer.java

[jira] [Created] (FLINK-4228) RocksDB semi-async snapshot to S3AFileSystem fails

2016-07-18 Thread Ufuk Celebi (JIRA)
Ufuk Celebi created FLINK-4228: -- Summary: RocksDB semi-async snapshot to S3AFileSystem fails Key: FLINK-4228 URL: https://issues.apache.org/jira/browse/FLINK-4228 Project: Flink Issue Type: Bug

[GitHub] flink pull request #2245: [hotfix] Fix Redis Sink to fail at opening if Redi...

2016-07-18 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/2245#discussion_r71157963 --- Diff: flink-streaming-connectors/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/container/RedisContainer.java

[GitHub] flink pull request #2245: [hotfix] Fix Redis Sink to fail at opening if Redi...

2016-07-18 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/2245#discussion_r71158368 --- Diff:

[GitHub] flink pull request #2245: [hotfix] Fix Redis Sink to fail at opening if Redi...

2016-07-18 Thread kl0u
Github user kl0u commented on a diff in the pull request: https://github.com/apache/flink/pull/2245#discussion_r71157753 --- Diff: flink-streaming-connectors/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/container/RedisContainer.java ---

[GitHub] flink pull request #2245: [hotfix] Fix Redis Sink to fail at opening if Redi...

2016-07-18 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/2245#discussion_r71157765 --- Diff: flink-streaming-connectors/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/container/RedisContainer.java

[GitHub] flink pull request #2245: [hotfix] Fix Redis Sink to fail at opening if Redi...

2016-07-18 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/2245#discussion_r71157239 --- Diff: flink-streaming-connectors/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/container/RedisContainer.java

[GitHub] flink pull request #2245: [hotfix] Fix Redis Sink to fail at opening if Redi...

2016-07-18 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/2245#discussion_r71157090 --- Diff:

[GitHub] flink pull request #2245: [hotfix] Fix Redis Sink to fail at opening if Redi...

2016-07-18 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/2245#discussion_r71156944 --- Diff: flink-streaming-connectors/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/RedisSink.java --- @@ -166,7

[GitHub] flink pull request #2259: [hotfix] Fixes broken TopSpeedWindowing scala exam...

2016-07-18 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/2259#discussion_r71156624 --- Diff: flink-examples/flink-examples-streaming/src/main/scala/org/apache/flink/streaming/scala/examples/windowing/TopSpeedWindowing.scala --- @@

[GitHub] flink issue #2259: [hotfix] Fixes broken TopSpeedWindowing scala example

2016-07-18 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/2259 Good changes @kl0u. I only had a minor comment. --- 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

[GitHub] flink pull request #2259: [hotfix] Fixes broken TopSpeedWindowing scala exam...

2016-07-18 Thread kl0u
Github user kl0u commented on a diff in the pull request: https://github.com/apache/flink/pull/2259#discussion_r71155772 --- Diff: flink-examples/flink-examples-streaming/src/main/scala/org/apache/flink/streaming/scala/examples/windowing/TopSpeedWindowing.scala --- @@ -72,7

[GitHub] flink pull request #2259: [hotfix] Fixes broken TopSpeedWindowing scala exam...

2016-07-18 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/2259#discussion_r71155160 --- Diff: flink-examples/flink-examples-streaming/src/main/scala/org/apache/flink/streaming/scala/examples/windowing/TopSpeedWindowing.scala --- @@

[jira] [Commented] (FLINK-1815) Add methods to read and write a Graph as adjacency list

2016-07-18 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1815?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15382306#comment-15382306 ] Greg Hogan commented on FLINK-1815: --- One area I would like to explore with the next release is storing

[jira] [Commented] (FLINK-4067) Add version header to savepoints

2016-07-18 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4067?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15382305#comment-15382305 ] Aljoscha Krettek commented on FLINK-4067: - What is the error message when you have a window

[jira] [Commented] (FLINK-4190) Generalise RollingSink to work with arbitrary buckets

2016-07-18 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15382297#comment-15382297 ] Aljoscha Krettek commented on FLINK-4190: - I think checking in invoke is the right thing to do.

[GitHub] flink issue #2240: [FLINK-4209] Fix issue on docker with multiple NICs and r...

2016-07-18 Thread aljoscha
Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/2240 Thanks! --- 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

[jira] [Commented] (FLINK-4209) Fix issue on docker with multiple NICs and remove supervisord dependency

2016-07-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4209?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15382270#comment-15382270 ] ASF GitHub Bot commented on FLINK-4209: --- Github user aljoscha commented on the issue:

[GitHub] flink pull request #2257: [FLINK-4152] Allow re-registration of TMs at resou...

2016-07-18 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/2257#discussion_r71145235 --- Diff: flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala --- @@ -405,36 +374,13 @@ class JobManager(

[jira] [Commented] (FLINK-4152) TaskManager registration exponential backoff doesn't work

2016-07-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4152?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15382267#comment-15382267 ] ASF GitHub Bot commented on FLINK-4152: --- Github user tillrohrmann commented on a diff in the pull

[GitHub] flink issue #2240: [FLINK-4209] Fix issue on docker with multiple NICs and r...

2016-07-18 Thread iemejia
Github user iemejia commented on the issue: https://github.com/apache/flink/pull/2240 Ok, I will check how is the procedure and I will tell you if we need something else. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well.

[jira] [Commented] (FLINK-4209) Fix issue on docker with multiple NICs and remove supervisord dependency

2016-07-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4209?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15382263#comment-15382263 ] ASF GitHub Bot commented on FLINK-4209: --- Github user iemejia commented on the issue:

[jira] [Commented] (FLINK-3921) StringParser not specifying encoding to use

2016-07-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3921?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15382262#comment-15382262 ] ASF GitHub Bot commented on FLINK-3921: --- Github user greghogan commented on the issue:

[jira] [Commented] (FLINK-4209) Fix issue on docker with multiple NICs and remove supervisord dependency

2016-07-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4209?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15382261#comment-15382261 ] ASF GitHub Bot commented on FLINK-4209: --- Github user aljoscha commented on the issue:

[GitHub] flink issue #2060: [FLINK-3921] StringParser encoding

2016-07-18 Thread greghogan
Github user greghogan commented on the issue: https://github.com/apache/flink/pull/2060 `StringParser` and `StringValueParser` have the method `enableQuotedStringParsing` which is called by `GenericCsvInputFormat.open` only for these types. We should consider doing the same for

[GitHub] flink issue #2240: [FLINK-4209] Fix issue on docker with multiple NICs and r...

2016-07-18 Thread aljoscha
Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/2240 Yes, that would probably be good. --- 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

[jira] [Commented] (FLINK-4209) Fix issue on docker with multiple NICs and remove supervisord dependency

2016-07-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4209?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15382259#comment-15382259 ] ASF GitHub Bot commented on FLINK-4209: --- Github user iemejia commented on the issue:

[jira] [Commented] (FLINK-4152) TaskManager registration exponential backoff doesn't work

2016-07-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4152?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15382258#comment-15382258 ] ASF GitHub Bot commented on FLINK-4152: --- Github user tillrohrmann commented on the issue:

[GitHub] flink issue #2240: [FLINK-4209] Fix issue on docker with multiple NICs and r...

2016-07-18 Thread iemejia
Github user iemejia commented on the issue: https://github.com/apache/flink/pull/2240 About the flink image version, we can support multiple versions via tags, those are pulled with the: separator, e.g. docker pull flink:1.0.3-hadoop26-scala_2.10 And we can agree on a default

[GitHub] flink issue #2257: [FLINK-4152] Allow re-registration of TMs at resource man...

2016-07-18 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/2257 It is true that the duplicate RegisterTaskManager messages fix could have been a separate PR. Since it surfaces as a symptom of the registration problem, I thought about fixing it in the same

[jira] [Updated] (FLINK-4209) Fix issue on docker with multiple NICs and remove supervisord dependency

2016-07-18 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4209?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-4209: Assignee: Ismaël Mejía > Fix issue on docker with multiple NICs and remove supervisord

[jira] [Commented] (FLINK-4209) Fix issue on docker with multiple NICs and remove supervisord dependency

2016-07-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4209?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15382254#comment-15382254 ] ASF GitHub Bot commented on FLINK-4209: --- Github user iemejia closed the pull request at:

[GitHub] flink issue #2240: [FLINK-4209] Fix issue on docker with multiple NICs and r...

2016-07-18 Thread iemejia
Github user iemejia commented on the issue: https://github.com/apache/flink/pull/2240 Great, closing now. --- 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,

[jira] [Commented] (FLINK-4209) Fix issue on docker with multiple NICs and remove supervisord dependency

2016-07-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4209?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15382253#comment-15382253 ] ASF GitHub Bot commented on FLINK-4209: --- Github user iemejia commented on the issue:

[jira] [Resolved] (FLINK-4209) Fix issue on docker with multiple NICs and remove supervisord dependency

2016-07-18 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4209?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek resolved FLINK-4209. - Resolution: Fixed Fix Version/s: 1.1.0 Fixed in

[GitHub] flink pull request #2240: [FLINK-4209] Fix issue on docker with multiple NIC...

2016-07-18 Thread iemejia
Github user iemejia closed the pull request at: https://github.com/apache/flink/pull/2240 --- 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

[jira] [Commented] (FLINK-4209) Fix issue on docker with multiple NICs and remove supervisord dependency

2016-07-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4209?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15382249#comment-15382249 ] ASF GitHub Bot commented on FLINK-4209: --- Github user aljoscha commented on the issue:

  1   2   >