dylanhz commented on PR #25127:
URL: https://github.com/apache/flink/pull/25127#issuecomment-2268322441
@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.
beryllw commented on PR #3490:
URL: https://github.com/apache/flink-cdc/pull/3490#issuecomment-2268338432
[compile_and_test](https://github.com/apache/flink-cdc/actions/runs/10195953793/job/28335622434?pr=3490#logs)
```
Error: Tests run: 1, Failures: 0, Errors: 1, Skipped: 0, Time ela
lincoln lee created FLINK-35976:
---
Summary: StreamPhysicalOverAggregate should handle column name
confliction
Key: FLINK-35976
URL: https://issues.apache.org/jira/browse/FLINK-35976
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-35976?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35976:
---
Labels: pull-request-available (was: )
> StreamPhysicalOverAggregate should handle column n
[
https://issues.apache.org/jira/browse/FLINK-35974?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-35974:
---
Priority: Critical (was: Major)
> PyFlink YARN per-job on Docker test failed because docker-compose
[
https://issues.apache.org/jira/browse/FLINK-35974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17870963#comment-17870963
]
Weijie Guo commented on FLINK-35974:
https://dev.azure.com/apache-flink/apache-flink
lincoln-lil opened a new pull request, #25152:
URL: https://github.com/apache/flink/pull/25152
## What is the purpose of the change
[FLINK-22121](https://issues.apache.org/jira/browse/FLINK-22121) fixed a
similar column name confliction both for rank and batch over agg scenarios, but
los
[
https://issues.apache.org/jira/browse/FLINK-35974?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-35974:
---
Priority: Blocker (was: Critical)
> PyFlink YARN per-job on Docker test failed because docker-compo
flinkbot commented on PR #25152:
URL: https://github.com/apache/flink/pull/25152#issuecomment-2268372484
## CI report:
* a9cddd19b65eae41b6dcacff03c02bfa6340 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-35976?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17870971#comment-17870971
]
Feng Jin commented on FLINK-35976:
--
A similar issue.
[https://issues.apache.org/jira/p
[
https://issues.apache.org/jira/browse/FLINK-35976?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17870971#comment-17870971
]
Feng Jin edited comment on FLINK-35976 at 8/5/24 7:46 AM:
--
A si
qg-lin commented on PR #3411:
URL: https://github.com/apache/flink-cdc/pull/3411#issuecomment-2268411831
> @qg-lin Please rebase the master branch and let's pass the CI.
done
--
This is an automated message from the Apache Git Service.
To respond to the message, please l
hlteoh37 commented on PR #76:
URL:
https://github.com/apache/flink-connector-aws/pull/76#issuecomment-2268475739
@Sunninsky Hey! We are currently working on implementing EFO support for the
new source connector. Estimate maybe end of the quarter?
--
This is an automated message from the
Sunninsky commented on PR #76:
URL:
https://github.com/apache/flink-connector-aws/pull/76#issuecomment-2268478660
> @Sunninsky Hey! We are currently working on implementing EFO support for
the new source connector. Estimate maybe end of the quarter?
That's very cool, thank you.
eskabetxe commented on PR #95:
URL:
https://github.com/apache/flink-connector-jdbc/pull/95#issuecomment-2268502868
@1996fanrui can you check please..
--
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
[
https://issues.apache.org/jira/browse/FLINK-35976?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17870989#comment-17870989
]
lincoln lee commented on FLINK-35976:
-
Thanks [~hackergin] for your tips! Let's move
banmoy commented on PR #3508:
URL: https://github.com/apache/flink-cdc/pull/3508#issuecomment-2268532722
@yuxiqian Thanks for the effort. Do you have the FE log with the exception?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitH
yuxiqian commented on PR #3508:
URL: https://github.com/apache/flink-cdc/pull/3508#issuecomment-2268537879
FE log
```
2024-08-05T07:10:43.9361779Z 968 [testcontainers-lifecycle-0] INFO
org.testcontainers.dockerclient.DockerClientProviderStrategy - Loaded
org.testcontainers.d
[
https://issues.apache.org/jira/browse/FLINK-27519?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17870999#comment-17870999
]
lincoln lee commented on FLINK-27519:
-
Thanks [~hackergin] for the tips and the disc
masteryhx commented on code in PR #25135:
URL: https://github.com/apache/flink/pull/25135#discussion_r1703812477
##
flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/ForStValueState.java:
##
@@ -87,8 +93,10 @@ public byte[] serializeKey(Con
kendn1993 commented on PR #421:
URL: https://github.com/apache/flink-cdc/pull/421#issuecomment-2268596720
flink1.17.1+cdc 2.4.1 还是会出现这个问题
--
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 speci
1996fanrui commented on code in PR #25134:
URL: https://github.com/apache/flink/pull/25134#discussion_r1703679953
##
flink-runtime/src/test/java/org/apache/flink/runtime/jobmaster/slotpool/DeclarativeSlotPoolBridgeResourceDeclarationTest.java:
##
@@ -205,12 +224,36 @@ void testR
hlteoh37 merged PR #153:
URL: https://github.com/apache/flink-connector-aws/pull/153
--
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-35815?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hong Liang Teoh resolved FLINK-35815.
-
Resolution: Fixed
> KinesisProxySyncV2 doesn't always retry throttling exceptions.
> --
[
https://issues.apache.org/jira/browse/FLINK-35815?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17871015#comment-17871015
]
Hong Liang Teoh commented on FLINK-35815:
-
merged commit
[{{6cfa13d}}|https://g
[
https://issues.apache.org/jira/browse/FLINK-35815?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hong Liang Teoh reassigned FLINK-35815:
---
Assignee: Aleksandr Pilipenko
> KinesisProxySyncV2 doesn't always retry throttling
[
https://issues.apache.org/jira/browse/FLINK-35955?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo resolved FLINK-35955.
Resolution: Resolved
> Remove outdated versions
>
>
> Key
dylanhz commented on PR #25127:
URL: https://github.com/apache/flink/pull/25127#issuecomment-2268840820
@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 co
[
https://issues.apache.org/jira/browse/FLINK-35964?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dylan He updated FLINK-35964:
-
Description:
Add STARTSWITH function.
Returns if {{expr}} begins with {{startExpr}}.
Example:
{cod
guluo created FLINK-35977:
-
Summary: Missing an import in datastream.md
Key: FLINK-35977
URL: https://issues.apache.org/jira/browse/FLINK-35977
Project: Flink
Issue Type: Bug
Affects Versions: 1.
guluo2016 opened a new pull request, #25153:
URL: https://github.com/apache/flink/pull/25153
## What is the purpose of the change
This PR fix
[FLINK-35977](https://issues.apache.org/jira/browse/FLINK-35977) that misssing
an import about OpenContext.
## Brief chang
[
https://issues.apache.org/jira/browse/FLINK-35977?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35977:
---
Labels: pull-request-available (was: )
> Missing an import in datastream.md
> -
flinkbot commented on PR #25153:
URL: https://github.com/apache/flink/pull/25153#issuecomment-2268927425
## CI report:
* e2421af596c1e888c6416a815fcee48a1d9682bf UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
borislitvak commented on PR #118:
URL:
https://github.com/apache/flink-connector-jdbc/pull/118#issuecomment-2268938459
@davidradl WDYT?
--
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 sp
leonardBang commented on PR #3449:
URL: https://github.com/apache/flink-cdc/pull/3449#issuecomment-2269086514
@aiwenmo @yuxiqian I append a commit to make sure our temporal function
semantics align with Flink SQL, please help review my commit
--
This is an automated message from the Apach
João Boto created FLINK-35978:
-
Summary: adapt labelling of boring cyborg
Key: FLINK-35978
URL: https://issues.apache.org/jira/browse/FLINK-35978
Project: Flink
Issue Type: Sub-task
R
eskabetxe opened a new pull request, #135:
URL: https://github.com/apache/flink-connector-jdbc/pull/135
Adapt the labelling to new structure.
--
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 s
[
https://issues.apache.org/jira/browse/FLINK-35978?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35978:
---
Labels: pull-request-available (was: )
> adapt labelling of boring cyborg
> ---
aiwenmo commented on PR #3449:
URL: https://github.com/apache/flink-cdc/pull/3449#issuecomment-2269264056
thx. I'm reviewing it.
--
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 comme
João Boto created FLINK-35979:
-
Summary: Add flink version 2.0-SNAPSHOT to ci
Key: FLINK-35979
URL: https://issues.apache.org/jira/browse/FLINK-35979
Project: Flink
Issue Type: Sub-task
aiwenmo commented on code in PR #3449:
URL: https://github.com/apache/flink-cdc/pull/3449#discussion_r170478
##
flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/parser/JaninoCompiler.java:
##
@@ -359,6 +407,15 @@ private static Java.Rvalue generateTypeConvertMeth
z3d1k opened a new pull request, #154:
URL: https://github.com/apache/flink-connector-aws/pull/154
## Purpose of the change
Update ci build configuration after 1.20.0 release
## Verifying this change
This change is already covered by Github approval workflow.
## Si
z3d1k commented on PR #154:
URL:
https://github.com/apache/flink-connector-aws/pull/154#issuecomment-2269514160
cc @hlteoh37
--
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
eskabetxe commented on PR #23:
URL:
https://github.com/apache/flink-connector-mongodb/pull/23#issuecomment-2269535265
hi @Jiabao-Sun
I'm not an contributor to this connector but it LGTM
--
This is an automated message from the Apache Git Service.
To respond to the message, please log
hackergin commented on code in PR #25152:
URL: https://github.com/apache/flink/pull/25152#discussion_r1704417002
##
flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/utils/OverAggregateUtil.scala:
##
@@ -219,4 +224,20 @@ object OverAggregateUtil
jnh5y opened a new pull request, #25154:
URL: https://github.com/apache/flink/pull/25154
## What is the purpose of the change
* In addition to the annotations, implement a BatchRestoreTest for this
operator.
* Moves the ValuesTestPrograms to a common package for re-use between
str
flinkbot commented on PR #25154:
URL: https://github.com/apache/flink/pull/25154#issuecomment-2269574388
## CI report:
* eea2abcf55eb4e4c5e7b910d5e92449fd9888aba UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
mattayes opened a new pull request, #25155:
URL: https://github.com/apache/flink/pull/25155
## What is the purpose of the change
Fix typo in `KeyedStream.keySelector` and `KeyedStream.getKeySelector()`
docs.
## Brief change log
* Fix typo in `KeyedStream.keyS
flinkbot commented on PR #25155:
URL: https://github.com/apache/flink/pull/25155#issuecomment-2269836853
## CI report:
* 116c31495887330b7c00ee3679e92696171926f8 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
github-actions[bot] commented on PR #3364:
URL: https://github.com/apache/flink-cdc/pull/3364#issuecomment-2270123855
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.
--
yuxiqian commented on code in PR #3449:
URL: https://github.com/apache/flink-cdc/pull/3449#discussion_r1704771418
##
flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/parser/JaninoCompiler.java:
##
@@ -300,7 +315,19 @@ private static Java.Rvalue generateOtherFunctionO
yux created FLINK-35980:
---
Summary: Add transform test coverage in Integrated / E2e tests
Key: FLINK-35980
URL: https://issues.apache.org/jira/browse/FLINK-35980
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-35980?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiabao Sun reassigned FLINK-35980:
--
Assignee: yux
> Add transform test coverage in Integrated / E2e tests
> -
1996fanrui merged PR #135:
URL: https://github.com/apache/flink-connector-jdbc/pull/135
--
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-35978?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17871196#comment-17871196
]
Rui Fan commented on FLINK-35978:
-
Merged to main(3.3.0) via: cc5e292ad1e1ef4bf0185dbf81
[
https://issues.apache.org/jira/browse/FLINK-35978?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan resolved FLINK-35978.
-
Fix Version/s: jdbc-3.3.0
Assignee: João Boto
Resolution: Fixed
> adapt labelling of bor
1996fanrui merged PR #95:
URL: https://github.com/apache/flink-connector-jdbc/pull/95
--
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-34215?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan resolved FLINK-34215.
-
Fix Version/s: jdbc-3.3.0
(was: jdbc-3.1.3)
Assignee: Jiabao Sun
R
[
https://issues.apache.org/jira/browse/FLINK-34214?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan updated FLINK-34214:
Fix Version/s: jdbc-3.3.0
(was: jdbc-3.1.3)
> FLIP-377: Support fine-grained config
Jiabao-Sun commented on PR #23:
URL:
https://github.com/apache/flink-connector-mongodb/pull/23#issuecomment-2270202389
Thanks @eskabetxe and @RocMarshal for the review.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use
Jiabao-Sun merged PR #23:
URL: https://github.com/apache/flink-connector-mongodb/pull/23
--
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
dylanhz commented on PR #25127:
URL: https://github.com/apache/flink/pull/25127#issuecomment-2270203780
@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-34216?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiabao Sun resolved FLINK-34216.
Assignee: Jiabao Sun
Resolution: Implemented
merged into main: 424d57a54c69d9d0e0fde4219e46b
[
https://issues.apache.org/jira/browse/FLINK-34214?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiabao Sun resolved FLINK-34214.
Assignee: Jiabao Sun (was: jiabao.sun)
Resolution: Implemented
jdbc main(3.3.0) via : b5980
becketqin commented on PR #25130:
URL: https://github.com/apache/flink/pull/25130#issuecomment-2270206455
@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.
yux created FLINK-35981:
---
Summary: Transform rule doesn't support referencing one column
more than once
Key: FLINK-35981
URL: https://issues.apache.org/jira/browse/FLINK-35981
Project: Flink
Issue Typ
dylanhz opened a new pull request, #25156:
URL: https://github.com/apache/flink/pull/25156
## What is the purpose of the change
Add the built-in function STARTSWITH.
Examples:
```SQL
> SELECT STARTSWITH('SparkSQL', 'Spark');
true
> SELECT STARTSWITH('SparkSQL', 'spark')
[
https://issues.apache.org/jira/browse/FLINK-35964?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35964:
---
Labels: pull-request-available (was: )
> Add STARTSWITH function
> ---
JingsongLi commented on PR #25129:
URL: https://github.com/apache/flink/pull/25129#issuecomment-2270263413
CC @luoyuxia
--
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
flinkbot commented on PR #25156:
URL: https://github.com/apache/flink/pull/25156#issuecomment-2270266374
## CI report:
* 7c21f6231604599aa8e17bde284791ccef23625e UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
leonardBang commented on code in PR #3449:
URL: https://github.com/apache/flink-cdc/pull/3449#discussion_r1704843120
##
flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/parser/JaninoCompiler.java:
##
@@ -359,6 +407,15 @@ private static Java.Rvalue generateTypeConvert
leonardBang commented on code in PR #3449:
URL: https://github.com/apache/flink-cdc/pull/3449#discussion_r1704843782
##
flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/functions/SystemFunctionUtils.java:
##
@@ -38,65 +41,62 @@
import java.util.regex.Matcher;
impor
yux created FLINK-35982:
---
Summary: Transform metadata config doesn't work if no projection
block was provided
Key: FLINK-35982
URL: https://issues.apache.org/jira/browse/FLINK-35982
Project: Flink
Iss
yux created FLINK-35983:
---
Summary: Job crashes when using wildcard (*) match with metadata
column
Key: FLINK-35983
URL: https://issues.apache.org/jira/browse/FLINK-35983
Project: Flink
Issue Type: Bug
yux created FLINK-35984:
---
Summary: Job crashes when metadata column names present in
transform rules
Key: FLINK-35984
URL: https://issues.apache.org/jira/browse/FLINK-35984
Project: Flink
Issue Type:
aiwenmo commented on PR #3449:
URL: https://github.com/apache/flink-cdc/pull/3449#issuecomment-2270316674
@yuxiqian Hi. I'm busy with other things. Could you add an e2e test for the
temporal function?
For example: Mysql -> Transform -> Doris/Values
`projection: *,LOCALTIME as time1
yuxiqian commented on PR #3449:
URL: https://github.com/apache/flink-cdc/pull/3449#issuecomment-2270319084
Sure, thanks for @aiwenmo's work so far, I'll create a patch for this.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub
dylanhz opened a new pull request, #25157:
URL: https://github.com/apache/flink/pull/25157
## What is the purpose of the change
Add the built-in function ENDSWITH.
Examples:
```SQL
> SELECT ENDSWITH('SparkSQL', 'SQL');
true
> SELECT ENDSWITH('SparkSQL', 'sql');
fals
[
https://issues.apache.org/jira/browse/FLINK-35965?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35965:
---
Labels: pull-request-available (was: )
> Add ENDSWITH function
> -
>
>
flinkbot commented on PR #25157:
URL: https://github.com/apache/flink/pull/25157#issuecomment-2270322010
## CI report:
* 29ac26cbcfbcbcd8f6839743c33268e24bd1d2bd UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
dylanhz commented on PR #25127:
URL: https://github.com/apache/flink/pull/25127#issuecomment-2270429171
@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.
yux created FLINK-35985:
---
Summary: SUBSTRING function not available in transform rules
Key: FLINK-35985
URL: https://issues.apache.org/jira/browse/FLINK-35985
Project: Flink
Issue Type: Bug
C
yux created FLINK-35986:
---
Summary: NULL literal is not supported in Transform rules
Key: FLINK-35986
URL: https://issues.apache.org/jira/browse/FLINK-35986
Project: Flink
Issue Type: Bug
Comp
dylanhz commented on PR #25127:
URL: https://github.com/apache/flink/pull/25127#issuecomment-2270462361
@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 co
[
https://issues.apache.org/jira/browse/FLINK-35980?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35980:
---
Labels: pull-request-available (was: )
> Add transform test coverage in Integrated / E2e te
Dylan He created FLINK-35987:
Summary: Add ELT function
Key: FLINK-35987
URL: https://issues.apache.org/jira/browse/FLINK-35987
Project: Flink
Issue Type: Sub-task
Components: Table SQL
leonardBang commented on code in PR #3449:
URL: https://github.com/apache/flink-cdc/pull/3449#discussion_r1705002901
##
flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/parser/JaninoCompiler.java:
##
@@ -359,6 +407,15 @@ private static Java.Rvalue generateTypeConvert
87 matches
Mail list logo
