Github user wuchong commented on a diff in the pull request:
https://github.com/apache/flink/pull/2319#discussion_r75998992
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/scala/table/expressionDsl.scala
---
@@ -223,10 +223,28 @@ trait ImplicitExpressionO
[
https://issues.apache.org/jira/browse/FLINK-4294?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15434228#comment-15434228
]
ASF GitHub Bot commented on FLINK-4294:
---
Github user wuchong commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15434205#comment-15434205
]
ASF GitHub Bot commented on FLINK-4437:
---
Github user ramkrish86 commented on the iss
Github user ramkrish86 commented on the issue:
https://github.com/apache/flink/pull/2409
If the lock scope is going to be moved for the entire triggerCheckpoint()
method then
`// since we released the lock in the meantime, we need to re-check
/
[
https://issues.apache.org/jira/browse/FLINK-4363?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15434147#comment-15434147
]
ASF GitHub Bot commented on FLINK-4363:
---
Github user wangzhijiang999 commented on th
Github user wangzhijiang999 commented on the issue:
https://github.com/apache/flink/pull/2400
Hi @mxm , I pushed some modifications based on your comments, including:
1. Make var as final
2. Implement TaskExecutorConfiguration class in java instead of
TaskManagerConfiguration i
[
https://issues.apache.org/jira/browse/FLINK-4348?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15434129#comment-15434129
]
ASF GitHub Bot commented on FLINK-4348:
---
Github user beyond1920 closed the pull requ
Github user beyond1920 closed the pull request at:
https://github.com/apache/flink/pull/2389
---
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
[
https://issues.apache.org/jira/browse/FLINK-4453?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15434116#comment-15434116
]
ASF GitHub Bot commented on FLINK-4453:
---
GitHub user wuchong opened a pull request:
GitHub user wuchong opened a pull request:
https://github.com/apache/flink/pull/2411
[FLINK-4453] [docs] Scala code example in Window documentation shows Java
quick fix... ð
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/wuc
[
https://issues.apache.org/jira/browse/FLINK-4348?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15434113#comment-15434113
]
ASF GitHub Bot commented on FLINK-4348:
---
Github user beyond1920 commented on the iss
Github user beyond1920 commented on the issue:
https://github.com/apache/flink/pull/2389
Hi, till. I submit a new PR #2410 which is focus on heartbeat. Please
review that PR, thanks very much.
---
If your project is set up for it, you can reply to this email and have your
reply app
[
https://issues.apache.org/jira/browse/FLINK-4449?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15434112#comment-15434112
]
ASF GitHub Bot commented on FLINK-4449:
---
GitHub user beyond1920 opened a pull reques
[
https://issues.apache.org/jira/browse/FLINK-4453?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu reassigned FLINK-4453:
--
Assignee: Jark Wu
> Scala code example in Window documentation shows Java
> ---
GitHub user beyond1920 opened a pull request:
https://github.com/apache/flink/pull/2410
[FLINK-4449] [cluster management] Heartbeat Manager between ResourceManager
and TaskExecutor
The PR is focus on Heartbeat Manager between ResourceManager and
TaskExecutor.
HeartbeatManager i
[
https://issues.apache.org/jira/browse/FLINK-4448?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xiaogang Shi closed FLINK-4448.
---
Resolution: Fixed
The functionality will be implemented in Flink-4457
https://issues.apache.org/jira/
[
https://issues.apache.org/jira/browse/FLINK-4408?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15434052#comment-15434052
]
Xiaogang Shi commented on FLINK-4408:
-
I think it's okay to pull the logics about lead
[
https://issues.apache.org/jira/browse/FLINK-4443?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15434046#comment-15434046
]
ASF GitHub Bot commented on FLINK-4443:
---
Github user wenlong88 closed the pull reque
Github user wenlong88 closed the pull request at:
https://github.com/apache/flink/pull/2401
---
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-4443?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15434044#comment-15434044
]
ASF GitHub Bot commented on FLINK-4443:
---
GitHub user wenlong88 reopened a pull reque
GitHub user wenlong88 reopened a pull request:
https://github.com/apache/flink/pull/2401
[FLINK-4443][rpc] Add support in RpcCompletenessTest for inheritance of
RpcGateway and RpcEndpoint
RpcCompletenessTest needs to support RpcGateway which is composited by some
basic functions li
[
https://issues.apache.org/jira/browse/FLINK-4443?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15434043#comment-15434043
]
ASF GitHub Bot commented on FLINK-4443:
---
Github user wenlong88 closed the pull reque
Github user wenlong88 closed the pull request at:
https://github.com/apache/flink/pull/2401
---
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-4100?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15433925#comment-15433925
]
Neelesh Srinivas Salian commented on FLINK-4100:
Hi,
Shall I go work on th
[
https://issues.apache.org/jira/browse/FLINK-3899?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15433883#comment-15433883
]
ASF GitHub Bot commented on FLINK-3899:
---
Github user danielblazevski commented on a
Github user danielblazevski commented on a diff in the pull request:
https://github.com/apache/flink/pull/2368#discussion_r75973261
--- Diff: docs/apis/streaming/windows.md ---
@@ -459,42 +459,106 @@ ready for processing. This allows to get the benefit
of incremental window compu
[
https://issues.apache.org/jira/browse/FLINK-4440?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15433851#comment-15433851
]
Ivan Mushketyk commented on FLINK-4440:
---
I assume that it will be used for instantia
[
https://issues.apache.org/jira/browse/FLINK-4341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15433850#comment-15433850
]
Tzu-Li (Gordon) Tai commented on FLINK-4341:
I agree. I've been trying around
[
https://issues.apache.org/jira/browse/FLINK-4418?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15433839#comment-15433839
]
Shannon Carey commented on FLINK-4418:
--
Thanks [~rmetzger]. Should I mark the issue a
Github user mushketyk commented on the issue:
https://github.com/apache/flink/pull/2244
@fhueske I've fixed the PR according to your review.
The only thing that I didn't do is reusing `ObjectNode` on every iteration.
It caused some weird NPEs during the integration tests and made c
[
https://issues.apache.org/jira/browse/FLINK-3874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15433831#comment-15433831
]
ASF GitHub Bot commented on FLINK-3874:
---
Github user mushketyk commented on the issu
[
https://issues.apache.org/jira/browse/FLINK-3899?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15433743#comment-15433743
]
ASF GitHub Bot commented on FLINK-3899:
---
Github user danielblazevski commented on a
Github user danielblazevski commented on a diff in the pull request:
https://github.com/apache/flink/pull/2368#discussion_r75961552
--- Diff: docs/apis/streaming/windows.md ---
@@ -459,42 +459,106 @@ ready for processing. This allows to get the benefit
of incremental window compu
[
https://issues.apache.org/jira/browse/FLINK-3899?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15433701#comment-15433701
]
ASF GitHub Bot commented on FLINK-3899:
---
Github user fhueske commented on the issue:
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/2368
No worries :-)
---
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
Github user danielblazevski commented on the issue:
https://github.com/apache/flink/pull/2368
Sorry, indeed, added that when playing around that the open PR to add
`FlinkCodyStyle.xml`
---
If your project is set up for it, you can reply to this email and have your
reply appear on Git
[
https://issues.apache.org/jira/browse/FLINK-3899?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15433689#comment-15433689
]
ASF GitHub Bot commented on FLINK-3899:
---
Github user danielblazevski commented on a
[
https://issues.apache.org/jira/browse/FLINK-3874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15433692#comment-15433692
]
ASF GitHub Bot commented on FLINK-3874:
---
Github user fhueske commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-3899?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15433698#comment-15433698
]
ASF GitHub Bot commented on FLINK-3899:
---
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/2368#discussion_r75959873
--- Diff: docs/apis/streaming/windows.md ---
@@ -459,42 +459,106 @@ ready for processing. This allows to get the benefit
of incremental window compu
the
[
https://issues.apache.org/jira/browse/FLINK-4148?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15433696#comment-15433696
]
Neelesh Srinivas Salian commented on FLINK-4148:
[~humanoid], thank you fo
[
https://issues.apache.org/jira/browse/FLINK-3899?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15433693#comment-15433693
]
ASF GitHub Bot commented on FLINK-3899:
---
Github user danielblazevski commented on th
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/2244
Ah, I see. Very good :-)
---
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
Github user danielblazevski commented on a diff in the pull request:
https://github.com/apache/flink/pull/2368#discussion_r75958831
--- Diff: docs/apis/streaming/windows.md ---
@@ -459,42 +459,106 @@ ready for processing. This allows to get the benefit
of incremental window compu
[
https://issues.apache.org/jira/browse/FLINK-3874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15433687#comment-15433687
]
ASF GitHub Bot commented on FLINK-3874:
---
Github user mushketyk commented on the issu
Github user mushketyk commented on the issue:
https://github.com/apache/flink/pull/2244
Hi @fhueske, I am running `mvn clean verify` locally right now and I hope
to update the commit soon.
Sorry for confusing you.
---
If your project is set up for it, you can reply to this e
[
https://issues.apache.org/jira/browse/FLINK-3030?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15433685#comment-15433685
]
Ivan Mushketyk commented on FLINK-3030:
---
I will works on this.
> Enhance Dashboard
[
https://issues.apache.org/jira/browse/FLINK-3030?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ivan Mushketyk reassigned FLINK-3030:
-
Assignee: Ivan Mushketyk
> Enhance Dashboard to show Execution Attempts
> ---
[
https://issues.apache.org/jira/browse/FLINK-2944?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15433683#comment-15433683
]
Ivan Mushketyk commented on FLINK-2944:
---
Is this somehow related to this issue:
ht
[
https://issues.apache.org/jira/browse/FLINK-3874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15433662#comment-15433662
]
ASF GitHub Bot commented on FLINK-3874:
---
Github user fhueske commented on the issue:
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/2244
Hi @mushketyk, thanks for the fast reply.
I saw your comments but no new commit. Did you forget to push to your PR
branch?
Thanks, Fabian
---
If your project is set up for it, you can
[
https://issues.apache.org/jira/browse/FLINK-3899?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15433654#comment-15433654
]
ASF GitHub Bot commented on FLINK-3899:
---
Github user fhueske commented on the issue:
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/2368
Thanks for the fast update @danielblazevski.
I think you accidentally added `tools/FlinkCodyStyle.xml` to your commit.
---
If your project is set up for it, you can reply to this email and have
[
https://issues.apache.org/jira/browse/FLINK-4231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15433647#comment-15433647
]
ASF GitHub Bot commented on FLINK-4231:
---
Github user fhueske commented on the issue:
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/2272
Thanks for the update @greghogan.
+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 project does not have this fe
[
https://issues.apache.org/jira/browse/FLINK-3414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15404852#comment-15404852
]
Ivan Mushketyk edited comment on FLINK-3414 at 8/23/16 8:37 PM:
[
https://issues.apache.org/jira/browse/FLINK-3414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15404852#comment-15404852
]
Ivan Mushketyk edited comment on FLINK-3414 at 8/23/16 8:34 PM:
[
https://issues.apache.org/jira/browse/FLINK-3874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15433508#comment-15433508
]
ASF GitHub Bot commented on FLINK-3874:
---
Github user mushketyk commented on a diff i
[
https://issues.apache.org/jira/browse/FLINK-3874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15433512#comment-15433512
]
ASF GitHub Bot commented on FLINK-3874:
---
Github user mushketyk commented on a diff i
[
https://issues.apache.org/jira/browse/FLINK-3874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15433511#comment-15433511
]
ASF GitHub Bot commented on FLINK-3874:
---
Github user mushketyk commented on a diff i
[
https://issues.apache.org/jira/browse/FLINK-3874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15433507#comment-15433507
]
ASF GitHub Bot commented on FLINK-3874:
---
Github user mushketyk commented on a diff i
[
https://issues.apache.org/jira/browse/FLINK-3874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15433510#comment-15433510
]
ASF GitHub Bot commented on FLINK-3874:
---
Github user mushketyk commented on a diff i
Github user mushketyk commented on a diff in the pull request:
https://github.com/apache/flink/pull/2244#discussion_r75938989
--- Diff:
flink-streaming-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/JsonRowSerializationSchemaTest.java
-
Github user mushketyk commented on a diff in the pull request:
https://github.com/apache/flink/pull/2244#discussion_r75939007
--- Diff:
flink-streaming-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaTableSinkTestBase.java
---
@
Github user mushketyk commented on a diff in the pull request:
https://github.com/apache/flink/pull/2244#discussion_r75938972
--- Diff:
flink-streaming-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/util/serialization/JsonRowSerializationSchema.java
---
Github user mushketyk commented on a diff in the pull request:
https://github.com/apache/flink/pull/2244#discussion_r75938953
--- Diff:
flink-streaming-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/KafkaTableSink.java
---
@@ -0,0 +
Github user mushketyk commented on a diff in the pull request:
https://github.com/apache/flink/pull/2244#discussion_r75938937
--- Diff:
flink-streaming-connectors/flink-connector-kafka-0.9/src/test/java/org/apache/flink/streaming/connectors/kafka/Kafka09JsonTableSinkTest.java
---
[
https://issues.apache.org/jira/browse/FLINK-3874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15433505#comment-15433505
]
ASF GitHub Bot commented on FLINK-3874:
---
Github user mushketyk commented on a diff i
Github user mushketyk commented on a diff in the pull request:
https://github.com/apache/flink/pull/2244#discussion_r75938899
--- Diff:
flink-streaming-connectors/flink-connector-kafka-0.8/src/test/java/org/apache/flink/streaming/connectors/kafka/Kafka08JsonTableSinkTest.java
---
[
https://issues.apache.org/jira/browse/FLINK-3874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15433506#comment-15433506
]
ASF GitHub Bot commented on FLINK-3874:
---
Github user mushketyk commented on a diff i
[
https://issues.apache.org/jira/browse/FLINK-3874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15433504#comment-15433504
]
ASF GitHub Bot commented on FLINK-3874:
---
Github user mushketyk commented on a diff i
Github user mushketyk commented on a diff in the pull request:
https://github.com/apache/flink/pull/2244#discussion_r75938768
--- Diff:
flink-streaming-connectors/flink-connector-kafka-0.9/src/main/java/org/apache/flink/streaming/connectors/kafka/Kafka09JsonTableSink.java
---
@@ -
Github user mushketyk commented on a diff in the pull request:
https://github.com/apache/flink/pull/2244#discussion_r75938748
--- Diff:
flink-streaming-connectors/flink-connector-kafka-0.9/src/main/java/org/apache/flink/streaming/connectors/kafka/Kafka09JsonTableSink.java
---
@@ -
[
https://issues.apache.org/jira/browse/FLINK-3874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15433501#comment-15433501
]
ASF GitHub Bot commented on FLINK-3874:
---
Github user mushketyk commented on a diff i
[
https://issues.apache.org/jira/browse/FLINK-3874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15433502#comment-15433502
]
ASF GitHub Bot commented on FLINK-3874:
---
Github user mushketyk commented on a diff i
Github user mushketyk commented on a diff in the pull request:
https://github.com/apache/flink/pull/2244#discussion_r75938632
--- Diff:
flink-streaming-connectors/flink-connector-kafka-0.8/src/main/java/org/apache/flink/streaming/connectors/kafka/Kafka08JsonTableSink.java
---
@@ -
[
https://issues.apache.org/jira/browse/FLINK-3874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15433500#comment-15433500
]
ASF GitHub Bot commented on FLINK-3874:
---
Github user mushketyk commented on a diff i
Github user mushketyk commented on a diff in the pull request:
https://github.com/apache/flink/pull/2244#discussion_r75938617
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/table.scala
---
@@ -26,6 +26,8 @@ import org.apache.flink.api.table.plan.lo
Github user mushketyk commented on a diff in the pull request:
https://github.com/apache/flink/pull/2244#discussion_r75938654
--- Diff:
flink-streaming-connectors/flink-connector-kafka-0.8/src/main/java/org/apache/flink/streaming/connectors/kafka/Kafka08JsonTableSink.java
---
@@ -
[
https://issues.apache.org/jira/browse/FLINK-3874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15433498#comment-15433498
]
ASF GitHub Bot commented on FLINK-3874:
---
Github user mushketyk commented on a diff i
Github user mushketyk commented on a diff in the pull request:
https://github.com/apache/flink/pull/2244#discussion_r75938408
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/sinks/TableSink.scala
---
@@ -41,46 +38,13 @@ trait TableSink[T] {
[
https://issues.apache.org/jira/browse/FLINK-4209?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15433418#comment-15433418
]
ASF GitHub Bot commented on FLINK-4209:
---
Github user jagatfx commented on the issue:
GitHub user tedyu opened a pull request:
https://github.com/apache/flink/pull/2409
FLINK-4437 Lock evasion around lastTriggeredCheckpoint may lead to lost
updates to related fields
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the following
Github user jagatfx commented on the issue:
https://github.com/apache/flink/pull/2240
@iemejia Were you able to followup on creating the official docker image.
It's a great idea.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub a
[
https://issues.apache.org/jira/browse/FLINK-4437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15433417#comment-15433417
]
ASF GitHub Bot commented on FLINK-4437:
---
GitHub user tedyu opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-4452?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15433407#comment-15433407
]
ASF GitHub Bot commented on FLINK-4452:
---
GitHub user greghogan opened a pull request
GitHub user greghogan opened a pull request:
https://github.com/apache/flink/pull/2408
[FLINK-4452] TaskManager network buffer gauges
Adds gauges for the number of total and available TaskManager network
memory segments.
You can merge this pull request into a Git repository by runn
[
https://issues.apache.org/jira/browse/FLINK-4452?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Hogan updated FLINK-4452:
--
Description:
Add gauges for {{network.getNetworkBufferPool.getTotalNumberOfMemorySegments}}
and {{netwo
[
https://issues.apache.org/jira/browse/FLINK-4452?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Hogan updated FLINK-4452:
--
Summary: TaskManager network buffer gauges (was: TaskManager network
buffer guages)
> TaskManager netw
[
https://issues.apache.org/jira/browse/FLINK-4408?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15433387#comment-15433387
]
Stephan Ewen commented on FLINK-4408:
-
I would actually like to pull this logic out of
Chen Qin created FLINK-4460:
---
Summary: Expose Late Arriving Events
Key: FLINK-4460
URL: https://issues.apache.org/jira/browse/FLINK-4460
Project: Flink
Issue Type: Improvement
Components:
[
https://issues.apache.org/jira/browse/FLINK-4449?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15433305#comment-15433305
]
Till Rohrmann commented on FLINK-4449:
--
Can we create a generic {{HeartbeatManager}}
Till Rohrmann created FLINK-4459:
Summary: Introduce SlotProvider to Scheduler
Key: FLINK-4459
URL: https://issues.apache.org/jira/browse/FLINK-4459
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-4459?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-4459:
-
Summary: Introduce SlotProvider for Scheduler (was: Introduce SlotProvider
to Scheduler)
> Intro
[
https://issues.apache.org/jira/browse/FLINK-4437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15433273#comment-15433273
]
ramkrishna.s.vasudevan commented on FLINK-4437:
---
bq.I wonder whether we shou
Till Rohrmann created FLINK-4458:
Summary: Remove ForkableFlinkMiniCluster
Key: FLINK-4458
URL: https://issues.apache.org/jira/browse/FLINK-4458
Project: Flink
Issue Type: Improvement
Till Rohrmann created FLINK-4457:
Summary: Make the ExecutionGraph independent of Akka
Key: FLINK-4457
URL: https://issues.apache.org/jira/browse/FLINK-4457
Project: Flink
Issue Type: Improve
[
https://issues.apache.org/jira/browse/FLINK-4435?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-4435.
---
> Replace Guava's VisibleForTesting annotation with Flink's annotation
> -
[
https://issues.apache.org/jira/browse/FLINK-4435?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-4435.
-
Resolution: Fixed
Fixed via 863dc180546ee782d30d8f24a7e488f28c4a91a9
Thank you for the contributi
[
https://issues.apache.org/jira/browse/FLINK-4437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15433216#comment-15433216
]
Stephan Ewen commented on FLINK-4437:
-
Actually, there are a few more things that can
1 - 100 of 338 matches
Mail list logo
