1996fanrui commented on PR #785:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/785#issuecomment-2114192076
> Thanks @czy006 for the contribution and @1996fanrui for the review. LGTM
on the whole. Just left a few of minor comments. PATL if you had the free time.
:)
Th
[
https://issues.apache.org/jira/browse/FLINK-35358?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rasmus Thygesen updated FLINK-35358:
Fix Version/s: 1.18.2
> Breaking change when loading artifacts
> -
[
https://issues.apache.org/jira/browse/FLINK-35358?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rasmus Thygesen updated FLINK-35358:
Fix Version/s: 1.19.1
(was: 1.18.2)
> Breaking change when loading
RocMarshal commented on code in PR #785:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/785#discussion_r1602676542
##
flink-autoscaler-standalone/src/main/java/org/apache/flink/autoscaler/standalone/utils/HikariJDBCUtil.java:
##
@@ -0,0 +1,50 @@
+/*
+ * Licensed
RocMarshal commented on code in PR #785:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/785#discussion_r1602673972
##
flink-autoscaler-standalone/src/main/java/org/apache/flink/autoscaler/standalone/utils/HikariJDBCUtil.java:
##
@@ -0,0 +1,50 @@
+/*
+ * Licensed
fredia commented on code in PR #24748:
URL: https://github.com/apache/flink/pull/24748#discussion_r1602677598
##
flink-runtime/src/main/java/org/apache/flink/runtime/asyncprocessing/EpochManager.java:
##
@@ -0,0 +1,207 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF)
loserwang1024 commented on PR #3254:
URL: https://github.com/apache/flink-cdc/pull/3254#issuecomment-2114099034
I am wondering how a commercial database sink like MaxCompute to do e2e test?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log o
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
type|https://githu
[
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
type|https://githu
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
>
>
> Key
[
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
- De
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 HiveParserCons
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 HiveParserCons
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: Sub
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 t
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 h
[
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 amplif
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, pl
[
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&focusedCommentId=17846791#comment-17846791
]
tianzhu.wen commented on FLINK-35325:
-
pr refer to: https://github.com/apache/flink-
[ 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 A
[
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 AddColumnEve
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 th
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 re
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)
## Brie
[
https://issues.apache.org/jira/browse/FLINK-35289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=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&focusedCommentId=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&focusedCommentId=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&focusedCommentId=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 Apache
[
https://issues.apache.org/jira/browse/FLINK-35289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=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&focusedCommentId=17846786#comment-17846786
]
Kanthi Vaidya commented on FLINK-35289:
---
package sample;
import lombok.extern.slf
[
https://issues.apache.org/jira/browse/FLINK-35318?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17846785#comment-17846785
]
linshangquan commented on FLINK-35318:
--
[https://github.com/apache/flink/pull/24787
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 Fou
[
https://issues.apache.org/jira/browse/FLINK-32092?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17846784#comment-17846784
]
Yanfei Lei commented on FLINK-32092:
Merged into master via b87ead7
> Integrate sna
[
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: issues-unsubscr...@flink.apache
[
https://issues.apache.org/jira/browse/FLINK-35325?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17846782#comment-17846782
]
tianzhu.wen commented on FLINK-35325:
-
I'd like to fix it, please assign it to me, t
[
https://issues.apache.org/jira/browse/FLINK-34380?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17846626#comment-17846626
]
Shuai Xu edited comment on FLINK-34380 at 5/16/24 1:58 AM:
---
Hi
[
https://issues.apache.org/jira/browse/FLINK-33109?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17846777#comment-17846777
]
Rui Fan commented on FLINK-33109:
-
Thanks [~YordanPavlov] for the feedback, let me close
[
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:
https://github.com/apach
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 iss
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 b
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, e-
[
https://issues.apache.org/jira/browse/FLINK-35289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17846759#comment-17846759
]
Jeyhun Karimov commented on FLINK-35289:
{code:java}
carData.assignTimestampsA
[
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 u
[
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 S
[
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 u
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, e-
[
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 u
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 1.20-SNAP
[
https://issues.apache.org/jira/browse/FLINK-33109?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17846747#comment-17846747
]
Yordan Pavlov commented on FLINK-33109:
---
Hi [~pnowojski] , yes we do not observe t
[
https://issues.apache.org/jira/browse/FLINK-23307?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17846732#comment-17846732
]
Glauber M Dantas commented on FLINK-23307:
--
I'm facing the same issue while usi
[
https://issues.apache.org/jira/browse/FLINK-35363?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17846731#comment-17846731
]
João Boto commented on FLINK-35363:
---
can anyone assign this to me please
> FLIP-449:
[
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 flink-connector-jdb
[
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&focusedCommentId=17846727#comment-17846727
]
João Boto commented on FLINK-35362:
---
closing as duplicated..
> Reorganization of flin
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
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
Componen
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
Com
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 sh
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&focusedCommentId=17846709#comment-17846709
]
Claire McCarthy commented on FLINK-20625:
-
yeah i am. got pre-empted by some oth
[
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 che
[
https://issues.apache.org/jira/browse/FLINK-32828?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17846694#comment-17846694
]
Piotr Nowojski edited comment on FLINK-32828 at 5/15/24 4:27 PM:
-
[
https://issues.apache.org/jira/browse/FLINK-35289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17846700#comment-17846700
]
Kanthi Vaidya edited comment on FLINK-35289 at 5/15/24 4:21 PM:
--
[
https://issues.apache.org/jira/browse/FLINK-35289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17846700#comment-17846700
]
Kanthi Vaidya edited comment on FLINK-35289 at 5/15/24 4:16 PM:
--
[
https://issues.apache.org/jira/browse/FLINK-35289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17846700#comment-17846700
]
Kanthi Vaidya commented on FLINK-35289:
---
If we do:
ctx.timerService().registerEven
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, e-mail:
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 org.apac
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 org.apache.fli
[
https://issues.apache.org/jira/browse/FLINK-32828?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17846694#comment-17846694
]
Piotr Nowojski commented on FLINK-32828:
We have just stumbled upon the same iss
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 org.apac
[
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 sho
[
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 no
[
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 shor
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 org.apache
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 org.apache
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 org.apache
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 org
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 org
1 - 100 of 185 matches
Mail list logo
