[
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
>
[
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
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:all-tabpanel
]
Sergey Nuyanzin reassigned FLINK-35779:
---
Assignee: Ahmed Hamdy
> Update documentation for PubSubSinkV2
> ---
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
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
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
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`
[
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
> ---
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-35910?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35910:
---
Labels: pull-request-available (was: )
> Add BTRIM function
> --
>
>
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
]
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
[
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
> -
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
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
[
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
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
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
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
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 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
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
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
[
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
[
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-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
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 {
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
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
[
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
[
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-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-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-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-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-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-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-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-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 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-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
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.
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.
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
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_r1694349382
##
flink-table/flink-sql-parser/pom.xml:
##
@@ -252,6 +252,7 @@ under the License.
it under ${project.build.directory} where all freemarker
tem
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
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
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:
##
@@
[
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
[
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
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
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
[
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
[
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}}
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-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-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
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
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
74 matches
Mail list logo
