[
https://issues.apache.org/jira/browse/FLINK-7456?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16330186#comment-16330186
]
ASF GitHub Bot commented on FLINK-7456:
---
Github user zhijiangW commented on a diff in the pull
Github user zhijiangW commented on a diff in the pull request:
https://github.com/apache/flink/pull/4552#discussion_r162266243
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/SpilledSubpartitionView.java
---
@@ -31,7 +31,6 @@
import
[
https://issues.apache.org/jira/browse/FLINK-7456?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16330155#comment-16330155
]
ASF GitHub Bot commented on FLINK-7456:
---
Github user zhijiangW commented on the issue:
Github user zhijiangW commented on the issue:
https://github.com/apache/flink/pull/4552
1. Thanks for you FLINK08425.
2. I would have thought the tests for
`ResultSubpartition#nextBufferIsEvent` which have already been covered before.
The test for
[
https://issues.apache.org/jira/browse/FLINK-7456?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16330126#comment-16330126
]
ASF GitHub Bot commented on FLINK-7456:
---
Github user zhijiangW commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-7456?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16330123#comment-16330123
]
ASF GitHub Bot commented on FLINK-7456:
---
Github user zhijiangW commented on a diff in the pull
Github user zhijiangW commented on a diff in the pull request:
https://github.com/apache/flink/pull/4552#discussion_r162259781
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/PartitionRequestClientFactory.java
---
@@ -164,11 +165,13 @@ private
[
https://issues.apache.org/jira/browse/FLINK-7456?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16330125#comment-16330125
]
ASF GitHub Bot commented on FLINK-7456:
---
Github user zhijiangW commented on a diff in the pull
Bhumika Bayani created FLINK-8448:
-
Summary: [flink-mesos] The flink-job jars uploaded in directory
'web.upload.dir' are deleted on flink-scheduler restart
Key: FLINK-8448
URL:
Github user zhijiangW commented on a diff in the pull request:
https://github.com/apache/flink/pull/4552#discussion_r162259728
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/PartitionRequestServerHandler.java
---
@@ -82,10 +83,17 @@ protected void
Github user zhijiangW commented on a diff in the pull request:
https://github.com/apache/flink/pull/4552#discussion_r162259766
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/PartitionRequestQueue.java
---
@@ -125,11 +126,11 @@ private void
suganya created FLINK-8447:
--
Summary: CLONE - Snapshot state of aggregated data is not
maintained in flink's checkpointing
Key: FLINK-8447
URL: https://issues.apache.org/jira/browse/FLINK-8447
Project:
[
https://issues.apache.org/jira/browse/FLINK-6590?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16329952#comment-16329952
]
ASF GitHub Bot commented on FLINK-6590:
---
Github user yew1eb commented on the issue:
Github user yew1eb commented on the issue:
https://github.com/apache/flink/pull/5119
nice!
LGTM
---
[
https://issues.apache.org/jira/browse/FLINK-8275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16329931#comment-16329931
]
ASF GitHub Bot commented on FLINK-8275:
---
Github user suez1224 commented on the issue:
Github user suez1224 commented on the issue:
https://github.com/apache/flink/pull/5172
Thanks a lot for the review, @EronWright. Could you please take another
look?
---
[
https://issues.apache.org/jira/browse/FLINK-8275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16329929#comment-16329929
]
ASF GitHub Bot commented on FLINK-8275:
---
Github user suez1224 commented on a diff in the pull
Github user suez1224 commented on a diff in the pull request:
https://github.com/apache/flink/pull/5172#discussion_r162239390
--- Diff:
flink-yarn/src/main/java/org/apache/flink/yarn/YarnTaskManagerRunner.java ---
@@ -126,12 +124,6 @@ public static void runYarnTaskManager(String[]
[
https://issues.apache.org/jira/browse/FLINK-7775?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-7775:
--
Description:
{code}
public int getNumberOfCachedJobs() {
return jobRefCounters.size();
}
{code}
The
[
https://issues.apache.org/jira/browse/FLINK-8390?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16329870#comment-16329870
]
ASF GitHub Bot commented on FLINK-8390:
---
GitHub user suez1224 opened a pull request:
GitHub user suez1224 opened a pull request:
https://github.com/apache/flink/pull/5306
[FLINK-8390][security]remove unused integration test code
## What is the purpose of the change
Remove unused integration test code from the main code.
## Brief change log
[
https://issues.apache.org/jira/browse/FLINK-8275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16329655#comment-16329655
]
ASF GitHub Bot commented on FLINK-8275:
---
Github user suez1224 commented on a diff in the pull
Github user suez1224 commented on a diff in the pull request:
https://github.com/apache/flink/pull/5172#discussion_r162204277
--- Diff:
flink-yarn/src/main/java/org/apache/flink/yarn/YarnTaskManagerRunner.java ---
@@ -142,19 +134,22 @@ public static void
[
https://issues.apache.org/jira/browse/FLINK-8037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16329624#comment-16329624
]
ASF GitHub Bot commented on FLINK-8037:
---
Github user greghogan commented on a diff in the pull
Github user greghogan commented on a diff in the pull request:
https://github.com/apache/flink/pull/5205#discussion_r162199532
--- Diff: flink-core/src/main/java/org/apache/flink/util/AbstractID.java ---
@@ -186,7 +186,7 @@ private static long byteArrayToLong(byte[] ba, int
Github user suez1224 commented on a diff in the pull request:
https://github.com/apache/flink/pull/5172#discussion_r162190016
--- Diff: flink-yarn/src/test/resources/flink-conf.yaml ---
@@ -0,0 +1,23 @@
[
https://issues.apache.org/jira/browse/FLINK-8275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16329529#comment-16329529
]
ASF GitHub Bot commented on FLINK-8275:
---
Github user suez1224 commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8431?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16329407#comment-16329407
]
Eron Wright commented on FLINK-8431:
-
I think that you can skip testing the FLIP-6 scripts, if you
[
https://issues.apache.org/jira/browse/FLINK-8284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16329054#comment-16329054
]
Chesnay Schepler commented on FLINK-8284:
-
You have to either configure multiple ports since each
[
https://issues.apache.org/jira/browse/FLINK-6590?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16329008#comment-16329008
]
ASF GitHub Bot commented on FLINK-6590:
---
Github user kl0u commented on the issue:
Github user kl0u commented on the issue:
https://github.com/apache/flink/pull/5119
Building the documentation seems to be working, and the docs look nice.
Thanks a lot for the work @zentol .
+1 to merge
---
[
https://issues.apache.org/jira/browse/FLINK-7456?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16328972#comment-16328972
]
ASF GitHub Bot commented on FLINK-7456:
---
Github user NicoK commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-7456?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16328971#comment-16328971
]
ASF GitHub Bot commented on FLINK-7456:
---
Github user NicoK commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-7456?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16328973#comment-16328973
]
ASF GitHub Bot commented on FLINK-7456:
---
Github user NicoK commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-7456?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16328974#comment-16328974
]
ASF GitHub Bot commented on FLINK-7456:
---
Github user NicoK commented on a diff in the pull request:
Github user NicoK commented on a diff in the pull request:
https://github.com/apache/flink/pull/4552#discussion_r162107348
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/SpilledSubpartitionView.java
---
@@ -31,7 +31,6 @@
import
Github user NicoK commented on a diff in the pull request:
https://github.com/apache/flink/pull/4552#discussion_r162103769
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/PartitionRequestClientFactory.java
---
@@ -164,11 +165,13 @@ private boolean
Github user NicoK commented on a diff in the pull request:
https://github.com/apache/flink/pull/4552#discussion_r162104968
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/PartitionRequestQueue.java
---
@@ -125,11 +126,11 @@ private void
Github user NicoK commented on a diff in the pull request:
https://github.com/apache/flink/pull/4552#discussion_r162106371
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/PartitionRequestServerHandler.java
---
@@ -82,10 +83,17 @@ protected void
[
https://issues.apache.org/jira/browse/FLINK-8284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16328953#comment-16328953
]
Julio Biason commented on FLINK-8284:
-
{quote}Do you see any metric for this particular operator?
[
https://issues.apache.org/jira/browse/FLINK-8284?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Julio Biason reopened FLINK-8284:
-
Ok, got the problem to happen again. It seems if I run in standalone mode,
everything goes fine. But
[
https://issues.apache.org/jira/browse/FLINK-8202?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kostas Kloudas reassigned FLINK-8202:
-
Assignee: Chesnay Schepler (was: Kostas Kloudas)
> Update queryable section on
Kostas Kloudas created FLINK-8446:
-
Summary: Add support for multiple broadcast states.
Key: FLINK-8446
URL: https://issues.apache.org/jira/browse/FLINK-8446
Project: Flink
Issue Type: New
Chris Thomson created FLINK-8445:
Summary: hostname used in metric names for taskmanager and
jobmanager are not consistent
Key: FLINK-8445
URL: https://issues.apache.org/jira/browse/FLINK-8445
[
https://issues.apache.org/jira/browse/FLINK-7850?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-7850:
Labels: starter (was: )
> Given each maven profile an activation property
>
[
https://issues.apache.org/jira/browse/FLINK-7391?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-7391:
Labels: starter (was: )
> Normalize release entries
> -
>
>
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/5303
see https://issues.apache.org/jira/browse/FLINK-8444
---
Chesnay Schepler created FLINK-8444:
---
Summary: Rework dependency setup docs
Key: FLINK-8444
URL: https://issues.apache.org/jira/browse/FLINK-8444
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-8444?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16328831#comment-16328831
]
ASF GitHub Bot commented on FLINK-8444:
---
Github user zentol commented on the issue:
Github user zentol closed the pull request at:
https://github.com/apache/flink/pull/5303
---
[
https://issues.apache.org/jira/browse/FLINK-7511?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16328772#comment-16328772
]
ASF GitHub Bot commented on FLINK-7511:
---
Github user dawidwys commented on a diff in the pull
Github user dawidwys commented on a diff in the pull request:
https://github.com/apache/flink/pull/4587#discussion_r162051801
--- Diff:
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/pattern/AndFilterFunction.java
---
@@ -1,55 +0,0 @@
-/*
- * Licensed to the
[
https://issues.apache.org/jira/browse/FLINK-7456?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16328747#comment-16328747
]
ASF GitHub Bot commented on FLINK-7456:
---
Github user NicoK commented on a diff in the pull request:
Github user NicoK commented on a diff in the pull request:
https://github.com/apache/flink/pull/4552#discussion_r162047076
--- Diff:
flink-tests/src/test/java/org/apache/flink/test/misc/SuccessAfterNetworkBuffersFailureITCase.java
---
@@ -59,7 +59,7 @@ public void
[
https://issues.apache.org/jira/browse/FLINK-7511?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16328728#comment-16328728
]
ASF GitHub Bot commented on FLINK-7511:
---
Github user dawidwys commented on a diff in the pull
Github user dawidwys commented on a diff in the pull request:
https://github.com/apache/flink/pull/4587#discussion_r162044383
--- Diff:
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/pattern/AndFilterFunction.java
---
@@ -1,55 +0,0 @@
-/*
- * Licensed to the
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/5303
Sounds good. Just to be sure: My write-up above was meant as a suggestion
or food-for-thought, not as a final decision ;-)
We should probably bring these thoughts to a dev discussion and
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/5303
In that case I'll revert the commit that caused all this, close this PR and
open a new JIRA for adding a new dependency management section to the project
setup guide (along with a sweep across the
[
https://issues.apache.org/jira/browse/FLINK-8279?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16328612#comment-16328612
]
ASF GitHub Bot commented on FLINK-8279:
---
Github user tillrohrmann commented on the issue:
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/5176
There are checkstyle violations. Could you please fix them @NicoK.
---
Piotr Nowojski created FLINK-8443:
-
Summary: YARNSessionCapacitySchedulerITCase is flakky
Key: FLINK-8443
URL: https://issues.apache.org/jira/browse/FLINK-8443
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-8431?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16328547#comment-16328547
]
Dongwon Kim edited comment on FLINK-8431 at 1/17/18 9:57 AM:
-
[~eronwright]
[
https://issues.apache.org/jira/browse/FLINK-8431?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16328547#comment-16328547
]
Dongwon Kim commented on FLINK-8431:
[~eronwright] What I need to do next is to cope with the new
[
https://issues.apache.org/jira/browse/FLINK-8344?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gary Yao reassigned FLINK-8344:
---
Assignee: Gary Yao
> Add support for HA to RestClusterClient
>
Github user GJL commented on the issue:
https://github.com/apache/flink/pull/5305
Thanks for your contribution, @nicktoker. Unfortunately with your pull
request you are trying to merge the `release-1.3` branch into the `master`. You
probably want to create a feature branch from a
GitHub user nicktoker opened a pull request:
https://github.com/apache/flink/pull/5305
Release 1.3
when asyncIO have timeout all operator fail and break the all stream
need to add option to control when timeout happen and choose what to do
in this case
ignore this stream
shuai.xu created FLINK-8442:
---
Summary: Should recovery the input split when an execution
failover with FailoverRegion
Key: FLINK-8442
URL: https://issues.apache.org/jira/browse/FLINK-8442
Project: Flink
67 matches
Mail list logo
