Github user pnowojski commented on the issue:
https://github.com/apache/flink/pull/4748
Thanks for merging!
---
[
https://issues.apache.org/jira/browse/FLINK-7406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16268278#comment-16268278
]
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 submit the codes for the missed comments, @NicoK
---
[
https://issues.apache.org/jira/browse/FLINK-7456?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16268222#comment-16268222
]
ASF GitHub Bot commented on FLINK-7456:
---
Github user zhijiangW commented on a diff i
Github user zhijiangW commented on a diff in the pull request:
https://github.com/apache/flink/pull/4552#discussion_r153405989
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/NetworkEnvironment.java
---
@@ -224,17 +224,9 @@ public void registerTask(Task t
[
https://issues.apache.org/jira/browse/FLINK-7456?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16268209#comment-16268209
]
ASF GitHub Bot commented on FLINK-7456:
---
Github user zhijiangW commented on the issu
Github user zhijiangW commented on the issue:
https://github.com/apache/flink/pull/4552
@NicoK , thanks for focusing on the last PR.
I am supposed to divide this into two separate ones as you said. But I am
afraid some current tests may fail if I only modify and enable the cre
[
https://issues.apache.org/jira/browse/FLINK-7468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16268193#comment-16268193
]
ASF GitHub Bot commented on FLINK-7468:
---
Github user zhijiangW commented on the issu
Github user zhijiangW commented on the issue:
https://github.com/apache/flink/pull/4559
@zentol , the failure travis seems no related with my codes. Do I need to
restart the travis to pass the tests before merging this PR?
---
Github user zhijiangW commented on the issue:
https://github.com/apache/flink/pull/4533
@NicoK , I updated the codes for the above comments.
---
[
https://issues.apache.org/jira/browse/FLINK-7416?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16268186#comment-16268186
]
ASF GitHub Bot commented on FLINK-7416:
---
Github user zhijiangW commented on the issu
[
https://issues.apache.org/jira/browse/FLINK-7416?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16268180#comment-16268180
]
ASF GitHub Bot commented on FLINK-7416:
---
Github user zhijiangW commented on a diff i
Github user zhijiangW commented on a diff in the pull request:
https://github.com/apache/flink/pull/4533#discussion_r153401374
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/RemoteInputChannel.java
---
@@ -283,10 +283,13 @@ public Stri
[
https://issues.apache.org/jira/browse/FLINK-8139?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16268127#comment-16268127
]
Aegeaner commented on FLINK-8139:
-
know it, we can get the type class.
> Check for proper
[
https://issues.apache.org/jira/browse/FLINK-7574?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16268126#comment-16268126
]
ASF GitHub Bot commented on FLINK-7574:
---
Github user yew1eb commented on the issue:
Github user yew1eb commented on the issue:
https://github.com/apache/flink/pull/5076
`mvn clean verify -pl flink-clients`, No dependency problems found.
> [INFO] --- maven-dependency-plugin:3.0.2:analyze-only (analyze) @
flink-clients_2.11 ---
> [INFO] No dependency proble
Github user Aegeaner commented on the issue:
https://github.com/apache/flink/pull/5065
@twalthr But when registering a table/TableSource, we only got a
`TableSchema`, which is an array of `TypeInformation` ? How should I check the
instances of values?
---
[
https://issues.apache.org/jira/browse/FLINK-8139?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16268123#comment-16268123
]
ASF GitHub Bot commented on FLINK-8139:
---
Github user Aegeaner commented on the issue
[
https://issues.apache.org/jira/browse/FLINK-8142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Hogan closed FLINK-8142.
-
Resolution: Implemented
master: f2b804a7479dcba7980dd68a445635f4ac2198c0
> Cleanup reference to deprecate
[
https://issues.apache.org/jira/browse/FLINK-7967?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Hogan closed FLINK-7967.
-
Resolution: Implemented
master: fae83c0b0c0a711d5d0f9de0b95fb6b703c4f912
> Deprecate Hadoop specific Flin
[
https://issues.apache.org/jira/browse/FLINK-8105?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Hogan closed FLINK-8105.
-
Resolution: Implemented
master: 3561222c5d6c7cee79f8c5872f32227632135c48
> Removed unnecessary null check
[
https://issues.apache.org/jira/browse/FLINK-7967?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Hogan updated FLINK-7967:
--
Fix Version/s: 1.5.0
> Deprecate Hadoop specific Flink configuration options
> -
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5034
---
[
https://issues.apache.org/jira/browse/FLINK-8105?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16268037#comment-16268037
]
ASF GitHub Bot commented on FLINK-8105:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-8142?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16268035#comment-16268035
]
ASF GitHub Bot commented on FLINK-8142:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/4946
---
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/4748
---
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5067
---
[
https://issues.apache.org/jira/browse/FLINK-7967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16268036#comment-16268036
]
ASF GitHub Bot commented on FLINK-7967:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-8155?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16268013#comment-16268013
]
jiesen.li commented on FLINK-8155:
--
no no no,same problem,I tried many versions about 1.3
[
https://issues.apache.org/jira/browse/FLINK-8158?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16267995#comment-16267995
]
Xingcan Cui commented on FLINK-8158:
Hi [~hequn8128], there's a document about the str
[
https://issues.apache.org/jira/browse/FLINK-8158?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16267990#comment-16267990
]
Hequn Cheng commented on FLINK-8158:
[~fhueske] [~xccui] hi, Moreover I am confused ab
[
https://issues.apache.org/jira/browse/FLINK-8158?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hequn Cheng updated FLINK-8158:
---
Attachment: screenshot-1xxx.png
> Rowtime window inner join emits late data
>
[
https://issues.apache.org/jira/browse/FLINK-7406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16267973#comment-16267973
]
ASF GitHub Bot commented on FLINK-7406:
---
Github user zhijiangW commented on a diff i
Github user zhijiangW commented on a diff in the pull request:
https://github.com/apache/flink/pull/4509#discussion_r153378748
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/RemoteInputChannel.java
---
@@ -572,20 +560,53 @@ void addExc
Github user ChrisChinchilla commented on the issue:
https://github.com/apache/flink/pull/5045
Changes pushed.
---
Github user ChrisChinchilla commented on a diff in the pull request:
https://github.com/apache/flink/pull/5045#discussion_r153374829
--- Diff: docs/concepts/runtime.md ---
@@ -74,10 +74,10 @@ To control how many tasks a worker accepts, a worker
has so called **task slots*
Each
Github user ChrisChinchilla commented on a diff in the pull request:
https://github.com/apache/flink/pull/5045#discussion_r153374312
--- Diff: docs/concepts/programming-model.md ---
@@ -33,53 +33,52 @@ Flink offers different levels of abstraction to develop
streaming/batch applicat
Github user dianfu commented on the issue:
https://github.com/apache/flink/pull/5063
@fhueske Thanks a lot for your comments. Definitely agree with you on the
motivation of punctuated watermark. But in practice, there are many cases there
is no watermark information in the source data
[
https://issues.apache.org/jira/browse/FLINK-8144?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16267921#comment-16267921
]
ASF GitHub Bot commented on FLINK-8144:
---
Github user dianfu commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-7636?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16267816#comment-16267816
]
ASF GitHub Bot commented on FLINK-7636:
---
Github user fhueske commented on the issue:
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/4681
Hi @beyond1920, I would like to apply your refactoring for the next release
1.5.0. However, we touched quite a few files for the refactoring of the
`TableSource` interface in Flink 1.4.0. Can you reb
[
https://issues.apache.org/jira/browse/FLINK-8144?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16267762#comment-16267762
]
ASF GitHub Bot commented on FLINK-8144:
---
Github user fhueske commented on the issue:
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/5063
A punctuated watermark assigner can emit `null` instead of a watermark. So
using a punctuated watermark assigner does not mean that for each event a
watermark must be emitted. The motivation for punc
[
https://issues.apache.org/jira/browse/FLINK-8162?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Cristian updated FLINK-8162:
Description:
When reading from Kinesis streams, one of the most valuable metrics is
"MillisBehindLatest" (s
Cristian created FLINK-8162:
---
Summary: Kinesis Connector to report millisBehindLatest metric
Key: FLINK-8162
URL: https://issues.apache.org/jira/browse/FLINK-8162
Project: Flink
Issue Type: Improve
[
https://issues.apache.org/jira/browse/FLINK-8126?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Hogan updated FLINK-8126:
--
Fix Version/s: 1.4.0
> Update and fix checkstyle
> -
>
> Key: FL
[
https://issues.apache.org/jira/browse/FLINK-8126?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Hogan closed FLINK-8126.
-
Resolution: Fixed
1.4: 4eae418b410c928b8e4b7893c1f5b9c48a5e3228
> Update and fix checkstyle
> ---
[
https://issues.apache.org/jira/browse/FLINK-8126?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Hogan reopened FLINK-8126:
---
> Update and fix checkstyle
> -
>
> Key: FLINK-8126
>
[
https://issues.apache.org/jira/browse/FLINK-8142?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16267406#comment-16267406
]
ASF GitHub Bot commented on FLINK-8142:
---
Github user greghogan commented on the issu
Github user greghogan commented on the issue:
https://github.com/apache/flink/pull/5067
+1; merging ...
---
Github user greghogan commented on the issue:
https://github.com/apache/flink/pull/5047
Do we still want to make this change since the PR is now only adding a
single comment?
---
[
https://issues.apache.org/jira/browse/FLINK-8126?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16267309#comment-16267309
]
ASF GitHub Bot commented on FLINK-8126:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5061
---
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/5091
[FLINK-7956] [flip6] Add support for queued scheduling with slot sharing to
SlotPool
## What is the purpose of the change
This commit adds support for queued scheduling with slot shari
[
https://issues.apache.org/jira/browse/FLINK-7956?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16267135#comment-16267135
]
ASF GitHub Bot commented on FLINK-7956:
---
GitHub user tillrohrmann opened a pull requ
[
https://issues.apache.org/jira/browse/FLINK-7416?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16267112#comment-16267112
]
ASF GitHub Bot commented on FLINK-7416:
---
Github user NicoK commented on a diff in th
[
https://issues.apache.org/jira/browse/FLINK-7416?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16267111#comment-16267111
]
ASF GitHub Bot commented on FLINK-7416:
---
Github user NicoK commented on a diff in th
[
https://issues.apache.org/jira/browse/FLINK-7416?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16267113#comment-16267113
]
ASF GitHub Bot commented on FLINK-7416:
---
Github user NicoK commented on a diff in th
[
https://issues.apache.org/jira/browse/FLINK-7416?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16267109#comment-16267109
]
ASF GitHub Bot commented on FLINK-7416:
---
Github user NicoK commented on a diff in th
[
https://issues.apache.org/jira/browse/FLINK-7416?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16267110#comment-16267110
]
ASF GitHub Bot commented on FLINK-7416:
---
Github user NicoK commented on a diff in th
Github user NicoK commented on a diff in the pull request:
https://github.com/apache/flink/pull/4533#discussion_r153261175
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/CreditBasedClientHandler.java
---
@@ -152,6 +170,26 @@ public void channelRead
Github user NicoK commented on a diff in the pull request:
https://github.com/apache/flink/pull/4533#discussion_r153266186
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/NettyMessage.java
---
@@ -539,4 +542,60 @@ static CloseRequest
readFrom(@Supp
Github user NicoK commented on a diff in the pull request:
https://github.com/apache/flink/pull/4533#discussion_r153269318
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/RemoteInputChannel.java
---
@@ -283,10 +283,13 @@ public String t
Github user NicoK commented on a diff in the pull request:
https://github.com/apache/flink/pull/4533#discussion_r153258008
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/CreditBasedClientHandler.java
---
@@ -88,6 +98,15 @@ void cancelRequestFor(Inp
Github user NicoK commented on a diff in the pull request:
https://github.com/apache/flink/pull/4533#discussion_r153263139
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/CreditBasedClientHandler.java
---
@@ -274,4 +313,49 @@ private void decodeBuff
[
https://issues.apache.org/jira/browse/FLINK-8089?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16267101#comment-16267101
]
ASF GitHub Bot commented on FLINK-8089:
---
GitHub user tillrohrmann opened a pull requ
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/5090
[FLINK-8089] Also check for other pending slot requests in
SlotPool#offerSlot
## What is the purpose of the change
Not only check for a slot request with the right allocation id but al
[
https://issues.apache.org/jira/browse/FLINK-8088?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16267094#comment-16267094
]
ASF GitHub Bot commented on FLINK-8088:
---
GitHub user tillrohrmann opened a pull requ
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/5089
[FLINK-8088] Associate logical slots with the slot request id
## What is the purpose of the change
Before, logical slots like the `SimpleSlot` and `SharedSlot` where
associated to the
[
https://issues.apache.org/jira/browse/FLINK-8087?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16267088#comment-16267088
]
ASF GitHub Bot commented on FLINK-8087:
---
GitHub user tillrohrmann opened a pull requ
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/5088
[FLINK-8087] Decouple Slot from AllocatedSlot
## What is the purpose of the change
This commit introduces the SlotContext which is an abstraction for the
SimpleSlot
to obtain the r
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/5087
[FLINK-8085] Thin out LogicalSlot interface
## What is the purpose of the change
Remove isCanceled, isReleased method and decouple logical slot from
Execution by
introducing a Payl
[
https://issues.apache.org/jira/browse/FLINK-8085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16267082#comment-16267082
]
ASF GitHub Bot commented on FLINK-8085:
---
GitHub user tillrohrmann opened a pull requ
[
https://issues.apache.org/jira/browse/FLINK-8078?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16267070#comment-16267070
]
ASF GitHub Bot commented on FLINK-8078:
---
GitHub user tillrohrmann opened a pull requ
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/5086
[FLINK-8078] Introduce LogicalSlot interface
## What is the purpose of the change
The LogicalSlot interface decouples the task deployment from the actual
slot implementation which at t
[
https://issues.apache.org/jira/browse/FLINK-7642?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16267051#comment-16267051
]
Ted Yu commented on FLINK-7642:
---
Over in hbase, we use 2.20.1 .
SUREFIRE-1255 has been inac
[
https://issues.apache.org/jira/browse/FLINK-7642?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16267037#comment-16267037
]
Greg Hogan commented on FLINK-7642:
---
Please stop adding and removing a blank line from t
[
https://issues.apache.org/jira/browse/FLINK-7406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16267030#comment-16267030
]
ASF GitHub Bot commented on FLINK-7406:
---
Github user NicoK commented on a diff in th
Github user NicoK commented on a diff in the pull request:
https://github.com/apache/flink/pull/4509#discussion_r153253247
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/RemoteInputChannel.java
---
@@ -572,20 +560,53 @@ void addExclusi
[
https://issues.apache.org/jira/browse/FLINK-8161?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16267023#comment-16267023
]
ASF GitHub Bot commented on FLINK-8161:
---
GitHub user tillrohrmann opened a pull requ
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/5085
[FLINK-8161] [tests] Harden YARNSessionCapacitySchedulerITCase
## What is the purpose of the change
Add "Remote connection to [null] failed with
java.nio.channels.NotYetConnectedExcept
Till Rohrmann created FLINK-8161:
Summary: Flakey YARNSessionCapacitySchedulerITCase on Travis
Key: FLINK-8161
URL: https://issues.apache.org/jira/browse/FLINK-8161
Project: Flink
Issue Type:
Github user zentol commented on the pull request:
https://github.com/apache/flink/commit/c940d5eff9897796625a696ed2989aed52c39ebd#commitcomment-25875079
In tools/releasing/create_source_release.sh:
In tools/releasing/create_source_release.sh on line 60:
maybe we should have a w
[
https://issues.apache.org/jira/browse/FLINK-7717?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16267007#comment-16267007
]
ASF GitHub Bot commented on FLINK-7717:
---
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/5081#discussion_r153243460
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/job/metrics/TaskManagerMetricsHandler.java
---
@@ -0,0 +1,64 @@
+/*
+ * Lice
[
https://issues.apache.org/jira/browse/FLINK-7873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16266992#comment-16266992
]
ASF GitHub Bot commented on FLINK-7873:
---
Github user StefanRRichter commented on a d
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/5074#discussion_r153241166
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/state/CachedCheckpointStreamFactory.java
---
@@ -0,0 +1,195 @@
+/*
+ * License
[
https://issues.apache.org/jira/browse/FLINK-7456?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16266984#comment-16266984
]
ASF GitHub Bot commented on FLINK-7456:
---
Github user NicoK commented on a diff in th
Github user NicoK commented on a diff in the pull request:
https://github.com/apache/flink/pull/4552#discussion_r152985049
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/NetworkEnvironment.java
---
@@ -224,17 +224,9 @@ public void registerTask(Task task)
[
https://issues.apache.org/jira/browse/FLINK-7873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16266966#comment-16266966
]
ASF GitHub Bot commented on FLINK-7873:
---
Github user StefanRRichter commented on a d
[
https://issues.apache.org/jira/browse/FLINK-7873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16266965#comment-16266965
]
ASF GitHub Bot commented on FLINK-7873:
---
Github user StefanRRichter commented on a d
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/5074#discussion_r153234962
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskManagerServices.java
---
@@ -190,6 +199,11 @@ public static TaskManag
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/5074#discussion_r153235421
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/savepoint/SavepointV2Serializer.java
---
@@ -510,6 +512,13 @@ private stati
[
https://issues.apache.org/jira/browse/FLINK-8154?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gregory Melekh closed FLINK-8154.
-
Resolution: Not A Problem
> JobSubmissionClientActor submited job,but there is no connection to a
[
https://issues.apache.org/jira/browse/FLINK-8154?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16266949#comment-16266949
]
Gregory Melekh commented on FLINK-8154:
---
Ohhh...You are right...
I should create hea
[
https://issues.apache.org/jira/browse/FLINK-7499?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16266940#comment-16266940
]
ASF GitHub Bot commented on FLINK-7499:
---
Github user tillrohrmann commented on the i
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/4581
Still failing with some checkstyle violations in `ResultPartition.java`
---
[
https://issues.apache.org/jira/browse/FLINK-8090?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16266871#comment-16266871
]
ASF GitHub Bot commented on FLINK-8090:
---
Github user aljoscha commented on the issue
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/5032
We could check based on the state descriptor.
---
1 - 100 of 194 matches
Mail list logo
