[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

[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 #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 #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] 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

[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

[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-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-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] [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] [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] [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] [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-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

[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-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

[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.

[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] [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

[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] [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

[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] [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 > --- > >

[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] [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-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

[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] [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 #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

[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 #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] 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] 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] 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

[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 > --

[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: ---

[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-11936) Remove AuxiliaryConverter pull-in from calcite and fix auxiliary converter issue.

[ https://issues.apache.org/jira/browse/FLINK-11936?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16932569#comment-16932569 ] Rong Rong commented on FLINK-11936: --- [~danny0405] yes. I think that would be great. >

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

walterddr 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-532740413 Thanks for the explanation @KurtYoung. NOW I think I understood what you meant. yeah

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

Johnlon 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-532739548 Hi @tillrohrmann did this make it onto master or a release? Thanks

[jira] [Comment Edited] (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=16932274#comment-16932274 ] Zijie Lu edited comment on FLINK-13746 at 9/18/19 3:23 PM: --- I

[GitHub] [flink] flinkbot edited a comment on issue #9707: [FLINK-14015][python] Introduces PythonScalarFunctionOperator to execute Python user-defined functions

flinkbot edited a comment on issue #9707: [FLINK-14015][python] Introduces PythonScalarFunctionOperator to execute Python user-defined functions URL: https://github.com/apache/flink/pull/9707#issuecomment-532703153 ## CI report: * 4709beb04e69d94956ce9a823553efd67fefb29a : SUCCES

[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

[GitHub] [flink] flinkbot edited a comment on issue #9663: [WIP][FLINK-12433][runtime] Implement DefaultScheduler stub

flinkbot edited a comment on issue #9663: [WIP][FLINK-12433][runtime] Implement DefaultScheduler stub URL: https://github.com/apache/flink/pull/9663#issuecomment-529930381 ## CI report: * 5bfec29d38218b1bd5236163a7f2dd2571afa8b2 : CANCELED [Build](https://travis-ci.com/flink-ci/

[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

[jira] [Closed] (FLINK-14014) Introduce PythonScalarFunctionRunner to handle the communication with Python worker for Python ScalarFunction execution

[ https://issues.apache.org/jira/browse/FLINK-14014?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-14014. --- Resolution: Resolved > Introduce PythonScalarFunctionRunner to handle the communication with Python

[jira] [Commented] (FLINK-14014) Introduce PythonScalarFunctionRunner to handle the communication with Python worker for Python ScalarFunction execution

[ https://issues.apache.org/jira/browse/FLINK-14014?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16932543#comment-16932543 ] Hequn Cheng commented on FLINK-14014: - Resolved in master: e7216eebc846a69272c21375a

[jira] [Closed] (FLINK-14017) Support to start up Python worker in process mode

[ https://issues.apache.org/jira/browse/FLINK-14017?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-14017. --- Resolution: Resolved > Support to start up Python worker in process mode > -

[jira] [Commented] (FLINK-14017) Support to start up Python worker in process mode

[ https://issues.apache.org/jira/browse/FLINK-14017?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16932539#comment-16932539 ] Hequn Cheng commented on FLINK-14017: - Resolved in master: f65ee55a53e50b7e09db55005

[GitHub] [flink] hequn8128 closed pull request #9655: [FLINK-14017][python] Support to start up Python worker in process mode.

hequn8128 closed pull request #9655: [FLINK-14017][python] Support to start up Python worker in process mode. URL: https://github.com/apache/flink/pull/9655 This is an automated message from the Apache Git Service. To respon

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

Till Rohrmann created FLINK-14120: - Summary: SystemProcessingTimeServiceTest.testImmediateShutdown failed on Travis Key: FLINK-14120 URL: https://issues.apache.org/jira/browse/FLINK-14120 Project: Fli

[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

[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=16932523#comment-16932523 ] ALEC CHEN commented on FLINK-14119: --- Correct me if I'm wrong. It seems like we need to

[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_r325712863 ## File path: flink-state-backends/flink-statebackend-heap-spillable/src

[GitHub] [flink] flinkbot edited a comment on issue #9707: [FLINK-14015][python] Introduces PythonScalarFunctionOperator to execute Python user-defined functions

flinkbot edited a comment on issue #9707: [FLINK-14015][python] Introduces PythonScalarFunctionOperator to execute Python user-defined functions URL: https://github.com/apache/flink/pull/9707#issuecomment-532703153 ## CI report: * 4709beb04e69d94956ce9a823553efd67fefb29a : PENDIN

[GitHub] [flink] flinkbot edited a comment on issue #9663: [WIP][FLINK-12433][runtime] Implement DefaultScheduler stub

flinkbot edited a comment on issue #9663: [WIP][FLINK-12433][runtime] Implement DefaultScheduler stub URL: https://github.com/apache/flink/pull/9663#issuecomment-529930381 ## CI report: * 5bfec29d38218b1bd5236163a7f2dd2571afa8b2 : CANCELED [Build](https://travis-ci.com/flink-ci/

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

TisonKun 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-532709246 For the PR itself, I second @aljoscha that it doesn't seem right we pass a lot of empty `Configuratio

[jira] [Commented] (FLINK-14113) Remove class JobWithJars

[ https://issues.apache.org/jira/browse/FLINK-14113?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16932491#comment-16932491 ] TisonKun commented on FLINK-14113: -- Thanks for your insights! I will create a pull requ

[GitHub] [flink] zhuzhurk commented on a change in pull request #9663: [WIP][FLINK-12433][runtime] Implement DefaultScheduler stub

zhuzhurk commented on a change in pull request #9663: [WIP][FLINK-12433][runtime] Implement DefaultScheduler stub URL: https://github.com/apache/flink/pull/9663#discussion_r325636828 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/Execution.java #

[GitHub] [flink] zhuzhurk commented on a change in pull request #9663: [WIP][FLINK-12433][runtime] Implement DefaultScheduler stub

zhuzhurk commented on a change in pull request #9663: [WIP][FLINK-12433][runtime] Implement DefaultScheduler stub URL: https://github.com/apache/flink/pull/9663#discussion_r325634779 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/Execution.java #

[GitHub] [flink] zhuzhurk commented on a change in pull request #9663: [WIP][FLINK-12433][runtime] Implement DefaultScheduler stub

zhuzhurk commented on a change in pull request #9663: [WIP][FLINK-12433][runtime] Implement DefaultScheduler stub URL: https://github.com/apache/flink/pull/9663#discussion_r325660299 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/Execution.java #

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

TisonKun 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-532703934 Thanks for reminding me @aljoscha. For the conflict part I notice that it is only related with `JobWi

[GitHub] [flink] flinkbot commented on issue #9707: [FLINK-14015][python] Introduces PythonScalarFunctionOperator to execute Python user-defined functions

flinkbot commented on issue #9707: [FLINK-14015][python] Introduces PythonScalarFunctionOperator to execute Python user-defined functions URL: https://github.com/apache/flink/pull/9707#issuecomment-532703153 ## CI report: * 4709beb04e69d94956ce9a823553efd67fefb29a : UNKNOWN

[GitHub] [flink] flinkbot edited a comment on issue #9663: [WIP][FLINK-12433][runtime] Implement DefaultScheduler stub

flinkbot edited a comment on issue #9663: [WIP][FLINK-12433][runtime] Implement DefaultScheduler stub URL: https://github.com/apache/flink/pull/9663#issuecomment-529930381 ## CI report: * 5bfec29d38218b1bd5236163a7f2dd2571afa8b2 : CANCELED [Build](https://travis-ci.com/flink-ci/

[GitHub] [flink] GJL commented on a change in pull request #9663: [WIP][FLINK-12433][runtime] Implement DefaultScheduler stub

GJL commented on a change in pull request #9663: [WIP][FLINK-12433][runtime] Implement DefaultScheduler stub URL: https://github.com/apache/flink/pull/9663#discussion_r325688666 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionGraph.java #

[GitHub] [flink] flinkbot commented on issue #9707: [FLINK-14015][python] Introduces PythonScalarFunctionOperator to execute Python user-defined functions

flinkbot commented on issue #9707: [FLINK-14015][python] Introduces PythonScalarFunctionOperator to execute Python user-defined functions URL: https://github.com/apache/flink/pull/9707#issuecomment-532694486 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot.

[jira] [Updated] (FLINK-14015) Introduce PythonScalarFunctionOperator as a standalone StreamOperator for Python ScalarFunction execution

[ https://issues.apache.org/jira/browse/FLINK-14015?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14015: --- Labels: pull-request-available (was: ) > Introduce PythonScalarFunctionOperator as a standa

[GitHub] [flink] dianfu opened a new pull request #9707: [FLINK-14015][python] Introduces PythonScalarFunctionOperator to execute Python user-defined functions

dianfu opened a new pull request #9707: [FLINK-14015][python] Introduces PythonScalarFunctionOperator to execute Python user-defined functions URL: https://github.com/apache/flink/pull/9707 ## What is the purpose of the change *This pull request introduces PythonScalarFunctionOpe

[GitHub] [flink] GJL commented on a change in pull request #9663: [WIP][FLINK-12433][runtime] Implement DefaultScheduler stub

GJL commented on a change in pull request #9663: [WIP][FLINK-12433][runtime] Implement DefaultScheduler stub URL: https://github.com/apache/flink/pull/9663#discussion_r325686297 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/DefaultScheduler.java

[GitHub] [flink] GJL commented on a change in pull request #9663: [WIP][FLINK-12433][runtime] Implement DefaultScheduler stub

GJL commented on a change in pull request #9663: [WIP][FLINK-12433][runtime] Implement DefaultScheduler stub URL: https://github.com/apache/flink/pull/9663#discussion_r325686040 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/DefaultScheduler.java

[GitHub] [flink] GJL commented on a change in pull request #9663: [WIP][FLINK-12433][runtime] Implement DefaultScheduler stub

GJL commented on a change in pull request #9663: [WIP][FLINK-12433][runtime] Implement DefaultScheduler stub URL: https://github.com/apache/flink/pull/9663#discussion_r325685891 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/DefaultScheduler.java

[jira] [Commented] (FLINK-14037) Deserializing the input/output formats failed: unread block data

[ https://issues.apache.org/jira/browse/FLINK-14037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16932461#comment-16932461 ] Aljoscha Krettek commented on FLINK-14037: -- I commented on the PR. > Deseriali

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

aljoscha 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-532688047 @TisonKun could you maybe have a look at this PR. I think this will clash with https://issues.apache.

[jira] [Commented] (FLINK-14113) Remove class JobWithJars

[ https://issues.apache.org/jira/browse/FLINK-14113?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16932453#comment-16932453 ] Aljoscha Krettek commented on FLINK-14113: -- I think this is a good refactoring,

[GitHub] [flink] flinkbot edited a comment on issue #9655: [FLINK-14017][python] Support to start up Python worker in process mode.

flinkbot edited a comment on issue #9655: [FLINK-14017][python] Support to start up Python worker in process mode. URL: https://github.com/apache/flink/pull/9655#issuecomment-529754597 ## CI report: * e02c8a291f5c82505750e200dda9b07d5e8b2fca : FAILURE [Build](https://travis-ci.c

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

Jark Wu created FLINK-14119: --- Summary: Clean idle state for RetractableTopNFunction Key: FLINK-14119 URL: https://issues.apache.org/jira/browse/FLINK-14119 Project: Flink Issue Type: Bug

[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=16932437#comment-16932437 ] Jark Wu commented on FLINK-14073: - According to the error message, it might be an occasi

[jira] [Commented] (FLINK-12692) Support disk spilling in HeapKeyedStateBackend

[ https://issues.apache.org/jira/browse/FLINK-12692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16932432#comment-16932432 ] Jiayi Liao commented on FLINK-12692: [~carp84] Any update on release version of this

[jira] [Updated] (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:all-tabpanel ] Jark Wu updated FLINK-14118: Fix Version/s: 1.9.1 > Reduce the unnecessary flushing when there is no data available for flush > ---

[jira] [Assigned] (FLINK-13682) Translate "Code Style - Scala Guide" page into Chinese

[ https://issues.apache.org/jira/browse/FLINK-13682?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-13682: --- Assignee: Jeff Yang > Translate "Code Style - Scala Guide" page into Chinese >

[jira] [Updated] (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:all-tabpanel ] Jark Wu updated FLINK-14118: Priority: Critical (was: Major) > Reduce the unnecessary flushing when there is no data available for flu

[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=16932426#comment-16932426 ] Alexander Kasyanenko commented on FLINK-14074: -- Hi [~till.rohrmann], I'm so

[jira] [Commented] (FLINK-13520) Add documentation for the different behavior of row count sliding window in blink planner

[ https://issues.apache.org/jira/browse/FLINK-13520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16932425#comment-16932425 ] Jark Wu commented on FLINK-13520: - Sure. But do you fully understand this issue? i.e. wh

[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=16932423#comment-16932423 ] TisonKun commented on FLINK-14010: -- I have thought of this. The problem is that when th

[jira] [Comment Edited] (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=16932423#comment-16932423 ] TisonKun edited comment on FLINK-14010 at 9/18/19 1:06 PM: --- I

[jira] [Updated] (FLINK-13656) Upgrade Calcite dependency to 1.21

[ https://issues.apache.org/jira/browse/FLINK-13656?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-13656: Description: Umbrella issue for all tasks related to the next Calcite upgrade to 1.21.x release Calcite

[jira] [Commented] (FLINK-14092) Upgrade Calcite version to 1.21 for Flink SQL

[ https://issues.apache.org/jira/browse/FLINK-14092?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16932410#comment-16932410 ] Jark Wu commented on FLINK-14092: - I have ported the description of this issue to FLINK-

[jira] [Updated] (FLINK-13656) Upgrade Calcite dependency to 1.21

[ https://issues.apache.org/jira/browse/FLINK-13656?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-13656: Description: Umbrella issue for all tasks related to the next Calcite upgrade to 1.21.x release Calcite

[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=16932407#comment-16932407 ] Jark Wu commented on FLINK-14099: - [~alfredlu] Btw, for your problem, maybe you can try

[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=16932402#comment-16932402 ] Jark Wu commented on FLINK-14099: - I agree with [~felixzheng]. I think computed column i

[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=16932396#comment-16932396 ] Till Rohrmann commented on FLINK-14010: --- Couldn't we simply use {{ResourceManager#

[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=16932394#comment-16932394 ] Till Rohrmann commented on FLINK-14109: --- Hi [~bremac], thanks for reporting this p

[jira] [Assigned] (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 ] Till Rohrmann reassigned FLINK-14109: - Assignee: Brendan MacDonell > Improve javadocs and tests for high-availability backend

[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=16932393#comment-16932393 ] Till Rohrmann commented on FLINK-14112: --- Yes, as [~Tison] says, the assumption is

[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_r325650441 ## File path: flink-state-backends/flink-statebackend-heap-spillable/src

[GitHub] [flink] flinkbot edited a comment on issue #9655: [FLINK-14017][python] Support to start up Python worker in process mode.

flinkbot edited a comment on issue #9655: [FLINK-14017][python] Support to start up Python worker in process mode. URL: https://github.com/apache/flink/pull/9655#issuecomment-529754597 ## CI report: * e02c8a291f5c82505750e200dda9b07d5e8b2fca : FAILURE [Build](https://travis-ci.c

[jira] [Commented] (FLINK-13682) Translate "Code Style - Scala Guide" page into Chinese

[ https://issues.apache.org/jira/browse/FLINK-13682?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16932388#comment-16932388 ] Jeff Yang commented on FLINK-13682: --- Hi,[~jark] sure , I have time to do this. Please

[jira] [Commented] (FLINK-12122) Spread out tasks evenly across all available registered TaskManagers

[ https://issues.apache.org/jira/browse/FLINK-12122?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16932389#comment-16932389 ] Till Rohrmann commented on FLINK-12122: --- Yes, this is something we should have fix

<    1   2   3   4   >