[GitHub] flink issue #3335: [FLINK-5818][Security]change checkpoint dir permission to...

2017-02-17 Thread greghogan
Github user greghogan commented on the issue: https://github.com/apache/flink/pull/3335 The HDFS administrator can configure the parent directory for checkpoints with user and/or group ACL permissions. A default ACL is then inherited by the newly created files and subdirectories

[jira] [Commented] (FLINK-5818) change checkpoint dir permission to 700 for security reason

2017-02-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5818?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15872516#comment-15872516 ] ASF GitHub Bot commented on FLINK-5818: --- Github user greghogan commented on the issue:

[GitHub] flink issue #3323: [hotfix] [core] Add missing stability annotations for cla...

2017-02-17 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/3323 Good cleanup, thanks a lot! Merging 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 does not have

[jira] [Commented] (FLINK-5763) Make savepoints self-contained and relocatable

2017-02-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5763?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15872532#comment-15872532 ] ASF GitHub Bot commented on FLINK-5763: --- Github user gyfora commented on the issue:

[GitHub] flink issue #3346: [FLINK-5763] [checkpoints] Add CheckpointOptions for self...

2017-02-17 Thread gyfora
Github user gyfora commented on the issue: https://github.com/apache/flink/pull/3346 So will the same savepoint logic apply to externalized checkpoints? I think it would be good to have a similar way of restoring from checkpoints and savepoints from a usability perspective.

[GitHub] flink issue #3335: [FLINK-5818][Security]change checkpoint dir permission to...

2017-02-17 Thread gyfora
Github user gyfora commented on the issue: https://github.com/apache/flink/pull/3335 I agree with @StephanEwen that people probably manage the directory permissions directly when configuring the Flink jobs. It would be quite annoying if the Flink job changed the permissions you set

[jira] [Commented] (FLINK-5818) change checkpoint dir permission to 700 for security reason

2017-02-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5818?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15872581#comment-15872581 ] ASF GitHub Bot commented on FLINK-5818: --- Github user gyfora commented on the issue:

[jira] [Commented] (FLINK-3679) DeserializationSchema should handle zero or more outputs for every input

2017-02-17 Thread Haohui Mai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3679?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15872506#comment-15872506 ] Haohui Mai commented on FLINK-3679: --- [~tzulitai] -- would you mind taking a look? >

[GitHub] flink issue #3332: [FLINK-5751] [docs] Add link check script

2017-02-17 Thread patricklucas
Github user patricklucas commented on the issue: https://github.com/apache/flink/pull/3332 :+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 enabled and wishes so, or if the

[GitHub] flink pull request #3332: [FLINK-5751] [docs] Add link check script

2017-02-17 Thread patricklucas
Github user patricklucas commented on a diff in the pull request: https://github.com/apache/flink/pull/3332#discussion_r101786279 --- Diff: docs/check_links.sh --- @@ -0,0 +1,36 @@ +#!/usr/bin/env bash

[jira] [Commented] (FLINK-5751) 404 in documentation

2017-02-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5751?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15872022#comment-15872022 ] ASF GitHub Bot commented on FLINK-5751: --- Github user patricklucas commented on the issue:

[jira] [Commented] (FLINK-5747) Eager Scheduling should deploy all Tasks together

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

[jira] [Commented] (FLINK-5747) Eager Scheduling should deploy all Tasks together

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

[GitHub] flink pull request #3295: [FLINK-5747] [distributed coordination] Eager sche...

2017-02-17 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/3295#discussion_r101766916 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/concurrent/FutureUtilsTest.java --- @@ -0,0 +1,190 @@ +/* + * Licensed to the

[jira] [Commented] (FLINK-4460) Side Outputs in Flink

2017-02-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4460?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15872032#comment-15872032 ] ASF GitHub Bot commented on FLINK-4460: --- Github user aljoscha commented on the issue:

[GitHub] flink pull request #3330: [FLINK-5795][TableAPI] Improve UDTF to support...

2017-02-17 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3330#discussion_r101759328 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/utils/UserDefinedFunctionUtils.scala --- @@ -22,7 +22,9 @@ package

[GitHub] flink pull request #3330: [FLINK-5795][TableAPI] Improve UDTF to support...

2017-02-17 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3330#discussion_r101765703 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/datastream/DataStreamUserDefinedFunctionITCase.scala --- @@ -0,0 +1,80

[GitHub] flink pull request #3330: [FLINK-5795][TableAPI] Improve UDTF to support...

2017-02-17 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3330#discussion_r101765235 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/dataset/DataSetUserDefinedFunctionITCase.scala --- @@ -0,0 +1,75 @@

[GitHub] flink pull request #3330: [FLINK-5795][TableAPI] Improve UDTF to support...

2017-02-17 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3330#discussion_r101760789 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/CodeGenerator.scala --- @@ -1463,21 +1465,23 @@ class CodeGenerator(

[GitHub] flink pull request #3330: [FLINK-5795][TableAPI] Improve UDTF to support...

2017-02-17 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3330#discussion_r101763661 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/CodeGenerator.scala --- @@ -1463,21 +1465,23 @@ class CodeGenerator(

[GitHub] flink pull request #3330: [FLINK-5795][TableAPI] Improve UDTF to support...

2017-02-17 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3330#discussion_r101762354 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/CodeGenerator.scala --- @@ -1463,21 +1465,23 @@ class CodeGenerator(

[GitHub] flink pull request #3330: [FLINK-5795][TableAPI] Improve UDTF to support...

2017-02-17 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3330#discussion_r101775264 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/CodeGenerator.scala --- @@ -1463,21 +1465,23 @@ class CodeGenerator(

[jira] [Commented] (FLINK-5795) Improve “UDTF" to support constructor with parameter.

2017-02-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15871956#comment-15871956 ] ASF GitHub Bot commented on FLINK-5795: --- Github user fhueske commented on a diff in the pull

[jira] [Commented] (FLINK-5795) Improve “UDTF" to support constructor with parameter.

2017-02-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15871952#comment-15871952 ] ASF GitHub Bot commented on FLINK-5795: --- Github user fhueske commented on a diff in the pull

[jira] [Commented] (FLINK-5795) Improve “UDTF" to support constructor with parameter.

2017-02-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15871951#comment-15871951 ] ASF GitHub Bot commented on FLINK-5795: --- Github user fhueske commented on a diff in the pull

[jira] [Commented] (FLINK-1707) Add an Affinity Propagation Library Method

2017-02-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15871997#comment-15871997 ] ASF GitHub Bot commented on FLINK-1707: --- Github user joseprupi commented on the issue:

[GitHub] flink issue #2885: [FLINK-1707] Affinity propagation

2017-02-17 Thread joseprupi
Github user joseprupi commented on the issue: https://github.com/apache/flink/pull/2885 Done @vasia. Sorry :( I'll be looking forward to modify anything you think that needs to be modified. I can share the results I used to compare with scikit if you want. Thanks!

[jira] [Commented] (FLINK-5795) Improve “UDTF" to support constructor with parameter.

2017-02-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15871954#comment-15871954 ] ASF GitHub Bot commented on FLINK-5795: --- Github user fhueske commented on a diff in the pull

[jira] [Commented] (FLINK-5795) Improve “UDTF" to support constructor with parameter.

2017-02-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15871953#comment-15871953 ] ASF GitHub Bot commented on FLINK-5795: --- Github user fhueske commented on a diff in the pull

[jira] [Commented] (FLINK-5795) Improve “UDTF" to support constructor with parameter.

2017-02-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15871950#comment-15871950 ] ASF GitHub Bot commented on FLINK-5795: --- Github user fhueske commented on a diff in the pull

[jira] [Commented] (FLINK-5795) Improve “UDTF" to support constructor with parameter.

2017-02-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15871955#comment-15871955 ] ASF GitHub Bot commented on FLINK-5795: --- Github user fhueske commented on a diff in the pull

[GitHub] flink pull request #3349: Updated DC/OS setup instructions.

2017-02-17 Thread joerg84
GitHub user joerg84 opened a pull request: https://github.com/apache/flink/pull/3349 Updated DC/OS setup instructions. Thanks for contributing to Apache Flink. Before you open your pull request, please take the following check list into consideration. If your changes take all

[jira] [Commented] (FLINK-4997) Extending Window Function Metadata

2017-02-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4997?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15872033#comment-15872033 ] ASF GitHub Bot commented on FLINK-4997: --- Github user aljoscha closed the pull request at:

[GitHub] flink pull request #3285: [FLINK-4997] [streaming] Introduce ProcessWindowFu...

2017-02-17 Thread aljoscha
Github user aljoscha closed the pull request at: https://github.com/apache/flink/pull/3285 --- 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-5825) In yarn mode, a small pic can not be loaded

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

[GitHub] flink pull request #3337: [FLINK-5825][UI]make the cite path relative to sho...

2017-02-17 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3337 --- 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] [Closed] (FLINK-5825) In yarn mode, a small pic can not be loaded

2017-02-17 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5825?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-5825. -- Resolution: Fixed Fix Version/s: 1.2.1 1.3.0 Fixed in a2b0816 (master),

[GitHub] flink issue #3341: [FLINK-5817]Fix test concurrent execution failure by test...

2017-02-17 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/3341 Good change, thank you. merging 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 does not have this feature

[jira] [Commented] (FLINK-5817) Fix test concurrent execution failure by test dir conflicts.

2017-02-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5817?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15872180#comment-15872180 ] ASF GitHub Bot commented on FLINK-5817: --- Github user StephanEwen commented on the issue:

[GitHub] flink issue #3309: [FLINK-5277] add unit tests for ResultPartition#add() in ...

2017-02-17 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/3309 Good addition, thanks! Merging 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 does not have this

[jira] [Commented] (FLINK-5838) Print shell script usage

2017-02-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5838?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15872400#comment-15872400 ] ASF GitHub Bot commented on FLINK-5838: --- GitHub user greghogan opened a pull request:

[jira] [Commented] (FLINK-5546) java.io.tmpdir setted as project build directory in surefire plugin

2017-02-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5546?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15872196#comment-15872196 ] ASF GitHub Bot commented on FLINK-5546: --- Github user StephanEwen commented on the issue:

[jira] [Commented] (FLINK-5277) missing unit test for ensuring ResultPartition#add always recycles buffers

2017-02-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5277?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15872246#comment-15872246 ] ASF GitHub Bot commented on FLINK-5277: --- Github user StephanEwen commented on the issue:

[jira] [Commented] (FLINK-3163) Configure Flink for NUMA systems

2017-02-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3163?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15872261#comment-15872261 ] ASF GitHub Bot commented on FLINK-3163: --- Github user greghogan commented on the issue:

[GitHub] flink issue #3246: [FLINK-5353] [elasticsearch] User-provided failure handle...

2017-02-17 Thread fpompermaier
Github user fpompermaier commented on the issue: https://github.com/apache/flink/pull/3246 Any news on 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 does not have this feature enabled and wishes

[jira] [Commented] (FLINK-5353) Elasticsearch Sink loses well-formed documents when there are malformed documents

2017-02-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5353?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15872297#comment-15872297 ] ASF GitHub Bot commented on FLINK-5353: --- Github user fpompermaier commented on the issue:

[jira] [Commented] (FLINK-5747) Eager Scheduling should deploy all Tasks together

2017-02-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5747?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15872360#comment-15872360 ] ASF GitHub Bot commented on FLINK-5747: --- Github user StephanEwen commented on a diff in the pull

[GitHub] flink issue #2982: [FLINK-4460] Side Outputs in Flink

2017-02-17 Thread chenqin
Github user chenqin commented on the issue: https://github.com/apache/flink/pull/2982 @aljoscha Looks good to me 👍 I briefly looked at your git branch, a minor comment would be adding comments to `sideOutputLateData` so user get better idea when they opt-in to late

[jira] [Commented] (FLINK-5640) configure the explicit Unit Test file suffix

2017-02-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5640?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15872225#comment-15872225 ] ASF GitHub Bot commented on FLINK-5640: --- Github user StephanEwen commented on the issue:

[jira] [Commented] (FLINK-3163) Configure Flink for NUMA systems

2017-02-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3163?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15872236#comment-15872236 ] ASF GitHub Bot commented on FLINK-3163: --- Github user StephanEwen commented on the issue:

[jira] [Commented] (FLINK-5024) Add SimpleStateDescriptor to clarify the concepts

2017-02-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5024?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15872233#comment-15872233 ] ASF GitHub Bot commented on FLINK-5024: --- Github user StephanEwen commented on the issue:

[jira] [Commented] (FLINK-5739) NullPointerException in CliFrontend

2017-02-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15872240#comment-15872240 ] ASF GitHub Bot commented on FLINK-5739: --- Github user StephanEwen commented on the issue:

[GitHub] flink issue #3292: [FLINK-5739] [client] fix NullPointerException in CliFron...

2017-02-17 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/3292 Change looks good, thank you! Merging 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 does not have

[jira] [Commented] (FLINK-4813) Having flink-test-utils as a dependency outside Flink fails the build

2017-02-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4813?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15872250#comment-15872250 ] ASF GitHub Bot commented on FLINK-4813: --- Github user StephanEwen commented on the issue:

[jira] [Commented] (FLINK-5747) Eager Scheduling should deploy all Tasks together

2017-02-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5747?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15872348#comment-15872348 ] ASF GitHub Bot commented on FLINK-5747: --- Github user StephanEwen commented on a diff in the pull

[GitHub] flink pull request #3295: [FLINK-5747] [distributed coordination] Eager sche...

2017-02-17 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/3295#discussion_r101827724 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/concurrent/FutureUtils.java --- @@ -88,4 +100,104 @@ public RetryException(Throwable

[GitHub] flink pull request #3295: [FLINK-5747] [distributed coordination] Eager sche...

2017-02-17 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/3295#discussion_r101829019 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/concurrent/FutureUtils.java --- @@ -88,4 +100,104 @@ public RetryException(Throwable

[GitHub] flink pull request #3352: [FLINK-5838] [scripts] Print shell script usage

2017-02-17 Thread greghogan
GitHub user greghogan opened a pull request: https://github.com/apache/flink/pull/3352 [FLINK-5838] [scripts] Print shell script usage If jobmanager.sh, taskmanager.sh, or zookeeper.sh are called without arguments then argument list for the call to flink-daemon.sh is misaligned and

[GitHub] flink issue #3322: [FLINK-4813][flink-test-utils] make the hadoop-minikdc de...

2017-02-17 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/3322 The change looks good, thank you! Merging 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 does not

[jira] [Updated] (FLINK-5838) Print shell script usage

2017-02-17 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5838?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan updated FLINK-5838: -- Description: {code} $ ./bin/jobmanager.sh Unknown daemon ''. Usage: flink-daemon.sh

[jira] [Updated] (FLINK-5838) Print shell script usage

2017-02-17 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5838?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan updated FLINK-5838: -- Summary: Print shell script usage (was: Fix jobmanager.sh usage) > Print shell script usage >

[GitHub] flink issue #3190: [FLINK-5546][build] java.io.tmpdir setted as project buil...

2017-02-17 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/3190 All right, I am convinced now that this is a helpful change. Merging this... --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as

[GitHub] flink issue #3211: [FLINK-5640][build]configure the explicit Unit Test file ...

2017-02-17 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/3211 Change looks good, thanks! Merging 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 does not have

[GitHub] flink issue #3231: [FLINK-5682] Fix scala version in flink-streaming-scala P...

2017-02-17 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/3231 @billliuatuber Since the dependency management section in the root `pom.xml` defines the Scala version for all sub-modules, I think this change is not needed. If you agree, could you close

[jira] [Commented] (FLINK-4810) Checkpoint Coordinator should fail ExecutionGraph after "n" unsuccessful checkpoints

2017-02-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4810?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15872260#comment-15872260 ] ASF GitHub Bot commented on FLINK-4810: --- Github user StephanEwen commented on the issue:

[GitHub] flink issue #3249: [FLINK-3163] [scripts] Configure Flink for NUMA systems

2017-02-17 Thread greghogan
Github user greghogan commented on the issue: https://github.com/apache/flink/pull/3249 @StephanEwen thanks for the review. I'll verify, test, and 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

[GitHub] flink issue #3249: [FLINK-3163] [scripts] Configure Flink for NUMA systems

2017-02-17 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/3249 Looks good. +1 from my side! --- 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-5682) Fix scala version in flink-streaming-scala POM file

2017-02-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5682?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15872231#comment-15872231 ] ASF GitHub Bot commented on FLINK-5682: --- Github user StephanEwen commented on the issue:

[GitHub] flink issue #3243: [FLINK-5024] [core] Refactor the interface of State and S...

2017-02-17 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/3243 Subsumed by another pull request... --- 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

[GitHub] flink pull request #3243: [FLINK-5024] [core] Refactor the interface of Stat...

2017-02-17 Thread StephanEwen
Github user StephanEwen closed the pull request at: https://github.com/apache/flink/pull/3243 --- 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

[jira] [Commented] (FLINK-5024) Add SimpleStateDescriptor to clarify the concepts

2017-02-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5024?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15872234#comment-15872234 ] ASF GitHub Bot commented on FLINK-5024: --- Github user StephanEwen closed the pull request at:

[GitHub] flink issue #3334: FLINK-4810 Checkpoint Coordinator should fail ExecutionGr...

2017-02-17 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/3334 Thank you for opening this pull request. I'll try to review it in the coming days... --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as

[GitHub] flink issue #3223: [FLINK-5669] Change DataStreamUtils to use the loopback a...

2017-02-17 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/3223 This change looks good, thank you! Merging 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 does

[GitHub] flink issue #3204: [FLINK-5634] Flink should not always redirect stdout to a...

2017-02-17 Thread greghogan
Github user greghogan commented on the issue: https://github.com/apache/flink/pull/3204 This is now looking like a game of hot potato :) I'm happy to let @iemejia create the PR but he had offered the same to me. If I don't hear otherwise first I'll create a PR for FLINK-4326. While

[jira] [Commented] (FLINK-5634) Flink should not always redirect stdout to a file.

2017-02-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15872294#comment-15872294 ] ASF GitHub Bot commented on FLINK-5634: --- Github user greghogan commented on the issue:

[jira] [Commented] (FLINK-5414) Bump up Calcite version to 1.11

2017-02-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15872765#comment-15872765 ] ASF GitHub Bot commented on FLINK-5414: --- Github user haohui commented on the issue:

[GitHub] flink issue #3338: [FLINK-5414] [table] Bump up Calcite version to 1.11

2017-02-17 Thread haohui
Github user haohui commented on the issue: https://github.com/apache/flink/pull/3338 Looks good to me overall. One question -- I wonder, does it mean that all array types become nullable after this change? --- If your project is set up for it, you can reply to this email and have

[jira] [Updated] (FLINK-4819) Checkpoint metadata+data inspection tool (view / update)

2017-02-17 Thread Zhenzhong Xu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4819?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhenzhong Xu updated FLINK-4819: Description: Checkpoint inspection tool for operationalization, troubleshooting, diagnostics, etc,

[GitHub] flink pull request #3353: Multithreaded `DataSet#flatMap` function

2017-02-17 Thread mohamagdy
GitHub user mohamagdy opened a pull request: https://github.com/apache/flink/pull/3353 Multithreaded `DataSet#flatMap` function # Mutli-Threaded FlatMap ## Overview The DataStream#flatMap function takes a FlatMapFunction interface that has a method named flatMap

[jira] [Resolved] (FLINK-4660) HadoopFileSystem (with S3A) may leak connections, which cause job to stuck in a restarting loop

2017-02-17 Thread Zhenzhong Xu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4660?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhenzhong Xu resolved FLINK-4660. - Resolution: Fixed > HadoopFileSystem (with S3A) may leak connections, which cause job to stuck in

[jira] [Commented] (FLINK-4660) HadoopFileSystem (with S3A) may leak connections, which cause job to stuck in a restarting loop

2017-02-17 Thread Zhenzhong Xu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15872727#comment-15872727 ] Zhenzhong Xu commented on FLINK-4660: - This is fixed,closing. > HadoopFileSystem (with S3A) may leak

[jira] [Closed] (FLINK-4660) HadoopFileSystem (with S3A) may leak connections, which cause job to stuck in a restarting loop

2017-02-17 Thread Zhenzhong Xu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4660?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhenzhong Xu closed FLINK-4660. --- > HadoopFileSystem (with S3A) may leak connections, which cause job to stuck in > a restarting loop >

[jira] [Commented] (FLINK-5414) Bump up Calcite version to 1.11

2017-02-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15873024#comment-15873024 ] ASF GitHub Bot commented on FLINK-5414: --- Github user wuchong commented on the issue:

[GitHub] flink issue #3338: [FLINK-5414] [table] Bump up Calcite version to 1.11

2017-02-17 Thread wuchong
Github user wuchong commented on the issue: https://github.com/apache/flink/pull/3338 Hi @fhueske , yes, Calcite forces an Calc after each aggregate that only renames fields, because we rename every aggregates in Table API which is not necessary. I changed the logic of getting

[jira] [Updated] (FLINK-5839) Flink Security problem collection

2017-02-17 Thread shijinkui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5839?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] shijinkui updated FLINK-5839: - Summary: Flink Security problem collection (was: Flink Security in Huawei's use case) > Flink Security

[jira] [Updated] (FLINK-5818) change checkpoint dir permission to 700 for security reason

2017-02-17 Thread shijinkui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5818?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] shijinkui updated FLINK-5818: - Issue Type: Sub-task (was: Improvement) Parent: FLINK-5839 > change checkpoint dir permission to

[jira] [Updated] (FLINK-5546) java.io.tmpdir setted as project build directory in surefire plugin

2017-02-17 Thread shijinkui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5546?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] shijinkui updated FLINK-5546: - Issue Type: Sub-task (was: Test) Parent: FLINK-5839 > java.io.tmpdir setted as project build

[jira] [Updated] (FLINK-5640) configure the explicit Unit Test file suffix

2017-02-17 Thread shijinkui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5640?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] shijinkui updated FLINK-5640: - Issue Type: Sub-task (was: Test) Parent: FLINK-5839 > configure the explicit Unit Test file

[jira] [Commented] (FLINK-3679) DeserializationSchema should handle zero or more outputs for every input

2017-02-17 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3679?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15873009#comment-15873009 ] Tzu-Li (Gordon) Tai commented on FLINK-3679: Hi [~wheat9], sure! I've noticed your PR, and

[GitHub] flink issue #3246: [FLINK-5353] [elasticsearch] User-provided failure handle...

2017-02-17 Thread tzulitai
Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/3246 Hi @fpompermaier, sorry I was busy with other stuff over the last week. I hope to work towards merging this by the end of next week! --- If your project is set up for it, you can reply to this

[jira] [Commented] (FLINK-5353) Elasticsearch Sink loses well-formed documents when there are malformed documents

2017-02-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5353?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15873008#comment-15873008 ] ASF GitHub Bot commented on FLINK-5353: --- Github user tzulitai commented on the issue:

[jira] [Created] (FLINK-5839) Flink Security in Huawei's use case

2017-02-17 Thread shijinkui (JIRA)
shijinkui created FLINK-5839: Summary: Flink Security in Huawei's use case Key: FLINK-5839 URL: https://issues.apache.org/jira/browse/FLINK-5839 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-5739) NullPointerException in CliFrontend

2017-02-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15872914#comment-15872914 ] ASF GitHub Bot commented on FLINK-5739: --- Github user clarkyzl commented on the issue:

[GitHub] flink issue #3292: [FLINK-5739] [client] fix NullPointerException in CliFron...

2017-02-17 Thread clarkyzl
Github user clarkyzl commented on the issue: https://github.com/apache/flink/pull/3292 Thanks a lot --- 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

[jira] [Commented] (FLINK-5682) Fix scala version in flink-streaming-scala POM file

2017-02-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5682?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15872986#comment-15872986 ] ASF GitHub Bot commented on FLINK-5682: --- Github user billliuatuber closed the pull request at:

[GitHub] flink pull request #3231: [FLINK-5682] Fix scala version in flink-streaming-...

2017-02-17 Thread billliuatuber
Github user billliuatuber closed the pull request at: https://github.com/apache/flink/pull/3231 --- 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

[jira] [Commented] (FLINK-5795) Improve “UDTF" to support constructor with parameter.

2017-02-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15873010#comment-15873010 ] ASF GitHub Bot commented on FLINK-5795: --- Github user wuchong commented on a diff in the pull

[jira] [Commented] (FLINK-5818) change checkpoint dir permission to 700 for security reason

2017-02-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5818?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15873048#comment-15873048 ] ASF GitHub Bot commented on FLINK-5818: --- Github user WangTaoTheTonic commented on the issue:

[GitHub] flink issue #3335: [FLINK-5818][Security]change checkpoint dir permission to...

2017-02-17 Thread WangTaoTheTonic
Github user WangTaoTheTonic commented on the issue: https://github.com/apache/flink/pull/3335 I've read all guys and list preconditions and solutions for this directory permission setting. ## Preconditions 1. Every flink job(session or single) can specify a directory

[GitHub] flink pull request #3269: [FLINK-5698] Add NestedFieldsProjectableTableSourc...

2017-02-17 Thread wuchong
Github user wuchong commented on a diff in the pull request: https://github.com/apache/flink/pull/3269#discussion_r101887738 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/rules/util/RexProgramProjectExtractor.scala --- @@ -84,6 +105,39 @@ object

  1   2   3   >