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 Calc
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 CalcITC
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 SqlITCa
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 CalcI
[
https://issues.apache.org/jira/browse/FLINK-8301?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16302802#comment-16302802
]
ASF GitHub Bot commented on FLINK-8301:
---
Github user sunjincheng121 commented on a d
[
https://issues.apache.org/jira/browse/FLINK-8301?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16302804#comment-16302804
]
ASF GitHub Bot commented on FLINK-8301:
---
Github user sunjincheng121 commented on a d
[
https://issues.apache.org/jira/browse/FLINK-8301?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16302803#comment-16302803
]
ASF GitHub Bot commented on FLINK-8301:
---
Github user sunjincheng121 commented on a d
[
https://issues.apache.org/jira/browse/FLINK-8301?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16302801#comment-16302801
]
ASF GitHub Bot commented on FLINK-8301:
---
Github user sunjincheng121 commented on a d
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 `coll
[
https://issues.apache.org/jira/browse/FLINK-8299?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16302807#comment-16302807
]
ASF GitHub Bot commented on FLINK-8299:
---
GitHub user GJL opened a pull request:
[
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
> --
[
https://issues.apache.org/jira/browse/FLINK-4834?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16302812#comment-16302812
]
Gary Yao commented on FLINK-4834:
-
All subtasks are done. Can this be closed?
> Implement
[
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
> ---
[
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
> ---
[
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
>
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
[
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
[
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 {{Completabl
[
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
> ---
[
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 trigger
Github user Xpray commented on the issue:
https://github.com/apache/flink/pull/5203
Thanks to @sunjincheng121 , the PR has updated.
---
[
https://issues.apache.org/jira/browse/FLINK-8301?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16302839#comment-16302839
]
ASF GitHub Bot commented on FLINK-8301:
---
Github user Xpray commented on the issue:
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 SqlITCa
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 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
[
https://issues.apache.org/jira/browse/FLINK-8312?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16302867#comment-16302867
]
ASF GitHub Bot commented on FLINK-8312:
---
Github user sunjincheng121 commented on a d
[
https://issues.apache.org/jira/browse/FLINK-8312?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16302868#comment-16302868
]
ASF GitHub Bot commented on FLINK-8312:
---
Github user sunjincheng121 commented on a d
[
https://issues.apache.org/jira/browse/FLINK-8312?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16302866#comment-16302866
]
ASF GitHub Bot commented on FLINK-8312:
---
Github user sunjincheng121 commented on a d
[
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
thr
[
https://issues.apache.org/jira/browse/FLINK-8312?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16303020#comment-16303020
]
ASF GitHub Bot commented on FLINK-8312:
---
Github user Xpray commented on the issue:
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.
---
[
https://issues.apache.org/jira/browse/FLINK-8289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16303117#comment-16303117
]
shuai.xu commented on FLINK-8289:
-
The RestServerEndpoint should never know whether there
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 runCluster(Configur
[
https://issues.apache.org/jira/browse/FLINK-8289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16303119#comment-16303119
]
ASF GitHub Bot commented on FLINK-8289:
---
Github user shuai-xu commented on a diff in
34 matches
Mail list logo