GitHub user shijinkui opened a pull request:
https://github.com/apache/flink/pull/3051
Flink 5399
Add checkpointId and triggerTime to TriggerSavepointSuccess
We can record the history of trigger checkpoint out of Flink System.
- [X] General
- The pull request
[
https://issues.apache.org/jira/browse/FLINK-5399?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15784687#comment-15784687
]
ASF GitHub Bot commented on FLINK-5399:
---
GitHub user shijinkui opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-5303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15784659#comment-15784659
]
ASF GitHub Bot commented on FLINK-5303:
---
Github user KurtYoung commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-5303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15784656#comment-15784656
]
ASF GitHub Bot commented on FLINK-5303:
---
Github user KurtYoung commented on a diff in the pull
Github user KurtYoung commented on a diff in the pull request:
https://github.com/apache/flink/pull/2976#discussion_r94104843
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/AggregateUtil.scala
---
@@ -98,7 +98,9 @@ object
Github user KurtYoung commented on a diff in the pull request:
https://github.com/apache/flink/pull/2976#discussion_r94104787
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/AggregateReduceGroupFunction.scala
---
@@ -40,6 +40,7 @@
[
https://issues.apache.org/jira/browse/FLINK-5303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15784657#comment-15784657
]
ASF GitHub Bot commented on FLINK-5303:
---
Github user KurtYoung commented on a diff in the pull
Github user KurtYoung commented on a diff in the pull request:
https://github.com/apache/flink/pull/2976#discussion_r94104766
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/AggregateReduceCombineFunction.scala
---
@@ -41,12 +41,14 @@
[
https://issues.apache.org/jira/browse/FLINK-5303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15784651#comment-15784651
]
ASF GitHub Bot commented on FLINK-5303:
---
Github user KurtYoung commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-5303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15784650#comment-15784650
]
ASF GitHub Bot commented on FLINK-5303:
---
Github user KurtYoung commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-5303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15784652#comment-15784652
]
ASF GitHub Bot commented on FLINK-5303:
---
Github user KurtYoung commented on a diff in the pull
Github user KurtYoung commented on a diff in the pull request:
https://github.com/apache/flink/pull/2976#discussion_r94104657
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamAggregate.scala
---
@@ -207,7 +210,9 @@ class
Github user KurtYoung commented on a diff in the pull request:
https://github.com/apache/flink/pull/2976#discussion_r94104637
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamAggregate.scala
---
@@ -70,7 +71,9 @@ class
Github user KurtYoung commented on a diff in the pull request:
https://github.com/apache/flink/pull/2976#discussion_r94104624
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/dataset/DataSetAggregate.scala
---
@@ -104,7 +107,9 @@ class
shijinkui created FLINK-5399:
Summary: Add more information to checkpoint result of
TriggerSavepointSuccess
Key: FLINK-5399
URL: https://issues.apache.org/jira/browse/FLINK-5399
Project: Flink
Xiaogang Shi created FLINK-5398:
---
Summary: Exclude generated files in module flink-batch-connectors
in license checking
Key: FLINK-5398
URL: https://issues.apache.org/jira/browse/FLINK-5398
Project:
[
https://issues.apache.org/jira/browse/FLINK-5280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15784253#comment-15784253
]
ASF GitHub Bot commented on FLINK-5280:
---
Github user wuchong commented on a diff in the pull
Github user wuchong commented on a diff in the pull request:
https://github.com/apache/flink/pull/3039#discussion_r94095173
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/utils/UserDefinedFunctionUtils.scala
---
@@ -268,23 +268,9 @@ object
Github user mushketyk commented on a diff in the pull request:
https://github.com/apache/flink/pull/3039#discussion_r94087339
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/utils/UserDefinedFunctionUtils.scala
---
@@ -268,23 +268,9 @@ object
[
https://issues.apache.org/jira/browse/FLINK-5280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15783939#comment-15783939
]
ASF GitHub Bot commented on FLINK-5280:
---
Github user mushketyk commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-5397?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15782811#comment-15782811
]
Xiaogang Shi commented on FLINK-5397:
-
The idea does work and is better. Very thanks for the quick fix
[
https://issues.apache.org/jira/browse/FLINK-5397?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15782747#comment-15782747
]
Stefan Richter commented on FLINK-5397:
---
Thanks for pointing out this problem. I opened a PR #3050
[
https://issues.apache.org/jira/browse/FLINK-5397?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter reassigned FLINK-5397:
-
Assignee: Stefan Richter
> Fail to deserialize savepoints in v1.1 when there exist
[
https://issues.apache.org/jira/browse/FLINK-4641?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Chermenin reassigned FLINK-4641:
--
Assignee: Alexander Chermenin
> Support branching CEP patterns
>
[
https://issues.apache.org/jira/browse/FLINK-4540?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Roman Maier reassigned FLINK-4540:
--
Assignee: Roman Maier
> Detached job execution may prevent cluster shutdown
>
[
https://issues.apache.org/jira/browse/FLINK-5397?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xiaogang Shi updated FLINK-5397:
Description:
To restore from the savepoints in previous versions, Flink now keeps all
classes
Xiaogang Shi created FLINK-5397:
---
Summary: Fail to deserialize savepoints in v1.1 when there exist
missing fields in class serialization descriptors
Key: FLINK-5397
URL:
[
https://issues.apache.org/jira/browse/FLINK-3615?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15782410#comment-15782410
]
Alexander Chermenin commented on FLINK-3615:
Hi all. Is it an actual issue or it has been
28 matches
Mail list logo