[
https://issues.apache.org/jira/browse/FLINK-2186?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Anton Solovev updated FLINK-2186:
-
Assignee: (was: Anton Solovev)
> Rework CSV import to support very wide files
> --
Github user wuchong commented on the issue:
https://github.com/apache/flink/pull/2653
Hi @fhueske @twalthr , could you have a look at this PR again ? I have fix
the conflicts again and squashed the commits.
---
If your project is set up for it, you can reply to this email and have
[
https://issues.apache.org/jira/browse/FLINK-4469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15707951#comment-15707951
]
ASF GitHub Bot commented on FLINK-4469:
---
Github user wuchong commented on the issue:
GitHub user shuai-xu opened a pull request:
https://github.com/apache/flink/pull/2903
[FLINK-5704] [runtime] add a zookeeper based running job registry
This pr is for jira
#[5074](https://issues.apache.org/jira/browse/FLINK-5074).
Implement a zookeeper based running job reg
GitHub user EronWright opened a pull request:
https://github.com/apache/flink/pull/2904
[FLINK-5091] Formalize the Mesos AppMaster environment for docker
compatibility
Fixes FLINK-5091 and FLINK-4826.
- introduced ContainerSpecification.
- reworked how the TM container
[
https://issues.apache.org/jira/browse/FLINK-5091?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15707963#comment-15707963
]
ASF GitHub Bot commented on FLINK-5091:
---
GitHub user EronWright opened a pull reques
GitHub user shuai-xu opened a pull request:
https://github.com/apache/flink/pull/2905
[FLINK-5190] [runtime] fix ZooKeeperLeaderRetrievalService close the â¦
This pr is for jira
#[5190](https://issues.apache.org/jira/browse/FLINK-5190).
The zk client for ZooKeeperLeaderRet
[
https://issues.apache.org/jira/browse/FLINK-5190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15708017#comment-15708017
]
ASF GitHub Bot commented on FLINK-5190:
---
GitHub user shuai-xu opened a pull request:
Github user twalthr commented on the issue:
https://github.com/apache/flink/pull/2653
I have already reviewed half of the new code. I will review the rest
tomorrow.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If you
[
https://issues.apache.org/jira/browse/FLINK-4905?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Andrew Efimov updated FLINK-4905:
-
Attachment: Kafka08Fetcher.png
> Kafka test instability IllegalStateException: Client is not start
[
https://issues.apache.org/jira/browse/FLINK-5132?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15708097#comment-15708097
]
ASF GitHub Bot commented on FLINK-5132:
---
GitHub user wangzhijiang999 opened a pull r
GitHub user wangzhijiang999 opened a pull request:
https://github.com/apache/flink/pull/2906
[FLINK-5132][FLINK-5133][FLINK-5134][Core,DataStream API,DataSet API]
Fine-grained Resource Configuration
Introduce the **ResourceSpec** structure to describe the different resource
fac
[
https://issues.apache.org/jira/browse/FLINK-4905?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15708105#comment-15708105
]
Andrew Efimov commented on FLINK-4905:
--
Hi [~tzulitai]
Thanks for reply.
It is very d
[
https://issues.apache.org/jira/browse/FLINK-5138?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang Wang reassigned FLINK-5138:
Assignee: Zhijiang Wang
> The StateBackend provides the method to estimate memory usage bas
GitHub user wangzhijiang999 opened a pull request:
https://github.com/apache/flink/pull/2907
[FLINK-5135][JM]ResourceProfile for slot request should be expanded to
correspond with ResourceSpec
Currently the **ResourceProfile** only contains cpu cores and memory
properties. The memo
[
https://issues.apache.org/jira/browse/FLINK-5135?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15708151#comment-15708151
]
ASF GitHub Bot commented on FLINK-5135:
---
GitHub user wangzhijiang999 opened a pull r
[
https://issues.apache.org/jira/browse/FLINK-4905?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15708105#comment-15708105
]
Andrew Efimov edited comment on FLINK-4905 at 11/30/16 10:34 AM:
---
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/2889
@fhueske Thank you for the review. I'll add a comment and merge it.
---
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
[
https://issues.apache.org/jira/browse/FLINK-5164?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15708191#comment-15708191
]
ASF GitHub Bot commented on FLINK-5164:
---
Github user zentol commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4905?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15708105#comment-15708105
]
Andrew Efimov edited comment on FLINK-4905 at 11/30/16 10:38 AM:
---
Github user mxm commented on the issue:
https://github.com/apache/flink/pull/2900
Rebased again to the latest Mesos changes to make sure tests pass.
---
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
[
https://issues.apache.org/jira/browse/FLINK-4676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15708217#comment-15708217
]
ASF GitHub Bot commented on FLINK-4676:
---
Github user zentol commented on the issue:
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/2897
This looks good; we should merge it at soon as possible.
---
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 t
[
https://issues.apache.org/jira/browse/FLINK-5166?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15708231#comment-15708231
]
ASF GitHub Bot commented on FLINK-5166:
---
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/2876#discussion_r90209936
--- Diff:
flink-java/src/test/java/org/apache/flink/api/java/io/TextInputFormatTest.java
---
@@ -90,7 +91,9 @@ public void testSimpleRead() {
@T
GitHub user mxm opened a pull request:
https://github.com/apache/flink/pull/2908
[maven] properly attach the CEP Scala source code
Two options, either change the default Maven source directory from
'src/main/java' to 'src/main/scala' or use the build-helper-maven-plugin
to at
[
https://issues.apache.org/jira/browse/FLINK-4611?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-4611:
-
Assignee: Wei-Che Wei
> Make "AUTO" credential provider as default for Kinesis Connector
> ---
Github user uce commented on the issue:
https://github.com/apache/flink/pull/2883
I renamed the config key and added unit tests for the sub components. This
should be good enough to get it in if Travis gives us an OK. As a follow up I
would like to finish a end to end test similar to
[
https://issues.apache.org/jira/browse/FLINK-5088?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15708432#comment-15708432
]
ASF GitHub Bot commented on FLINK-5088:
---
Github user uce commented on the issue:
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/2896
Thanks for the review @uce. Failing test cases are unrelated. Merging this
PR.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If
[
https://issues.apache.org/jira/browse/FLINK-5197?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15708485#comment-15708485
]
ASF GitHub Bot commented on FLINK-5197:
---
Github user tillrohrmann commented on the i
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/2895
Merging this PR. @uce reviewed the backport.
---
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 f
[
https://issues.apache.org/jira/browse/FLINK-5197?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15708494#comment-15708494
]
ASF GitHub Bot commented on FLINK-5197:
---
Github user tillrohrmann commented on the i
[
https://issues.apache.org/jira/browse/FLINK-5197?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-5197.
Resolution: Fixed
1.2.0 fixed via ae0975c16b997fe792790216820a559d01a01894
1.1.4 fixed via 569a9666f
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/2908#discussion_r90225400
--- Diff: flink-libraries/flink-cep-scala/pom.xml ---
@@ -93,6 +93,8 @@ under the License.
+
+src/main/scala
Github user tillrohrmann closed the pull request at:
https://github.com/apache/flink/pull/2896
---
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 i
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/2895
Forgot to include the closing tag in the commit.
---
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 thi
[
https://issues.apache.org/jira/browse/FLINK-5197?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15708502#comment-15708502
]
ASF GitHub Bot commented on FLINK-5197:
---
Github user tillrohrmann commented on the i
Github user tillrohrmann closed the pull request at:
https://github.com/apache/flink/pull/2895
---
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 i
[
https://issues.apache.org/jira/browse/FLINK-5197?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15708500#comment-15708500
]
ASF GitHub Bot commented on FLINK-5197:
---
Github user tillrohrmann closed the pull re
[
https://issues.apache.org/jira/browse/FLINK-5197?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15708503#comment-15708503
]
ASF GitHub Bot commented on FLINK-5197:
---
Github user tillrohrmann closed the pull re
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/2908
had small comment, but looks good. The `builder-helper-maven-plugin` block
is identical to the ones used in other modules containing scala code.
---
If your project is set up for it, you can reply to
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/2909
[FLINK-5193] [jm] Harden job recovery in case of recovery failures
When recovering multiple jobs a single recovery failure caused all jobs to
be not recovered.
This PR changes this behaviou
[
https://issues.apache.org/jira/browse/FLINK-5193?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15708551#comment-15708551
]
ASF GitHub Bot commented on FLINK-5193:
---
GitHub user tillrohrmann opened a pull requ
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/2910
[backport] [FLINK-5193] [jm] Harden job recovery in case of recovery
failures
This is a backport of #2909 to the release 1.1 branch.
When recovering multiple jobs a single recovery fai
[
https://issues.apache.org/jira/browse/FLINK-5193?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15708557#comment-15708557
]
ASF GitHub Bot commented on FLINK-5193:
---
GitHub user tillrohrmann opened a pull requ
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/2899#discussion_r90229390
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/fs/hdfs/HadoopFileSystem.java
---
@@ -211,17 +209,14 @@ public HadoopFileSystem(Class fsC
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/2899#discussion_r90228943
--- Diff: flink-dist/src/main/flink-bin/conf/log4j.properties ---
@@ -16,14 +16,26 @@
# limitations under the License.
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/2899#discussion_r90229425
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/fs/hdfs/HadoopFileSystem.java
---
@@ -211,17 +209,14 @@ public HadoopFileSystem(Class fsC
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/2899#discussion_r90229315
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/TaskState.java
---
@@ -168,4 +168,21 @@ public boolean equals(Object obj) {
[
https://issues.apache.org/jira/browse/FLINK-3053?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15708611#comment-15708611
]
Robert Metzger commented on FLINK-3053:
---
https://api.travis-ci.org/jobs/179840673/lo
Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/2899#discussion_r90233907
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/fs/hdfs/HadoopFileSystem.java
---
@@ -211,17 +209,14 @@ public HadoopFileSystem(Class fsClass
Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/2899#discussion_r90233890
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/TaskState.java
---
@@ -168,4 +168,21 @@ public boolean equals(Object obj) {
pub
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/2899#discussion_r90234726
--- Diff: flink-dist/src/main/flink-bin/conf/log4j.properties ---
@@ -16,14 +16,26 @@
# limitations under the License.
Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/2899#discussion_r90235045
--- Diff: flink-dist/src/main/flink-bin/conf/log4j.properties ---
@@ -16,14 +16,26 @@
# limitations under the License.
#
[
https://issues.apache.org/jira/browse/FLINK-2435?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Anton Mushin reassigned FLINK-2435:
---
Assignee: Anton Mushin
> Add support for custom CSV field parsers
> -
Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/2910#discussion_r90235223
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/jobmanager/SubmittedJobGraphStore.java
---
@@ -64,6 +57,14 @@
void removeJobGraph(JobID jo
Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/2910#discussion_r90237601
--- Diff:
flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala
---
@@ -505,37 +507,31 @@ class JobManager(
}
Till Rohrmann created FLINK-5210:
Summary: Failing performCheckpoint method causes task to fail
Key: FLINK-5210
URL: https://issues.apache.org/jira/browse/FLINK-5210
Project: Flink
Issue Typ
Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/2910#discussion_r90235653
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/jobmanager/ZooKeeperSubmittedJobGraphStore.java
---
@@ -275,6 +242,25 @@ public void removeJobGrap
[
https://issues.apache.org/jira/browse/FLINK-5193?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15708683#comment-15708683
]
ASF GitHub Bot commented on FLINK-5193:
---
Github user uce commented on a diff in the
[
https://issues.apache.org/jira/browse/FLINK-5193?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15708682#comment-15708682
]
ASF GitHub Bot commented on FLINK-5193:
---
Github user uce commented on a diff in the
[
https://issues.apache.org/jira/browse/FLINK-5193?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15708684#comment-15708684
]
ASF GitHub Bot commented on FLINK-5193:
---
Github user uce commented on a diff in the
[
https://issues.apache.org/jira/browse/FLINK-2435?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15708691#comment-15708691
]
Anton Mushin commented on FLINK-2435:
-
Hi [~fhueske]
could you tell for what case need
Github user NicoK commented on the issue:
https://github.com/apache/flink/pull/2891
Sorry for the hassle, found a regression and added a fix plus an
appropriate test for it. Should be fine now.
---
If your project is set up for it, you can reply to this email and have your
reply appe
[
https://issues.apache.org/jira/browse/FLINK-5129?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15708696#comment-15708696
]
ASF GitHub Bot commented on FLINK-5129:
---
Github user NicoK commented on the issue:
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/2899
We should also set the received and handled message in
`FlinkUntypedActor#onReceive` to trace.
---
If your project is set up for it, you can reply to this email and have your
reply appear on Gi
GitHub user NicoK opened a pull request:
https://github.com/apache/flink/pull/2911
[FLINK-5178] allow BLOB_STORAGE_DIRECTORY_KEY to point to a distributed
file system
Previously, this was restricted to a local file system path but now we can
allow it to be distributed, too, whic
Github user NicoK commented on the issue:
https://github.com/apache/flink/pull/2911
@uce can you have a look after processing #2891 (FLINK-5129)?
---
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 ha
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2850
---
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-4895?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger resolved FLINK-4895.
---
Resolution: Fixed
Fix Version/s: 1.2.0
Resolved in http://git-wip-us.apache.org/repos/a
[
https://issues.apache.org/jira/browse/FLINK-4895?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15708769#comment-15708769
]
ASF GitHub Bot commented on FLINK-4895:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-5178?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15708766#comment-15708766
]
ASF GitHub Bot commented on FLINK-5178:
---
Github user NicoK commented on the issue:
Github user shijinkui commented on a diff in the pull request:
https://github.com/apache/flink/pull/2876#discussion_r90246314
--- Diff:
flink-java/src/test/java/org/apache/flink/api/java/io/TextInputFormatTest.java
---
@@ -90,7 +91,9 @@ public void testSimpleRead() {
[
https://issues.apache.org/jira/browse/FLINK-5166?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15708780#comment-15708780
]
ASF GitHub Bot commented on FLINK-5166:
---
Github user shijinkui commented on a diff i
Chesnay Schepler created FLINK-5211:
---
Summary: Include an example configuration for all reporters
Key: FLINK-5211
URL: https://issues.apache.org/jira/browse/FLINK-5211
Project: Flink
Issue
Nico Kruber created FLINK-5212:
--
Summary: Flakey ScalaShellITCase#testPreventRecreationBatch (out
of Java heap space)
Key: FLINK-5212
URL: https://issues.apache.org/jira/browse/FLINK-5212
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-5114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15708810#comment-15708810
]
ASF GitHub Bot commented on FLINK-5114:
---
GitHub user uce opened a pull request:
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/2876#discussion_r90249472
--- Diff:
flink-java/src/test/java/org/apache/flink/api/java/io/TextInputFormatTest.java
---
@@ -90,23 +92,23 @@ public void testSimpleRead() {
[
https://issues.apache.org/jira/browse/FLINK-5166?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15708815#comment-15708815
]
ASF GitHub Bot commented on FLINK-5166:
---
Github user zentol commented on a diff in t
[
https://issues.apache.org/jira/browse/FLINK-5114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15708824#comment-15708824
]
ASF GitHub Bot commented on FLINK-5114:
---
GitHub user uce opened a pull request:
GitHub user uce opened a pull request:
https://github.com/apache/flink/pull/2913
[backport] [FLINK-5114] [network] Handle partition producer state check for
unregistered executions
This is a backport of #2912.
Code between 1.1 and 1.2 slightly changed. I decided to further
GitHub user uce opened a pull request:
https://github.com/apache/flink/pull/2912
[FLINK-5114] [network] Handle partition producer state check for
unregistered executions
If a partition state request is triggered for a producer that terminates
before the request arrives, the executi
[
https://issues.apache.org/jira/browse/FLINK-5178?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15708761#comment-15708761
]
ASF GitHub Bot commented on FLINK-5178:
---
GitHub user NicoK opened a pull request:
Github user uce commented on the issue:
https://github.com/apache/flink/pull/2899
Added `FlinkUntypedActor` as well and addressed the comments, Till. I would
like to merge this now.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub
Ufuk Celebi created FLINK-5213:
--
Summary: Missing @Override in Task
Key: FLINK-5213
URL: https://issues.apache.org/jira/browse/FLINK-5213
Project: Flink
Issue Type: Improvement
Repor
[
https://issues.apache.org/jira/browse/FLINK-5213?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi closed FLINK-5213.
--
Resolution: Fixed
Fixed in 8cdb406 (master).
> Missing @Override in Task
> -
>
[
https://issues.apache.org/jira/browse/FLINK-3160?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15708872#comment-15708872
]
Ufuk Celebi commented on FLINK-3160:
Maybe I'm misunderstanding something, too. ;-) To
Github user uce closed the pull request at:
https://github.com/apache/flink/pull/2899
---
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 enabled
Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/2873#discussion_r90257889
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinator.java
---
@@ -651,64 +651,33 @@ public boolean
receiveDeclineMess
Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/2873#discussion_r90258796
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinator.java
---
@@ -731,46 +700,100 @@ public boolean
receiveAcknowledg
Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/2873#discussion_r90258638
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinator.java
---
@@ -731,46 +700,100 @@ public boolean
receiveAcknowledg
Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/2873#discussion_r90258544
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinator.java
---
@@ -731,46 +700,100 @@ public boolean
receiveAcknowledg
[
https://issues.apache.org/jira/browse/FLINK-5158?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15708911#comment-15708911
]
ASF GitHub Bot commented on FLINK-5158:
---
Github user uce commented on a diff in the
[
https://issues.apache.org/jira/browse/FLINK-5158?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15708914#comment-15708914
]
ASF GitHub Bot commented on FLINK-5158:
---
Github user uce commented on a diff in the
[
https://issues.apache.org/jira/browse/FLINK-5158?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15708912#comment-15708912
]
ASF GitHub Bot commented on FLINK-5158:
---
Github user uce commented on a diff in the
[
https://issues.apache.org/jira/browse/FLINK-5158?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15708913#comment-15708913
]
ASF GitHub Bot commented on FLINK-5158:
---
Github user uce commented on a diff in the
Github user greghogan commented on a diff in the pull request:
https://github.com/apache/flink/pull/2902#discussion_r90273043
--- Diff:
flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/handlers/TaskManagersHandler.java
---
@@ -124,13 +124,21 @@ public String han
Github user greghogan commented on a diff in the pull request:
https://github.com/apache/flink/pull/2902#discussion_r90272935
--- Diff:
flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/handlers/TaskManagersHandler.java
---
@@ -124,13 +124,21 @@ public String han
Github user greghogan commented on a diff in the pull request:
https://github.com/apache/flink/pull/2902#discussion_r90274186
--- Diff:
flink-runtime-web/web-dashboard/app/partials/taskmanager/taskmanager.metrics.jade
---
@@ -75,18 +75,18 @@ div(ng-if="metrics.id")
tbody
1 - 100 of 166 matches
Mail list logo
