[
https://issues.apache.org/jira/browse/FLINK-8690?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske closed FLINK-8690.
Resolution: Implemented
Fix Version/s: 1.6.0
Implemented for 1.6.0 with 53610c31e88d3c4194990
GitHub user StephanEwen opened a pull request:
https://github.com/apache/flink/pull/5965
[FLINK-9310] [security] Update standard cipher suites for secure mode
## What is the purpose of the change
This sets the cipher suits accepted by default to those recommended in
IETF
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/5965
@EronWright This might be interesting to you.
---
[
https://issues.apache.org/jira/browse/FLINK-9310?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16466379#comment-16466379
]
ASF GitHub Bot commented on FLINK-9310:
---
GitHub user StephanEwen opened a pull reque
[
https://issues.apache.org/jira/browse/FLINK-9310?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16466380#comment-16466380
]
ASF GitHub Bot commented on FLINK-9310:
---
Github user StephanEwen commented on the is
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/5961#discussion_r186527277
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/util/typeutils/FieldAccessor.java
---
@@ -197,7 +196,7 @@ public T set(T record, F f
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/5961#discussion_r186527205
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/util/typeutils/FieldAccessor.java
---
@@ -157,15 +156,15 @@ public T set(T record, F
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/5961#discussion_r186477977
--- Diff:
flink-java/src/main/java/org/apache/flink/api/java/functions/SelectByMinFunction.java
---
@@ -41,7 +41,7 @@
* is regarded in the reduce f
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/5961#discussion_r186528901
--- Diff:
flink-streaming-java/src/test/java/org/apache/flink/streaming/util/typeutils/FieldAccessorTest.java
---
@@ -368,4 +369,23 @@ public void testIlleg
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/5961#discussion_r186484649
--- Diff:
flink-java/src/test/java/org/apache/flink/api/java/operator/MaxByOperatorTest.java
---
@@ -230,4 +235,43 @@ public String toString() {
[
https://issues.apache.org/jira/browse/FLINK-8255?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16466384#comment-16466384
]
ASF GitHub Bot commented on FLINK-8255:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-8255?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16466381#comment-16466381
]
ASF GitHub Bot commented on FLINK-8255:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-8255?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16466383#comment-16466383
]
ASF GitHub Bot commented on FLINK-8255:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-8255?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16466382#comment-16466382
]
ASF GitHub Bot commented on FLINK-8255:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-8255?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16466385#comment-16466385
]
ASF GitHub Bot commented on FLINK-8255:
---
Github user fhueske commented on a diff in
Stephan Ewen created FLINK-9312:
---
Summary: Perform mutual authentication during SSL handshakes
Key: FLINK-9312
URL: https://issues.apache.org/jira/browse/FLINK-9312
Project: Flink
Issue Type: N
Stephan Ewen created FLINK-9313:
---
Summary: Enable mutual authentication for RPC (akka)
Key: FLINK-9313
URL: https://issues.apache.org/jira/browse/FLINK-9313
Project: Flink
Issue Type: Sub-task
Stephan Ewen created FLINK-9314:
---
Summary: Enable SSL mutual authentication for Netty / TaskManagers
Key: FLINK-9314
URL: https://issues.apache.org/jira/browse/FLINK-9314
Project: Flink
Issue T
[
https://issues.apache.org/jira/browse/FLINK-9311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16466409#comment-16466409
]
Richard Deurwaarder commented on FLINK-9311:
PubSub works more like RabbitMQ t
[
https://issues.apache.org/jira/browse/FLINK-9311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16466409#comment-16466409
]
Richard Deurwaarder edited comment on FLINK-9311 at 5/7/18 8:06 PM:
GitHub user StephanEwen opened a pull request:
https://github.com/apache/flink/pull/5966
[FLINK-9312] [security] Add mutual authentication for RPC and data plane
## What is the purpose of the change
Currently, the Flink processes encrypted connections via SSL:
- Data e
[
https://issues.apache.org/jira/browse/FLINK-9312?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16466431#comment-16466431
]
ASF GitHub Bot commented on FLINK-9312:
---
GitHub user StephanEwen opened a pull reque
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/5966
@EronWright This might be interesting to you as well
---
[
https://issues.apache.org/jira/browse/FLINK-9312?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16466435#comment-16466435
]
ASF GitHub Bot commented on FLINK-9312:
---
Github user StephanEwen commented on the is
[
https://issues.apache.org/jira/browse/FLINK-8237?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske reassigned FLINK-8237:
Assignee: Pavel Shvetsov
> BucketingSink throws NPE when Writer.duplicate returns null
> --
[
https://issues.apache.org/jira/browse/FLINK-9281?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16466438#comment-16466438
]
Tim commented on FLINK-9281:
Not really. Here's what I know
a) If I run the Flink job in my
[
https://issues.apache.org/jira/browse/FLINK-8237?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske closed FLINK-8237.
Resolution: Fixed
Fix Version/s: 1.4.3
1.5.0
Fixed for 1.4.3 with c7d9ad49
Github user yuqi1129 commented on a diff in the pull request:
https://github.com/apache/flink/pull/5902#discussion_r186599431
--- Diff:
flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/history/HistoryServerArchiveFetcher.java
---
@@ -162,7 +166,7 @@ public void
[
https://issues.apache.org/jira/browse/FLINK-9194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16466736#comment-16466736
]
ASF GitHub Bot commented on FLINK-9194:
---
Github user yuqi1129 commented on a diff in
Github user yuqi1129 commented on a diff in the pull request:
https://github.com/apache/flink/pull/5959#discussion_r186603684
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/metrics/groups/ComponentMetricGroup.java
---
@@ -57,11 +57,12 @@ public ComponentMetricGroup
[
https://issues.apache.org/jira/browse/FLINK-9258?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16466777#comment-16466777
]
ASF GitHub Bot commented on FLINK-9258:
---
Github user yuqi1129 commented on a diff in
Biao Liu created FLINK-9315:
---
Summary: TaskManagerRunner.shutDown() would stuck in waiting rpc
service terminated
Key: FLINK-9315
URL: https://issues.apache.org/jira/browse/FLINK-9315
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-9315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Biao Liu updated FLINK-9315:
Description: Currently shutdown TaskManagerRunner would stuck
> TaskManagerRunner.shutDown() would stuck in
[
https://issues.apache.org/jira/browse/FLINK-9315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Biao Liu updated FLINK-9315:
Summary: TaskManagerRunner.shutDown() would be stuck in waiting rpc service
terminated (was: TaskManagerRun
[
https://issues.apache.org/jira/browse/FLINK-9315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Biao Liu updated FLINK-9315:
Description: Currently shutdown TaskManagerRunner may be stuck. Because
(was: Currently shutdown TaskManag
[
https://issues.apache.org/jira/browse/FLINK-9315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Biao Liu updated FLINK-9315:
Summary: TaskManagerRunner.shutDown() may be stuck in waiting rpc service
terminated (was: TaskManagerRunne
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/5958#discussion_r186606104
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/serialization/DeserializationSchema.java
---
@@ -42,14 +42,22 @@
@Public
public in
[
https://issues.apache.org/jira/browse/FLINK-8500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16466797#comment-16466797
]
ASF GitHub Bot commented on FLINK-8500:
---
Github user tzulitai commented on the issue
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/5958
Thanks for the update @FredTing.
I'll try to take another look at the PR within the next days.
---
[
https://issues.apache.org/jira/browse/FLINK-8500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16466795#comment-16466795
]
ASF GitHub Bot commented on FLINK-8500:
---
Github user tzulitai commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-9315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Biao Liu updated FLINK-9315:
Description:
Currently the TaskManagerRunner would be waiting for rpc service terminated
synchronously. If
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/5926#discussion_r186608526
--- Diff: flink-end-to-end-tests/run-nightly-tests.sh ---
@@ -58,25 +58,97 @@ fi
if [ $EXIT_CODE == 0 ]; then
printf
"\n==
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/5926
Thanks for the review @StefanRRichter! Will address your comment and merge
this.
---
[
https://issues.apache.org/jira/browse/FLINK-9073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16466810#comment-16466810
]
ASF GitHub Bot commented on FLINK-9073:
---
Github user tzulitai commented on the issue
[
https://issues.apache.org/jira/browse/FLINK-9073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16466809#comment-16466809
]
ASF GitHub Bot commented on FLINK-9073:
---
Github user tzulitai commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-7789?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai reassigned FLINK-7789:
--
Assignee: blues zheng
> Add handler for Async IO operator timeouts
> -
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/5959#discussion_r186630665
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/metrics/groups/ComponentMetricGroup.java
---
@@ -57,11 +57,12 @@ public ComponentMetricGroup(M
[
https://issues.apache.org/jira/browse/FLINK-9258?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16466963#comment-16466963
]
ASF GitHub Bot commented on FLINK-9258:
---
Github user zentol commented on a diff in t
201 - 248 of 248 matches
Mail list logo