[GitHub] [flink] flinkbot edited a comment on issue #10232: [FLINK-14314][runtime] Allocate shared slot resources respecting the resources of all vertices in the group

flinkbot edited a comment on issue #10232: [FLINK-14314][runtime] Allocate shared slot resources respecting the resources of all vertices in the group URL: https://github.com/apache/flink/pull/10232#issuecomment-554775330 ## CI report: * b62006e7cf875fa318b3ce57afb14b0b2679bcb5 :

[GitHub] [flink] flinkbot edited a comment on issue #10200: [FLINK-14062][runtime] Calculate managed memory fraction based on slot sharing groups

flinkbot edited a comment on issue #10200: [FLINK-14062][runtime] Calculate managed memory fraction based on slot sharing groups URL: https://github.com/apache/flink/pull/10200#issuecomment-553966392 ## CI report: * e4e45953ce0e5f3a20040e7bdf0016f90a0ea76e : SUCCESS [Build](http

[GitHub] [flink] TisonKun commented on a change in pull request #10251: [FLINK-14851][FLINK-14850] Implement Executors and wire them to the ContextEnvironment

TisonKun commented on a change in pull request #10251: [FLINK-14851][FLINK-14850] Implement Executors and wire them to the ContextEnvironment URL: https://github.com/apache/flink/pull/10251#discussion_r348933979 ## File path: flink-clients/src/main/java/org/apache/flink/client/dep

[GitHub] [flink] TisonKun commented on a change in pull request #10251: [FLINK-14851][FLINK-14850] Implement Executors and wire them to the ContextEnvironment

TisonKun commented on a change in pull request #10251: [FLINK-14851][FLINK-14850] Implement Executors and wire them to the ContextEnvironment URL: https://github.com/apache/flink/pull/10251#discussion_r348933979 ## File path: flink-clients/src/main/java/org/apache/flink/client/dep

[GitHub] [flink] TisonKun commented on a change in pull request #10251: [FLINK-14851][FLINK-14850] Implement Executors and wire them to the ContextEnvironment

TisonKun commented on a change in pull request #10251: [FLINK-14851][FLINK-14850] Implement Executors and wire them to the ContextEnvironment URL: https://github.com/apache/flink/pull/10251#discussion_r348933298 ## File path: flink-clients/src/main/java/org/apache/flink/client/dep

[GitHub] [flink] guoweiM commented on a change in pull request #10256: [FLINK-14467][runtime] Let MesosJobClusterEntrypoint use user code class loader

guoweiM commented on a change in pull request #10256: [FLINK-14467][runtime] Let MesosJobClusterEntrypoint use user code class loader URL: https://github.com/apache/flink/pull/10256#discussion_r348932460 ## File path: docs/ops/deployment/mesos.zh.md ## @@ -177,16 +177,16 @

[GitHub] [flink] KurtYoung commented on a change in pull request #10271: [FLINK-14874] [table-planner-blink] add local aggregate to solve data skew for ROLLUP/CUBE case

KurtYoung commented on a change in pull request #10271: [FLINK-14874] [table-planner-blink] add local aggregate to solve data skew for ROLLUP/CUBE case URL: https://github.com/apache/flink/pull/10271#discussion_r348932219 ## File path: flink-table/flink-table-planner-blink/src/mai

[GitHub] [flink] guoweiM commented on a change in pull request #10256: [FLINK-14467][runtime] Let MesosJobClusterEntrypoint use user code class loader

guoweiM commented on a change in pull request #10256: [FLINK-14467][runtime] Let MesosJobClusterEntrypoint use user code class loader URL: https://github.com/apache/flink/pull/10256#discussion_r348932328 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/clusterfram

[GitHub] [flink] guoweiM commented on a change in pull request #10256: [FLINK-14467][runtime] Let MesosJobClusterEntrypoint use user code class loader

guoweiM commented on a change in pull request #10256: [FLINK-14467][runtime] Let MesosJobClusterEntrypoint use user code class loader URL: https://github.com/apache/flink/pull/10256#discussion_r348932262 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/clusterfram

[GitHub] [flink] guoweiM commented on a change in pull request #10256: [FLINK-14467][runtime] Let MesosJobClusterEntrypoint use user code class loader

guoweiM commented on a change in pull request #10256: [FLINK-14467][runtime] Let MesosJobClusterEntrypoint use user code class loader URL: https://github.com/apache/flink/pull/10256#discussion_r348931566 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/clusterfram

[GitHub] [flink] flinkbot edited a comment on issue #10275: [FLINK-14733][runtime] Introduce a builder for flexible ResourceProfile building

flinkbot edited a comment on issue #10275: [FLINK-14733][runtime] Introduce a builder for flexible ResourceProfile building URL: https://github.com/apache/flink/pull/10275#issuecomment-556931854 ## CI report: * f6c984aee2adafa83829762496ad13b75e8e : SUCCESS [Build](https://t

[GitHub] [flink] flinkbot edited a comment on issue #7197: [FLINK-12909][flink-runtime][network] continue trying to find a suitable spilling channel even in case of exceptions

flinkbot edited a comment on issue #7197: [FLINK-12909][flink-runtime][network] continue trying to find a suitable spilling channel even in case of exceptions URL: https://github.com/apache/flink/pull/7197#issuecomment-556931640 ## CI report: * 2d14be4d9a87d1f0fb958a672cb3ec6bdaf

[jira] [Commented] (FLINK-14872) Potential deadlock for task reading from blocking ResultPartition.

[ https://issues.apache.org/jira/browse/FLINK-14872?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16979037#comment-16979037 ] Yingjie Cao commented on FLINK-14872: - Only limit the number of Buffers can be alloc

[GitHub] [flink] flinkbot edited a comment on issue #10264: [FLINK-14811][runtime] Replace Java Streams in input check methods with for-loops

flinkbot edited a comment on issue #10264: [FLINK-14811][runtime] Replace Java Streams in input check methods with for-loops URL: https://github.com/apache/flink/pull/10264#issuecomment-555926846 ## CI report: * aa7f5b430b1e6ecf017b0bae97dc41f4549ba488 : CANCELED [Build](https:/

[jira] [Comment Edited] (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:comment-tabpanel&focusedCommentId=16979029#comment-16979029 ] Yu Li edited comment on FLINK-7289 at 11/21/19 6:58 AM: Here is a

[jira] [Commented] (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:comment-tabpanel&focusedCommentId=16979029#comment-16979029 ] Yu Li commented on FLINK-7289: -- Here is a quick update on progress of the work: Overall we

[GitHub] [flink] flinkbot edited a comment on issue #10274: [FLINK-14873][client] Make PackagedProgram#savepointSettings final

flinkbot edited a comment on issue #10274: [FLINK-14873][client] Make PackagedProgram#savepointSettings final URL: https://github.com/apache/flink/pull/10274#issuecomment-556864266 ## CI report: * 3764315269f0aa0522945d85364994a219b8d599 : FAILURE [Build](https://travis-ci.com/f

[GitHub] [flink] flinkbot edited a comment on issue #10232: [FLINK-14314][runtime] Allocate shared slot resources respecting the resources of all vertices in the group

flinkbot edited a comment on issue #10232: [FLINK-14314][runtime] Allocate shared slot resources respecting the resources of all vertices in the group URL: https://github.com/apache/flink/pull/10232#issuecomment-554775330 ## CI report: * b62006e7cf875fa318b3ce57afb14b0b2679bcb5 :

[GitHub] [flink] flinkbot edited a comment on issue #10200: [FLINK-14062][runtime] Calculate managed memory fraction based on slot sharing groups

flinkbot edited a comment on issue #10200: [FLINK-14062][runtime] Calculate managed memory fraction based on slot sharing groups URL: https://github.com/apache/flink/pull/10200#issuecomment-553966392 ## CI report: * e4e45953ce0e5f3a20040e7bdf0016f90a0ea76e : SUCCESS [Build](http

[GitHub] [flink] QiLuo-BD commented on a change in pull request #9864: [FLINK-14254][table] Introduce FileSystemOutputFormat for batch

QiLuo-BD commented on a change in pull request #9864: [FLINK-14254][table] Introduce FileSystemOutputFormat for batch URL: https://github.com/apache/flink/pull/9864#discussion_r348913374 ## File path: flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/filesy

[GitHub] [flink] flinkbot edited a comment on issue #10274: [FLINK-14873][client] Make PackagedProgram#savepointSettings final

flinkbot edited a comment on issue #10274: [FLINK-14873][client] Make PackagedProgram#savepointSettings final URL: https://github.com/apache/flink/pull/10274#issuecomment-556864266 ## CI report: * 3764315269f0aa0522945d85364994a219b8d599 : FAILURE [Build](https://travis-ci.com/f

[GitHub] [flink] flinkbot edited a comment on issue #10275: [FLINK-14733][runtime] Introduce a builder for flexible ResourceProfile building

flinkbot edited a comment on issue #10275: [FLINK-14733][runtime] Introduce a builder for flexible ResourceProfile building URL: https://github.com/apache/flink/pull/10275#issuecomment-556931854 ## CI report: * f6c984aee2adafa83829762496ad13b75e8e : PENDING [Build](https://t

[GitHub] [flink] flinkbot edited a comment on issue #7197: [FLINK-12909][flink-runtime][network] continue trying to find a suitable spilling channel even in case of exceptions

flinkbot edited a comment on issue #7197: [FLINK-12909][flink-runtime][network] continue trying to find a suitable spilling channel even in case of exceptions URL: https://github.com/apache/flink/pull/7197#issuecomment-556931640 ## CI report: * 2d14be4d9a87d1f0fb958a672cb3ec6bdaf

[jira] [Updated] (FLINK-14872) Potential deadlock for task reading from blocking ResultPartition.

[ https://issues.apache.org/jira/browse/FLINK-14872?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yingjie Cao updated FLINK-14872: Fix Version/s: 1.10.0 > Potential deadlock for task reading from blocking ResultPartition. > -

[GitHub] [flink] flinkbot edited a comment on issue #10264: [FLINK-14811][runtime] Replace Java Streams in input check methods with for-loops

flinkbot edited a comment on issue #10264: [FLINK-14811][runtime] Replace Java Streams in input check methods with for-loops URL: https://github.com/apache/flink/pull/10264#issuecomment-555926846 ## CI report: * aa7f5b430b1e6ecf017b0bae97dc41f4549ba488 : CANCELED [Build](https:/

[jira] [Commented] (FLINK-14845) Introduce data compression to blocking shuffle.

[ https://issues.apache.org/jira/browse/FLINK-14845?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16979002#comment-16979002 ] Yingjie Cao commented on FLINK-14845: - [~pnowojski] , thanks for proposing these opt

[GitHub] [flink] flinkbot edited a comment on issue #10232: [FLINK-14314][runtime] Allocate shared slot resources respecting the resources of all vertices in the group

flinkbot edited a comment on issue #10232: [FLINK-14314][runtime] Allocate shared slot resources respecting the resources of all vertices in the group URL: https://github.com/apache/flink/pull/10232#issuecomment-554775330 ## CI report: * b62006e7cf875fa318b3ce57afb14b0b2679bcb5 :

[GitHub] [flink] flinkbot edited a comment on issue #10200: [FLINK-14062][runtime] Calculate managed memory fraction based on slot sharing groups

flinkbot edited a comment on issue #10200: [FLINK-14062][runtime] Calculate managed memory fraction based on slot sharing groups URL: https://github.com/apache/flink/pull/10200#issuecomment-553966392 ## CI report: * e4e45953ce0e5f3a20040e7bdf0016f90a0ea76e : SUCCESS [Build](http

[GitHub] [flink] flinkbot commented on issue #10275: [FLINK-14733][runtime] Introduce a builder for flexible ResourceProfile building

flinkbot commented on issue #10275: [FLINK-14733][runtime] Introduce a builder for flexible ResourceProfile building URL: https://github.com/apache/flink/pull/10275#issuecomment-556931854 ## CI report: * f6c984aee2adafa83829762496ad13b75e8e : UNKNOWN Bot commands

[GitHub] [flink] flinkbot commented on issue #7197: [FLINK-12909][flink-runtime][network] continue trying to find a suitable spilling channel even in case of exceptions

flinkbot commented on issue #7197: [FLINK-12909][flink-runtime][network] continue trying to find a suitable spilling channel even in case of exceptions URL: https://github.com/apache/flink/pull/7197#issuecomment-556931640 ## CI report: * 2d14be4d9a87d1f0fb958a672cb3ec6bdafda0d2 :

[GitHub] [flink] dianfu commented on issue #10273: [FLINK-14866][doc] fix a few broken doc links

dianfu commented on issue #10273: [FLINK-14866][doc] fix a few broken doc links URL: https://github.com/apache/flink/pull/10273#issuecomment-556931519 @bowenli86 Thanks for the quick fix. LGTM. This is an automated message fro

[GitHub] [flink] flinkbot edited a comment on issue #10264: [FLINK-14811][runtime] Replace Java Streams in input check methods with for-loops

flinkbot edited a comment on issue #10264: [FLINK-14811][runtime] Replace Java Streams in input check methods with for-loops URL: https://github.com/apache/flink/pull/10264#issuecomment-555926846 ## CI report: * aa7f5b430b1e6ecf017b0bae97dc41f4549ba488 : CANCELED [Build](https:/

[jira] [Closed] (FLINK-9761) Potential buffer leak in PartitionRequestClientHandler during job failures

[ https://issues.apache.org/jira/browse/FLINK-9761?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhijiang closed FLINK-9761. --- Resolution: Won't Fix It was out of date. PartitionRequestClientHandler would not be used by default and be

[GitHub] [flink] flinkbot commented on issue #10275: [FLINK-14733][runtime] Introduce a builder for flexible ResourceProfile building

flinkbot commented on issue #10275: [FLINK-14733][runtime] Introduce a builder for flexible ResourceProfile building URL: https://github.com/apache/flink/pull/10275#issuecomment-556928407 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the communit

[GitHub] [flink] zhijiangW commented on issue #7197: [FLINK-12909][flink-runtime][network] continue trying to find a suitable spilling channel even in case of exceptions

zhijiangW commented on issue #7197: [FLINK-12909][flink-runtime][network] continue trying to find a suitable spilling channel even in case of exceptions URL: https://github.com/apache/flink/pull/7197#issuecomment-556928301 @maqingxiang are you still available for updating this PR to address

[jira] [Updated] (FLINK-14733) Introduce ResourceProfile builder to enable flexible building

[ https://issues.apache.org/jira/browse/FLINK-14733?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14733: --- Labels: pull-request-available (was: ) > Introduce ResourceProfile builder to enable flexib

[jira] [Closed] (FLINK-12994) Improve the buffer processing performance in SpilledBufferOrEventSequence#getNext

[ https://issues.apache.org/jira/browse/FLINK-12994?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhijiang closed FLINK-12994. Resolution: Won't Fix > Improve the buffer processing performance in > SpilledBufferOrEventSequence#getNe

[GitHub] [flink] buptljy edited a comment on issue #8125: [FLINK-10205] Batch Job: InputSplit Fault tolerant for DataSourceTask

buptljy edited a comment on issue #8125: [FLINK-10205] Batch Job: InputSplit Fault tolerant for DataSourceTask URL: https://github.com/apache/flink/pull/8125#issuecomment-556927189 @Ryantaocer @StefanRRichter Sorry for bring this out again. Currently I'm doing something about scheduler

[GitHub] [flink] zhuzhurk opened a new pull request #10275: [FLINK-14733][runtime] Introduce a builder for flexible ResourceProfile building

zhuzhurk opened a new pull request #10275: [FLINK-14733][runtime] Introduce a builder for flexible ResourceProfile building URL: https://github.com/apache/flink/pull/10275 ## What is the purpose of the change The ResourceProfile constructors may accept values in raw types (double

[jira] [Commented] (FLINK-12994) Improve the buffer processing performance in SpilledBufferOrEventSequence#getNext

[ https://issues.apache.org/jira/browse/FLINK-12994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16978992#comment-16978992 ] zhijiang commented on FLINK-12994: -- I guess this issue is not worth improving, because

[GitHub] [flink] buptljy edited a comment on issue #8125: [FLINK-10205] Batch Job: InputSplit Fault tolerant for DataSourceTask

buptljy edited a comment on issue #8125: [FLINK-10205] Batch Job: InputSplit Fault tolerant for DataSourceTask URL: https://github.com/apache/flink/pull/8125#issuecomment-556927189 @Ryantaocer @StefanRRichter Sorry for bring this out again. Currently I'm doing something about scheduler

[GitHub] [flink] buptljy commented on issue #8125: [FLINK-10205] Batch Job: InputSplit Fault tolerant for DataSourceTask

buptljy commented on issue #8125: [FLINK-10205] Batch Job: InputSplit Fault tolerant for DataSourceTask URL: https://github.com/apache/flink/pull/8125#issuecomment-556927189 @Ryantaocer @StefanRRichter Sorry for bring this out again. Currently I'm doing something about scheduler and I'

[GitHub] [flink] zhuzhurk commented on issue #10264: [FLINK-14811][runtime] Replace Java Streams in input check methods with for-loops

zhuzhurk commented on issue #10264: [FLINK-14811][runtime] Replace Java Streams in input check methods with for-loops URL: https://github.com/apache/flink/pull/10264#issuecomment-556925651 Rebased onto latest master. This is

[GitHub] [flink] flinkbot edited a comment on issue #10270: [FLINK-14672][sql-client] Make Executor stateful in sql client

flinkbot edited a comment on issue #10270: [FLINK-14672][sql-client] Make Executor stateful in sql client URL: https://github.com/apache/flink/pull/10270#issuecomment-555974946 ## CI report: * 4b5c6f4491d27b2ac16b571e3b92ce96c02c4a9a : SUCCESS [Build](https://travis-ci.com/flink

[GitHub] [flink] flinkbot edited a comment on issue #10272: [FLINK-14878]Support `use catalog` through sqlUpdate() method in TableEnvironment

flinkbot edited a comment on issue #10272: [FLINK-14878]Support `use catalog` through sqlUpdate() method in TableEnvironment URL: https://github.com/apache/flink/pull/10272#issuecomment-556228055 ## CI report: * ea0572560ca5e700a8d749484aac2edb17c07ba9 : SUCCESS [Build](https:/

[GitHub] [flink] zhuzhurk commented on a change in pull request #10232: [FLINK-14314][runtime] Allocate shared slot resources respecting the resources of all vertices in the group

zhuzhurk commented on a change in pull request #10232: [FLINK-14314][runtime] Allocate shared slot resources respecting the resources of all vertices in the group URL: https://github.com/apache/flink/pull/10232#discussion_r34881 ## File path: flink-runtime/src/main/java/org/ap

[GitHub] [flink] zhuzhurk commented on a change in pull request #10232: [FLINK-14314][runtime] Allocate shared slot resources respecting the resources of all vertices in the group

zhuzhurk commented on a change in pull request #10232: [FLINK-14314][runtime] Allocate shared slot resources respecting the resources of all vertices in the group URL: https://github.com/apache/flink/pull/10232#discussion_r348900012 ## File path: flink-table/flink-table-planner-bl

[GitHub] [flink] zhuzhurk commented on issue #10200: [FLINK-14062][runtime] Calculate managed memory fraction based on slot sharing groups

zhuzhurk commented on issue #10200: [FLINK-14062][runtime] Calculate managed memory fraction based on slot sharing groups URL: https://github.com/apache/flink/pull/10200#issuecomment-556924691 Rebased. This is an automated me

[GitHub] [flink] flinkbot edited a comment on issue #10239: [Flink-11491][Test] Support all TPC-DS queries

flinkbot edited a comment on issue #10239: [Flink-11491][Test] Support all TPC-DS queries URL: https://github.com/apache/flink/pull/10239#issuecomment-555095322 ## CI report: * edeb89cee6855c328f60c821aabee81cd3a3554c : FAILURE [Build](https://travis-ci.com/flink-ci/flink/builds

[jira] [Commented] (FLINK-14735) Improve batch schedule check input consumable performance

[ https://issues.apache.org/jira/browse/FLINK-14735?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16978982#comment-16978982 ] Zhu Zhu commented on FLINK-14735: - Thanks for merging the fix for new scheduler! [~sewen

[GitHub] [flink] flinkbot edited a comment on issue #10209: [FLINK-14688] Add table related DDLs support in SQL Parser

flinkbot edited a comment on issue #10209: [FLINK-14688] Add table related DDLs support in SQL Parser URL: https://github.com/apache/flink/pull/10209#issuecomment-554237951 ## CI report: * cf4946735df4ffcc8b41384b323b31e6a68726a2 : SUCCESS [Build](https://travis-ci.com/flink-ci/

[GitHub] [flink] flinkbot edited a comment on issue #10274: [FLINK-14873][client] Make PackagedProgram#savepointSettings final

flinkbot edited a comment on issue #10274: [FLINK-14873][client] Make PackagedProgram#savepointSettings final URL: https://github.com/apache/flink/pull/10274#issuecomment-556864266 ## CI report: * 3764315269f0aa0522945d85364994a219b8d599 : FAILURE [Build](https://travis-ci.com/f

[jira] [Updated] (FLINK-14482) Bump up rocksdb version

[ https://issues.apache.org/jira/browse/FLINK-14482?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Li updated FLINK-14482: -- Summary: Bump up rocksdb version (was: Bump up rocksdb version to support WriteBufferManager) > Bump up rock

[jira] [Assigned] (FLINK-14877) Enable FRocksDB to optimize performance via options when bounding total memory

[ https://issues.apache.org/jira/browse/FLINK-14877?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhijiang reassigned FLINK-14877: Assignee: Yun Tang > Enable FRocksDB to optimize performance via options when bounding total memo

[jira] [Commented] (FLINK-14482) Bump up rocksdb version to support WriteBufferManager

[ https://issues.apache.org/jira/browse/FLINK-14482?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16978966#comment-16978966 ] Yu Li commented on FLINK-14482: --- Change the JIRA type to Improvement and decouple it from

[jira] [Updated] (FLINK-14482) Bump up rocksdb version to support WriteBufferManager

[ https://issues.apache.org/jira/browse/FLINK-14482?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Li updated FLINK-14482: -- Parent: (was: FLINK-7289) Issue Type: Improvement (was: Sub-task) > Bump up rocksdb version to su

[jira] [Updated] (FLINK-14492) Modify state backend to report reserved memory to MemoryManager

[ https://issues.apache.org/jira/browse/FLINK-14492?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Li updated FLINK-14492: -- Parent: FLINK-14883 Issue Type: Sub-task (was: Task) > Modify state backend to report reserved memory

[jira] [Updated] (FLINK-14492) Modify state backend to report reserved memory to MemoryManager

[ https://issues.apache.org/jira/browse/FLINK-14492?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Li updated FLINK-14492: -- Parent: (was: FLINK-7289) Issue Type: Task (was: Sub-task) > Modify state backend to report reser

[jira] [Created] (FLINK-14884) User defined function for checkpoint trigger time and interval behavior

Shuwen Zhou created FLINK-14884: --- Summary: User defined function for checkpoint trigger time and interval behavior Key: FLINK-14884 URL: https://issues.apache.org/jira/browse/FLINK-14884 Project: Flink

[jira] [Updated] (FLINK-14489) Check and make sure state backend fits into TaskExecutor memory configuration

[ https://issues.apache.org/jira/browse/FLINK-14489?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Li updated FLINK-14489: -- Parent: FLINK-14883 Issue Type: Sub-task (was: Task) > Check and make sure state backend fits into Ta

[jira] [Updated] (FLINK-14489) Check and make sure state backend fits into TaskExecutor memory configuration

[ https://issues.apache.org/jira/browse/FLINK-14489?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Li updated FLINK-14489: -- Parent: (was: FLINK-7289) Issue Type: Task (was: Sub-task) > Check and make sure state backend fi

[GitHub] [flink] flinkbot edited a comment on issue #10272: [FLINK-14878]Support `use catalog` through sqlUpdate() method in TableEnvironment

flinkbot edited a comment on issue #10272: [FLINK-14878]Support `use catalog` through sqlUpdate() method in TableEnvironment URL: https://github.com/apache/flink/pull/10272#issuecomment-556228055 ## CI report: * ea0572560ca5e700a8d749484aac2edb17c07ba9 : SUCCESS [Build](https:/

[GitHub] [flink] flinkbot edited a comment on issue #10270: [FLINK-14672][sql-client] Make Executor stateful in sql client

flinkbot edited a comment on issue #10270: [FLINK-14672][sql-client] Make Executor stateful in sql client URL: https://github.com/apache/flink/pull/10270#issuecomment-555974946 ## CI report: * 4b5c6f4491d27b2ac16b571e3b92ce96c02c4a9a : SUCCESS [Build](https://travis-ci.com/flink

[GitHub] [flink] flinkbot edited a comment on issue #10271: [FLINK-14874] [table-planner-blink] add local aggregate to solve data skew for ROLLUP/CUBE case

flinkbot edited a comment on issue #10271: [FLINK-14874] [table-planner-blink] add local aggregate to solve data skew for ROLLUP/CUBE case URL: https://github.com/apache/flink/pull/10271#issuecomment-556037401 ## CI report: * dfd530a162b1912b00f5740ca07f828b44dcd4bd : FAILURE [B

[jira] [Commented] (FLINK-14883) Resource management on state backends

[ https://issues.apache.org/jira/browse/FLINK-14883?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16978956#comment-16978956 ] Yu Li commented on FLINK-14883: --- We will open a special FLIP to describe more details and

[jira] [Updated] (FLINK-14882) Wrong null order when change flink default null order from NullCollation.LOW to NullCollation.FIRST

[ https://issues.apache.org/jira/browse/FLINK-14882?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-14882: --- Description: Flink's default null collation keeps Nulls last for DESC, nulls first for ASC which na

[jira] [Created] (FLINK-14883) Resource management on state backends

Yu Li created FLINK-14883: - Summary: Resource management on state backends Key: FLINK-14883 URL: https://issues.apache.org/jira/browse/FLINK-14883 Project: Flink Issue Type: New Feature Com

[GitHub] [flink] flinkbot edited a comment on issue #10239: [Flink-11491][Test] Support all TPC-DS queries

flinkbot edited a comment on issue #10239: [Flink-11491][Test] Support all TPC-DS queries URL: https://github.com/apache/flink/pull/10239#issuecomment-555095322 ## CI report: * edeb89cee6855c328f60c821aabee81cd3a3554c : FAILURE [Build](https://travis-ci.com/flink-ci/flink/builds

[GitHub] [flink] flinkbot edited a comment on issue #10228: [FLINK-14816] Add thread dump feature for taskmanager

flinkbot edited a comment on issue #10228: [FLINK-14816] Add thread dump feature for taskmanager URL: https://github.com/apache/flink/pull/10228#issuecomment-554599522 ## CI report: * 8c07f8927fcbb96ae2e6f7b155ebc89287e2dbe9 : FAILURE [Build](https://travis-ci.com/flink-ci/flink

[GitHub] [flink] flinkbot edited a comment on issue #10209: [FLINK-14688] Add table related DDLs support in SQL Parser

flinkbot edited a comment on issue #10209: [FLINK-14688] Add table related DDLs support in SQL Parser URL: https://github.com/apache/flink/pull/10209#issuecomment-554237951 ## CI report: * cf4946735df4ffcc8b41384b323b31e6a68726a2 : SUCCESS [Build](https://travis-ci.com/flink-ci/

[GitHub] [flink] flinkbot edited a comment on issue #10268: [Flink-14599][table-planner-blink] Support precision of TimestampType in blink planner

flinkbot edited a comment on issue #10268: [Flink-14599][table-planner-blink] Support precision of TimestampType in blink planner URL: https://github.com/apache/flink/pull/10268#issuecomment-555964030 ## CI report: * 72414aad5f654b834205103f23fbbfc3d5466748 : FAILURE [Build](htt

[GitHub] [flink] flinkbot edited a comment on issue #10270: [FLINK-14672][sql-client] Make Executor stateful in sql client

flinkbot edited a comment on issue #10270: [FLINK-14672][sql-client] Make Executor stateful in sql client URL: https://github.com/apache/flink/pull/10270#issuecomment-555974946 ## CI report: * 4b5c6f4491d27b2ac16b571e3b92ce96c02c4a9a : SUCCESS [Build](https://travis-ci.com/flink

[GitHub] [flink] flinkbot edited a comment on issue #10272: [FLINK-14878]Support `use catalog` through sqlUpdate() method in TableEnvironment

flinkbot edited a comment on issue #10272: [FLINK-14878]Support `use catalog` through sqlUpdate() method in TableEnvironment URL: https://github.com/apache/flink/pull/10272#issuecomment-556228055 ## CI report: * ea0572560ca5e700a8d749484aac2edb17c07ba9 : SUCCESS [Build](https:/

[GitHub] [flink] dianfu commented on a change in pull request #10017: [FLINK-14019][python] add support for managing environment and dependencies of Python UDF in Flink Python API

dianfu commented on a change in pull request #10017: [FLINK-14019][python] add support for managing environment and dependencies of Python UDF in Flink Python API URL: https://github.com/apache/flink/pull/10017#discussion_r348874740 ## File path: flink-python/src/main/java/org/apa

[GitHub] [flink] dianfu commented on a change in pull request #10017: [FLINK-14019][python] add support for managing environment and dependencies of Python UDF in Flink Python API

dianfu commented on a change in pull request #10017: [FLINK-14019][python] add support for managing environment and dependencies of Python UDF in Flink Python API URL: https://github.com/apache/flink/pull/10017#discussion_r348866414 ## File path: flink-python/pyflink/common/depende

[GitHub] [flink] dianfu commented on a change in pull request #10017: [FLINK-14019][python] add support for managing environment and dependencies of Python UDF in Flink Python API

dianfu commented on a change in pull request #10017: [FLINK-14019][python] add support for managing environment and dependencies of Python UDF in Flink Python API URL: https://github.com/apache/flink/pull/10017#discussion_r348504293 ## File path: flink-python/pyflink/table/table_en

[GitHub] [flink] dianfu commented on a change in pull request #10017: [FLINK-14019][python] add support for managing environment and dependencies of Python UDF in Flink Python API

dianfu commented on a change in pull request #10017: [FLINK-14019][python] add support for managing environment and dependencies of Python UDF in Flink Python API URL: https://github.com/apache/flink/pull/10017#discussion_r348512789 ## File path: flink-python/pyflink/table/table_en

[GitHub] [flink] dianfu commented on a change in pull request #10017: [FLINK-14019][python] add support for managing environment and dependencies of Python UDF in Flink Python API

dianfu commented on a change in pull request #10017: [FLINK-14019][python] add support for managing environment and dependencies of Python UDF in Flink Python API URL: https://github.com/apache/flink/pull/10017#discussion_r348873473 ## File path: flink-python/src/main/java/org/apa

[GitHub] [flink] dianfu commented on a change in pull request #10017: [FLINK-14019][python] add support for managing environment and dependencies of Python UDF in Flink Python API

dianfu commented on a change in pull request #10017: [FLINK-14019][python] add support for managing environment and dependencies of Python UDF in Flink Python API URL: https://github.com/apache/flink/pull/10017#discussion_r348875088 ## File path: flink-python/src/main/java/org/apa

[GitHub] [flink] dianfu commented on a change in pull request #10017: [FLINK-14019][python] add support for managing environment and dependencies of Python UDF in Flink Python API

dianfu commented on a change in pull request #10017: [FLINK-14019][python] add support for managing environment and dependencies of Python UDF in Flink Python API URL: https://github.com/apache/flink/pull/10017#discussion_r348868115 ## File path: flink-python/pyflink/table/table_co

[GitHub] [flink] dianfu commented on a change in pull request #10017: [FLINK-14019][python] add support for managing environment and dependencies of Python UDF in Flink Python API

dianfu commented on a change in pull request #10017: [FLINK-14019][python] add support for managing environment and dependencies of Python UDF in Flink Python API URL: https://github.com/apache/flink/pull/10017#discussion_r348504315 ## File path: flink-python/pyflink/table/table_en

[GitHub] [flink] dianfu commented on a change in pull request #10017: [FLINK-14019][python] add support for managing environment and dependencies of Python UDF in Flink Python API

dianfu commented on a change in pull request #10017: [FLINK-14019][python] add support for managing environment and dependencies of Python UDF in Flink Python API URL: https://github.com/apache/flink/pull/10017#discussion_r348864049 ## File path: flink-python/pyflink/common/depende

[GitHub] [flink] dianfu commented on a change in pull request #10017: [FLINK-14019][python] add support for managing environment and dependencies of Python UDF in Flink Python API

dianfu commented on a change in pull request #10017: [FLINK-14019][python] add support for managing environment and dependencies of Python UDF in Flink Python API URL: https://github.com/apache/flink/pull/10017#discussion_r348506288 ## File path: flink-python/pyflink/table/table_en

[GitHub] [flink] dianfu commented on a change in pull request #10017: [FLINK-14019][python] add support for managing environment and dependencies of Python UDF in Flink Python API

dianfu commented on a change in pull request #10017: [FLINK-14019][python] add support for managing environment and dependencies of Python UDF in Flink Python API URL: https://github.com/apache/flink/pull/10017#discussion_r348877737 ## File path: flink-python/src/main/java/org/apa

[GitHub] [flink] dianfu commented on a change in pull request #10017: [FLINK-14019][python] add support for managing environment and dependencies of Python UDF in Flink Python API

dianfu commented on a change in pull request #10017: [FLINK-14019][python] add support for managing environment and dependencies of Python UDF in Flink Python API URL: https://github.com/apache/flink/pull/10017#discussion_r348867856 ## File path: flink-python/pyflink/table/table_co

[GitHub] [flink] dianfu commented on a change in pull request #10017: [FLINK-14019][python] add support for managing environment and dependencies of Python UDF in Flink Python API

dianfu commented on a change in pull request #10017: [FLINK-14019][python] add support for managing environment and dependencies of Python UDF in Flink Python API URL: https://github.com/apache/flink/pull/10017#discussion_r348864272 ## File path: flink-python/pyflink/common/depende

[GitHub] [flink] dianfu commented on a change in pull request #10017: [FLINK-14019][python] add support for managing environment and dependencies of Python UDF in Flink Python API

dianfu commented on a change in pull request #10017: [FLINK-14019][python] add support for managing environment and dependencies of Python UDF in Flink Python API URL: https://github.com/apache/flink/pull/10017#discussion_r348862323 ## File path: flink-python/pyflink/common/depende

[GitHub] [flink] dianfu commented on a change in pull request #10017: [FLINK-14019][python] add support for managing environment and dependencies of Python UDF in Flink Python API

dianfu commented on a change in pull request #10017: [FLINK-14019][python] add support for managing environment and dependencies of Python UDF in Flink Python API URL: https://github.com/apache/flink/pull/10017#discussion_r348863651 ## File path: flink-python/pyflink/common/depende

[GitHub] [flink] dianfu commented on a change in pull request #10017: [FLINK-14019][python] add support for managing environment and dependencies of Python UDF in Flink Python API

dianfu commented on a change in pull request #10017: [FLINK-14019][python] add support for managing environment and dependencies of Python UDF in Flink Python API URL: https://github.com/apache/flink/pull/10017#discussion_r348877266 ## File path: flink-python/src/main/java/org/apa

[GitHub] [flink] dianfu commented on a change in pull request #10017: [FLINK-14019][python] add support for managing environment and dependencies of Python UDF in Flink Python API

dianfu commented on a change in pull request #10017: [FLINK-14019][python] add support for managing environment and dependencies of Python UDF in Flink Python API URL: https://github.com/apache/flink/pull/10017#discussion_r348871126 ## File path: flink-python/src/main/java/org/apa

[GitHub] [flink] dianfu commented on a change in pull request #10017: [FLINK-14019][python] add support for managing environment and dependencies of Python UDF in Flink Python API

dianfu commented on a change in pull request #10017: [FLINK-14019][python] add support for managing environment and dependencies of Python UDF in Flink Python API URL: https://github.com/apache/flink/pull/10017#discussion_r348882011 ## File path: flink-python/src/main/java/org/apa

[GitHub] [flink] dianfu commented on a change in pull request #10017: [FLINK-14019][python] add support for managing environment and dependencies of Python UDF in Flink Python API

dianfu commented on a change in pull request #10017: [FLINK-14019][python] add support for managing environment and dependencies of Python UDF in Flink Python API URL: https://github.com/apache/flink/pull/10017#discussion_r348864443 ## File path: flink-python/pyflink/common/depende

[GitHub] [flink] dianfu commented on a change in pull request #10017: [FLINK-14019][python] add support for managing environment and dependencies of Python UDF in Flink Python API

dianfu commented on a change in pull request #10017: [FLINK-14019][python] add support for managing environment and dependencies of Python UDF in Flink Python API URL: https://github.com/apache/flink/pull/10017#discussion_r348506519 ## File path: flink-python/pyflink/table/table_en

[GitHub] [flink] dianfu commented on a change in pull request #10017: [FLINK-14019][python] add support for managing environment and dependencies of Python UDF in Flink Python API

dianfu commented on a change in pull request #10017: [FLINK-14019][python] add support for managing environment and dependencies of Python UDF in Flink Python API URL: https://github.com/apache/flink/pull/10017#discussion_r348496520 ## File path: flink-python/src/main/java/org/apa

[GitHub] [flink] dianfu commented on a change in pull request #10017: [FLINK-14019][python] add support for managing environment and dependencies of Python UDF in Flink Python API

dianfu commented on a change in pull request #10017: [FLINK-14019][python] add support for managing environment and dependencies of Python UDF in Flink Python API URL: https://github.com/apache/flink/pull/10017#discussion_r348880204 ## File path: flink-python/src/main/java/org/apa

[GitHub] [flink] dianfu commented on a change in pull request #10017: [FLINK-14019][python] add support for managing environment and dependencies of Python UDF in Flink Python API

dianfu commented on a change in pull request #10017: [FLINK-14019][python] add support for managing environment and dependencies of Python UDF in Flink Python API URL: https://github.com/apache/flink/pull/10017#discussion_r348507704 ## File path: flink-python/pyflink/table/table_en

[GitHub] [flink] dianfu commented on a change in pull request #10017: [FLINK-14019][python] add support for managing environment and dependencies of Python UDF in Flink Python API

dianfu commented on a change in pull request #10017: [FLINK-14019][python] add support for managing environment and dependencies of Python UDF in Flink Python API URL: https://github.com/apache/flink/pull/10017#discussion_r348878372 ## File path: flink-python/src/main/java/org/apa

[GitHub] [flink] dianfu commented on a change in pull request #10017: [FLINK-14019][python] add support for managing environment and dependencies of Python UDF in Flink Python API

dianfu commented on a change in pull request #10017: [FLINK-14019][python] add support for managing environment and dependencies of Python UDF in Flink Python API URL: https://github.com/apache/flink/pull/10017#discussion_r348495162 ## File path: flink-python/src/main/java/org/apa

[GitHub] [flink] dianfu commented on a change in pull request #10017: [FLINK-14019][python] add support for managing environment and dependencies of Python UDF in Flink Python API

dianfu commented on a change in pull request #10017: [FLINK-14019][python] add support for managing environment and dependencies of Python UDF in Flink Python API URL: https://github.com/apache/flink/pull/10017#discussion_r348865980 ## File path: flink-python/pyflink/common/depende

[GitHub] [flink] dianfu commented on a change in pull request #10017: [FLINK-14019][python] add support for managing environment and dependencies of Python UDF in Flink Python API

dianfu commented on a change in pull request #10017: [FLINK-14019][python] add support for managing environment and dependencies of Python UDF in Flink Python API URL: https://github.com/apache/flink/pull/10017#discussion_r348489736 ## File path: flink-python/src/main/java/org/apa

  1   2   3   4   5   6   7   >