[GitHub] [flink] flinkbot edited a comment on issue #10388: [FLINK-14912][Table] create, drop catalog functions through catalog manager

flinkbot edited a comment on issue #10388: [FLINK-14912][Table] create, drop catalog functions through catalog manager URL: https://github.com/apache/flink/pull/10388#issuecomment-560948011 ## CI report: * bd56213c9d550b0815cea7467929ae853a86c68b : SUCCESS

[GitHub] [flink] flinkbot edited a comment on issue #10330: [FLINK-14189][runtime] Extend TaskExecutor to support dynamic slot allocation

flinkbot edited a comment on issue #10330: [FLINK-14189][runtime] Extend TaskExecutor to support dynamic slot allocation URL: https://github.com/apache/flink/pull/10330#issuecomment-558970102 ## CI report: * 38f2c1c450122cae9aa99258c19c6d07e998 : FAILURE

[GitHub] [flink] flinkbot commented on issue #10449: [FLINK-7289][state-backend] Integrate RocksDB memory use with managed memory

flinkbot commented on issue #10449: [FLINK-7289][state-backend] Integrate RocksDB memory use with managed memory URL: https://github.com/apache/flink/pull/10449#issuecomment-562304122 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community

[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 ] ASF GitHub Bot updated FLINK-7289: -- Labels: pull-request-available (was: ) > Memory allocation of RocksDB can be problematic in

[GitHub] [flink] StephanEwen opened a new pull request #10449: [FLINK-7289][state-backend] Integrate RocksDB memory use with managed memory

StephanEwen opened a new pull request #10449: [FLINK-7289][state-backend] Integrate RocksDB memory use with managed memory URL: https://github.com/apache/flink/pull/10449 # What is the purpose of the change This PR sums up several PRs into a whole that allows users to either let

[GitHub] [flink] flinkbot edited a comment on issue #10446: [FLINK-15076][task] Fix SourceStreamTask cancellation

flinkbot edited a comment on issue #10446: [FLINK-15076][task] Fix SourceStreamTask cancellation URL: https://github.com/apache/flink/pull/10446#issuecomment-562210711 ## CI report: * b23a4477442b92ceda70901ab0a3736eefb4b224 : CANCELED

[GitHub] [flink] flinkbot edited a comment on issue #10435: [FLINK-13955][runtime] migrate ContinuousFileReaderOperator to the mailbox execution model

flinkbot edited a comment on issue #10435: [FLINK-13955][runtime] migrate ContinuousFileReaderOperator to the mailbox execution model URL: https://github.com/apache/flink/pull/10435#issuecomment-562048103 ## CI report: * d07737bd54c586aa87204c6ac298309f432cc06c : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #10388: [FLINK-14912][Table] create, drop catalog functions through catalog manager

flinkbot edited a comment on issue #10388: [FLINK-14912][Table] create, drop catalog functions through catalog manager URL: https://github.com/apache/flink/pull/10388#issuecomment-560948011 ## CI report: * bd56213c9d550b0815cea7467929ae853a86c68b : SUCCESS

[GitHub] [flink] xintongsong commented on a change in pull request #10146: [FLINK-14188][runtime] TaskExecutor derive and register with default slot resource profile

xintongsong commented on a change in pull request #10146: [FLINK-14188][runtime] TaskExecutor derive and register with default slot resource profile URL: https://github.com/apache/flink/pull/10146#discussion_r354521231 ## File path:

[GitHub] [flink] je-ik commented on issue #9579: [FLINK-13925] use current thread's context classloader as parent of flink classloader

je-ik commented on issue #9579: [FLINK-13925] use current thread's context classloader as parent of flink classloader URL: https://github.com/apache/flink/pull/9579#issuecomment-562286334 There was a discussion around that on ML:

[GitHub] [flink] flinkbot edited a comment on issue #10448: [hotfix][task] Refactor StreamTask#disposed field

flinkbot edited a comment on issue #10448: [hotfix][task] Refactor StreamTask#disposed field URL: https://github.com/apache/flink/pull/10448#issuecomment-562240197 ## CI report: * bc4e07fd44aaee32c31a038680c2a5f67d9a62ff : CANCELED

[GitHub] [flink] flinkbot edited a comment on issue #10446: [FLINK-15076][task] Fix SourceStreamTask cancellation

flinkbot edited a comment on issue #10446: [FLINK-15076][task] Fix SourceStreamTask cancellation URL: https://github.com/apache/flink/pull/10446#issuecomment-562210711 ## CI report: * b23a4477442b92ceda70901ab0a3736eefb4b224 : PENDING

[GitHub] [flink] flinkbot edited a comment on issue #10433: [FLINK-15071] YARN vcore capacity check can not pass when use large slotPerTaskManager

flinkbot edited a comment on issue #10433: [FLINK-15071] YARN vcore capacity check can not pass when use large slotPerTaskManager URL: https://github.com/apache/flink/pull/10433#issuecomment-562047908 ## CI report: * ad17546e86c7273f447591448b9bea9dafa83d8e : SUCCESS

[GitHub] [flink] flinkbot edited a comment on issue #10432: [FLINK-13450][table api] Use StrictMath instead of Math for exp

flinkbot edited a comment on issue #10432: [FLINK-13450][table api] Use StrictMath instead of Math for exp URL: https://github.com/apache/flink/pull/10432#issuecomment-562047809 ## CI report: * a69782464ce80d238c4ea94045b603738d62d13c : SUCCESS

[jira] [Commented] (FLINK-15056) Python test: ExecutionEnvironmentCompletenessTests.test_completeness failed

[ https://issues.apache.org/jira/browse/FLINK-15056?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16989087#comment-16989087 ] Robert Metzger commented on FLINK-15056: Mh, something is a bit messed up around the ticket and

[GitHub] [flink] bowenli86 commented on a change in pull request #10249: [FLINK-14847][hive] Support retrieving Hive PK constraints

bowenli86 commented on a change in pull request #10249: [FLINK-14847][hive] Support retrieving Hive PK constraints URL: https://github.com/apache/flink/pull/10249#discussion_r354497654 ## File path:

[GitHub] [flink] bowenli86 commented on a change in pull request #10249: [FLINK-14847][hive] Support retrieving Hive PK constraints

bowenli86 commented on a change in pull request #10249: [FLINK-14847][hive] Support retrieving Hive PK constraints URL: https://github.com/apache/flink/pull/10249#discussion_r354497654 ## File path:

[GitHub] [flink] bowenli86 commented on a change in pull request #10249: [FLINK-14847][hive] Support retrieving Hive PK constraints

bowenli86 commented on a change in pull request #10249: [FLINK-14847][hive] Support retrieving Hive PK constraints URL: https://github.com/apache/flink/pull/10249#discussion_r354495325 ## File path:

[GitHub] [flink] pnowojski commented on a change in pull request #10446: [FLINK-15076][task] Fix SourceStreamTask cancellation

pnowojski commented on a change in pull request #10446: [FLINK-15076][task] Fix SourceStreamTask cancellation URL: https://github.com/apache/flink/pull/10446#discussion_r354495322 ## File path:

[GitHub] [flink] bowenli86 commented on a change in pull request #10401: [FLINK-15020][hive] Support timestamp type in hive

bowenli86 commented on a change in pull request #10401: [FLINK-15020][hive] Support timestamp type in hive URL: https://github.com/apache/flink/pull/10401#discussion_r353920915 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #10448: [hotfix][task] Refactor StreamTask#disposed field

flinkbot edited a comment on issue #10448: [hotfix][task] Refactor StreamTask#disposed field URL: https://github.com/apache/flink/pull/10448#issuecomment-562240197 ## CI report: * bc4e07fd44aaee32c31a038680c2a5f67d9a62ff : PENDING

[GitHub] [flink] bowenli86 commented on issue #10410: [FLINK-14692][table]support rename/alter table in tableEnvironment in both flink/blink planner

bowenli86 commented on issue #10410: [FLINK-14692][table]support rename/alter table in tableEnvironment in both flink/blink planner URL: https://github.com/apache/flink/pull/10410#issuecomment-562266032 LGTM, will merge if @KurtYoung doesn't have more concerns

[GitHub] [flink] flinkbot edited a comment on issue #10388: [FLINK-14912][Table] create, drop catalog functions through catalog manager

flinkbot edited a comment on issue #10388: [FLINK-14912][Table] create, drop catalog functions through catalog manager URL: https://github.com/apache/flink/pull/10388#issuecomment-560948011 ## CI report: * bd56213c9d550b0815cea7467929ae853a86c68b : SUCCESS

[GitHub] [flink] flinkbot edited a comment on issue #10344: [FLINK-14264][StateBackend][Rest] Expose state backend in checkpoint rest api

flinkbot edited a comment on issue #10344: [FLINK-14264][StateBackend][Rest] Expose state backend in checkpoint rest api URL: https://github.com/apache/flink/pull/10344#issuecomment-559371382 ## CI report: * fbd6e8914b49348a275657130ebdd9413d7d17c6 : SUCCESS

[GitHub] [flink] Myasuka commented on issue #9579: [FLINK-13925] use current thread's context classloader as parent of flink classloader

Myasuka commented on issue #9579: [FLINK-13925] use current thread's context classloader as parent of flink classloader URL: https://github.com/apache/flink/pull/9579#issuecomment-562261898 Why we need this fix? It has not been clarified clearly in original JIRA issue.

[GitHub] [flink] Myasuka commented on a change in pull request #9602: [FLINK-13856][checkpoint] Reduce the delete file api when the checkpo…

Myasuka commented on a change in pull request #9602: [FLINK-13856][checkpoint] Reduce the delete file api when the checkpo… URL: https://github.com/apache/flink/pull/9602#discussion_r354480441 ## File path:

[GitHub] [flink] Myasuka commented on a change in pull request #9602: [FLINK-13856][checkpoint] Reduce the delete file api when the checkpo…

Myasuka commented on a change in pull request #9602: [FLINK-13856][checkpoint] Reduce the delete file api when the checkpo… URL: https://github.com/apache/flink/pull/9602#discussion_r354480329 ## File path:

[GitHub] [flink] dawidwys commented on a change in pull request #10368: [FLINK-14983][table-common] Add interfaces for input type inference

dawidwys commented on a change in pull request #10368: [FLINK-14983][table-common] Add interfaces for input type inference URL: https://github.com/apache/flink/pull/10368#discussion_r354480993 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #10448: [hotfix][task] Refactor StreamTask#disposed field

flinkbot edited a comment on issue #10448: [hotfix][task] Refactor StreamTask#disposed field URL: https://github.com/apache/flink/pull/10448#issuecomment-562240197 ## CI report: * bc4e07fd44aaee32c31a038680c2a5f67d9a62ff : PENDING

[GitHub] [flink] flinkbot edited a comment on issue #10439: [FLINK-15059][table-common] Update ASM opcode to 7

flinkbot edited a comment on issue #10439: [FLINK-15059][table-common] Update ASM opcode to 7 URL: https://github.com/apache/flink/pull/10439#issuecomment-562116580 ## CI report: * 0abdda405869e046f43beb94e7a316b11ee8e72f : CANCELED

[GitHub] [flink] flinkbot edited a comment on issue #10436: [FLINK-14920] [flink-end-to-end-perf-tests] Set up environment to run performance e2e tests

flinkbot edited a comment on issue #10436: [FLINK-14920] [flink-end-to-end-perf-tests] Set up environment to run performance e2e tests URL: https://github.com/apache/flink/pull/10436#issuecomment-562103759 ## CI report: * 3441142c77315169ce7a3b48d4d59e710c1016c2 : CANCELED

[GitHub] [flink] flinkbot edited a comment on issue #10430: [FLINK-14019][python][cli] Add command-line options for managing Python UDF environment and dependencies.

flinkbot edited a comment on issue #10430: [FLINK-14019][python][cli] Add command-line options for managing Python UDF environment and dependencies. URL: https://github.com/apache/flink/pull/10430#issuecomment-562033539 ## CI report: * 735df4f522069f08b8b4b26a0018a6440293c507 :

[GitHub] [flink] flinkbot edited a comment on issue #10388: [FLINK-14912][Table] create, drop catalog functions through catalog manager

flinkbot edited a comment on issue #10388: [FLINK-14912][Table] create, drop catalog functions through catalog manager URL: https://github.com/apache/flink/pull/10388#issuecomment-560948011 ## CI report: * bd56213c9d550b0815cea7467929ae853a86c68b : SUCCESS

[jira] [Commented] (FLINK-14777) Migrate duration and memory size ConfigOptions in MetricOptions

[ https://issues.apache.org/jira/browse/FLINK-14777?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16989050#comment-16989050 ] Yun Tang commented on FLINK-14777: -- [~dwysakowicz] I could help to take this issue. > Migrate duration

[jira] [Comment Edited] (FLINK-14777) Migrate duration and memory size ConfigOptions in MetricOptions

[ https://issues.apache.org/jira/browse/FLINK-14777?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16989050#comment-16989050 ] Yun Tang edited comment on FLINK-14777 at 12/5/19 6:19 PM: --- [~dwysakowicz] , I

[jira] [Commented] (FLINK-14775) Migrate duration and memory size ConfigOptions in CheckpointingOptions

[ https://issues.apache.org/jira/browse/FLINK-14775?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16989049#comment-16989049 ] Yun Tang commented on FLINK-14775: -- [~dwysakowicz] I could help to take this issue.  > Migrate

[GitHub] [flink] flinkbot edited a comment on issue #10249: [FLINK-14847][hive] Support retrieving Hive PK constraints

flinkbot edited a comment on issue #10249: [FLINK-14847][hive] Support retrieving Hive PK constraints URL: https://github.com/apache/flink/pull/10249#issuecomment-555440054 ## CI report: * bd253651412e9ca6857cf0ba299bdd1bf544c2c4 : SUCCESS

[jira] [Closed] (FLINK-15059) DataTypeExtractorTest fails on travis

[ https://issues.apache.org/jira/browse/FLINK-15059?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-15059. Resolution: Fixed Fixed in 1.10.0: 23ea91bb80ade0e3a715498d52c1564c45b80d5b >

[GitHub] [flink] asfgit closed pull request #10439: [FLINK-15059][table-common] Update ASM opcode to 7

asfgit closed pull request #10439: [FLINK-15059][table-common] Update ASM opcode to 7 URL: https://github.com/apache/flink/pull/10439 This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [flink] Myasuka commented on issue #10378: [FLINK-14919] [flink-end-to-end-perf-tests] Add performance e2e test suite for basic operations

Myasuka commented on issue #10378: [FLINK-14919] [flink-end-to-end-perf-tests] Add performance e2e test suite for basic operations URL: https://github.com/apache/flink/pull/10378#issuecomment-562241887 Hi @Li-Aihua , one suggestion but not any actual review comment: use your github

[GitHub] [flink] flinkbot edited a comment on issue #10447: [FLINK-15084][runtime] Add shared resources tracking to MemoryManager

flinkbot edited a comment on issue #10447: [FLINK-15084][runtime] Add shared resources tracking to MemoryManager URL: https://github.com/apache/flink/pull/10447#issuecomment-562226173 ## CI report: * fba7ae37fda85dbac2cd235e5c1c049fe33df3df : PENDING

[GitHub] [flink] flinkbot commented on issue #10448: [hotfix][task] Replace StreamTask#disposed field with a local variable

flinkbot commented on issue #10448: [hotfix][task] Replace StreamTask#disposed field with a local variable URL: https://github.com/apache/flink/pull/10448#issuecomment-562240197 ## CI report: * bc4e07fd44aaee32c31a038680c2a5f67d9a62ff : UNKNOWN Bot commands The

[GitHub] [flink] flinkbot edited a comment on issue #10436: [FLINK-14920] [flink-end-to-end-perf-tests] Set up environment to run performance e2e tests

flinkbot edited a comment on issue #10436: [FLINK-14920] [flink-end-to-end-perf-tests] Set up environment to run performance e2e tests URL: https://github.com/apache/flink/pull/10436#issuecomment-562103759 ## CI report: * 3441142c77315169ce7a3b48d4d59e710c1016c2 : CANCELED

[GitHub] [flink] twalthr commented on issue #10439: [FLINK-15059][table-common] Update ASM opcode to 7

twalthr commented on issue #10439: [FLINK-15059][table-common] Update ASM opcode to 7 URL: https://github.com/apache/flink/pull/10439#issuecomment-562239108 Thanks @zentol. Good point will also update L551 and merge this.

[GitHub] [flink] flinkbot edited a comment on issue #10431: [FLINK-15067][table] Pass configuration to the underlying ExecutionEnvironment from TableEnvironment

flinkbot edited a comment on issue #10431: [FLINK-15067][table] Pass configuration to the underlying ExecutionEnvironment from TableEnvironment URL: https://github.com/apache/flink/pull/10431#issuecomment-562033619 ## CI report: * e0b1afaebe5bd4fc07e61785a38ef82f55e16f69 :

[GitHub] [flink] flinkbot edited a comment on issue #10429: [FLINK-14965] [table-planner-blink] correct the logic of convertToTableStats method in CatalogTableStatisticsConverter

flinkbot edited a comment on issue #10429: [FLINK-14965] [table-planner-blink] correct the logic of convertToTableStats method in CatalogTableStatisticsConverter URL: https://github.com/apache/flink/pull/10429#issuecomment-562021544 ## CI report: *

[GitHub] [flink] twalthr commented on a change in pull request #10368: [FLINK-14983][table-common] Add interfaces for input type inference

twalthr commented on a change in pull request #10368: [FLINK-14983][table-common] Add interfaces for input type inference URL: https://github.com/apache/flink/pull/10368#discussion_r354456988 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #10330: [FLINK-14189][runtime] Extend TaskExecutor to support dynamic slot allocation

flinkbot edited a comment on issue #10330: [FLINK-14189][runtime] Extend TaskExecutor to support dynamic slot allocation URL: https://github.com/apache/flink/pull/10330#issuecomment-558970102 ## CI report: * 38f2c1c450122cae9aa99258c19c6d07e998 : FAILURE

[GitHub] [flink] twalthr commented on a change in pull request #10368: [FLINK-14983][table-common] Add interfaces for input type inference

twalthr commented on a change in pull request #10368: [FLINK-14983][table-common] Add interfaces for input type inference URL: https://github.com/apache/flink/pull/10368#discussion_r354449529 ## File path:

[GitHub] [flink] pnowojski commented on a change in pull request #10375: [FLINK-14845][runtime] Introduce data compression to reduce disk and network IO of shuffle.

pnowojski commented on a change in pull request #10375: [FLINK-14845][runtime] Introduce data compression to reduce disk and network IO of shuffle. URL: https://github.com/apache/flink/pull/10375#discussion_r354407611 ## File path:

[GitHub] [flink] pnowojski commented on a change in pull request #10375: [FLINK-14845][runtime] Introduce data compression to reduce disk and network IO of shuffle.

pnowojski commented on a change in pull request #10375: [FLINK-14845][runtime] Introduce data compression to reduce disk and network IO of shuffle. URL: https://github.com/apache/flink/pull/10375#discussion_r354447367 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #10146: [FLINK-14188][runtime] TaskExecutor derive and register with default slot resource profile

flinkbot edited a comment on issue #10146: [FLINK-14188][runtime] TaskExecutor derive and register with default slot resource profile URL: https://github.com/apache/flink/pull/10146#issuecomment-552307115 ## CI report: * 25f9e4b87846e5a736aa329c834f82962e1f50c4 : FAILURE

[GitHub] [flink] flinkbot commented on issue #10447: [FLINK-15084][runtime] Add shared resources tracking to MemoryManager

flinkbot commented on issue #10447: [FLINK-15084][runtime] Add shared resources tracking to MemoryManager URL: https://github.com/apache/flink/pull/10447#issuecomment-562226173 ## CI report: * fba7ae37fda85dbac2cd235e5c1c049fe33df3df : UNKNOWN Bot commands The

[GitHub] [flink] flinkbot edited a comment on issue #10446: [FLINK-15076][task] Fix SourceStreamTask cancellation

flinkbot edited a comment on issue #10446: [FLINK-15076][task] Fix SourceStreamTask cancellation URL: https://github.com/apache/flink/pull/10446#issuecomment-562210711 ## CI report: * b23a4477442b92ceda70901ab0a3736eefb4b224 : PENDING

[GitHub] [flink] flinkbot edited a comment on issue #10441: [FLINK-14857][runtime] Remove checkpoint lock usage from AsyncWaitOperator.

flinkbot edited a comment on issue #10441: [FLINK-14857][runtime] Remove checkpoint lock usage from AsyncWaitOperator. URL: https://github.com/apache/flink/pull/10441#issuecomment-562129081 ## CI report: * d2fa376d69e43da56c4f8605bd663fc4113bc67f : CANCELED

[GitHub] [flink] flinkbot edited a comment on issue #10431: [FLINK-15067][table] Pass configuration to the underlying ExecutionEnvironment from TableEnvironment

flinkbot edited a comment on issue #10431: [FLINK-15067][table] Pass configuration to the underlying ExecutionEnvironment from TableEnvironment URL: https://github.com/apache/flink/pull/10431#issuecomment-562033619 ## CI report: * e0b1afaebe5bd4fc07e61785a38ef82f55e16f69 :

[GitHub] [flink] flinkbot edited a comment on issue #10427: [FLINK-14566] Enable to get/set whether an operator uses managed memory

flinkbot edited a comment on issue #10427: [FLINK-14566] Enable to get/set whether an operator uses managed memory URL: https://github.com/apache/flink/pull/10427#issuecomment-561973242 ## CI report: * 22ccb31308d510df2bfea3bdee521bbb73949a7b : CANCELED

[GitHub] [flink] flinkbot edited a comment on issue #10422: [FLINK-15057][tests] Set JM and TM memory config in flink-conf.yaml

flinkbot edited a comment on issue #10422: [FLINK-15057][tests] Set JM and TM memory config in flink-conf.yaml URL: https://github.com/apache/flink/pull/10422#issuecomment-561743112 ## CI report: * 88f6f7790d8bb0b517958be4446e95146605c369 : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #10418: [FLINK-15050][table-planner-blink] DataFormatConverters should suppor…

flinkbot edited a comment on issue #10418: [FLINK-15050][table-planner-blink] DataFormatConverters should suppor… URL: https://github.com/apache/flink/pull/10418#issuecomment-561567846 ## CI report: * 6951e77dff9c9c4fb1945d79ef4253e5ea2c0f0f : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #10403: [FLINK-14645][table] Support to keep nullability and precision when converting DataTypes to properties

flinkbot edited a comment on issue #10403: [FLINK-14645][table] Support to keep nullability and precision when converting DataTypes to properties URL: https://github.com/apache/flink/pull/10403#issuecomment-561208418 ## CI report: * 038052c833940fbaef3111ed92525216f13edee2 :

[GitHub] [flink] flinkbot edited a comment on issue #10375: [FLINK-14845][runtime] Introduce data compression to reduce disk and network IO of shuffle.

flinkbot edited a comment on issue #10375: [FLINK-14845][runtime] Introduce data compression to reduce disk and network IO of shuffle. URL: https://github.com/apache/flink/pull/10375#issuecomment-560214201 ## CI report: * af7ab17308bafebf22198881ad59ec4516da43e2 : SUCCESS

[GitHub] [flink] flinkbot commented on issue #10448: [hotfix][task] Replace StreamTask#disposed field with a local variable

flinkbot commented on issue #10448: [hotfix][task] Replace StreamTask#disposed field with a local variable URL: https://github.com/apache/flink/pull/10448#issuecomment-56721 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to

[GitHub] [flink] carp84 commented on a change in pull request #10447: [FLINK-15084][runtime] Add shared resources tracking to MemoryManager

carp84 commented on a change in pull request #10447: [FLINK-15084][runtime] Add shared resources tracking to MemoryManager URL: https://github.com/apache/flink/pull/10447#discussion_r354424986 ## File path:

[GitHub] [flink] carp84 commented on a change in pull request #10447: [FLINK-15084][runtime] Add shared resources tracking to MemoryManager

carp84 commented on a change in pull request #10447: [FLINK-15084][runtime] Add shared resources tracking to MemoryManager URL: https://github.com/apache/flink/pull/10447#discussion_r354437363 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #10330: [FLINK-14189][runtime] Extend TaskExecutor to support dynamic slot allocation

flinkbot edited a comment on issue #10330: [FLINK-14189][runtime] Extend TaskExecutor to support dynamic slot allocation URL: https://github.com/apache/flink/pull/10330#issuecomment-558970102 ## CI report: * 38f2c1c450122cae9aa99258c19c6d07e998 : FAILURE

[GitHub] [flink] carp84 commented on a change in pull request #10447: [FLINK-15084][runtime] Add shared resources tracking to MemoryManager

carp84 commented on a change in pull request #10447: [FLINK-15084][runtime] Add shared resources tracking to MemoryManager URL: https://github.com/apache/flink/pull/10447#discussion_r354428016 ## File path:

[GitHub] [flink] pnowojski opened a new pull request #10448: [hotfix][task] Replace StreamTask#disposed field with a local variable

pnowojski opened a new pull request #10448: [hotfix][task] Replace StreamTask#disposed field with a local variable URL: https://github.com/apache/flink/pull/10448 Replace (volatile) StreamTask#disposed field with a local variable. ## Verifying this change This change is

[GitHub] [flink] StephanEwen commented on a change in pull request #10375: [FLINK-14845][runtime] Introduce data compression to reduce disk and network IO of shuffle.

StephanEwen commented on a change in pull request #10375: [FLINK-14845][runtime] Introduce data compression to reduce disk and network IO of shuffle. URL: https://github.com/apache/flink/pull/10375#discussion_r354436307 ## File path:

[GitHub] [flink] aljoscha commented on issue #10408: [FLINK-14992][client] Add job listener to execution environments

aljoscha commented on issue #10408: [FLINK-14992][client] Add job listener to execution environments URL: https://github.com/apache/flink/pull/10408#issuecomment-562220278 Maybe to outline a bit more how things work: As a user you would write this code when submitting a

[GitHub] [flink] StephanEwen commented on issue #10432: [FLINK-13450][table api] Use StrictMath instead of Math for exp

StephanEwen commented on issue #10432: [FLINK-13450][table api] Use StrictMath instead of Math for exp URL: https://github.com/apache/flink/pull/10432#issuecomment-562217077 Looks good to me, +1 Will merge once the CI builds are green.

[GitHub] [flink] aljoscha commented on issue #10408: [FLINK-14992][client] Add job listener to execution environments

aljoscha commented on issue #10408: [FLINK-14992][client] Add job listener to execution environments URL: https://github.com/apache/flink/pull/10408#issuecomment-562214822 But if the listener just gets the same `JobClient` that the user gets as a return value of `executeAsync()`, you can

[GitHub] [flink] flinkbot edited a comment on issue #10146: [FLINK-14188][runtime] TaskExecutor derive and register with default slot resource profile

flinkbot edited a comment on issue #10146: [FLINK-14188][runtime] TaskExecutor derive and register with default slot resource profile URL: https://github.com/apache/flink/pull/10146#issuecomment-552307115 ## CI report: * 25f9e4b87846e5a736aa329c834f82962e1f50c4 : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes.

flinkbot edited a comment on issue #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes. URL: https://github.com/apache/flink/pull/9984#issuecomment-545881191 ## CI report: * 802ebf37e3d932169f9826b40df483bb5e9ac064 : SUCCESS

[GitHub] [flink] rkhachatryan commented on a change in pull request #10446: [FLINK-15076][task] Fix SourceStreamTask cancellation

rkhachatryan commented on a change in pull request #10446: [FLINK-15076][task] Fix SourceStreamTask cancellation URL: https://github.com/apache/flink/pull/10446#discussion_r354420898 ## File path:

[GitHub] [flink] xintongsong commented on issue #10330: [FLINK-14189][runtime] Extend TaskExecutor to support dynamic slot allocation

xintongsong commented on issue #10330: [FLINK-14189][runtime] Extend TaskExecutor to support dynamic slot allocation URL: https://github.com/apache/flink/pull/10330#issuecomment-562210954 Thanks for the review, @azagrebin. I've updated the PR, addressed your comments, and added a commit

[GitHub] [flink] flinkbot commented on issue #10446: [FLINK-15076][task] Fix SourceStreamTask cancellation

flinkbot commented on issue #10446: [FLINK-15076][task] Fix SourceStreamTask cancellation URL: https://github.com/apache/flink/pull/10446#issuecomment-562210711 ## CI report: * b23a4477442b92ceda70901ab0a3736eefb4b224 : UNKNOWN Bot commands The @flinkbot bot

[GitHub] [flink] rkhachatryan commented on a change in pull request #10446: [FLINK-15076][task] Fix SourceStreamTask cancellation

rkhachatryan commented on a change in pull request #10446: [FLINK-15076][task] Fix SourceStreamTask cancellation URL: https://github.com/apache/flink/pull/10446#discussion_r354422240 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #10436: [FLINK-14920] [flink-end-to-end-perf-tests] Set up environment to run performance e2e tests

flinkbot edited a comment on issue #10436: [FLINK-14920] [flink-end-to-end-perf-tests] Set up environment to run performance e2e tests URL: https://github.com/apache/flink/pull/10436#issuecomment-562103759 ## CI report: * 3441142c77315169ce7a3b48d4d59e710c1016c2 : CANCELED

[GitHub] [flink] flinkbot edited a comment on issue #10441: [FLINK-14857][runtime] Remove checkpoint lock usage from AsyncWaitOperator.

flinkbot edited a comment on issue #10441: [FLINK-14857][runtime] Remove checkpoint lock usage from AsyncWaitOperator. URL: https://github.com/apache/flink/pull/10441#issuecomment-562129081 ## CI report: * d2fa376d69e43da56c4f8605bd663fc4113bc67f : PENDING

[GitHub] [flink] xintongsong commented on issue #10146: [FLINK-14188][runtime] TaskExecutor derive and register with default slot resource profile

xintongsong commented on issue #10146: [FLINK-14188][runtime] TaskExecutor derive and register with default slot resource profile URL: https://github.com/apache/flink/pull/10146#issuecomment-562210380 Thanks for the review, @azagrebin. Comments are addressed.

[GitHub] [flink] flinkbot edited a comment on issue #10427: [FLINK-14566] Enable to get/set whether an operator uses managed memory

flinkbot edited a comment on issue #10427: [FLINK-14566] Enable to get/set whether an operator uses managed memory URL: https://github.com/apache/flink/pull/10427#issuecomment-561973242 ## CI report: * 22ccb31308d510df2bfea3bdee521bbb73949a7b : CANCELED

[GitHub] [flink] flinkbot edited a comment on issue #10422: [FLINK-15057][tests] Set JM and TM memory config in flink-conf.yaml

flinkbot edited a comment on issue #10422: [FLINK-15057][tests] Set JM and TM memory config in flink-conf.yaml URL: https://github.com/apache/flink/pull/10422#issuecomment-561743112 ## CI report: * 88f6f7790d8bb0b517958be4446e95146605c369 : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #10403: [FLINK-14645][table] Support to keep nullability and precision when converting DataTypes to properties

flinkbot edited a comment on issue #10403: [FLINK-14645][table] Support to keep nullability and precision when converting DataTypes to properties URL: https://github.com/apache/flink/pull/10403#issuecomment-561208418 ## CI report: * 038052c833940fbaef3111ed92525216f13edee2 :

[GitHub] [flink] flinkbot commented on issue #10447: [FLINK-15084][runtime] Add shared resources tracking to MemoryManager

flinkbot commented on issue #10447: [FLINK-15084][runtime] Add shared resources tracking to MemoryManager URL: https://github.com/apache/flink/pull/10447#issuecomment-562207982 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to

[GitHub] [flink] walterddr commented on a change in pull request #8746: [hotfix][FLINK-11120][table]fix the bug of timestampadd handles time

walterddr commented on a change in pull request #8746: [hotfix][FLINK-11120][table]fix the bug of timestampadd handles time URL: https://github.com/apache/flink/pull/8746#discussion_r354417812 ## File path:

[GitHub] [flink] walterddr commented on a change in pull request #8746: [hotfix][FLINK-11120][table]fix the bug of timestampadd handles time

walterddr commented on a change in pull request #8746: [hotfix][FLINK-11120][table]fix the bug of timestampadd handles time URL: https://github.com/apache/flink/pull/8746#discussion_r354418398 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #10375: [FLINK-14845][runtime] Introduce data compression to reduce disk and network IO of shuffle.

flinkbot edited a comment on issue #10375: [FLINK-14845][runtime] Introduce data compression to reduce disk and network IO of shuffle. URL: https://github.com/apache/flink/pull/10375#issuecomment-560214201 ## CI report: * af7ab17308bafebf22198881ad59ec4516da43e2 : SUCCESS

[GitHub] [flink] flinkbot edited a comment on issue #10315: [FLINK-14552][table] Enable partition statistics in blink planner

flinkbot edited a comment on issue #10315: [FLINK-14552][table] Enable partition statistics in blink planner URL: https://github.com/apache/flink/pull/10315#issuecomment-558221318 ## CI report: * 05b30617c280796e80e8569dae48b726cddb23d8 : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #10329: [FLINK-12785][StateBackend] RocksDB savepoint recovery can use a lot of unmanaged memory

flinkbot edited a comment on issue #10329: [FLINK-12785][StateBackend] RocksDB savepoint recovery can use a lot of unmanaged memory URL: https://github.com/apache/flink/pull/10329#issuecomment-558970068 ## CI report: * e3aa8e5a567a13f07598ee6fe0e8fb8e72dfb986 : SUCCESS

[jira] [Updated] (FLINK-15084) Let MemoryManager allocate and track shared memory resources

[ https://issues.apache.org/jira/browse/FLINK-15084?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-15084: --- Labels: pull-request-available (was: ) > Let MemoryManager allocate and track shared

[GitHub] [flink] StephanEwen opened a new pull request #10447: [FLINK-15084][runtime] Add shared resources tracking to MemoryManager

StephanEwen opened a new pull request #10447: [FLINK-15084][runtime] Add shared resources tracking to MemoryManager URL: https://github.com/apache/flink/pull/10447 ## What is the purpose of the change This change allows the memory manager to track shared opaque resources form other

[GitHub] [flink] zhuzhurk commented on a change in pull request #10427: [FLINK-14566] Enable to get/set whether an operator uses managed memory

zhuzhurk commented on a change in pull request #10427: [FLINK-14566] Enable to get/set whether an operator uses managed memory URL: https://github.com/apache/flink/pull/10427#discussion_r354416234 ## File path:

[GitHub] [flink] pnowojski commented on a change in pull request #10375: [FLINK-14845][runtime] Introduce data compression to reduce disk and network IO of shuffle.

pnowojski commented on a change in pull request #10375: [FLINK-14845][runtime] Introduce data compression to reduce disk and network IO of shuffle. URL: https://github.com/apache/flink/pull/10375#discussion_r354413514 ## File path:

[GitHub] [flink] pnowojski commented on a change in pull request #10375: [FLINK-14845][runtime] Introduce data compression to reduce disk and network IO of shuffle.

pnowojski commented on a change in pull request #10375: [FLINK-14845][runtime] Introduce data compression to reduce disk and network IO of shuffle. URL: https://github.com/apache/flink/pull/10375#discussion_r354413036 ## File path:

[GitHub] [flink] pnowojski commented on a change in pull request #10375: [FLINK-14845][runtime] Introduce data compression to reduce disk and network IO of shuffle.

pnowojski commented on a change in pull request #10375: [FLINK-14845][runtime] Introduce data compression to reduce disk and network IO of shuffle. URL: https://github.com/apache/flink/pull/10375#discussion_r354407611 ## File path:

[GitHub] [flink] pnowojski commented on a change in pull request #10375: [FLINK-14845][runtime] Introduce data compression to reduce disk and network IO of shuffle.

pnowojski commented on a change in pull request #10375: [FLINK-14845][runtime] Introduce data compression to reduce disk and network IO of shuffle. URL: https://github.com/apache/flink/pull/10375#discussion_r354407611 ## File path:

[GitHub] [flink] pnowojski commented on a change in pull request #10375: [FLINK-14845][runtime] Introduce data compression to reduce disk and network IO of shuffle.

pnowojski commented on a change in pull request #10375: [FLINK-14845][runtime] Introduce data compression to reduce disk and network IO of shuffle. URL: https://github.com/apache/flink/pull/10375#discussion_r354411783 ## File path:

[jira] [Created] (FLINK-15084) Let MemoryManager allocate and track shared memory resources

Stephan Ewen created FLINK-15084: Summary: Let MemoryManager allocate and track shared memory resources Key: FLINK-15084 URL: https://issues.apache.org/jira/browse/FLINK-15084 Project: Flink

[jira] [Created] (FLINK-15083) Fix connectors only pick physical fields from TableSchema

Jark Wu created FLINK-15083: --- Summary: Fix connectors only pick physical fields from TableSchema Key: FLINK-15083 URL: https://issues.apache.org/jira/browse/FLINK-15083 Project: Flink Issue Type:

[GitHub] [flink] flinkbot edited a comment on issue #10146: [FLINK-14188][runtime] TaskExecutor derive and register with default slot resource profile

flinkbot edited a comment on issue #10146: [FLINK-14188][runtime] TaskExecutor derive and register with default slot resource profile URL: https://github.com/apache/flink/pull/10146#issuecomment-552307115 ## CI report: * 25f9e4b87846e5a736aa329c834f82962e1f50c4 : FAILURE

<    1   2   3   4   5   6   7   8   9   10   >