[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

[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

[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

[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

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

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

[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

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

[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=16932569#comment-16932569 ] Rong Rong commented on FLINK-11936: --- [~danny0405] yes. I think that would be great. > Remove

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

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

[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

[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

[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

[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=16932543#comment-16932543 ] Hequn Cheng commented on FLINK-14014: - Resolved in master: e7216eebc846a69272c21375af0f4db8009c2e3e

[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=16932539#comment-16932539 ] Hequn Cheng commented on FLINK-14017: - Resolved in master: f65ee55a53e50b7e09db5500565ee4884670b7d2

[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

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

[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

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

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

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

[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

[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

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

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

[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

[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

[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

[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

[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

[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=16932461#comment-16932461 ] Aljoscha Krettek commented on FLINK-14037: -- I commented on the PR. > Deserializing the

[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

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

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

[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

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

[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=16932432#comment-16932432 ] Jiayi Liao commented on FLINK-12692: [~carp84] Any update on release version of this issue? >

[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

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

[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=16932425#comment-16932425 ] Jark Wu commented on FLINK-13520: - Sure. But do you fully understand this issue? i.e. what's the

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

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

[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=16932410#comment-16932410 ] Jark Wu commented on FLINK-14092: - I have ported the description of this issue to FLINK-13656. >

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

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

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

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

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

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

[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

[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=16932388#comment-16932388 ] Jeff Yang commented on FLINK-13682: --- Hi,[~jark] sure , I have time to do this. Please assign this

[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=16932389#comment-16932389 ] Till Rohrmann commented on FLINK-12122: --- Yes, this is something we should have fixed much faster.

[jira] [Resolved] (FLINK-13965) Keep hasDeprecatedKeys and deprecatedKeys methods in ConfigOption and mark it with @Deprecated annotation

[ https://issues.apache.org/jira/browse/FLINK-13965?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-13965. --- Resolution: Done Done via 1.10.0: 64b656b705864ed88d8ca0c4794f4a9bba7faabb 1.9.1:

[jira] [Commented] (FLINK-14078) Introduce more JDBCDialect implementations

[ https://issues.apache.org/jira/browse/FLINK-14078?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16932383#comment-16932383 ] Jark Wu commented on FLINK-14078: - +1 to do this. > Introduce more JDBCDialect implementations >

[jira] [Commented] (FLINK-14098) Support multiple sql statements splitting by semicolon for TableEnvironment

[ https://issues.apache.org/jira/browse/FLINK-14098?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16932381#comment-16932381 ] Jark Wu commented on FLINK-14098: - I don't think this is a duplicate ticket to FLINK-12845. This one 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_r325646539 ## File path:

[GitHub] [flink] tillrohrmann closed pull request #9691: [FLINK-13965] Keep hasDeprecatedKeys and deprecatedKeys methods in ConfigOption and mark it with @Deprecated annotation

tillrohrmann closed pull request #9691: [FLINK-13965] Keep hasDeprecatedKeys and deprecatedKeys methods in ConfigOption and mark it with @Deprecated annotation URL: https://github.com/apache/flink/pull/9691 This is an

[jira] [Commented] (FLINK-13975) Translate "Upcoming Events" on Chinese index.html

[ https://issues.apache.org/jira/browse/FLINK-13975?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16932378#comment-16932378 ] Jark Wu commented on FLINK-13975: - Hi [~alfredlu], I assigned this to you. > Translate "Upcoming

[jira] [Assigned] (FLINK-13975) Translate "Upcoming Events" on Chinese index.html

[ https://issues.apache.org/jira/browse/FLINK-13975?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-13975: --- Assignee: Zijie Lu > Translate "Upcoming Events" on Chinese index.html >

[GitHub] [flink] flinkbot edited a comment on issue #9706: [FLINK-14118][runtime]Reduce the unnecessary flushing when there is no data available for flush.

flinkbot edited a comment on issue #9706: [FLINK-14118][runtime]Reduce the unnecessary flushing when there is no data available for flush. URL: https://github.com/apache/flink/pull/9706#issuecomment-532638785 ## CI report: * 053ed30d568a00ba42d75d1a9534843c59a068af : SUCCESS

[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=16932377#comment-16932377 ] Jark Wu commented on FLINK-13682: - Hi [~highfei2...@126.com], do you still have time to do this? Hi

[jira] [Commented] (FLINK-13900) Add a built-in "console" sink to print results in console

[ https://issues.apache.org/jira/browse/FLINK-13900?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16932373#comment-16932373 ] Jark Wu commented on FLINK-13900: - I think it's nice to have a configuration to control the print speed.

[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

[GitHub] [flink] hequn8128 commented on issue #9655: [FLINK-14017][python] Support to start up Python worker in process mode.

hequn8128 commented on issue #9655: [FLINK-14017][python] Support to start up Python worker in process mode. URL: https://github.com/apache/flink/pull/9655#issuecomment-532654905 @WeiZhong94 Thanks a lot for the update. LGTM. merging...

[GitHub] [flink] asfgit closed pull request #9653: [FLINK-14014][python] Introduce PythonScalarFunctionRunner to handle the communication with Python worker for Python ScalarFunction execution

asfgit closed pull request #9653: [FLINK-14014][python] Introduce PythonScalarFunctionRunner to handle the communication with Python worker for Python ScalarFunction execution URL: https://github.com/apache/flink/pull/9653

[GitHub] [flink] flinkbot edited a comment on issue #9705: [hotfix][comment]remove useless comment

flinkbot edited a comment on issue #9705: [hotfix][comment]remove useless comment URL: https://github.com/apache/flink/pull/9705#issuecomment-532617191 ## CI report: * c915efcec6323de5a998b058edf5ea7422e64e4b : SUCCESS

[GitHub] [flink] flinkbot edited a comment on issue #9706: [FLINK-14118][runtime]Reduce the unnecessary flushing when there is no data available for flush.

flinkbot edited a comment on issue #9706: [FLINK-14118][runtime]Reduce the unnecessary flushing when there is no data available for flush. URL: https://github.com/apache/flink/pull/9706#issuecomment-532638785 ## CI report: * 053ed30d568a00ba42d75d1a9534843c59a068af : PENDING

[GitHub] [flink] flinkbot commented on issue #9706: [FLINK-14118][runtime]Reduce the unnecessary flushing when there is no data available for flush.

flinkbot commented on issue #9706: [FLINK-14118][runtime]Reduce the unnecessary flushing when there is no data available for flush. URL: https://github.com/apache/flink/pull/9706#issuecomment-532638785 ## CI report: * 053ed30d568a00ba42d75d1a9534843c59a068af : UNKNOWN

[GitHub] [flink] flinkbot edited a comment on issue #9691: [FLINK-13965] Keep hasDeprecatedKeys and deprecatedKeys methods in ConfigOption and mark it with @Deprecated annotation

flinkbot edited a comment on issue #9691: [FLINK-13965] Keep hasDeprecatedKeys and deprecatedKeys methods in ConfigOption and mark it with @Deprecated annotation URL: https://github.com/apache/flink/pull/9691#issuecomment-531758345 ## CI report: *

[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

[jira] [Commented] (FLINK-14066) Pyflink building failure in master and 1.9.0 version

[ https://issues.apache.org/jira/browse/FLINK-14066?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16932312#comment-16932312 ] Hequn Cheng commented on FLINK-14066: - [~coldmoon777] Hi, thanks for reporting the problem! The

[GitHub] [flink] flinkbot commented on issue #9706: [FLINK-14118][runtime]Reduce the unnecessary flushing when there is no data available for flush.

flinkbot commented on issue #9706: [FLINK-14118][runtime]Reduce the unnecessary flushing when there is no data available for flush. URL: https://github.com/apache/flink/pull/9706#issuecomment-532633944 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I

[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 ] ASF GitHub Bot updated FLINK-14118: --- Labels: pull-request-available (was: ) > Reduce the unnecessary flushing when there is no

[jira] [Updated] (FLINK-7289) Memory allocation of RocksDB can be problematic in container environments

[ https://issues.apache.org/jira/browse/FLINK-7289?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Li updated FLINK-7289: - Fix Version/s: 1.10.0 > Memory allocation of RocksDB can be problematic in container environments >

[GitHub] [flink] wsry opened a new pull request #9706: [FLINK-14118][runtime]Reduce the unnecessary flushing when there is no data available for flush.

wsry opened a new pull request #9706: [FLINK-14118][runtime]Reduce the unnecessary flushing when there is no data available for flush. URL: https://github.com/apache/flink/pull/9706 ## What is the purpose of the change The purpose of this pr is to reduce unnecessary flushing when there

[jira] [Commented] (FLINK-13808) Checkpoints expired by timeout may leak RocksDB files

[ https://issues.apache.org/jira/browse/FLINK-13808?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16932283#comment-16932283 ] Julius Michaelis commented on FLINK-13808: -- Hm, Is it possible that checkpoints also spawn

[GitHub] [flink] flinkbot edited a comment on issue #9705: [hotfix][comment]remove useless comment

flinkbot edited a comment on issue #9705: [hotfix][comment]remove useless comment URL: https://github.com/apache/flink/pull/9705#issuecomment-532617191 ## CI report: * c915efcec6323de5a998b058edf5ea7422e64e4b : PENDING

[GitHub] [flink] flinkbot edited a comment on issue #9691: [FLINK-13965] Keep hasDeprecatedKeys and deprecatedKeys methods in ConfigOption and mark it with @Deprecated annotation

flinkbot edited a comment on issue #9691: [FLINK-13965] Keep hasDeprecatedKeys and deprecatedKeys methods in ConfigOption and mark it with @Deprecated annotation URL: https://github.com/apache/flink/pull/9691#issuecomment-531758345 ## CI report: *

[GitHub] [flink] flinkbot edited a comment on issue #9653: [FLINK-14014][python] Introduce PythonScalarFunctionRunner to handle the communication with Python worker for Python ScalarFunction execution

flinkbot edited a comment on issue #9653: [FLINK-14014][python] Introduce PythonScalarFunctionRunner to handle the communication with Python worker for Python ScalarFunction execution URL: https://github.com/apache/flink/pull/9653#issuecomment-529525552 ## CI report: *

[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

<    1   2   3   4   >