flinkbot commented on PR #20682:
URL: https://github.com/apache/flink/pull/20682#issuecomment-1228083861
## CI report:
* 0d74aae52de1e81fc295d75ce17c22b6381767b0 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
flinkbot commented on PR #20683:
URL: https://github.com/apache/flink/pull/20683#issuecomment-1228083915
## CI report:
* 2df58244ec548ed59efc136f9a978a5a19953a53 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
pltbkd commented on PR #20683:
URL: https://github.com/apache/flink/pull/20683#issuecomment-1228083279
@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.
[
https://issues.apache.org/jira/browse/FLINK-29107?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17585163#comment-17585163
]
Yun Tang commented on FLINK-29107:
--
[~chesnay] Unfortunately to hear this:(, could you share the
pltbkd commented on PR #20682:
URL: https://github.com/apache/flink/pull/20682#issuecomment-1228082950
@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.
flinkbot commented on PR #20681:
URL: https://github.com/apache/flink/pull/20681#issuecomment-1228081391
## CI report:
* 7a9135403876f4cd10d02758f2992cc30d534480 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
pltbkd commented on PR #20681:
URL: https://github.com/apache/flink/pull/20681#issuecomment-1228080726
@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.
pltbkd opened a new pull request, #20683:
URL: https://github.com/apache/flink/pull/20683
## 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
pltbkd opened a new pull request, #20682:
URL: https://github.com/apache/flink/pull/20682
## 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
pltbkd opened a new pull request, #20681:
URL: https://github.com/apache/flink/pull/20681
## 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
[
https://issues.apache.org/jira/browse/FLINK-29110?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17585152#comment-17585152
]
Gyula Fora commented on FLINK-29110:
What would be the benefit of adding support for these
wangyang0918 commented on PR #20673:
URL: https://github.com/apache/flink/pull/20673#issuecomment-1228046277
@XComp Oh, my bad. I should not introduce this concurrent issue here. Either
the `callbackInvocationCount` needs to be asserted in the whenComplete, or I
should execute
[
https://issues.apache.org/jira/browse/FLINK-29110?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora updated FLINK-29110:
---
Issue Type: Improvement (was: New Feature)
> Support to mount a dynamically-created pvc for JM and
[
https://issues.apache.org/jira/browse/FLINK-29110?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora updated FLINK-29110:
---
Component/s: Kubernetes Operator
(was: Deployment / Kubernetes)
> Support to
[
https://issues.apache.org/jira/browse/FLINK-29110?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17585133#comment-17585133
]
Peng Yuan commented on FLINK-29110:
---
[~wangyang0918] [~gyfora] [~usamj]
> Support to mount a
[
https://issues.apache.org/jira/browse/FLINK-29110?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Peng Yuan updated FLINK-29110:
--
Description:
Use StatefulSet instead of Deployment to deploy JM and TM to support mount a
Peng Yuan created FLINK-29110:
-
Summary: Support to mount a dynamically-created pvc for JM and TM
in standalone mode with StatefulSet.
Key: FLINK-29110
URL: https://issues.apache.org/jira/browse/FLINK-29110
akshathsk closed pull request #20680: Fixed Flaky Test Case
CheckpointCoordinatorTest#testTriggerAndDeclineCheckpointComplex
URL: https://github.com/apache/flink/pull/20680
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use
akshathsk opened a new pull request, #20680:
URL: https://github.com/apache/flink/pull/20680
## 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
[
https://issues.apache.org/jira/browse/FLINK-28939?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17585118#comment-17585118
]
Yunhong Zheng commented on FLINK-28939:
---
Hi, [~godfreyhe] , I have finished the tests, fixed the
[
https://issues.apache.org/jira/browse/FLINK-27773?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shengkai Fang closed FLINK-27773.
-
Resolution: Fixed
> Introduce the E2E tests for SQL Gateway
>
[
https://issues.apache.org/jira/browse/FLINK-27773?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17585117#comment-17585117
]
Shengkai Fang commented on FLINK-27773:
---
Merged into master:
[
https://issues.apache.org/jira/browse/FLINK-29006?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17585116#comment-17585116
]
Yufan Sheng edited comment on FLINK-29006 at 8/26/22 3:32 AM:
--
[~renqs] I
[
https://issues.apache.org/jira/browse/FLINK-29006?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17585116#comment-17585116
]
Yufan Sheng edited comment on FLINK-29006 at 8/26/22 3:32 AM:
--
[~renqs] I
[
https://issues.apache.org/jira/browse/FLINK-29006?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17585116#comment-17585116
]
Yufan Sheng commented on FLINK-29006:
-
[~renqs] I have checked the log. It seems like the root cause
[ https://issues.apache.org/jira/browse/FLINK-29006 ]
Yufan Sheng deleted comment on FLINK-29006:
-
was (Author: syhily):
[~hxbks2ks] This should get fixed in latest release-1.15. Can you check it?
> PulsarSourceITCase failed with Could not
fsk119 merged PR #20609:
URL: https://github.com/apache/flink/pull/20609
--
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-29108?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17585114#comment-17585114
]
Hangxiang Yu commented on FLINK-29108:
--
Hi, [~rcroc...@newrelic.com] . I see "Querable state" has
[
https://issues.apache.org/jira/browse/FLINK-29006?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17585110#comment-17585110
]
Yufan Sheng commented on FLINK-29006:
-
[~hxbks2ks] This should get fixed in latest release-1.15. Can
SmirAlex commented on PR #20676:
URL: https://github.com/apache/flink/pull/20676#issuecomment-1227979712
Successful pipeline -
https://dev.azure.com/asmirnov1/Flink/_build/results?buildId=30=results
--
This is an automated message from the Apache Git Service.
To respond to the message,
[
https://issues.apache.org/jira/browse/FLINK-27149?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xingbo Huang updated FLINK-27149:
-
Labels: test-stability (was: )
> KafkaSourceE2ECase.testScaleUp failed on AZP
>
[
https://issues.apache.org/jira/browse/FLINK-28177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xingbo Huang closed FLINK-28177.
Resolution: Fixed
Merged into master via cdc4f4b100d3b2e66536a23685d7505c1f6670af
>
[
https://issues.apache.org/jira/browse/FLINK-28177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xingbo Huang updated FLINK-28177:
-
Fix Version/s: 1.16.0
> Elasticsearch6DynamicSinkITCase.testWritingDocumentsNoPrimaryKey failed
HuangXingBo closed pull request #20362: [FLINK-28177][Connectors/ElasticSearch]
add retry in elasticsearch ta…
URL: https://github.com/apache/flink/pull/20362
--
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
leozhangsr commented on PR #20389:
URL: https://github.com/apache/flink/pull/20389#issuecomment-1227969108
> Commit message looks in sync with master
As in pull request(https://github.com/apache/flink/pull/20234), PatrickRen
asked for another two pull request for release-1.14 and
swuferhong commented on PR #20664:
URL: https://github.com/apache/flink/pull/20664#issuecomment-1227917280
@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
lincoln-lil commented on PR #20577:
URL: https://github.com/apache/flink/pull/20577#issuecomment-1227913112
@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
Thomas Weise created FLINK-29109:
Summary: Checkpoint path conflict with stateless upgrade mode
Key: FLINK-29109
URL: https://issues.apache.org/jira/browse/FLINK-29109
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-29088?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17585069#comment-17585069
]
Aitozi edited comment on FLINK-29088 at 8/26/22 12:34 AM:
--
I propose to support
[
https://issues.apache.org/jira/browse/FLINK-29088?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17585069#comment-17585069
]
Aitozi commented on FLINK-29088:
I propose to support this level reuse by this way:
1) Detect the same
[
https://issues.apache.org/jira/browse/FLINK-28395?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17585062#comment-17585062
]
KurtDing commented on FLINK-28395:
--
Pr is avaliable, need a reviewer
>
[
https://issues.apache.org/jira/browse/FLINK-28177?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17585061#comment-17585061
]
KurtDing commented on FLINK-28177:
--
Pr is avaliable ,need a reviewer
>
LadyForest opened a new pull request, #277:
URL: https://github.com/apache/flink-table-store/pull/277
The current description for restoring a job from a savepoint only applies
for jar jobs.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log
[
https://issues.apache.org/jira/browse/FLINK-11529?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-11529:
---
Labels: auto-deprioritized-major auto-deprioritized-minor auto-unassigned
[
https://issues.apache.org/jira/browse/FLINK-28934?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-28934:
---
Labels: bug stale-critical (was: bug)
I am the [Flink Jira
[
https://issues.apache.org/jira/browse/FLINK-28177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-28177:
---
Labels: pull-request-available stale-assigned test-stability (was:
pull-request-available
[
https://issues.apache.org/jira/browse/FLINK-28424?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-28424:
---
Labels: auto-deprioritized-critical test-stability (was:
auto-deprioritized-critical
[
https://issues.apache.org/jira/browse/FLINK-24573?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-24573:
---
Labels: auto-deprioritized-major auto-deprioritized-minor test-stability
(was:
Ron Crocker created FLINK-29108:
---
Summary: Kubernetes operator: Support queryable state
Key: FLINK-29108
URL: https://issues.apache.org/jira/browse/FLINK-29108
Project: Flink
Issue Type: New
[
https://issues.apache.org/jira/browse/FLINK-29107?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17585020#comment-17585020
]
Chesnay Schepler commented on FLINK-29107:
--
we cant upgrade spotless. The current version we
[
https://issues.apache.org/jira/browse/FLINK-29107?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17584911#comment-17584911
]
Yun Tang commented on FLINK-29107:
--
An interesting feature. [~Yu Chen] , already assigned to you,
[
https://issues.apache.org/jira/browse/FLINK-29107?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Tang reassigned FLINK-29107:
Assignee: Yu Chen
> Upgrade spotless version to improve spotless check efficiency
>
morhidi commented on code in PR #351:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/351#discussion_r955084321
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/reconciler/deployment/AbstractFlinkResourceReconciler.java:
##
@@
morhidi commented on code in PR #351:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/351#discussion_r955077692
##
flink-kubernetes-operator/src/test/java/org/apache/flink/kubernetes/operator/reconciler/diff/SpecDiffTest.java:
##
@@ -0,0 +1,171 @@
+/*
+ *
morhidi commented on code in PR #351:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/351#discussion_r955077692
##
flink-kubernetes-operator/src/test/java/org/apache/flink/kubernetes/operator/reconciler/diff/SpecDiffTest.java:
##
@@ -0,0 +1,171 @@
+/*
+ *
morhidi commented on code in PR #351:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/351#discussion_r955074814
##
flink-kubernetes-operator/src/test/java/org/apache/flink/kubernetes/operator/reconciler/diff/SpecDiffTest.java:
##
@@ -0,0 +1,171 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-29107?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yu Chen updated FLINK-29107:
Description:
I noticed a [discussion|https://github.com/diffplug/spotless/issues/927] in the
spotless
[
https://issues.apache.org/jira/browse/FLINK-29107?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yu Chen updated FLINK-29107:
Summary: Upgrade spotless version to improve spotless check efficiency
(was: Bump up spotless version to
Yu Chen created FLINK-29107:
---
Summary: Bump up spotless version to improve efficiently
Key: FLINK-29107
URL: https://issues.apache.org/jira/browse/FLINK-29107
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-29059?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Godfrey He closed FLINK-29059.
--
Resolution: Fixed
Fixed in master: fe392645421d10923c75cd5438b91d9ed55900d3
> The existing column
[
https://issues.apache.org/jira/browse/FLINK-29059?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Godfrey He reassigned FLINK-29059:
--
Assignee: Yunhong Zheng
> The existing column stats are deleted incorrectly when analyze
godfreyhe closed pull request #20672: [FLINK-29059][table-planner] Fix the
existing column stats are deleted incorrectly when analyze table for partial
columns
URL: https://github.com/apache/flink/pull/20672
--
This is an automated message from the Apache Git Service.
To respond to the
jaumebecks commented on PR #20343:
URL: https://github.com/apache/flink/pull/20343#issuecomment-1227296392
Hi, any plans on merging this? :smile:
--
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
[
https://issues.apache.org/jira/browse/FLINK-28695?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Simonas updated FLINK-28695:
Description:
After upgrade to *1.15.1* we started getting error while running JOB
{code:java}
swuferhong commented on PR #20664:
URL: https://github.com/apache/flink/pull/20664#issuecomment-1227234108
hi, @HuangXingBo, @luoyuxia, @godfreyhe , hive3 and hadoop3 tests passed, I
revert the test commits to run hive2.
swuferhong commented on code in PR #20513:
URL: https://github.com/apache/flink/pull/20513#discussion_r954896567
##
docs/content/docs/dev/table/sql/queries/hints.md:
##
@@ -84,4 +84,244 @@ insert into kafka_table1 /*+
OPTIONS('sink.partitioner'='round-robin') */ select
```
XComp commented on PR #20673:
URL: https://github.com/apache/flink/pull/20673#issuecomment-1227172486
hm, is the failure happening because we're not explicitly setting the direct
executor for the initial `CompletableFuture` that gets created through
`CompletableFuture.supplyAsync`. That
[
https://issues.apache.org/jira/browse/FLINK-29106?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-29106.
Resolution: Duplicate
> value of metric 'idleTimeMsPerSecond' more than 1000
>
swuferhong commented on code in PR #20513:
URL: https://github.com/apache/flink/pull/20513#discussion_r954868511
##
docs/content/docs/dev/table/sql/queries/hints.md:
##
@@ -84,4 +84,244 @@ insert into kafka_table1 /*+
OPTIONS('sink.partitioner'='round-robin') */ select
```
ganlute commented on PR #20542:
URL: https://github.com/apache/flink/pull/20542#issuecomment-1227154498
@wuchong @dannycranmer could you please help me review the changes？Thank
you.
--
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-29106?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
chenyuzhi updated FLINK-29106:
--
Description:
As the picture shown below, the value of metric 'idleTimeMsPerSecond' is more
than
[
https://issues.apache.org/jira/browse/FLINK-29106?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
chenyuzhi updated FLINK-29106:
--
Attachment: image-2022-08-25-19-18-52-755.png
> value of metric 'idleTimeMsPerSecond' more than 1000
chenyuzhi created FLINK-29106:
-
Summary: value of metric 'idleTimeMsPerSecond' more than 1000
Key: FLINK-29106
URL: https://issues.apache.org/jira/browse/FLINK-29106
Project: Flink
Issue Type:
WencongLiu commented on PR #20609:
URL: https://github.com/apache/flink/pull/20609#issuecomment-1227104472
@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
SmirAlex commented on PR #20676:
URL: https://github.com/apache/flink/pull/20676#issuecomment-1227099921
Successful pipeline -
https://dev.azure.com/asmirnov1/Flink/_build/results?buildId=30=results
--
This is an automated message from the Apache Git Service.
To respond to the message,
WencongLiu commented on PR #20678:
URL: https://github.com/apache/flink/pull/20678#issuecomment-1227082549
@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
flinkbot commented on PR #20679:
URL: https://github.com/apache/flink/pull/20679#issuecomment-1227069404
## CI report:
* a8ff03d9242f439a91aad367ee8738c6dbab14f1 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-28738?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-28738:
---
Labels: pull-request-available (was: )
> [doc] Add a user doc about the correctness for
lincoln-lil opened a new pull request, #20679:
URL: https://github.com/apache/flink/pull/20679
## What is the purpose of the change
This is the documentation followup work of
[FLINK-27849](https://issues.apache.org/jira/browse/FLINK-27849).
Mainly illustrates the determinism in
[
https://issues.apache.org/jira/browse/FLINK-27491?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora reassigned FLINK-27491:
--
Assignee: Peter Vary
> Support env replacement in flink-kubernetes-operator CR
>
swuferhong commented on code in PR #20513:
URL: https://github.com/apache/flink/pull/20513#discussion_r954770285
##
docs/content/docs/dev/table/sql/queries/hints.md:
##
@@ -84,4 +84,244 @@ insert into kafka_table1 /*+
OPTIONS('sink.partitioner'='round-robin') */ select
```
swuferhong commented on code in PR #20513:
URL: https://github.com/apache/flink/pull/20513#discussion_r954770026
##
docs/content/docs/dev/table/sql/queries/hints.md:
##
@@ -84,4 +84,244 @@ insert into kafka_table1 /*+
OPTIONS('sink.partitioner'='round-robin') */ select
```
swuferhong commented on code in PR #20513:
URL: https://github.com/apache/flink/pull/20513#discussion_r954768543
##
docs/content/docs/dev/table/sql/queries/hints.md:
##
@@ -84,4 +84,244 @@ insert into kafka_table1 /*+
OPTIONS('sink.partitioner'='round-robin') */ select
```
swuferhong commented on code in PR #20513:
URL: https://github.com/apache/flink/pull/20513#discussion_r954767542
##
docs/content/docs/dev/table/sql/queries/hints.md:
##
@@ -84,4 +84,244 @@ insert into kafka_table1 /*+
OPTIONS('sink.partitioner'='round-robin') */ select
```
[
https://issues.apache.org/jira/browse/FLINK-28261?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora updated FLINK-28261:
---
Affects Version/s: (was: kubernetes-operator-1.1.0)
> Consider Using Dependent Resources for
[
https://issues.apache.org/jira/browse/FLINK-28436?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora closed FLINK-28436.
--
Resolution: Not A Problem
> test_multi_sessionjob.sh is failing intermittently
>
[
https://issues.apache.org/jira/browse/FLINK-28272?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora reassigned FLINK-28272:
--
Assignee: Gabor Somogyi
> Handle TLS Certificate Renewal in Webhook
>
[
https://issues.apache.org/jira/browse/FLINK-28593?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora updated FLINK-28593:
---
Fix Version/s: (was: kubernetes-operator-1.2.0)
> Introduce default CR templates at operator
[
https://issues.apache.org/jira/browse/FLINK-28594?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora updated FLINK-28594:
---
Fix Version/s: (was: kubernetes-operator-1.2.0)
> Add metrics for FlinkService
>
[
https://issues.apache.org/jira/browse/FLINK-28648?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora updated FLINK-28648:
---
Fix Version/s: (was: kubernetes-operator-1.2.0)
> Allow session deletion to block on any
[
https://issues.apache.org/jira/browse/FLINK-28649?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora updated FLINK-28649:
---
Fix Version/s: (was: kubernetes-operator-1.2.0)
> Allow adopting unmanaged jobs as
swuferhong commented on code in PR #20513:
URL: https://github.com/apache/flink/pull/20513#discussion_r954750530
##
docs/content/docs/dev/table/sql/queries/hints.md:
##
@@ -84,4 +84,244 @@ insert into kafka_table1 /*+
OPTIONS('sink.partitioner'='round-robin') */ select
```
[
https://issues.apache.org/jira/browse/FLINK-28966?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora reassigned FLINK-28966:
--
Assignee: Matyas Orhidi
> Check backward compatibility against both 1.1.0 and 1.0.0 (all
[
https://issues.apache.org/jira/browse/FLINK-29086?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora reassigned FLINK-29086:
--
Assignee: Xin Hao
> Fix the Helm chart's Pod env reference
>
swuferhong commented on code in PR #20513:
URL: https://github.com/apache/flink/pull/20513#discussion_r954745770
##
docs/content/docs/dev/table/sql/queries/hints.md:
##
@@ -84,4 +84,244 @@ insert into kafka_table1 /*+
OPTIONS('sink.partitioner'='round-robin') */ select
```
swuferhong commented on code in PR #20513:
URL: https://github.com/apache/flink/pull/20513#discussion_r954745426
##
docs/content/docs/dev/table/sql/queries/hints.md:
##
@@ -84,4 +84,244 @@ insert into kafka_table1 /*+
OPTIONS('sink.partitioner'='round-robin') */ select
```
swuferhong commented on code in PR #20513:
URL: https://github.com/apache/flink/pull/20513#discussion_r954743859
##
docs/content/docs/dev/table/sql/queries/hints.md:
##
@@ -84,4 +84,244 @@ insert into kafka_table1 /*+
OPTIONS('sink.partitioner'='round-robin') */ select
```
swuferhong commented on code in PR #20513:
URL: https://github.com/apache/flink/pull/20513#discussion_r954741138
##
docs/content/docs/dev/table/sql/queries/hints.md:
##
@@ -84,4 +84,244 @@ insert into kafka_table1 /*+
OPTIONS('sink.partitioner'='round-robin') */ select
```
swuferhong commented on code in PR #20513:
URL: https://github.com/apache/flink/pull/20513#discussion_r954734770
##
docs/content/docs/dev/table/sql/queries/hints.md:
##
@@ -84,4 +84,244 @@ insert into kafka_table1 /*+
OPTIONS('sink.partitioner'='round-robin') */ select
```
swuferhong commented on code in PR #20513:
URL: https://github.com/apache/flink/pull/20513#discussion_r954731592
##
docs/content/docs/dev/table/sql/queries/hints.md:
##
@@ -84,4 +84,244 @@ insert into kafka_table1 /*+
OPTIONS('sink.partitioner'='round-robin') */ select
```
1 - 100 of 140 matches
Mail list logo
