[
https://issues.apache.org/jira/browse/FLINK-8276?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16317912#comment-16317912
]
ASF GitHub Bot commented on FLINK-8276:
---
Github user zhangminglei commented on the i
Github user zhangminglei commented on the issue:
https://github.com/apache/flink/pull/5173
Thanks @pnowojski.
---
[
https://issues.apache.org/jira/browse/FLINK-3089?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16317829#comment-16317829
]
Sihua Zhou commented on FLINK-3089:
---
[~phoenixjiangnan] Maybe we shouldn't enforce TtlDB
[
https://issues.apache.org/jira/browse/FLINK-3089?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16317800#comment-16317800
]
Bowen Li commented on FLINK-3089:
-
[~srichter] [~aljoscha] guys, I want to follow up on th
[
https://issues.apache.org/jira/browse/FLINK-8302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16317730#comment-16317730
]
ASF GitHub Bot commented on FLINK-8302:
---
Github user dubin555 commented on the issue
Github user dubin555 commented on the issue:
https://github.com/apache/flink/pull/5202
Hi @sunjincheng121 , thanks for the overall review of my code. I've done
some typo fix and add some test case base on your comment. Really appreciate
for your careful review!
Du Bin
---
[
https://issues.apache.org/jira/browse/FLINK-7775?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-7775:
--
Description:
{code}
public int getNumberOfCachedJobs() {
return jobRefCounters.size();
}
{code}
The met
[
https://issues.apache.org/jira/browse/FLINK-8369?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Biao Liu reassigned FLINK-8369:
---
Assignee: Biao Liu
> Port SubtaskExecutionAttemptAccumulatorsHandler to new REST endpoint
> -
[
https://issues.apache.org/jira/browse/FLINK-7406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16317529#comment-16317529
]
ASF GitHub Bot commented on FLINK-7406:
---
Github user zhijiangW commented on the issu
Github user zhijiangW commented on the issue:
https://github.com/apache/flink/pull/4509
Already close it
---
Github user zhijiangW closed the pull request at:
https://github.com/apache/flink/pull/4509
---
[
https://issues.apache.org/jira/browse/FLINK-7406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16317530#comment-16317530
]
ASF GitHub Bot commented on FLINK-7406:
---
Github user zhijiangW closed the pull reque
Github user zhijiangW closed the pull request at:
https://github.com/apache/flink/pull/4533
---
[
https://issues.apache.org/jira/browse/FLINK-7416?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16317516#comment-16317516
]
ASF GitHub Bot commented on FLINK-7416:
---
Github user zhijiangW closed the pull reque
[
https://issues.apache.org/jira/browse/FLINK-7416?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16317515#comment-16317515
]
ASF GitHub Bot commented on FLINK-7416:
---
Github user zhijiangW commented on the issu
Github user zhijiangW commented on the issue:
https://github.com/apache/flink/pull/4533
Sure, I close it.
---
[
https://issues.apache.org/jira/browse/FLINK-8381?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16317262#comment-16317262
]
ASF GitHub Bot commented on FLINK-8381:
---
Github user fhueske commented on a diff in
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/5257#discussion_r160275286
--- Diff: docs/dev/table/common.md ---
@@ -802,7 +802,87 @@ val dsTuple: DataSet[(String, Int)] =
tableEnv.toDataSet[(String, Int)](table)
### Map
[
https://issues.apache.org/jira/browse/FLINK-8381?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16317263#comment-16317263
]
ASF GitHub Bot commented on FLINK-8381:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-8381?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16317264#comment-16317264
]
ASF GitHub Bot commented on FLINK-8381:
---
Github user fhueske commented on a diff in
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/5257#discussion_r160274966
--- Diff: docs/dev/table/common.md ---
@@ -802,7 +802,87 @@ val dsTuple: DataSet[(String, Int)] =
tableEnv.toDataSet[(String, Int)](table)
### Map
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/5257#discussion_r160275240
--- Diff: docs/dev/table/common.md ---
@@ -802,7 +802,87 @@ val dsTuple: DataSet[(String, Int)] =
tableEnv.toDataSet[(String, Int)](table)
### Map
[
https://issues.apache.org/jira/browse/FLINK-8325?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16317225#comment-16317225
]
ASF GitHub Bot commented on FLINK-8325:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-8325?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16317218#comment-16317218
]
ASF GitHub Bot commented on FLINK-8325:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-8325?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16317220#comment-16317220
]
ASF GitHub Bot commented on FLINK-8325:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-8325?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16317223#comment-16317223
]
ASF GitHub Bot commented on FLINK-8325:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-8325?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16317217#comment-16317217
]
ASF GitHub Bot commented on FLINK-8325:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-8325?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16317228#comment-16317228
]
ASF GitHub Bot commented on FLINK-8325:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-8325?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16317230#comment-16317230
]
ASF GitHub Bot commented on FLINK-8325:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-8325?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16317233#comment-16317233
]
ASF GitHub Bot commented on FLINK-8325:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-8325?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16317224#comment-16317224
]
ASF GitHub Bot commented on FLINK-8325:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-8325?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16317234#comment-16317234
]
ASF GitHub Bot commented on FLINK-8325:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-8325?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16317227#comment-16317227
]
ASF GitHub Bot commented on FLINK-8325:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-8325?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16317231#comment-16317231
]
ASF GitHub Bot commented on FLINK-8325:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-8325?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16317221#comment-16317221
]
ASF GitHub Bot commented on FLINK-8325:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-8325?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16317219#comment-16317219
]
ASF GitHub Bot commented on FLINK-8325:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-8325?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16317232#comment-16317232
]
ASF GitHub Bot commented on FLINK-8325:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-8325?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16317229#comment-16317229
]
ASF GitHub Bot commented on FLINK-8325:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-8325?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16317222#comment-16317222
]
ASF GitHub Bot commented on FLINK-8325:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-8325?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16317226#comment-16317226
]
ASF GitHub Bot commented on FLINK-8325:
---
Github user fhueske commented on a diff in
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/5241#discussion_r160253551
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/AggregationCodeGenerator.scala
---
@@ -383,12 +388,16 @@ class Aggregati
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/5241#discussion_r160255960
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/aggfunctions/AggFunctionTestBase.scala
---
@@ -146,14 +146,31 @@ abstrac
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/5241#discussion_r160267929
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamOverAggregate.scala
---
@@ -145,6 +145,14 @@ cla
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/5241#discussion_r160250581
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/AggregationCodeGenerator.scala
---
@@ -139,7 +139,7 @@ class Aggregation
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/5241#discussion_r160257426
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/batch/sql/JoinITCase.scala
---
@@ -254,7 +254,7 @@ class JoinITCase(
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/5241#discussion_r160260174
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/stream/sql/GroupWindowITCase.scala
---
@@ -0,0 +1,122 @@
+/*
+ *
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/5241#discussion_r160259534
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/batch/sql/SetOperatorsITCase.scala
---
@@ -278,7 +278,14 @@ class SetOpe
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/5241#discussion_r160255883
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/aggfunctions/AggFunctionTestBase.scala
---
@@ -146,14 +146,31 @@ abstrac
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/5241#discussion_r160268630
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/AggregateUtil.scala
---
@@ -1130,259 +1134,263 @@ object Aggre
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/5241#discussion_r160250423
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/AggregationCodeGenerator.scala
---
@@ -121,7 +121,7 @@ class Aggregation
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/5241#discussion_r160253454
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/AggregationCodeGenerator.scala
---
@@ -359,12 +359,17 @@ class Aggregati
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/5241#discussion_r160260046
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/stream/sql/GroupWindowITCase.scala
---
@@ -0,0 +1,122 @@
+/*
+ *
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/5241#discussion_r160268601
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/AggregateUtil.scala
---
@@ -1130,259 +1134,263 @@ object Aggre
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/5241#discussion_r160250511
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/AggregationCodeGenerator.scala
---
@@ -121,7 +121,7 @@ class Aggregation
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/5241#discussion_r160251387
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/aggfunctions/CountAggFunction.scala
---
@@ -33,7 +33,20 @@ class Count
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/5241#discussion_r160271966
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/AggregateUtil.scala
---
@@ -1130,259 +1134,263 @@ object Aggre
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/5241#discussion_r160251401
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/aggfunctions/CountAggFunction.scala
---
@@ -33,7 +33,20 @@ class Count
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/5241#discussion_r160265977
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamOverAggregate.scala
---
@@ -145,6 +145,14 @@ cla
[
https://issues.apache.org/jira/browse/FLINK-8275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16317067#comment-16317067
]
Shuyi Chen edited comment on FLINK-8275 at 1/8/18 10:00 PM:
Hi
[
https://issues.apache.org/jira/browse/FLINK-8320?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16317126#comment-16317126
]
Chesnay Schepler commented on FLINK-8320:
-
docs adjusted for 1.4 in 6f50ed256a8a2c
[
https://issues.apache.org/jira/browse/FLINK-8200?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-8200.
---
Resolution: Fixed
Fix Version/s: 1.4.1
1.4: 78e3405becb13ec74d6edd4624727f7fd40fea07
>
[
https://issues.apache.org/jira/browse/FLINK-8390?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shuyi Chen updated FLINK-8390:
--
Description: As suggested in [Flink-8270|
https://issues.apache.org/jira/browse/FLINK-8270] and
[Flink-
Shuyi Chen created FLINK-8390:
-
Summary: Refactor Hadoop kerberos integration test code
Key: FLINK-8390
URL: https://issues.apache.org/jira/browse/FLINK-8390
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-8275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16317067#comment-16317067
]
Shuyi Chen edited comment on FLINK-8275 at 1/8/18 9:12 PM:
---
Hi,
[
https://issues.apache.org/jira/browse/FLINK-8275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16317067#comment-16317067
]
Shuyi Chen commented on FLINK-8275:
---
[~tzulitai], [~eronwright],
I've added unittest to
[
https://issues.apache.org/jira/browse/FLINK-7797?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16316873#comment-16316873
]
ASF GitHub Bot commented on FLINK-7797:
---
Github user fhueske commented on the issue:
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/5140
Thanks for the update and excellent work.
PR is good to merge :-)
---
[
https://issues.apache.org/jira/browse/FLINK-7511?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16316860#comment-16316860
]
ASF GitHub Bot commented on FLINK-7511:
---
Github user dawidwys commented on the issue
Github user dawidwys commented on the issue:
https://github.com/apache/flink/pull/4587
@pnowojski I've updated the PR, will be grateful for your review, thx!
---
[
https://issues.apache.org/jira/browse/FLINK-8383?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-8383:
Affects Version/s: 1.5.0
> flink-mesos build failing: duplicate Jackson relocation in shaded
[
https://issues.apache.org/jira/browse/FLINK-8383?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16316840#comment-16316840
]
Chesnay Schepler commented on FLINK-8383:
-
Band-aid merged to master in 7c2a32c286
[
https://issues.apache.org/jira/browse/FLINK-8383?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-8383:
Fix Version/s: 1.5.0
> flink-mesos build failing: duplicate Jackson relocation in shaded jar
[
https://issues.apache.org/jira/browse/FLINK-8292?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-8292.
---
Resolution: Fixed
Fix Version/s: (was: 1.4.1)
master: 3cdc5d1dce7c8cf0db0352d86867f
[
https://issues.apache.org/jira/browse/FLINK-8388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16316834#comment-16316834
]
ASF GitHub Bot commented on FLINK-8388:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-8250?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16316832#comment-16316832
]
ASF GitHub Bot commented on FLINK-8250:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5263
---
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5258
---
[
https://issues.apache.org/jira/browse/FLINK-8383?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16316833#comment-16316833
]
ASF GitHub Bot commented on FLINK-8383:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-8320?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16316826#comment-16316826
]
Chesnay Schepler commented on FLINK-8320:
-
docs adjusted for master in 1ef1f321192
[
https://issues.apache.org/jira/browse/FLINK-8280?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-8280.
---
Resolution: Fixed
Fix Version/s: 1.5.0
master: 50301254182283433d52b5359b1afa6093d0514b
[
https://issues.apache.org/jira/browse/FLINK-8280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16316831#comment-16316831
]
ASF GitHub Bot commented on FLINK-8280:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-8200?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16316828#comment-16316828
]
Chesnay Schepler commented on FLINK-8200:
-
master: 4ac348d1fa539d64ce9317035716243
[
https://issues.apache.org/jira/browse/FLINK-8250?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-8250.
---
Resolution: Fixed
master: 10aae991833447506e8e8231c32fb9f816920597
> Remove RecordSerializer#
[
https://issues.apache.org/jira/browse/FLINK-8200?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-8200:
Fix Version/s: 1.5.0
> RocksDBAsyncSnapshotTest should use temp fold instead of fold with fi
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5213
---
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5175
---
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5162
---
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5249
---
[
https://issues.apache.org/jira/browse/FLINK-8388?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-8388.
---
Resolution: Fixed
master: f16335d427592007a5b242a1b4b0cfcd5bd36858
> Snapshot documentation r
[
https://issues.apache.org/jira/browse/FLINK-8347?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16316731#comment-16316731
]
ASF GitHub Bot commented on FLINK-8347:
---
Github user GJL commented on a diff in the
[
https://issues.apache.org/jira/browse/FLINK-8347?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16316730#comment-16316730
]
ASF GitHub Bot commented on FLINK-8347:
---
Github user GJL commented on a diff in the
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5232#discussion_r160216156
--- Diff:
flink-clients/src/test/java/org/apache/flink/client/cli/CliFrontendStopTest.java
---
@@ -98,24 +103,26 @@ public void testUnknownJobId() throws Except
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5232#discussion_r160209875
--- Diff:
flink-yarn/src/test/java/org/apache/flink/yarn/AbstractYarnClusterTest.java ---
@@ -83,7 +83,7 @@ public void
testClusterClientRetrievalOfFinishedYarn
[
https://issues.apache.org/jira/browse/FLINK-8389?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16316672#comment-16316672
]
ASF GitHub Bot commented on FLINK-8389:
---
GitHub user tillrohrmann opened a pull requ
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/5265
[FLINK-8389] [flip6] Release all slots upon closing of JobManager
connection
## What is the purpose of the change
Release the slots assigned to a `JobMaster` once it disconnects from
[
https://issues.apache.org/jira/browse/FLINK-8343?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16316664#comment-16316664
]
ASF GitHub Bot commented on FLINK-8343:
---
Github user GJL commented on a diff in the
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5229#discussion_r160209100
--- Diff:
flink-clients/src/main/java/org/apache/flink/client/deployment/ClusterDescriptor.java
---
@@ -56,7 +57,15 @@
* @return Cluster client to talk
[
https://issues.apache.org/jira/browse/FLINK-8347?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16316656#comment-16316656
]
ASF GitHub Bot commented on FLINK-8347:
---
Github user GJL commented on a diff in the
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5232#discussion_r160208748
--- Diff:
flink-yarn/src/main/java/org/apache/flink/yarn/AbstractYarnClusterDescriptor.java
---
@@ -367,40 +366,31 @@ public ClusterClient retrieve(String appli
Till Rohrmann created FLINK-8389:
Summary: Release all slots upon closing of JobMaster connection
Key: FLINK-8389
URL: https://issues.apache.org/jira/browse/FLINK-8389
Project: Flink
Issue Ty
1 - 100 of 395 matches
Mail list logo
