[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=15869647#comment-15869647 ] ASF GitHub Bot commented on FLINK-5773: --- Github user StephanEwen commented on the issue:

[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

[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

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

[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

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

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

[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=15869680#comment-15869680 ] Ufuk Celebi commented on FLINK-5742: [~colinbreame] Did you have time to look into it? > Breakpoints

[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=15869795#comment-15869795 ] ASF GitHub Bot commented on FLINK-5571: --- Github user godfreyhe commented on the issue:

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

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

[GitHub] flink issue #3285: [FLINK-4997] [streaming] Introduce ProcessWindowFunction

2017-02-16 Thread VenturaDelMonte
Github user VenturaDelMonte commented on the issue: https://github.com/apache/flink/pull/3285 Sure, I can take care of the all-window case! --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have

[GitHub] flink pull request #3324: [backport] [FLINK-5773] Use akka.actor.Status.Fail...

2017-02-16 Thread tillrohrmann
Github user tillrohrmann closed the pull request at: https://github.com/apache/flink/pull/3324 --- 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-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=15870194#comment-15870194 ] ASF GitHub Bot commented on FLINK-5773: --- Github user tillrohrmann closed the pull request at:

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

2017-02-16 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5705?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-5705. - Resolution: Fixed Fix Version/s: 1.3.0 Fixed in - 1.2.1 via

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

2017-02-16 Thread shijinkui
Github user shijinkui commented on the issue: https://github.com/apache/flink/pull/3190 > Here is a related issue: https://issues.apache.org/jira/browse/FLINK-5817 I sounds good. I want to change the default system property `java.io.tmpdir` to be in the `target` directory.

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

2017-02-16 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/3211 @shijinkui I think the Unite test include pattern is a good change, would merge that. Can we exclude the changes to the compiler configuration from the initial change? --- If your

[jira] [Resolved] (FLINK-5773) Cannot cast scala.util.Failure to org.apache.flink.runtime.messages.Acknowledge

2017-02-16 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5773?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-5773. -- Resolution: Fixed 1.3.0: 413609d13fcf924fa8581450618bccc6abdbbda0 1.2.1:

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

2017-02-16 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5811?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-5811. Resolution: Fixed Fix Version/s: 1.3.0 Fixed via 494edb041b5e8474c84eed563e9dfa4406240bb5 >

[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=15870199#comment-15870199 ] ASF GitHub Bot commented on FLINK-5640: --- Github user StephanEwen commented on the issue:

[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=15870109#comment-15870109 ] ASF GitHub Bot commented on FLINK-5546: --- Github user shijinkui commented on the issue:

[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=15870196#comment-15870196 ] ASF GitHub Bot commented on FLINK-5811: --- Github user tillrohrmann commented on the issue:

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

2017-02-16 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/3326 Thanks for your review @StephanEwen. Merging this 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

[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=15870205#comment-15870205 ] ASF GitHub Bot commented on FLINK-5705: --- Github user asfgit closed the pull request at:

[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 Merging --- 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] [Closed] (FLINK-5814) flink-dist creates wrong symlink when not used with cleaned before

2017-02-16 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5814?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-5814. --- > flink-dist creates wrong symlink when not used with cleaned before >

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

2017-02-16 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3257 --- 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-5705) webmonitor's request/response use UTF-8 explicitly

2017-02-16 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5705?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-5705. --- > webmonitor's request/response use UTF-8 explicitly > --

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

2017-02-16 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/3324 Thanks for your review @StephanEwen. Travis has passed. Merging this 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

[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=15870190#comment-15870190 ] ASF GitHub Bot commented on FLINK-5773: --- Github user tillrohrmann commented on the issue:

[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=15870193#comment-15870193 ] ASF GitHub Bot commented on FLINK-5773: --- Github user asfgit closed the pull request at:

[GitHub] flink pull request #3321: [FLINK-5773] Use akka.actor.Status.Failure class t...

2017-02-16 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3321 --- 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-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=15870210#comment-15870210 ] ASF GitHub Bot commented on FLINK-5624: --- Github user fhueske commented on the issue:

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

2017-02-16 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5814?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-5814. - Resolution: Fixed Fix Version/s: 1.2.1 1.3.0 Fixed in - 1.2.1 via

[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=15870073#comment-15870073 ] ASF GitHub Bot commented on FLINK-5640: --- Github user shijinkui commented on the issue:

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

2017-02-16 Thread shijinkui
Github user shijinkui commented on the issue: https://github.com/apache/flink/pull/3211 @StephanEwen Thank for your quickly reviewing. >`**/*Test.*` This can clearly show what unit test's file name like, just like `integration-tests` does. If omitting the `include`, it means

[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=15870186#comment-15870186 ] ASF GitHub Bot commented on FLINK-5773: --- Github user tillrohrmann commented on the issue:

[GitHub] flink issue #3321: [FLINK-5773] Use akka.actor.Status.Failure class to send ...

2017-02-16 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/3321 Thanks for the review @StephanEwen. Tests have passed on Travis. Merging this PR. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as

[GitHub] flink pull request #3326: [FLINK-5811] [tests] Harden YarnClusterDescriptorT...

2017-02-16 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3326 --- 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-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=15870201#comment-15870201 ] ASF GitHub Bot commented on FLINK-5811: --- Github user asfgit closed the pull request at:

[GitHub] flink issue #3311: [FLINK-5799] Let RpcService.scheduleRunnable return a Sch...

2017-02-16 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/3311 Thanks for the review @StephanEwen. You mean something like the `Executor` interface with the additional methods for the scheduled execution. Differently said, removing the `Service`

[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=15870230#comment-15870230 ] ASF GitHub Bot commented on FLINK-5640: --- Github user shijinkui 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=15870238#comment-15870238 ] ASF GitHub Bot commented on FLINK-4813: --- Github user NicoK commented on the issue:

[GitHub] flink pull request #3322: [FLINK-4813][flink-test-utils] make the hadoop-min...

2017-02-16 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/3322#discussion_r101565321 --- Diff: flink-test-utils-parent/flink-test-utils/src/main/java/org/apache/flink/test/util/SecureTestEnvironment.java --- @@ -37,9 +37,39 @@ /**

[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=15870240#comment-15870240 ] ASF GitHub Bot commented on FLINK-4813: --- Github user StephanEwen commented on a diff in the pull

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

2017-02-16 Thread fhueske
Github user fhueske commented on the issue: https://github.com/apache/flink/pull/3302 Hi @huawei-flink, thanks for the update! The changes are now pretty much aligned with #3252. I'm in the process of merging #3252 (running last tests). It would be great if you could rebase

[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=15870226#comment-15870226 ] ASF GitHub Bot commented on FLINK-5710: --- Github user fhueske commented on the issue:

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

2017-02-16 Thread shijinkui
Github user shijinkui commented on the issue: https://github.com/apache/flink/pull/3211 @StephanEwen have finished that. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled

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

2017-02-16 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1725?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15870236#comment-15870236 ] Stephan Ewen commented on FLINK-1725: - I would like to make this user-driven. While it sounds like an

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

2017-02-16 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5624?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-5624. Resolution: Implemented Fix Version/s: 1.3.0 Implemented for 1.3.0 with

[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=15870346#comment-15870346 ] ASF GitHub Bot commented on FLINK-5710: --- Github user fhueske commented on the issue:

[jira] [Commented] (FLINK-5799) Let RpcService.scheduleRunnable return ScheduledFuture

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

[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=15870339#comment-15870339 ] ASF GitHub Bot commented on FLINK-5624: --- Github user asfgit closed the pull request at:

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

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

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

2017-02-16 Thread fhueske
Github user fhueske commented on the issue: https://github.com/apache/flink/pull/3302 FYI: PR #3252 was just merged. --- 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

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

2017-02-16 Thread NicoK
Github user NicoK commented on the issue: https://github.com/apache/flink/pull/3322 sure, that makes sense actually, I only had to add it to the flink-test-utils sub-project since all the others already included the bundler :) --- If your project is set up for it, you can reply

[jira] [Commented] (FLINK-5183) [py] Support multiple jobs per Python plan file

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

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

2017-02-16 Thread Haohui Mai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15870558#comment-15870558 ] Haohui Mai commented on FLINK-5414: --- [~jark], are there any progresses on this jira? We are interested

[GitHub] flink issue #3232: [FLINK-5183] [py] Support mulitple jobs per plan file

2017-02-16 Thread GEOFBOT
Github user GEOFBOT commented on the issue: https://github.com/apache/flink/pull/3232 > It may have worked with a smaller file, but there may be issues with heavier jobs. How silly of me. This problem had nothing to do with this pull request, with YARN, with issues in Flink,

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

2017-02-16 Thread Tao Wang (JIRA)
Tao Wang created FLINK-5825: --- Summary: In yarn mode, a small pic can not be loaded Key: FLINK-5825 URL: https://issues.apache.org/jira/browse/FLINK-5825 Project: Flink Issue Type: Bug

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

2017-02-16 Thread Zhuoluo Yang (JIRA)
Zhuoluo Yang created FLINK-5826: --- Summary: UDF/UDTF should support variable types and variable arguments Key: FLINK-5826 URL: https://issues.apache.org/jira/browse/FLINK-5826 Project: Flink

[jira] [Updated] (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:all-tabpanel ] Zhuoluo Yang updated FLINK-5826: Description: In some cases, UDF/UDTF should support variable types and variable arguments. Many

<    1   2