[
https://issues.apache.org/jira/browse/FLINK-34752?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17837975#comment-17837975
]
LvYanquan commented on FLINK-34752:
---
[~siriusfan] Thanks for taking this, I don't have the authority
[
https://issues.apache.org/jira/browse/FLINK-35112?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17837965#comment-17837965
]
Dian Fu commented on FLINK-35112:
-
Great (y). Thanks [~wzorgdrager]
> Membership for Row class does
[
https://issues.apache.org/jira/browse/FLINK-35089?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xintong Song closed FLINK-35089.
Fix Version/s: 1.20.0
1.19.1
Resolution: Fixed
- master (1.20):
xintongsong closed pull request #24655: [FLINK-35089][runtime] Initialize
lastRecordAttributes in AbstractStreamOperator during setup
URL: https://github.com/apache/flink/pull/24655
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
fredia commented on code in PR #24671:
URL: https://github.com/apache/flink/pull/24671#discussion_r1568129118
##
flink-runtime/src/main/java/org/apache/flink/runtime/state/v2/InternalSyncState.java:
##
@@ -0,0 +1,51 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF)
[
https://issues.apache.org/jira/browse/FLINK-34907?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan updated FLINK-34907:
Description:
Currently, we consider the timestamp that JobStatus is changed to RUNNING as
jobRunningTs.
[
https://issues.apache.org/jira/browse/FLINK-35129?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17837942#comment-17837942
]
Hongshun Wang commented on FLINK-35129:
---
[~m.orazow] , would you like to take it?
> Postgres
Hongshun Wang created FLINK-35129:
-
Summary: Postgres source commits the offset after every multiple
checkpoint cycles.
Key: FLINK-35129
URL: https://issues.apache.org/jira/browse/FLINK-35129
Zakelly commented on code in PR #24657:
URL: https://github.com/apache/flink/pull/24657#discussion_r1568151628
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/asyncprocessing/AsyncStateProcessing.java:
##
@@ -34,19 +34,6 @@ public interface
Zakelly commented on code in PR #24657:
URL: https://github.com/apache/flink/pull/24657#discussion_r1568147623
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/asyncprocessing/AsyncStateProcessingOperator.java:
##
@@ -0,0 +1,54 @@
+/*
+ *
masteryhx commented on PR #24651:
URL: https://github.com/apache/flink/pull/24651#issuecomment-2060251285
Rebased master.
I will merge it after the CI is green.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
[
https://issues.apache.org/jira/browse/FLINK-35092?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xiqian YU updated FLINK-35092:
--
Summary: Add integrated test for Doris / Starrocks sink pipeline connector
(was: Add integrated test
[
https://issues.apache.org/jira/browse/FLINK-35071?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35071:
---
Labels: pull-request-available (was: )
> Remove dependency on flink-shaded from cdc source
loserwang1024 commented on PR #3083:
URL: https://github.com/apache/flink-cdc/pull/3083#issuecomment-2060246663
@PatrickRen , CC?
--
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
yuxiqian commented on code in PR #3207:
URL: https://github.com/apache/flink-cdc/pull/3207#discussion_r1568134905
##
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-doris/src/main/java/org/apache/flink/cdc/connectors/doris/sink/DorisRowConverter.java:
loserwang1024 commented on PR #3230:
URL: https://github.com/apache/flink-cdc/pull/3230#issuecomment-2060235695
@PatrickRen , @morazow , CC
--
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
[
https://issues.apache.org/jira/browse/FLINK-35128?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35128:
---
Labels: pull-request-available (was: )
> Re-calculate the starting change log offset after
loserwang1024 opened a new pull request, #3230:
URL: https://github.com/apache/flink-cdc/pull/3230
In mysql cdc, re-calculate the starting binlog offset after the new table
added in MySqlBinlogSplit#appendFinishedSplitInfos, while there lack of same
action in
[
https://issues.apache.org/jira/browse/FLINK-35028?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yanfei Lei reassigned FLINK-35028:
--
Assignee: Yanfei Lei
> Timer firing under async execution model
>
[
https://issues.apache.org/jira/browse/FLINK-35079?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiabao Sun resolved FLINK-35079.
Fix Version/s: cdc-3.1.0
Resolution: Fixed
resolved via cdc master:
Jiabao-Sun merged PR #3221:
URL: https://github.com/apache/flink-cdc/pull/3221
--
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-35046?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hangxiang Yu resolved FLINK-35046.
--
Fix Version/s: 1.20.0
Resolution: Fixed
merged 691cc671 into master.
> Introduce New
masteryhx closed pull request #24663: [FLINK-35046][state] Introduce
AsyncKeyedStateBackend supporting to create StateExecutor
URL: https://github.com/apache/flink/pull/24663
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
[
https://issues.apache.org/jira/browse/FLINK-35128?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hongshun Wang updated FLINK-35128:
--
Description:
In mysql cdc, re-calculate the starting binlog offset after the new table added
[
https://issues.apache.org/jira/browse/FLINK-35128?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hongshun Wang updated FLINK-35128:
--
Summary: Re-calculate the starting change log offset after the new table
added (was:
Hongshun Wang created FLINK-35128:
-
Summary: Re-calculate the starting binlog offset after the new
table added
Key: FLINK-35128
URL: https://issues.apache.org/jira/browse/FLINK-35128
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-35127?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17837929#comment-17837929
]
Jiabao Sun commented on FLINK-35127:
Hi [~kunni],
Could you help take a look?
> CDC
Jiabao Sun created FLINK-35127:
--
Summary: CDC ValuesDataSourceITCase crashed due to OutOfMemoryError
Key: FLINK-35127
URL: https://issues.apache.org/jira/browse/FLINK-35127
Project: Flink
Issue
ZmmBigdata opened a new pull request, #3229:
URL: https://github.com/apache/flink-cdc/pull/3229
There is an issue with the format of three shell scripts
yunfengzhou-hub commented on code in PR #24657:
URL: https://github.com/apache/flink/pull/24657#discussion_r1567131634
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/asyncprocessing/AsyncStateProcessingOperator.java:
##
@@ -0,0 +1,54 @@
+/*
+
mas-chen commented on code in PR #24564:
URL: https://github.com/apache/flink/pull/24564#discussion_r1568044466
##
docs/static/generated/rest_v1_dispatcher.yml:
##
@@ -1089,6 +1089,37 @@ paths:
application/json:
schema:
$ref:
mas-chen commented on code in PR #24564:
URL: https://github.com/apache/flink/pull/24564#discussion_r1568044466
##
docs/static/generated/rest_v1_dispatcher.yml:
##
@@ -1089,6 +1089,37 @@ paths:
application/json:
schema:
$ref:
gyfora commented on PR #816:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/816#issuecomment-2059797010
Together with the version bump, this workaround can also be removed I
believe:
[
https://issues.apache.org/jira/browse/FLINK-31966?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Adrian Vasiliu updated FLINK-31966:
---
Attachment: (was: image-2024-04-16-16-33-39-644.png)
> Flink Kubernetes operator lacks
snuyanzin merged PR #45:
URL: https://github.com/apache/flink-connector-hbase/pull/45
--
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:
Gyula Fora created FLINK-35126:
--
Summary: Improve checkpoint progress health check config and
enable by default
Key: FLINK-35126
URL: https://issues.apache.org/jira/browse/FLINK-35126
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-34653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17837752#comment-17837752
]
Leonard Xu commented on FLINK-34653:
master via 6017b165289d8e6f40db396cd07c62285be7fca9
> Support
[
https://issues.apache.org/jira/browse/FLINK-34653?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu updated FLINK-34653:
---
Release Note: (was: master via 6017b165289d8e6f40db396cd07c62285be7fca9)
> Support table merging
[
https://issues.apache.org/jira/browse/FLINK-34653?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu closed FLINK-34653.
--
Release Note: master via 6017b165289d8e6f40db396cd07c62285be7fca9
Resolution: Fixed
> Support
leonardBang merged PR #3129:
URL: https://github.com/apache/flink-cdc/pull/3129
--
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:
leonardBang commented on PR #2997:
URL: https://github.com/apache/flink-cdc/pull/2997#issuecomment-2059264100
@lvyanquan kindly ping
--
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
leonardBang commented on code in PR #3128:
URL: https://github.com/apache/flink-cdc/pull/3128#discussion_r1567483688
##
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/pipeline/PipelineOptions.java:
##
@@ -85,5 +89,12 @@ public class PipelineOptions {
[
https://issues.apache.org/jira/browse/FLINK-31966?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Adrian Vasiliu updated FLINK-31966:
---
Attachment: image-2024-04-16-16-33-39-644.png
> Flink Kubernetes operator lacks TLS support
snuyanzin merged PR #44:
URL: https://github.com/apache/flink-connector-hbase/pull/44
--
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 PR #44:
URL:
https://github.com/apache/flink-connector-hbase/pull/44#issuecomment-2059202176
Thanks for taking a look
--
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
snuyanzin opened a new pull request, #44:
URL: https://github.com/apache/flink-connector-hbase/pull/44
The PR will allow to differentiate between Hbase connector statistics and
others with name ci
--
This is an automated message from the Apache Git Service.
To respond to the
[
https://issues.apache.org/jira/browse/FLINK-34878?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-34878:
---
Labels: github-import pull-request-available (was: github-import)
> [Feature][Pipeline]
[
https://issues.apache.org/jira/browse/FLINK-33440?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin closed FLINK-33440.
---
> Bump flink version on flink-connectors-hbase
>
>
[
https://issues.apache.org/jira/browse/FLINK-33440?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin resolved FLINK-33440.
-
Fix Version/s: hbase-4.0.0
Resolution: Fixed
> Bump flink version on
[
https://issues.apache.org/jira/browse/FLINK-33440?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17837705#comment-17837705
]
Sergey Nuyanzin commented on FLINK-33440:
-
Merged as
csviri commented on code in PR #816:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/816#discussion_r1567338233
##
flink-kubernetes-operator-api/src/main/java/org/apache/flink/kubernetes/operator/api/validation/CrdCompatibilityChecker.java:
##
@@ -93,7 +93,10 @@
[
https://issues.apache.org/jira/browse/FLINK-33440?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin reassigned FLINK-33440:
---
Assignee: Ferenc Csaky
> Bump flink version on flink-connectors-hbase
>
snuyanzin merged PR #35:
URL: https://github.com/apache/flink-connector-hbase/pull/35
--
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:
mbalassi commented on PR #816:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/816#issuecomment-2059011676
I will take a look at the test failure later, it is a timeout in
`AbstractFlinkServiceTest#testBlockingDeploymentDeletion`. I managed to
reproduce it locally.
--
flinkbot commented on PR #24672:
URL: https://github.com/apache/flink/pull/24672#issuecomment-2059006200
## CI report:
* 6507dc0d38dec17e91fa3f722cd924ca82197622 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
afedulov commented on code in PR #24564:
URL: https://github.com/apache/flink/pull/24564#discussion_r1567286518
##
docs/static/generated/rest_v1_dispatcher.yml:
##
@@ -1089,6 +1089,37 @@ paths:
application/json:
schema:
$ref:
[
https://issues.apache.org/jira/browse/FLINK-35028?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35028:
---
Labels: pull-request-available (was: )
> Timer firing under async execution model
>
fredia opened a new pull request, #24672:
URL: https://github.com/apache/flink/pull/24672
## What is the purpose of the change
This PR adapts timer firing to async state execution. The entrances are
`AbstractAsyncStateStreamOperator ` and `AbstractAsyncStateStreamOperatorV2`,
dfontana commented on PR #23226:
URL: https://github.com/apache/flink/pull/23226#issuecomment-2058978531
Hi @singhravidutt thank you for your efforts; are you actively working on
this PR? I am also interested in seeing this land; am happy to help where needed
--
This is an automated
flinkbot commented on PR #24671:
URL: https://github.com/apache/flink/pull/24671#issuecomment-2058974205
## CI report:
* f4b1a4374cc6c579ff50e5b09bb5715b386645d2 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-35125?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35125:
---
Labels: pull-request-available (was: )
> Implement ValueState for ForStStateBackend
>
ljz2051 opened a new pull request, #24671:
URL: https://github.com/apache/flink/pull/24671
## What is the purpose of the change
This pull request implements the ValueState for ForStStateBackend.
## Brief change log
- Define the InternalSyncState interfaces in
Jinzhong Li created FLINK-35125:
---
Summary: Implement ValueState for ForStStateBackend
Key: FLINK-35125
URL: https://issues.apache.org/jira/browse/FLINK-35125
Project: Flink
Issue Type:
ferenc-csaky commented on PR #35:
URL:
https://github.com/apache/flink-connector-hbase/pull/35#issuecomment-2058924269
@snuyanzin I fixed the dep convergence for 1.19 the last CI run failed on,
also had to change `HBaseTablePlanTest` as the JUnit5 migration for
`TableTestBase` in the core
Zakelly commented on code in PR #24657:
URL: https://github.com/apache/flink/pull/24657#discussion_r1567158767
##
flink-runtime/src/main/java/org/apache/flink/runtime/asyncprocessing/StateRequestBuffer.java:
##
@@ -59,6 +60,9 @@ public StateRequestBuffer() {
}
void
[
https://issues.apache.org/jira/browse/FLINK-35116?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35116:
---
Labels: pull-request-available (was: )
> Upgrade JOSDK dependency to 4.8.3
>
mbalassi opened a new pull request, #816:
URL: https://github.com/apache/flink-kubernetes-operator/pull/816
Also bumps fabric8 client 6.11.0 to harmonize it with JOSDK.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use
dannycranmer opened a new pull request, #733:
URL: https://github.com/apache/flink-web/pull/733
(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
Zakelly commented on code in PR #24632:
URL: https://github.com/apache/flink/pull/24632#discussion_r1567124524
##
flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/fs/ByteBufferReadableFSDataInputStream.java:
##
@@ -0,0 +1,195 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-33991?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-33991:
--
Affects Version/s: (was: aws-connector-4.2.0)
> Custom Error Handling for Kinesis Polling
[
https://issues.apache.org/jira/browse/FLINK-32007?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-32007:
--
Fix Version/s: aws-connector-4.4.0
(was: aws-connector-4.3.0)
>
[
https://issues.apache.org/jira/browse/FLINK-33259?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-33259:
--
Fix Version/s: aws-connector-4.4.0
(was: aws-connector-4.3.0)
>
[
https://issues.apache.org/jira/browse/FLINK-33259?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-33259:
--
Affects Version/s: aws-connector-4.3.0
> flink-connector-aws should use/extend the common
[
https://issues.apache.org/jira/browse/FLINK-33991?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-33991:
--
Fix Version/s: aws-connector-4.4.0
(was: aws-connector-4.3.0)
> Custom
[
https://issues.apache.org/jira/browse/FLINK-31872?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-31872:
--
Affects Version/s: (was: aws-connector-4.2.0)
> Add Support for Configuring AIMD
[
https://issues.apache.org/jira/browse/FLINK-32116?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-32116:
--
Affects Version/s: aws-connector-4.3.0
> FlinkKinesisConsumer cannot stop-with-savepoint when
[
https://issues.apache.org/jira/browse/FLINK-25779?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-25779:
--
Fix Version/s: aws-connector-4.4.0
(was: aws-connector-4.3.0)
> Define
[
https://issues.apache.org/jira/browse/FLINK-31922?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-31922:
--
Affects Version/s: aws-connector-4.3.0
> Port over Kinesis Client configurations for retry
[
https://issues.apache.org/jira/browse/FLINK-24379?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-24379:
--
Affects Version/s: (was: aws-connector-4.2.0)
> Support AWS Glue Schema Registry Avro for
[
https://issues.apache.org/jira/browse/FLINK-31922?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-31922:
--
Fix Version/s: aws-connector-4.4.0
(was: aws-connector-4.3.0)
> Port
[
https://issues.apache.org/jira/browse/FLINK-32116?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-32116:
--
Fix Version/s: aws-connector-4.4.0
(was: aws-connector-4.3.0)
>
[
https://issues.apache.org/jira/browse/FLINK-24379?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-24379:
--
Fix Version/s: aws-connector-4.4.0
(was: aws-connector-4.3.0)
>
[
https://issues.apache.org/jira/browse/FLINK-25779?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-25779:
--
Affects Version/s: aws-connector-4.3.0
> Define ConfigOption for aws, scan and sink map in
[
https://issues.apache.org/jira/browse/FLINK-31872?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-31872:
--
Fix Version/s: aws-connector-4.4.0
(was: aws-connector-4.3.0)
> Add
[
https://issues.apache.org/jira/browse/FLINK-35124?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17837654#comment-17837654
]
Danny Cranmer commented on FLINK-35124:
---
[~echauchot] do you recall why the tools directory was
Danny Cranmer created FLINK-35124:
-
Summary: Connector Release Fails to run Checkstyle
Key: FLINK-35124
URL: https://issues.apache.org/jira/browse/FLINK-35124
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-35041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17837647#comment-17837647
]
Ryan Skraba commented on FLINK-35041:
-
1.20 test_ci core
[
https://issues.apache.org/jira/browse/FLINK-35041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17837642#comment-17837642
]
Ryan Skraba commented on FLINK-35041:
-
* 1.20 Java 11: Test (module: core)
[
https://issues.apache.org/jira/browse/FLINK-34919?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17837643#comment-17837643
]
Ryan Skraba commented on FLINK-34919:
-
1.19 Java 21: Test (module: core)
fredia commented on code in PR #24657:
URL: https://github.com/apache/flink/pull/24657#discussion_r1567096409
##
flink-runtime/src/main/java/org/apache/flink/runtime/asyncprocessing/StateRequestBuffer.java:
##
@@ -59,6 +60,9 @@ public StateRequestBuffer() {
}
void
[
https://issues.apache.org/jira/browse/FLINK-35002?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17837641#comment-17837641
]
Ryan Skraba commented on FLINK-35002:
-
1.20 AdaptiveScheduler: Compile
flinkbot commented on PR #24670:
URL: https://github.com/apache/flink/pull/24670#issuecomment-2058604771
## CI report:
* aae449392b8ce075a2413679ed2a0c42eaa52c68 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
fredia commented on code in PR #24657:
URL: https://github.com/apache/flink/pull/24657#discussion_r1567004818
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/RecordProcessorUtils.java:
##
@@ -82,6 +87,10 @@ public static ThrowingConsumer,
snuyanzin merged PR #89:
URL: https://github.com/apache/flink-connector-pulsar/pull/89
--
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-35123?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17837610#comment-17837610
]
Gyula Fora commented on FLINK-35123:
I agree that if the rest api is accessible we could call
snuyanzin commented on PR #89:
URL:
https://github.com/apache/flink-connector-pulsar/pull/89#issuecomment-2058580128
yep, thanks for noticing it
however i guess it is worth discussion first to change it
thanks for taking a look
--
This is an automated message from the Apache Git
GOODBOY008 commented on PR #24670:
URL: https://github.com/apache/flink/pull/24670#issuecomment-2058579166
@Jiabao-Sun @1996fanrui PTAL
--
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
reswqa commented on code in PR #24541:
URL: https://github.com/apache/flink/pull/24541#discussion_r1566991099
##
flink-datastream-api/src/main/java/org/apache/flink/datastream/api/context/TimestampManager.java:
##
@@ -0,0 +1,35 @@
+/*
+ * Licensed to the Apache Software
reswqa commented on code in PR #24541:
URL: https://github.com/apache/flink/pull/24541#discussion_r1566988135
##
flink-datastream-api/src/main/java/org/apache/flink/datastream/api/context/StateManager.java:
##
@@ -0,0 +1,35 @@
+/*
+ * Licensed to the Apache Software Foundation
reswqa commented on code in PR #24541:
URL: https://github.com/apache/flink/pull/24541#discussion_r1566978504
##
flink-datastream/src/main/java/org/apache/flink/datastream/impl/stream/ProcessConfigurableDataStream.java:
##
@@ -0,0 +1,72 @@
+/*
+ * Licensed to the Apache
1 - 100 of 175 matches
Mail list logo
