[jira] [Closed] (FLINK-8690) Support distinct aggregation on group windowed streaming tables.

2018-05-07 Thread Fabian Hueske (JIRA)
[ 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] flink pull request #5965: [FLINK-9310] [security] Update standard cipher sui...

2018-05-07 Thread StephanEwen
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] flink issue #5965: [FLINK-9310] [security] Update standard cipher suites for...

2018-05-07 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/5965 @EronWright This might be interesting to you. ---

[jira] [Commented] (FLINK-9310) Update default cyphersuites

2018-05-07 Thread ASF GitHub Bot (JIRA)
[ 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

[jira] [Commented] (FLINK-9310) Update default cyphersuites

2018-05-07 Thread ASF GitHub Bot (JIRA)
[ 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] flink pull request #5961: [FLINK-8255][DataSet API, DataStream API] key expr...

2018-05-07 Thread fhueske
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] flink pull request #5961: [FLINK-8255][DataSet API, DataStream API] key expr...

2018-05-07 Thread fhueske
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] flink pull request #5961: [FLINK-8255][DataSet API, DataStream API] key expr...

2018-05-07 Thread fhueske
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] flink pull request #5961: [FLINK-8255][DataSet API, DataStream API] key expr...

2018-05-07 Thread fhueske
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] flink pull request #5961: [FLINK-8255][DataSet API, DataStream API] key expr...

2018-05-07 Thread fhueske
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() {

[jira] [Commented] (FLINK-8255) Key expressions on named row types do not work

2018-05-07 Thread ASF GitHub Bot (JIRA)
[ 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

[jira] [Commented] (FLINK-8255) Key expressions on named row types do not work

2018-05-07 Thread ASF GitHub Bot (JIRA)
[ 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

[jira] [Commented] (FLINK-8255) Key expressions on named row types do not work

2018-05-07 Thread ASF GitHub Bot (JIRA)
[ 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

[jira] [Commented] (FLINK-8255) Key expressions on named row types do not work

2018-05-07 Thread ASF GitHub Bot (JIRA)
[ 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

[jira] [Commented] (FLINK-8255) Key expressions on named row types do not work

2018-05-07 Thread ASF GitHub Bot (JIRA)
[ 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

[jira] [Created] (FLINK-9312) Perform mutual authentication during SSL handshakes

2018-05-07 Thread Stephan Ewen (JIRA)
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

[jira] [Created] (FLINK-9313) Enable mutual authentication for RPC (akka)

2018-05-07 Thread Stephan Ewen (JIRA)
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

[jira] [Created] (FLINK-9314) Enable SSL mutual authentication for Netty / TaskManagers

2018-05-07 Thread Stephan Ewen (JIRA)
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

[jira] [Commented] (FLINK-9311) PubSub connector

2018-05-07 Thread Richard Deurwaarder (JIRA)
[ 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

[jira] [Comment Edited] (FLINK-9311) PubSub connector

2018-05-07 Thread Richard Deurwaarder (JIRA)
[ 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] flink pull request #5966: [FLINK-9312] [security] Add mutual authentication ...

2018-05-07 Thread StephanEwen
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

[jira] [Commented] (FLINK-9312) Perform mutual authentication during SSL handshakes

2018-05-07 Thread ASF GitHub Bot (JIRA)
[ 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] flink issue #5966: [FLINK-9312] [security] Add mutual authentication for RPC...

2018-05-07 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/5966 @EronWright This might be interesting to you as well ---

[jira] [Commented] (FLINK-9312) Perform mutual authentication during SSL handshakes

2018-05-07 Thread ASF GitHub Bot (JIRA)
[ 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

[jira] [Assigned] (FLINK-8237) BucketingSink throws NPE when Writer.duplicate returns null

2018-05-07 Thread Fabian Hueske (JIRA)
[ 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 > --

[jira] [Commented] (FLINK-9281) LogBack not working

2018-05-07 Thread Tim (JIRA)
[ 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

[jira] [Closed] (FLINK-8237) BucketingSink throws NPE when Writer.duplicate returns null

2018-05-07 Thread Fabian Hueske (JIRA)
[ 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] flink pull request #5902: [FLINK-9194][history] Add HistoryServer support to...

2018-05-07 Thread yuqi1129
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

[jira] [Commented] (FLINK-9194) Finished jobs are not archived to HistoryServer

2018-05-07 Thread ASF GitHub Bot (JIRA)
[ 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] flink pull request #5959: [FLINK-9258][metrics] Thread-safe initialization o...

2018-05-07 Thread yuqi1129
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

[jira] [Commented] (FLINK-9258) ConcurrentModificationException in ComponentMetricGroup.getAllVariables

2018-05-07 Thread ASF GitHub Bot (JIRA)
[ 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

[jira] [Created] (FLINK-9315) TaskManagerRunner.shutDown() would stuck in waiting rpc service terminated

2018-05-07 Thread Biao Liu (JIRA)
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

[jira] [Updated] (FLINK-9315) TaskManagerRunner.shutDown() would stuck in waiting rpc service terminated

2018-05-07 Thread Biao Liu (JIRA)
[ 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

[jira] [Updated] (FLINK-9315) TaskManagerRunner.shutDown() would be stuck in waiting rpc service terminated

2018-05-07 Thread Biao Liu (JIRA)
[ 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

[jira] [Updated] (FLINK-9315) TaskManagerRunner.shutDown() would be stuck in waiting rpc service terminated

2018-05-07 Thread Biao Liu (JIRA)
[ 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

[jira] [Updated] (FLINK-9315) TaskManagerRunner.shutDown() may be stuck in waiting rpc service terminated

2018-05-07 Thread Biao Liu (JIRA)
[ 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] flink pull request #5958: [FLINK-8500] Get the timestamp of the Kafka messag...

2018-05-07 Thread tzulitai
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

[jira] [Commented] (FLINK-8500) Get the timestamp of the Kafka message from kafka consumer(Kafka010Fetcher)

2018-05-07 Thread ASF GitHub Bot (JIRA)
[ 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] flink issue #5958: [FLINK-8500] Get the timestamp of the Kafka message from ...

2018-05-07 Thread tzulitai
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. ---

[jira] [Commented] (FLINK-8500) Get the timestamp of the Kafka message from kafka consumer(Kafka010Fetcher)

2018-05-07 Thread ASF GitHub Bot (JIRA)
[ 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

[jira] [Updated] (FLINK-9315) TaskManagerRunner.shutDown() may be stuck in waiting rpc service terminated

2018-05-07 Thread Biao Liu (JIRA)
[ 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] flink pull request #5926: [FLINK-9073] [e2e-tests] Extend savepoint e2e test...

2018-05-07 Thread tzulitai
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] flink issue #5926: [FLINK-9073] [e2e-tests] Extend savepoint e2e tests for d...

2018-05-07 Thread tzulitai
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. ---

[jira] [Commented] (FLINK-9073) Resume from savepoint end-to-end tests should be extended for different state backends

2018-05-07 Thread ASF GitHub Bot (JIRA)
[ 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

[jira] [Commented] (FLINK-9073) Resume from savepoint end-to-end tests should be extended for different state backends

2018-05-07 Thread ASF GitHub Bot (JIRA)
[ 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

[jira] [Assigned] (FLINK-7789) Add handler for Async IO operator timeouts

2018-05-07 Thread Tzu-Li (Gordon) Tai (JIRA)
[ 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] flink pull request #5959: [FLINK-9258][metrics] Thread-safe initialization o...

2018-05-07 Thread zentol
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

[jira] [Commented] (FLINK-9258) ConcurrentModificationException in ComponentMetricGroup.getAllVariables

2018-05-07 Thread ASF GitHub Bot (JIRA)
[ 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

<    1   2   3