zhongqishang commented on code in PR #3226:
URL: https://github.com/apache/flink-cdc/pull/3226#discussion_r1581741205
##
flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/event/DataChangeEventSerializer.java:
##
@@ -76,28 +72,18 @@ public DataChangeEvent de
hzjhjjyy commented on PR #2495:
URL: https://github.com/apache/flink-cdc/pull/2495#issuecomment-2080353903
> Hi @hzjhjjyy, thanks for your contribution! Could you please rebase your
PR with latest `master` branch before it could be merged? You may need to
rename packages like from `com.verv
melin created FLINK-35248:
-
Summary: Support table/column comment to modify DDL
Key: FLINK-35248
URL: https://issues.apache.org/jira/browse/FLINK-35248
Project: Flink
Issue Type: New Feature
wangqinghuan closed pull request #1071: support op_type metadata columns
URL: https://github.com/apache/flink-cdc/pull/1071
--
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 u
HuangZhenQiu commented on code in PR #24618:
URL: https://github.com/apache/flink/pull/24618#discussion_r1581716086
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/common/CommonExecTableSourceScan.java:
##
@@ -133,6 +139,21 @@ prot
HuangZhenQiu commented on code in PR #24618:
URL: https://github.com/apache/flink/pull/24618#discussion_r1581321727
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/transformations/PhysicalTransformation.java:
##
@@ -34,6 +35,7 @@
public abstract class Physi
HuangZhenQiu commented on code in PR #24618:
URL: https://github.com/apache/flink/pull/24618#discussion_r1581715242
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamGraph.java:
##
@@ -123,6 +124,7 @@ public class StreamGraph implements Pipeline {
mas-chen commented on code in PR #97:
URL:
https://github.com/apache/flink-connector-kafka/pull/97#discussion_r1581372979
##
flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/dynamic/source/enumerator/DynamicKafkaSourceEnumeratorTest.java:
##
@@ -464,6 +466,8
[
https://issues.apache.org/jira/browse/FLINK-35247?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mason Chen updated FLINK-35247:
---
Description:
Spotless apply version from flink-connector-parent does not work with Java 21
Issue fo
Mason Chen created FLINK-35247:
--
Summary: Upgrade spotless apply to `2.41.1` in
flink-connector-parent to work with Java 21
Key: FLINK-35247
URL: https://issues.apache.org/jira/browse/FLINK-35247
Project
HuangZhenQiu commented on code in PR #24618:
URL: https://github.com/apache/flink/pull/24618#discussion_r1581326630
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/stream/StreamExecLegacyTableSourceScan.java:
##
@@ -90,6 +90,7 @@ p
HuangZhenQiu commented on code in PR #24618:
URL: https://github.com/apache/flink/pull/24618#discussion_r1581321727
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/transformations/PhysicalTransformation.java:
##
@@ -34,6 +35,7 @@
public abstract class Physi
[
https://issues.apache.org/jira/browse/FLINK-35240?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17841301#comment-17841301
]
Zhongqiang Gong edited comment on FLINK-35240 at 4/26/24 5:11 PM:
flinkbot commented on PR #24731:
URL: https://github.com/apache/flink/pull/24731#issuecomment-2079751600
## CI report:
* 93207bb3788bdcd5f6cf3657c2feb5d92ddb5871 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-35240?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17841301#comment-17841301
]
Zhongqiang Gong commented on FLINK-35240:
-
[~afedulov] I opened a pr to patch th
HuangZhenQiu opened a new pull request, #24731:
URL: https://github.com/apache/flink/pull/24731
## What is the purpose of the change
Format the class comments of lineage interface classes
## Brief change log
- Remove the unneeded empty line of class comments
## Veri
flinkbot commented on PR #24730:
URL: https://github.com/apache/flink/pull/24730#issuecomment-2079743542
## CI report:
* 418a88849ef1c9f850cc80b5f691cfe033ac7c09 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
GOODBOY008 commented on code in PR #90:
URL:
https://github.com/apache/flink-connector-pulsar/pull/90#discussion_r1581286005
##
flink-connector-pulsar/src/test/java/org/apache/flink/connector/pulsar/testutils/SampleData.java:
##
@@ -49,7 +49,7 @@ public Foo() {}
@Ove
[
https://issues.apache.org/jira/browse/FLINK-35240?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35240:
---
Labels: pull-request-available (was: )
> Disable FLUSH_AFTER_WRITE_VALUE to avoid flush per
GOODBOY008 opened a new pull request, #24730:
URL: https://github.com/apache/flink/pull/24730
Changes:
- Disable `FLUSH_AFTER_WRITE_VALUE`
- Use
`ObjectWriter#writeValue(org.apache.flink.shaded.jackson2.com.fasterxml.jackson.core.JsonGenerator,
java.lang.Object)` instead of `ObjectWr
davidradl commented on PR #22026:
URL: https://github.com/apache/flink/pull/22026#issuecomment-2079731646
> > @davidradl Make sense to back port this as we should treat this as a
bugfix because sql client previously supported SSL, which is a kind of
regresssion.
> > If you want, just go
ferenc-csaky commented on code in PR #22789:
URL: https://github.com/apache/flink/pull/22789#discussion_r1581270742
##
flink-filesystems/flink-gs-fs-hadoop/src/test/java/org/apache/flink/fs/gs/writer/GSRecoverableFsDataOutputStreamTest.java:
##
@@ -133,57 +131,57 @@ public void
davidradl closed pull request #24729: [FLINK-31223][sqlgateway] Introduce
getFlinkConfigurationOptions to g…
URL: https://github.com/apache/flink/pull/24729
--
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
[ https://issues.apache.org/jira/browse/FLINK-31223 ]
david radley deleted comment on FLINK-31223:
--
was (Author: JIRAUSER300523):
[~Weijie Guo] I have created pr [https://github.com/apache/flink/pull/24729]
for the 1.18 backport
> sql-client.
davidradl commented on PR #24729:
URL: https://github.com/apache/flink/pull/24729#issuecomment-2079655100
incomplete will redo
--
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-31223?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17841279#comment-17841279
]
david radley edited comment on FLINK-31223 at 4/26/24 3:47 PM:
---
[
https://issues.apache.org/jira/browse/FLINK-31223?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17841279#comment-17841279
]
david radley commented on FLINK-31223:
--
[~Weijie Guo] I have created pr [https://gi
[
https://issues.apache.org/jira/browse/FLINK-35240?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17841271#comment-17841271
]
Alexander Fedulov commented on FLINK-35240:
---
[~gongzhongqiang] and [~robyoung]
[
https://issues.apache.org/jira/browse/FLINK-35240?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Fedulov updated FLINK-35240:
--
Attachment: image-2024-04-26-17-16-20-647.png
> Disable FLUSH_AFTER_WRITE_VALUE to avo
[
https://issues.apache.org/jira/browse/FLINK-35240?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Fedulov updated FLINK-35240:
--
Attachment: image-2024-04-26-17-16-30-293.png
> Disable FLUSH_AFTER_WRITE_VALUE to avo
[
https://issues.apache.org/jira/browse/FLINK-35240?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Fedulov updated FLINK-35240:
--
Attachment: image-2024-04-26-17-16-07-925.png
> Disable FLUSH_AFTER_WRITE_VALUE to avo
[
https://issues.apache.org/jira/browse/FLINK-35232?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17841267#comment-17841267
]
Oleksandr Nitavskyi commented on FLINK-35232:
-
[~galenwarren] thanks. We hav
[
https://issues.apache.org/jira/browse/FLINK-35232?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Oleksandr Nitavskyi updated FLINK-35232:
Description:
https://issues.apache.org/jira/browse/FLINK-32877 is tracking ability
[
https://issues.apache.org/jira/browse/FLINK-35232?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Oleksandr Nitavskyi updated FLINK-35232:
Description:
https://issues.apache.org/jira/browse/FLINK-32877 is tracking ability
[
https://issues.apache.org/jira/browse/FLINK-35232?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Oleksandr Nitavskyi updated FLINK-35232:
Description:
https://issues.apache.org/jira/browse/FLINK-32877 is tracking ability
vahmed-hamdy commented on code in PR #136:
URL:
https://github.com/apache/flink-connector-aws/pull/136#discussion_r1581114799
##
flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/sink/DynamoDbTypeInformedElementConverter.java:
##
@@
IgnasD commented on PR #97:
URL:
https://github.com/apache/flink-connector-kafka/pull/97#issuecomment-2079488271
Changed the title as requested. Also, I've added filtering to
`unassignedInitialPartitions` as suggested and covered it with a test case.
--
This is an automated message from
IgnasD commented on code in PR #97:
URL:
https://github.com/apache/flink-connector-kafka/pull/97#discussion_r1581103075
##
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source/enumerator/DynamicKafkaSourceEnumerator.java:
##
@@ -288,36 +288,39 @@
vahmed-hamdy commented on code in PR #136:
URL:
https://github.com/apache/flink-connector-aws/pull/136#discussion_r1581083313
##
flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/sink/DynamoDbTypeInformedElementConverter.java:
##
@@
[
https://issues.apache.org/jira/browse/FLINK-35240?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17841232#comment-17841232
]
Zhongqiang Gong edited comment on FLINK-35240 at 4/26/24 1:34 PM:
[
https://issues.apache.org/jira/browse/FLINK-35240?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17841238#comment-17841238
]
Zhongqiang Gong commented on FLINK-35240:
-
Base on the logic of _writer. close，W
[
https://issues.apache.org/jira/browse/FLINK-35240?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17841232#comment-17841232
]
Zhongqiang Gong commented on FLINK-35240:
-
!截图-1.png!
The close methed always
[
https://issues.apache.org/jira/browse/FLINK-35240?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17841232#comment-17841232
]
Zhongqiang Gong edited comment on FLINK-35240 at 4/26/24 1:22 PM:
[
https://issues.apache.org/jira/browse/FLINK-35246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17841227#comment-17841227
]
Weijie Guo commented on FLINK-35246:
master via 4e6dbe2d1a225a0d0e48fd0997c1f1131740
[
https://issues.apache.org/jira/browse/FLINK-35246?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo closed FLINK-35246.
--
Resolution: Fixed
> SqlClientSSLTest.testGatewayMode failed in AZP
> -
reswqa merged PR #24727:
URL: https://github.com/apache/flink/pull/24727
--
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
reswqa commented on PR #24727:
URL: https://github.com/apache/flink/pull/24727#issuecomment-2079379345
Thanks for the review, merging...
--
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 specif
syhily commented on PR #84:
URL:
https://github.com/apache/flink-connector-pulsar/pull/84#issuecomment-2079360052
Plz close this PR for it has been fixed in #85. @tisonkun
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
syhily commented on code in PR #90:
URL:
https://github.com/apache/flink-connector-pulsar/pull/90#discussion_r1581009843
##
flink-connector-pulsar/src/test/java/org/apache/flink/connector/pulsar/testutils/SampleData.java:
##
@@ -49,7 +49,7 @@ public Foo() {}
@Overrid
syhily commented on PR #91:
URL:
https://github.com/apache/flink-connector-pulsar/pull/91#issuecomment-2079354340
> > The pulsar-client-all should be upgrade to the 3.0.4 in the mean time.
>
> @syhily After `pulsar-client-all` was updated to 3.0.4, the unit test
failed. I took a brie
flinkbot commented on PR #24728:
URL: https://github.com/apache/flink/pull/24728#issuecomment-2079305845
## CI report:
* 6511c8930cde9f8a3e3acef78fc3bcecb5e9cb51 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
davidradl commented on PR #22026:
URL: https://github.com/apache/flink/pull/22026#issuecomment-2079304678
> @davidradl Make sense to back port this as we should treat this as a
bugfix because sql client previously supported SSL, which is a kind of
regresssion.
>
> If you want, just g
[
https://issues.apache.org/jira/browse/FLINK-35194?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35194:
---
Labels: pull-request-available (was: )
> Support describe job syntax and execution
> --
xuyangzhong opened a new pull request, #24728:
URL: https://github.com/apache/flink/pull/24728
## What is the purpose of the change
Support syntax '{ DESCRIBE | DESC } JOB 'xxx''
## Brief change log
- *Support to parse syntax { DESCRIBE | DESC } JOB 'xxx'*
- *Suppo
[
https://issues.apache.org/jira/browse/FLINK-35097?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17841197#comment-17841197
]
David Perkins commented on FLINK-35097:
---
Can the fix get applied to 1.17 also?
>
yuxiqian commented on code in PR #3226:
URL: https://github.com/apache/flink-cdc/pull/3226#discussion_r1580840112
##
flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/event/DataChangeEventSerializer.java:
##
@@ -76,28 +72,18 @@ public DataChangeEvent deseri
[
https://issues.apache.org/jira/browse/FLINK-35026?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yanfei Lei resolved FLINK-35026.
Resolution: Resolved
> Introduce async execution configurations
>
[
https://issues.apache.org/jira/browse/FLINK-35026?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17841182#comment-17841182
]
Yanfei Lei commented on FLINK-35026:
Merged into master via 713c30f..3ff2ba4
> Int
fredia merged PR #24667:
URL: https://github.com/apache/flink/pull/24667
--
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
kottmann commented on PR #22789:
URL: https://github.com/apache/flink/pull/22789#issuecomment-2079230716
Sorry for the delay on my end, I added a new commit to address all your
comments above.
--
This is an automated message from the Apache Git Service.
To respond to the message, please l
boring-cyborg[bot] commented on PR #99:
URL:
https://github.com/apache/flink-connector-kafka/pull/99#issuecomment-2079138385
Thanks for opening this pull request! Please check out our contributing
guidelines. (https://flink.apache.org/contributing/how-to-contribute.html)
--
This is a
yuxiqian commented on code in PR #3226:
URL: https://github.com/apache/flink-cdc/pull/3226#discussion_r1580840112
##
flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/event/DataChangeEventSerializer.java:
##
@@ -76,28 +72,18 @@ public DataChangeEvent deseri
yuxiqian commented on code in PR #3226:
URL: https://github.com/apache/flink-cdc/pull/3226#discussion_r1580840112
##
flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/event/DataChangeEventSerializer.java:
##
@@ -76,28 +72,18 @@ public DataChangeEvent deseri
[
https://issues.apache.org/jira/browse/FLINK-34694?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17837205#comment-17837205
]
Roman Boyko edited comment on FLINK-34694 at 4/26/24 10:04 AM:
---
[
https://issues.apache.org/jira/browse/FLINK-34694?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17837205#comment-17837205
]
Roman Boyko edited comment on FLINK-34694 at 4/26/24 10:05 AM:
---
[
https://issues.apache.org/jira/browse/FLINK-34694?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17837205#comment-17837205
]
Roman Boyko edited comment on FLINK-34694 at 4/26/24 10:01 AM:
---
[
https://issues.apache.org/jira/browse/FLINK-35192?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17841129#comment-17841129
]
Biao Geng commented on FLINK-35192:
---
!screenshot-3.png!
According to the flink k8s o
[
https://issues.apache.org/jira/browse/FLINK-35192?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Biao Geng updated FLINK-35192:
--
Attachment: screenshot-3.png
> operator oom
>
>
> Key: FLINK-35192
>
[
https://issues.apache.org/jira/browse/FLINK-35195?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
dalongliu reassigned FLINK-35195:
-
Assignee: dalongliu
> Support the execution of create materialized table in continuous refresh
[
https://issues.apache.org/jira/browse/FLINK-35189?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17841128#comment-17841128
]
dalongliu commented on FLINK-35189:
---
Merged in master: 714d1cb2e0bd0df03393492dc87cbd8
[
https://issues.apache.org/jira/browse/FLINK-35189?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
dalongliu resolved FLINK-35189.
---
Resolution: Fixed
> Introduce test-filesystem Catalog based on FileSystem Connector to support
> ma
lsyldliu merged PR #24712:
URL: https://github.com/apache/flink/pull/24712
--
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.apac
[
https://issues.apache.org/jira/browse/FLINK-35197?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
dalongliu reassigned FLINK-35197:
-
Assignee: Feng Jin
> Support the execution of suspend, resume materialized table in continuous
[
https://issues.apache.org/jira/browse/FLINK-35194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17841122#comment-17841122
]
dalongliu commented on FLINK-35194:
---
Yeah, assigned to you.
> Support describe job sy
[
https://issues.apache.org/jira/browse/FLINK-35194?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
dalongliu reassigned FLINK-35194:
-
Assignee: xuyang
> Support describe job syntax and execution
>
yuxiqian commented on PR #3226:
URL: https://github.com/apache/flink-cdc/pull/3226#issuecomment-2079004056
@Jiabao-Sun Sure, I'll take 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 spec
Jiabao-Sun commented on PR #3226:
URL: https://github.com/apache/flink-cdc/pull/3226#issuecomment-2078993303
Thanks @zhongqishang for this fix.
Hi @yuxiqian, do you have time to review this PR?
--
This is an automated message from the Apache Git Service.
To respond to the message, pleas
[
https://issues.apache.org/jira/browse/FLINK-35240?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17841117#comment-17841117
]
Alexander Fedulov commented on FLINK-35240:
---
I don't think touching any of the
[
https://issues.apache.org/jira/browse/FLINK-32877?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer resolved FLINK-32877.
---
Resolution: Done
> Support for HTTP connect and timeout options while writes in GCS connecto
dannycranmer commented on PR #23226:
URL: https://github.com/apache/flink/pull/23226#issuecomment-2078971443
Merged in https://github.com/apache/flink/pull/24673
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
dannycranmer closed pull request #23226: [FLINK-32877][Filesystem]add HTTP
options to gcs-cloud-storage client
URL: https://github.com/apache/flink/pull/23226
--
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
flinkbot commented on PR #24727:
URL: https://github.com/apache/flink/pull/24727#issuecomment-2078971258
## CI report:
* a327b1e5ee7948bfd7f5c699222be5575e72f6f6 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-35244?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiabao Sun reassigned FLINK-35244:
--
Assignee: Xie Yi
> Move package for flink-connector-tidb-cdc test
> -
[
https://issues.apache.org/jira/browse/FLINK-32877?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-32877:
--
Affects Version/s: 1.18.1
1.19.0
> Support for HTTP connect and timeout
[
https://issues.apache.org/jira/browse/FLINK-32877?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-32877:
--
Fix Version/s: 1.20.0
> Support for HTTP connect and timeout options while writes in GCS conne
dannycranmer merged PR #24673:
URL: https://github.com/apache/flink/pull/24673
--
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.
dannycranmer commented on PR #24673:
URL: https://github.com/apache/flink/pull/24673#issuecomment-2078968511
Apologies I did not fix the commit message 🤦
--
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 t
[
https://issues.apache.org/jira/browse/FLINK-35246?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35246:
---
Labels: pull-request-available (was: )
> SqlClientSSLTest.testGatewayMode failed in AZP
> -
reswqa commented on PR #22026:
URL: https://github.com/apache/flink/pull/22026#issuecomment-2078960338
@davidradl Make sense to back port this as we should treat this as a bugfix
because sql client previously supported SSL, which is a kind of regresssion.
--
This is an automated message f
[
https://issues.apache.org/jira/browse/FLINK-35235?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiabao Sun resolved FLINK-35235.
Assignee: LvYanquan
Resolution: Fixed
Resolved via
* cdc master: ec643c9dd7365261f3cee620d4
dannycranmer commented on PR #24673:
URL: https://github.com/apache/flink/pull/24673#issuecomment-2078965258
LGTM, I will fix the commit message on merge
--
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
[
https://issues.apache.org/jira/browse/FLINK-35194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17841113#comment-17841113
]
xuyang commented on FLINK-35194:
Hi, can I take this jira?
> Support describe job synta
Jiabao-Sun merged PR #3262:
URL: https://github.com/apache/flink-cdc/pull/3262
--
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.
[
https://issues.apache.org/jira/browse/FLINK-35246?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo reassigned FLINK-35246:
--
Assignee: Weijie Guo
> SqlClientSSLTest.testGatewayMode failed in AZP
> -
Weijie Guo created FLINK-35246:
--
Summary: SqlClientSSLTest.testGatewayMode failed in AZP
Key: FLINK-35246
URL: https://issues.apache.org/jira/browse/FLINK-35246
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-35246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1784#comment-1784
]
Weijie Guo commented on FLINK-35246:
{code:java}
InetSocketAddress.createUnresolved
Jiabao-Sun merged PR #3263:
URL: https://github.com/apache/flink-cdc/pull/3263
--
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.
[
https://issues.apache.org/jira/browse/FLINK-35246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1784#comment-1784
]
Weijie Guo edited comment on FLINK-35246 at 4/26/24 8:59 AM:
-
fredia commented on PR #24653:
URL: https://github.com/apache/flink/pull/24653#issuecomment-2078953534
@Zakelly @1996fanrui would you please to take a look? thanks!
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
U
xieyi888 commented on PR #1974:
URL: https://github.com/apache/flink-cdc/pull/1974#issuecomment-2078942188
> add metrcis: currentFetchEventTimeLag, currentEmitEventTimeLag,
sourceIdleTime for TiKVRichParallelSourceFunction
> Thanks @xieyi888 for the great work! Before this PR
1 - 100 of 131 matches
Mail list logo
