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

2017-02-16 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15869473#comment-15869473 ] sunjincheng commented on FLINK-5792: HI, [~fhueske] Thanks for your attention to this JIRA. Thanks

[jira] [Commented] (FLINK-5786) Add support GetClusterStatus message for standalong flink cluster

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

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

2017-02-16 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15869488#comment-15869488 ] sunjincheng commented on FLINK-5792: BYW, when I implement the issue, I had try to use `kryo`

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

2017-02-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5818?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15871046#comment-15871046 ] 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-16 Thread WangTaoTheTonic
Github user WangTaoTheTonic commented on the issue: https://github.com/apache/flink/pull/3335 Hi @greghogan , I'm not sure I understand the relationship between HDFS ACLs and this change I proposed. Could you explain more specifically? Thanks. --- If your project is set up for it,

[jira] [Commented] (FLINK-4856) Add MapState for keyed streams

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

[GitHub] flink pull request #3336: [FLINK-4856][state] Add MapState in KeyedState

2017-02-16 Thread shixiaogang
GitHub user shixiaogang opened a pull request: https://github.com/apache/flink/pull/3336 [FLINK-4856][state] Add MapState in KeyedState 1. Add `MapState` and `MapStateDescriptor` 2. Implementation of `MapState` in `HeapKeyedStateBackend` and `RocksDBKeyedStateBackend`. 3.

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

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

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

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

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

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

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

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

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

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

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

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

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

2017-02-16 Thread shijinkui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5817?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15871082#comment-15871082 ] shijinkui commented on FLINK-5817: -- [~StephanEwen] [~wenlong.lwl], there no overlapping between

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

2017-02-16 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15871154#comment-15871154 ] Jark Wu commented on FLINK-5414: Hi [~wheat9], sorry for the delay. Actually, I had some problems when

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

2017-02-16 Thread Zhuoluo Yang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15871230#comment-15871230 ] Zhuoluo Yang commented on FLINK-5792: - Hi [~sunjincheng121], I think this feature is very important to

[jira] [Comment Edited] (FLINK-5826) UDF/UDTF should support variable types and variable arguments

2017-02-16 Thread Zhuoluo Yang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5826?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15871338#comment-15871338 ] Zhuoluo Yang edited comment on FLINK-5826 at 2/17/17 7:33 AM: -- I have already

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

2017-02-16 Thread WangTaoTheTonic
GitHub user WangTaoTheTonic opened a pull request: https://github.com/apache/flink/pull/3337 [FLINK-5825][UI]make the cite path relative to show it correctly In yarn mode, the web frontend url is accessed from yarn in format like

[jira] [Commented] (FLINK-5825) In yarn mode, a small pic can not be loaded

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

[jira] [Commented] (FLINK-5826) UDF/UDTF should support variable types and variable arguments

2017-02-16 Thread Zhuoluo Yang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5826?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15871338#comment-15871338 ] Zhuoluo Yang commented on FLINK-5826: - I have already made a small modification in

[jira] [Created] (FLINK-5819) Improve metrics reporting

2017-02-16 Thread Paul Nelligan (JIRA)
Paul Nelligan created FLINK-5819: Summary: Improve metrics reporting Key: FLINK-5819 URL: https://issues.apache.org/jira/browse/FLINK-5819 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-5823) Store Checkpoint Root Metadata in StateBackend (not in HA custom store)

2017-02-16 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-5823: --- Summary: Store Checkpoint Root Metadata in StateBackend (not in HA custom store) Key: FLINK-5823 URL: https://issues.apache.org/jira/browse/FLINK-5823 Project: Flink

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

2017-02-16 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/3335 Thank you for the contribution. I see the idea behind the fix. I am unsure whether we should let Flink manage the permissions of these directories. My gut feeling is that this is

[jira] [Updated] (FLINK-5824) Fix String/byte conversions without explicit encoding

2017-02-16 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5824?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-5824: Priority: Blocker (was: Major) > Fix String/byte conversions without explicit encoding >

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

2017-02-16 Thread Tao Wang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5818?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tao Wang updated FLINK-5818: Hi Stephan, You may have a little misunderstanding about this change. It only controls directories with job

[jira] [Commented] (FLINK-5588) Add a unit scaler based on different norms

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

[GitHub] flink issue #3252: [FLINK-5624] Support tumbling window on streaming tables ...

2017-02-16 Thread fhueske
Github user fhueske commented on the issue: https://github.com/apache/flink/pull/3252 Thanks for the update @haohui. PR is 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

[jira] [Commented] (FLINK-5824) Fix String/byte conversions without explicit encoding

2017-02-16 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5824?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15869989#comment-15869989 ] Stephan Ewen commented on FLINK-5824: - We should add a checkstyle rule that forbids

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

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

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

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

[jira] [Created] (FLINK-5824) Fix String/byte conversion without explicit encodings

2017-02-16 Thread Ufuk Celebi (JIRA)
Ufuk Celebi created FLINK-5824: -- Summary: Fix String/byte conversion without explicit encodings Key: FLINK-5824 URL: https://issues.apache.org/jira/browse/FLINK-5824 Project: Flink Issue Type:

[GitHub] flink issue #3257: [FLINK-5705] [WebMonitor] request/response use UTF-8 expl...

2017-02-16 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/3257 The fix 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 this

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

2017-02-16 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/3190 Here is a related issue: https://issues.apache.org/jira/browse/FLINK-5817 --- 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] [Commented] (FLINK-5817) Fix test concurrent execution failure by test dir conflicts.

2017-02-16 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5817?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15869939#comment-15869939 ] Stephan Ewen commented on FLINK-5817: - There is also a pull request that tries to change the tmp

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

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

[GitHub] flink issue #3313: [FLINK-5588][ml] add a data normalizer to ml library

2017-02-16 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/3313 But please don't do a force push on a branch which has been opened as a PR. If there was a review ongoing, then the force push might invalidate it (e.g. if you changed something in the relevant

[GitHub] flink issue #3302: [FLINK-5710] Add ProcTime() function to indicate StreamSQ...

2017-02-16 Thread huawei-flink
Github user huawei-flink commented on the issue: https://github.com/apache/flink/pull/3302 @fhueske I've addressed most of the points, however there is a thing that is not clear to me yet. So far, the procTime() function generates a timestamp. My understanding is that this is not

[jira] [Created] (FLINK-5820) Extend State Backend Abstraction to support Global Cleanup Hooks

2017-02-16 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-5820: --- Summary: Extend State Backend Abstraction to support Global Cleanup Hooks Key: FLINK-5820 URL: https://issues.apache.org/jira/browse/FLINK-5820 Project: Flink

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

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

[jira] [Commented] (FLINK-5710) Add ProcTime() function to indicate StreamSQL

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

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

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

[jira] [Commented] (FLINK-5819) Improve metrics reporting

2017-02-16 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5819?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15870011#comment-15870011 ] Greg Hogan commented on FLINK-5819: --- Some charts were added in FLINK-2730 but had to be removed due to

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

2017-02-16 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/3322 Very good, I had stumbled over that problem as well. Could you also remove the bundle plugin from the root pom (this should speed up dependency resolutions in IDEs by a lot) and instead

[GitHub] flink issue #3211: [FLINK-5640][test]onfigure the explicit Unit Test file su...

2017-02-16 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/3211 Can you briefly explain what this fixes? Currently, it behaves exactly like you describe: The "test" phase executes the `*Test.java` and `*Test.scala` classes, and the "verify" phase executes

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

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

[GitHub] flink issue #3327: [FLINK-5616] [tests] Harden YarnIntraNonHaMasterServicesT...

2017-02-16 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/3327 True, this does not make much sense, what I've done here. Somehow I was under the assumption that `verify` will block until the call happened when I wrote it. Will correct it. Thanks for the

[jira] [Commented] (FLINK-5616) YarnPreConfiguredMasterHaServicesTest fails sometimes

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

[GitHub] flink issue #3313: [FLINK-5588][ml] add a data normalizer to ml library

2017-02-16 Thread greghogan
Github user greghogan commented on the issue: https://github.com/apache/flink/pull/3313 @skonto another option, if the master branch has a newer commit, is to rebase and force push. --- If your project is set up for it, you can reply to this email and have your reply appear on

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

2017-02-16 Thread greghogan
Github user greghogan commented on the issue: https://github.com/apache/flink/pull/3335 @WangTaoTheTonic HDFS supports posix ACLs ([link](http://hadoop.apache.org/docs/r2.4.1/hadoop-project-dist/hadoop-hdfs/HdfsPermissionsGuide.html#ACLs_Access_Control_Lists)). These are

[jira] [Commented] (FLINK-5588) Add a unit scaler based on different norms

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

[jira] [Commented] (FLINK-5616) YarnPreConfiguredMasterHaServicesTest fails sometimes

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

[jira] [Commented] (FLINK-3687) org.apache.flink.runtime.net.ConnectionUtilsTest fails

2017-02-16 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3687?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15869604#comment-15869604 ] Till Rohrmann commented on FLINK-3687: -- Another instance:

[jira] [Updated] (FLINK-3687) org.apache.flink.runtime.net.ConnectionUtilsTest fails

2017-02-16 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3687?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-3687: - Priority: Critical (was: Major) > org.apache.flink.runtime.net.ConnectionUtilsTest fails >

[jira] [Updated] (FLINK-3687) org.apache.flink.runtime.net.ConnectionUtilsTest fails

2017-02-16 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3687?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-3687: - Labels: test-stability (was: ) > org.apache.flink.runtime.net.ConnectionUtilsTest fails >

[GitHub] flink issue #3324: [backport] [FLINK-5773] Use akka.actor.Status.Failure cla...

2017-02-16 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/3324 +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

[jira] [Commented] (FLINK-5811) Harden YarnClusterDescriptorTest

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

[GitHub] flink issue #3326: [FLINK-5811] [tests] Harden YarnClusterDescriptorTest

2017-02-16 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/3326 I think this looks 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 and

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

2017-02-16 Thread Wenlong Lyu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5817?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15869704#comment-15869704 ] Wenlong Lyu commented on FLINK-5817: ok, It seems good, I will try it instead of adding a random

[jira] [Commented] (FLINK-1725) New Partitioner for better load balancing for skewed data

2017-02-16 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1725?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15869741#comment-15869741 ] Aljoscha Krettek commented on FLINK-1725: - I think this issue is a bit more complicated than it

[jira] [Updated] (FLINK-1725) New Partitioner for better load balancing for skewed data

2017-02-16 Thread Anis Nasir (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1725?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anis Nasir updated FLINK-1725: -- I guess the idea is to avoid shuffle grouping. For instance, if you have a cluster of 1000 machines, you

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

2017-02-16 Thread Tao Wang (JIRA)
Tao Wang created FLINK-5818: --- Summary: change checkpoint dir permission to 700 for security reason Key: FLINK-5818 URL: https://issues.apache.org/jira/browse/FLINK-5818 Project: Flink Issue Type:

[jira] [Created] (FLINK-5821) Create StateBackend root interface

2017-02-16 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-5821: --- Summary: Create StateBackend root interface Key: FLINK-5821 URL: https://issues.apache.org/jira/browse/FLINK-5821 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-5822) Make Checkpoint Coordinator aware of State Backend

2017-02-16 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-5822: --- Summary: Make Checkpoint Coordinator aware of State Backend Key: FLINK-5822 URL: https://issues.apache.org/jira/browse/FLINK-5822 Project: Flink Issue Type:

[jira] [Updated] (FLINK-5824) Fix String/byte conversions without explicit encoding

2017-02-16 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5824?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi updated FLINK-5824: --- Summary: Fix String/byte conversions without explicit encoding (was: Fix String/byte conversion

[jira] [Commented] (FLINK-5705) webmonitor's request/response use UTF-8 explicitly

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

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

2017-02-16 Thread WangTaoTheTonic
Github user WangTaoTheTonic commented on the issue: https://github.com/apache/flink/pull/3335 Hi Stephan, You may have a little misunderstanding about this change. It only controls directories with job id (generated using UUID), but not the configured root checkpoint

[jira] [Commented] (FLINK-5624) Support tumbling window on streaming tables in the SQL API

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

[jira] [Commented] (FLINK-5588) Add a unit scaler based on different norms

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

[GitHub] flink issue #3313: [FLINK-5588][ml] add a data normalizer to ml library

2017-02-16 Thread skonto
Github user skonto commented on the issue: https://github.com/apache/flink/pull/3313 Ok sorry for that I did squash the commits, also I am used to it from other projects where the comments are invalidated. --- If your project is set up for it, you can reply to this email and have

[jira] [Created] (FLINK-5814) flink-dist creates wrong symlink when not used with cleaned before

2017-02-16 Thread Nico Kruber (JIRA)
Nico Kruber created FLINK-5814: -- Summary: flink-dist creates wrong symlink when not used with cleaned before Key: FLINK-5814 URL: https://issues.apache.org/jira/browse/FLINK-5814 Project: Flink

[GitHub] flink issue #3327: [FLINK-5616] [tests] Harden YarnIntraNonHaMasterServicesT...

2017-02-16 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/3327 I am wondering if this is the same as the original timeout meaning. I though that using `verify` with a timeout will wait for a while until the call must have happened. Without the

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

2017-02-16 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5751?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-5751. -- Resolution: Fixed Fix Version/s: 1.2.1 1.3.0 67e3d9d (release-1.2), 67e3d9d

[jira] [Updated] (FLINK-1725) New Partitioner for better load balancing for skewed data

2017-02-16 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1725?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-1725: Component/s: (was: Local Runtime) DataStream API > New Partitioner for

[GitHub] flink pull request #3333: Webui/watermarks

2017-02-16 Thread nellboy
GitHub user nellboy opened a pull request: https://github.com/apache/flink/pull/ Webui/watermarks 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 of the items into

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

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

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

2017-02-16 Thread uce
GitHub user uce opened a pull request: https://github.com/apache/flink/pull/3332 [FLINK-5751] [docs] Add link check script This is a slightly adjusted script from @patricklucas as posted in FLINK-5751. I was wondering whether it makes sense to have it inside the repo, the

[GitHub] flink pull request #3331: [FLINK-5814] fix packaging flink-dist in unclean s...

2017-02-16 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3331 --- 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-5814) flink-dist creates wrong symlink when not used with cleaned before

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

[jira] [Commented] (FLINK-5588) Add a unit scaler based on different norms

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

[GitHub] flink issue #3313: [FLINK-5588][ml] add a data normalizer to ml library

2017-02-16 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/3313 Hi @skonto, if you have activated the Travis integration for your own repo, then you can restart the testing job there. For the apache account it is not possible. However, I've seen that only

[jira] [Created] (FLINK-5815) Add resource files configuration for Yarn Mode

2017-02-16 Thread Wenlong Lyu (JIRA)
Wenlong Lyu created FLINK-5815: -- Summary: Add resource files configuration for Yarn Mode Key: FLINK-5815 URL: https://issues.apache.org/jira/browse/FLINK-5815 Project: Flink Issue Type:

[jira] [Commented] (FLINK-5814) flink-dist creates wrong symlink when not used with cleaned before

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

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

2017-02-16 Thread Wenlong Lyu (JIRA)
Wenlong Lyu created FLINK-5817: -- Summary: Fix test concurrent execution failure by test dir conflicts. Key: FLINK-5817 URL: https://issues.apache.org/jira/browse/FLINK-5817 Project: Flink

[jira] [Comment Edited] (FLINK-5816) I would like to stream data from MongoDB using Flink's source function. Is this possible? Thank you.

2017-02-16 Thread Pedro Lima Monteiro (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5816?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15869597#comment-15869597 ] Pedro Lima Monteiro edited comment on FLINK-5816 at 2/16/17 9:24 AM: -

[jira] [Closed] (FLINK-5816) I would like to stream data from MongoDB using Flink's source function. Is this possible? Thank you.

2017-02-16 Thread Pedro Lima Monteiro (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5816?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Pedro Lima Monteiro closed FLINK-5816. -- Resolution: Invalid > I would like to stream data from MongoDB using Flink's source

[jira] [Commented] (FLINK-5816) I would like to stream data from MongoDB using Flink's source function. Is this possible? Thank you.

2017-02-16 Thread Pedro Lima Monteiro (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5816?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15869597#comment-15869597 ] Pedro Lima Monteiro commented on FLINK-5816: Hello Fabian, Thank you for the fast response. I

[jira] [Resolved] (FLINK-3687) org.apache.flink.runtime.net.ConnectionUtilsTest fails

2017-02-16 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3687?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-3687. -- Resolution: Duplicate Duplicate of FLINK-4052. Closing this issue because for the other issue

[jira] [Updated] (FLINK-3273) Remove Scala dependency from flink-streaming-java

2017-02-16 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3273?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-3273: Component/s: (was: Scala API) DataStream API > Remove Scala dependency

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

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

[jira] [Commented] (FLINK-5616) YarnPreConfiguredMasterHaServicesTest fails sometimes

2017-02-16 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5616?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15869560#comment-15869560 ] Till Rohrmann commented on FLINK-5616: -- Forget what I've written. It simply is a race condition

[jira] [Created] (FLINK-5816) I would like to stream data from MongoDB using Flink's source function. Is this possible? Thank you.

2017-02-16 Thread Pedro Lima Monteiro (JIRA)
Pedro Lima Monteiro created FLINK-5816: -- Summary: I would like to stream data from MongoDB using Flink's source function. Is this possible? Thank you. Key: FLINK-5816 URL:

[jira] [Commented] (FLINK-5816) I would like to stream data from MongoDB using Flink's source function. Is this possible? Thank you.

2017-02-16 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5816?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15869589#comment-15869589 ] Fabian Hueske commented on FLINK-5816: -- Hi [~pedromlm], we use JIRA to track bugs and discuss new

[jira] [Updated] (FLINK-4052) Unstable test ConnectionUtilsTest

2017-02-16 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4052?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-4052: - Affects Version/s: 1.3.0 > Unstable test ConnectionUtilsTest > -

[jira] [Reopened] (FLINK-4052) Unstable test ConnectionUtilsTest

2017-02-16 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4052?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reopened FLINK-4052: -- The problem still seems to persist: https://api.travis-ci.org/jobs/201937905/log.txt?deansi=true

[GitHub] flink pull request #3335: [FLINK-5818][Security]change checkpoint dir permis...

2017-02-16 Thread WangTaoTheTonic
GitHub user WangTaoTheTonic opened a pull request: https://github.com/apache/flink/pull/3335 [FLINK-5818][Security]change checkpoint dir permission to 700 Now checkpoint directory is made w/o specified permission, so it is easy for another user to delete or read files under it,

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

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

[GitHub] flink issue #3176: [FLINK-5571] [table] add open and close methods for UserD...

2017-02-16 Thread godfreyhe
Github user godfreyhe commented on the issue: https://github.com/apache/flink/pull/3176 Thanks for the suggestions @twalthr, I have updated the PR. --- 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

[GitHub] flink pull request #3307: [FLINK-5420] Make CEP operators rescalable

2017-02-16 Thread kl0u
Github user kl0u closed the pull request at: https://github.com/apache/flink/pull/3307 --- 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-5420) Make CEP operators rescalable

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

[jira] [Closed] (FLINK-5657) Add processing time OVER RANGE BETWEEN UNBOUNDED PRECEDING aggregation to SQL

2017-02-16 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5657?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng closed FLINK-5657. -- Resolution: Won't Fix Move to FLINK-5803 & FLINK-5804. > Add processing time OVER RANGE BETWEEN

  1   2   >