[jira] [Commented] (FLINK-8289) The RestServerEndpoint should return the address with real ip when getRestAdddress

2017-12-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16303119#comment-16303119 ] ASF GitHub Bot commented on FLINK-8289: --- Github user shuai-xu commented on a diff in the pull

[GitHub] flink pull request #5190: [FLINK-8289] [runtime] set the rest.address to the...

2017-12-24 Thread shuai-xu
Github user shuai-xu commented on a diff in the pull request: https://github.com/apache/flink/pull/5190#discussion_r158627004 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/entrypoint/ClusterEntrypoint.java --- @@ -155,6 +156,7 @@ protected void

[jira] [Commented] (FLINK-8289) The RestServerEndpoint should return the address with real ip when getRestAdddress

2017-12-24 Thread shuai.xu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16303117#comment-16303117 ] shuai.xu commented on FLINK-8289: - The RestServerEndpoint should never know whether there is a proxy, so I

[GitHub] flink issue #5206: [FLINK-8312][TableAPI && SQL] Fix ScalarFunction varargs ...

2017-12-24 Thread Xpray
Github user Xpray commented on the issue: https://github.com/apache/flink/pull/5206 Hi, @sunjincheng121 , thanks for the comments, I've updated this PR. ---

[jira] [Commented] (FLINK-8312) Fix ScalarFunction varargs length exceeds 254 for SQL

2017-12-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8312?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16303020#comment-16303020 ] ASF GitHub Bot commented on FLINK-8312: --- Github user Xpray commented on the issue:

[jira] [Updated] (FLINK-8043) change fullRestarts (for fine grained recovery) from guage to counter

2017-12-24 Thread Steven Zhen Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8043?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Steven Zhen Wu updated FLINK-8043: -- Description: Fine grained recovery publish fullRestarts as guage, which is not suitable for

[jira] [Commented] (FLINK-8312) Fix ScalarFunction varargs length exceeds 254 for SQL

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

[jira] [Commented] (FLINK-8312) Fix ScalarFunction varargs length exceeds 254 for SQL

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

[jira] [Commented] (FLINK-8312) Fix ScalarFunction varargs length exceeds 254 for SQL

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

[GitHub] flink pull request #5206: [FLINK-8312][TableAPI && SQL] Fix ScalarFunction v...

2017-12-24 Thread sunjincheng121
Github user sunjincheng121 commented on a diff in the pull request: https://github.com/apache/flink/pull/5206#discussion_r158604394 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/utils/ScalarSqlFunction.scala --- @@ -153,15 +154,19 @@ object

[GitHub] flink pull request #5206: [FLINK-8312][TableAPI && SQL] Fix ScalarFunction v...

2017-12-24 Thread sunjincheng121
Github user sunjincheng121 commented on a diff in the pull request: https://github.com/apache/flink/pull/5206#discussion_r158603997 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/utils/ScalarSqlFunction.scala --- @@ -153,15 +154,19 @@ object

[GitHub] flink pull request #5206: [FLINK-8312][TableAPI && SQL] Fix ScalarFunction v...

2017-12-24 Thread sunjincheng121
Github user sunjincheng121 commented on a diff in the pull request: https://github.com/apache/flink/pull/5206#discussion_r158603987 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/stream/sql/SqlITCase.scala --- @@ -481,4 +484,34 @@ class

[jira] [Commented] (FLINK-8301) Support Unicode in codegen for SQL && TableAPI

2017-12-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8301?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16302839#comment-16302839 ] ASF GitHub Bot commented on FLINK-8301: --- Github user Xpray commented on the issue:

[GitHub] flink issue #5203: [FLINK-8301] Support Unicode in codegen for SQL && TableA...

2017-12-24 Thread Xpray
Github user Xpray commented on the issue: https://github.com/apache/flink/pull/5203 Thanks to @sunjincheng121 , the PR has updated. ---

[jira] [Assigned] (FLINK-8317) Enable Triggering of Savepoints via RestfulGateway

2017-12-24 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8317?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao reassigned FLINK-8317: --- Assignee: Gary Yao > Enable Triggering of Savepoints via RestfulGateway >

[jira] [Updated] (FLINK-8317) Enable Triggering of Savepoints via RestfulGateway

2017-12-24 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8317?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-8317: Description: Enable triggering of savepoints via RestfulGateway: * Add method to {{CompletableFuture

[jira] [Updated] (FLINK-8317) Enable Triggering of Savepoints via RestfulGateway

2017-12-24 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8317?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-8317: Description: Enable triggering of savepoints in FLIP-6 mode via RestfulGateway: * Add method to

[jira] [Updated] (FLINK-8317) Enable triggering of Savepoints via RestfulGateway

2017-12-24 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8317?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-8317: Description: Enable triggering of savepoints via RestfulGateway. (was: Enable triggering of savepoints via

[jira] [Created] (FLINK-8317) Expose met triggering of Savepoints via HTTP

2017-12-24 Thread Gary Yao (JIRA)
Gary Yao created FLINK-8317: --- Summary: Expose met triggering of Savepoints via HTTP Key: FLINK-8317 URL: https://issues.apache.org/jira/browse/FLINK-8317 Project: Flink Issue Type: New Feature

[jira] [Closed] (FLINK-7780) Integrate savepoint command into REST client

2017-12-24 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7780?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao closed FLINK-7780. --- Resolution: Fixed Re-opened to edit the labels. > Integrate savepoint command into REST client >

[jira] [Updated] (FLINK-7780) Integrate savepoint command into REST client

2017-12-24 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7780?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-7780: Labels: flip-6 (was: ) > Integrate savepoint command into REST client >

[jira] [Reopened] (FLINK-7780) Integrate savepoint command into REST client

2017-12-24 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7780?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao reopened FLINK-7780: - Assignee: Gary Yao (was: Chesnay Schepler) > Integrate savepoint command into REST client >

[jira] [Commented] (FLINK-4834) Implement unified High Availability Services Abstraction

2017-12-24 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4834?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16302812#comment-16302812 ] Gary Yao commented on FLINK-4834: - All subtasks are done. Can this be closed? > Implement unified High

[jira] [Closed] (FLINK-8231) Extend AbstractRestHandler to return response headers

2017-12-24 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8231?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao closed FLINK-8231. --- Resolution: Won't Do Not needed for now. > Extend AbstractRestHandler to return response headers >

[jira] [Commented] (FLINK-8299) Retrieve ExecutionResult by REST polling

2017-12-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8299?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16302807#comment-16302807 ] ASF GitHub Bot commented on FLINK-8299: --- GitHub user GJL opened a pull request:

[GitHub] flink pull request #5207: [FLINK-8299][flip6] Poll JobExecutionResult after ...

2017-12-24 Thread GJL
GitHub user GJL opened a pull request: https://github.com/apache/flink/pull/5207 [FLINK-8299][flip6] Poll JobExecutionResult after job submission ## What is the purpose of the change *Poll JobExecutionResult after job submission. This is needed, for example, to enable

[jira] [Commented] (FLINK-8301) Support Unicode in codegen for SQL && TableAPI

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

[jira] [Commented] (FLINK-8301) Support Unicode in codegen for SQL && TableAPI

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

[jira] [Commented] (FLINK-8301) Support Unicode in codegen for SQL && TableAPI

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

[jira] [Commented] (FLINK-8301) Support Unicode in codegen for SQL && TableAPI

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

[GitHub] flink pull request #5203: [FLINK-8301] Support Unicode in codegen for SQL &&...

2017-12-24 Thread sunjincheng121
Github user sunjincheng121 commented on a diff in the pull request: https://github.com/apache/flink/pull/5203#discussion_r158598552 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/stream/sql/SqlITCase.scala --- @@ -481,4 +484,84 @@ class

[GitHub] flink pull request #5203: [FLINK-8301] Support Unicode in codegen for SQL &&...

2017-12-24 Thread sunjincheng121
Github user sunjincheng121 commented on a diff in the pull request: https://github.com/apache/flink/pull/5203#discussion_r158598528 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/batch/table/CalcITCase.scala --- @@ -541,6 +541,48 @@ class

[GitHub] flink pull request #5203: [FLINK-8301] Support Unicode in codegen for SQL &&...

2017-12-24 Thread sunjincheng121
Github user sunjincheng121 commented on a diff in the pull request: https://github.com/apache/flink/pull/5203#discussion_r158598561 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/stream/table/CalcITCase.scala --- @@ -352,4 +354,64 @@ class

[GitHub] flink pull request #5203: [FLINK-8301] Support Unicode in codegen for SQL &&...

2017-12-24 Thread sunjincheng121
Github user sunjincheng121 commented on a diff in the pull request: https://github.com/apache/flink/pull/5203#discussion_r158598514 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/batch/sql/CalcITCase.scala --- @@ -352,6 +353,72 @@ class