[jira] [Commented] (FLINK-7251) Merge the flink-java8 project into flink-core

[ https://issues.apache.org/jira/browse/FLINK-7251?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16546758#comment-16546758 ] ASF GitHub Bot commented on FLINK-7251: --- Github user aljoscha commented on a diff i

[jira] [Updated] (FLINK-9764) Failure in LocalRecoveryRocksDBFullITCase

[ https://issues.apache.org/jira/browse/FLINK-9764?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Deepak Sharma updated FLINK-9764: - Component/s: Tests > Failure in LocalRecoveryRocksDBFullITCase >

[jira] [Created] (FLINK-9879) Find sane defaults for (advanced) SSL session parameters

Nico Kruber created FLINK-9879: -- Summary: Find sane defaults for (advanced) SSL session parameters Key: FLINK-9879 URL: https://issues.apache.org/jira/browse/FLINK-9879 Project: Flink Issue Type

[GitHub] flink pull request #6120: [FLINK-7251] [types] Remove the flink-java8 module...

Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/6120#discussion_r203060212 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/util/JarFileCreatorTest.java --- @@ -102,15 +104,62 @@ public void TestAnonymousInnerClassTr

[jira] [Updated] (FLINK-9812) SpanningRecordSerializationTest fails on travis

[ https://issues.apache.org/jira/browse/FLINK-9812?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Deepak Sharma updated FLINK-9812: - Component/s: Tests > SpanningRecordSerializationTest fails on travis > --

[jira] [Commented] (FLINK-9777) YARN: JM and TM Memory must be specified with Units

[ https://issues.apache.org/jira/browse/FLINK-9777?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16546755#comment-16546755 ] ASF GitHub Bot commented on FLINK-9777: --- Github user dawidwys commented on the issu

[jira] [Created] (FLINK-9878) IO worker threads BLOCKED on SSL Session Cache while CMS full gc

Nico Kruber created FLINK-9878: -- Summary: IO worker threads BLOCKED on SSL Session Cache while CMS full gc Key: FLINK-9878 URL: https://issues.apache.org/jira/browse/FLINK-9878 Project: Flink I

[GitHub] flink issue #6297: [FLINK-9777] YARN: JM and TM Memory must be specified wit...

Github user dawidwys commented on the issue: https://github.com/apache/flink/pull/6297 LGTM for me, Thanks for your contribution @yanghua. @GJL would you like to have last look, or can I merge it? ---

[jira] [Updated] (FLINK-9851) Add documentation for unified table sources/sinks

[ https://issues.apache.org/jira/browse/FLINK-9851?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-9851: - Affects Version/s: 1.6.0 > Add documentation for unified table sources/sinks > --

[jira] [Updated] (FLINK-9851) Add documentation for unified table sources/sinks

[ https://issues.apache.org/jira/browse/FLINK-9851?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-9851: - Priority: Critical (was: Major) > Add documentation for unified table sources/sinks > --

[jira] [Updated] (FLINK-9851) Add documentation for unified table sources/sinks

[ https://issues.apache.org/jira/browse/FLINK-9851?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-9851: - Fix Version/s: 1.6.0 > Add documentation for unified table sources/sinks > --

[jira] [Updated] (FLINK-9852) Expose descriptor-based sink creation in table environments

[ https://issues.apache.org/jira/browse/FLINK-9852?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-9852: - Affects Version/s: 1.6.0 > Expose descriptor-based sink creation in table environments >

[jira] [Updated] (FLINK-9858) State TTL End-to-End Test

[ https://issues.apache.org/jira/browse/FLINK-9858?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-9858: - Priority: Critical (was: Major) > State TTL End-to-End Test > - > >

[jira] [Updated] (FLINK-9858) State TTL End-to-End Test

[ https://issues.apache.org/jira/browse/FLINK-9858?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-9858: - Fix Version/s: 1.6.0 > State TTL End-to-End Test > - > >

[jira] [Updated] (FLINK-9858) State TTL End-to-End Test

[ https://issues.apache.org/jira/browse/FLINK-9858?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-9858: - Component/s: Tests > State TTL End-to-End Test > - > > Ke

[jira] [Resolved] (FLINK-9865) flink-hadoop-compatibility should assume Hadoop as provided

[ https://issues.apache.org/jira/browse/FLINK-9865?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-9865. -- Resolution: Fixed Fixed via 975fdbe5a762bd80bee843927e67e8eba417af8d > flink-hadoop-compatibil

[jira] [Updated] (FLINK-9870) Support field mapping and time attributes for table sinks

[ https://issues.apache.org/jira/browse/FLINK-9870?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-9870: - Fix Version/s: 1.7.0 > Support field mapping and time attributes for table sinks > --

[jira] [Commented] (FLINK-9872) SavepointITCase#testSavepointForJobWithIteration does not properly cancel jobs

[ https://issues.apache.org/jira/browse/FLINK-9872?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16546703#comment-16546703 ] Till Rohrmann commented on FLINK-9872: -- Is this a test instability [~Zentol]? > Sav

[jira] [Commented] (FLINK-9658) Test data output directories are no longer cleaned up

[ https://issues.apache.org/jira/browse/FLINK-9658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16546699#comment-16546699 ] Deepak Sharma commented on FLINK-9658: -- This may have been taken care of by  [FLINK-

[jira] [Updated] (FLINK-9874) set_conf_ssl in E2E tests fails on macOS

[ https://issues.apache.org/jira/browse/FLINK-9874?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-9874: - Labels: test-stability (was: ) > set_conf_ssl in E2E tests fails on macOS >

[jira] [Updated] (FLINK-9874) set_conf_ssl in E2E tests fails on macOS

[ https://issues.apache.org/jira/browse/FLINK-9874?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-9874: - Priority: Critical (was: Blocker) > set_conf_ssl in E2E tests fails on macOS > -

[jira] [Updated] (FLINK-9874) set_conf_ssl in E2E tests fails on macOS

[ https://issues.apache.org/jira/browse/FLINK-9874?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-9874: - Fix Version/s: 1.6.0 > set_conf_ssl in E2E tests fails on macOS > ---

[jira] [Closed] (FLINK-9868) Expose channel id to ProcessFunction

[ https://issues.apache.org/jira/browse/FLINK-9868?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-9868. - Resolution: Won't Fix > Expose channel id to ProcessFunction > --

[jira] [Closed] (FLINK-9876) ExecutionGraphCoLocationRestartTest testConstraintsAfterRestart sometimes fails with timeout

[ https://issues.apache.org/jira/browse/FLINK-9876?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-9876. Resolution: Duplicate > ExecutionGraphCoLocationRestartTest testConstraintsAfterRestart sometimes

[jira] [Closed] (FLINK-9856) ExecutionGraphCoLocationRestartTest#testConstraintsAfterRestart failed on travis

[ https://issues.apache.org/jira/browse/FLINK-9856?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-9856. Resolution: Duplicate > ExecutionGraphCoLocationRestartTest#testConstraintsAfterRestart failed on

[jira] [Commented] (FLINK-9868) Expose channel id to ProcessFunction

[ https://issues.apache.org/jira/browse/FLINK-9868?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16546694#comment-16546694 ] Kostas Kloudas commented on FLINK-9868: --- Thanks a lot [~hequn8128]! > Expose chann

[jira] [Updated] (FLINK-9876) ExecutionGraphCoLocationRestartTest testConstraintsAfterRestart sometimes fails with timeout

[ https://issues.apache.org/jira/browse/FLINK-9876?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Deepak Sharma updated FLINK-9876: - Component/s: Tests > ExecutionGraphCoLocationRestartTest testConstraintsAfterRestart sometimes >

[jira] [Commented] (FLINK-9868) Expose channel id to ProcessFunction

[ https://issues.apache.org/jira/browse/FLINK-9868?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16546692#comment-16546692 ] Hequn Cheng commented on FLINK-9868: Hi [~kkl0u] [~yanghua] Thanks for your replies.

[jira] [Updated] (FLINK-5601) Window operator does not checkpoint watermarks

[ https://issues.apache.org/jira/browse/FLINK-5601?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-5601: - Fix Version/s: (was: 1.6.0) 1.7.0 > Window operator does not checkpoint wa

[jira] [Updated] (FLINK-6306) Sink for eventually consistent file systems

[ https://issues.apache.org/jira/browse/FLINK-6306?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-6306: - Fix Version/s: (was: 1.6.0) > Sink for eventually consistent file systems > -

[jira] [Resolved] (FLINK-6306) Sink for eventually consistent file systems

[ https://issues.apache.org/jira/browse/FLINK-6306?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-6306. -- Resolution: Duplicate This issue should be covered by FLINK-9752 (once it is completed). > Sin

[jira] [Updated] (FLINK-6944) Introduce DefaultTypeSerializerConfigSnapshot as a base implementation for serializer compatibility checks

[ https://issues.apache.org/jira/browse/FLINK-6944?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-6944: - Fix Version/s: (was: 1.6.0) 1.7.0 > Introduce DefaultTypeSerializerConfigS

[jira] [Updated] (FLINK-6856) Eagerly check if serializer config snapshots are deserializable when snapshotting

[ https://issues.apache.org/jira/browse/FLINK-6856?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-6856: - Fix Version/s: (was: 1.6.0) 1.7.0 > Eagerly check if serializer config sna

[jira] [Updated] (FLINK-6856) Eagerly check if serializer config snapshots are deserializable when snapshotting

[ https://issues.apache.org/jira/browse/FLINK-6856?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-6856: - Affects Version/s: 1.6.0 1.4.2 1.5.1 > Eagerly chec

[jira] [Created] (FLINK-9877) Add separate docs page for different join types in DataStream API

Florian Schmidt created FLINK-9877: -- Summary: Add separate docs page for different join types in DataStream API Key: FLINK-9877 URL: https://issues.apache.org/jira/browse/FLINK-9877 Project: Flink

[jira] [Updated] (FLINK-7386) Flink Elasticsearch 5 connector is not compatible with Elasticsearch 5.2+ client

[ https://issues.apache.org/jira/browse/FLINK-7386?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-7386: - Fix Version/s: (was: 1.6.0) 1.7.0 > Flink Elasticsearch 5 connector is not

[jira] [Assigned] (FLINK-9874) set_conf_ssl in E2E tests fails on macOS

[ https://issues.apache.org/jira/browse/FLINK-9874?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Florian Schmidt reassigned FLINK-9874: -- Assignee: (was: Florian Schmidt) > set_conf_ssl in E2E tests fails on macOS >

[jira] [Commented] (FLINK-7251) Merge the flink-java8 project into flink-core

[ https://issues.apache.org/jira/browse/FLINK-7251?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16546681#comment-16546681 ] ASF GitHub Bot commented on FLINK-7251: --- Github user twalthr commented on a diff in

[GitHub] flink pull request #6120: [FLINK-7251] [types] Remove the flink-java8 module...

Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/6120#discussion_r203040441 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/util/JarFileCreatorTest.java --- @@ -102,15 +104,62 @@ public void TestAnonymousInnerClassTri

[jira] [Commented] (FLINK-8418) Kafka08ITCase.testStartFromLatestOffsets() times out on Travis

[ https://issues.apache.org/jira/browse/FLINK-8418?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16546677#comment-16546677 ] Till Rohrmann commented on FLINK-8418: -- Any new insights [~tzulitai]? > Kafka08ITCa

[jira] [Updated] (FLINK-8871) Checkpoint cancellation is not propagated to stop checkpointing threads on the task manager

[ https://issues.apache.org/jira/browse/FLINK-8871?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-8871: - Fix Version/s: (was: 1.6.0) 1.7.0 > Checkpoint cancellation is not propaga

[jira] [Updated] (FLINK-8871) Checkpoint cancellation is not propagated to stop checkpointing threads on the task manager

[ https://issues.apache.org/jira/browse/FLINK-8871?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-8871: - Affects Version/s: 1.6.0 > Checkpoint cancellation is not propagated to stop checkpointing thread

[jira] [Updated] (FLINK-8971) Create general purpose testing job

[ https://issues.apache.org/jira/browse/FLINK-8971?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-8971: - Fix Version/s: (was: 1.6.0) 1.7.0 > Create general purpose testing job > -

[jira] [Updated] (FLINK-9000) Add automated cluster framework tests

[ https://issues.apache.org/jira/browse/FLINK-9000?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-9000: - Fix Version/s: (was: 1.6.0) 1.7.0 > Add automated cluster framework tests

[jira] [Updated] (FLINK-9377) Remove writing serializers as part of the checkpoint meta information

[ https://issues.apache.org/jira/browse/FLINK-9377?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-9377: - Fix Version/s: (was: 1.6.0) 1.7.0 > Remove writing serializers as part of

[jira] [Updated] (FLINK-9574) Add a dedicated documentation page for state evolution

[ https://issues.apache.org/jira/browse/FLINK-9574?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-9574: - Fix Version/s: (was: 1.6.0) 1.7.0 > Add a dedicated documentation page for

[jira] [Updated] (FLINK-9376) Allow upgrading to incompatible state serializers (state schema evolution)

[ https://issues.apache.org/jira/browse/FLINK-9376?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-9376: - Fix Version/s: (was: 1.6.0) 1.7.0 > Allow upgrading to incompatible state

[jira] [Updated] (FLINK-9876) ExecutionGraphCoLocationRestartTest testConstraintsAfterRestart sometimes fails with timeout

[ https://issues.apache.org/jira/browse/FLINK-9876?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Florian Schmidt updated FLINK-9876: --- Description:  See [https://travis-ci.org/florianschmidt1994/flink/jobs/404871788] {code:java}

[jira] [Created] (FLINK-9876) ExecutionGraphCoLocationRestartTest testConstraintsAfterRestart sometimes fails with timeout

Florian Schmidt created FLINK-9876: -- Summary: ExecutionGraphCoLocationRestartTest testConstraintsAfterRestart sometimes fails with timeout Key: FLINK-9876 URL: https://issues.apache.org/jira/browse/FLINK-9876

[jira] [Commented] (FLINK-8981) End-to-end test: Kerberos security

[ https://issues.apache.org/jira/browse/FLINK-8981?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16546639#comment-16546639 ] Aljoscha Krettek commented on FLINK-8981: - I'm actually working on a Kerberos tes

[jira] [Assigned] (FLINK-8981) End-to-end test: Kerberos security

[ https://issues.apache.org/jira/browse/FLINK-8981?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-8981: --- Assignee: Aljoscha Krettek (was: Shuyi Chen) > End-to-end test: Kerberos security >

[jira] [Commented] (FLINK-8981) End-to-end test: Kerberos security

[ https://issues.apache.org/jira/browse/FLINK-8981?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16546640#comment-16546640 ] Aljoscha Krettek commented on FLINK-8981: - [~suez1224] I hope it's alright if I a

[jira] [Commented] (FLINK-9869) Send PartitionInfo in batch to Improve perfornance

[ https://issues.apache.org/jira/browse/FLINK-9869?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16546628#comment-16546628 ] ASF GitHub Bot commented on FLINK-9869: --- Github user tison1 commented on the issue:

[GitHub] flink issue #6345: [FLINK-9869] Send PartitionInfo in batch to Improve perfo...

Github user tison1 commented on the issue: https://github.com/apache/flink/pull/6345 cc @sihuazhou ---

[jira] [Commented] (FLINK-7251) Merge the flink-java8 project into flink-core

[ https://issues.apache.org/jira/browse/FLINK-7251?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16546614#comment-16546614 ] ASF GitHub Bot commented on FLINK-7251: --- Github user twalthr commented on a diff in

[GitHub] flink pull request #6120: [FLINK-7251] [types] Remove the flink-java8 module...

Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/6120#discussion_r203021961 --- Diff: flink-core/src/test/java/org/apache/flink/api/java/typeutils/LambdaExtractionTest.java --- @@ -50,12 +41,12 @@ import static org.junit.Assert

[jira] [Commented] (FLINK-9875) Add concurrent creation of execution job vertex

[ https://issues.apache.org/jira/browse/FLINK-9875?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16546612#comment-16546612 ] ASF GitHub Bot commented on FLINK-9875: --- GitHub user tison1 opened a pull request:

[jira] [Commented] (FLINK-9855) Check all calls to the TypeExtractor.getBinaryOperatorReturnType()

[ https://issues.apache.org/jira/browse/FLINK-9855?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16546610#comment-16546610 ] Till Rohrmann commented on FLINK-9855: -- Could we maybe add some easier to use conven

[jira] [Updated] (FLINK-9875) Add concurrent creation of execution job vertex

[ https://issues.apache.org/jira/browse/FLINK-9875?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-9875: -- Labels: pull-request-available (was: ) > Add concurrent creation of execution job vertex > ---

[GitHub] flink pull request #6353: [FLINK-9875] Add concurrent creation of execution ...

GitHub user tison1 opened a pull request: https://github.com/apache/flink/pull/6353 [FLINK-9875] Add concurrent creation of execution job vertex ## Add concurrent creation of execution job vertex in some case like inputformat vertex, creation of execution job vertex is time

[jira] [Created] (FLINK-9875) Add concurrent creation of execution job vertex

陈梓立 created FLINK-9875: -- Summary: Add concurrent creation of execution job vertex Key: FLINK-9875 URL: https://issues.apache.org/jira/browse/FLINK-9875 Project: Flink Issue Type: Improvement C

[jira] [Commented] (FLINK-9874) set_conf_ssl in E2E tests fails on macOS

[ https://issues.apache.org/jira/browse/FLINK-9874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16546587#comment-16546587 ] Florian Schmidt commented on FLINK-9874: I think we should be able to work around

[jira] [Commented] (FLINK-5735) Non-overlapping sliding window is not deterministic

[ https://issues.apache.org/jira/browse/FLINK-5735?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16546585#comment-16546585 ] Valerii Florov commented on FLINK-5735: --- It is not reproducible if all rows are in

[jira] [Assigned] (FLINK-9874) set_conf_ssl in E2E tests fails on macOS

[ https://issues.apache.org/jira/browse/FLINK-9874?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Florian Schmidt reassigned FLINK-9874: -- Assignee: Florian Schmidt > set_conf_ssl in E2E tests fails on macOS > ---

[jira] [Created] (FLINK-9874) set_conf_ssl in E2E tests fails on macOS

Florian Schmidt created FLINK-9874: -- Summary: set_conf_ssl in E2E tests fails on macOS Key: FLINK-9874 URL: https://issues.apache.org/jira/browse/FLINK-9874 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-9860) Netty resource leak on receiver side

[ https://issues.apache.org/jira/browse/FLINK-9860?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16546579#comment-16546579 ] Nico Kruber commented on FLINK-9860: FYI: with leak detection (as well as error loggi

[jira] [Updated] (FLINK-9860) Netty resource leak on receiver side

[ https://issues.apache.org/jira/browse/FLINK-9860?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-9860: --- Affects Version/s: 1.5.1 > Netty resource leak on receiver side > ---

[jira] [Commented] (FLINK-5735) Non-overlapping sliding window is not deterministic

[ https://issues.apache.org/jira/browse/FLINK-5735?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16546574#comment-16546574 ] Aljoscha Krettek commented on FLINK-5735: - I think the problem here is that the w

[jira] [Closed] (FLINK-9857) Processing-time timers fire too early

[ https://issues.apache.org/jira/browse/FLINK-9857?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-9857. --- Resolution: Fixed Fixed on master in 690bc370e19d8003add4e41c05acfb4dccc662b4 Fixed on relea

[jira] [Commented] (FLINK-9857) Processing-time timers fire too early

[ https://issues.apache.org/jira/browse/FLINK-9857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16546548#comment-16546548 ] ASF GitHub Bot commented on FLINK-9857: --- Github user aljoscha closed the pull reque

[GitHub] flink pull request #6348: [FLINK-9857] Delay firing of processing-time timer...

Github user aljoscha closed the pull request at: https://github.com/apache/flink/pull/6348 ---

[jira] [Updated] (FLINK-9646) ExecutionGraphCoLocationRestartTest.testConstraintsAfterRestart failed on Travis

[ https://issues.apache.org/jira/browse/FLINK-9646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-9646: - Fix Version/s: (was: 1.5.1) 1.5.2 > ExecutionGraphCoLocationRestartTest.te

[jira] [Commented] (FLINK-9857) Processing-time timers fire too early

[ https://issues.apache.org/jira/browse/FLINK-9857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16546541#comment-16546541 ] ASF GitHub Bot commented on FLINK-9857: --- Github user aljoscha commented on the issu

[jira] [Reopened] (FLINK-9646) ExecutionGraphCoLocationRestartTest.testConstraintsAfterRestart failed on Travis

[ https://issues.apache.org/jira/browse/FLINK-9646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reopened FLINK-9646: -- The problem is still not fully fixed: https://api.travis-ci.org/v3/job/404321779/log.txt > Execut

[GitHub] flink issue #6348: [FLINK-9857] Delay firing of processing-time timers by 1 ...

Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/6348 I quickly talked to @StephanEwen directly and he agreed the fix is good so I'm merging. ---

[jira] [Commented] (FLINK-7251) Merge the flink-java8 project into flink-core

[ https://issues.apache.org/jira/browse/FLINK-7251?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16546533#comment-16546533 ] ASF GitHub Bot commented on FLINK-7251: --- Github user aljoscha commented on a diff i

[jira] [Commented] (FLINK-7251) Merge the flink-java8 project into flink-core

[ https://issues.apache.org/jira/browse/FLINK-7251?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16546531#comment-16546531 ] ASF GitHub Bot commented on FLINK-7251: --- Github user aljoscha commented on a diff i

[jira] [Commented] (FLINK-7251) Merge the flink-java8 project into flink-core

[ https://issues.apache.org/jira/browse/FLINK-7251?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16546532#comment-16546532 ] ASF GitHub Bot commented on FLINK-7251: --- Github user aljoscha commented on a diff i

[jira] [Commented] (FLINK-7251) Merge the flink-java8 project into flink-core

[ https://issues.apache.org/jira/browse/FLINK-7251?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16546530#comment-16546530 ] ASF GitHub Bot commented on FLINK-7251: --- Github user aljoscha commented on a diff i

[GitHub] flink pull request #6120: [FLINK-7251] [types] Remove the flink-java8 module...

Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/6120#discussion_r203002928 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/util/JarFileCreatorTest.java --- @@ -102,15 +104,62 @@ public void TestAnonymousInnerClassTr

[GitHub] flink pull request #6120: [FLINK-7251] [types] Remove the flink-java8 module...

Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/6120#discussion_r203001399 --- Diff: flink-core/src/test/java/org/apache/flink/api/java/typeutils/LambdaExtractionTest.java --- @@ -271,19 +214,20 @@ public void testKeySelectorLambd

[GitHub] flink pull request #6120: [FLINK-7251] [types] Remove the flink-java8 module...

Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/6120#discussion_r203003680 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/KeyedStream.java --- @@ -237,19 +248,81 @@ private boolean validate

[GitHub] flink pull request #6120: [FLINK-7251] [types] Remove the flink-java8 module...

Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/6120#discussion_r203001023 --- Diff: flink-core/src/test/java/org/apache/flink/api/java/typeutils/LambdaExtractionTest.java --- @@ -50,12 +41,12 @@ import static org.junit.Asser

[jira] [Commented] (FLINK-9792) Cannot add html tags in options description

[ https://issues.apache.org/jira/browse/FLINK-9792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16546526#comment-16546526 ] ASF GitHub Bot commented on FLINK-9792: --- Github user dawidwys commented on a diff i

[GitHub] flink pull request #6312: [FLINK-9792] Added custom Description class for Co...

Github user dawidwys commented on a diff in the pull request: https://github.com/apache/flink/pull/6312#discussion_r203003509 --- Diff: flink-core/src/main/java/org/apache/flink/configuration/description/HtmlFormatter.java --- @@ -0,0 +1,67 @@ +/* + * Licensed to the Apach

[jira] [Commented] (FLINK-9777) YARN: JM and TM Memory must be specified with Units

[ https://issues.apache.org/jira/browse/FLINK-9777?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16546517#comment-16546517 ] ASF GitHub Bot commented on FLINK-9777: --- Github user dawidwys commented on a diff i

[jira] [Commented] (FLINK-9777) YARN: JM and TM Memory must be specified with Units

[ https://issues.apache.org/jira/browse/FLINK-9777?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16546518#comment-16546518 ] ASF GitHub Bot commented on FLINK-9777: --- Github user dawidwys commented on a diff i

[jira] [Commented] (FLINK-9777) YARN: JM and TM Memory must be specified with Units

[ https://issues.apache.org/jira/browse/FLINK-9777?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16546520#comment-16546520 ] ASF GitHub Bot commented on FLINK-9777: --- Github user dawidwys commented on a diff i

[jira] [Commented] (FLINK-9777) YARN: JM and TM Memory must be specified with Units

[ https://issues.apache.org/jira/browse/FLINK-9777?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16546519#comment-16546519 ] ASF GitHub Bot commented on FLINK-9777: --- Github user dawidwys commented on a diff i

[GitHub] flink pull request #6297: [FLINK-9777] YARN: JM and TM Memory must be specif...

Github user dawidwys commented on a diff in the pull request: https://github.com/apache/flink/pull/6297#discussion_r203000441 --- Diff: flink-yarn/src/test/java/org/apache/flink/yarn/FlinkYarnSessionCliTest.java --- @@ -352,6 +352,76 @@ public void testConfigurationClusterSpecifica

[GitHub] flink pull request #6297: [FLINK-9777] YARN: JM and TM Memory must be specif...

Github user dawidwys commented on a diff in the pull request: https://github.com/apache/flink/pull/6297#discussion_r203000456 --- Diff: flink-yarn/src/test/java/org/apache/flink/yarn/FlinkYarnSessionCliTest.java --- @@ -352,6 +352,76 @@ public void testConfigurationClusterSpecifica

[GitHub] flink pull request #6297: [FLINK-9777] YARN: JM and TM Memory must be specif...

Github user dawidwys commented on a diff in the pull request: https://github.com/apache/flink/pull/6297#discussion_r203000672 --- Diff: flink-yarn/src/test/java/org/apache/flink/yarn/FlinkYarnSessionCliTest.java --- @@ -352,6 +352,76 @@ public void testConfigurationClusterSpecifica

[GitHub] flink pull request #6297: [FLINK-9777] YARN: JM and TM Memory must be specif...

Github user dawidwys commented on a diff in the pull request: https://github.com/apache/flink/pull/6297#discussion_r203000806 --- Diff: flink-yarn/src/test/java/org/apache/flink/yarn/FlinkYarnSessionCliTest.java --- @@ -352,6 +352,76 @@ public void testConfigurationClusterSpecifica

[jira] [Commented] (FLINK-9792) Cannot add html tags in options description

[ https://issues.apache.org/jira/browse/FLINK-9792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16546493#comment-16546493 ] ASF GitHub Bot commented on FLINK-9792: --- Github user dawidwys commented on a diff i

[GitHub] flink pull request #6312: [FLINK-9792] Added custom Description class for Co...

Github user dawidwys commented on a diff in the pull request: https://github.com/apache/flink/pull/6312#discussion_r202992096 --- Diff: flink-core/src/main/java/org/apache/flink/configuration/description/HtmlFormatter.java --- @@ -0,0 +1,67 @@ +/* + * Licensed to the Apach

[jira] [Commented] (FLINK-5735) Non-overlapping sliding window is not deterministic

[ https://issues.apache.org/jira/browse/FLINK-5735?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16546488#comment-16546488 ] Valerii Florov commented on FLINK-5735: --- Hello dear all I shortened the given exam

[jira] [Commented] (FLINK-9852) Expose descriptor-based sink creation in table environments

[ https://issues.apache.org/jira/browse/FLINK-9852?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16546471#comment-16546471 ] ASF GitHub Bot commented on FLINK-9852: --- Github user twalthr commented on a diff in

[GitHub] flink pull request #6343: [FLINK-9852] [table] Expose descriptor-based sink ...

Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/6343#discussion_r202990315 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/sinks/CsvAppendTableSinkFactory.scala --- @@ -0,0 +1,52 @@ +/* + * Licen

[jira] [Updated] (FLINK-8163) NonHAQueryableStateFsBackendITCase test getting stuck on Travis

[ https://issues.apache.org/jira/browse/FLINK-8163?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-8163: -- Labels: pull-request-available test-stability (was: test-stability) > NonHAQueryableStateFsBac

[jira] [Commented] (FLINK-8163) NonHAQueryableStateFsBackendITCase test getting stuck on Travis

[ https://issues.apache.org/jira/browse/FLINK-8163?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16546468#comment-16546468 ] ASF GitHub Bot commented on FLINK-8163: --- GitHub user zentol opened a pull request:

<    1   2   3   4   >