[
https://issues.apache.org/jira/browse/FLINK-8533?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16360404#comment-16360404
]
Tzu-Li (Gordon) Tai commented on FLINK-8533:
[~eronwright]thanks for the heads up on this
[
https://issues.apache.org/jira/browse/FLINK-8364?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16360389#comment-16360389
]
ASF GitHub Bot commented on FLINK-8364:
---
Github user bowenli86 commented on the issue:
Github user bowenli86 commented on the issue:
https://github.com/apache/flink/pull/5356
@StefanRRichter I think how `null` is handled is one major benefit, not
all. Another benefit is that `iterator()` is more intuitive in traversing all
values. For example, this change makes
[
https://issues.apache.org/jira/browse/FLINK-8638?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ran Tao closed FLINK-8638.
--
Resolution: Duplicate
> Job restart when Checkpoint On Barrier failed
>
[
https://issues.apache.org/jira/browse/FLINK-8638?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16360378#comment-16360378
]
Ran Tao commented on FLINK-8638:
[~yanghua] OK, thanks.
> Job restart when Checkpoint On Barrier failed
>
[
https://issues.apache.org/jira/browse/FLINK-8516?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16360377#comment-16360377
]
ASF GitHub Bot commented on FLINK-8516:
---
Github user tzulitai commented on the issue:
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/5393
@tweise changes look good, will merge this to `master`.
Thanks a lot for the work!
---
[
https://issues.apache.org/jira/browse/FLINK-8459?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang reassigned FLINK-8459:
---
Assignee: vinoyang
> Implement cancelWithSavepoint in RestClusterClient
>
[
https://issues.apache.org/jira/browse/FLINK-8459?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16360352#comment-16360352
]
vinoyang commented on FLINK-8459:
-
Hi [~gjy] , are you handling this issue? If not , can I assign to
[
https://issues.apache.org/jira/browse/FLINK-7711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16360348#comment-16360348
]
ASF GitHub Bot commented on FLINK-7711:
---
Github user GJL commented on a diff in the pull request:
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5455#discussion_r167474541
--- Diff:
flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/handlers/ng/JarListHandler.java
---
@@ -0,0 +1,156 @@
+/*
+ * Licensed to
[
https://issues.apache.org/jira/browse/FLINK-8638?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang reassigned FLINK-8638:
---
Assignee: (was: vinoyang)
> Job restart when Checkpoint On Barrier failed
>
[
https://issues.apache.org/jira/browse/FLINK-8638?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16360342#comment-16360342
]
vinoyang commented on FLINK-8638:
-
[~insomnia] , I also fixed this bug in our inner version. But I just
[
https://issues.apache.org/jira/browse/FLINK-8638?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16360292#comment-16360292
]
Ran Tao commented on FLINK-8638:
Hi， [~yanghua]
It is indeed the case. I fixed this bug in the inner
[
https://issues.apache.org/jira/browse/FLINK-8638?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16360273#comment-16360273
]
vinoyang commented on FLINK-8638:
-
Hi [~insomnia] , we also see this problem in our production
[
https://issues.apache.org/jira/browse/FLINK-8638?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang reassigned FLINK-8638:
---
Assignee: vinoyang
> Job restart when Checkpoint On Barrier failed
>
[
https://issues.apache.org/jira/browse/FLINK-8638?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ran Tao updated FLINK-8638:
---
Description:
The following example comes from the one snapshotState process by using hdfs,
snapshotState
Ran Tao created FLINK-8638:
--
Summary: Job restart when Checkpoint On Barrier failed
Key: FLINK-8638
URL: https://issues.apache.org/jira/browse/FLINK-8638
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-8636?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-8636:
-
Issue Type: Improvement (was: Bug)
> Pass TaskManagerServices to TaskExecutor
>
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/5457
[FLINK-8637] [flip6] Use JobManagerSharedServices to pass in services to
JobMaster
## What is the purpose of the change
Pass a JobManagerSharedServices instance to the JobMaster
[
https://issues.apache.org/jira/browse/FLINK-8637?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16360180#comment-16360180
]
ASF GitHub Bot commented on FLINK-8637:
---
GitHub user tillrohrmann opened a pull request:
Till Rohrmann created FLINK-8637:
Summary: Pass JobManagerSharedServices to JobMaster
Key: FLINK-8637
URL: https://issues.apache.org/jira/browse/FLINK-8637
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-8636?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16360177#comment-16360177
]
ASF GitHub Bot commented on FLINK-8636:
---
GitHub user tillrohrmann opened a pull request:
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/5456
[FLINK-8636] [flip6] Use TaskManagerServices to pass in services to
TaskExecutor
## What is the purpose of the change
Pass in the TaskExecutor services via the TaskManagerServices
Till Rohrmann created FLINK-8636:
Summary: Pass TaskManagerServices to TaskExecutor
Key: FLINK-8636
URL: https://issues.apache.org/jira/browse/FLINK-8636
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-8560?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16360156#comment-16360156
]
Bowen Li commented on FLINK-8560:
-
[~aljoscha] [~pnowojski] I have taken a look at this, and am wondering
[
https://issues.apache.org/jira/browse/FLINK-8297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16360123#comment-16360123
]
ASF GitHub Bot commented on FLINK-8297:
---
Github user je-ik commented on the issue:
Github user je-ik commented on the issue:
https://github.com/apache/flink/pull/5185
@aljoscha I (partly) reworked this PR as you suggest. There are still some
unresolved questions though:
1) I'm not 100% sure how to cleanly support the migration between list
state savepoints,
[
https://issues.apache.org/jira/browse/FLINK-6469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16359954#comment-16359954
]
ASF GitHub Bot commented on FLINK-6469:
---
Github user yanghua commented on the issue:
Github user yanghua commented on the issue:
https://github.com/apache/flink/pull/5448
Hi @StephanEwen , with the help of your `MemorySize` (sub task of
FLINK-6469)ï¼I finished the remained work, replaced the old memory config (in
codeãconfig file and shell script) with the memory
[
https://issues.apache.org/jira/browse/FLINK-7711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16359904#comment-16359904
]
ASF GitHub Bot commented on FLINK-7711:
---
GitHub user GJL opened a pull request:
GitHub user GJL opened a pull request:
https://github.com/apache/flink/pull/5455
[FLINK-7711][flip6] Port JarListHandler
## What is the purpose of the change
*Port JarListHandler.*
cc: @tillrohrmann
PR is based on #5442
## Brief change log
[
https://issues.apache.org/jira/browse/FLINK-7713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16359894#comment-16359894
]
ASF GitHub Bot commented on FLINK-7713:
---
Github user GJL commented on a diff in the pull request:
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5442#discussion_r167430276
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/webmonitor/WebMonitorUtils.java
---
@@ -207,6 +215,53 @@ public static WebMonitor
[
https://issues.apache.org/jira/browse/FLINK-7713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16359888#comment-16359888
]
ASF GitHub Bot commented on FLINK-7713:
---
Github user GJL commented on a diff in the pull request:
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5442#discussion_r167429820
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/webmonitor/WebMonitorUtils.java
---
@@ -207,6 +215,53 @@ public static WebMonitor
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5442#discussion_r167429671
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/webmonitor/WebMonitorUtils.java
---
@@ -207,6 +215,53 @@ public static WebMonitor
[
https://issues.apache.org/jira/browse/FLINK-7713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16359886#comment-16359886
]
ASF GitHub Bot commented on FLINK-7713:
---
Github user GJL commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-7713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16359885#comment-16359885
]
ASF GitHub Bot commented on FLINK-7713:
---
Github user GJL commented on a diff in the pull request:
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5442#discussion_r167429608
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/DispatcherRestEndpoint.java
---
@@ -100,6 +107,16 @@ public DispatcherRestEndpoint(
[
https://issues.apache.org/jira/browse/FLINK-7711?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gary Yao reassigned FLINK-7711:
---
Assignee: Gary Yao (was: Fang Yong)
> Port JarListHandler to new REST endpoint
>
[
https://issues.apache.org/jira/browse/FLINK-8212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16359861#comment-16359861
]
mingleizhang commented on FLINK-8212:
-
I can directly move those methods to {{TaskManagerServices}}
[
https://issues.apache.org/jira/browse/FLINK-8543?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16359852#comment-16359852
]
chris snow commented on FLINK-8543:
---
I'm hoping that I can get access to an internal cluster that will
[
https://issues.apache.org/jira/browse/FLINK-8477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16359841#comment-16359841
]
ASF GitHub Bot commented on FLINK-8477:
---
Github user Aitozi commented on the issue:
Github user Aitozi commented on the issue:
https://github.com/apache/flink/pull/5405
Hi @aljoscha , you have mentioned two points :
1. The events arrived may out of order in event-time processing
2. We can use windowFunction or ProcessWindowFunction to filter serverl
window
45 matches
Mail list logo
