[GitHub] [flink] flinkbot edited a comment on pull request #18394: [FLINK-25520][Table SQL/API] Implement "ALTER TABLE ... COMPACT" SQL

flinkbot edited a comment on pull request #18394: URL: https://github.com/apache/flink/pull/18394#issuecomment-1015323011 ## CI report: * 7da11c60c656bfab79cf3ae76bc56cc729ae24a6 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18407: [FLINK-25669][runtime] Support register operator coordinators for newly initialized ExecutionJobVertex

flinkbot edited a comment on pull request #18407: URL: https://github.com/apache/flink/pull/18407#issuecomment-1017107067 ## CI report: * 1716622b272f2141ee4c29cf978265d8de00fa1b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18360: [FLINK-25329][runtime] Support memory execution graph store in session cluster

flinkbot edited a comment on pull request #18360: URL: https://github.com/apache/flink/pull/18360#issuecomment-1012981724 ## CI report: * 36e5148ffb71691d7c9798b51fb52e88f1927748 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18126: [FLINK-25036][runtime] Introduce vertex wise scheduling strategy

flinkbot edited a comment on pull request #18126: URL: https://github.com/apache/flink/pull/18126#issuecomment-995489268 ## CI report: * 8a780946fc7b1f8657f46dde23f23f642776efa2 Azure:

[jira] [Comment Edited] (FLINK-25649) Scheduling jobs fails with org.apache.flink.runtime.jobmanager.scheduler.NoResourceAvailableException

[ https://issues.apache.org/jira/browse/FLINK-25649?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17480881#comment-17480881 ] Gil De Grove edited comment on FLINK-25649 at 1/24/22, 7:54 AM: Hello

[jira] [Commented] (FLINK-25649) Scheduling jobs fails with org.apache.flink.runtime.jobmanager.scheduler.NoResourceAvailableException

[ https://issues.apache.org/jira/browse/FLINK-25649?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17480881#comment-17480881 ] Gil De Grove commented on FLINK-25649: -- Hello [~trohrmann], [~zhuzh] Thanks for the reply, due to

[jira] [Updated] (FLINK-25649) Scheduling jobs fails with org.apache.flink.runtime.jobmanager.scheduler.NoResourceAvailableException

[ https://issues.apache.org/jira/browse/FLINK-25649?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gil De Grove updated FLINK-25649: - Attachment: flink_scheduler_deadlock.json.zip > Scheduling jobs fails with >

[GitHub] [flink] zjureel commented on pull request #18360: [FLINK-25329][runtime] Support memory execution graph store in session cluster

zjureel commented on pull request #18360: URL: https://github.com/apache/flink/pull/18360#issuecomment-1019809836 Thanks @KarmaGYZ I have updated the codes and add a config option `jobstore.flush-to-disk` in `FileExecutionGraphInfoStore` instead of a memory store -- This is an

[jira] [Closed] (FLINK-22578) deployment configuration page miss content navigate menu

[ https://issues.apache.org/jira/browse/FLINK-22578?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang closed FLINK-22578. Fix Version/s: (was: 1.15.0) (was: 1.13.6) Resolution: Implemented >

[jira] [Reopened] (FLINK-22578) deployment configuration page miss content navigate menu

[ https://issues.apache.org/jira/browse/FLINK-22578?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang reopened FLINK-22578: -- > deployment configuration page miss content navigate menu >

[GitHub] [flink] flinkbot edited a comment on pull request #18407: [FLINK-25669][runtime] Support register operator coordinators for newly initialized ExecutionJobVertex

flinkbot edited a comment on pull request #18407: URL: https://github.com/apache/flink/pull/18407#issuecomment-1017107067 ## CI report: * 1716622b272f2141ee4c29cf978265d8de00fa1b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18360: [FLINK-25329][runtime] Support memory execution graph store in session cluster

flinkbot edited a comment on pull request #18360: URL: https://github.com/apache/flink/pull/18360#issuecomment-1012981724 ## CI report: * 36e5148ffb71691d7c9798b51fb52e88f1927748 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18459: fix syntax errors in joins.md

flinkbot edited a comment on pull request #18459: URL: https://github.com/apache/flink/pull/18459#issuecomment-1019802598 ## CI report: * 0c3df235f0c927490dd0d4917d39092f175e7fd0 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18324: [FLINK-25557][checkpoint] Introduce incremental/full checkpoint size stats

flinkbot edited a comment on pull request #18324: URL: https://github.com/apache/flink/pull/18324#issuecomment-1009752905 ## CI report: * b05c9a39758867364fb4d00a709696785a3f054f Azure:

[jira] [Created] (FLINK-25769) Add internal functions and basic function versioning

Timo Walther created FLINK-25769: Summary: Add internal functions and basic function versioning Key: FLINK-25769 URL: https://issues.apache.org/jira/browse/FLINK-25769 Project: Flink Issue

[jira] [Comment Edited] (FLINK-18356) Exit code 137 returned from process

[ https://issues.apache.org/jira/browse/FLINK-18356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17480871#comment-17480871 ] Yun Gao edited comment on FLINK-18356 at 1/24/22, 7:40 AM: ---

[GitHub] [flink] flinkbot commented on pull request #18459: fix syntax errors in joins.md

flinkbot commented on pull request #18459: URL: https://github.com/apache/flink/pull/18459#issuecomment-1019802598 ## CI report: * 0c3df235f0c927490dd0d4917d39092f175e7fd0 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot commented on pull request #18459: fix syntax errors in joins.md

flinkbot commented on pull request #18459: URL: https://github.com/apache/flink/pull/18459#issuecomment-1019801901 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

[jira] [Commented] (FLINK-18356) Exit code 137 returned from process

[ https://issues.apache.org/jira/browse/FLINK-18356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17480871#comment-17480871 ] Yun Gao commented on FLINK-18356: -

[jira] [Commented] (FLINK-25758) GCS Filesystem implementation fails on Java 11 tests due to licensing issues

[ https://issues.apache.org/jira/browse/FLINK-25758?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17480870#comment-17480870 ] Yun Gao commented on FLINK-25758: -

[GitHub] [flink] JacobAP opened a new pull request #18459: fix syntax errors in joins.md

JacobAP opened a new pull request #18459: URL: https://github.com/apache/flink/pull/18459 flink/docs/content/docs/dev/table/sql/queries/joins.md " update_time TIMESTAMP(3) METADATA FROM `values.source.timestamp` VIRTUAL " change to " update_time TIMESTAMP(3) METADATA FROM

[GitHub] [flink] flinkbot edited a comment on pull request #18119: [FLINK-24947] Support hostNetwork for native K8s integration on session mode

flinkbot edited a comment on pull request #18119: URL: https://github.com/apache/flink/pull/18119#issuecomment-994734000 ## CI report: * 6a4a6c064380db3219fb92805e9a87712bb85fa2 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18157: [FLINK-17808] Rename checkpoint meta file to "_metadata" until it has…

flinkbot edited a comment on pull request #18157: URL: https://github.com/apache/flink/pull/18157#issuecomment-998436589 ## CI report: * a7afbb3176d79338140da86934d9b8cafdb5c1c7 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18454: [hotfix][connector/pulsar] Fix typo in JavaDocs example.

flinkbot edited a comment on pull request #18454: URL: https://github.com/apache/flink/pull/18454#issuecomment-1019661681 ## CI report: * dc8bef8341a40b7c13a8c72a9fd9f70dfd1899a1 Azure:

[jira] [Updated] (FLINK-25768) Python test BlinkBatchTableEnvironmentTests.test_explain_with_multi_sinks failed on azure

[ https://issues.apache.org/jira/browse/FLINK-25768?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-25768: Component/s: Table SQL / Planner > Python test

[jira] [Created] (FLINK-25768) Python test BlinkBatchTableEnvironmentTests.test_explain_with_multi_sinks failed on azure

Yun Gao created FLINK-25768: --- Summary: Python test BlinkBatchTableEnvironmentTests.test_explain_with_multi_sinks failed on azure Key: FLINK-25768 URL: https://issues.apache.org/jira/browse/FLINK-25768

[GitHub] [flink] flinkbot edited a comment on pull request #18376: [FLINK-25668][runtime] Support calcuate network memory for dynamic graph

flinkbot edited a comment on pull request #18376: URL: https://github.com/apache/flink/pull/18376#issuecomment-1014266348 ## CI report: * a415c9901fe5addb7e042b2ea760b2de95c736ca Azure:

[jira] [Commented] (FLINK-25768) Python test BlinkBatchTableEnvironmentTests.test_explain_with_multi_sinks failed on azure

[ https://issues.apache.org/jira/browse/FLINK-25768?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17480861#comment-17480861 ] Yun Gao commented on FLINK-25768: - cc [~hxbks2ks] ~  > Python test

[GitHub] [flink] flinkbot edited a comment on pull request #18376: [FLINK-25668][runtime] Support calcuate network memory for dynamic graph

flinkbot edited a comment on pull request #18376: URL: https://github.com/apache/flink/pull/18376#issuecomment-1014266348 ## CI report: * a415c9901fe5addb7e042b2ea760b2de95c736ca Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18409: [hotfix][dist] Fix that flink-gs-fs-hadoop not included in flink-dist

flinkbot edited a comment on pull request #18409: URL: https://github.com/apache/flink/pull/18409#issuecomment-1017132626 ## CI report: * d5d44917306061cd0bb6db9a20f2d1a4f95b0f94 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18409: [hotfix][dist] Fix that flink-gs-fs-hadoop not included in flink-dist

flinkbot edited a comment on pull request #18409: URL: https://github.com/apache/flink/pull/18409#issuecomment-1017132626 ## CI report: * d5d44917306061cd0bb6db9a20f2d1a4f95b0f94 Azure:

[jira] [Commented] (FLINK-25728) Protential memory leaks in StreamMultipleInputProcessor

[ https://issues.apache.org/jira/browse/FLINK-25728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17480850#comment-17480850 ] Yun Gao commented on FLINK-25728: - Thanks [~wpc009] for reporting the issue! I'll have a look~  >

[GitHub] [flink] flinkbot edited a comment on pull request #18412: [FLINK-25696][datastream] Introduce MetadataPublisher interface to SinkWriter

flinkbot edited a comment on pull request #18412: URL: https://github.com/apache/flink/pull/18412#issuecomment-1017147201 ## CI report: * 256bff679ff13cc486f2f6543745924d23920176 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18409: [hotfix][dist] Fix that flink-gs-fs-hadoop not included in flink-dist

flinkbot edited a comment on pull request #18409: URL: https://github.com/apache/flink/pull/18409#issuecomment-1017132626 ## CI report: * d5d44917306061cd0bb6db9a20f2d1a4f95b0f94 Azure:

[jira] [Commented] (FLINK-25728) Protential memory leaks in StreamMultipleInputProcessor

[ https://issues.apache.org/jira/browse/FLINK-25728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17480848#comment-17480848 ] pc wang commented on FLINK-25728: - [~gaoyunhaii] hello, could you please take a look at this issue?

[GitHub] [flink] flinkbot edited a comment on pull request #18409: [hotfix][dist] Fix that flink-gs-fs-hadoop not included in flink-dist

flinkbot edited a comment on pull request #18409: URL: https://github.com/apache/flink/pull/18409#issuecomment-1017132626 ## CI report: * d5d44917306061cd0bb6db9a20f2d1a4f95b0f94 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18458: [FLINK-21789][network] Make FileChannelManagerImpl#getNextPathNum select data directories fairly

flinkbot edited a comment on pull request #18458: URL: https://github.com/apache/flink/pull/18458#issuecomment-1019767867 ## CI report: * 572d143d54fb5f9c87c5e251e3c2e1816a0249ed Azure:

[GitHub] [flink] flinkbot commented on pull request #18458: [FLINK-21789][network] Make FileChannelManagerImpl#getNextPathNum select data directories fairly

flinkbot commented on pull request #18458: URL: https://github.com/apache/flink/pull/18458#issuecomment-1019767867 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To

[GitHub] [flink] flinkbot edited a comment on pull request #18455: [FLINK-25529][hive] add orc-core dependency specification in hive con…

flinkbot edited a comment on pull request #18455: URL: https://github.com/apache/flink/pull/18455#issuecomment-1019685703 ## CI report: * a739fb9e7bf9856f58be079986d6d19c4c1a11d7 Azure:

[jira] [Updated] (FLINK-25760) Support custom SQL syntax

[ https://issues.apache.org/jira/browse/FLINK-25760?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] melin updated FLINK-25760: -- Description: Supports custom SQL syntax, similar to Spark Extensions Feature. Custom SQL syntax can be

[GitHub] [flink] TanYuxin-tyx opened a new pull request #18458: [FLINK-21789][network] Make FileChannelManagerImpl#getNextPathNum select data directories fairly

TanYuxin-tyx opened a new pull request #18458: URL: https://github.com/apache/flink/pull/18458 ## What is the purpose of the change `FileChannelManagerImpl#getNextPathNum` is not atomic which may cause unfairness of data directory selection. This patch makes the selection of

[jira] [Updated] (FLINK-25760) Support custom SQL syntax

[ https://issues.apache.org/jira/browse/FLINK-25760?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] melin updated FLINK-25760: -- Summary: Support custom SQL syntax (was: Support for extended SQL syntax) > Support custom SQL syntax >

[jira] [Updated] (FLINK-25728) Protential memory leaks in StreamMultipleInputProcessor

[ https://issues.apache.org/jira/browse/FLINK-25728?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] pc wang updated FLINK-25728: Summary: Protential memory leaks in StreamMultipleInputProcessor (was: Protential memory leeks in

[GitHub] [flink] flinkbot edited a comment on pull request #18388: [FLINK-25530][python][connector/pulsar] Support Pulsar source connector in Python DataStream API.

flinkbot edited a comment on pull request #18388: URL: https://github.com/apache/flink/pull/18388#issuecomment-1015205179 ## CI report: * 837b39cfdaf47aeb2f3a1b824bcffc22aff529ce Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18388: [FLINK-25530][python][connector/pulsar] Support Pulsar source connector in Python DataStream API.

flinkbot edited a comment on pull request #18388: URL: https://github.com/apache/flink/pull/18388#issuecomment-1015205179 ## CI report: * 837b39cfdaf47aeb2f3a1b824bcffc22aff529ce Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18157: [FLINK-17808] Rename checkpoint meta file to "_metadata" until it has…

flinkbot edited a comment on pull request #18157: URL: https://github.com/apache/flink/pull/18157#issuecomment-998436589 ## CI report: * bdbbf550bb2fa01fdfad3d1e64ee08cff4a2fb0e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18157: [FLINK-17808] Rename checkpoint meta file to "_metadata" until it has…

flinkbot edited a comment on pull request #18157: URL: https://github.com/apache/flink/pull/18157#issuecomment-998436589 ## CI report: * bdbbf550bb2fa01fdfad3d1e64ee08cff4a2fb0e Azure:

[GitHub] [flink] curcur commented on a change in pull request #18431: [FLINK-25024][docs] Add Changelog backend docs

curcur commented on a change in pull request #18431: URL: https://github.com/apache/flink/pull/18431#discussion_r790412520 ## File path: docs/content/docs/ops/state/state_backends.md ## @@ -325,6 +325,126 @@ public class MyOptionsFactory implements

[jira] [Commented] (FLINK-25767) Translation of page 'Working with State' is incomplete

[ https://issues.apache.org/jira/browse/FLINK-25767?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17480830#comment-17480830 ] Yun Tang commented on FLINK-25767: -- [~paul8263] already assigned to you, please go ahead. >

[jira] [Assigned] (FLINK-25767) Translation of page 'Working with State' is incomplete

[ https://issues.apache.org/jira/browse/FLINK-25767?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang reassigned FLINK-25767: Assignee: Yao Zhang > Translation of page 'Working with State' is incomplete >

[GitHub] [flink] flinkbot edited a comment on pull request #17452: [FLINK-20732][connector/pulsar] Introduction of Pulsar Sink

flinkbot edited a comment on pull request #17452: URL: https://github.com/apache/flink/pull/17452#issuecomment-940136217 ## CI report: * c8820e335d23677ffb548b0d1fa8771fa7c1bce1 Azure:

[jira] [Comment Edited] (FLINK-25761) Translate Avro format page into Chinese.

[ https://issues.apache.org/jira/browse/FLINK-25761?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17480460#comment-17480460 ] Zhiwu Wang edited comment on FLINK-25761 at 1/24/22, 6:12 AM: --

[GitHub] [flink] flinkbot edited a comment on pull request #18457: [FLINK-14902][code] Supports jdbc async lookup join

flinkbot edited a comment on pull request #18457: URL: https://github.com/apache/flink/pull/18457#issuecomment-1019749225 ## CI report: * 1ff6b7fdc37a68de37d05a96a922ae4fb56055b0 Azure:

[GitHub] [flink] flinkbot commented on pull request #18457: [FLINK-14902][code] Supports jdbc async lookup join

flinkbot commented on pull request #18457: URL: https://github.com/apache/flink/pull/18457#issuecomment-1019749225 ## CI report: * 1ff6b7fdc37a68de37d05a96a922ae4fb56055b0 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #18409: [hotfix][dist] Fix that flink-gs-fs-hadoop not included in flink-dist

flinkbot edited a comment on pull request #18409: URL: https://github.com/apache/flink/pull/18409#issuecomment-1017132626 ## CI report: * d5d44917306061cd0bb6db9a20f2d1a4f95b0f94 Azure:

[GitHub] [flink] flinkbot commented on pull request #18457: [FLINK-14902][code] Supports jdbc async lookup join

flinkbot commented on pull request #18457: URL: https://github.com/apache/flink/pull/18457#issuecomment-1019748804 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

[GitHub] [flink] flinkbot edited a comment on pull request #18409: [hotfix][dist] Fix that flink-gs-fs-hadoop not included in flink-dist

flinkbot edited a comment on pull request #18409: URL: https://github.com/apache/flink/pull/18409#issuecomment-1017132626 ## CI report: * d5d44917306061cd0bb6db9a20f2d1a4f95b0f94 Azure:

[GitHub] [flink] ranqiqiang opened a new pull request #18457: [FLINK-14902][code] Supports jdbc async lookup join

ranqiqiang opened a new pull request #18457: URL: https://github.com/apache/flink/pull/18457 ## **What is the purpose of the change** JdbcTableSource supports jdbc async look up join ## **Brief change log** 1.add class JdbcRowDataAsyncLookupFunction 2.add class

[GitHub] [flink] ranqiqiang commented on pull request #18268: [FLINK-14902][connector] Supports jdbc async lookup join

ranqiqiang commented on pull request #18268: URL: https://github.com/apache/flink/pull/18268#issuecomment-1019745078 Found a bug ,resubmit the pr -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go

[GitHub] [flink] ranqiqiang closed pull request #18268: [FLINK-14902][connector] Supports jdbc async lookup join

ranqiqiang closed pull request #18268: URL: https://github.com/apache/flink/pull/18268 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

[GitHub] [flink] flinkbot edited a comment on pull request #18414: [hotfix][docs]fix flink sql Cascading Window TVF Aggregation exception

flinkbot edited a comment on pull request #18414: URL: https://github.com/apache/flink/pull/18414#issuecomment-1017182067 ## CI report: * 2d7b1b7425be2b9cfb9020d92cf08cc6d5596ef6 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18414: [hotfix][docs]fix flink sql Cascading Window TVF Aggregation exception

flinkbot edited a comment on pull request #18414: URL: https://github.com/apache/flink/pull/18414#issuecomment-1017182067 ## CI report: * 2d7b1b7425be2b9cfb9020d92cf08cc6d5596ef6 Azure:

[GitHub] [flink] simenliuxing commented on a change in pull request #18414: [hotfix][docs]fix flink sql Cascading Window TVF Aggregation exception

simenliuxing commented on a change in pull request #18414: URL: https://github.com/apache/flink/pull/18414#discussion_r790426803 ## File path: docs/content.zh/docs/dev/table/sql/queries/window-agg.md ## @@ -199,7 +199,8 @@ The following shows a cascading window aggregation

[GitHub] [flink] deadwind4 commented on a change in pull request #18388: [FLINK-25530][python][connector/pulsar] Support Pulsar source connector in Python DataStream API.

deadwind4 commented on a change in pull request #18388: URL: https://github.com/apache/flink/pull/18388#discussion_r790425806 ## File path: flink-python/pyflink/datastream/tests/test_connectors.py ## @@ -149,6 +150,80 @@ def tearDown(self):

[GitHub] [flink] wanglijie95 commented on a change in pull request #18376: [FLINK-25668][runtime] Support calcuate network memory for dynamic graph

wanglijie95 commented on a change in pull request #18376: URL: https://github.com/apache/flink/pull/18376#discussion_r790425616 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/SsgNetworkMemoryCalculationUtils.java ## @@ -148,6 +161,78 @@ private

[GitHub] [flink] wanglijie95 commented on a change in pull request #18376: [FLINK-25668][runtime] Support calcuate network memory for dynamic graph

wanglijie95 commented on a change in pull request #18376: URL: https://github.com/apache/flink/pull/18376#discussion_r790425616 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/SsgNetworkMemoryCalculationUtils.java ## @@ -148,6 +161,78 @@ private

[GitHub] [flink] wanglijie95 commented on a change in pull request #18376: [FLINK-25668][runtime] Support calcuate network memory for dynamic graph

wanglijie95 commented on a change in pull request #18376: URL: https://github.com/apache/flink/pull/18376#discussion_r790425357 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/SsgNetworkMemoryCalculationUtils.java ## @@ -148,6 +161,78 @@ private

[GitHub] [flink] wanglijie95 commented on a change in pull request #18376: [FLINK-25668][runtime] Support calcuate network memory for dynamic graph

wanglijie95 commented on a change in pull request #18376: URL: https://github.com/apache/flink/pull/18376#discussion_r790424936 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/SsgNetworkMemoryCalculationUtils.java ## @@ -148,6 +161,78 @@ private

[jira] [Commented] (FLINK-13550) Support for CPU FlameGraphs in web UI

[ https://issues.apache.org/jira/browse/FLINK-13550?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17480821#comment-17480821 ] jackylau commented on FLINK-13550: -- hi [~afedulov] do you have any thoughts the comments i add >

[jira] [Comment Edited] (FLINK-13550) Support for CPU FlameGraphs in web UI

[ https://issues.apache.org/jira/browse/FLINK-13550?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17472570#comment-17472570 ] jackylau edited comment on FLINK-13550 at 1/24/22, 5:29 AM: hi [~dmvk] ,

[GitHub] [flink] flinkbot edited a comment on pull request #18453: [FLINK-25562][hive] add detail explanation about bundled hive jar to …

flinkbot edited a comment on pull request #18453: URL: https://github.com/apache/flink/pull/18453#issuecomment-1019659584 ## CI report: * 653b4f8de5758180898ee04fde4d2870770f1a9e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18388: [FLINK-25530][python][connector/pulsar] Support Pulsar source connector in Python DataStream API.

flinkbot edited a comment on pull request #18388: URL: https://github.com/apache/flink/pull/18388#issuecomment-1015205179 ## CI report: * 837b39cfdaf47aeb2f3a1b824bcffc22aff529ce Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18157: [FLINK-17808] Rename checkpoint meta file to "_metadata" until it has…

flinkbot edited a comment on pull request #18157: URL: https://github.com/apache/flink/pull/18157#issuecomment-998436589 ## CI report: * bdbbf550bb2fa01fdfad3d1e64ee08cff4a2fb0e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18388: [FLINK-25530][python][connector/pulsar] Support Pulsar source connector in Python DataStream API.

flinkbot edited a comment on pull request #18388: URL: https://github.com/apache/flink/pull/18388#issuecomment-1015205179 ## CI report: * 837b39cfdaf47aeb2f3a1b824bcffc22aff529ce Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18157: [FLINK-17808] Rename checkpoint meta file to "_metadata" until it has…

flinkbot edited a comment on pull request #18157: URL: https://github.com/apache/flink/pull/18157#issuecomment-998436589 ## CI report: * bdbbf550bb2fa01fdfad3d1e64ee08cff4a2fb0e Azure:

[GitHub] [flink] zuston commented on a change in pull request #18157: [FLINK-17808] Rename checkpoint meta file to "_metadata" until it has…

zuston commented on a change in pull request #18157: URL: https://github.com/apache/flink/pull/18157#discussion_r790413135 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/state/filesystem/FsCheckpointMetadataOutputStream.java ## @@ -162,4 +161,20 @@ public

[GitHub] [flink] zuston commented on a change in pull request #18157: [FLINK-17808] Rename checkpoint meta file to "_metadata" until it has…

zuston commented on a change in pull request #18157: URL: https://github.com/apache/flink/pull/18157#discussion_r790413069 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/state/filesystem/FsCheckpointMetadataOutputStream.java ## @@ -162,4 +161,20 @@ public

[GitHub] [flink] flinkbot edited a comment on pull request #18388: [FLINK-25530][python][connector/pulsar] Support Pulsar source connector in Python DataStream API.

flinkbot edited a comment on pull request #18388: URL: https://github.com/apache/flink/pull/18388#issuecomment-1015205179 ## CI report: * 837b39cfdaf47aeb2f3a1b824bcffc22aff529ce Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18388: [FLINK-25530][python][connector/pulsar] Support Pulsar source connector in Python DataStream API.

flinkbot edited a comment on pull request #18388: URL: https://github.com/apache/flink/pull/18388#issuecomment-1015205179 ## CI report: * 837b39cfdaf47aeb2f3a1b824bcffc22aff529ce Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18388: [FLINK-25530][python][connector/pulsar] Support Pulsar source connector in Python DataStream API.

flinkbot edited a comment on pull request #18388: URL: https://github.com/apache/flink/pull/18388#issuecomment-1015205179 ## CI report: * 837b39cfdaf47aeb2f3a1b824bcffc22aff529ce Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18388: [FLINK-25530][python][connector/pulsar] Support Pulsar source connector in Python DataStream API.

flinkbot edited a comment on pull request #18388: URL: https://github.com/apache/flink/pull/18388#issuecomment-1015205179 ## CI report: * 837b39cfdaf47aeb2f3a1b824bcffc22aff529ce Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18388: [FLINK-25530][python][connector/pulsar] Support Pulsar source connector in Python DataStream API.

flinkbot edited a comment on pull request #18388: URL: https://github.com/apache/flink/pull/18388#issuecomment-1015205179 ## CI report: * 837b39cfdaf47aeb2f3a1b824bcffc22aff529ce Azure:

[GitHub] [flink] deadwind4 commented on a change in pull request #18388: [FLINK-25530][python][connector/pulsar] Support Pulsar source connector in Python DataStream API.

deadwind4 commented on a change in pull request #18388: URL: https://github.com/apache/flink/pull/18388#discussion_r790406471 ## File path: flink-python/pyflink/datastream/connectors.py ## @@ -1079,6 +1085,320 @@ def for_row_format(base_path: str, encoder: Encoder) ->

[GitHub] [flink] flinkbot edited a comment on pull request #18388: [FLINK-25530][python][connector/pulsar] Support Pulsar source connector in Python DataStream API.

flinkbot edited a comment on pull request #18388: URL: https://github.com/apache/flink/pull/18388#issuecomment-1015205179 ## CI report: * 837b39cfdaf47aeb2f3a1b824bcffc22aff529ce Azure:

[jira] [Commented] (FLINK-25577) Update GCS documentation

[ https://issues.apache.org/jira/browse/FLINK-25577?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17480813#comment-17480813 ] Xintong Song commented on FLINK-25577: -- [~galenwarren], The release notes can only be added when

[GitHub] [flink] flinkbot edited a comment on pull request #18361: [FLINK-25631][table] Support enhanced `show tables` syntax

flinkbot edited a comment on pull request #18361: URL: https://github.com/apache/flink/pull/18361#issuecomment-1012985152 ## CI report: * a99d1e2258fda0f16b582210a3ab7bd950506aed Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18412: [FLINK-25696][datastream] Introduce MetadataPublisher interface to SinkWriter

flinkbot edited a comment on pull request #18412: URL: https://github.com/apache/flink/pull/18412#issuecomment-1017147201 ## CI report: * 91a7a1406e7d09b6914bff1caeaf4ec92a798d8d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18388: [FLINK-25530][python][connector/pulsar] Support Pulsar source connector in Python DataStream API.

flinkbot edited a comment on pull request #18388: URL: https://github.com/apache/flink/pull/18388#issuecomment-1015205179 ## CI report: * 837b39cfdaf47aeb2f3a1b824bcffc22aff529ce Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18268: [FLINK-14902][connector] Supports jdbc async lookup join

flinkbot edited a comment on pull request #18268: URL: https://github.com/apache/flink/pull/18268#issuecomment-1005479356 ## CI report: * f64a2fe9f7c1ca9a041641256dc09d00253ce837 UNKNOWN * 259aeca4d91fc0adfaef93fdba9aa872a866a3c8 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18388: [FLINK-25530][python][connector/pulsar] Support Pulsar source connector in Python DataStream API.

flinkbot edited a comment on pull request #18388: URL: https://github.com/apache/flink/pull/18388#issuecomment-1015205179 ## CI report: * 837b39cfdaf47aeb2f3a1b824bcffc22aff529ce Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18412: [FLINK-25696][datastream] Introduce MetadataPublisher interface to SinkWriter

flinkbot edited a comment on pull request #18412: URL: https://github.com/apache/flink/pull/18412#issuecomment-1017147201 ## CI report: * 91a7a1406e7d09b6914bff1caeaf4ec92a798d8d Azure:

[GitHub] [flink] xintongsong commented on pull request #15599: [FLINK-11838][flink-gs-fs-hadoop] Create Google Storage file system with recoverable writer support

xintongsong commented on pull request #15599: URL: https://github.com/apache/flink/pull/15599#issuecomment-1019700632 @galenwarren, sorry for the late response. I was OoO the past a few days. > The change I'd propose to help @sap1ens (or anyone else who used the pre-released code)

[GitHub] [flink] flinkbot edited a comment on pull request #18268: [FLINK-14902][connector] Supports jdbc async lookup join

flinkbot edited a comment on pull request #18268: URL: https://github.com/apache/flink/pull/18268#issuecomment-1005479356 ## CI report: * f64a2fe9f7c1ca9a041641256dc09d00253ce837 UNKNOWN * 259aeca4d91fc0adfaef93fdba9aa872a866a3c8 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18119: [FLINK-24947] Support hostNetwork for native K8s integration on session mode

flinkbot edited a comment on pull request #18119: URL: https://github.com/apache/flink/pull/18119#issuecomment-994734000 ## CI report: * c15632cf1ee4b38d0060a87c3bedb5cb4d545264 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18388: [FLINK-25530][python][connector/pulsar] Support Pulsar source connector in Python DataStream API.

flinkbot edited a comment on pull request #18388: URL: https://github.com/apache/flink/pull/18388#issuecomment-1015205179 ## CI report: * 837b39cfdaf47aeb2f3a1b824bcffc22aff529ce Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18268: [FLINK-14902][connector] Supports jdbc async lookup join

flinkbot edited a comment on pull request #18268: URL: https://github.com/apache/flink/pull/18268#issuecomment-1005479356 ## CI report: * f64a2fe9f7c1ca9a041641256dc09d00253ce837 UNKNOWN * 259aeca4d91fc0adfaef93fdba9aa872a866a3c8 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18119: [FLINK-24947] Support hostNetwork for native K8s integration on session mode

flinkbot edited a comment on pull request #18119: URL: https://github.com/apache/flink/pull/18119#issuecomment-994734000 ## CI report: * c15632cf1ee4b38d0060a87c3bedb5cb4d545264 Azure:

[GitHub] [flink] Myasuka commented on a change in pull request #18157: [FLINK-17808] Rename checkpoint meta file to "_metadata" until it has…

Myasuka commented on a change in pull request #18157: URL: https://github.com/apache/flink/pull/18157#discussion_r790401088 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/state/filesystem/FsCheckpointMetadataOutputStream.java ## @@ -162,4 +161,20 @@ public

[GitHub] [flink] flinkbot edited a comment on pull request #18456: [FLINK-21790][network] Shuffle data directories to make directory selection of different TaskManagers fairer

flinkbot edited a comment on pull request #18456: URL: https://github.com/apache/flink/pull/18456#issuecomment-1019691654 ## CI report: * cd74a88227edf6a00098a9d651634e009ac3fe9f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18388: [FLINK-25530][python][connector/pulsar] Support Pulsar source connector in Python DataStream API.

flinkbot edited a comment on pull request #18388: URL: https://github.com/apache/flink/pull/18388#issuecomment-1015205179 ## CI report: * 837b39cfdaf47aeb2f3a1b824bcffc22aff529ce Azure:

  1   2   3   >