haoxins opened a new pull request, #818:
URL: https://github.com/apache/flink-kubernetes-operator/pull/818
## What is the purpose of the change
*(For example: This pull request adds a new feature to periodically create
and maintain savepoints through the `FlinkDeployment`
[
https://issues.apache.org/jira/browse/FLINK-34380?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17839474#comment-17839474
]
Roman Boyko commented on FLINK-34380:
-
Hi [~xuyangzhong] , [~xu_shuai_] !
1) The RowKind can't be
caicancai commented on code in PR #810:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/810#discussion_r1574122219
##
docs/content.zh/docs/concepts/overview.md:
##
@@ -24,86 +24,93 @@ specific language governing permissions and limitations
under the License.
flinkbot commented on PR #24696:
URL: https://github.com/apache/flink/pull/24696#issuecomment-2068485490
## CI report:
* 51874ab3e4d2d2b8b84c22bc1e3e6326dba6839a UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
TanYuxin-tyx opened a new pull request, #24696:
URL: https://github.com/apache/flink/pull/24696
## What is the purpose of the change
Backport to Flink 1.18 for
https://github.com/apache/flink/pull/24688#event-12553480360
*When using sortBufferAccumulator, we should
flinkbot commented on PR #24695:
URL: https://github.com/apache/flink/pull/24695#issuecomment-2068471232
## CI report:
* 4923275887fdcdfe189f070894fd779dc8fe0f46 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
TanYuxin-tyx opened a new pull request, #24695:
URL: https://github.com/apache/flink/pull/24695
## What is the purpose of the change
Backport to Flink 1.19 for
https://github.com/apache/flink/pull/24688#event-12553480360
*When using sortBufferAccumulator, we should
JNSimba commented on PR #3227:
URL: https://github.com/apache/flink-cdc/pull/3227#issuecomment-2068453899
It seems that some codes are duplicated with pr #3222
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
caicancai commented on code in PR #809:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/809#discussion_r1574098275
##
docs/content.zh/docs/concepts/architecture.md:
##
@@ -24,57 +24,66 @@ specific language governing permissions and limitations
under the License.
banmoy commented on PR #3231:
URL: https://github.com/apache/flink-cdc/pull/3231#issuecomment-2068440105
@yuxiqian Thanks for the work. Left some comments. Also cc @lvyanquan
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub
banmoy commented on code in PR #3231:
URL: https://github.com/apache/flink-cdc/pull/3231#discussion_r1574081602
##
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-starrocks/src/test/resources/log4j2-test.properties:
##
@@ -15,7 +15,7 @@
# Set
caicancai commented on code in PR #809:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/809#discussion_r1574091929
##
docs/content.zh/docs/concepts/architecture.md:
##
@@ -24,57 +24,66 @@ specific language governing permissions and limitations
under the License.
RocMarshal commented on PR #115:
URL:
https://github.com/apache/flink-connector-jdbc/pull/115#issuecomment-2068437230
hi, @Jiabao-Sun master, Could you help to have a review if you had the free
time ?
Thank you~
--
This is an automated message from the Apache Git Service.
To
[
https://issues.apache.org/jira/browse/FLINK-35184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17839464#comment-17839464
]
Shuai Xu commented on FLINK-35184:
--
Hi [~rovboyko] , thx for reporting this bug which is caused by the
[
https://issues.apache.org/jira/browse/FLINK-35169?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-35169:
---
Fix Version/s: 1.20.0
> Recycle buffers to freeSegments before releasing data buffer for sort
>
[
https://issues.apache.org/jira/browse/FLINK-35169?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo closed FLINK-35169.
--
Resolution: Fixed
master via 68a84fd02fb8e288ff7605073f55834468dcf53a.
> Recycle buffers to
reswqa merged PR #24688:
URL: https://github.com/apache/flink/pull/24688
--
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:
ljz2051 commented on code in PR #24681:
URL: https://github.com/apache/flink/pull/24681#discussion_r1574080412
##
flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/ForStWriteBatchOperation.java:
##
@@ -0,0 +1,96 @@
+/*
+ * Licensed to the
1996fanrui commented on code in PR #809:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/809#discussion_r1574071090
##
docs/content.zh/docs/concepts/architecture.md:
##
@@ -24,57 +24,66 @@ specific language governing permissions and limitations
under the
Zakelly commented on PR #24690:
URL: https://github.com/apache/flink/pull/24690#issuecomment-2068416578
Rebased master to resolve conflicts.
--
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
[
https://issues.apache.org/jira/browse/FLINK-35158?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yanfei Lei reassigned FLINK-35158:
--
Assignee: Yanfei Lei
> Error handling in StateFuture's callback
>
ljz2051 commented on code in PR #24681:
URL: https://github.com/apache/flink/pull/24681#discussion_r1574076315
##
flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/ForStGeneralMultiGetOperation.java:
##
@@ -0,0 +1,105 @@
+/*
+ * Licensed
fredia commented on code in PR #24678:
URL: https://github.com/apache/flink/pull/24678#discussion_r1574075445
##
flink-datastream/src/main/java/org/apache/flink/datastream/impl/operators/ProcessOperator.java:
##
@@ -46,6 +46,12 @@ public
[
https://issues.apache.org/jira/browse/FLINK-35058?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
MOBIN closed FLINK-35058.
-
Resolution: Not A Bug
> Encountered change event for table db.table whose schema isn't known to this
>
[
https://issues.apache.org/jira/browse/FLINK-35178?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17839458#comment-17839458
]
Jinzhong Li commented on FLINK-35178:
-
[~elon] Thanks for reporting this.
For case 1: Let me
[
https://issues.apache.org/jira/browse/FLINK-35027?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yanfei Lei resolved FLINK-35027.
Resolution: Resolved
> Implement checkpoint drain in AsyncExecutionController
>
fredia merged PR #24676:
URL: https://github.com/apache/flink/pull/24676
--
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:
fredia commented on code in PR #24672:
URL: https://github.com/apache/flink/pull/24672#discussion_r1574062845
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InternalTimerServiceAsyncImpl.java:
##
@@ -0,0 +1,146 @@
+/*
+ * Licensed to the Apache
RocMarshal commented on code in PR #810:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/810#discussion_r1574054494
##
docs/content.zh/docs/concepts/overview.md:
##
@@ -24,86 +24,93 @@ specific language governing permissions and limitations
under the License.
Zakelly commented on code in PR #24678:
URL: https://github.com/apache/flink/pull/24678#discussion_r1574052485
##
flink-datastream/src/main/java/org/apache/flink/datastream/impl/operators/ProcessOperator.java:
##
@@ -23,15 +23,15 @@
import
X-czh commented on PR #23998:
URL: https://github.com/apache/flink/pull/23998#issuecomment-2068376358
@affo Thanks! @huwh Could you help take a look at 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
flinkbot commented on PR #24694:
URL: https://github.com/apache/flink/pull/24694#issuecomment-2068368531
## CI report:
* b5857ed21eeda0a1338a5df27caa1743ea5cf150 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
caicancai opened a new pull request, #24694:
URL: https://github.com/apache/flink/pull/24694
## What is the purpose of the change
①mvn clean package compilation, using IDEA to run unit tests may fail to
build
②
GOODBOY008 commented on PR #3241:
URL: https://github.com/apache/flink-cdc/pull/3241#issuecomment-2068366576
And bump maven-setup action version to avoid warning.
https://github.com/apache/flink-cdc/assets/13617900/91047893-f711-4b7c-beac-054ecaee0332;>
--
This is an automated
masteryhx commented on PR #23844:
URL: https://github.com/apache/flink/pull/23844#issuecomment-2068360164
Hi, just kindly ping. Could we resolve this by the solution metioned by
@MartijnVisser ?
We tried to use positionable read with ByteBuffer on hadoop to imporve the
performance but
[
https://issues.apache.org/jira/browse/FLINK-35185?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-35185:
---
Description:
{code:java}
pr 21 00:52:11 Running externalized checkpoints test, with
Weijie Guo created FLINK-35185:
--
Summary: Resuming Externalized Checkpoint(rocks, incremental, no
parallelism change) end-to-end test failed
Key: FLINK-35185
URL: https://issues.apache.org/jira/browse/FLINK-35185
[
https://issues.apache.org/jira/browse/FLINK-35175?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hangxiang Yu resolved FLINK-35175.
--
Fix Version/s: 1.20.0
Assignee: Hangxiang Yu
Resolution: Fixed
merged
[
https://issues.apache.org/jira/browse/FLINK-35175?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17839447#comment-17839447
]
Weijie Guo commented on FLINK-35175:
hadoop313:
masteryhx closed pull request #24691: [FLINK-35175][filesystem] Avoid reading
with ByteBuffer on hadoop version below 3.3.0
URL: https://github.com/apache/flink/pull/24691
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use
[
https://issues.apache.org/jira/browse/FLINK-35041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17839445#comment-17839445
]
Weijie Guo commented on FLINK-35041:
test_cron_jdk21 core
[
https://issues.apache.org/jira/browse/FLINK-35175?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17839444#comment-17839444
]
Weijie Guo commented on FLINK-35175:
1.20 compile_cron_hadoop313
[
https://issues.apache.org/jira/browse/FLINK-35166?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yuxin Tan reassigned FLINK-35166:
-
Assignee: Jiang Xin
> Improve the performance of Hybrid Shuffle when enable memory decoupling
jectpro7 commented on code in PR #24681:
URL: https://github.com/apache/flink/pull/24681#discussion_r1573855255
##
flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/ForStGeneralMultiGetOperation.java:
##
@@ -0,0 +1,105 @@
+/*
+ * Licensed
caicancai commented on code in PR #810:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/810#discussion_r1573750686
##
docs/content.zh/docs/concepts/overview.md:
##
@@ -24,86 +24,93 @@ specific language governing permissions and limitations
under the License.
caicancai commented on code in PR #809:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/809#discussion_r1573750776
##
docs/content.zh/docs/concepts/architecture.md:
##
@@ -24,57 +24,66 @@ specific language governing permissions and limitations
under the License.
[
https://issues.apache.org/jira/browse/FLINK-35184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17839382#comment-17839382
]
Roman Boyko commented on FLINK-35184:
-
please assign this bug on me, I'm working on it.
> Hash
Roman Boyko created FLINK-35184:
---
Summary: Hash collision inside MiniBatchStreamingJoin operator
Key: FLINK-35184
URL: https://issues.apache.org/jira/browse/FLINK-35184
Project: Flink
Issue
48 matches
Mail list logo
