[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&focusedCommentId=15869904#comment-15869904 ] ASF GitHub Bot commented on FLINK-5818: --- Github user StephanEwen commented on the is

[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 corr

[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

[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: Su

[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-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] [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 Com

[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 enab

[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&focusedCommentId=15869824#comment-15869824 ] ASF GitHub Bot commented on FLINK-5814: --- Github user asfgit closed the pull request

[jira] [Commented] (FLINK-5571) add open and close methods for UserDefinedFunction in TableAPI & SQL

2017-02-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5571?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15869795#comment-15869795 ] ASF GitHub Bot commented on FLINK-5571: --- Github user godfreyhe commented on the issu

[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 #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, whic

[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&focusedCommentId=15869776#comment-15869776 ] ASF GitHub Bot commented on FLINK-5818: --- GitHub user WangTaoTheTonic opened a pull r

[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&focusedCommentId=15869773#comment-15869773 ] ASF GitHub Bot commented on FLINK-4810: --- GitHub user ramkrish86 opened a pull reques

[GitHub] flink pull request #3334: FLINK-4810 Checkpoint Coordinator should fail Exec...

2017-02-16 Thread ramkrish86
GitHub user ramkrish86 opened a pull request: https://github.com/apache/flink/pull/3334 FLINK-4810 Checkpoint Coordinator should fail ExecutionGraph after "n" unsuccessful checkpoints unsuccessful checkpoints Thanks for contributing to Apache Flink. Before you open your pul

[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] [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 mig

[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&focusedCommentId=15869741#comment-15869741 ] Aljoscha Krettek commented on FLINK-1725: - I think this issue is a bit more compli

[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 #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 a

[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&focusedCommentId=15869734#comment-15869734 ] ASF GitHub Bot commented on FLINK-5751: --- GitHub user uce opened a pull request:

[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&focusedCommentId=15869704#comment-15869704 ] Wenlong Lyu commented on FLINK-5817: ok, It seems good, I will try it instead of addin

[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&focusedCommentId=15869687#comment-15869687 ] Stephan Ewen commented on FLINK-5817: - I would encourage you to use the JUnit tool to

[jira] [Commented] (FLINK-5742) Breakpoints on documentation website

2017-02-16 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5742?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15869680#comment-15869680 ] Ufuk Celebi commented on FLINK-5742: [~colinbreame] Did you have time to look into it?

[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

[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-5773) Cannot cast scala.util.Failure to org.apache.flink.runtime.messages.Acknowledge

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

[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 feat

[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 wis

[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&focusedCommentId=15869646#comment-15869646 ] ASF GitHub Bot commented on FLINK-5811: --- Github user StephanEwen commented on the is

[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 th

[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

[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 > ---

[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&focusedCommentId=15869604#comment-15869604 ] Till Rohrmann commented on FLINK-3687: -- Another instance: https://api.travis-ci.org/j

[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] [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 func

[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&focusedCommentId=15869597#comment-15869597 ] Pedro Lima Monteiro commented on FLINK-5816: Hello Fabian, Thank you for the

[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&focusedCommentId=15869597#comment-15869597 ] Pedro Lima Monteiro edited comment on FLINK-5816 at 2/16/17 9:24 AM: ---

[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 (m

[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&focusedCommentId=15869589#comment-15869589 ] Fabian Hueske commented on FLINK-5816: -- Hi [~pedromlm], we use JIRA to track bugs and

[GitHub] flink pull request #3329: [FLINK-5751] Fix some broken links in docs

2017-02-16 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3329 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enab

[jira] [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 UNBOUND

[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&focusedCommentId=15869578#comment-15869578 ] ASF GitHub Bot commented on FLINK-5751: --- Github user asfgit closed the pull request

[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 Issue

[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 timeou

[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&focusedCommentId=15869569#comment-15869569 ] ASF GitHub Bot commented on FLINK-5616: --- Github user StephanEwen commented on the 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&focusedCommentId=15869565#comment-15869565 ] ASF GitHub Bot commented on FLINK-5814: --- Github user StephanEwen commented on the is

[GitHub] flink issue #3331: [FLINK-5814] fix packaging flink-dist in unclean source d...

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

[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: https://issues.apache.org/jira/brows

[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&focusedCommentId=15869560#comment-15869560 ] Till Rohrmann commented on FLINK-5616: -- Forget what I've written. It simply is a race

[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: Improvem

[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&focusedCommentId=15869534#comment-15869534 ] ASF GitHub Bot commented on FLINK-5420: --- Github user kl0u closed the pull request at

[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 enable

[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&focusedCommentId=15869530#comment-15869530 ] ASF GitHub Bot commented on FLINK-5814: --- GitHub user NicoK opened a pull request:

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

2017-02-16 Thread NicoK
GitHub user NicoK opened a pull request: https://github.com/apache/flink/pull/3331 [FLINK-5814] fix packaging flink-dist in unclean source directory If `/build-target` already existed, running `mvn package` for flink-dist would create a symbolic link inside `/build-target` in

[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

[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&focusedCommentId=15869518#comment-15869518 ] ASF GitHub Bot commented on FLINK-5588: --- Github user tillrohrmann commented on the i

[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 th

[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&focusedCommentId=15869488#comment-15869488 ] sunjincheng commented on FLINK-5792: BYW, when I implement the issue, I had try to use

[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&focusedCommentId=15869473#comment-15869473 ] sunjincheng commented on FLINK-5792: HI, [~fhueske] Thanks for your attention to this

[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&focusedCommentId=15869450#comment-15869450 ] ASF GitHub Bot commented on FLINK-5786: --- Github user mylog00 commented on the issue:

<    1   2