[
https://issues.apache.org/jira/browse/FLINK-29313?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora reassigned FLINK-29313:
--
Assignee: Gyula Fora
> Some config overrides are ignored when set under
zjureel commented on code in PR #19380:
URL: https://github.com/apache/flink/pull/19380#discussion_r974074196
##
flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/TestingResultPartitionProvider.java:
##
@@ -0,0 +1,69 @@
+/*
+ * Licensed to the Apache
[
https://issues.apache.org/jira/browse/FLINK-29315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17606542#comment-17606542
]
Xingbo Huang commented on FLINK-29315:
--
[~mapohl] Ok. I will reach out them for help.
>
csviri commented on code in PR #362:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/362#discussion_r974124231
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/FlinkOperator.java:
##
@@ -113,6 +113,9 @@ private void
morhidi commented on code in PR #362:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/362#discussion_r974159882
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/FlinkOperator.java:
##
@@ -113,6 +113,9 @@ private void
[
https://issues.apache.org/jira/browse/FLINK-29328?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17606514#comment-17606514
]
Jason edited comment on FLINK-29328 at 9/19/22 9:53 AM:
Yanfei Lei Thanks for
flinkbot commented on PR #20854:
URL: https://github.com/apache/flink/pull/20854#issuecomment-1250808494
## CI report:
* 700ec0ecd4f6b667ef7f0abc00f70c699700128f UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-14055?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
dalongliu updated FLINK-14055:
--
Release Note:
In 1.16, we introduced the `CREATE FUNCTION ... USING JAR` syntax to support
the
MOBIN-F commented on PR #290:
URL:
https://github.com/apache/flink-table-store/pull/290#issuecomment-1250850715
> > @JingsongLi @liyubin117 @SteNicholas I think it's more straightforward
to create tables using a connector approach, like Hudi/Iceberg, and now Delta
is also
JingsongLi closed pull request #245: [WIP] Introduce full-compaction changelog
producer
URL: https://github.com/apache/flink-table-store/pull/245
--
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
gyfora commented on code in PR #370:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/370#discussion_r974159354
##
flink-kubernetes-standalone/src/main/java/org/apache/flink/kubernetes/operator/kubeclient/parameters/StandaloneKubernetesJobManagerParameters.java:
[
https://issues.apache.org/jira/browse/FLINK-29235?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17606628#comment-17606628
]
Chesnay Schepler edited comment on FLINK-29235 at 9/19/22 2:50 PM:
---
[
https://issues.apache.org/jira/browse/FLINK-29235?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17606628#comment-17606628
]
Chesnay Schepler commented on FLINK-29235:
--
Mind you that the CVE likely doesn't apply because
[
https://issues.apache.org/jira/browse/FLINK-29313?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-29313:
---
Labels: pull-request-available (was: )
> Some config overrides are ignored when set under
wuchong opened a new pull request, #20856:
URL: https://github.com/apache/flink/pull/20856
This is a cherry-pick back to release-1.16 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 to go to the
zjureel commented on PR #19380:
URL: https://github.com/apache/flink/pull/19380#issuecomment-1250823961
Hi @KarmaGYZ @pnowojski Thanks for your reviews and I'm very sorry for
updating this PR so late.
I have rebased the code from master and updated the codes in the PR via your
[
https://issues.apache.org/jira/browse/FLINK-6755?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17458438#comment-17458438
]
Piotr Nowojski edited comment on FLINK-6755 at 9/19/22 10:19 AM:
-
The
[
https://issues.apache.org/jira/browse/FLINK-29315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17606540#comment-17606540
]
Matthias Pohl commented on FLINK-29315:
---
[~hxb] could you access the custom CI workers that are
JingsongLi commented on code in PR #292:
URL: https://github.com/apache/flink-table-store/pull/292#discussion_r974118665
##
flink-table-store-common/src/test/java/org/apache/flink/table/store/format/FileStatsExtractorTestBase.java:
##
@@ -128,6 +129,9 @@ private Object
[
https://issues.apache.org/jira/browse/FLINK-28810?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-28810.
Resolution: Fixed
master: fc73a0bc4427741b41cb4b15e75c2dba363b97fb
> Introduce
JingsongLi merged PR #262:
URL: https://github.com/apache/flink-table-store/pull/262
--
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:
Matthias Pohl created FLINK-29334:
-
Summary: StateHandleStore#releaseAndTryRemoveAll is not used and
can be removed
Key: FLINK-29334
URL: https://issues.apache.org/jira/browse/FLINK-29334
Project:
[
https://issues.apache.org/jira/browse/FLINK-28766?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17606586#comment-17606586
]
Anton Kalashnikov commented on FLINK-28766:
---
[~martijnvisser], I will take a look
>
[
https://issues.apache.org/jira/browse/FLINK-28766?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Anton Kalashnikov reassigned FLINK-28766:
-
Assignee: Anton Kalashnikov
> UnalignedCheckpointStressITCase.runStressTest
morhidi commented on code in PR #360:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/360#discussion_r974255685
##
examples/kubernetes-client-examples/README.MD:
##
@@ -0,0 +1,48 @@
+
+
+# Flink Kubernetes Client Code Example
+
+## Overview
+
+This is an
[
https://issues.apache.org/jira/browse/FLINK-29093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17606611#comment-17606611
]
Jark Wu commented on FLINK-29093:
-
zjureel commented on code in PR #19380:
URL: https://github.com/apache/flink/pull/19380#discussion_r974072849
##
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/PartitionRequestNotifierTimeout.java:
##
@@ -0,0 +1,36 @@
+/*
+ * Licensed to the Apache
zjureel commented on code in PR #19380:
URL: https://github.com/apache/flink/pull/19380#discussion_r974072694
##
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/ResultPartitionManager.java:
##
@@ -104,12 +192,40 @@ public void shutdown() {
[
https://issues.apache.org/jira/browse/FLINK-29330?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17606539#comment-17606539
]
Matthias Pohl commented on FLINK-29330:
---
I guess, it's a good idea. The shutdown logic is hard to
morhidi commented on PR #362:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/362#issuecomment-1250859590
Hi @SteNicholas, if we stick with the current fabric8 version I don't see
any problems merging this PR with the upcoming FOv1.2 release.
--
This is an automated
Dhananjay Badaya created FLINK-29333:
Summary: Flink SQL Planner Module doesn't read config from
flink-conf.yaml
Key: FLINK-29333
URL: https://issues.apache.org/jira/browse/FLINK-29333
Project:
gyfora merged PR #369:
URL: https://github.com/apache/flink-kubernetes-operator/pull/369
--
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:
lsyldliu commented on PR #20652:
URL: https://github.com/apache/flink/pull/20652#issuecomment-1250904811
> Hi @lsyldliu, do you have time to take a look?
Thanks for your contribution, I will review it as soon as possible.
--
This is an automated message from the Apache Git Service.
Matthias Pohl created FLINK-29335:
-
Summary: OperatorSubtaskState swallows exception
Key: FLINK-29335
URL: https://issues.apache.org/jira/browse/FLINK-29335
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-29209?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia closed FLINK-29209.
Resolution: Not A Problem
> Fail to connect HiveServer endpoint with TProtocolException
>
[
https://issues.apache.org/jira/browse/FLINK-28766?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17606589#comment-17606589
]
Martijn Visser commented on FLINK-28766:
Thanks [~akalashnikov]
>
morhidi commented on PR #362:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/362#issuecomment-1250988273
+1 LGTM
--
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
wuchong commented on PR #20630:
URL: https://github.com/apache/flink/pull/20630#issuecomment-1251074156
The failed cases are tracked by FLINK-29315 and FLINK-29093.
--
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-29235?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler reassigned FLINK-29235:
Assignee: Chesnay Schepler
> CVE-2022-25857 on flink-shaded
>
[
https://issues.apache.org/jira/browse/FLINK-29235?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17606626#comment-17606626
]
Chesnay Schepler commented on FLINK-29235:
--
I guess so.
> CVE-2022-25857 on flink-shaded
>
stevenzwu commented on code in PR #20757:
URL: https://github.com/apache/flink/pull/20757#discussion_r974416546
##
flink-tests/src/test/java/org/apache/flink/api/connector/source/lib/util/RateLimitedSourceReaderITCase.java:
##
@@ -0,0 +1,138 @@
+/*
+ * Licensed to the Apache
SteNicholas commented on code in PR #362:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/362#discussion_r974146152
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/FlinkOperator.java:
##
@@ -113,6 +113,9 @@ private void
[
https://issues.apache.org/jira/browse/FLINK-29256?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora closed FLINK-29256.
--
Resolution: Fixed
merged to main 1b2b0f3d5dd519fd6c9ea191e4b353679bc7312e
> Docs for k8s operator
SteNicholas commented on code in PR #362:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/362#discussion_r974184645
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/FlinkOperator.java:
##
@@ -113,6 +113,9 @@ private void
jeesmon commented on code in PR #370:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/370#discussion_r974199626
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/validation/DefaultValidator.java:
##
@@ -180,10 +180,6 @@ private
csviri commented on code in PR #362:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/362#discussion_r974199023
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/FlinkOperator.java:
##
@@ -113,6 +113,9 @@ private void
[
https://issues.apache.org/jira/browse/FLINK-29261?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matyas Orhidi updated FLINK-29261:
--
Summary: Use FAIL_ON_UNKNOWN_PROPERTIES=false in ReconciliationUtils (was:
Consider using
[
https://issues.apache.org/jira/browse/FLINK-29332?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser closed FLINK-29332.
--
Resolution: Duplicate
> Flink SQL Planner Module doesn't read config from flink-conf.yaml
>
[
https://issues.apache.org/jira/browse/FLINK-29148?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu closed FLINK-29148.
---
Resolution: Fixed
> Add docs for SQL Gateway
>
>
> Key:
[
https://issues.apache.org/jira/browse/FLINK-29148?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17606524#comment-17606524
]
Jark Wu edited comment on FLINK-29148 at 9/19/22 2:11 PM:
--
Fixed in
- master:
[
https://issues.apache.org/jira/browse/FLINK-29023?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu closed FLINK-29023.
---
Fix Version/s: 1.17.0
Assignee: dalongliu
Resolution: Fixed
Fixed in
- master:
afedulov commented on code in PR #20757:
URL: https://github.com/apache/flink/pull/20757#discussion_r974351472
##
flink-tests/src/test/java/org/apache/flink/api/connector/source/lib/DataGeneratorSourceITCase.java:
##
@@ -0,0 +1,193 @@
+/*
+ * Licensed to the Apache Software
gyfora opened a new pull request, #371:
URL: https://github.com/apache/flink-kubernetes-operator/pull/371
## What is the purpose of the change
This PR improves the logic of the observe configuration to avoid problems
with juggling operator specific confg between the new and deployed
wuchong commented on PR #20696:
URL: https://github.com/apache/flink/pull/20696#issuecomment-1251131456
LGTM. I added 4 commits to adjust the page order anduse dash-case
("hive-compatibility") instead of camelCase ("hiveComptibility") in URL and
remove "alias" front matter.
--
This is
gyfora commented on PR #371:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/371#issuecomment-1251131290
cc @morhidi
--
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
zjureel commented on code in PR #19380:
URL: https://github.com/apache/flink/pull/19380#discussion_r974066032
##
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/PartitionRequestQueue.java:
##
@@ -243,6 +246,22 @@ public void
zjureel commented on code in PR #19380:
URL: https://github.com/apache/flink/pull/19380#discussion_r974073780
##
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/CreditBasedSequenceNumberingViewReader.java:
##
@@ -101,6 +105,55 @@ public void
zjureel commented on code in PR #19380:
URL: https://github.com/apache/flink/pull/19380#discussion_r974073974
##
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/PartitionRequestServerHandler.java:
##
@@ -88,10 +88,8 @@ protected void
zjureel commented on code in PR #19380:
URL: https://github.com/apache/flink/pull/19380#discussion_r974073384
##
flink-core/src/main/java/org/apache/flink/configuration/NettyShuffleEnvironmentOptions.java:
##
@@ -451,6 +451,14 @@ public class NettyShuffleEnvironmentOptions {
zjureel commented on code in PR #19380:
URL: https://github.com/apache/flink/pull/19380#discussion_r974073559
##
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/NetworkSequenceViewReader.java:
##
@@ -40,6 +45,30 @@ void requestSubpartitionView(
int
[
https://issues.apache.org/jira/browse/FLINK-29233?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora updated FLINK-29233:
---
Fix Version/s: (was: kubernetes-operator-1.2.0)
> Flink Kubernetes Operator example/kustomize
Matthias Pohl created FLINK-29336:
-
Summary: SubtaskState#discardState swallows exceptions
Key: FLINK-29336
URL: https://issues.apache.org/jira/browse/FLINK-29336
Project: Flink
Issue Type:
flinkbot commented on PR #20855:
URL: https://github.com/apache/flink/pull/20855#issuecomment-1250960061
## CI report:
* 7d7b0bb51d4d6a0471ced9ba38bfdf23a75824c2 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
morhidi commented on PR #360:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/360#issuecomment-1251032990
LGTM, some wording suggestions added.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
morhidi commented on code in PR #360:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/360#discussion_r974256567
##
examples/kubernetes-client-examples/README.MD:
##
@@ -0,0 +1,48 @@
+
+
+# Flink Kubernetes Client Code Example
+
+## Overview
+
+This is an
[
https://issues.apache.org/jira/browse/FLINK-29315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17606613#comment-17606613
]
Jark Wu commented on FLINK-29315:
-
[
https://issues.apache.org/jira/browse/FLINK-29235?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17606618#comment-17606618
]
Martijn Visser commented on FLINK-29235:
[~chesnay] Should this be fixed before Flink 1.16?
>
[
https://issues.apache.org/jira/browse/FLINK-14055?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu closed FLINK-14055.
---
Resolution: Fixed
> Add advanced function DDL syntax "USING JAR"
>
gyfora merged PR #362:
URL: https://github.com/apache/flink-kubernetes-operator/pull/362
--
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:
wuchong commented on code in PR #20696:
URL: https://github.com/apache/flink/pull/20696#discussion_r974354109
##
docs/content/docs/dev/table/hiveCompatibility/hiveDialect/overview.md:
##
@@ -0,0 +1,97 @@
+---
+title: "Overview"
+weight: 1
+type: docs
+aliases:
+-
wuchong commented on code in PR #20696:
URL: https://github.com/apache/flink/pull/20696#discussion_r974354501
##
docs/content/docs/dev/table/hiveCompatibility/hiveDialect/overview.md:
##
@@ -0,0 +1,97 @@
+---
+title: "Overview"
+weight: 1
+type: docs
+aliases:
+-
morhidi commented on code in PR #362:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/362#discussion_r974107970
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/FlinkOperator.java:
##
@@ -113,6 +113,9 @@ private void
luoyuxia created FLINK-29337:
Summary: Fix fail to use HiveDialect for non-hive table
Key: FLINK-29337
URL: https://issues.apache.org/jira/browse/FLINK-29337
Project: Flink
Issue Type: Bug
afedulov commented on code in PR #20757:
URL: https://github.com/apache/flink/pull/20757#discussion_r974346595
##
flink-core/src/main/java/org/apache/flink/api/connector/source/lib/util/GatedRateLimiter.java:
##
@@ -0,0 +1,64 @@
+/*
+ * Licensed to the Apache Software
afedulov commented on code in PR #20757:
URL: https://github.com/apache/flink/pull/20757#discussion_r974346238
##
flink-core/src/main/java/org/apache/flink/api/connector/source/SourceReaderContext.java:
##
@@ -63,4 +63,11 @@ public interface SourceReaderContext {
* @see
gyfora commented on code in PR #365:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/365#discussion_r974378675
##
docs/content/docs/custom-resource/job-management.md:
##
@@ -98,8 +98,8 @@ The `upgradeMode` setting controls both the stop and restore
mechanisms as
[
https://issues.apache.org/jira/browse/FLINK-29131?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora updated FLINK-29131:
---
Fix Version/s: (was: kubernetes-operator-1.2.0)
> Kubernetes operator webhook can use hostPort
[
https://issues.apache.org/jira/browse/FLINK-27273?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora updated FLINK-27273:
---
Fix Version/s: (was: kubernetes-operator-1.2.0)
> Support both configMap and zookeeper based HA
[
https://issues.apache.org/jira/browse/FLINK-27281?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora updated FLINK-27281:
---
Fix Version/s: (was: kubernetes-operator-1.2.0)
> Improve stability conditions for rollback
[
https://issues.apache.org/jira/browse/FLINK-26972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora updated FLINK-26972:
---
Fix Version/s: (was: kubernetes-operator-1.2.0)
> Support spot instance in Flink Kubernetes
[
https://issues.apache.org/jira/browse/FLINK-27190?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora updated FLINK-27190:
---
Fix Version/s: (was: kubernetes-operator-1.2.0)
> Revisit error handling in main reconcile()
SteNicholas commented on code in PR #362:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/362#discussion_r974183418
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/FlinkOperator.java:
##
@@ -113,6 +113,9 @@ private void
[
https://issues.apache.org/jira/browse/FLINK-29337?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-29337:
---
Labels: pull-request-available (was: )
> Fix fail to use HiveDialect for non-hive table
>
[
https://issues.apache.org/jira/browse/FLINK-26606?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-26606:
--
Priority: Major (was: Critical)
> CompletedCheckpoints that failed to be discarded are not
luoyuxia opened a new pull request, #20855:
URL: https://github.com/apache/flink/pull/20855
## What is the purpose of the change
Ti fix the failure for the query with non-hive table in Hive dialect.
## Brief change log
// todo:
## Verifying this change
gyfora commented on code in PR #370:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/370#discussion_r974285814
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/validation/DefaultValidator.java:
##
@@ -180,10 +180,6 @@ private
[
https://issues.apache.org/jira/browse/FLINK-29315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-29315:
Fix Version/s: 1.16.0
1.17.0
> HDFSTest#testBlobServerRecovery fails on CI
>
wuchong merged PR #20630:
URL: https://github.com/apache/flink/pull/20630
--
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:
afedulov commented on code in PR #20757:
URL: https://github.com/apache/flink/pull/20757#discussion_r974320992
##
flink-core/src/main/java/org/apache/flink/api/connector/source/lib/util/GatedRateLimiter.java:
##
@@ -0,0 +1,64 @@
+/*
+ * Licensed to the Apache Software
flinkbot commented on PR #20856:
URL: https://github.com/apache/flink/pull/20856#issuecomment-1251149181
## CI report:
* 2c0a744075586d6cac0e9c5043fc1960a2cee590 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
JingsongLi commented on code in PR #262:
URL: https://github.com/apache/flink-table-store/pull/262#discussion_r974060913
##
flink-table-store-core/src/main/java/org/apache/flink/table/store/file/data/AppendOnlyCompactManager.java:
##
@@ -58,10 +59,9 @@ public
zjureel commented on code in PR #19380:
URL: https://github.com/apache/flink/pull/19380#discussion_r974068841
##
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/NetworkSequenceViewReader.java:
##
@@ -40,6 +45,30 @@ void requestSubpartitionView(
int
zjureel commented on code in PR #19380:
URL: https://github.com/apache/flink/pull/19380#discussion_r974068347
##
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/ResultPartitionManager.java:
##
@@ -79,8 +128,47 @@ public ResultSubpartitionView
zjureel commented on code in PR #19380:
URL: https://github.com/apache/flink/pull/19380#discussion_r974068617
##
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/ResultPartitionManager.java:
##
@@ -104,12 +192,40 @@ public void shutdown() {
[
https://issues.apache.org/jira/browse/FLINK-27530?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17606530#comment-17606530
]
fanrui commented on FLINK-27530:
Hi [~godfreyhe] , as I understand, [~pnowojski] has written the
morhidi commented on code in PR #362:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/362#discussion_r974107812
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/FlinkOperator.java:
##
@@ -113,6 +113,9 @@ private void
[
https://issues.apache.org/jira/browse/FLINK-29330?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17606545#comment-17606545
]
Chesnay Schepler commented on FLINK-29330:
--
> I noticed that we do not use
Dhananjay Badaya created FLINK-29332:
Summary: Flink SQL Planner Module doesn't read config from
flink-conf.yaml
Key: FLINK-29332
URL: https://issues.apache.org/jira/browse/FLINK-29332
Project:
csviri commented on code in PR #362:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/362#discussion_r974168823
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/FlinkOperator.java:
##
@@ -113,6 +113,9 @@ private void
[
https://issues.apache.org/jira/browse/FLINK-26606?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17606582#comment-17606582
]
Matthias Pohl commented on FLINK-26606:
---
Lowering priority from {{CRITICAL}} to {{Major}} because
1 - 100 of 244 matches
Mail list logo
