masteryhx commented on code in PR #24798:
URL: https://github.com/apache/flink/pull/24798#discussion_r1602658277
##
flink-runtime/src/main/java/org/apache/flink/runtime/state/v2/ReducingStateDescriptor.java:
##
@@ -0,0 +1,74 @@
+/*
+ * Licensed to the Apache Software Foundation
[
https://issues.apache.org/jira/browse/FLINK-35371?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ammar Master updated FLINK-35371:
-
Description:
Flink always creates a keystore and trustore using the [default
[
https://issues.apache.org/jira/browse/FLINK-35371?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ammar Master updated FLINK-35371:
-
Description:
Flink always creates a keystore and trustore using the [default
Ammar Master created FLINK-35371:
Summary: Allow the keystore and truststore type to configured for
SSL
Key: FLINK-35371
URL: https://issues.apache.org/jira/browse/FLINK-35371
Project: Flink
flinkbot commented on PR #24798:
URL: https://github.com/apache/flink/pull/24798#issuecomment-2114037580
## CI report:
* a8938c86450f0cf9cc878926e560630e7f063e2c UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-35356?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zakelly Lan reassigned FLINK-35356:
---
Assignee: Zakelly Lan
> Async reducing state
>
>
>
[
https://issues.apache.org/jira/browse/FLINK-35356?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35356:
---
Labels: pull-request-available (was: )
> Async reducing state
>
>
>
Zakelly opened a new pull request, #24798:
URL: https://github.com/apache/flink/pull/24798
## What is the purpose of the change
This PR provides the definition of `StateDescriptor` and simple
implementation for `ReducingState` in `State V2`.
## Brief change log
-
reswqa commented on code in PR #18:
URL:
https://github.com/apache/flink-connector-hive/pull/18#discussion_r1602581492
##
flink-connector-hive/src/main/java/org/apache/flink/table/planner/delegation/hive/HiveParserConstants.java:
##
@@ -30,4 +30,6 @@ public class
reswqa commented on code in PR #18:
URL:
https://github.com/apache/flink-connector-hive/pull/18#discussion_r1602576000
##
flink-connector-hive/src/main/java/org/apache/flink/table/planner/delegation/hive/HiveParserConstants.java:
##
@@ -30,4 +30,6 @@ public class
João Boto created FLINK-35370:
-
Summary: Create a temp module to test backward compatibility
Key: FLINK-35370
URL: https://issues.apache.org/jira/browse/FLINK-35370
Project: Flink
Issue Type:
reswqa commented on code in PR #18:
URL:
https://github.com/apache/flink-connector-hive/pull/18#discussion_r1602571412
##
flink-connector-hive/src/test/java/org/apache/flink/connectors/hive/HiveDialectSupportSQL11ReservedKeywordAsIdentifierTest.java:
##
@@ -0,0 +1,230 @@
+/*
+
melin commented on PR #3323:
URL: https://github.com/apache/flink-cdc/pull/3323#issuecomment-2113979566
https://github.com/apache/paimon/issues/3316
--
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
Zakelly commented on code in PR #24766:
URL: https://github.com/apache/flink/pull/24766#discussion_r1602564828
##
docs/content/docs/dev/datastream/fault-tolerance/checkpointing.md:
##
@@ -292,4 +292,26 @@ The final checkpoint would be triggered immediately after
all operators
[
https://issues.apache.org/jira/browse/FLINK-32088?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zakelly Lan reassigned FLINK-32088:
---
Assignee: Zakelly Lan (was: Han Yin)
> Re-uploading in state file-merging for space
Jiabao-Sun opened a new pull request, #3324:
URL: https://github.com/apache/flink-cdc/pull/3324
--
This is an automated message from the Apache Git Service.
To respond to the message,
[
https://issues.apache.org/jira/browse/FLINK-32083?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zakelly Lan closed FLINK-32083.
---
Resolution: Duplicate
> Chinese translation of documentation of checkpoint file-merging
>
[
https://issues.apache.org/jira/browse/FLINK-35325?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17846791#comment-17846791
]
tianzhu.wen commented on FLINK-35325:
-
pr refer to: https://github.com/apache/flink-cdc/pull/3323
>
[ https://issues.apache.org/jira/browse/FLINK-35325 ]
tianzhu.wen deleted comment on FLINK-35325:
-
was (Author: JIRAUSER305385):
pr refer to: https://github.com/apache/flink-cdc/pull/3323
> Paimon connector miss the position of AddColumnEvent
joyCurry30 opened a new pull request, #3323:
URL: https://github.com/apache/flink-cdc/pull/3323
Refer to jira: https://issues.apache.org/jira/browse/FLINK-35325
Adding support for specifying column order when adding new columns to a
table.
--
This is an automated message from the
[
https://issues.apache.org/jira/browse/FLINK-35325?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35325:
---
Labels: pull-request-available (was: )
> Paimon connector miss the position of
Zakelly commented on PR #24793:
URL: https://github.com/apache/flink/pull/24793#issuecomment-2113919880
@drymatini I think your commits include the wrong files by mistake, maybe
you amend commit my previous one?
--
This is an automated message from the Apache Git Service.
To respond to
hackergin commented on PR #24767:
URL: https://github.com/apache/flink/pull/24767#issuecomment-2113912527
@lsyldliu Thanks for the updates and explanations, LGTM.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
flinkbot commented on PR #24797:
URL: https://github.com/apache/flink/pull/24797#issuecomment-2113909464
## CI report:
* 2b52d0c6115bda908bb717fbaedca29efde7e52c UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
flinkbot commented on PR #24796:
URL: https://github.com/apache/flink/pull/24796#issuecomment-2113905453
## CI report:
* 822fd38cfcecd1061ca4014c4461ace561303000 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-35226?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35226:
---
Labels: pull-request-available (was: )
> Deprecate execution-mode in ExecutionConfigInfo
1996fanrui opened a new pull request, #24797:
URL: https://github.com/apache/flink/pull/24797
## What is the purpose of the change
See
[FLIP-441](https://cwiki.apache.org/confluence/display/FLINK/FLIP-441%3A+Show+the+JobType+and+remove+Execution+Mode+on+Flink+WebUI)
##
[
https://issues.apache.org/jira/browse/FLINK-35289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17846786#comment-17846786
]
Kanthi Vaidya edited comment on FLINK-35289 at 5/16/24 2:31 AM:
[
https://issues.apache.org/jira/browse/FLINK-35225?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35225:
---
Labels: pull-request-available (was: )
> Remove Execution mode in Flink WebUI
>
[
https://issues.apache.org/jira/browse/FLINK-35289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17846786#comment-17846786
]
Kanthi Vaidya edited comment on FLINK-35289 at 5/16/24 2:29 AM:
[
https://issues.apache.org/jira/browse/FLINK-35289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17846786#comment-17846786
]
Kanthi Vaidya edited comment on FLINK-35289 at 5/16/24 2:28 AM:
[
https://issues.apache.org/jira/browse/FLINK-35289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17846786#comment-17846786
]
Kanthi Vaidya edited comment on FLINK-35289 at 5/16/24 2:27 AM:
lsyldliu commented on code in PR #24767:
URL: https://github.com/apache/flink/pull/24767#discussion_r1602508279
##
flink-table/flink-table-common/src/main/java/org/apache/flink/table/factories/WorkflowSchedulerFactoryUtil.java:
##
@@ -0,0 +1,156 @@
+/*
+ * Licensed to the
[
https://issues.apache.org/jira/browse/FLINK-35289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17846786#comment-17846786
]
Kanthi Vaidya edited comment on FLINK-35289 at 5/16/24 2:22 AM:
[
https://issues.apache.org/jira/browse/FLINK-35289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17846786#comment-17846786
]
Kanthi Vaidya commented on FLINK-35289:
---
package sample;
import lombok.extern.slf4j.Slf4j;
import
[
https://issues.apache.org/jira/browse/FLINK-35318?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17846785#comment-17846785
]
linshangquan commented on FLINK-35318:
--
[https://github.com/apache/flink/pull/24787]
Hi [~qingyue]
lsyldliu commented on code in PR #24767:
URL: https://github.com/apache/flink/pull/24767#discussion_r1602497989
##
flink-table/flink-table-common/src/main/java/org/apache/flink/table/workflow/WorkflowScheduler.java:
##
@@ -0,0 +1,91 @@
+/*
+ * Licensed to the Apache Software
[
https://issues.apache.org/jira/browse/FLINK-32092?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17846784#comment-17846784
]
Yanfei Lei commented on FLINK-32092:
Merged into master via b87ead7
> Integrate snapshot
[
https://issues.apache.org/jira/browse/FLINK-32092?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yanfei Lei resolved FLINK-32092.
Resolution: Resolved
> Integrate snapshot file-merging with existing IT cases
>
fredia merged PR #24789:
URL: https://github.com/apache/flink/pull/24789
--
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-35325?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17846782#comment-17846782
]
tianzhu.wen commented on FLINK-35325:
-
I'd like to fix it, please assign it to me, thanks.
> Paimon
[
https://issues.apache.org/jira/browse/FLINK-34380?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17846626#comment-17846626
]
Shuai Xu edited comment on FLINK-34380 at 5/16/24 1:58 AM:
---
Hi [~rovboyko] ,
[
https://issues.apache.org/jira/browse/FLINK-33109?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17846777#comment-17846777
]
Rui Fan commented on FLINK-33109:
-
Thanks [~YordanPavlov] for the feedback, let me close this JIRA.
>
[
https://issues.apache.org/jira/browse/FLINK-33109?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan closed FLINK-33109.
---
Resolution: Not A Problem
> Watermark alignment not applied after recovery from checkpoint
>
flinkbot commented on PR #24795:
URL: https://github.com/apache/flink/pull/24795#issuecomment-2113596687
## CI report:
* c3b588c4a44d135ccebe6acafa75e3b1a9aa4895 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
ViktorCosenza commented on PR #23881:
URL: https://github.com/apache/flink/pull/23881#issuecomment-2113594484
> Hi @LoveHeat, can you cherry-pick the change in #24029 from @ukby1234 and
merge the two PRs?
@xccui, i've created a PR cherry picking both commits:
ViktorCosenza opened a new pull request, #24795:
URL: https://github.com/apache/flink/pull/24795
## What is the purpose of the change
This Pull request adds commits from
https://github.com/apache/flink/pull/24029 and
https://github.com/apache/flink/pull/23881 to fully resolve
jeyhunkarimov commented on code in PR #24788:
URL: https://github.com/apache/flink/pull/24788#discussion_r1602288457
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/utils/DynamicPartitionPruningUtils.java:
##
@@ -234,20 +234,16 @@ private static
snuyanzin opened a new pull request, #741:
URL: https://github.com/apache/flink-web/pull/741
(no comment)
--
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,
[
https://issues.apache.org/jira/browse/FLINK-35289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17846759#comment-17846759
]
Jeyhun Karimov commented on FLINK-35289:
{code:java}
carData.assignTimestampsAndWatermarks(
[
https://issues.apache.org/jira/browse/FLINK-35369?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Keith Lee updated FLINK-35369:
--
Description:
Flink has rich and varied SQL offerings/deployment mode, it can take some time
for new
[
https://issues.apache.org/jira/browse/FLINK-35369?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Keith Lee updated FLINK-35369:
--
Summary: Improve `Table API and SQL` overview page or add new page to guide
new users to right Flink
[
https://issues.apache.org/jira/browse/FLINK-35369?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Keith Lee updated FLINK-35369:
--
Description:
Flink has rich and varied SQL offerings/deployment mode, it can take some time
for new
snuyanzin opened a new pull request, #740:
URL: https://github.com/apache/flink-web/pull/740
(no comment)
--
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,
[
https://issues.apache.org/jira/browse/FLINK-35369?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Keith Lee updated FLINK-35369:
--
Description:
Flink has rich and varied SQL offerings/deployment mode, it can take some time
for new
Keith Lee created FLINK-35369:
-
Summary: Improve `Table API and SQL` page or add new page to guide
new users to right Flink SQL option
Key: FLINK-35369
URL: https://issues.apache.org/jira/browse/FLINK-35369
[
https://issues.apache.org/jira/browse/FLINK-35094?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin updated FLINK-35094:
Fix Version/s: opensearch-2.0.0
> SinkTestSuiteBase.testScaleDown is hanging for
[
https://issues.apache.org/jira/browse/FLINK-33109?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17846747#comment-17846747
]
Yordan Pavlov commented on FLINK-33109:
---
Hi [~pnowojski] , yes we do not observe the problem in
[
https://issues.apache.org/jira/browse/FLINK-23307?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17846732#comment-17846732
]
Glauber M Dantas commented on FLINK-23307:
--
I'm facing the same issue while using the JDBC
[
https://issues.apache.org/jira/browse/FLINK-35363?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17846731#comment-17846731
]
João Boto commented on FLINK-35363:
---
can anyone assign this to me please
> FLIP-449: Reorganization
[
https://issues.apache.org/jira/browse/FLINK-35363?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
João Boto updated FLINK-35363:
--
Summary: FLIP-449: Reorganization of flink-connector-jdbc (was:
Reorganization of
[
https://issues.apache.org/jira/browse/FLINK-35362?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
João Boto closed FLINK-35362.
-
Resolution: Duplicate
> Reorganization of flink-connector-jdbc
> --
[
https://issues.apache.org/jira/browse/FLINK-35362?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17846727#comment-17846727
]
João Boto commented on FLINK-35362:
---
closing as duplicated..
> Reorganization of flink-connector-jdbc
João Boto created FLINK-35368:
-
Summary: Reorganize table code
Key: FLINK-35368
URL: https://issues.apache.org/jira/browse/FLINK-35368
Project: Flink
Issue Type: Sub-task
Reporter:
João Boto created FLINK-35367:
-
Summary: Reorganize datastream sink and source
Key: FLINK-35367
URL: https://issues.apache.org/jira/browse/FLINK-35367
Project: Flink
Issue Type: Sub-task
João Boto created FLINK-35366:
-
Summary: Create all database modules
Key: FLINK-35366
URL: https://issues.apache.org/jira/browse/FLINK-35366
Project: Flink
Issue Type: Sub-task
João Boto created FLINK-35365:
-
Summary: Reorganize catalog and dialect code
Key: FLINK-35365
URL: https://issues.apache.org/jira/browse/FLINK-35365
Project: Flink
Issue Type: Sub-task
João Boto created FLINK-35364:
-
Summary: Create core module and move code
Key: FLINK-35364
URL: https://issues.apache.org/jira/browse/FLINK-35364
Project: Flink
Issue Type: Sub-task
flinkbot commented on PR #24794:
URL: https://github.com/apache/flink/pull/24794#issuecomment-2113084800
## CI report:
* 18492c53d984d530f1182c161942ae9a61b84733 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-32828?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-32828:
---
Labels: pull-request-available (was: )
> Partition aware watermark not handled correctly
pnowojski opened a new pull request, #24794:
URL: https://github.com/apache/flink/pull/24794
## What is the purpose of the change
Properly initialize initial splits in WatermarkOutputMultiplexer
Without this fix, initial splits were registered in the multiplexer only
anleib commented on code in PR #23610:
URL: https://github.com/apache/flink/pull/23610#discussion_r1601965479
##
flink-metrics/flink-metrics-datadog/src/main/java/org/apache/flink/metrics/datadog/DatadogHttpClient.java:
##
@@ -41,9 +41,9 @@ public class DatadogHttpClient {
[
https://issues.apache.org/jira/browse/FLINK-20625?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17846709#comment-17846709
]
Claire McCarthy commented on FLINK-20625:
-
yeah i am. got pre-empted by some other work but it's
[
https://issues.apache.org/jira/browse/FLINK-32828?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski updated FLINK-32828:
---
Summary: Partition aware watermark not handled correctly shortly after job
start up from
[
https://issues.apache.org/jira/browse/FLINK-32828?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17846694#comment-17846694
]
Piotr Nowojski edited comment on FLINK-32828 at 5/15/24 4:27 PM:
-
We
[
https://issues.apache.org/jira/browse/FLINK-35289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17846700#comment-17846700
]
Kanthi Vaidya edited comment on FLINK-35289 at 5/15/24 4:21 PM:
When
[
https://issues.apache.org/jira/browse/FLINK-35289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17846700#comment-17846700
]
Kanthi Vaidya edited comment on FLINK-35289 at 5/15/24 4:16 PM:
When
[
https://issues.apache.org/jira/browse/FLINK-35289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17846700#comment-17846700
]
Kanthi Vaidya commented on FLINK-35289:
---
If we do:
João Boto created FLINK-35363:
-
Summary: Reorganization of flink-connector-jdbc
Key: FLINK-35363
URL: https://issues.apache.org/jira/browse/FLINK-35363
Project: Flink
Issue Type: Improvement
João Boto created FLINK-35362:
-
Summary: Reorganization of flink-connector-jdbc
Key: FLINK-35362
URL: https://issues.apache.org/jira/browse/FLINK-35362
Project: Flink
Issue Type: Improvement
manoellins closed pull request #82: Fsip module 2b
URL: https://github.com/apache/flink-training/pull/82
--
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,
snuyanzin commented on code in PR #27:
URL:
https://github.com/apache/flink-connector-gcp-pubsub/pull/27#discussion_r1601908776
##
flink-connector-gcp-pubsub/src/main/java/org/apache/flink/connector/gcp/pubsub/sink/PubSubSinkV2Builder.java:
##
@@ -0,0 +1,93 @@
+package
snuyanzin commented on code in PR #27:
URL:
https://github.com/apache/flink-connector-gcp-pubsub/pull/27#discussion_r1601907967
##
flink-connector-gcp-pubsub/src/main/java/org/apache/flink/connector/gcp/pubsub/sink/PubSubWriter.java:
##
@@ -0,0 +1,195 @@
+package
[
https://issues.apache.org/jira/browse/FLINK-32828?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17846694#comment-17846694
]
Piotr Nowojski commented on FLINK-32828:
We have just stumbled upon the same issue and I can
snuyanzin commented on code in PR #27:
URL:
https://github.com/apache/flink-connector-gcp-pubsub/pull/27#discussion_r1601895646
##
flink-connector-gcp-pubsub/src/main/java/org/apache/flink/connector/gcp/pubsub/sink/PubSubSinkV2Builder.java:
##
@@ -0,0 +1,93 @@
+package
[
https://issues.apache.org/jira/browse/FLINK-32828?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski updated FLINK-32828:
---
Priority: Critical (was: Major)
> Kafka partition aware watermark not handled correctly
[
https://issues.apache.org/jira/browse/FLINK-32828?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski updated FLINK-32828:
---
Affects Version/s: 1.18.1
1.19.0
> Kafka partition aware watermark
[
https://issues.apache.org/jira/browse/FLINK-32828?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski reassigned FLINK-32828:
--
Assignee: Piotr Nowojski
> Kafka partition aware watermark not handled correctly
snuyanzin commented on code in PR #27:
URL:
https://github.com/apache/flink-connector-gcp-pubsub/pull/27#discussion_r1601877099
##
flink-connector-gcp-pubsub/src/test/java/org/apache/flink/connector/gcp/pubsub/sink/PubSubWriterTest.java:
##
@@ -0,0 +1,245 @@
+package
snuyanzin commented on code in PR #27:
URL:
https://github.com/apache/flink-connector-gcp-pubsub/pull/27#discussion_r1601876558
##
flink-connector-gcp-pubsub/src/test/java/org/apache/flink/connector/gcp/pubsub/sink/PubSubWriterTest.java:
##
@@ -0,0 +1,245 @@
+package
snuyanzin commented on code in PR #27:
URL:
https://github.com/apache/flink-connector-gcp-pubsub/pull/27#discussion_r1601876167
##
flink-connector-gcp-pubsub/src/test/java/org/apache/flink/connector/gcp/pubsub/sink/PubSubWriterTest.java:
##
@@ -0,0 +1,245 @@
+package
snuyanzin commented on code in PR #27:
URL:
https://github.com/apache/flink-connector-gcp-pubsub/pull/27#discussion_r1601875238
##
flink-connector-gcp-pubsub/src/test/java/org/apache/flink/connector/gcp/pubsub/sink/PubSubSinkV2BuilderTest.java:
##
@@ -0,0 +1,133 @@
+package
snuyanzin commented on code in PR #27:
URL:
https://github.com/apache/flink-connector-gcp-pubsub/pull/27#discussion_r1601874397
##
flink-connector-gcp-pubsub/src/test/java/org/apache/flink/connector/gcp/pubsub/sink/PubSubSinkV2BuilderTest.java:
##
@@ -0,0 +1,133 @@
+package
snuyanzin commented on code in PR #27:
URL:
https://github.com/apache/flink-connector-gcp-pubsub/pull/27#discussion_r1601862072
##
flink-connector-gcp-pubsub/src/main/java/org/apache/flink/connector/gcp/pubsub/sink/PubSubSinkV2Builder.java:
##
@@ -0,0 +1,93 @@
+package
snuyanzin commented on code in PR #27:
URL:
https://github.com/apache/flink-connector-gcp-pubsub/pull/27#discussion_r1601862072
##
flink-connector-gcp-pubsub/src/main/java/org/apache/flink/connector/gcp/pubsub/sink/PubSubSinkV2Builder.java:
##
@@ -0,0 +1,93 @@
+package
flinkbot commented on PR #24793:
URL: https://github.com/apache/flink/pull/24793#issuecomment-2112866675
## CI report:
* 7e6de7ba7ec1eb66d47384ba7a3a829f661d4423 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
snuyanzin commented on code in PR #27:
URL:
https://github.com/apache/flink-connector-gcp-pubsub/pull/27#discussion_r1601857522
##
.github/workflows/weekly.yml:
##
@@ -37,10 +37,6 @@ jobs:
flink: 1.19-SNAPSHOT,
jdk: '8, 11, 17, 21',
branch:
morazow commented on code in PR #29:
URL:
https://github.com/apache/flink-connector-rabbitmq/pull/29#discussion_r1601778225
##
flink-connector-rabbitmq/src/main/java/org/apache/flink/connector/rabbitmq/common/RabbitMQConnectionConfig.java:
##
@@ -0,0 +1,465 @@
+package
drymatini commented on PR #24793:
URL: https://github.com/apache/flink/pull/24793#issuecomment-2112848104
@wuchong @Zakelly Hi, I have finished the translation of the page.Could you
please verify my pull request?
--
This is an automated message from the Apache Git Service.
To respond to
drymatini opened a new pull request, #24793:
URL: https://github.com/apache/flink/pull/24793
## What is the purpose of the change
"Profiler "page was released in English and it should be translated into
Chineses
## Brief change log
translate
1 - 100 of 186 matches
Mail list logo
