[
https://issues.apache.org/jira/browse/FLINK-5943?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
mingleizhang reassigned FLINK-5943:
---
Assignee: mingleizhang
> Unprotected access to haServices in
> YarnFlinkApplicationMasterRun
[
https://issues.apache.org/jira/browse/FLINK-5943?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15970759#comment-15970759
]
mingleizhang commented on FLINK-5943:
-
[~tedyu] Hi, Ted, How do you think of this ? I
mingleizhang created FLINK-6313:
---
Summary: Some words was spelled wrong and incorrect LOG.error
without print
Key: FLINK-6313
URL: https://issues.apache.org/jira/browse/FLINK-6313
Project: Flink
GitHub user zhangminglei opened a pull request:
https://github.com/apache/flink/pull/3728
[FLINK-6313] [flink-runtime] Fix Some words was spelled wrong and incâ¦
â¦orrect LOG.error without print.
Thanks for contributing to Apache Flink. Before you open your pull request,
[
https://issues.apache.org/jira/browse/FLINK-6313?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15970818#comment-15970818
]
ASF GitHub Bot commented on FLINK-6313:
---
GitHub user zhangminglei opened a pull requ
Github user sunjincheng121 commented on the issue:
https://github.com/apache/flink/pull/3697
@zentol Thank you for the reminder. And I added some change messages.
Thanks,
SunJincheng
---
If your project is set up for it, you can reply to this email and have your
reply appear o
[
https://issues.apache.org/jira/browse/FLINK-6257?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15970882#comment-15970882
]
ASF GitHub Bot commented on FLINK-6257:
---
Github user sunjincheng121 commented on the
[
https://issues.apache.org/jira/browse/FLINK-1960?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15970928#comment-15970928
]
hzhuangzhenxi commented on FLINK-1960:
--
HI,
I would like to work on this issue.
Github user zhangminglei commented on the issue:
https://github.com/apache/flink/pull/3726
@tzulitai Hi, Could you please review my code ? I am appreciate it.
---
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 projec
[
https://issues.apache.org/jira/browse/FLINK-6130?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15970959#comment-15970959
]
ASF GitHub Bot commented on FLINK-6130:
---
Github user zhangminglei commented on the i
[
https://issues.apache.org/jira/browse/FLINK-6130?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15970972#comment-15970972
]
ASF GitHub Bot commented on FLINK-6130:
---
Github user tzulitai commented on a diff in
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/3726#discussion_r111730519
--- Diff:
flink-yarn/src/main/java/org/apache/flink/yarn/YarnFlinkApplicationMasterRunner.java
---
@@ -158,14 +160,16 @@ protected int runApplicationMaster
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/3726
I don't think the timeout was related. We'll see from this Travis run :)
---
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 proje
[
https://issues.apache.org/jira/browse/FLINK-6130?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15970973#comment-15970973
]
ASF GitHub Bot commented on FLINK-6130:
---
Github user tzulitai commented on the issue
Github user zhangminglei commented on a diff in the pull request:
https://github.com/apache/flink/pull/3726#discussion_r111731104
--- Diff:
flink-yarn/src/main/java/org/apache/flink/yarn/YarnFlinkApplicationMasterRunner.java
---
@@ -158,14 +160,16 @@ protected int runApplicationMa
[
https://issues.apache.org/jira/browse/FLINK-6130?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15970975#comment-15970975
]
ASF GitHub Bot commented on FLINK-6130:
---
Github user zhangminglei commented on a dif
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/3726#discussion_r111731219
--- Diff:
flink-yarn/src/main/java/org/apache/flink/yarn/YarnFlinkApplicationMasterRunner.java
---
@@ -158,14 +160,16 @@ protected int runApplicationMaster
[
https://issues.apache.org/jira/browse/FLINK-6130?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15970977#comment-15970977
]
ASF GitHub Bot commented on FLINK-6130:
---
Github user tzulitai commented on a diff in
Github user zhangminglei commented on the issue:
https://github.com/apache/flink/pull/3726
Travis sucks some time.
---
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 wis
[
https://issues.apache.org/jira/browse/FLINK-6130?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15970983#comment-15970983
]
ASF GitHub Bot commented on FLINK-6130:
---
Github user zhangminglei commented on the i
Github user zhangminglei commented on a diff in the pull request:
https://github.com/apache/flink/pull/3726#discussion_r111732371
--- Diff:
flink-yarn/src/main/java/org/apache/flink/yarn/YarnFlinkApplicationMasterRunner.java
---
@@ -158,14 +160,16 @@ protected int runApplicationMa
[
https://issues.apache.org/jira/browse/FLINK-6130?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15970988#comment-15970988
]
ASF GitHub Bot commented on FLINK-6130:
---
Github user zhangminglei commented on a dif
[
https://issues.apache.org/jira/browse/FLINK-5943?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15971074#comment-15971074
]
Ted Yu commented on FLINK-5943:
---
lgtm
> Unprotected access to haServices in
> YarnFlinkApp
Chesnay Schepler created FLINK-6314:
---
Summary: Allow setting mapper options
Key: FLINK-6314
URL: https://issues.apache.org/jira/browse/FLINK-6314
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-6306?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Seth Wiesman updated FLINK-6306:
Description: Currently Flink provides the BucketingSink as an exactly once
method for writing out to
[
https://issues.apache.org/jira/browse/FLINK-6306?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Seth Wiesman updated FLINK-6306:
Description: Currently Flink provides the BucketingSink as an exactly once
method for writing out to
Seth Wiesman created FLINK-6315:
---
Summary: Notify on checkpoint timeout
Key: FLINK-6315
URL: https://issues.apache.org/jira/browse/FLINK-6315
Project: Flink
Issue Type: New Feature
C
[
https://issues.apache.org/jira/browse/FLINK-5550?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15971389#comment-15971389
]
Neelesh Srinivas Salian commented on FLINK-5550:
Hi [~jeffreyji666], is th
[
https://issues.apache.org/jira/browse/FLINK-5506?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15971390#comment-15971390
]
Neelesh Srinivas Salian commented on FLINK-5506:
Hi, [~mcoimbra] is this s
[
https://issues.apache.org/jira/browse/FLINK-6306?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Seth Wiesman updated FLINK-6306:
Attachment: eventually-consistent-sink
> Sink for eventually consistent file systems
> -
[
https://issues.apache.org/jira/browse/FLINK-6306?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15971397#comment-15971397
]
Seth Wiesman commented on FLINK-6306:
-
The idea is that data is buffered on local disk
[
https://issues.apache.org/jira/browse/FLINK-4831?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15971400#comment-15971400
]
Neelesh Srinivas Salian commented on FLINK-4831:
Shall I work on this if n
GitHub user sjwiesman opened a pull request:
https://github.com/apache/flink/pull/3729
[FLINK-6315] Notify on checkpoint timeout
https://issues.apache.org/jira/browse/FLINK-6315
A common use case when writing a custom operator that outputs data to some
third party location
[
https://issues.apache.org/jira/browse/FLINK-6315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15971404#comment-15971404
]
ASF GitHub Bot commented on FLINK-6315:
---
GitHub user sjwiesman opened a pull request
[
https://issues.apache.org/jira/browse/FLINK-4831?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15971428#comment-15971428
]
Chesnay Schepler commented on FLINK-4831:
-
I have some work-in-progress here: http
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/3459
Hi @huawei-flink, the feature was contributed in a follow up PR.
Could you close this PR? Thanks!
---
If your project is set up for it, you can reply to this email and have your
reply appear on
[
https://issues.apache.org/jira/browse/FLINK-5654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15971520#comment-15971520
]
ASF GitHub Bot commented on FLINK-5654:
---
Github user fhueske commented on the issue:
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3696#discussion_r111804596
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamCorrelate.scala
---
@@ -36,14 +36,14 @@ import o
[
https://issues.apache.org/jira/browse/FLINK-6090?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15971543#comment-15971543
]
ASF GitHub Bot commented on FLINK-6090:
---
Github user fhueske commented on a diff in
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/3696
Hi @hequn8128 and @shaoxuan-wang, I merged this PR to the
`table-retraction` branch.
Could you close it? Thanks!
---
If your project is set up for it, you can reply to this email and have your
r
[
https://issues.apache.org/jira/browse/FLINK-6090?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15971577#comment-15971577
]
ASF GitHub Bot commented on FLINK-6090:
---
Github user fhueske commented on the issue:
Github user shaoxuan-wang commented on a diff in the pull request:
https://github.com/apache/flink/pull/3694#discussion_r111813245
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/AggregateUtil.scala
---
@@ -792,6 +792,20 @@ object Aggr
Github user shaoxuan-wang commented on the issue:
https://github.com/apache/flink/pull/3694
Thanks @fhueske , I have addressed your comments, please take a look.
---
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 pro
[
https://issues.apache.org/jira/browse/FLINK-6240?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15971602#comment-15971602
]
ASF GitHub Bot commented on FLINK-6240:
---
Github user shaoxuan-wang commented on the
[
https://issues.apache.org/jira/browse/FLINK-6240?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15971601#comment-15971601
]
ASF GitHub Bot commented on FLINK-6240:
---
Github user shaoxuan-wang commented on a di
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3694#discussion_r111816123
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/AggregateUtil.scala
---
@@ -792,6 +792,20 @@ object AggregateU
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3694#discussion_r111814395
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/CodeGenerator.scala
---
@@ -396,13 +396,68 @@ class CodeGenerator(
[
https://issues.apache.org/jira/browse/FLINK-6240?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15971623#comment-15971623
]
ASF GitHub Bot commented on FLINK-6240:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6240?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15971624#comment-15971624
]
ASF GitHub Bot commented on FLINK-6240:
---
Github user fhueske commented on a diff in
Github user NicoK commented on the issue:
https://github.com/apache/flink/pull/3348
yes, that's exactly why
---
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,
[
https://issues.apache.org/jira/browse/FLINK-5090?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15971632#comment-15971632
]
ASF GitHub Bot commented on FLINK-5090:
---
Github user NicoK commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-6292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15971637#comment-15971637
]
Nico Kruber commented on FLINK-6292:
does it make sense to cherry-pick this commit int
[
https://issues.apache.org/jira/browse/FLINK-6240?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15971754#comment-15971754
]
ASF GitHub Bot commented on FLINK-6240:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/3694
---
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 enab
[
https://issues.apache.org/jira/browse/FLINK-6240?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske closed FLINK-6240.
Resolution: Implemented
Fix Version/s: 1.3.0
Implemented with 9be5cc42c02c258d3843c373b735024
Tzu-Li (Gordon) Tai created FLINK-6316:
--
Summary: Kinesis connector docs should mention that
FlinkKinesisConsumer does not provide strong ordering guarantees on resharding
Key: FLINK-6316
URL: https://issues.
Github user lingjinjiang commented on the issue:
https://github.com/apache/flink/pull/3711
@greghogan thanks for your review. I have another question, how can I
assign the issue to myself ?
---
If your project is set up for it, you can reply to this email and have your
reply appear
[
https://issues.apache.org/jira/browse/FLINK-6286?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15971920#comment-15971920
]
ASF GitHub Bot commented on FLINK-6286:
---
Github user lingjinjiang commented on the i
Github user zhangminglei commented on the issue:
https://github.com/apache/flink/pull/3728
@tzulitai Hi, Could you please review those code ? Thanks and appreciate ~
---
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
[
https://issues.apache.org/jira/browse/FLINK-6313?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15971944#comment-15971944
]
ASF GitHub Bot commented on FLINK-6313:
---
Github user zhangminglei commented on the i
Github user hequn8128 closed the pull request at:
https://github.com/apache/flink/pull/3696
---
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 e
[
https://issues.apache.org/jira/browse/FLINK-6090?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15971958#comment-15971958
]
ASF GitHub Bot commented on FLINK-6090:
---
Github user hequn8128 closed the pull reque
[
https://issues.apache.org/jira/browse/FLINK-6090?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hequn Cheng closed FLINK-6090.
--
Resolution: Fixed
> Add RetractionRule at the stage of decoration
>
[
https://issues.apache.org/jira/browse/FLINK-5943?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15971966#comment-15971966
]
mingleizhang commented on FLINK-5943:
-
[~tedyu] Thanks and appreciate it. I will give
Github user KurtYoung commented on a diff in the pull request:
https://github.com/apache/flink/pull/3594#discussion_r111856357
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/BatchTableEnvironment.scala
---
@@ -228,15 +229,24 @@ abstract class Batch
[
https://issues.apache.org/jira/browse/FLINK-6149?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15971969#comment-15971969
]
ASF GitHub Bot commented on FLINK-6149:
---
Github user KurtYoung commented on a diff i
[
https://issues.apache.org/jira/browse/FLINK-5550?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15971984#comment-15971984
]
jiwengang commented on FLINK-5550:
--
yep
> NotFoundException: Could not find job with id
Github user KurtYoung commented on a diff in the pull request:
https://github.com/apache/flink/pull/3594#discussion_r111857715
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/rel/logical/FlinkLogicalJoin.scala
---
@@ -0,0 +1,130 @@
+/*
+ * Licen
[
https://issues.apache.org/jira/browse/FLINK-6149?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15971988#comment-15971988
]
ASF GitHub Bot commented on FLINK-6149:
---
Github user KurtYoung commented on a diff i
Github user KurtYoung commented on a diff in the pull request:
https://github.com/apache/flink/pull/3594#discussion_r111857813
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/rel/logical/FlinkLogicalAggregate.scala
---
@@ -0,0 +1,92 @@
+/*
+ * L
[
https://issues.apache.org/jira/browse/FLINK-6149?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15971990#comment-15971990
]
ASF GitHub Bot commented on FLINK-6149:
---
Github user KurtYoung commented on a diff i
[
https://issues.apache.org/jira/browse/FLINK-5943?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15971996#comment-15971996
]
ASF GitHub Bot commented on FLINK-5943:
---
GitHub user zhangminglei opened a pull requ
GitHub user zhangminglei opened a pull request:
https://github.com/apache/flink/pull/3730
[FLINK-5943] [YARN] Fix unprotected access to haServices in YarnFlinkâ¦
â¦ApplicationMasterRunner#shutdown().
Thanks for contributing to Apache Flink. Before you open your pull reques
Github user KurtYoung commented on a diff in the pull request:
https://github.com/apache/flink/pull/3594#discussion_r111858923
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/rel/logical/FlinkLogicalAggregate.scala
---
@@ -0,0 +1,92 @@
+/*
+ * L
Github user KurtYoung commented on a diff in the pull request:
https://github.com/apache/flink/pull/3594#discussion_r111859756
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/rel/logical/FlinkLogicalSort.scala
---
@@ -0,0 +1,148 @@
+/*
+ * Licen
[
https://issues.apache.org/jira/browse/FLINK-6149?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15972015#comment-15972015
]
ASF GitHub Bot commented on FLINK-6149:
---
Github user KurtYoung commented on a diff i
Github user KurtYoung commented on a diff in the pull request:
https://github.com/apache/flink/pull/3594#discussion_r111860136
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/rel/logical/FlinkLogicalTableSourceScan.scala
---
@@ -0,0 +1,109 @@
+/*
[
https://issues.apache.org/jira/browse/FLINK-6149?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15972018#comment-15972018
]
ASF GitHub Bot commented on FLINK-6149:
---
Github user KurtYoung commented on a diff i
Github user KurtYoung commented on a diff in the pull request:
https://github.com/apache/flink/pull/3594#discussion_r111860657
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/TableEnvironmentTest.scala
---
@@ -335,7 +335,8 @@ class TableEnvironmentTest
[
https://issues.apache.org/jira/browse/FLINK-6149?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15972024#comment-15972024
]
ASF GitHub Bot commented on FLINK-6149:
---
Github user KurtYoung commented on a diff i
Github user KurtYoung commented on a diff in the pull request:
https://github.com/apache/flink/pull/3594#discussion_r111861037
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/cost/FlinkRelMdRowCount.scala
---
@@ -23,13 +23,17 @@ import org.apache.c
[
https://issues.apache.org/jira/browse/FLINK-6149?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15972028#comment-15972028
]
ASF GitHub Bot commented on FLINK-6149:
---
Github user KurtYoung commented on a diff i
Github user KurtYoung commented on a diff in the pull request:
https://github.com/apache/flink/pull/3594#discussion_r111861591
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/rules/dataSet/DataSetCorrelateRule.scala
---
@@ -18,58 +18,57 @@
pac
[
https://issues.apache.org/jira/browse/FLINK-6149?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15972034#comment-15972034
]
ASF GitHub Bot commented on FLINK-6149:
---
Github user KurtYoung commented on a diff i
Github user KurtYoung commented on the issue:
https://github.com/apache/flink/pull/3594
Hi @fhueske , sorry for taking it so long to update this PR.
Looks like it has so many conflicts with master now, once you are ok with
all the changes, i will rebase it to master.
---
If your
[
https://issues.apache.org/jira/browse/FLINK-6149?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15972040#comment-15972040
]
ASF GitHub Bot commented on FLINK-6149:
---
Github user KurtYoung commented on the issu
[
https://issues.apache.org/jira/browse/FLINK-5867?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
shuai.xu updated FLINK-5867:
Description:
The RestartPipelinedRegionStrategy's responsibility is the following:
1. Calculate all Failover
[
https://issues.apache.org/jira/browse/FLINK-5867?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
shuai.xu updated FLINK-5867:
Summary: The implementation of RestartPipelinedRegionStrategy (was: The
implementation of FailoverCoordinat
Github user fanyon commented on the issue:
https://github.com/apache/flink/pull/3652
Hi @shixiaogang , as we discussed before, I have closed all resources in
latest commit, thank you for your comments.
---
If your project is set up for it, you can reply to this email and have your
re
[
https://issues.apache.org/jira/browse/FLINK-6210?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15972200#comment-15972200
]
ASF GitHub Bot commented on FLINK-6210:
---
Github user fanyon commented on the issue:
Github user patricklucas commented on the issue:
https://github.com/apache/flink/pull/3686
@fpompermaier FYI your author email address on this commit was
"f.pomperma...@gmai.com" (missing 'l'). You might have a typo in your gitconfig?
---
If your project is set up for it, you can rep
[
https://issues.apache.org/jira/browse/FLINK-6271?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15972202#comment-15972202
]
ASF GitHub Bot commented on FLINK-6271:
---
Github user patricklucas commented on the i
92 matches
Mail list logo
