[GitHub] [flink] flinkbot edited a comment on issue #9702: [FLINK-14107][kinesis] Erroneous queue selection in record emitter may lead to deadlock

flinkbot edited a comment on issue #9702: [FLINK-14107][kinesis] Erroneous queue selection in record emitter may lead to deadlock URL: https://github.com/apache/flink/pull/9702#issuecomment-532344762 ## CI report: * b5d14cefce1ec689f991fcc0e02bb229195f4418 : SUCCESS [Build](http

[jira] [Updated] (FLINK-14001) add a API to enable user to get the operator code generated by Flink engine

[ https://issues.apache.org/jira/browse/FLINK-14001?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dezhi Cai updated FLINK-14001: -- Fix Version/s: (was: 1.10.0) Affects Version/s: (was: 1.9.0) > add a API to enable use

[jira] [Comment Edited] (FLINK-14074) MesosResourceManager can't create new taskmanagers in Session Cluster Mode.

[ https://issues.apache.org/jira/browse/FLINK-14074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16932426#comment-16932426 ] Alexander Kasyanenko edited comment on FLINK-14074 at 9/18/19 3:41 PM: ---

[jira] [Assigned] (FLINK-12869) Add yarn acls capability to flink containers

[ https://issues.apache.org/jira/browse/FLINK-12869?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao reassigned FLINK-12869: Assignee: Nicolas Fraison > Add yarn acls capability to flink containers > --

[GitHub] [flink] carp84 commented on a change in pull request #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend

carp84 commented on a change in pull request #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend URL: https://github.com/apache/flink/pull/9501#discussion_r325763513 ## File path: flink-core/src/test/java/org/apache/flink/core/memory/Byte

[GitHub] [flink] carp84 commented on a change in pull request #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend

carp84 commented on a change in pull request #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend URL: https://github.com/apache/flink/pull/9501#discussion_r325743874 ## File path: flink-core/src/test/java/org/apache/flink/core/memory/Byte

[GitHub] [flink] flinkbot commented on issue #8760: [FLINK-12869] Add yarn acls capability to flink containers

flinkbot commented on issue #8760: [FLINK-12869] Add yarn acls capability to flink containers URL: https://github.com/apache/flink/pull/8760#issuecomment-532754938 ## CI report: * 8acc0e804c56fcb7119f0240ae79f4a49743a98d : UNKNOWN

[GitHub] [flink] flinkbot edited a comment on issue #9350: [FLINK-13485] [chinese-translation] Translate "Table API Example Walkthrough" page into Chinese

flinkbot edited a comment on issue #9350: [FLINK-13485] [chinese-translation] Translate "Table API Example Walkthrough" page into Chinese URL: https://github.com/apache/flink/pull/9350#issuecomment-517933636 ## CI report: * b9c0f8b802135f95b9674a2440a4c4d9c6ebe5e4 : FAILURE [Bui

[GitHub] [flink] tillrohrmann edited a comment on issue #9456: [FLINK-13588] flink-streaming-java don't throw away exception info in logging

tillrohrmann edited a comment on issue #9456: [FLINK-13588] flink-streaming-java don't throw away exception info in logging URL: https://github.com/apache/flink/pull/9456#issuecomment-532757299 I've merged it into the `1.10.0` and `1.9.1` branch. So you can expect it with the next bug fix

[GitHub] [flink] tillrohrmann commented on issue #9456: [FLINK-13588] flink-streaming-java don't throw away exception info in logging

tillrohrmann commented on issue #9456: [FLINK-13588] flink-streaming-java don't throw away exception info in logging URL: https://github.com/apache/flink/pull/9456#issuecomment-532757299 I've merged into the `1.10.0` and `1.9.1` branch. So you can expect it with the next bug fix release o

[GitHub] [flink] flinkbot edited a comment on issue #8760: [FLINK-12869] Add yarn acls capability to flink containers

flinkbot edited a comment on issue #8760: [FLINK-12869] Add yarn acls capability to flink containers URL: https://github.com/apache/flink/pull/8760#issuecomment-532754938 ## CI report: * 8acc0e804c56fcb7119f0240ae79f4a49743a98d : FAILURE [Build](https://travis-ci.com/flink-ci/fl

[jira] [Created] (FLINK-14121) upgrade tocommons-compress:1.19 due to CVE

John Lonergan created FLINK-14121: - Summary: upgrade tocommons-compress:1.19 due to CVE Key: FLINK-14121 URL: https://issues.apache.org/jira/browse/FLINK-14121 Project: Flink Issue Type: Impr

[GitHub] [flink] flinkbot edited a comment on issue #9702: [FLINK-14107][kinesis] Erroneous queue selection in record emitter may lead to deadlock

flinkbot edited a comment on issue #9702: [FLINK-14107][kinesis] Erroneous queue selection in record emitter may lead to deadlock URL: https://github.com/apache/flink/pull/9702#issuecomment-532344762 ## CI report: * b5d14cefce1ec689f991fcc0e02bb229195f4418 : SUCCESS [Build](http

[jira] [Commented] (FLINK-13746) Elasticsearch (v2.3.5) sink end-to-end test fails on Travis

[ https://issues.apache.org/jira/browse/FLINK-13746?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16932637#comment-16932637 ] Till Rohrmann commented on FLINK-13746: --- Yes, this should work. Please also test w

[jira] [Commented] (FLINK-14074) MesosResourceManager can't create new taskmanagers in Session Cluster Mode.

[ https://issues.apache.org/jira/browse/FLINK-14074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16932634#comment-16932634 ] Till Rohrmann commented on FLINK-14074: --- Thanks a lot for looking into the problem

[jira] [Commented] (FLINK-14073) CalcITCase failed on Travis

[ https://issues.apache.org/jira/browse/FLINK-14073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16932639#comment-16932639 ] Till Rohrmann commented on FLINK-14073: --- Then I would suggest to close the issue f

[jira] [Closed] (FLINK-14073) CalcITCase failed on Travis

[ https://issues.apache.org/jira/browse/FLINK-14073?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-14073. - Resolution: Cannot Reproduce > CalcITCase failed on Travis > --- > >

[GitHub] [flink] flinkbot edited a comment on issue #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend

flinkbot edited a comment on issue #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend URL: https://github.com/apache/flink/pull/9501#issuecomment-523769032 ## CI report: * 6107a00876759dcef075592c8bfa56764f66b6fa : FAILURE [Build](htt

[jira] [Commented] (FLINK-14111) Flink should be robust to a non-leader Zookeeper host going down

[ https://issues.apache.org/jira/browse/FLINK-14111?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16932661#comment-16932661 ] Aaron Levin commented on FLINK-14111: - [~elevy] [~Tison] yes, duplicate! My apologie

[jira] [Commented] (FLINK-14112) Removing zookeeper state should cause the task manager and job managers to restart

[ https://issues.apache.org/jira/browse/FLINK-14112?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16932660#comment-16932660 ] Aaron Levin commented on FLINK-14112: - [~Tison] [~till.rohrmann] thanks for respondi

[jira] [Closed] (FLINK-14111) Flink should be robust to a non-leader Zookeeper host going down

[ https://issues.apache.org/jira/browse/FLINK-14111?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aaron Levin closed FLINK-14111. --- Resolution: Duplicate Closing in favour of: https://issues.apache.org/jira/browse/FLINK-10052 > Fli

[GitHub] [flink] flinkbot edited a comment on issue #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend

flinkbot edited a comment on issue #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend URL: https://github.com/apache/flink/pull/9501#issuecomment-523769032 ## CI report: * 6107a00876759dcef075592c8bfa56764f66b6fa : FAILURE [Build](htt

[jira] [Commented] (FLINK-14110) Deleting state.backend.rocksdb.localdir causes silent failure

[ https://issues.apache.org/jira/browse/FLINK-14110?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16932672#comment-16932672 ] Aaron Levin commented on FLINK-14110: - [~carp84] [~klion26] I have not made a patch.

[jira] [Commented] (FLINK-14010) Dispatcher & JobManagers don't give up leadership when AM is shut down

[ https://issues.apache.org/jira/browse/FLINK-14010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16932676#comment-16932676 ] Till Rohrmann commented on FLINK-14010: --- Can't we say that we always complete {{D

[GitHub] [flink] flinkbot edited a comment on issue #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend

flinkbot edited a comment on issue #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend URL: https://github.com/apache/flink/pull/9501#issuecomment-523769032 ## CI report: * 6107a00876759dcef075592c8bfa56764f66b6fa : FAILURE [Build](htt

[jira] [Commented] (FLINK-14112) Removing zookeeper state should cause the task manager and job managers to restart

[ https://issues.apache.org/jira/browse/FLINK-14112?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16932720#comment-16932720 ] Stephan Ewen commented on FLINK-14112: -- >From the RM / JM side (leader contender) c

[jira] [Updated] (FLINK-14109) Improve javadocs and tests for high-availability backend

[ https://issues.apache.org/jira/browse/FLINK-14109?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Brendan MacDonell updated FLINK-14109: -- Description: My team at Sight Machine just finished building a custom HA backend for o

[jira] [Commented] (FLINK-14109) Improve javadocs and tests for high-availability backend

[ https://issues.apache.org/jira/browse/FLINK-14109?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16932735#comment-16932735 ] Brendan MacDonell commented on FLINK-14109: --- Thanks. I'll try to send an initi

[jira] [Commented] (FLINK-14076) 'ClassNotFoundException: KafkaException' on Flink v1.9 w/ checkpointing

[ https://issues.apache.org/jira/browse/FLINK-14076?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16932737#comment-16932737 ] Jeffrey Martin commented on FLINK-14076: Two steps to get the JobManager to stay

[jira] [Comment Edited] (FLINK-14076) 'ClassNotFoundException: KafkaException' on Flink v1.9 w/ checkpointing

[ https://issues.apache.org/jira/browse/FLINK-14076?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16932737#comment-16932737 ] Jeffrey Martin edited comment on FLINK-14076 at 9/18/19 6:38 PM: -

[jira] [Comment Edited] (FLINK-14076) 'ClassNotFoundException: KafkaException' on Flink v1.9 w/ checkpointing

[ https://issues.apache.org/jira/browse/FLINK-14076?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16932737#comment-16932737 ] Jeffrey Martin edited comment on FLINK-14076 at 9/18/19 6:47 PM: -

[jira] [Commented] (FLINK-14120) SystemProcessingTimeServiceTest.testImmediateShutdown failed on Travis

[ https://issues.apache.org/jira/browse/FLINK-14120?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16932778#comment-16932778 ] Anatolii Siuniaev commented on FLINK-14120: --- I'd like to look into this issue.

[jira] [Comment Edited] (FLINK-14120) SystemProcessingTimeServiceTest.testImmediateShutdown failed on Travis

[ https://issues.apache.org/jira/browse/FLINK-14120?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16932778#comment-16932778 ] Anatolii Siuniaev edited comment on FLINK-14120 at 9/18/19 8:10 PM: --

[jira] [Commented] (FLINK-14112) Removing zookeeper state should cause the task manager and job managers to restart

[ https://issues.apache.org/jira/browse/FLINK-14112?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16932792#comment-16932792 ] Till Rohrmann commented on FLINK-14112: --- You are right Stephan. For leader electio

[GitHub] [flink] tweise merged pull request #9702: [FLINK-14107][kinesis] Erroneous queue selection in record emitter may lead to deadlock

tweise merged pull request #9702: [FLINK-14107][kinesis] Erroneous queue selection in record emitter may lead to deadlock URL: https://github.com/apache/flink/pull/9702 This is an automated message from the Apache Git Servic

[GitHub] [flink] tweise opened a new pull request #9708: [FLINK-14107][kinesis] Erroneous queue selection in record emitter may lead to deadlock

tweise opened a new pull request #9708: [FLINK-14107][kinesis] Erroneous queue selection in record emitter may lead to deadlock URL: https://github.com/apache/flink/pull/9708 backport from master This is an automated message

[GitHub] [flink] flinkbot commented on issue #9708: [FLINK-14107][kinesis] Erroneous queue selection in record emitter may lead to deadlock

flinkbot commented on issue #9708: [FLINK-14107][kinesis] Erroneous queue selection in record emitter may lead to deadlock URL: https://github.com/apache/flink/pull/9708#issuecomment-532887432 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the com

[GitHub] [flink] tweise opened a new pull request #9709: [FLINK-14107][kinesis] Erroneous queue selection in record emitter may lead to deadlock

tweise opened a new pull request #9709: [FLINK-14107][kinesis] Erroneous queue selection in record emitter may lead to deadlock URL: https://github.com/apache/flink/pull/9709 backport from master This is an automated message

[GitHub] [flink] flinkbot commented on issue #9709: [FLINK-14107][kinesis] Erroneous queue selection in record emitter may lead to deadlock

flinkbot commented on issue #9709: [FLINK-14107][kinesis] Erroneous queue selection in record emitter may lead to deadlock URL: https://github.com/apache/flink/pull/9709#issuecomment-532888105 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the com

[jira] [Resolved] (FLINK-14107) Kinesis consumer record emitter deadlock under event time alignment

[ https://issues.apache.org/jira/browse/FLINK-14107?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise resolved FLINK-14107. -- Fix Version/s: 1.10.0 Resolution: Fixed > Kinesis consumer record emitter deadlock unde

[GitHub] [flink] flinkbot commented on issue #9708: [FLINK-14107][kinesis] Erroneous queue selection in record emitter may lead to deadlock

flinkbot commented on issue #9708: [FLINK-14107][kinesis] Erroneous queue selection in record emitter may lead to deadlock URL: https://github.com/apache/flink/pull/9708#issuecomment-532891597 ## CI report: * adf5d969d37c127653d77821bfa5fe48cf212a6d : UNKNOWN ---

[GitHub] [flink] flinkbot commented on issue #9709: [FLINK-14107][kinesis] Erroneous queue selection in record emitter may lead to deadlock

flinkbot commented on issue #9709: [FLINK-14107][kinesis] Erroneous queue selection in record emitter may lead to deadlock URL: https://github.com/apache/flink/pull/9709#issuecomment-532891619 ## CI report: * 02a0e0ea41b1dc31f233ca4d25434b5370451d1a : UNKNOWN ---

[GitHub] [flink] flinkbot edited a comment on issue #9709: [FLINK-14107][kinesis] Erroneous queue selection in record emitter may lead to deadlock

flinkbot edited a comment on issue #9709: [FLINK-14107][kinesis] Erroneous queue selection in record emitter may lead to deadlock URL: https://github.com/apache/flink/pull/9709#issuecomment-532891619 ## CI report: * 02a0e0ea41b1dc31f233ca4d25434b5370451d1a : PENDING [Build](http

[GitHub] [flink] flinkbot edited a comment on issue #9708: [FLINK-14107][kinesis] Erroneous queue selection in record emitter may lead to deadlock

flinkbot edited a comment on issue #9708: [FLINK-14107][kinesis] Erroneous queue selection in record emitter may lead to deadlock URL: https://github.com/apache/flink/pull/9708#issuecomment-532891597 ## CI report: * adf5d969d37c127653d77821bfa5fe48cf212a6d : PENDING [Build](http

[GitHub] [flink] flinkbot edited a comment on issue #9709: [FLINK-14107][kinesis] Erroneous queue selection in record emitter may lead to deadlock

flinkbot edited a comment on issue #9709: [FLINK-14107][kinesis] Erroneous queue selection in record emitter may lead to deadlock URL: https://github.com/apache/flink/pull/9709#issuecomment-532891619 ## CI report: * 02a0e0ea41b1dc31f233ca4d25434b5370451d1a : FAILURE [Build](http

[GitHub] [flink] flinkbot edited a comment on issue #9708: [FLINK-14107][kinesis] Erroneous queue selection in record emitter may lead to deadlock

flinkbot edited a comment on issue #9708: [FLINK-14107][kinesis] Erroneous queue selection in record emitter may lead to deadlock URL: https://github.com/apache/flink/pull/9708#issuecomment-532891597 ## CI report: * adf5d969d37c127653d77821bfa5fe48cf212a6d : FAILURE [Build](http

[GitHub] [flink] tweise merged pull request #9709: [FLINK-14107][kinesis] Erroneous queue selection in record emitter may lead to deadlock

tweise merged pull request #9709: [FLINK-14107][kinesis] Erroneous queue selection in record emitter may lead to deadlock URL: https://github.com/apache/flink/pull/9709 This is an automated message from the Apache Git Servic

[GitHub] [flink] tweise commented on issue #9709: [FLINK-14107][kinesis] Erroneous queue selection in record emitter may lead to deadlock

tweise commented on issue #9709: [FLINK-14107][kinesis] Erroneous queue selection in record emitter may lead to deadlock URL: https://github.com/apache/flink/pull/9709#issuecomment-532910374 unrelated test failure This is an

[GitHub] [flink] tweise commented on issue #9708: [FLINK-14107][kinesis] Erroneous queue selection in record emitter may lead to deadlock

tweise commented on issue #9708: [FLINK-14107][kinesis] Erroneous queue selection in record emitter may lead to deadlock URL: https://github.com/apache/flink/pull/9708#issuecomment-532910734 unrelated test failure This is an

[GitHub] [flink] tweise merged pull request #9708: [FLINK-14107][kinesis] Erroneous queue selection in record emitter may lead to deadlock

tweise merged pull request #9708: [FLINK-14107][kinesis] Erroneous queue selection in record emitter may lead to deadlock URL: https://github.com/apache/flink/pull/9708 This is an automated message from the Apache Git Servic

[jira] [Commented] (FLINK-14109) Improve javadocs and tests for high-availability backend

[ https://issues.apache.org/jira/browse/FLINK-14109?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16932959#comment-16932959 ] TisonKun commented on FLINK-14109: -- [~bremac] aha, nice to hear :-) > Improve javadocs

[GitHub] [flink] TisonKun commented on issue #9684: [FLINK-13992][coordination] Refactor Optional parameter in InputGateWithMetrics#updateMetrics

TisonKun commented on issue #9684: [FLINK-13992][coordination] Refactor Optional parameter in InputGateWithMetrics#updateMetrics URL: https://github.com/apache/flink/pull/9684#issuecomment-532922137 ping @azagrebin as a reminder :-) -

[jira] [Created] (FLINK-14122) Extend State Processor API to read ListCheckpointed operator state

Seth Wiesman created FLINK-14122: Summary: Extend State Processor API to read ListCheckpointed operator state Key: FLINK-14122 URL: https://issues.apache.org/jira/browse/FLINK-14122 Project: Flink

[GitHub] [flink] docete commented on a change in pull request #8706: [FLINK-12814][sql-client] Support a traditional and scrolling view of…

docete commented on a change in pull request #8706: [FLINK-12814][sql-client] Support a traditional and scrolling view of… URL: https://github.com/apache/flink/pull/8706#discussion_r325958597 ## File path: flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/cli

[GitHub] [flink] docete commented on a change in pull request #8706: [FLINK-12814][sql-client] Support a traditional and scrolling view of…

docete commented on a change in pull request #8706: [FLINK-12814][sql-client] Support a traditional and scrolling view of… URL: https://github.com/apache/flink/pull/8706#discussion_r325959037 ## File path: flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/cli

[GitHub] [flink] docete commented on a change in pull request #8706: [FLINK-12814][sql-client] Support a traditional and scrolling view of…

docete commented on a change in pull request #8706: [FLINK-12814][sql-client] Support a traditional and scrolling view of… URL: https://github.com/apache/flink/pull/8706#discussion_r325958937 ## File path: flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/cli

[jira] [Commented] (FLINK-14038) ExecutionGraph deploy failed due to akka timeout

[ https://issues.apache.org/jira/browse/FLINK-14038?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16932982#comment-16932982 ] liupengcheng commented on FLINK-14038: -- [~zhuzh] [~trohrmann] This PR not only prov

[GitHub] [flink] docete commented on a change in pull request #8706: [FLINK-12814][sql-client] Support a traditional and scrolling view of…

docete commented on a change in pull request #8706: [FLINK-12814][sql-client] Support a traditional and scrolling view of… URL: https://github.com/apache/flink/pull/8706#discussion_r325960076 ## File path: flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/con

[jira] [Assigned] (FLINK-14119) Clean idle state for RetractableTopNFunction

[ https://issues.apache.org/jira/browse/FLINK-14119?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-14119: --- Assignee: ALEC CHEN > Clean idle state for RetractableTopNFunction > --

[jira] [Commented] (FLINK-14119) Clean idle state for RetractableTopNFunction

[ https://issues.apache.org/jira/browse/FLINK-14119?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16932988#comment-16932988 ] Jark Wu commented on FLINK-14119: - Yes. We need to cleanup the idle state in {{onTimer()

[jira] [Updated] (FLINK-14119) Clean idle state for RetractableTopNFunction

[ https://issues.apache.org/jira/browse/FLINK-14119?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-14119: Affects Version/s: 1.9.0 > Clean idle state for RetractableTopNFunction >

[GitHub] [flink] docete commented on a change in pull request #8706: [FLINK-12814][sql-client] Support a traditional and scrolling view of…

docete commented on a change in pull request #8706: [FLINK-12814][sql-client] Support a traditional and scrolling view of… URL: https://github.com/apache/flink/pull/8706#discussion_r325963126 ## File path: flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/con

[GitHub] [flink] docete commented on a change in pull request #8706: [FLINK-12814][sql-client] Support a traditional and scrolling view of…

docete commented on a change in pull request #8706: [FLINK-12814][sql-client] Support a traditional and scrolling view of… URL: https://github.com/apache/flink/pull/8706#discussion_r325963191 ## File path: flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/gat

[jira] [Updated] (FLINK-13993) Using FlinkUserCodeClassLoaders to load the user class in the perjob mode

[ https://issues.apache.org/jira/browse/FLINK-13993?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma updated FLINK-13993: -- Remaining Estimate: 168h Original Estimate: 168h > Using FlinkUserCodeClassLoaders to load the us

[GitHub] [flink] flinkbot edited a comment on issue #9581: [FLINK-13864][streaming]: Modify the StreamingFileSink Builder interface to allow for easier subclassing of StreamingFileSink

flinkbot edited a comment on issue #9581: [FLINK-13864][streaming]: Modify the StreamingFileSink Builder interface to allow for easier subclassing of StreamingFileSink URL: https://github.com/apache/flink/pull/9581#issuecomment-526715445 ## CI report: * dc9cdc1364b9050c3d2f3cba

[jira] [Commented] (FLINK-14033) Distributed caches are not registered in Yarn Per Job Cluster Mode

[ https://issues.apache.org/jira/browse/FLINK-14033?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16932995#comment-16932995 ] Yang Wang commented on FLINK-14033: --- [~ZhenqiuHuang] Yeah, even many users are using -

[jira] [Commented] (FLINK-14093) Java8 lambdas and exceptions lead to compile error

[ https://issues.apache.org/jira/browse/FLINK-14093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16932996#comment-16932996 ] zzsmdfj commented on FLINK-14093: - [~Tison]  yes, you are right. I will start a discussi

[GitHub] [flink] flinkbot edited a comment on issue #9581: [FLINK-13864][streaming]: Modify the StreamingFileSink Builder interface to allow for easier subclassing of StreamingFileSink

flinkbot edited a comment on issue #9581: [FLINK-13864][streaming]: Modify the StreamingFileSink Builder interface to allow for easier subclassing of StreamingFileSink URL: https://github.com/apache/flink/pull/9581#issuecomment-526715445 ## CI report: * dc9cdc1364b9050c3d2f3cba

[jira] [Commented] (FLINK-14099) SQL supports timestamp in Long

[ https://issues.apache.org/jira/browse/FLINK-14099?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16933009#comment-16933009 ] Zijie Lu commented on FLINK-14099: -- I have tried what you mentioned, but it seems that

[jira] [Comment Edited] (FLINK-14099) SQL supports timestamp in Long

[ https://issues.apache.org/jira/browse/FLINK-14099?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16933009#comment-16933009 ] Zijie Lu edited comment on FLINK-14099 at 9/19/19 2:44 AM: --- I

[GitHub] [flink] AT-Fieldless closed pull request #9350: [FLINK-13485] [chinese-translation] Translate "Table API Example Walkthrough" page into Chinese

AT-Fieldless closed pull request #9350: [FLINK-13485] [chinese-translation] Translate "Table API Example Walkthrough" page into Chinese URL: https://github.com/apache/flink/pull/9350 This is an automated message from the Apa

[GitHub] [flink] AT-Fieldless commented on issue #9350: [FLINK-13485] [chinese-translation] Translate "Table API Example Walkthrough" page into Chinese

AT-Fieldless commented on issue #9350: [FLINK-13485] [chinese-translation] Translate "Table API Example Walkthrough" page into Chinese URL: https://github.com/apache/flink/pull/9350#issuecomment-532941960 > Hi @AT-Fieldless , do you have time to update this PR?

[GitHub] [flink] AT-Fieldless removed a comment on issue #9350: [FLINK-13485] [chinese-translation] Translate "Table API Example Walkthrough" page into Chinese

AT-Fieldless removed a comment on issue #9350: [FLINK-13485] [chinese-translation] Translate "Table API Example Walkthrough" page into Chinese URL: https://github.com/apache/flink/pull/9350#issuecomment-532941960 > Hi @AT-Fieldless , do you have time to update this PR? ---

[GitHub] [flink] AT-Fieldless commented on issue #9350: [FLINK-13485] [chinese-translation] Translate "Table API Example Walkthrough" page into Chinese

AT-Fieldless commented on issue #9350: [FLINK-13485] [chinese-translation] Translate "Table API Example Walkthrough" page into Chinese URL: https://github.com/apache/flink/pull/9350#issuecomment-532942135 > Hi @AT-Fieldless , do you have time to update this PR? Yes, I will create a n

[jira] [Commented] (FLINK-14112) Removing zookeeper state should cause the task manager and job managers to restart

[ https://issues.apache.org/jira/browse/FLINK-14112?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16933022#comment-16933022 ] TisonKun commented on FLINK-14112: -- I agree with [~trohrmann]'s comments. Another ques

[GitHub] [flink] HuangZhenQiu commented on issue #9689: [FLINK-7151] add a basic function ddl

HuangZhenQiu commented on issue #9689: [FLINK-7151] add a basic function ddl URL: https://github.com/apache/flink/pull/9689#issuecomment-532946316 @suez1224 @fhueske @danny0405 Would you please take a look the PR? This is an a

[jira] [Commented] (FLINK-14118) Reduce the unnecessary flushing when there is no data available for flush

[ https://issues.apache.org/jira/browse/FLINK-14118?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16933023#comment-16933023 ] Jark Wu commented on FLINK-14118: - Is it only affect to 1.9? Should we also fix this in

[jira] [Commented] (FLINK-14010) Dispatcher & JobManagers don't give up leadership when AM is shut down

[ https://issues.apache.org/jira/browse/FLINK-14010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16933030#comment-16933030 ] TisonKun commented on FLINK-14010: -- [~trohrmann] Technically I agree that it is a valid

[GitHub] [flink] KarmaGYZ commented on issue #9705: [hotfix][comment]remove useless comment

KarmaGYZ commented on issue #9705: [hotfix][comment]remove useless comment URL: https://github.com/apache/flink/pull/9705#issuecomment-532950384 Thanks for the hotfix, but IMO removed comment is not useless. -1 for this pr.

[GitHub] [flink] KurtYoung commented on issue #8468: [FLINK-12399][table][table-planner] Fix FilterableTableSource does not change after applyPredicate

KurtYoung commented on issue #8468: [FLINK-12399][table][table-planner] Fix FilterableTableSource does not change after applyPredicate URL: https://github.com/apache/flink/pull/8468#issuecomment-532953494 Never mind, it's me didn't explain my thought clear enough. ---

[GitHub] [flink] zzsmdfj commented on issue #9705: [hotfix][comment]remove useless comment

zzsmdfj commented on issue #9705: [hotfix][comment]remove useless comment URL: https://github.com/apache/flink/pull/9705#issuecomment-532953571 > Thanks for the hotfix, but IMO removed comment is not useless. > -1 for this pr. that comment is just meaning for "session windows UTTes

[GitHub] [flink] liupc commented on issue #9683: [FLINK-14037]Use same userCodeClassLoader as jobManager in jobClient to fix input/…

liupc commented on issue #9683: [FLINK-14037]Use same userCodeClassLoader as jobManager in jobClient to fix input/… URL: https://github.com/apache/flink/pull/9683#issuecomment-532955334 @TisonKun @aljoscha Thanks for reply, I will update as commented. --

[GitHub] [flink] flinkbot edited a comment on issue #9581: [FLINK-13864][streaming]: Modify the StreamingFileSink Builder interface to allow for easier subclassing of StreamingFileSink

flinkbot edited a comment on issue #9581: [FLINK-13864][streaming]: Modify the StreamingFileSink Builder interface to allow for easier subclassing of StreamingFileSink URL: https://github.com/apache/flink/pull/9581#issuecomment-526715445 ## CI report: * dc9cdc1364b9050c3d2f3cba

[GitHub] [flink] carp84 commented on a change in pull request #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend

carp84 commented on a change in pull request #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend URL: https://github.com/apache/flink/pull/9501#discussion_r325980641 ## File path: flink-state-backends/flink-statebackend-heap-spillable/src

[GitHub] [flink] xuyang1706 commented on a change in pull request #9184: [FLINK-13339][ml] Add an implementation of pipeline's api

xuyang1706 commented on a change in pull request #9184: [FLINK-13339][ml] Add an implementation of pipeline's api URL: https://github.com/apache/flink/pull/9184#discussion_r325981768 ## File path: flink-ml-parent/flink-ml-lib/src/main/java/org/apache/flink/ml/batchoperator/source/T

[GitHub] [flink] KarmaGYZ commented on a change in pull request #9679: [hotfix] Fix the comments related to side output.

KarmaGYZ commented on a change in pull request #9679: [hotfix] Fix the comments related to side output. URL: https://github.com/apache/flink/pull/9679#discussion_r325982247 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/OperatorChain.java

[GitHub] [flink] AT-Fieldless opened a new pull request #9350: [FLINK-13485] [chinese-translation] Translate "Table API Example Walkthrough" page into Chinese

AT-Fieldless opened a new pull request #9350: [FLINK-13485] [chinese-translation] Translate "Table API Example Walkthrough" page into Chinese URL: https://github.com/apache/flink/pull/9350 ## What is the purpose of the change Translate "Table API Example Walkthrough" page in

[GitHub] [flink] gaoyunhaii commented on a change in pull request #9679: [hotfix] Fix the comments related to side output.

gaoyunhaii commented on a change in pull request #9679: [hotfix] Fix the comments related to side output. URL: https://github.com/apache/flink/pull/9679#discussion_r325982849 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/OperatorChain.jav

[GitHub] [flink] flinkbot edited a comment on issue #9581: [FLINK-13864][streaming]: Modify the StreamingFileSink Builder interface to allow for easier subclassing of StreamingFileSink

flinkbot edited a comment on issue #9581: [FLINK-13864][streaming]: Modify the StreamingFileSink Builder interface to allow for easier subclassing of StreamingFileSink URL: https://github.com/apache/flink/pull/9581#issuecomment-526715445 ## CI report: * dc9cdc1364b9050c3d2f3cba

[GitHub] [flink] wsry opened a new pull request #9710: [FLINK-11859][runtime]Improve SpanningRecordSerializer performance by serializing record length to data buffer directly.

wsry opened a new pull request #9710: [FLINK-11859][runtime]Improve SpanningRecordSerializer performance by serializing record length to data buffer directly. URL: https://github.com/apache/flink/pull/9710 ## What is the purpose of the change The purpose of this pr is to improve the

[jira] [Updated] (FLINK-11859) Improve SpanningRecordSerializer performance by serializing record length to serialization buffer directly

[ https://issues.apache.org/jira/browse/FLINK-11859?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-11859: --- Labels: pull-request-available (was: ) > Improve SpanningRecordSerializer performance by se

[GitHub] [flink] flinkbot commented on issue #9710: [FLINK-11859][runtime]Improve SpanningRecordSerializer performance by serializing record length to data buffer directly.

flinkbot commented on issue #9710: [FLINK-11859][runtime]Improve SpanningRecordSerializer performance by serializing record length to data buffer directly. URL: https://github.com/apache/flink/pull/9710#issuecomment-532959252 Thanks a lot for your contribution to the Apache Flink project.

[jira] [Updated] (FLINK-11859) Improve SpanningRecordSerializer performance by serializing record length to serialization buffer directly

[ https://issues.apache.org/jira/browse/FLINK-11859?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yingjie Cao updated FLINK-11859: Fix Version/s: 1.10.0 > Improve SpanningRecordSerializer performance by serializing record length

[GitHub] [flink] flinkbot commented on issue #9710: [FLINK-11859][runtime]Improve SpanningRecordSerializer performance by serializing record length to data buffer directly.

flinkbot commented on issue #9710: [FLINK-11859][runtime]Improve SpanningRecordSerializer performance by serializing record length to data buffer directly. URL: https://github.com/apache/flink/pull/9710#issuecomment-532961713 ## CI report: * 9df06c32a009c53dce3f13c7de12892eb8563

[GitHub] [flink] carp84 commented on a change in pull request #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend

carp84 commented on a change in pull request #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend URL: https://github.com/apache/flink/pull/9501#discussion_r325986596 ## File path: flink-state-backends/flink-statebackend-heap-spillable/src

[GitHub] [flink] carp84 commented on a change in pull request #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend

carp84 commented on a change in pull request #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend URL: https://github.com/apache/flink/pull/9501#discussion_r325987134 ## File path: flink-state-backends/flink-statebackend-heap-spillable/src

[GitHub] [flink] flinkbot edited a comment on issue #9710: [FLINK-11859][runtime]Improve SpanningRecordSerializer performance by serializing record length to data buffer directly.

flinkbot edited a comment on issue #9710: [FLINK-11859][runtime]Improve SpanningRecordSerializer performance by serializing record length to data buffer directly. URL: https://github.com/apache/flink/pull/9710#issuecomment-532961713 ## CI report: * 9df06c32a009c53dce3f13c7de1289

[GitHub] [flink] flinkbot edited a comment on issue #9581: [FLINK-13864][streaming]: Modify the StreamingFileSink Builder interface to allow for easier subclassing of StreamingFileSink

flinkbot edited a comment on issue #9581: [FLINK-13864][streaming]: Modify the StreamingFileSink Builder interface to allow for easier subclassing of StreamingFileSink URL: https://github.com/apache/flink/pull/9581#issuecomment-526715445 ## CI report: * dc9cdc1364b9050c3d2f3cba

[GitHub] [flink] carp84 commented on a change in pull request #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend

carp84 commented on a change in pull request #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend URL: https://github.com/apache/flink/pull/9501#discussion_r325990356 ## File path: flink-state-backends/flink-statebackend-heap-spillable/src

[GitHub] [flink] HuangZhenQiu opened a new pull request #9711: [FLINK-14033] upload user artifacts for yarn job cluster

HuangZhenQiu opened a new pull request #9711: [FLINK-14033] upload user artifacts for yarn job cluster URL: https://github.com/apache/flink/pull/9711 ## What is the purpose of the change Upload user artifacts that registered in distributed caches for yarn job clusters. Currently, di

<    1   2   3   4   >