Wang Qilong created FLINK-35905:
---
Summary: Flink physical operator replacement support
Key: FLINK-35905
URL: https://issues.apache.org/jira/browse/FLINK-35905
Project: Flink
Issue Type: Bug
Zakelly commented on code in PR #25126:
URL: https://github.com/apache/flink/pull/25126#discussion_r169445
##
flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/ForStInnerTable.java:
##
@@ -73,7 +73,7 @@ public interface ForStInnerTable
jiangcheng created FLINK-35906:
--
Summary: Inconsistent timestamp precision handling in Flink CDC
PostgreSQL Connector
Key: FLINK-35906
URL: https://issues.apache.org/jira/browse/FLINK-35906
Project: Flin
[
https://issues.apache.org/jira/browse/FLINK-35906?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
jiangcheng updated FLINK-35906:
---
Description:
I have encountered an inconsistency issue with the Flink CDC PostgreSQL
Connector when
jiangcheng created FLINK-35907:
--
Summary: Inconsistent handling of bit and bit(n) types in Flink
CDC PostgreSQL Connector
Key: FLINK-35907
URL: https://issues.apache.org/jira/browse/FLINK-35907
Project:
[
https://issues.apache.org/jira/browse/FLINK-35907?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
jiangcheng updated FLINK-35907:
---
Description:
I am encountering issues with the Flink CDC PostgreSQL Connector's handling of
{{bit}}
[
https://issues.apache.org/jira/browse/FLINK-35907?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
jiangcheng updated FLINK-35907:
---
Description:
I am encountering issues with the Flink CDC PostgreSQL Connector's handling of
{{bit}}
[
https://issues.apache.org/jira/browse/FLINK-35907?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
jiangcheng updated FLINK-35907:
---
Description:
I am encountering issues with the Flink CDC PostgreSQL Connector's handling of
{{bit}}
[
https://issues.apache.org/jira/browse/FLINK-35907?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
jiangcheng updated FLINK-35907:
---
Description:
I am encountering issues with the Flink CDC PostgreSQL Connector's handling of
{{bit}}
[
https://issues.apache.org/jira/browse/FLINK-35907?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
jiangcheng updated FLINK-35907:
---
Description:
I am encountering issues with the Flink CDC PostgreSQL Connector's handling of
{{bit}}
[
https://issues.apache.org/jira/browse/FLINK-35907?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
jiangcheng updated FLINK-35907:
---
Description:
I am encountering issues with the Flink CDC PostgreSQL Connector's handling of
{{bit}}
[
https://issues.apache.org/jira/browse/FLINK-35907?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
jiangcheng updated FLINK-35907:
---
Description:
I am encountering issues with the Flink CDC PostgreSQL Connector's handling of
{{bit}}
[
https://issues.apache.org/jira/browse/FLINK-35907?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
jiangcheng updated FLINK-35907:
---
Description:
I am encountering issues with the Flink CDC PostgreSQL Connector's handling of
{{bit}}
[
https://issues.apache.org/jira/browse/FLINK-35907?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
jiangcheng updated FLINK-35907:
---
Description:
I am encountering issues with the Flink CDC PostgreSQL Connector's handling of
{{bit}}
[
https://issues.apache.org/jira/browse/FLINK-35817?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17869170#comment-17869170
]
Zhanghao Chen commented on FLINK-35817:
---
The screenshot indicates high usage of JV
vahmed-hamdy commented on code in PR #25091:
URL: https://github.com/apache/flink/pull/25091#discussion_r1694253214
##
docs/content.zh/release-notes/flink-1.20.md:
##
@@ -0,0 +1,434 @@
+---
+title: "Release Notes - Flink 1.20"
+---
+
+
+# Release notes - Flink 1.20
+
+These rele
yiheng tang created FLINK-35908:
---
Summary: Flink log can not output method name and line number.
Key: FLINK-35908
URL: https://issues.apache.org/jira/browse/FLINK-35908
Project: Flink
Issue Ty
[
https://issues.apache.org/jira/browse/FLINK-35908?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
yiheng tang updated FLINK-35908:
Description:
log4j.properties:
{code}
appender.main.name = MainAppender
appender.main.type = Rolli
[
https://issues.apache.org/jira/browse/FLINK-35908?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
yiheng tang updated FLINK-35908:
Description:
log4j.properties:
{code}
appender.main.name = MainAppender
appender.main.type = Rolli
[
https://issues.apache.org/jira/browse/FLINK-35908?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
yiheng tang updated FLINK-35908:
Description:
I changed appender.main.layout.pattern in log4j.properties as follows:
{code}
appende
vahmed-hamdy commented on code in PR #152:
URL:
https://github.com/apache/flink-connector-aws/pull/152#discussion_r1694261617
##
flink-connector-aws/flink-connector-dynamodb/src/test/java/org/apache/flink/connector/dynamodb/table/RowDataToAttributeValueConverterTest.java:
##
@@
vahmed-hamdy commented on PR #152:
URL:
https://github.com/apache/flink-connector-aws/pull/152#issuecomment-2254549295
There are some style violations, Could you run `mvn spotless:apply` ahead of
the PR please?
--
This is an automated message from the Apache Git Service.
To respond to th
X-czh commented on PR #23998:
URL: https://github.com/apache/flink/pull/23998#issuecomment-2254670632
@becketqin Hi, I've added test cases and rebased it onto the latest master.
Could you take a look again?
--
This is an automated message from the Apache Git Service.
To respond to the me
snuyanzin commented on code in PR #24317:
URL: https://github.com/apache/flink/pull/24317#discussion_r1694349382
##
flink-table/flink-sql-parser/pom.xml:
##
@@ -252,6 +252,7 @@ under the License.
it under ${project.build.directory} where all freemarker
tem
snuyanzin commented on code in PR #24317:
URL: https://github.com/apache/flink/pull/24317#discussion_r1694349499
##
flink-table/flink-sql-parser/src/main/codegen/templates/Parser.jj:
##
@@ -0,0 +1,8469 @@
+/*
Review Comment:
it is already a part of Flink as it was added some
snuyanzin commented on code in PR #24317:
URL: https://github.com/apache/flink/pull/24317#discussion_r1694352182
##
flink-table/flink-sql-parser/src/test/java/org/apache/flink/sql/parser/FlinkSqlParserImplTest.java:
##
@@ -107,6 +107,10 @@ void testExplainAsDot() {}
void te
yuxiqian commented on code in PR #3497:
URL: https://github.com/apache/flink-cdc/pull/3497#discussion_r1694407945
##
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-sqlserver-cdc/src/main/java/org/apache/flink/cdc/connectors/sqlserver/source/dialect/SqlServerChunkSplitter.
1996fanrui merged PR #123:
URL: https://github.com/apache/flink-connector-jdbc/pull/123
--
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-35370?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17869218#comment-17869218
]
Rui Fan commented on FLINK-35370:
-
Merged to main(3.3.0) via: 26655e5e8864511d20208ebf6d
[
https://issues.apache.org/jira/browse/FLINK-35370?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan updated FLINK-35370:
Fix Version/s: jdbc-3.3.0
> Create a temp module to test backward compatibility
>
[
https://issues.apache.org/jira/browse/FLINK-35364?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan resolved FLINK-35364.
-
Fix Version/s: jdbc-3.3.0
Resolution: Fixed
Merged to main(3.3.0) via: b5c030bb3910a356a219fa3c0f
[
https://issues.apache.org/jira/browse/FLINK-35370?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan resolved FLINK-35370.
-
Resolution: Fixed
> Create a temp module to test backward compatibility
> --
[
https://issues.apache.org/jira/browse/FLINK-35365?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan resolved FLINK-35365.
-
Fix Version/s: jdbc-3.3.0
Resolution: Fixed
Merged to main(3.3.0) via:
* a00115191ff34bfdfc4c8d
[
https://issues.apache.org/jira/browse/FLINK-35367?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan resolved FLINK-35367.
-
Fix Version/s: jdbc-3.3.0
Resolution: Fixed
Merged to main(3.3.0) via: 64b4c8246f3e050f57df159adc
[
https://issues.apache.org/jira/browse/FLINK-35366?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan resolved FLINK-35366.
-
Fix Version/s: jdbc-3.3.0
Resolution: Fixed
Merged to main(3.3.0) via:
e07ec5f4d68a31145f0d5424
[
https://issues.apache.org/jira/browse/FLINK-35494?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan resolved FLINK-35494.
-
Fix Version/s: jdbc-3.3.0
Resolution: Fixed
Merged to main(3.3.0) via: 231542bbdbe96ecd3bfcc3f6c2
[
https://issues.apache.org/jira/browse/FLINK-35788?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan resolved FLINK-35788.
-
Fix Version/s: jdbc-3.3.0
Assignee: João Boto
Resolution: Fixed
Merged to main(3.3.0) vi
[
https://issues.apache.org/jira/browse/FLINK-35368?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan resolved FLINK-35368.
-
Fix Version/s: jdbc-3.3.0
Resolution: Fixed
Merged to main(3.3.0) via: 67046e0aabd9a36f000f6f3475
[
https://issues.apache.org/jira/browse/FLINK-35363?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17869226#comment-17869226
]
Rui Fan commented on FLINK-35363:
-
Merged to main(3.3.0) via:
* 9d535c6fefdb652faaa8a4
[
https://issues.apache.org/jira/browse/FLINK-35363?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan updated FLINK-35363:
Fix Version/s: jdbc-3.3.0
> FLIP-449: Reorganization of flink-connector-jdbc
> ---
[
https://issues.apache.org/jira/browse/FLINK-35909?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan updated FLINK-35909:
Description:
JdbcFilterPushdownPreparedStatementVisitorTest fails[1] after FLINK-35363 is
merged.
Hey
Rui Fan created FLINK-35909:
---
Summary: JdbcFilterPushdownPreparedStatementVisitorTest fails
Key: FLINK-35909
URL: https://issues.apache.org/jira/browse/FLINK-35909
Project: Flink
Issue Type: Bug
Dylan He created FLINK-35910:
Summary: Add BTRIM function
Key: FLINK-35910
URL: https://issues.apache.org/jira/browse/FLINK-35910
Project: Flink
Issue Type: Sub-task
Components: Table S
dylanhz commented on code in PR #25109:
URL: https://github.com/apache/flink/pull/25109#discussion_r1694450013
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/data/binary/BinaryStringDataUtil.java:
##
@@ -52,6 +52,8 @@ public class BinaryStringDataUtil {
[
https://issues.apache.org/jira/browse/FLINK-35817?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17869232#comment-17869232
]
ZHangTianLong commented on FLINK-35817:
---
After using this commit, the problem seem
[
https://issues.apache.org/jira/browse/FLINK-35911?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gang Yang updated FLINK-35911:
--
Description:
问题描述：业务反馈数据丢失，经排查发现是上游Kafka-Source部分分区数据没有被消费，其次业务也多次从状态重启，但这个问题仍然存在。
解决方式：后续为了排查定位问题配置了
Gang Yang created FLINK-35911:
-
Summary: Flink kafka-source connector
Key: FLINK-35911
URL: https://issues.apache.org/jira/browse/FLINK-35911
Project: Flink
Issue Type: Bug
Components:
[
https://issues.apache.org/jira/browse/FLINK-35911?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gang Yang updated FLINK-35911:
--
Description:
问题描述：业务反馈数据丢失，经排查发现是上游Kafka-Source部分分区数据没有被消费，其次业务也多次从状态重启，但这个问题仍然存在。
解决方式：后续为了排查定位问题配置了
[
https://issues.apache.org/jira/browse/FLINK-35911?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gang Yang updated FLINK-35911:
--
Description:
Problem description: Business feedback data is lost. After investigation, it is
found th
LiPL2017 commented on PR #3497:
URL: https://github.com/apache/flink-cdc/pull/3497#issuecomment-2254898541
> Thanks for @LiPL2017's contribution! Could you please also create a JIRA
ticket [here](https://issues.apache.org/jira/projects/FLINK/summary) to track
this issue?
Sorry, I hav
yux created FLINK-35912:
---
Summary: SqlServer CDC doesn't chunk UUID-typed columns correctly
Key: FLINK-35912
URL: https://issues.apache.org/jira/browse/FLINK-35912
Project: Flink
Issue Type: Bug
yuxiqian commented on PR #3497:
URL: https://github.com/apache/flink-cdc/pull/3497#issuecomment-2254901149
Created FLINK-35912 to trace this issue. Would be nice if you could rename
this PR to link it with this ticket :)
--
This is an automated message from the Apache Git Service.
To resp
yuxiqian commented on PR #3491:
URL: https://github.com/apache/flink-cdc/pull/3491#issuecomment-2254904642
Seems CI is failing since
https://github.com/apache/flink-cdc/commit/17ff659ff72e6d144e06256ed12162e604dc4804
doesn't generate `test` jar by default, which is required by Paimon E2e te
yuxiqian commented on code in PR #3497:
URL: https://github.com/apache/flink-cdc/pull/3497#discussion_r1694501101
##
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-sqlserver-cdc/src/test/java/org/apache/flink/cdc/connectors/sqlserver/testutils/SqlserverCompareUuidTest.jav
huxx created FLINK-35913:
Summary: The issue of using StreamExecutioneEnvironment to execute
multiple jobs in a program on Flink CDC
Key: FLINK-35913
URL: https://issues.apache.org/jira/browse/FLINK-35913
Pro
LiPL2017 commented on PR #3497:
URL: https://github.com/apache/flink-cdc/pull/3497#issuecomment-2254942039
> Looks good! Except you need to run `mvn spotless:apply` to fix code style
violations.
Are there any other adjustments needed besides these?
--
This is an automated message f
[
https://issues.apache.org/jira/browse/FLINK-35912?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35912:
---
Labels: pull-request-available (was: )
> SqlServer CDC doesn't chunk UUID-typed columns cor
yuxiqian commented on PR #3497:
URL: https://github.com/apache/flink-cdc/pull/3497#issuecomment-2254950848
Could @GOODBOY008 please help driving this to be merged?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
UR
sushil_karwasra created FLINK-35914:
---
Summary: Flink 1.18 runtime not supporting java 17
Key: FLINK-35914
URL: https://issues.apache.org/jira/browse/FLINK-35914
Project: Flink
Issue Type: B
[
https://issues.apache.org/jira/browse/FLINK-35914?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sushil_karwasra updated FLINK-35914:
Attachment: Flink 1.18.png
> Flink 1.18 runtime not supporting java 17
> -
[
https://issues.apache.org/jira/browse/FLINK-35910?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dylan He updated FLINK-35910:
-
Description:
Add BTRIM function as the same in Spark, where 'B' stands for BOTH.
Returns {{str}} wi
[
https://issues.apache.org/jira/browse/FLINK-35910?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dylan He updated FLINK-35910:
-
Description:
Add BTRIM function as the same in Spark, where 'B' stands for BOTH.
Returns {{str}} wi
dylanhz opened a new pull request, #25127:
URL: https://github.com/apache/flink/pull/25127
## What is the purpose of the change
Add CONV function.
Examples:
```SQL
> SELECT BTRIM(' test ');
test
> SELECT BTRIM('test', 't');
es
```
## Brief change log
[
https://issues.apache.org/jira/browse/FLINK-35910?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35910:
---
Labels: pull-request-available (was: )
> Add BTRIM function
> --
>
>
yuxiqian commented on PR #3352:
URL: https://github.com/apache/flink-cdc/pull/3352#issuecomment-2255011225
Could @ruanhang1993 take a look on this?
--
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
[
https://issues.apache.org/jira/browse/FLINK-35432?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruan Hang reassigned FLINK-35432:
-
Assignee: hk__lrzy
> Support catch modify-event for mysql-cdc
> ---
flinkbot commented on PR #25127:
URL: https://github.com/apache/flink/pull/25127#issuecomment-2255016744
## CI report:
* 28a6f290b0a46e7c73d27e07f2bba8a146ee2bc6 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
lvyanquan commented on code in PR #3495:
URL: https://github.com/apache/flink-cdc/pull/3495#discussion_r1692402071
##
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-elasticsearch/src/main/java/org/apache/flink/cdc/connectors/elasticsearch/serializer/Elastic
Dylan He created FLINK-35915:
Summary: Add MASK function
Key: FLINK-35915
URL: https://issues.apache.org/jira/browse/FLINK-35915
Project: Flink
Issue Type: Sub-task
Components: Table SQ
snuyanzin commented on PR #105:
URL:
https://github.com/apache/flink-connector-elasticsearch/pull/105#issuecomment-2255067000
thanks for the contribution @liuml07
the ci is still failing, can you please have a look ?
--
This is an automated message from the Apache Git Service.
To resp
[
https://issues.apache.org/jira/browse/FLINK-35779?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin reassigned FLINK-35779:
---
Assignee: Ahmed Hamdy
> Update documentation for PubSubSinkV2
> ---
snuyanzin merged PR #29:
URL: https://github.com/apache/flink-connector-gcp-pubsub/pull/29
--
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-unsubs
[
https://issues.apache.org/jira/browse/FLINK-35779?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17869250#comment-17869250
]
Sergey Nuyanzin commented on FLINK-35779:
-
Merged as
[a8ccb5b41c9a144fb4a58f809
[
https://issues.apache.org/jira/browse/FLINK-35779?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin resolved FLINK-35779.
-
Resolution: Fixed
> Update documentation for PubSubSinkV2
>
74 matches
Mail list logo
