Jark Wu created FLINK-4598:
--
Summary: Support NULLIF in Table API
Key: FLINK-4598
URL: https://issues.apache.org/jira/browse/FLINK-4598
Project: Flink
Issue Type: New Feature
Components:
Jark Wu created FLINK-4597:
--
Summary: Improve Scalar Function section in Table API documentation
Key: FLINK-4597
URL: https://issues.apache.org/jira/browse/FLINK-4597
Project: Flink
Issue Type: Impr
[
https://issues.apache.org/jira/browse/FLINK-4376?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kurt Young closed FLINK-4376.
-
Resolution: Duplicate
I think this is duplicated with https://issues.apache.org/jira/browse/FLINK-4408
>
[
https://issues.apache.org/jira/browse/FLINK-4406?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kurt Young updated FLINK-4406:
--
Assignee: (was: Kurt Young)
> Implement job master registration at resource manager
> --
[
https://issues.apache.org/jira/browse/FLINK-4408?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15472703#comment-15472703
]
ASF GitHub Bot commented on FLINK-4408:
---
GitHub user KurtYoung opened a pull request
GitHub user KurtYoung opened a pull request:
https://github.com/apache/flink/pull/2480
[FLINK-4408][JobManager] Introduce JobMasterRunner and implement job
submission & setting up the ExecutionGraph
Introduce JobMasterRunner to deal with job level leader election and make
underlyin
[
https://issues.apache.org/jira/browse/FLINK-4538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15472686#comment-15472686
]
ASF GitHub Bot commented on FLINK-4538:
---
Github user beyond1920 commented on a diff
Github user beyond1920 commented on a diff in the pull request:
https://github.com/apache/flink/pull/2463#discussion_r77943543
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/ResourceManager.java
---
@@ -52,15 +58,28 @@
*
*/
public
[
https://issues.apache.org/jira/browse/FLINK-1707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15425389#comment-15425389
]
Josep Rubió edited comment on FLINK-1707 at 9/8/16 3:49 AM:
Hi
[
https://issues.apache.org/jira/browse/FLINK-1526?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15472586#comment-15472586
]
Olga Golovneva commented on FLINK-1526:
---
Hi,
I was wondering what is the current sta
[
https://issues.apache.org/jira/browse/FLINK-4427?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kurt Young updated FLINK-4427:
--
Summary: Implement container releasing logic (Standalone / Yarn / Mesos)
(was: Add slot / Implement con
[
https://issues.apache.org/jira/browse/FLINK-4551?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhangjing reassigned FLINK-4551:
Assignee: zhangjing
> Heartbeat Manager integration with JobMaster
> --
GitHub user beyond1920 opened a pull request:
https://github.com/apache/flink/pull/2479
[FLINK-4537] [cluster management] ResourceManager registration with
JobManager
This pull request is to implement ResourceManager registration with
JobManager, which including:
1. Check wheth
[
https://issues.apache.org/jira/browse/FLINK-4537?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15472525#comment-15472525
]
ASF GitHub Bot commented on FLINK-4537:
---
GitHub user beyond1920 opened a pull reques
[
https://issues.apache.org/jira/browse/FLINK-4591?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15472401#comment-15472401
]
Jark Wu commented on FLINK-4591:
It seems that {{GROUP BY *}} is not allowed in SQL. Mayb
Nagarjun Guraja created FLINK-4596:
--
Summary: Class not found exception when RESTART_STRATEGY is
configured with fully qualified class name in the yaml
Key: FLINK-4596
URL: https://issues.apache.org/jira/browse/F
[
https://issues.apache.org/jira/browse/FLINK-4586?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Johannes updated FLINK-4586:
Attachment: FLINK4586Test.scala
Scala unit test
> NumberSequenceIterator and Accumulator threading issue
>
[
https://issues.apache.org/jira/browse/FLINK-4586?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Johannes updated FLINK-4586:
Attachment: (was: FLINK4586Test.scala)
> NumberSequenceIterator and Accumulator threading issue
> --
GitHub user apivovarov opened a pull request:
https://github.com/apache/flink/pull/2478
[FLINK-4595] Close FileOutputStream in ParameterTool
https://issues.apache.org/jira/browse/FLINK-4595
You can merge this pull request into a Git repository by running:
$ git pull https://git
[
https://issues.apache.org/jira/browse/FLINK-4595?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15471823#comment-15471823
]
ASF GitHub Bot commented on FLINK-4595:
---
GitHub user apivovarov opened a pull reques
Alexander Pivovarov created FLINK-4595:
--
Summary: Close FileOutputStream in ParameterTool
Key: FLINK-4595
URL: https://issues.apache.org/jira/browse/FLINK-4595
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-4585?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger resolved FLINK-4585.
---
Resolution: Fixed
Resolved in http://git-wip-us.apache.org/repos/asf/flink-web/commit/bb6d820f
Greg Hogan created FLINK-4594:
-
Summary: Validate lower bound in MathUtils.checkedDownCast
Key: FLINK-4594
URL: https://issues.apache.org/jira/browse/FLINK-4594
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-4572?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15471566#comment-15471566
]
ASF GitHub Bot commented on FLINK-4572:
---
Github user greghogan commented on the issu
Github user greghogan commented on the issue:
https://github.com/apache/flink/pull/2469
Do you have a second use case in mind for adding this function to
`MathUtils`? My thought would be to keep this separate to avoid confusion
between signed and unsigned downcasts.
---
If your proj
[
https://issues.apache.org/jira/browse/FLINK-4593?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Pivovarov updated FLINK-4593:
---
Flags: Patch
> Fix PageRank algorithm example
> --
>
>
[
https://issues.apache.org/jira/browse/FLINK-4572?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15471484#comment-15471484
]
ASF GitHub Bot commented on FLINK-4572:
---
Github user StephanEwen commented on the is
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2469
Looks good. Does it make sense to add to extend the
`MathUtils.checkedDownCast(...)` function, or add a
`MathUtils.checkedSignedDownCast(...)` function?
---
If your project is set up for it, yo
[
https://issues.apache.org/jira/browse/FLINK-4593?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Pivovarov updated FLINK-4593:
---
Description:
This page https://flink.apache.org/features.html shows the code which
im
Alexander Pivovarov created FLINK-4593:
--
Summary: Fix PageRank algorithm example
Key: FLINK-4593
URL: https://issues.apache.org/jira/browse/FLINK-4593
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-4585?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Pivovarov updated FLINK-4585:
---
Flags: Patch
> Fix broken links in index.md
>
>
>
[
https://issues.apache.org/jira/browse/FLINK-3755?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15471287#comment-15471287
]
ASF GitHub Bot commented on FLINK-3755:
---
Github user StefanRRichter commented on a d
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/2440#discussion_r77870173
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/state/KeyGroupRangeAssignment.java
---
@@ -0,0 +1,97 @@
+/*
+ * Licensed to the
[
https://issues.apache.org/jira/browse/FLINK-3755?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15471283#comment-15471283
]
ASF GitHub Bot commented on FLINK-3755:
---
Github user StefanRRichter commented on the
Github user StefanRRichter commented on the issue:
https://github.com/apache/flink/pull/2440
I don't think that this is giving us the correct inverse for
```computeOperatorIndexForKeyGroup(...)```. Our test
```CheckpointCoordinatorTest::testCreateKeyGroupPartitions()```generates
coun
[
https://issues.apache.org/jira/browse/FLINK-3755?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15471057#comment-15471057
]
ASF GitHub Bot commented on FLINK-3755:
---
Github user tillrohrmann commented on a dif
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/2440#discussion_r77856665
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/state/KeyGroupRangeAssignment.java
---
@@ -0,0 +1,97 @@
+/*
+ * Licensed to the A
Timo Walther created FLINK-4592:
---
Summary: Fix flaky test ScalarFunctionsTest.testCurrentTimePoint
Key: FLINK-4592
URL: https://issues.apache.org/jira/browse/FLINK-4592
Project: Flink
Issue Typ
Github user greghogan commented on a diff in the pull request:
https://github.com/apache/flink/pull/2337#discussion_r77842627
--- Diff:
flink-core/src/main/java/org/apache/flink/api/java/typeutils/TypeExtractor.java
---
@@ -792,12 +832,40 @@ else if (t instanceof Class) {
[
https://issues.apache.org/jira/browse/FLINK-3042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15470881#comment-15470881
]
ASF GitHub Bot commented on FLINK-3042:
---
Github user greghogan commented on a diff i
[
https://issues.apache.org/jira/browse/FLINK-3950?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15470749#comment-15470749
]
ASF GitHub Bot commented on FLINK-3950:
---
Github user rmetzger commented on a diff in
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/2443#discussion_r77829590
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/AbstractStreamOperator.java
---
@@ -105,7 +106,9 @@ public void setup(
[
https://issues.apache.org/jira/browse/FLINK-3042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15470728#comment-15470728
]
ASF GitHub Bot commented on FLINK-3042:
---
Github user greghogan commented on a diff i
Github user greghogan commented on a diff in the pull request:
https://github.com/apache/flink/pull/2337#discussion_r77827675
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/typeinfo/TypeInfoFactory.java
---
@@ -0,0 +1,55 @@
+/*
+ * Licensed to the Apache So
[
https://issues.apache.org/jira/browse/FLINK-3950?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15470705#comment-15470705
]
ASF GitHub Bot commented on FLINK-3950:
---
Github user zentol commented on a diff in t
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/2443#discussion_r77825932
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/AbstractStreamOperator.java
---
@@ -105,7 +106,9 @@ public void setup(St
[
https://issues.apache.org/jira/browse/FLINK-3950?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15470653#comment-15470653
]
ASF GitHub Bot commented on FLINK-3950:
---
Github user rmetzger commented on a diff in
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/2443#discussion_r77821528
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/AbstractStreamOperator.java
---
@@ -105,7 +106,9 @@ public void setup(
Github user rmetzger commented on the issue:
https://github.com/apache/flink/pull/2443
Overall a good change.
Once my two comments are addressed, +1 to merge.
---
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 pr
[
https://issues.apache.org/jira/browse/FLINK-3950?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15470566#comment-15470566
]
ASF GitHub Bot commented on FLINK-3950:
---
Github user rmetzger commented on the issue
[
https://issues.apache.org/jira/browse/FLINK-3950?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15470554#comment-15470554
]
ASF GitHub Bot commented on FLINK-3950:
---
Github user rmetzger commented on a diff in
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/2443#discussion_r77815865
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/AbstractStreamOperator.java
---
@@ -105,7 +106,9 @@ public void setup(
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/2443#discussion_r77814628
--- Diff:
flink-metrics/flink-metrics-core/src/main/java/org/apache/flink/metrics/MeterView.java
---
@@ -0,0 +1,70 @@
+/*
+ * Licensed to the Apache
[
https://issues.apache.org/jira/browse/FLINK-3950?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15470536#comment-15470536
]
ASF GitHub Bot commented on FLINK-3950:
---
Github user rmetzger commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4506?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15470488#comment-15470488
]
ASF GitHub Bot commented on FLINK-4506:
---
GitHub user kirill-morozov-epam opened a pu
GitHub user kirill-morozov-epam opened a pull request:
https://github.com/apache/flink/pull/2477
[FLINK-4506] CsvOutputFormat defaults allowNullValues to false, even â¦
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/kirill-moro
[
https://issues.apache.org/jira/browse/FLINK-4565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15470472#comment-15470472
]
Simone Robutti commented on FLINK-4565:
---
That's exactly why I'm asking it: I had no
Timo Walther created FLINK-4591:
---
Summary: Select star does not work with grouping
Key: FLINK-4591
URL: https://issues.apache.org/jira/browse/FLINK-4591
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-4506?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirill Morozov reassigned FLINK-4506:
-
Assignee: Kirill Morozov
> CsvOutputFormat defaults allowNullValues to false, even though
[
https://issues.apache.org/jira/browse/FLINK-4565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15470437#comment-15470437
]
Fabian Hueske commented on FLINK-4565:
--
I thought rather of something like this: {{ds
[
https://issues.apache.org/jira/browse/FLINK-3322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15470419#comment-15470419
]
ramkrishna.s.vasudevan commented on FLINK-3322:
---
I am able to handle cases f
[
https://issues.apache.org/jira/browse/FLINK-4565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15470412#comment-15470412
]
Simone Robutti commented on FLINK-4565:
---
The resulting API should look like `ds1.joi
[
https://issues.apache.org/jira/browse/FLINK-4589?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15470397#comment-15470397
]
ASF GitHub Bot commented on FLINK-4589:
---
GitHub user aljoscha opened a pull request:
GitHub user aljoscha opened a pull request:
https://github.com/apache/flink/pull/2476
[FLINK-4589] Fix Merging of Covering Window in MergingWindowSet
This also adds two new test cases for that problem.
R: @StephanEwen
You can merge this pull request into a Git repository b
Robert Metzger created FLINK-4590:
-
Summary: Some Table API tests are failing when debug lvl is set to
DEBUG
Key: FLINK-4590
URL: https://issues.apache.org/jira/browse/FLINK-4590
Project: Flink
Aljoscha Krettek created FLINK-4589:
---
Summary: Fix Merging of Covering Window in MergingWindowSet
Key: FLINK-4589
URL: https://issues.apache.org/jira/browse/FLINK-4589
Project: Flink
Issue
Aljoscha Krettek created FLINK-4588:
---
Summary: Fix Merging of Covering Window in MergingWindowSet
Key: FLINK-4588
URL: https://issues.apache.org/jira/browse/FLINK-4588
Project: Flink
Issue
Github user liuyuzhong commented on the issue:
https://github.com/apache/flink/pull/2452
@mxm OK.
---
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
[
https://issues.apache.org/jira/browse/FLINK-4579?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-4579:
-
Issue Type: Improvement (was: Bug)
> Add StateBackendFactory for RocksDB Backend
> --
[
https://issues.apache.org/jira/browse/FLINK-4538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15470114#comment-15470114
]
ASF GitHub Bot commented on FLINK-4538:
---
Github user tillrohrmann commented on a dif
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/2463#discussion_r77787126
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/highavailability/LeaderIdRegistry.java
---
@@ -15,11 +15,27 @@
* See the License fo
Github user mxm commented on the issue:
https://github.com/apache/flink/pull/2452
@liuyuzhong Let's wait a couple more days for the community to respond. You
don't have to close the PR.
---
If your project is set up for it, you can reply to this email and have your
reply appear on Gi
[
https://issues.apache.org/jira/browse/FLINK-4538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15470065#comment-15470065
]
ASF GitHub Bot commented on FLINK-4538:
---
Github user mxm commented on a diff in the
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2463#discussion_r77783497
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/highavailability/LeaderIdRegistry.java
---
@@ -15,11 +15,27 @@
* See the License for the spe
[
https://issues.apache.org/jira/browse/FLINK-4547?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15470051#comment-15470051
]
ASF GitHub Bot commented on FLINK-4547:
---
Github user tillrohrmann commented on a dif
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/2455#discussion_r77782622
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rpc/akka/AkkaInvocationHandler.java
---
@@ -189,7 +191,49 @@ public void stop() {
[
https://issues.apache.org/jira/browse/FLINK-4547?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15469997#comment-15469997
]
ASF GitHub Bot commented on FLINK-4547:
---
Github user beyond1920 commented on the iss
Github user beyond1920 commented on the issue:
https://github.com/apache/flink/pull/2455
@tillrohrmann @StephanEwen , thanks for your review. I changed the code
based on your comment, including two points:
1. Change the JIRA and the PR subject line to better reflect the actual
cha
Github user chobeat commented on a diff in the pull request:
https://github.com/apache/flink/pull/2149#discussion_r7389
--- Diff: docs/apis/cli.md ---
@@ -187,6 +187,8 @@ Action "run" compiles and runs a program.
java.net.URLClassLo
[
https://issues.apache.org/jira/browse/FLINK-4084?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15469963#comment-15469963
]
ASF GitHub Bot commented on FLINK-4084:
---
Github user chobeat commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-3042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15469960#comment-15469960
]
ASF GitHub Bot commented on FLINK-3042:
---
Github user twalthr commented on a diff in
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/2337#discussion_r7227
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/typeinfo/TypeInformation.java
---
@@ -122,14 +123,25 @@
public abstract Class getTypeC
[
https://issues.apache.org/jira/browse/FLINK-4565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15469879#comment-15469879
]
Timo Walther commented on FLINK-4565:
-
It seems my answer was to late. Yes, I would al
[
https://issues.apache.org/jira/browse/FLINK-4565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15469873#comment-15469873
]
Timo Walther commented on FLINK-4565:
-
Calcite translates the IN operator in
{{org.ap
[
https://issues.apache.org/jira/browse/FLINK-4565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15469851#comment-15469851
]
Simone Robutti commented on FLINK-4565:
---
I imagined it could happen that way and I w
[
https://issues.apache.org/jira/browse/FLINK-4565?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Simone Robutti reassigned FLINK-4565:
-
Assignee: Simone Robutti
> Support for SQL IN operator
> ---
>
>
[
https://issues.apache.org/jira/browse/FLINK-4565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15469836#comment-15469836
]
Fabian Hueske commented on FLINK-4565:
--
SQL {{IN}} does not require a special impleme
[
https://issues.apache.org/jira/browse/FLINK-4538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15469801#comment-15469801
]
ASF GitHub Bot commented on FLINK-4538:
---
Github user beyond1920 commented on a diff
Github user beyond1920 commented on a diff in the pull request:
https://github.com/apache/flink/pull/2463#discussion_r77769044
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/slotmanager/SlotManager.java
---
@@ -89,32 +93,37 @@ public SlotManager(Res
[
https://issues.apache.org/jira/browse/FLINK-4565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15469797#comment-15469797
]
Simone Robutti commented on FLINK-4565:
---
Actually the confusing part is that the tra
90 matches
Mail list logo
