mas-chen commented on code in PR #20475:
URL: https://github.com/apache/flink/pull/20475#discussion_r994178677
##
flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaWriter.java:
##
@@ -398,6 +407,11 @@ private void
[
https://issues.apache.org/jira/browse/FLINK-29611?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sopan Phaltankar updated FLINK-29611:
-
Description:
The test
[
https://issues.apache.org/jira/browse/FLINK-29612?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-29612:
---
Labels: pull-request-available (was: )
> Extract changelog files out of
tsreaper opened a new pull request, #316:
URL: https://github.com/apache/flink-table-store/pull/316
Currently changelog files are stored as extra files in `DataFileMeta`.
However for the full compaction changelog we're about to introduce, it cannot
be added as extra files because their
Caizhi Weng created FLINK-29612:
---
Summary: Extract changelog files out of DataFileMeta#extraFiles
Key: FLINK-29612
URL: https://issues.apache.org/jira/browse/FLINK-29612
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-29611?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sopan Phaltankar updated FLINK-29611:
-
Description:
The test
Sopan Phaltankar created FLINK-29611:
Summary: Fix flaky tests in CoBroadcastWithNonKeyedOperatorTest
Key: FLINK-29611
URL: https://issues.apache.org/jira/browse/FLINK-29611
Project: Flink
flinkbot commented on PR #21043:
URL: https://github.com/apache/flink/pull/21043#issuecomment-1276994446
## CI report:
* 0bd76544b8806a10f266ebaffbc184f34edb2b31 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
junjie1209 opened a new pull request, #21043:
URL: https://github.com/apache/flink/pull/21043
## What is the purpose of the change
*(For example: This pull request makes task deployment go through the blob
server, rather than through RPC. That way we avoid re-transferring
[
https://issues.apache.org/jira/browse/FLINK-25205?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee updated FLINK-25205:
-
Fix Version/s: 1.17.0
> Optimize SinkUpsertMaterializer
> ---
>
>
[
https://issues.apache.org/jira/browse/FLINK-25205?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee reassigned FLINK-25205:
Assignee: lincoln lee
> Optimize SinkUpsertMaterializer
>
flinkbot commented on PR #21042:
URL: https://github.com/apache/flink/pull/21042#issuecomment-1276968219
## CI report:
* d27b08165bbdfdc6c7aec35f4d83a429ac62b63c UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
zjureel commented on PR #313:
URL:
https://github.com/apache/flink-table-store/pull/313#issuecomment-1276966383
> Hi @zjureel can you do some benchmark to verify the improvement?
Hi @JingsongLi It's a good idea and I like it. I find there's a
`flink-table-store-benchmark` project in
luoyuxia opened a new pull request, #21042:
URL: https://github.com/apache/flink/pull/21042
## What is the purpose of the change
*(For example: This pull request makes task deployment go through the blob
server, rather than through RPC. That way we avoid re-transferring them
luoyuxia closed pull request #20907: Flink 29337 hive3
URL: https://github.com/apache/flink/pull/20907
--
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:
luoyuxia closed pull request #21020: Hive fix
URL: https://github.com/apache/flink/pull/21020
--
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-28128?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-28128.
Assignee: Shammon
Resolution: Fixed
> Create e2e test for spark reader
>
JingsongLi merged PR #314:
URL: https://github.com/apache/flink-table-store/pull/314
--
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:
flinkbot commented on PR #21041:
URL: https://github.com/apache/flink/pull/21041#issuecomment-1276957240
## CI report:
* 6d0754ff9f9915f9bba2f772801132c334aa2033 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
JingsongLi merged PR #571:
URL: https://github.com/apache/flink-web/pull/571
--
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:
leletan commented on PR #20852:
URL: https://github.com/apache/flink/pull/20852#issuecomment-1276935626
@zentol Thanks for the detailed feedbacks, really appreciated them!
I should have addressed all the comments in this round. Please take another
look when you have a chance.
--
This
leletan commented on code in PR #20852:
URL: https://github.com/apache/flink/pull/20852#discussion_r994043353
##
flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/job/checkpoints/CheckpointTriggerHandlers.java:
##
@@ -0,0 +1,261 @@
+/*
+ * Licensed to the Apache
Jiale Tan created FLINK-29610:
-
Summary: Infinite timeout is used in SavepointHandlers calls to
RestfulGateway
Key: FLINK-29610
URL: https://issues.apache.org/jira/browse/FLINK-29610
Project: Flink
flinkbot commented on PR #21040:
URL: https://github.com/apache/flink/pull/21040#issuecomment-1276929337
## CI report:
* 0216638dc7fe0d32ffef260bd43a8f1e9abc0ecc UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
SteNicholas commented on code in PR #311:
URL: https://github.com/apache/flink-table-store/pull/311#discussion_r993463151
##
flink-table-store-core/src/main/java/org/apache/flink/table/store/file/mergetree/compact/PartialUpdateMergeFunction.java:
##
@@ -54,9 +53,15 @@ public
yuzelin opened a new pull request, #21040:
URL: https://github.com/apache/flink/pull/21040
## What is the purpose of the change
*(For example: This pull request makes task deployment go through the blob
server, rather than through RPC. That way we avoid re-transferring them
lsyldliu commented on PR #20016:
URL: https://github.com/apache/flink/pull/20016#issuecomment-1276917202
@luoyuxia Can you help rebase the latest master branch?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
luoyuxia commented on PR #21026:
URL: https://github.com/apache/flink/pull/21026#issuecomment-1276917121
@flinkbot run azure
--
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.
lsyldliu commented on PR #16211:
URL: https://github.com/apache/flink/pull/16211#issuecomment-1276916499
@luoyuxia Can you help rebase the latest branch?
--
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
snuyanzin commented on code in PR #20850:
URL: https://github.com/apache/flink/pull/20850#discussion_r993950327
##
flink-table/flink-sql-parser-hive/pom.xml:
##
@@ -56,6 +56,12 @@ under the License.
guava
${guava.version}
snuyanzin commented on code in PR #20850:
URL: https://github.com/apache/flink/pull/20850#discussion_r993941510
##
flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/catalog/JavaCatalogTableTest.xml:
##
@@ -76,12 +75,11 @@
snuyanzin commented on code in PR #20850:
URL: https://github.com/apache/flink/pull/20850#discussion_r993950327
##
flink-table/flink-sql-parser-hive/pom.xml:
##
@@ -56,6 +56,12 @@ under the License.
guava
${guava.version}
snuyanzin commented on code in PR #20850:
URL: https://github.com/apache/flink/pull/20850#discussion_r993941510
##
flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/catalog/JavaCatalogTableTest.xml:
##
@@ -76,12 +75,11 @@
[
https://issues.apache.org/jira/browse/FLINK-27344?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17616698#comment-17616698
]
Alexey Leonov-Vendrovskiy commented on FLINK-27344:
---
Hi all,
+*System*+ stored
[
https://issues.apache.org/jira/browse/FLINK-29608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17616695#comment-17616695
]
Martijn Visser commented on FLINK-29608:
[~zyfeiyu] If you can translate the ticket, I will
[
https://issues.apache.org/jira/browse/FLINK-29608?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser closed FLINK-29608.
--
Resolution: Invalid
> 使用 pyflink1.17dev datastream 经过reduce 后
[
https://issues.apache.org/jira/browse/FLINK-25343?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17616627#comment-17616627
]
Ferenc Csaky commented on FLINK-25343:
--
Was that validated before that when the test fails what the
[
https://issues.apache.org/jira/browse/FLINK-29401?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-29401:
---
Labels: pull-request-available (was: )
> Improve observer structure
>
gyfora commented on PR #400:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/400#issuecomment-1276529737
cc @morhidi @gaborgsomogyi
--
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
gyfora opened a new pull request, #400:
URL: https://github.com/apache/flink-kubernetes-operator/pull/400
## What is the purpose of the change
The goal is to create a shared observer hierarchy for all Flink resources
and factor out the common bits to base classes in a similar way how
leletan commented on code in PR #20852:
URL: https://github.com/apache/flink/pull/20852#discussion_r993738316
##
flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/CheckpointTriggerStatusHeaders.java:
##
@@ -0,0 +1,82 @@
+/*
+ * Licensed to the
flinkbot commented on PR #21039:
URL: https://github.com/apache/flink/pull/21039#issuecomment-1276513698
## CI report:
* 3b7b65a0aec3eee7ddd96fa61fd8c06ee47b6ac6 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-25343?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-25343:
---
Labels: pull-request-available stale-assigned test-stability (was:
stale-assigned
ferenc-csaky opened a new pull request, #21039:
URL: https://github.com/apache/flink/pull/21039
## What is the purpose of the change
TODO
## Brief change log
TODO
## Verifying this change
This change is a trivial rework / code cleanup without any test
kosigz closed pull request #21024: Unpin cloudpickle
URL: https://github.com/apache/flink/pull/21024
--
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:
kosigz commented on PR #21024:
URL: https://github.com/apache/flink/pull/21024#issuecomment-1276471102
Wrong repo. This should be against the Lyft fork.
--
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
XComp commented on code in PR #21019:
URL: https://github.com/apache/flink/pull/21019#discussion_r993681403
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamingJobGraphGenerator.java:
##
@@ -298,6 +303,27 @@ private JobGraph createJobGraph() {
sap1ens commented on PR #20475:
URL: https://github.com/apache/flink/pull/20475#issuecomment-1276450517
@PatrickRen thanks for reminding me about that, I kicked off the discussion.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
XComp commented on code in PR #21019:
URL: https://github.com/apache/flink/pull/21019#discussion_r993681403
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamingJobGraphGenerator.java:
##
@@ -298,6 +303,27 @@ private JobGraph createJobGraph() {
XComp commented on code in PR #21019:
URL: https://github.com/apache/flink/pull/21019#discussion_r993677013
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamingJobGraphGenerator.java:
##
@@ -298,6 +303,27 @@ private JobGraph createJobGraph() {
[
https://issues.apache.org/jira/browse/FLINK-29548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-29548:
-
Summary: Remove deprecated MiniClusterResource (was: Remove deprecated
class files of
[
https://issues.apache.org/jira/browse/FLINK-29548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-29548:
-
Issue Type: Technical Debt (was: Improvement)
> Remove deprecated MiniClusterResource
[
https://issues.apache.org/jira/browse/FLINK-29548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-29548.
Release Note:
The deprecated MiniClusterResource in flink-test-utils has been removed.
zentol merged PR #20989:
URL: https://github.com/apache/flink/pull/20989
--
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:
gaborgsomogyi commented on PR #394:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/394#issuecomment-1276402549
Updated PR description to reflect latest code.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
gaborgsomogyi commented on PR #394:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/394#issuecomment-1276398075
I've retested it manually and works fine.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use
kristoffSC commented on PR #20979:
URL: https://github.com/apache/flink/pull/20979#issuecomment-1276386158
@flinkbot run azure
--
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
kristoffSC commented on PR #21029:
URL: https://github.com/apache/flink/pull/21029#issuecomment-1276385366
@flinkbot run azure
--
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
gaborgsomogyi commented on code in PR #394:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/394#discussion_r993617128
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/reconciler/deployment/ApplicationReconciler.java:
##
@@ -272,6
gaborgsomogyi commented on code in PR #394:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/394#discussion_r993616745
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/reconciler/deployment/JobHealthChecker.java:
##
@@ -0,0 +1,130 @@
echauchot commented on PR #21037:
URL: https://github.com/apache/flink/pull/21037#issuecomment-1276320564
> What is the exception that you? Is it the assertion error about the final
job state? Why not just allow both canceled & finished?
While testing an incorrect bounded source that
echauchot commented on code in PR #21037:
URL: https://github.com/apache/flink/pull/21037#discussion_r993500768
##
flink-test-utils-parent/flink-connector-test-utils/src/main/java/org/apache/flink/connector/testframe/testsuites/SourceTestSuiteBase.java:
##
@@ -462,11 +477,18 @@
MartijnVisser commented on PR #20170:
URL: https://github.com/apache/flink/pull/20170#issuecomment-1276309598
@zentol Can I get one more look at this one too?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
MartijnVisser commented on code in PR #20955:
URL: https://github.com/apache/flink/pull/20955#discussion_r993568474
##
flink-filesystems/flink-fs-hadoop-shaded/src/main/resources/META-INF/NOTICE:
##
@@ -32,6 +32,8 @@ This project bundles the following dependencies under the
zjureel commented on PR #314:
URL:
https://github.com/apache/flink-table-store/pull/314#issuecomment-1276273061
@JingsongLi Thanks for your comments, and I have updated the codes :)
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
[
https://issues.apache.org/jira/browse/FLINK-29570?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-29570.
Fix Version/s: 1.17.0
Resolution: Fixed
master:
zentol merged PR #20736:
URL: https://github.com/apache/flink/pull/20736
--
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-29609:
--
Summary: Clean up jobmanager deployment on suspend after recording
savepoint info
Key: FLINK-29609
URL: https://issues.apache.org/jira/browse/FLINK-29609
Project: Flink
echauchot commented on code in PR #21035:
URL: https://github.com/apache/flink/pull/21035#discussion_r993466238
##
flink-test-utils-parent/flink-connector-test-utils/src/main/java/org/apache/flink/connector/testframe/testsuites/SourceTestSuiteBase.java:
##
@@ -448,7 +451,7 @@
XComp commented on code in PR #574:
URL: https://github.com/apache/flink-web/pull/574#discussion_r993507797
##
_posts/2022-10-10-1.16-announcement.md:
##
@@ -0,0 +1,401 @@
+---
+layout: post
+title: "Announcing the Release of Apache Flink 1.16"
+subtitle: ""
+date:
echauchot commented on code in PR #21037:
URL: https://github.com/apache/flink/pull/21037#discussion_r993503365
##
flink-test-utils-parent/flink-connector-test-utils/src/main/java/org/apache/flink/connector/testframe/testsuites/SourceTestSuiteBase.java:
##
@@ -462,11 +477,18 @@
[
https://issues.apache.org/jira/browse/FLINK-25205?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17616441#comment-17616441
]
lincoln lee commented on FLINK-25205:
-
[~lzljs3620320] can you assign it to me? I'd like to try to
echauchot commented on code in PR #21037:
URL: https://github.com/apache/flink/pull/21037#discussion_r993503365
##
flink-test-utils-parent/flink-connector-test-utils/src/main/java/org/apache/flink/connector/testframe/testsuites/SourceTestSuiteBase.java:
##
@@ -462,11 +477,18 @@
echauchot commented on code in PR #21037:
URL: https://github.com/apache/flink/pull/21037#discussion_r993500768
##
flink-test-utils-parent/flink-connector-test-utils/src/main/java/org/apache/flink/connector/testframe/testsuites/SourceTestSuiteBase.java:
##
@@ -462,11 +477,18 @@
[
https://issues.apache.org/jira/browse/FLINK-29607?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17616435#comment-17616435
]
Matyas Orhidi commented on FLINK-29607:
---
+1 this is a great idea
> Simplify controller flow by
kristoffSC commented on PR #20979:
URL: https://github.com/apache/flink/pull/20979#issuecomment-1276202112
@flinkbot run azure
--
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
echauchot commented on code in PR #21035:
URL: https://github.com/apache/flink/pull/21035#discussion_r993466238
##
flink-test-utils-parent/flink-connector-test-utils/src/main/java/org/apache/flink/connector/testframe/testsuites/SourceTestSuiteBase.java:
##
@@ -448,7 +451,7 @@
flinkbot commented on PR #21038:
URL: https://github.com/apache/flink/pull/21038#issuecomment-1276177128
## CI report:
* 3d383e663e63ea2a70c5b64b5593a6191f2adce4 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
SteNicholas commented on code in PR #311:
URL: https://github.com/apache/flink-table-store/pull/311#discussion_r993463151
##
flink-table-store-core/src/main/java/org/apache/flink/table/store/file/mergetree/compact/PartialUpdateMergeFunction.java:
##
@@ -54,9 +53,15 @@ public
SteNicholas commented on code in PR #311:
URL: https://github.com/apache/flink-table-store/pull/311#discussion_r993462724
##
docs/layouts/shortcodes/generated/core_configuration.html:
##
@@ -170,6 +170,12 @@
MemorySize
Memory page size.
+
SteNicholas commented on code in PR #311:
URL: https://github.com/apache/flink-table-store/pull/311#discussion_r991985956
##
docs/layouts/shortcodes/generated/core_configuration.html:
##
@@ -170,6 +170,12 @@
MemorySize
Memory page size.
+
zentol commented on code in PR #21012:
URL: https://github.com/apache/flink/pull/21012#discussion_r993456043
##
flink-runtime-web/src/test/java/org/apache/flink/runtime/webmonitor/handlers/JarRunHandlerParameterTest.java:
##
@@ -90,7 +90,6 @@ static void setup(@TempDir File
flinkbot commented on PR #21037:
URL: https://github.com/apache/flink/pull/21037#issuecomment-1276166901
## CI report:
* 4505e0c5d6384a7faadb84d98b7339bf9527 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
zentol commented on code in PR #21035:
URL: https://github.com/apache/flink/pull/21035#discussion_r993453532
##
flink-test-utils-parent/flink-connector-test-utils/src/main/java/org/apache/flink/connector/testframe/testsuites/SourceTestSuiteBase.java:
##
@@ -448,7 +451,7 @@
zoucao opened a new pull request, #21038:
URL: https://github.com/apache/flink/pull/21038
## What is the purpose of the change
backport of https://github.com/apache/flink/pull/19250
## Brief change log
*(for example:)*
- *The TaskInfo is stored in the blob
[
https://issues.apache.org/jira/browse/FLINK-29608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17616415#comment-17616415
]
Martijn Visser commented on FLINK-29608:
[~zyfeiyu] Can you please translate your ticket to
[
https://issues.apache.org/jira/browse/FLINK-29608?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-29608:
---
Affects Version/s: (was: shaded-16.0)
> 使用 pyflink1.17dev datastream 经过reduce 后
[
https://issues.apache.org/jira/browse/FLINK-29605?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-29605:
---
Labels: pull-request-available (was: )
> Create a bounded version of
zentol commented on code in PR #21037:
URL: https://github.com/apache/flink/pull/21037#discussion_r993448262
##
flink-test-utils-parent/flink-connector-test-utils/src/main/java/org/apache/flink/connector/testframe/testsuites/SourceTestSuiteBase.java:
##
@@ -462,11 +477,18 @@
[
https://issues.apache.org/jira/browse/FLINK-21708?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17616412#comment-17616412
]
Chesnay Schepler commented on FLINK-21708:
--
[~tapan_halani] It's not possible to hide this
fapaul commented on PR #21029:
URL: https://github.com/apache/flink/pull/21029#issuecomment-1276155740
flinkbot run azure
--
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.
echauchot opened a new pull request, #21037:
URL: https://github.com/apache/flink/pull/21037
## What is the purpose of the change
Allow implementers to have bounded and unbounded
SourceTestSuiteBase#testSourceMetrics
Based on [timeout
[
https://issues.apache.org/jira/browse/FLINK-21708?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17616407#comment-17616407
]
Tapan Halani commented on FLINK-21708:
--
[~rmetzger] I am a newbie to flink, and I am trying to
[
https://issues.apache.org/jira/browse/FLINK-29606?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17616405#comment-17616405
]
Hamid EL MAAZOUZ commented on FLINK-29606:
--
[~martijnvisser] Thanks for the info, I will move
flinkbot commented on PR #21036:
URL: https://github.com/apache/flink/pull/21036#issuecomment-1276126918
## CI report:
* d691b5727738e5997c4c4c20f6127fd8986e69ba UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
zoucao opened a new pull request, #21036:
URL: https://github.com/apache/flink/pull/21036
## What is the purpose of the change
backport of https://github.com/apache/flink/pull/19250
## Brief change log
*(for example:)*
- *The TaskInfo is stored in the
flinkbot commented on PR #21035:
URL: https://github.com/apache/flink/pull/21035#issuecomment-1276101855
## CI report:
* 56c44bd4e3ef6ed5e3e65d12079f1fd257c3cc57 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
flinkbot commented on PR #21034:
URL: https://github.com/apache/flink/pull/21034#issuecomment-1276101525
## CI report:
* 114c25904da642623aaeb783403e59523056873e UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-29337?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17616391#comment-17616391
]
luoyuxia commented on FLINK-29337:
--
[~jark] Yes. I have opened the pr
[
https://issues.apache.org/jira/browse/FLINK-29563?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-29563:
---
Labels: pull-request-available (was: )
> SourceTestSuiteBase#testSourceMetrics enters an
1 - 100 of 287 matches
Mail list logo
