reswqa commented on code in PR #23013:
URL: https://github.com/apache/flink/pull/23013#discussion_r1280153766
##
flink-connectors/flink-connector-files/src/main/java/org/apache/flink/connector/file/table/stream/StreamingSink.java:
##
@@ -173,7 +173,7 @@ public static
wanglijie95 commented on code in PR #23085:
URL: https://github.com/apache/flink/pull/23085#discussion_r1280165421
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamingJobGraphGenerator.java:
##
@@ -896,12 +896,13 @@ private String
Matthias Pohl created FLINK-32722:
-
Summary: 239 exit code in flink-runtime
Key: FLINK-32722
URL: https://issues.apache.org/jira/browse/FLINK-32722
Project: Flink
Issue Type: Bug
Rui Fan created FLINK-32723:
---
Summary: FLIP-334 : Decoupling autoscaler and kubernetes
Key: FLINK-32723
URL: https://issues.apache.org/jira/browse/FLINK-32723
Project: Flink
Issue Type: New
JunRuiLee commented on code in PR #23085:
URL: https://github.com/apache/flink/pull/23085#discussion_r1280227631
##
flink-streaming-java/src/test/java/org/apache/flink/streaming/api/graph/StreamingJobGraphGeneratorTest.java:
##
@@ -1693,6 +1723,10 @@ public JobGraph
zoltar9264 opened a new pull request, #23111:
URL: https://github.com/apache/flink/pull/23111
…ownloader
## What is the purpose of the change
Fix unstable test :
RocksDBStateDownloaderTest.testMultiThreadCleanupOnFailure , discuss in
[
https://issues.apache.org/jira/browse/FLINK-32681?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-32681:
---
Labels: pull-request-available test-stability (was: test-stability)
>
flinkbot commented on PR #23111:
URL: https://github.com/apache/flink/pull/23111#issuecomment-1659784617
## CI report:
* 4194cd88a4b5f3e51d2d54d99fb7325cc0a2b8b7 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-32706?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Konstantin Knauf reassigned FLINK-32706:
Assignee: Hanyu Zheng
> Add SPLIT(STRING) support in SQL & Table API
>
lindong28 commented on code in PR #22931:
URL: https://github.com/apache/flink/pull/22931#discussion_r1280153092
##
flink-runtime/src/main/java/org/apache/flink/runtime/source/event/EndOfDataEvent.java:
##
@@ -0,0 +1,24 @@
+/*
+ * Licensed to the Apache Software Foundation
[
https://issues.apache.org/jira/browse/FLINK-32681?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl reassigned FLINK-32681:
-
Assignee: Stefan Richter
> RocksDBStateDownloaderTest.testMultiThreadCleanupOnFailure
JunRuiLee commented on code in PR #23085:
URL: https://github.com/apache/flink/pull/23085#discussion_r1280228067
##
flink-streaming-java/src/test/java/org/apache/flink/streaming/api/graph/StreamingJobGraphGeneratorTest.java:
##
@@ -1693,6 +1723,10 @@ public JobGraph
JunRuiLee commented on PR #23085:
URL: https://github.com/apache/flink/pull/23085#issuecomment-1659747018
@wanglijie95 Thanks for CR and I've updated this pr, PTAL.
--
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-32681?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17749541#comment-17749541
]
Feifan Wang commented on FLINK-32681:
-
Sorry [~mapohl] I didn't notice that the ticket has been
xintongsong commented on code in PR #23026:
URL: https://github.com/apache/flink/pull/23026#discussion_r1280146390
##
flink-examples/flink-examples-batch/pom.xml:
##
@@ -48,25 +48,6 @@ under the License.
-
-
[
https://issues.apache.org/jira/browse/FLINK-32223?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17749498#comment-17749498
]
Qingsheng Ren commented on FLINK-32223:
---
I can't find any confirmation from RMs about this issue
[
https://issues.apache.org/jira/browse/FLINK-32645?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17749501#comment-17749501
]
Vijaya Bhaskar V commented on FLINK-32645:
--
[~syhily] thanks its working fine now. Will report
[
https://issues.apache.org/jira/browse/FLINK-32681?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17749522#comment-17749522
]
Feifan Wang edited comment on FLINK-32681 at 8/1/23 8:03 AM:
-
Hi [~srichter]
flinkbot commented on PR #23112:
URL: https://github.com/apache/flink/pull/23112#issuecomment-1659808707
## CI report:
* ead319a56e310e4d0c9330d68736bbde25708a4a UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
whhe commented on PR #17:
URL:
https://github.com/apache/flink-connector-hbase/pull/17#issuecomment-1659629496
Any progress? @MartijnVisser
--
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-32223?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17749491#comment-17749491
]
Matthias Pohl commented on FLINK-32223:
---
That said, was this issue confirmed by the release
[
https://issues.apache.org/jira/browse/FLINK-32223?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl reopened FLINK-32223:
---
[~gaborgsomogyi] [~jiaoqb] I'm reopening the issue. It introduced a compilation
error on
[
https://issues.apache.org/jira/browse/FLINK-32223?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-32223:
--
Component/s: Connectors / Hadoop Compatibility
> Add Hive delegation token support
>
[
https://issues.apache.org/jira/browse/FLINK-32223?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-32223:
--
Priority: Blocker (was: Minor)
> Add Hive delegation token support
>
[
https://issues.apache.org/jira/browse/FLINK-32663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17749523#comment-17749523
]
Qingsheng Ren commented on FLINK-32663:
---
[~fanrui] Could you help investigating this issue? It's
[
https://issues.apache.org/jira/browse/FLINK-32681?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17749522#comment-17749522
]
Feifan Wang commented on FLINK-32681:
-
Hi [~srichter] , I'm also very interested in this problem. I
[
https://issues.apache.org/jira/browse/FLINK-32570?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-32570:
--
Parent: (was: FLINK-32557)
Issue Type: Technical Debt (was: Sub-task)
>
luoyuxia commented on code in PR #23013:
URL: https://github.com/apache/flink/pull/23013#discussion_r1280147373
##
flink-connectors/flink-connector-files/src/main/java/org/apache/flink/connector/file/table/stream/StreamingSink.java:
##
@@ -173,7 +173,7 @@ public static
[
https://issues.apache.org/jira/browse/FLINK-32268?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17749492#comment-17749492
]
Qingsheng Ren commented on FLINK-32268:
---
I checked the log but found no clue... Probably some
[
https://issues.apache.org/jira/browse/FLINK-32268?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Qingsheng Ren updated FLINK-32268:
--
Priority: Major (was: Critical)
> KafkaTableITCase.testKafkaSourceSinkWithBoundedTimestamp
[
https://issues.apache.org/jira/browse/FLINK-32268?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Qingsheng Ren updated FLINK-32268:
--
Affects Version/s: kafka-4.0.0
(was: 1.18.0)
>
[
https://issues.apache.org/jira/browse/FLINK-32722?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17749506#comment-17749506
]
Matthias Pohl commented on FLINK-32722:
---
I did a log analysis on unfinished tests without success.
JunRuiLee commented on code in PR #23085:
URL: https://github.com/apache/flink/pull/23085#discussion_r1280229513
##
flink-streaming-java/src/test/java/org/apache/flink/streaming/api/graph/StreamingJobGraphGeneratorTest.java:
##
@@ -1655,28 +1655,58 @@ void
[
https://issues.apache.org/jira/browse/FLINK-32663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17749525#comment-17749525
]
Rui Fan commented on FLINK-32663:
-
Thanks for the report, I will take a look asap. cc [~renqs]
>
reswqa opened a new pull request, #23112:
URL: https://github.com/apache/flink/pull/23112
## 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 on
xintongsong commented on code in PR #23026:
URL: https://github.com/apache/flink/pull/23026#discussion_r1280173681
##
flink-examples/flink-examples-batch/pom.xml:
##
@@ -48,25 +48,6 @@ under the License.
-
-
[
https://issues.apache.org/jira/browse/FLINK-32662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17749486#comment-17749486
]
Matthias Pohl commented on FLINK-32662:
---
[
https://issues.apache.org/jira/browse/FLINK-32645?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17746603#comment-17746603
]
Vijaya Bhaskar V edited comment on FLINK-32645 at 8/1/23 7:04 AM:
--
[
https://issues.apache.org/jira/browse/FLINK-15736?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17749535#comment-17749535
]
Konstantin Knauf commented on FLINK-15736:
--
How do users usually learn about support for new
reswqa commented on PR #23112:
URL: https://github.com/apache/flink/pull/23112#issuecomment-1659794575
Before:
After:
gaborgsomogyi commented on PR #21788:
URL: https://github.com/apache/flink/pull/21788#issuecomment-1659816555
@MartijnVisser are you fine w/ the PR? I'm merging if you say to...
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub
[
https://issues.apache.org/jira/browse/FLINK-32559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-32559:
---
Labels: pull-request-available (was: )
> Deprecate Queryable State
>
WencongLiu commented on PR #23100:
URL: https://github.com/apache/flink/pull/23100#issuecomment-1659886610
@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
[
https://issues.apache.org/jira/browse/FLINK-32678?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Qingsheng Ren updated FLINK-32678:
--
Summary: Release Testing: Stress-Test to cover multiple low-level changes
in Flink (was:
[
https://issues.apache.org/jira/browse/FLINK-32678?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Qingsheng Ren updated FLINK-32678:
--
Parent: FLINK-32726
Issue Type: Sub-task (was: Technical Debt)
> Stress-Test to
[
https://issues.apache.org/jira/browse/FLINK-32570?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Qingsheng Ren updated FLINK-32570:
--
Priority: Major (was: Blocker)
> Deprecate API that uses Flink's Time implementation
flinkbot commented on PR #23115:
URL: https://github.com/apache/flink/pull/23115#issuecomment-1660101777
## CI report:
* 15e5ae87167dc6ecf69f2ad1e830552b1dd9af5a UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-32685?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo reassigned FLINK-32685:
--
Assignee: Weijie Guo
> Performance regression on sortedMultiInput and sortedTwoInput since
[
https://issues.apache.org/jira/browse/FLINK-32663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17749651#comment-17749651
]
Rui Fan edited comment on FLINK-32663 at 8/1/23 12:04 PM:
--
This bug is caused
[
https://issues.apache.org/jira/browse/FLINK-32581?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-32581:
---
Labels: pull-request-available (was: )
> Add document for atomic CTAS
>
Tartarus0zm commented on PR #23116:
URL: https://github.com/apache/flink/pull/23116#issuecomment-1660176464
@luoyuxia PTAL, if you have time, thanks~
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to
[
https://issues.apache.org/jira/browse/FLINK-32709?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yuxin Tan updated FLINK-32709:
--
Summary: Fix the bug of low memory utilization for Hybrid Shuffle (was:
Improve memory utilization
flinkbot commented on PR #23117:
URL: https://github.com/apache/flink/pull/23117#issuecomment-1660384516
## CI report:
* ce9264b05678dad2696a23c68d15df5864e319e7 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-32680?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lijie Wang closed FLINK-32680.
--
Fix Version/s: 1.18.0
1.16.3
1.17.2
Resolution: Fixed
>
[
https://issues.apache.org/jira/browse/FLINK-32223?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17749616#comment-17749616
]
Gabor Somogyi commented on FLINK-32223:
---
> It introduced a compilation error on master in the
[
https://issues.apache.org/jira/browse/FLINK-32663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17749667#comment-17749667
]
Rui Fan commented on FLINK-32663:
-
The priority is upgraded to blocker due to it's caused in 1.18. cc
[
https://issues.apache.org/jira/browse/FLINK-32662?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl reassigned FLINK-32662:
-
Assignee: Matthias Pohl (was: Hong Liang Teoh)
>
[
https://issues.apache.org/jira/browse/FLINK-32663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17749725#comment-17749725
]
Rui Fan commented on FLINK-32663:
-
Hi [~lindong], thanks for your quick feedback.
{quote}For example,
[
https://issues.apache.org/jira/browse/FLINK-32680?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17749791#comment-17749791
]
Lijie Wang commented on FLINK-32680:
Fixed via:
master(1.18):
Qingsheng Ren created FLINK-32726:
-
Summary: [Umbrella] Test Flink Release 1.18
Key: FLINK-32726
URL: https://issues.apache.org/jira/browse/FLINK-32726
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-32558?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Qingsheng Ren updated FLINK-32558:
--
Priority: Major (was: Blocker)
> Properly deprecate DataSet API
>
[
https://issues.apache.org/jira/browse/FLINK-32557?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Qingsheng Ren updated FLINK-32557:
--
Priority: Major (was: Blocker)
> API deprecations in Flink 1.18
>
[
https://issues.apache.org/jira/browse/FLINK-32559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Qingsheng Ren updated FLINK-32559:
--
Priority: Major (was: Blocker)
> Deprecate Queryable State
> -
>
>
[
https://issues.apache.org/jira/browse/FLINK-32557?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17749579#comment-17749579
]
Qingsheng Ren commented on FLINK-32557:
---
As discussed in the release sync, these deprecations will
XComp commented on PR #23114:
URL: https://github.com/apache/flink/pull/23114#issuecomment-1660067221
`git revert 70e6359` performed without any conflicts
--
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
[
https://issues.apache.org/jira/browse/FLINK-32223?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17749628#comment-17749628
]
Gabor Somogyi commented on FLINK-32223:
---
Thanks for taking care, approved the revert.
>
[
https://issues.apache.org/jira/browse/FLINK-32686?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo reassigned FLINK-32686:
--
Assignee: Wencong Liu
> Performance regression on startScheduling.BATCH and
[
https://issues.apache.org/jira/browse/FLINK-28386?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated FLINK-28386:
-
Summary: Trigger an immediate checkpoint after all tasks finished (was:
Trigger an immediate
[
https://issues.apache.org/jira/browse/FLINK-28386?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated FLINK-28386:
-
Summary: Trigger an immediate checkpoint after all tasks has received
end-of-data (was: Trigger an
[
https://issues.apache.org/jira/browse/FLINK-32223?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-32223:
--
Fix Version/s: (was: 1.18.0)
> Add Hive delegation token support
>
[
https://issues.apache.org/jira/browse/FLINK-32223?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17749752#comment-17749752
]
Matthias Pohl commented on FLINK-32223:
---
I merged the revert into {{master}} and updated the Jira
[
https://issues.apache.org/jira/browse/FLINK-32223?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-32223:
--
Priority: Major (was: Blocker)
> Add Hive delegation token support
>
wanglijie95 closed pull request #23085: [FLINK-32680][streaming] Fix the messed
up JobVertex name when the source nodes chained with a MultipleInput node.
URL: https://github.com/apache/flink/pull/23085
--
This is an automated message from the Apache Git Service.
To respond to the message,
[
https://issues.apache.org/jira/browse/FLINK-32726?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Qingsheng Ren updated FLINK-32726:
--
Labels: release-testing (was: )
> [Umbrella] Test Flink Release 1.18
>
xintongsong commented on code in PR #23077:
URL: https://github.com/apache/flink/pull/23077#discussion_r1280384166
##
docs/content.zh/docs/ops/batch/batch_shuffle.md:
##
@@ -127,6 +127,12 @@ These could be configured via
[jobmanager.partition.hybrid.partition-data-consum
-
[
https://issues.apache.org/jira/browse/FLINK-32681?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17749599#comment-17749599
]
Stefan Richter commented on FLINK-32681:
[~Feifan Wang]Thanks for the offer but I've already
[
https://issues.apache.org/jira/browse/FLINK-32223?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17749619#comment-17749619
]
Matthias Pohl edited comment on FLINK-32223 at 8/1/23 10:53 AM:
Thanks
[
https://issues.apache.org/jira/browse/FLINK-32223?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17749619#comment-17749619
]
Matthias Pohl edited comment on FLINK-32223 at 8/1/23 10:53 AM:
Thanks
xintongsong commented on code in PR #23113:
URL: https://github.com/apache/flink/pull/23113#discussion_r1280456502
##
docs/content.zh/docs/deployment/resource-providers/standalone/docker.md:
##
@@ -574,7 +574,7 @@ You can customize the Flink image in several ways:
$ echo
[
https://issues.apache.org/jira/browse/FLINK-32663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17749656#comment-17749656
]
Rui Fan commented on FLINK-32663:
-
Hi [~lindong], I see you help reviewed the FLINK-28386, it caused
TanYuxin-tyx commented on code in PR #23077:
URL: https://github.com/apache/flink/pull/23077#discussion_r1280542679
##
docs/content.zh/docs/ops/batch/batch_shuffle.md:
##
@@ -127,6 +127,12 @@ These could be configured via
[jobmanager.partition.hybrid.partition-data-consum
-
[
https://issues.apache.org/jira/browse/FLINK-28386?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated FLINK-28386:
-
Description: Currently for bounded job in streaming mode, by default it
will wait for one more
[
https://issues.apache.org/jira/browse/FLINK-28386?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated FLINK-28386:
-
Summary: Trigger an immediate checkpoint after all tasks has reached
end-of-data (was: Trigger an
[
https://issues.apache.org/jira/browse/FLINK-28386?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated FLINK-28386:
-
Description: Currently for bounded job in streaming mode, by default it
will wait for one more
[
https://issues.apache.org/jira/browse/FLINK-32663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17749656#comment-17749656
]
Rui Fan edited comment on FLINK-32663 at 8/1/23 12:39 PM:
--
Hi [~lindong], I see
[
https://issues.apache.org/jira/browse/FLINK-32223?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17749762#comment-17749762
]
Matthias Pohl edited comment on FLINK-32223 at 8/1/23 1:51 PM:
---
{quote}
[
https://issues.apache.org/jira/browse/FLINK-31634?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yuxin Tan updated FLINK-31634:
--
Release Note: Hybrid Shuffle supports storing the shuffle data in remote
storage. The remote storage
[
https://issues.apache.org/jira/browse/FLINK-31634?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yuxin Tan updated FLINK-31634:
--
Release Note: Hybrid Shuffle supports storing the shuffle data in remote
storage. The remote storage
flinkbot commented on PR #23114:
URL: https://github.com/apache/flink/pull/23114#issuecomment-1660075239
## CI report:
* 8639303d70e39376a1de051345aa4d1e053a9bba UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
StefanRRichter opened a new pull request, #23115:
URL: https://github.com/apache/flink/pull/23115
## What is the purpose of the change
Fixes a test failure in `RocksDBStateDownloaderTest` by ensuring that on
failure we first wait for all parallel download threads to complete and
[
https://issues.apache.org/jira/browse/FLINK-28386?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan updated FLINK-28386:
Fix Version/s: 1.18.0
> Trigger an immediate checkpoint after all sources finished
>
Tartarus0zm opened a new pull request, #23116:
URL: https://github.com/apache/flink/pull/23116
## What is the purpose of the change
Add docs for atomic CTAS and RTAS
## Brief change log
add docs
## Verifying this change
no need test
## Does this
[
https://issues.apache.org/jira/browse/FLINK-32686?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo resolved FLINK-32686.
Fix Version/s: 1.18.0
Resolution: Fixed
master(1.18) via
[
https://issues.apache.org/jira/browse/FLINK-32686?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo closed FLINK-32686.
--
> Performance regression on startScheduling.BATCH and startScheduling.STREAMING
> since 2023-07-24
>
mxm commented on PR #637:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/637#issuecomment-1660275978
There was a test failure in the last run which probably is not fixed by the
latest changes:
[
https://issues.apache.org/jira/browse/FLINK-32223?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17749762#comment-17749762
]
Matthias Pohl commented on FLINK-32223:
---
{quote}
How can one double check that before merge not to
[
https://issues.apache.org/jira/browse/FLINK-32223?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17749752#comment-17749752
]
Matthias Pohl edited comment on FLINK-32223 at 8/1/23 1:43 PM:
---
I merged
[
https://issues.apache.org/jira/browse/FLINK-32223?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17749762#comment-17749762
]
Matthias Pohl edited comment on FLINK-32223 at 8/1/23 1:51 PM:
---
{quote}
[
https://issues.apache.org/jira/browse/FLINK-32662?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-32662:
---
Labels: pull-request-available test-stability (was: test-stability)
>
[
https://issues.apache.org/jira/browse/FLINK-32560?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Qingsheng Ren updated FLINK-32560:
--
Priority: Major (was: Blocker)
> Properly deprecate all Scala APIs
>
1 - 100 of 177 matches
Mail list logo
