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
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.
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`
[
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
> -
>
>
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');
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
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
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:
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:
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
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;
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
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`
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
[
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
> ---
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',
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
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
[
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 :
[
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:
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.
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:
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
[
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
[
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
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:
[
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
[
https://issues.apache.org/jira/browse/FLINK-35978?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17871196#comment-17871196
]
Rui Fan commented on FLINK-35978:
-
Merged to main(3.3.0) via: cc5e292ad1e1ef4bf0185dbf8185346b6b95d895
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:
[
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
>
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
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
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.
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`
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
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`
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
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
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
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
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.
##
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
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 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
[
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
>
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
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
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
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
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`
[
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
>
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
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:
[
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:
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
[
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
>
>
>
[
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-35815?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17871015#comment-17871015
]
Hong Liang Teoh commented on FLINK-35815:
-
merged commit
[
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.
>
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:
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
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
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[]
[
https://issues.apache.org/jira/browse/FLINK-27519?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17870999#comment-17870999
]
lincoln lee commented on FLINK-27519:
-
Thanks [~hackergin] for the tips and the discussion here!
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
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
[
https://issues.apache.org/jira/browse/FLINK-35976?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17870989#comment-17870989
]
lincoln lee commented on FLINK-35976:
-
Thanks [~hackergin] for your tips! Let's move the disscussion
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
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.
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
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
[
https://issues.apache.org/jira/browse/FLINK-35976?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17870971#comment-17870971
]
Feng Jin edited comment on FLINK-35976 at 8/5/24 7:46 AM:
--
A similar issue.
[
https://issues.apache.org/jira/browse/FLINK-35976?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17870971#comment-17870971
]
Feng Jin commented on FLINK-35976:
--
A similar issue.
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-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
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
[
https://issues.apache.org/jira/browse/FLINK-35974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17870963#comment-17870963
]
Weijie Guo commented on FLINK-35974:
[
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
[
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
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
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
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.
dylanhz commented on code in PR #24972:
URL: https://github.com/apache/flink/pull/24972#discussion_r1703604984
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/scalar/SubstringIndexFunction.java:
##
@@ -0,0 +1,155 @@
+/*
+ * Licensed to
ruanhang1993 commented on PR #3411:
URL: https://github.com/apache/flink-cdc/pull/3411#issuecomment-2268266128
@qg-lin Please rebase the master branch and let's pass the CI.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
84 matches
Mail list logo
