reswqa merged PR #25393:
URL: https://github.com/apache/flink/pull/25393
--
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: issues-unsubscr...@flink.apache
[
https://issues.apache.org/jira/browse/FLINK-36375?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-36375:
---
Labels: pull-request-available (was: )
> Missing default value in AddColumnEvent
>
qg-lin commented on PR #3622:
URL: https://github.com/apache/flink-cdc/pull/3622#issuecomment-2375891374
@lvyanquan @yuxiqian PTAL
--
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 com
[
https://issues.apache.org/jira/browse/FLINK-36374?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zakelly Lan reassigned FLINK-36374:
---
Assignee: Zakelly Lan
> Bundle forst statebackend in flink-dist and provide shortcut to ena
Zakelly Lan created FLINK-36374:
---
Summary: Bundle forst statebackend in flink-dist and provide
shortcut to enable
Key: FLINK-36374
URL: https://issues.apache.org/jira/browse/FLINK-36374
Project: Flink
qg-lin commented on PR #3615:
URL: https://github.com/apache/flink-cdc/pull/3615#issuecomment-2375852444
Since DeduplicateFunctionHelper#processLastRowOnChangelog returns the row
before deletion, the `delete` type is temporarily missing.
--
This is an automated message from the Apache Git
linqigeng created FLINK-36375:
-
Summary: Missing default value in AddColumnEvent
Key: FLINK-36375
URL: https://issues.apache.org/jira/browse/FLINK-36375
Project: Flink
Issue Type: Bug
C
Zakelly opened a new pull request, #25402:
URL: https://github.com/apache/flink/pull/25402
## What is the purpose of the change
Currently, the forst statebackend are built under
`flink-statebackend-forst`, but is not included in the `flink-dist`'s jar. This
PR make forst statebackend
[
https://issues.apache.org/jira/browse/FLINK-36374?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-36374:
---
Labels: pull-request-available (was: )
> Bundle forst statebackend in flink-dist and provid
flinkbot commented on PR #25402:
URL: https://github.com/apache/flink/pull/25402#issuecomment-2375878995
## CI report:
* 3b63165442e17ced06c405d00f575fa02307cb2d UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
lvyanquan commented on PR #25331:
URL: https://github.com/apache/flink/pull/25331#issuecomment-2375887294
@flinkbot run azure
--
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 comm
qg-lin opened a new pull request, #3622:
URL: https://github.com/apache/flink-cdc/pull/3622
SchemaOperator receives an AddColumnEvent, the default value will be lost
when sent downstream.
JIRA: [https://issues.apache.org/jira/browse/FLINK-36375](url)
--
This is an automated message fro
[
https://issues.apache.org/jira/browse/FLINK-36375?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
linqigeng updated FLINK-36375:
--
Description:
SchemaOperator receives an AddColumnEvent or RenameColumnEvent, the default
value will b
spena opened a new pull request, #25401:
URL: https://github.com/apache/flink/pull/25401
## What is the purpose of the change
This PR allows you to use CTAS to reorder the columns defined in the
`SELECT` part by specifying all column names without data types in the `CREATE`
part. Thi
flinkbot commented on PR #25401:
URL: https://github.com/apache/flink/pull/25401#issuecomment-2375351231
## CI report:
* dfb06e8b80b48a4c25a0c50a1fb3841426ccb7e5 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
showuon commented on code in PR #25371:
URL: https://github.com/apache/flink/pull/25371#discussion_r1776302945
##
flink-connectors/flink-connector-base/src/test/java/org/apache/flink/connector/base/source/reader/fetcher/SplitFetcherManagerTest.java:
##
@@ -71,7 +71,7 @@ public v
Zakelly commented on PR #25384:
URL: https://github.com/apache/flink/pull/25384#issuecomment-2375806647
I'd suggest removing `GenericArraySerializerConfigSnapshot` and
`EitherSerializerSnapshot` with another commit by this PR.
--
This is an automated message from the Apache Git Service.
T
Tan Nguyen created FLINK-36372:
--
Summary: Can not insert data to sink with reserved keywords column
name
Key: FLINK-36372
URL: https://issues.apache.org/jira/browse/FLINK-36372
Project: Flink
I
[
https://issues.apache.org/jira/browse/FLINK-36372?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tan Nguyen updated FLINK-36372:
---
Description:
Hi teams,
I created a flink application running as batch mode, we read data from kafka
[
https://issues.apache.org/jira/browse/FLINK-36372?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tan Nguyen updated FLINK-36372:
---
Description:
Hi teams,
I created a flink application running as batch mode, we read data from kafka
Yanfei Lei created FLINK-36373:
--
Summary: Support distribute state requests in task thread
Key: FLINK-36373
URL: https://issues.apache.org/jira/browse/FLINK-36373
Project: Flink
Issue Type: Sub-
[
https://issues.apache.org/jira/browse/FLINK-36364?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17884842#comment-17884842
]
Zakelly Lan commented on FLINK-36364:
-
Merge 82582b3a7b75b7ffae9d48895088189b1324caa
[
https://issues.apache.org/jira/browse/FLINK-35928?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zakelly Lan reassigned FLINK-35928:
---
Assignee: Yanfei Lei (was: Hangxiang Yu)
> ForSt supports compiling with RocksDB
> ---
[
https://issues.apache.org/jira/browse/FLINK-36364?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zakelly Lan resolved FLINK-36364.
-
Fix Version/s: 2.0-preview
Resolution: Fixed
> Do not reuse serialized key in Forst map s
Zakelly merged PR #25394:
URL: https://github.com/apache/flink/pull/25394
--
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: issues-unsubscr...@flink.apach
github-actions[bot] commented on PR #3289:
URL: https://github.com/apache/flink-cdc/pull/3289#issuecomment-2375474952
This pull request has been automatically marked as stale because it has not
had recent activity for 60 days. It will be closed in 30 days if no further
activity occurs.
--
[
https://issues.apache.org/jira/browse/FLINK-21820?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17884829#comment-17884829
]
zhanghuaibei commented on FLINK-21820:
--
h4. [~leonard] [~jark] [~yangsanity] [~nich
noorall commented on PR #25366:
URL: https://github.com/apache/flink/pull/25366#issuecomment-2375736309
@flinkbot run azure
--
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.
yunfengzhou-hub closed pull request #25391: [FLINK-36355][runtime] Remove
deprecated KeydStream#asQueryableState
URL: https://github.com/apache/flink/pull/25391
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL abov
yunfengzhou-hub commented on PR #25391:
URL: https://github.com/apache/flink/pull/25391#issuecomment-2376037028
According to offline discussion with @Zakelly, this component will
temporarily not be removed until a new query state solution is proposed in
Flink 2.x.
--
This is an automated
[
https://issues.apache.org/jira/browse/FLINK-36166?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17884867#comment-17884867
]
xuyang edited comment on FLINK-36166 at 9/26/24 6:37 AM:
-
Everyt
[
https://issues.apache.org/jira/browse/FLINK-36166?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17884867#comment-17884867
]
xuyang edited comment on FLINK-36166 at 9/26/24 6:14 AM:
-
I'm no
qg-lin commented on PR #3622:
URL: https://github.com/apache/flink-cdc/pull/3622#issuecomment-2376090149
> Thanks for @qg-lin's contribution! Seems lenientized `RenameColumnEvent`
is also prone to this issue. Would you like to fix this in this PR?
my pleasure
--
This is an automate
SamBarker commented on code in PR #881:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/881#discussion_r1776061626
##
pom.xml:
##
@@ -110,6 +110,7 @@ under the License.
10.15.2.0
+24.1.0
Review Comment:
I've removed `@NotNull` from
SamBarker commented on code in PR #881:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/881#discussion_r1776062522
##
.github/workflows/ci.yml:
##
@@ -78,6 +79,7 @@ jobs:
namespace: ["default","flink"]
mode: ["native", "standalone"]
java
SamBarker commented on code in PR #881:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/881#discussion_r1776062259
##
.github/workflows/ci.yml:
##
@@ -47,7 +48,7 @@ jobs:
${{ runner.os }}-maven-
- name: Build with Maven
run: |
-
fredia commented on code in PR #25394:
URL: https://github.com/apache/flink/pull/25394#discussion_r1776219418
##
flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/ForStSerializerUtils.java:
##
@@ -0,0 +1,63 @@
+/*
+ * Licensed to the Apache
Myasuka commented on PR #25399:
URL: https://github.com/apache/flink/pull/25399#issuecomment-2375646639
@flinkbot run azure
--
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.
lincoln-lil commented on code in PR #25380:
URL: https://github.com/apache/flink/pull/25380#discussion_r1774875365
##
flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/utils/RankUtil.scala:
##
@@ -352,21 +352,55 @@ object RankUtil {
}
Sergey Nuyanzin created FLINK-36367:
---
Summary: Use RexNormalize in EquivalentExprShuttle
Key: FLINK-36367
URL: https://issues.apache.org/jira/browse/FLINK-36367
Project: Flink
Issue Type: B
snuyanzin commented on code in PR #25388:
URL: https://github.com/apache/flink/pull/25388#discussion_r1774883976
##
flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/utils/FlinkRexUtil.scala:
##
@@ -439,17 +439,16 @@ object FlinkRexUtil {
})
Arvid Heise created FLINK-36368:
---
Summary: Fix subtask management in CommittableCollector
Key: FLINK-36368
URL: https://issues.apache.org/jira/browse/FLINK-36368
Project: Flink
Issue Type: Bug
snuyanzin commented on PR #25388:
URL: https://github.com/apache/flink/pull/25388#issuecomment-2373541247
thanks for taking a look
--
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 com
AHeise commented on PR #25353:
URL: https://github.com/apache/flink/pull/25353#issuecomment-2373541699
Addressed feedback and slimmed down PR a bit to the essentials. I have
created FLINK-36368 for follow-up work.
--
This is an automated message from the Apache Git Service.
To respond to
reswqa merged PR #25323:
URL: https://github.com/apache/flink/pull/25323
--
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: issues-unsubscr...@flink.apache
[
https://issues.apache.org/jira/browse/FLINK-36275?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo resolved FLINK-36275.
Fix Version/s: 2.0-preview
Resolution: Done
master(2.0) via f58a3e02a63b094e8c64344a7a74808
[
https://issues.apache.org/jira/browse/FLINK-36275?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo reassigned FLINK-36275:
--
Assignee: Weijie Guo
> Remove deprecated ProgramArgsQueryParameter
>
AlexYinHan commented on PR #25384:
URL: https://github.com/apache/flink/pull/25384#issuecomment-2373451676
@masteryhx Thanks for the comments. I have update the docs. PTAL.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and u
flinkbot commented on PR #25397:
URL: https://github.com/apache/flink/pull/25397#issuecomment-2373503514
## CI report:
* 28d1f2ed93431e3ec739b3f5af700dc0704accc9 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-35035?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-35035:
--
Fix Version/s: 2.0-preview
> Reduce job pause time when cluster resources are expanded in adap
showuon commented on code in PR #25371:
URL: https://github.com/apache/flink/pull/25371#discussion_r1774665859
##
flink-connectors/flink-connector-base/src/test/java/org/apache/flink/connector/base/source/reader/fetcher/SplitFetcherManagerTest.java:
##
@@ -71,7 +71,7 @@ public v
[
https://issues.apache.org/jira/browse/FLINK-35035?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl resolved FLINK-35035.
---
Resolution: Fixed
Closing this parent issue. All subtasks are addressed and the no new test
flinkbot commented on PR #25396:
URL: https://github.com/apache/flink/pull/25396#issuecomment-2373400996
## CI report:
* 9f67d79ffaceec279e944054d51880ebb8d340cd UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
zoltar9264 opened a new pull request, #25397:
URL: https://github.com/apache/flink/pull/25397
## What is the purpose of the change
Impletement basic restore from checkpoint in ForStStateBackend, the
checkpoint implement in
[FLINK-35510](https://issues.apache.org/jira/browse/FLINK-355
[
https://issues.apache.org/jira/browse/FLINK-36325?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-36325:
---
Labels: pull-request-available (was: )
> Implement basic restore from checkpoint for ForStS
[
https://issues.apache.org/jira/browse/FLINK-36011?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17884537#comment-17884537
]
Matthias Pohl commented on FLINK-36011:
---
master:
[c869326d089705475481c2c2ea42a6e
reswqa commented on PR #25393:
URL: https://github.com/apache/flink/pull/25393#issuecomment-2373310633
@flinkbot run azure
--
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.
T
Weijie Guo created FLINK-36366:
--
Summary: Remove deprecate API in flink-core exclude connector and
state part
Key: FLINK-36366
URL: https://issues.apache.org/jira/browse/FLINK-36366
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-36366?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-36366:
---
Labels: pull-request-available (was: )
> Remove deprecate API in flink-core exclude connect
reswqa opened a new pull request, #25396:
URL: https://github.com/apache/flink/pull/25396
## What is the purpose of the change
*Remove deprecate API in flink-core exclude connector and state part*
## Verifying this change
This change is a trivial rework / code cleanup
JunRuiLee commented on code in PR #25366:
URL: https://github.com/apache/flink/pull/25366#discussion_r1772938079
##
flink-runtime/src/main/java/org/apache/flink/streaming/api/graph/util/JobVertexBuildContext.java:
##
@@ -0,0 +1,161 @@
+/*
+ * Licensed to the Apache Software Foun
snuyanzin merged PR #25388:
URL: https://github.com/apache/flink/pull/25388
--
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: issues-unsubscr...@flink.apa
[
https://issues.apache.org/jira/browse/FLINK-36361?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17884527#comment-17884527
]
Sergey Nuyanzin commented on FLINK-36361:
-
Merged as
[0578c8e17dddc88444635e7ad
[
https://issues.apache.org/jira/browse/FLINK-36361?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin resolved FLINK-36361.
-
Fix Version/s: 2.0-preview
Resolution: Fixed
> Do not use StringBuilder for Equiv
[
https://issues.apache.org/jira/browse/FLINK-36273?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lincoln lee closed FLINK-36273.
---
Assignee: xuyang
Resolution: Fixed
Fixed in master: 733a56682bcceabab6625b621547538c6d993976
lincoln-lil merged PR #25334:
URL: https://github.com/apache/flink/pull/25334
--
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: issues-unsubscr...@flink.a
boring-cyborg[bot] commented on PR #49:
URL:
https://github.com/apache/flink-connector-hbase/pull/49#issuecomment-2373679524
Awesome work, congrats on your first merged pull request!
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on
[
https://issues.apache.org/jira/browse/FLINK-36188?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ferenc Csaky reassigned FLINK-36188:
Assignee: MOBIN
> HBase disable buffer flush lose efficacy
>
ferenc-csaky merged PR #49:
URL: https://github.com/apache/flink-connector-hbase/pull/49
--
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: issues-unsubscr
[
https://issues.apache.org/jira/browse/FLINK-36188?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ferenc Csaky closed FLINK-36188.
Resolution: Fixed
[{{c6eb87f}}|https://github.com/apache/flink-connector-hbase/commit/c6eb87f809cd
[
https://issues.apache.org/jira/browse/FLINK-36188?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ferenc Csaky updated FLINK-36188:
-
Fix Version/s: hbase-4.0.0
> HBase disable buffer flush lose efficacy
>
ferenc-csaky merged PR #48:
URL: https://github.com/apache/flink-connector-hbase/pull/48
--
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: issues-unsubscr
becketqin commented on code in PR #25371:
URL: https://github.com/apache/flink/pull/25371#discussion_r1775726090
##
flink-connectors/flink-connector-base/src/test/java/org/apache/flink/connector/base/source/reader/fetcher/SplitFetcherManagerTest.java:
##
@@ -71,7 +71,7 @@ public
becketqin commented on code in PR #25371:
URL: https://github.com/apache/flink/pull/25371#discussion_r1775726090
##
flink-connectors/flink-connector-base/src/test/java/org/apache/flink/connector/base/source/reader/fetcher/SplitFetcherManagerTest.java:
##
@@ -71,7 +71,7 @@ public
codenohup commented on PR #25365:
URL: https://github.com/apache/flink/pull/25365#issuecomment-2374836433
@flinkbot run azure
--
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.
leonardBang merged PR #3621:
URL: https://github.com/apache/flink-cdc/pull/3621
--
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: issues-unsubscr...@flink
lincoln-lil commented on PR #25334:
URL: https://github.com/apache/flink/pull/25334#issuecomment-2373644347
For 2nd commit, went over all options mentioned in
https://issues.apache.org/jira/browse/FLINK-35473
All deprecated options there were remove except the occurrences in
correspondi
xuyangzhong commented on PR #25400:
URL: https://github.com/apache/flink/pull/25400#issuecomment-2374388353
@flinkbot run azure
--
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 commen
[
https://issues.apache.org/jira/browse/FLINK-34702?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lincoln lee closed FLINK-34702.
---
Fix Version/s: 2.0-preview
(was: 2.0.0)
Resolution: Fixed
fixed in mas
lincoln-lil merged PR #25380:
URL: https://github.com/apache/flink/pull/25380
--
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: issues-unsubscr...@flink.a
gyfora commented on code in PR #881:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/881#discussion_r1774650443
##
.github/workflows/ci.yml:
##
@@ -47,7 +48,7 @@ jobs:
${{ runner.os }}-maven-
- name: Build with Maven
run: |
-
gyfora commented on code in PR #881:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/881#discussion_r1774647193
##
.github/workflows/ci.yml:
##
@@ -78,6 +79,7 @@ jobs:
namespace: ["default","flink"]
mode: ["native", "standalone"]
java-ve
gyfora commented on PR #882:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/882#issuecomment-2373230412
Hi @xieyang1994 !
New features need a JIRA first and the PR should be opened against main in
any case unless we are back porting a bug fix to one of the supported re
noorall commented on code in PR #25366:
URL: https://github.com/apache/flink/pull/25366#discussion_r1774908113
##
flink-runtime/src/main/java/org/apache/flink/streaming/api/graph/StreamingJobGraphGenerator.java:
##
@@ -593,15 +616,22 @@ private Map
buildChainedInputsAndGetHeadI
noorall commented on PR #25366:
URL: https://github.com/apache/flink/pull/25366#issuecomment-2373601784
@flinkbot run azure
--
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.
[
https://issues.apache.org/jira/browse/FLINK-36109?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17884626#comment-17884626
]
Gyula Fora commented on FLINK-36109:
I think adding these labels makes sense for now
yuxiqian commented on PR #3465:
URL: https://github.com/apache/flink-cdc/pull/3465#issuecomment-2374215861
Hi @mamineturki, `flink-cdc-pipeline-udf-examples` are for testing purposes
only. If you'd like to test it, using
`org.apache.flink.cdc.udf.examples.scala.AddOneFunctionClass` should w
mamineturki commented on PR #3465:
URL: https://github.com/apache/flink-cdc/pull/3465#issuecomment-2374187978
@yuxiqian Hi, I have been trying to run an example with this new feature but
I always get `java.lang.ClassNotFoundException:
org.example.udf.AddOneFunctionClass`
I tried load
mamineturki commented on PR #3465:
URL: https://github.com/apache/flink-cdc/pull/3465#issuecomment-2374243091
Thanks for the speedy reply @yuxiqian . moving the jar to `Flink lib` did
not help. passing the jar with `--jar` caused the `Flink-cdc.sh` command to get
stuck with no logs, and no
mamineturki commented on PR #3465:
URL: https://github.com/apache/flink-cdc/pull/3465#issuecomment-2374250013
Thanks for the speedy response @yuxiqian . passing the jar using `--jar`
worked for me.
--
This is an automated message from the Apache Git Service.
To respond to the message, pl
flinkbot commented on PR #25400:
URL: https://github.com/apache/flink/pull/25400#issuecomment-2374256737
## CI report:
* 259abc16084da0205bae73b37033c29ecb079b29 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
Aniruddh J created FLINK-36370:
--
Summary: Flink 1.18 fails with Empty server certificate chain when
High Availability and mTLS both enabled
Key: FLINK-36370
URL: https://issues.apache.org/jira/browse/FLINK-36370
[
https://issues.apache.org/jira/browse/FLINK-36370?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aniruddh J updated FLINK-36370:
---
Attachment: flink-cert-issue.log
Description:
Hi, in my kubernetes cluster I have flink-kuberne
[
https://issues.apache.org/jira/browse/FLINK-36371?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eason Ye updated FLINK-36371:
-
Description:
The pipeline is Source(Kafka serialize msg to RowData type) -> FlatMap
--(keyby)–> TumbleP
Eason Ye created FLINK-36371:
Summary: Field BinaryStringData as keySelector would lead the same
records hash shuffle into different tumble windows
Key: FLINK-36371
URL: https://issues.apache.org/jira/browse/FLINK-363
[
https://issues.apache.org/jira/browse/FLINK-36371?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eason Ye updated FLINK-36371:
-
Description:
The pipeline is Source(Kafka serialize msg to RowData type) -> FlatMap
--(keyby)–> TumbleP
xuyangzhong commented on PR #25400:
URL: https://github.com/apache/flink/pull/25400#issuecomment-2374330934
@flinkbot run azure
--
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 commen
[
https://issues.apache.org/jira/browse/FLINK-36370?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aniruddh J updated FLINK-36370:
---
Priority: Major (was: Minor)
> Flink 1.18 fails with Empty server certificate chain when High Avail
codenohup commented on PR #25393:
URL: https://github.com/apache/flink/pull/25393#issuecomment-2373796766
@flinkbot run azure
--
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.
RocMarshal commented on code in PR #25218:
URL: https://github.com/apache/flink/pull/25218#discussion_r1775043513
##
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/allocator/DefaultSlotAssigner.java:
##
@@ -43,35 +47,43 @@ public Collection assignSlots(
1 - 100 of 134 matches
Mail list logo
