Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/3349
Awesome to see that Flink is that easy to install in DC/OS...
Merging this...
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as we
[
https://issues.apache.org/jira/browse/FLINK-5828?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15872105#comment-15872105
]
ASF GitHub Bot commented on FLINK-5828:
---
Github user StephanEwen commented on the is
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/3342
Merging this...
---
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, o
[
https://issues.apache.org/jira/browse/FLINK-5837?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15872103#comment-15872103
]
ASF GitHub Bot commented on FLINK-5837:
---
GitHub user alpinegizmo opened a pull reque
GitHub user alpinegizmo opened a pull request:
https://github.com/apache/flink/pull/3350
[FLINK-5837][docs] improve readability of the queryable state docs
Some edits to make the page read better. Also, a blank line was missing, so
the bullet list at line 55 wasn't actually a bullet
[
https://issues.apache.org/jira/browse/FLINK-5747?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15872093#comment-15872093
]
ASF GitHub Bot commented on FLINK-5747:
---
Github user tillrohrmann commented on the i
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/3295
+1 for merging
---
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, o
David Anderson created FLINK-5837:
-
Summary: improve readability of the queryable state docs
Key: FLINK-5837
URL: https://issues.apache.org/jira/browse/FLINK-5837
Project: Flink
Issue Type: I
[
https://issues.apache.org/jira/browse/FLINK-4997?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15872059#comment-15872059
]
ASF GitHub Bot commented on FLINK-4997:
---
Github user aljoscha commented on the issue
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/2756
I finally merged it! Thanks for staying with this for so long and working
on this, @VenturaDelMonte ð
Hopefully, we can now make faster progress.
Could you please close this PR?
[
https://issues.apache.org/jira/browse/FLINK-4997?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek closed FLINK-4997.
---
Resolution: Fixed
Fix Version/s: 1.3.0
Implemented in:
1dcb2dcd8969941988a4fc7e5488e927
[
https://issues.apache.org/jira/browse/FLINK-5825?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi closed FLINK-5825.
--
Resolution: Fixed
Fix Version/s: 1.2.1
1.3.0
Fixed in a2b0816 (master), 69d453
[
https://issues.apache.org/jira/browse/FLINK-5825?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15872037#comment-15872037
]
ASF GitHub Bot commented on FLINK-5825:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/3337
---
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-4997?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15872033#comment-15872033
]
ASF GitHub Bot commented on FLINK-4997:
---
Github user aljoscha closed the pull reques
Github user aljoscha closed the pull request at:
https://github.com/apache/flink/pull/3285
---
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 en
[
https://issues.apache.org/jira/browse/FLINK-4460?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15872032#comment-15872032
]
ASF GitHub Bot commented on FLINK-4460:
---
Github user aljoscha commented on the issue
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/2982
@chenqin
I rebased and consolidated your PR a bit and played around with the APIs.
Some of the changes:
- Separation into internal changes/window operator changes and
user-fun
[
https://issues.apache.org/jira/browse/FLINK-5687?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu resolved FLINK-5687.
---
Resolution: Not A Problem
> Missing null check for return value from listFiles() in JarListHandler
> -
[
https://issues.apache.org/jira/browse/FLINK-5751?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15872025#comment-15872025
]
ASF GitHub Bot commented on FLINK-5751:
---
Github user patricklucas commented on a dif
Github user patricklucas commented on a diff in the pull request:
https://github.com/apache/flink/pull/3332#discussion_r101786279
--- Diff: docs/check_links.sh ---
@@ -0,0 +1,36 @@
+#!/usr/bin/env bash
+###
[
https://issues.apache.org/jira/browse/FLINK-5751?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15872022#comment-15872022
]
ASF GitHub Bot commented on FLINK-5751:
---
Github user patricklucas commented on the i
Github user patricklucas commented on the issue:
https://github.com/apache/flink/pull/3332
:+1:
---
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 f
Github user joseprupi commented on the issue:
https://github.com/apache/flink/pull/2885
Done @vasia. Sorry :(
I'll be looking forward to modify anything you think that needs to be
modified. I can share the results I used to compare with scikit if you want.
Thanks!
[
https://issues.apache.org/jira/browse/FLINK-1707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15871997#comment-15871997
]
ASF GitHub Bot commented on FLINK-1707:
---
Github user joseprupi commented on the issu
GitHub user joerg84 opened a pull request:
https://github.com/apache/flink/pull/3349
Updated DC/OS setup instructions.
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the following check list into consideration.
If your changes take all of
[
https://issues.apache.org/jira/browse/FLINK-5795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15871951#comment-15871951
]
ASF GitHub Bot commented on FLINK-5795:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-5795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15871956#comment-15871956
]
ASF GitHub Bot commented on FLINK-5795:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-5795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15871952#comment-15871952
]
ASF GitHub Bot commented on FLINK-5795:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-5795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15871953#comment-15871953
]
ASF GitHub Bot commented on FLINK-5795:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-5795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15871954#comment-15871954
]
ASF GitHub Bot commented on FLINK-5795:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-5795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15871955#comment-15871955
]
ASF GitHub Bot commented on FLINK-5795:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-5795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15871950#comment-15871950
]
ASF GitHub Bot commented on FLINK-5795:
---
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/3330#discussion_r101759328
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/utils/UserDefinedFunctionUtils.scala
---
@@ -22,7 +22,9 @@ package org
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3330#discussion_r101762354
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/CodeGenerator.scala
---
@@ -1463,21 +1465,23 @@ class CodeGenerator(
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3330#discussion_r101775264
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/CodeGenerator.scala
---
@@ -1463,21 +1465,23 @@ class CodeGenerator(
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3330#discussion_r101765703
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/datastream/DataStreamUserDefinedFunctionITCase.scala
---
@@ -0,0 +1,80 @
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3330#discussion_r101765235
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/dataset/DataSetUserDefinedFunctionITCase.scala
---
@@ -0,0 +1,75 @@
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3330#discussion_r101760789
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/CodeGenerator.scala
---
@@ -1463,21 +1465,23 @@ class CodeGenerator(
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3330#discussion_r101763661
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/CodeGenerator.scala
---
@@ -1463,21 +1465,23 @@ class CodeGenerator(
[
https://issues.apache.org/jira/browse/FLINK-5090?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15871934#comment-15871934
]
ASF GitHub Bot commented on FLINK-5090:
---
GitHub user NicoK opened a pull request:
GitHub user NicoK opened a pull request:
https://github.com/apache/flink/pull/3348
[FLINK-5090] [network] Add metrics for details about inbound/outbound
network queues
These metrics are optimised go go through the channels only once in order to
gather all metrics, i.e. min, max,
[
https://issues.apache.org/jira/browse/FLINK-5747?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15871923#comment-15871923
]
ASF GitHub Bot commented on FLINK-5747:
---
Github user tillrohrmann commented on a dif
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/3295#discussion_r101766916
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/concurrent/FutureUtilsTest.java
---
@@ -0,0 +1,190 @@
+/*
+ * Licensed to the Ap
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/3295#discussion_r101766842
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionGraph.java
---
@@ -754,6 +759,139 @@ public void scheduleForExec
[
https://issues.apache.org/jira/browse/FLINK-5747?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15871921#comment-15871921
]
ASF GitHub Bot commented on FLINK-5747:
---
Github user tillrohrmann commented on a dif
[
https://issues.apache.org/jira/browse/FLINK-5747?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15871919#comment-15871919
]
ASF GitHub Bot commented on FLINK-5747:
---
Github user tillrohrmann commented on a dif
[
https://issues.apache.org/jira/browse/FLINK-5716?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai updated FLINK-5716:
---
Component/s: DataStream API
> Make streaming SourceContexts aware of source idleness
>
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/3295#discussion_r101765953
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/concurrent/FutureUtils.java
---
@@ -88,4 +100,104 @@ public RetryException(Throwable cau
[
https://issues.apache.org/jira/browse/FLINK-5716?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15871908#comment-15871908
]
ASF GitHub Bot commented on FLINK-5716:
---
GitHub user tzulitai opened a pull request:
GitHub user tzulitai opened a pull request:
https://github.com/apache/flink/pull/3347
[FLINK-5716] [streaming] Make StreamSourceContexts aware of source idleness
This PR is the second part of adding `StreamStatus` to the streaming
runtime to facilitate idle sources in Flink.
Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/3346#discussion_r101761879
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/AbstractStreamOperator.java
---
@@ -431,11 +436,12 @@ public void snapshot
Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/3346#discussion_r101760988
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinator.java
---
@@ -296,15 +298,42 @@ public boolean isShutdown() {
[
https://issues.apache.org/jira/browse/FLINK-5820?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15871885#comment-15871885
]
ASF GitHub Bot commented on FLINK-5820:
---
GitHub user uce opened a pull request:
GitHub user uce opened a pull request:
https://github.com/apache/flink/pull/3346
Selfcontained
This is based on #3345 and only the last two commits are relevant here.
I've separated the test changes (last commit) and the main changes (2nd last
commit) for better reviewability. I wo
[
https://issues.apache.org/jira/browse/FLINK-5763?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15871874#comment-15871874
]
ASF GitHub Bot commented on FLINK-5763:
---
GitHub user uce opened a pull request:
GitHub user uce opened a pull request:
https://github.com/apache/flink/pull/3345
[FLINK-5763] [checkpoints] Minor meta data refactorings
This PR groups some refactorings I did as part of FLINK-5763 into a
separate PR.
1) Acknowledges with explicit ID and `CheckpointMetrics`
[
https://issues.apache.org/jira/browse/FLINK-5817?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15871867#comment-15871867
]
ASF GitHub Bot commented on FLINK-5817:
---
Github user NicoK commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-5402?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15871846#comment-15871846
]
Dawid Wysakowicz edited comment on FLINK-5402 at 2/17/17 1:41 PM:
--
Github user NicoK commented on the issue:
https://github.com/apache/flink/pull/3341
Thanks, this looks like a really nice addition and simplifies the code a
lot.
---
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
Till Rohrmann created FLINK-5836:
Summary: Race condition between slot offering and task deployment
Key: FLINK-5836
URL: https://issues.apache.org/jira/browse/FLINK-5836
Project: Flink
Issue
Zhuoluo Yang created FLINK-5835:
---
Summary: Support for Hive's User-defined Aggregation Function
(UDAF)
Key: FLINK-5835
URL: https://issues.apache.org/jira/browse/FLINK-5835
Project: Flink
Issu
[
https://issues.apache.org/jira/browse/FLINK-5833?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhuoluo Yang reassigned FLINK-5833:
---
Assignee: Zhuoluo Yang
> Support for Hive GenericUDF
> ---
>
>
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3269#discussion_r101739816
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/sources/NestedFieldsProjectableTableSource.scala
---
@@ -0,0 +1,39 @@
+/*
Zhuoluo Yang created FLINK-5834:
---
Summary: Support for Hive User-defined Table-generating Function
(UDTF)
Key: FLINK-5834
URL: https://issues.apache.org/jira/browse/FLINK-5834
Project: Flink
I
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3269#discussion_r101755176
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/rules/util/RexProgramProjectExtractor.scala
---
@@ -84,6 +105,39 @@ object
[
https://issues.apache.org/jira/browse/FLINK-5698?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15871864#comment-15871864
]
ASF GitHub Bot commented on FLINK-5698:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-5698?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15871865#comment-15871865
]
ASF GitHub Bot commented on FLINK-5698:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4856?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15871850#comment-15871850
]
ASF GitHub Bot commented on FLINK-4856:
---
Github user aljoscha commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4856?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15871851#comment-15871851
]
ASF GitHub Bot commented on FLINK-4856:
---
Github user aljoscha commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4856?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15871849#comment-15871849
]
ASF GitHub Bot commented on FLINK-4856:
---
Github user aljoscha commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4856?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15871852#comment-15871852
]
ASF GitHub Bot commented on FLINK-4856:
---
Github user aljoscha commented on a diff in
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/3336#discussion_r101749935
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/state/MapState.java ---
@@ -0,0 +1,111 @@
+/*
+ * Licensed to the Apache Software Fou
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/3336#discussion_r101750130
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/MapSerializer.java
---
@@ -0,0 +1,179 @@
+/*
+ * Licensed to the Apac
[
https://issues.apache.org/jira/browse/FLINK-5402?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15871846#comment-15871846
]
Dawid Wysakowicz commented on FLINK-5402:
-
It is very macOS specific case. It is d
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/3336#discussion_r101750262
--- Diff:
flink-core/src/main/java/org/apache/flink/api/java/typeutils/MapTypeInfo.java
---
@@ -0,0 +1,147 @@
+/*
+ * Licensed to the Apache Softwa
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/3336#discussion_r10175
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/state/MapStateDescriptor.java
---
@@ -0,0 +1,132 @@
+/*
+ * Licensed to the Apache S
[
https://issues.apache.org/jira/browse/FLINK-5758?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-5758:
-
Affects Version/s: 1.3.0
> Port-range for the web interface via YARN
> ---
[
https://issues.apache.org/jira/browse/FLINK-5744?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-5744:
-
Affects Version/s: 1.3.0
> Check remote connection in Flink-shell
> --
[
https://issues.apache.org/jira/browse/FLINK-5758?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-5758:
-
Component/s: (was: Web Client)
> Port-range for the web interface via YARN
> -
Zhuoluo Yang created FLINK-5833:
---
Summary: Support for Hive GenericUDF
Key: FLINK-5833
URL: https://issues.apache.org/jira/browse/FLINK-5833
Project: Flink
Issue Type: Sub-task
Repo
Zhuoluo Yang created FLINK-5832:
---
Summary: Support for simple hive UDF
Key: FLINK-5832
URL: https://issues.apache.org/jira/browse/FLINK-5832
Project: Flink
Issue Type: Sub-task
Repo
[
https://issues.apache.org/jira/browse/FLINK-5791?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15871841#comment-15871841
]
ASF GitHub Bot commented on FLINK-5791:
---
Github user tillrohrmann commented on the i
[
https://issues.apache.org/jira/browse/FLINK-5389?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15871840#comment-15871840
]
Dawid Wysakowicz edited comment on FLINK-5389 at 2/17/17 1:21 PM:
--
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/3295#discussion_r101754578
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/concurrent/FutureUtils.java
---
@@ -88,4 +100,104 @@ public RetryException(Throwable caus
[
https://issues.apache.org/jira/browse/FLINK-5747?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15871843#comment-15871843
]
ASF GitHub Bot commented on FLINK-5747:
---
Github user StephanEwen commented on a diff
[
https://issues.apache.org/jira/browse/FLINK-5389?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15871840#comment-15871840
]
Dawid Wysakowicz commented on FLINK-5389:
-
Same reason for failing those tests.
>
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/3304
Hi @shuai-xu, thanks for your contribution :-) I'm currently working on a
new implementation of the slot manager. So we might have to rebase this PR
then. But the changes are not too big. I try
[
https://issues.apache.org/jira/browse/FLINK-5799?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15871839#comment-15871839
]
Till Rohrmann commented on FLINK-5799:
--
[~wangzj], yes you're right. We can change th
[
https://issues.apache.org/jira/browse/FLINK-5747?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15871838#comment-15871838
]
ASF GitHub Bot commented on FLINK-5747:
---
Github user StephanEwen commented on a diff
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/3295#discussion_r101753992
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionGraph.java
---
@@ -292,7 +305,8 @@ public ExecutionGraph(
[
https://issues.apache.org/jira/browse/FLINK-5402?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15871836#comment-15871836
]
ASF GitHub Bot commented on FLINK-5402:
---
Github user dawidwys closed the pull reques
[
https://issues.apache.org/jira/browse/FLINK-5747?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15871835#comment-15871835
]
ASF GitHub Bot commented on FLINK-5747:
---
Github user StephanEwen commented on a diff
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/3295#discussion_r101753888
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionGraph.java
---
@@ -754,6 +759,139 @@ public void scheduleForExecu
[
https://issues.apache.org/jira/browse/FLINK-5815?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15871834#comment-15871834
]
Till Rohrmann commented on FLINK-5815:
--
Hi Wenlong, just wanted to ask whether you're
Github user dawidwys closed the pull request at:
https://github.com/apache/flink/pull/3343
---
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 en
[
https://issues.apache.org/jira/browse/FLINK-5815?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-5815:
-
Affects Version/s: 1.3.0
> Add resource files configuration for Yarn Mode
> --
[
https://issues.apache.org/jira/browse/FLINK-5747?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15871830#comment-15871830
]
ASF GitHub Bot commented on FLINK-5747:
---
Github user StephanEwen commented on a diff
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/3295#discussion_r101753597
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionGraphUtils.java
---
@@ -0,0 +1,108 @@
+/*
+ * Licensed to
[
https://issues.apache.org/jira/browse/FLINK-5815?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-5815:
-
Component/s: (was: Distributed Coordination)
YARN
> Add resource files config
101 - 200 of 306 matches
Mail list logo
