[GitHub] [flink] Thesharing commented on a diff in pull request #22674: [FLINK-32201][runtime]Automatically determine if the shuffle descriptor needs to be offloaded by the blob server based on the nu

Thesharing commented on code in PR #22674: URL: https://github.com/apache/flink/pull/22674#discussion_r1209723546 ## flink-runtime/src/main/java/org/apache/flink/runtime/deployment/CachedShuffleDescriptors.java: ## @@ -104,4 +122,14 @@ public void

[GitHub] [flink] reswqa commented on a diff in pull request #22501: [FLINK-31637][network] Implement the BufferAccumulator for the tiered storage

reswqa commented on code in PR #22501: URL: https://github.com/apache/flink/pull/22501#discussion_r1209718857 ## flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/storage/HashBufferAccumulator.java: ## @@ -0,0 +1,112 @@ +/* + * Licensed to

[jira] [Created] (FLINK-32215) Date format in flink-statefun startupPosition documentation is incorrect

Leijurv created FLINK-32215: --- Summary: Date format in flink-statefun startupPosition documentation is incorrect Key: FLINK-32215 URL: https://issues.apache.org/jira/browse/FLINK-32215 Project: Flink

[GitHub] [flink] FangYongs commented on pull request #22671: [FLINK-32211][sql-client] Supports row format in executor

FangYongs commented on PR #22671: URL: https://github.com/apache/flink/pull/22671#issuecomment-1567720336 Hi @libenchao Please help to review this PR when you are free, thanks -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

[GitHub] [flink] TanYuxin-tyx commented on pull request #22501: [FLINK-31637][network] Implement the BufferAccumulator for the tiered storage

TanYuxin-tyx commented on PR #22501: URL: https://github.com/apache/flink/pull/22501#issuecomment-1567713695 @xintongsong Thanks a lot for the quick review. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

[jira] [Created] (FLINK-32214) Fetch more info in the FlinkDeployment status by using the overview API

Xin Hao created FLINK-32214: --- Summary: Fetch more info in the FlinkDeployment status by using the overview API Key: FLINK-32214 URL: https://issues.apache.org/jira/browse/FLINK-32214 Project: Flink

[jira] [Updated] (FLINK-31640) Write the accumulated buffers to the right storage tier

[ https://issues.apache.org/jira/browse/FLINK-31640?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuxin Tan updated FLINK-31640: -- Summary: Write the accumulated buffers to the right storage tier (was: Introduce segment index

[GitHub] [flink-ml] zhipeng93 commented on a diff in pull request #237: [Flink-27826] Support training very high dimensional logistic regression

zhipeng93 commented on code in PR #237: URL: https://github.com/apache/flink-ml/pull/237#discussion_r1209661397 ## flink-ml-lib/src/main/java/org/apache/flink/ml/common/ps/message/MessageUtils.java: ## @@ -0,0 +1,123 @@ +/* + * Licensed to the Apache Software Foundation (ASF)

[GitHub] [flink-ml] zhipeng93 commented on a diff in pull request #237: [Flink-27826] Support training very high dimensional logistic regression

zhipeng93 commented on code in PR #237: URL: https://github.com/apache/flink-ml/pull/237#discussion_r1209650931 ## flink-ml-lib/src/main/java/org/apache/flink/ml/common/ps/message/MessageType.java: ## @@ -0,0 +1,48 @@ +/* + * Licensed to the Apache Software Foundation (ASF)

[GitHub] [flink] flinkbot commented on pull request #22675: [FLINK-32211][core] Add get off heap buffer in segment

flinkbot commented on PR #22675: URL: https://github.com/apache/flink/pull/22675#issuecomment-1567669992 ## CI report: * 8856bd988ad35e6a947f2be5659dbbc993c1cbe2 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Commented] (FLINK-26541) SQL Client should support submitting SQL jobs in application mode

[ https://issues.apache.org/jira/browse/FLINK-26541?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17727239#comment-17727239 ] Paul Lin commented on FLINK-26541: -- I've created

[GitHub] [flink] FangYongs opened a new pull request, #22675: [FLINK-32211][core] Add get off heap buffer in segment

FangYongs opened a new pull request, #22675: URL: https://github.com/apache/flink/pull/22675 ## What is the purpose of the change This PR aims to add `getOffHeapBuffer` in `MemorySegment` and iceberg/paimon sink operator can create writer buffer with managed memory in Flink

[GitHub] [flink-ml] Fanoid commented on a diff in pull request #210: [FLINK-31010] Add Transformer and Estimator for GBTClassifier and GBTRegressor

Fanoid commented on code in PR #210: URL: https://github.com/apache/flink-ml/pull/210#discussion_r1206315147 ## flink-ml-core/src/main/java/org/apache/flink/ml/common/sharedobjects/SharedObjectsStreamOperator.java: ## @@ -0,0 +1,38 @@ +/* + * Licensed to the Apache Software

[jira] [Created] (FLINK-32213) Add get off heap buffer in memory segment

Fang Yong created FLINK-32213: - Summary: Add get off heap buffer in memory segment Key: FLINK-32213 URL: https://issues.apache.org/jira/browse/FLINK-32213 Project: Flink Issue Type: Improvement

[GitHub] [flink-ml] Fanoid commented on a diff in pull request #210: [FLINK-31010] Add Transformer and Estimator for GBTClassifier and GBTRegressor

Fanoid commented on code in PR #210: URL: https://github.com/apache/flink-ml/pull/210#discussion_r1209635209 ## flink-ml-lib/src/main/java/org/apache/flink/ml/common/gbt/GBTRunner.java: ## @@ -0,0 +1,304 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one + *

[GitHub] [flink-ml] Fanoid commented on a diff in pull request #210: [FLINK-31010] Add Transformer and Estimator for GBTClassifier and GBTRegressor

Fanoid commented on code in PR #210: URL: https://github.com/apache/flink-ml/pull/210#discussion_r1209634597 ## flink-ml-lib/src/main/java/org/apache/flink/ml/common/gbt/GBTRunner.java: ## @@ -0,0 +1,304 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one + *

[jira] (FLINK-32194) Elasticsearch connector should remove the dependency on flink-shaded

[ https://issues.apache.org/jira/browse/FLINK-32194 ] Yuxin Tan deleted comment on FLINK-32194: --- was (Author: tanyuxin): [~Sergey Nuyanzin]  Could you help review this change? It is also like FLINK-32187. > Elasticsearch connector should remove

[GitHub] [flink-ml] zhipeng93 commented on a diff in pull request #237: [Flink-27826] Support training very high dimensional logistic regression

zhipeng93 commented on code in PR #237: URL: https://github.com/apache/flink-ml/pull/237#discussion_r1209272423 ## flink-ml-lib/src/main/java/org/apache/flink/ml/common/ps/MirrorWorkerOperator.java: ## @@ -0,0 +1,122 @@ +/* + * Licensed to the Apache Software Foundation (ASF)

[GitHub] [flink-ml] zhipeng93 commented on a diff in pull request #237: [Flink-27826] Support training very high dimensional logistic regression

zhipeng93 commented on code in PR #237: URL: https://github.com/apache/flink-ml/pull/237#discussion_r1209272423 ## flink-ml-lib/src/main/java/org/apache/flink/ml/common/ps/MirrorWorkerOperator.java: ## @@ -0,0 +1,122 @@ +/* + * Licensed to the Apache Software Foundation (ASF)

[GitHub] [flink] FangYongs commented on pull request #22583: [FLINK-31673][jdbc-driver] Add e2e test for flink jdbc driver

FangYongs commented on PR #22583: URL: https://github.com/apache/flink/pull/22583#issuecomment-1567634131 Thanks @libenchao Sounds good to me, I'll move it there -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

[jira] [Updated] (FLINK-32212) Job restarting indefinitely after an IllegalStateException from BlobLibraryCacheManager

[ https://issues.apache.org/jira/browse/FLINK-32212?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matheus Felisberto updated FLINK-32212: --- Description: After running for a few hours the job starts to throw

[jira] [Updated] (FLINK-32212) Job restarting indefinitely after an IllegalStateException from BlobLibraryCacheManager

[ https://issues.apache.org/jira/browse/FLINK-32212?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matheus Felisberto updated FLINK-32212: --- Description: After running for a few hours the job starts to throw

[jira] [Updated] (FLINK-32212) Job restarting indefinitely after an IllegalStateException from BlobLibraryCacheManager

[ https://issues.apache.org/jira/browse/FLINK-32212?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matheus Felisberto updated FLINK-32212: --- Environment: Apache Flink Kubernetes Operator 1.4 (was: I'm running my workload on

[jira] [Created] (FLINK-32212) Job restarting indefinitely after an IllegalStateException from BlobLibraryCacheManager

Matheus Felisberto created FLINK-32212: -- Summary: Job restarting indefinitely after an IllegalStateException from BlobLibraryCacheManager Key: FLINK-32212 URL:

[GitHub] [flink-connector-jdbc] eskabetxe commented on a diff in pull request #8: [FLINK-14102] Introduce DB2Dialect.

eskabetxe commented on code in PR #8: URL: https://github.com/apache/flink-connector-jdbc/pull/8#discussion_r1209311925 ## flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/internal/converter/Db2RowConverter.java: ## @@ -0,0 +1,46 @@ +/* + * Licensed to the

[GitHub] [flink-connector-jdbc] eskabetxe commented on a diff in pull request #3: [FLINK-15462][connectors] Add Trino dialect

eskabetxe commented on code in PR #3: URL: https://github.com/apache/flink-connector-jdbc/pull/3#discussion_r1209310699 ## flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/dialect/trino/TrinoPreparedStatementTest.java: ## @@ -0,0 +1,153 @@ +/* + * Licensed to

[GitHub] [flink-connector-jdbc] eskabetxe commented on a diff in pull request #3: [FLINK-15462][connectors] Add Trino dialect

eskabetxe commented on code in PR #3: URL: https://github.com/apache/flink-connector-jdbc/pull/3#discussion_r1209310393 ## flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/dialect/trino/TrinoDialect.java: ## @@ -0,0 +1,112 @@ +/* + * Licensed to the Apache

[GitHub] [flink] WencongLiu commented on a diff in pull request #22342: [FLINK-31636][network] Upstream supports reading buffers from tiered store

WencongLiu commented on code in PR #22342: URL: https://github.com/apache/flink/pull/22342#discussion_r1209306292 ## flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/netty/ConsumerNettyService.java: ## @@ -0,0 +1,65 @@ +/* + * Licensed to

[GitHub] [flink] WencongLiu commented on a diff in pull request #22342: [FLINK-31636][network] Upstream supports reading buffers from tiered store

WencongLiu commented on code in PR #22342: URL: https://github.com/apache/flink/pull/22342#discussion_r1209305502 ## flink-runtime/src/main/java/org/apache/flink/runtime/io/network/api/EndOfSegmentEvent.java: ## @@ -0,0 +1,64 @@ +/* + * Licensed to the Apache Software

[GitHub] [flink] TanYuxin-tyx commented on a diff in pull request #22342: [FLINK-31636][network] Upstream supports reading buffers from tiered store

TanYuxin-tyx commented on code in PR #22342: URL: https://github.com/apache/flink/pull/22342#discussion_r1209299273 ## flink-runtime/src/main/java/org/apache/flink/runtime/io/network/api/EndOfSegmentEvent.java: ## @@ -0,0 +1,64 @@ +/* + * Licensed to the Apache Software

[GitHub] [flink-ml] zhipeng93 commented on a diff in pull request #237: [Flink-27826] Support training very high dimensional logistic regression

zhipeng93 commented on code in PR #237: URL: https://github.com/apache/flink-ml/pull/237#discussion_r1209272423 ## flink-ml-lib/src/main/java/org/apache/flink/ml/common/ps/MirrorWorkerOperator.java: ## @@ -0,0 +1,122 @@ +/* + * Licensed to the Apache Software Foundation (ASF)

[GitHub] [flink-ml] zhipeng93 commented on a diff in pull request #237: [Flink-27826] Support training very high dimensional logistic regression

zhipeng93 commented on code in PR #237: URL: https://github.com/apache/flink-ml/pull/237#discussion_r1209272423 ## flink-ml-lib/src/main/java/org/apache/flink/ml/common/ps/MirrorWorkerOperator.java: ## @@ -0,0 +1,122 @@ +/* + * Licensed to the Apache Software Foundation (ASF)

[GitHub] [flink-ml] zhipeng93 commented on a diff in pull request #237: [Flink-27826] Support training very high dimensional logistic regression

zhipeng93 commented on code in PR #237: URL: https://github.com/apache/flink-ml/pull/237#discussion_r1209268250 ## flink-ml-lib/src/main/java/org/apache/flink/ml/common/ps/message/ZerosToPushM.java: ## @@ -0,0 +1,76 @@ +/* + * Licensed to the Apache Software Foundation (ASF)

[GitHub] [flink-ml] zhipeng93 commented on a diff in pull request #237: [Flink-27826] Support training very high dimensional logistic regression

zhipeng93 commented on code in PR #237: URL: https://github.com/apache/flink-ml/pull/237#discussion_r1209262254 ## flink-ml-servable-lib/src/main/java/org/apache/flink/ml/classification/logisticregression/LogisticRegressionModelServable.java: ## @@ -81,11 +82,49 @@ public

[GitHub] [flink-ml] zhipeng93 commented on a diff in pull request #237: [Flink-27826] Support training very high dimensional logistic regression

zhipeng93 commented on code in PR #237: URL: https://github.com/apache/flink-ml/pull/237#discussion_r1209259740 ## flink-ml-servable-core/src/main/java/org/apache/flink/ml/common/feature/LabeledLargePointWithWeight.java: ## @@ -0,0 +1,40 @@ +/* + * Licensed to the Apache

[GitHub] [flink] zhougit86 commented on pull request #22624: [FLINK-32132][table-planner] Cast function CODEGEN does not work as e…

zhougit86 commented on PR #22624: URL: https://github.com/apache/flink/pull/22624#issuecomment-1567066058 @snuyanzin Hi Master, Could you please help review the test case and let me know if it makes sense -- This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink-ml] zhipeng93 commented on a diff in pull request #237: [Flink-27826] Support training very high dimensional logistic regression

zhipeng93 commented on code in PR #237: URL: https://github.com/apache/flink-ml/pull/237#discussion_r1209259740 ## flink-ml-servable-core/src/main/java/org/apache/flink/ml/common/feature/LabeledLargePointWithWeight.java: ## @@ -0,0 +1,40 @@ +/* + * Licensed to the Apache

[GitHub] [flink-connector-elasticsearch] TanYuxin-tyx commented on pull request #65: [FLINK-32194][connectors/elasticsearch] Remove the dependency on flink-shaded

TanYuxin-tyx commented on PR #65: URL: https://github.com/apache/flink-connector-elasticsearch/pull/65#issuecomment-1567063394 @reswqa Thanks a lot for the quick review. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

[GitHub] [flink-connector-jdbc] WenDing-Y commented on pull request #49: [FLINK-32068] connector jdbc support clickhouse

WenDing-Y commented on PR #49: URL: https://github.com/apache/flink-connector-jdbc/pull/49#issuecomment-1567061806 Please help me review, thank you very much @snuyanzin -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

[GitHub] [flink-ml] zhipeng93 commented on a diff in pull request #237: [Flink-27826] Support training very high dimensional logistic regression

zhipeng93 commented on code in PR #237: URL: https://github.com/apache/flink-ml/pull/237#discussion_r1209256528 ## flink-ml-lib/src/main/java/org/apache/flink/ml/classification/logisticregression/LogisticRegressionWithFtrl.java: ## @@ -0,0 +1,380 @@ +/* + * Licensed to the

[GitHub] [flink-ml] zhipeng93 commented on a diff in pull request #237: [Flink-27826] Support training very high dimensional logistic regression

zhipeng93 commented on code in PR #237: URL: https://github.com/apache/flink-ml/pull/237#discussion_r1209256528 ## flink-ml-lib/src/main/java/org/apache/flink/ml/classification/logisticregression/LogisticRegressionWithFtrl.java: ## @@ -0,0 +1,380 @@ +/* + * Licensed to the

[GitHub] [flink] TanYuxin-tyx commented on a diff in pull request #22501: [FLINK-31637][network] Implement the BufferAccumulator for the tiered storage

TanYuxin-tyx commented on code in PR #22501: URL: https://github.com/apache/flink/pull/22501#discussion_r1209256140 ## flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/storage/HashBufferAccumulator.java: ## @@ -0,0 +1,95 @@ +/* + *

[GitHub] [flink] TanYuxin-tyx commented on a diff in pull request #22501: [FLINK-31637][network] Implement the BufferAccumulator for the tiered storage

TanYuxin-tyx commented on code in PR #22501: URL: https://github.com/apache/flink/pull/22501#discussion_r1209254305 ## flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/storage/SubpartitionHashBufferAccumulator.java: ## @@ -0,0 +1,169 @@

[GitHub] [flink] TanYuxin-tyx commented on a diff in pull request #22501: [FLINK-31637][network] Implement the BufferAccumulator for the tiered storage

TanYuxin-tyx commented on code in PR #22501: URL: https://github.com/apache/flink/pull/22501#discussion_r1209254538 ## flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/storage/SubpartitionHashBufferAccumulator.java: ## @@ -0,0 +1,169 @@

[GitHub] [flink] TanYuxin-tyx commented on a diff in pull request #22501: [FLINK-31637][network] Implement the BufferAccumulator for the tiered storage

TanYuxin-tyx commented on code in PR #22501: URL: https://github.com/apache/flink/pull/22501#discussion_r1209253952 ## flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/storage/SubpartitionHashBufferAccumulator.java: ## @@ -0,0 +1,169 @@

[GitHub] [flink] TanYuxin-tyx commented on a diff in pull request #22501: [FLINK-31637][network] Implement the BufferAccumulator for the tiered storage

TanYuxin-tyx commented on code in PR #22501: URL: https://github.com/apache/flink/pull/22501#discussion_r1209253279 ## flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/storage/HashBufferAccumulator.java: ## @@ -0,0 +1,95 @@ +/* + *

[GitHub] [flink-ml] zhipeng93 commented on a diff in pull request #237: [Flink-27826] Support training very high dimensional logistic regression

zhipeng93 commented on code in PR #237: URL: https://github.com/apache/flink-ml/pull/237#discussion_r1209250004 ## flink-ml-lib/src/main/java/org/apache/flink/ml/common/updater/ModelUpdater.java: ## @@ -0,0 +1,52 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under

[GitHub] [flink-ml] zhipeng93 commented on a diff in pull request #237: [Flink-27826] Support training very high dimensional logistic regression

zhipeng93 commented on code in PR #237: URL: https://github.com/apache/flink-ml/pull/237#discussion_r1209245957 ## flink-ml-lib/src/main/java/org/apache/flink/ml/common/updater/ModelUpdater.java: ## @@ -0,0 +1,52 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under

[GitHub] [flink-ml] zhipeng93 commented on a diff in pull request #237: [Flink-27826] Support training very high dimensional logistic regression

zhipeng93 commented on code in PR #237: URL: https://github.com/apache/flink-ml/pull/237#discussion_r1209245957 ## flink-ml-lib/src/main/java/org/apache/flink/ml/common/updater/ModelUpdater.java: ## @@ -0,0 +1,52 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under

[jira] [Updated] (FLINK-32194) Elasticsearch connector should remove the dependency on flink-shaded

[ https://issues.apache.org/jira/browse/FLINK-32194?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-32194: --- Fix Version/s: elasticsearch-4.0.0 > Elasticsearch connector should remove the dependency on

[jira] [Resolved] (FLINK-32194) Elasticsearch connector should remove the dependency on flink-shaded

[ https://issues.apache.org/jira/browse/FLINK-32194?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo resolved FLINK-32194. Resolution: Done main via 71a8567bbd83a111df4f85d4465e4cda0ccae916. > Elasticsearch connector

[GitHub] [flink-connector-elasticsearch] boring-cyborg[bot] commented on pull request #65: [FLINK-32194][connectors/elasticsearch] Remove the dependency on flink-shaded

boring-cyborg[bot] commented on PR #65: URL: https://github.com/apache/flink-connector-elasticsearch/pull/65#issuecomment-1567033289 Awesome work, congrats on your first merged pull request! -- This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [flink-connector-elasticsearch] reswqa merged pull request #65: [FLINK-32194][connectors/elasticsearch] Remove the dependency on flink-shaded

reswqa merged PR #65: URL: https://github.com/apache/flink-connector-elasticsearch/pull/65 -- 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:

[jira] [Commented] (FLINK-31689) Filesystem sink fails when parallelism of compactor operator changed

[ https://issues.apache.org/jira/browse/FLINK-31689?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17727071#comment-17727071 ] jirawech.s commented on FLINK-31689: Anyone can help me review PR pls

[GitHub] [flink] curcur commented on pull request #22590: [FLINK-32071] Implement the snapshot manager for merged checkpoint files in TM

curcur commented on PR #22590: URL: https://github.com/apache/flink/pull/22590#issuecomment-1566937767 Some additional feedback as discussed offline: 1. add a high-level layout overview of the directory with file merging enabled 2. add some descriptions about the policy of

[jira] [Commented] (FLINK-30629) ClientHeartbeatTest.testJobRunningIfClientReportHeartbeat is unstable

[ https://issues.apache.org/jira/browse/FLINK-30629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17727062#comment-17727062 ] Liu commented on FLINK-30629: - [~Sergey Nuyanzin] I have tried multi times but can not reproduce it locally.

[jira] [Commented] (FLINK-31992) FlinkKafkaConsumer API is suggested to use as part of documentation, when that API is deprecated for flink version 1.14

[ https://issues.apache.org/jira/browse/FLINK-31992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17727057#comment-17727057 ] Jeyassri Balachandran commented on FLINK-31992: --- Hi [~sandeshmendan] , I'm new to the

[GitHub] [flink] flinkbot commented on pull request #22674: [FLINK-32201][runtime]Automatically determine if the shuffle descriptor needs to be offloaded by the blob server based on the number of Shuf

flinkbot commented on PR #22674: URL: https://github.com/apache/flink/pull/22674#issuecomment-1566794737 ## CI report: * 19fda849b088b4d70ce03e6c650843ed12313651 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-32201) Enable the distribution of shuffle descriptors via the blob server by connection number

[ https://issues.apache.org/jira/browse/FLINK-32201?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-32201: --- Labels: pull-request-available (was: ) > Enable the distribution of shuffle descriptors

[GitHub] [flink] huwh opened a new pull request, #22674: [FLINK-32201][runtime]Automatically determine if the shuffle descriptor needs to be offloaded by the blob server based on the number of Shuffle

huwh opened a new pull request, #22674: URL: https://github.com/apache/flink/pull/22674 ## What is the purpose of the change Flink support distributes shuffle descriptors via the blob server to reduce JobManager overhead. But the default threshold to enable it is 1MB, which never

[GitHub] [flink] pnowojski commented on a diff in pull request #22670: [FLINK-28386] Trigger an immediate checkpoint after all sinks finished

pnowojski commented on code in PR #22670: URL: https://github.com/apache/flink/pull/22670#discussion_r1209080632 ## flink-runtime/src/main/java/org/apache/flink/runtime/sink/coordinator/SinkCoordinator.java: ## @@ -0,0 +1,158 @@ +/* + * Licensed to the Apache Software

[jira] [Commented] (FLINK-31757) Optimize Flink un-balanced tasks scheduling

[ https://issues.apache.org/jira/browse/FLINK-31757?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17727041#comment-17727041 ] RocMarshal commented on FLINK-31757: I have compiled a draft  

[jira] [Comment Edited] (FLINK-31757) Optimize Flink un-balanced tasks scheduling

[ https://issues.apache.org/jira/browse/FLINK-31757?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17727041#comment-17727041 ] RocMarshal edited comment on FLINK-31757 at 5/29/23 8:25 AM: - I have

[GitHub] [flink] flinkbot commented on pull request #22673: [BP-1.16][FLINK-32023][API / DataStream] Add config execution.buffer-…

flinkbot commented on PR #22673: URL: https://github.com/apache/flink/pull/22673#issuecomment-1566714352 ## CI report: * 916094433c3fb27a7dfa18e36ea52b20d17d3983 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] Myracle opened a new pull request, #22673: [BP-1.16][FLINK-32023][API / DataStream] Add config execution.buffer-…

Myracle opened a new pull request, #22673: URL: https://github.com/apache/flink/pull/22673 Backports [FLINK-32023](https://issues.apache.org/jira/browse/FLINK-32023) to release-1.16. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

[GitHub] [flink] flinkbot commented on pull request #22672: [BP-1.17][FLINK-32023][API / DataStream] Add config execution.buffer-…

flinkbot commented on PR #22672: URL: https://github.com/apache/flink/pull/22672#issuecomment-1566709340 ## CI report: * babcbd0bac7c0f236d910cf2df724b3e21aa7e4c UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] Myracle opened a new pull request, #22672: [BP-1.17][FLINK-32023][API / DataStream] Add config execution.buffer-…

Myracle opened a new pull request, #22672: URL: https://github.com/apache/flink/pull/22672 Backports [FLINK-32023](https://issues.apache.org/jira/browse/FLINK-32023) to release-1.17. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

[GitHub] [flink] flinkbot commented on pull request #22671: [FLINK-32211][sql-client] Supports row format in executor

flinkbot commented on PR #22671: URL: https://github.com/apache/flink/pull/22671#issuecomment-1566659328 ## CI report: * 35f84f5d9918c99cfc7f9941530bced0f7ae8402 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-32211) Supports row format in ExecutorImpl for jdbc driver

[ https://issues.apache.org/jira/browse/FLINK-32211?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-32211: --- Labels: pull-request-available (was: ) > Supports row format in ExecutorImpl for jdbc

[GitHub] [flink] FangYongs opened a new pull request, #22671: [FLINK-32211][sql-client] Supports row format in executor

FangYongs opened a new pull request, #22671: URL: https://github.com/apache/flink/pull/22671 ## What is the purpose of the change This PR aims to add row format in `ExecutorImpl` and flink jdbc driver can use json format to get results. ## Brief change log - Add row

[jira] [Created] (FLINK-32211) Supports row format in ExecutorImpl for jdbc driver

Fang Yong created FLINK-32211: - Summary: Supports row format in ExecutorImpl for jdbc driver Key: FLINK-32211 URL: https://issues.apache.org/jira/browse/FLINK-32211 Project: Flink Issue Type:

[GitHub] [flink] reswqa commented on pull request #21527: [FLINK-27925] [kubernetes]Performance optimization when watch tm pod and list pod.

reswqa commented on PR #21527: URL: https://github.com/apache/flink/pull/21527#issuecomment-1566618712 It seems that some conflicts need to be resolved. -- 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

[jira] [Updated] (FLINK-32023) execution.buffer-timeout cannot be set to -1 ms

[ https://issues.apache.org/jira/browse/FLINK-32023?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-32023: Fix Version/s: 1.18.0 > execution.buffer-timeout cannot be set to -1 ms >

[jira] [Commented] (FLINK-32023) execution.buffer-timeout cannot be set to -1 ms

[ https://issues.apache.org/jira/browse/FLINK-32023?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17727021#comment-17727021 ] Rui Fan commented on FLINK-32023: - 522ff833ad7e3b3c80f4c1ba326cb05fdc4d6a3c > execution.buffer-timeout

[GitHub] [flink] 1996fanrui commented on pull request #22560: [FLINK-32023][API / DataStream] Support negative Duration for special usage, such as -1ms for execution.buffer-timeout

1996fanrui commented on PR #22560: URL: https://github.com/apache/flink/pull/22560#issuecomment-1566601162 Thanks everyone who discussed here, and @Myracle 's contribution, merging. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

[GitHub] [flink] 1996fanrui merged pull request #22560: [FLINK-32023][API / DataStream] Support negative Duration for special usage, such as -1ms for execution.buffer-timeout

1996fanrui merged PR #22560: URL: https://github.com/apache/flink/pull/22560 -- 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: