ljz2051 opened a new pull request, #23407:
URL: https://github.com/apache/flink/pull/23407
## What is the purpose of the change
This pull request add notes about changing state TTL value when restore
checkpoint.
## Brief change log
- Add a note in "state.md" document.
[
https://issues.apache.org/jira/browse/FLINK-32953?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-32953:
---
Labels: pull-request-available (was: )
> [State TTL]resolve data correctness problem after
Junrui Li created FLINK-33080:
-
Summary: The checkpoint storage configured in the job level by
config option will not take effect
Key: FLINK-33080
URL: https://issues.apache.org/jira/browse/FLINK-33080
Pr
[
https://issues.apache.org/jira/browse/FLINK-33080?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lijie Wang reassigned FLINK-33080:
--
Assignee: Junrui Li
> The checkpoint storage configured in the job level by config option wil
flinkbot commented on PR #23407:
URL: https://github.com/apache/flink/pull/23407#issuecomment-1717067773
## CI report:
* f59f7f7004c10ba16d2cdbb1dec363964414880c UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-32953?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17764518#comment-17764518
]
Jinzhong Li commented on FLINK-32953:
-
[~masteryhx] I publish a pr which add some n
[
https://issues.apache.org/jira/browse/FLINK-30400?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu reassigned FLINK-30400:
--
Assignee: Hang Ruan
> Stop bundling connector-base in externalized connectors
> -
[
https://issues.apache.org/jira/browse/FLINK-33080?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Junrui Li updated FLINK-33080:
--
Description:
When we configure the checkpoint storage at the job level, it can only be done
through t
lindong28 commented on code in PR #248:
URL: https://github.com/apache/flink-ml/pull/248#discussion_r1299531846
##
flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/operator/feedback/SpillableFeedbackQueue.java:
##
@@ -0,0 +1,115 @@
+/*
+ * Li
[
https://issues.apache.org/jira/browse/FLINK-33052?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yuan Mei reassigned FLINK-33052:
Assignee: Zakelly Lan (was: Yuan Mei)
> codespeed server is down
>
>
>
JunRuiLee opened a new pull request, #23408:
URL: https://github.com/apache/flink/pull/23408
## What is the purpose of the change
Make the configured checkpoint storage in the job-side configuration will
take effect.
## Brief change log
Load checkpoin
[
https://issues.apache.org/jira/browse/FLINK-33080?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-33080:
---
Labels: pull-request-available (was: )
> The checkpoint storage configured in the job level
flinkbot commented on PR #23408:
URL: https://github.com/apache/flink/pull/23408#issuecomment-1717151891
## CI report:
* 9960939d8f00229a2cd201c2a9a87db4e90a5c10 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
gaborgsomogyi commented on PR #23359:
URL: https://github.com/apache/flink/pull/23359#issuecomment-1717171777
Asked in the dev discussion thread whether somebody has addition, nothing
arrived so I would say yes. I'm intended to merge it soon...
--
This is an automated message from the Apa
[
https://issues.apache.org/jira/browse/FLINK-32863?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yangze Guo reassigned FLINK-32863:
--
Assignee: Jufang He
> Improve Flink UI's time precision from second level to millisecond leve
KarmaGYZ commented on code in PR #23403:
URL: https://github.com/apache/flink/pull/23403#discussion_r1324171749
##
flink-runtime-web/web-dashboard/src/app/components/humanize-duration.pipe.ts:
##
@@ -46,23 +46,23 @@ export class HumanizeDurationPipe implements PipeTransform {
[
https://issues.apache.org/jira/browse/FLINK-31387?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski closed FLINK-31387.
--
> StreamTaskCancellationTest.testCancelTaskShouldPreventAdditionalProcessingTimeTimersFromBeingFir
hejufang commented on code in PR #23403:
URL: https://github.com/apache/flink/pull/23403#discussion_r1324189387
##
flink-runtime-web/web-dashboard/src/app/components/humanize-duration.pipe.ts:
##
@@ -46,23 +46,23 @@ export class HumanizeDurationPipe implements PipeTransform {
Gyula Fora created FLINK-33081:
--
Summary: Move parallelism override logic into scale method
Key: FLINK-33081
URL: https://issues.apache.org/jira/browse/FLINK-33081
Project: Flink
Issue Type: Imp
maosuhan commented on PR #23162:
URL: https://github.com/apache/flink/pull/23162#issuecomment-1717237735
@ljw-hit Hi, thanks for your effort and the code is already in good shape to
me. I have left a few comments about unit tests. And could you provide a
benchmark test for this improvement?
[
https://issues.apache.org/jira/browse/FLINK-33052?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski updated FLINK-33052:
---
Priority: Blocker (was: Major)
> codespeed server is down
>
>
>
[
https://issues.apache.org/jira/browse/FLINK-33052?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski updated FLINK-33052:
---
Affects Version/s: 1.18.0
> codespeed server is down
>
>
>
[
https://issues.apache.org/jira/browse/FLINK-33052?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski updated FLINK-33052:
---
Component/s: Benchmarks
> codespeed server is down
>
>
>
[
https://issues.apache.org/jira/browse/FLINK-33052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17764564#comment-17764564
]
Piotr Nowojski commented on FLINK-33052:
Thanks for investigating this issue [~j
[
https://issues.apache.org/jira/browse/FLINK-33081?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-33081:
---
Labels: pull-request-available (was: )
> Move parallelism override logic into scale method
gyfora opened a new pull request, #672:
URL: https://github.com/apache/flink-kubernetes-operator/pull/672
## What is the purpose of the change
Simplify the scale / parallelism override flow based on previous feedback.
This change is a refactor and does not introduce new behaviour.
echauchot commented on code in PR #22985:
URL: https://github.com/apache/flink/pull/22985#discussion_r1324233808
##
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/Executing.java:
##
@@ -124,17 +154,33 @@ private void handleDeploymentFailure(ExecutionVert
[
https://issues.apache.org/jira/browse/FLINK-18356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17764565#comment-17764565
]
Sergey Nuyanzin commented on FLINK-18356:
-
https://dev.azure.com/apache-flink/ap
[
https://issues.apache.org/jira/browse/FLINK-33082?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin updated FLINK-33082:
Affects Version/s: 1.17.2
> Azure Pipelines 4 is not responding on AZP
> -
Sergey Nuyanzin created FLINK-33082:
---
Summary: Azure Pipelines 4 is not responding on AZP
Key: FLINK-33082
URL: https://issues.apache.org/jira/browse/FLINK-33082
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-18356?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin updated FLINK-18356:
Affects Version/s: 1.19.0
> flink-table-planner Exit code 137 returned from process
>
[
https://issues.apache.org/jira/browse/FLINK-18356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17764568#comment-17764568
]
Sergey Nuyanzin commented on FLINK-18356:
-
https://dev.azure.com/apache-flink/ap
echauchot commented on code in PR #22985:
URL: https://github.com/apache/flink/pull/22985#discussion_r1324233808
##
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/Executing.java:
##
@@ -124,17 +154,33 @@ private void handleDeploymentFailure(ExecutionVert
echauchot commented on PR #22985:
URL: https://github.com/apache/flink/pull/22985#issuecomment-1717288424
> @dmvk as you authored part on the code in that part, can you review the PR
as well ?
The discussions went around `scalingIntervalMax`, @zentol was the one who
proposed the addi
Dawid Wysakowicz created FLINK-33083:
Summary: SupportsReadingMetadata is not applied when loading a
CompiledPlan
Key: FLINK-33083
URL: https://issues.apache.org/jira/browse/FLINK-33083
Project: F
[
https://issues.apache.org/jira/browse/FLINK-33052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17764570#comment-17764570
]
Yuan Mei commented on FLINK-33052:
--
[~pnowojski] We have the historical data backed up.
[
https://issues.apache.org/jira/browse/FLINK-33052?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yuan Mei updated FLINK-33052:
-
Priority: Critical (was: Blocker)
> codespeed server is down
>
>
>
wangyang0918 commented on PR #23164:
URL: https://github.com/apache/flink/pull/23164#issuecomment-1717326350
@architgyl Could you please verify this PR in a real YARN cluster whether it
solves your original requirement about hive config?
--
This is an automated message from the Apache Git
mbalassi commented on PR #668:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/668#issuecomment-1717336055
@sbrother could you please open a ticket for this, as a good example see
this one:
https://issues.apache.org/jira/browse/FLINK-33066
Could you clarify what do y
mbalassi commented on PR #671:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/671#issuecomment-1717348931
Thanks, @dongwoo6kim. Please include the documentation in this change,
unfortunately we maintain that manually here:
https://github.com/apache/flink-kubernetes-operat
TanYuxin-tyx commented on PR #23401:
URL: https://github.com/apache/flink/pull/23401#issuecomment-1717360318
@reswqa Thanks for fixing the configuration bug. 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
reswqa commented on PR #23401:
URL: https://github.com/apache/flink/pull/23401#issuecomment-1717361467
Thanks! merging...
--
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
reswqa merged PR #23401:
URL: https://github.com/apache/flink/pull/23401
--
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: issues-unsubscr...@flink.apache
Junrui Li created FLINK-33084:
-
Summary: Migrate globalJobParameter in ExecutionConfig to
configuration instance
Key: FLINK-33084
URL: https://issues.apache.org/jira/browse/FLINK-33084
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-33052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17764581#comment-17764581
]
Piotr Nowojski commented on FLINK-33052:
We have been always treating benchmarki
[
https://issues.apache.org/jira/browse/FLINK-30906?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo closed FLINK-30906.
--
Resolution: Fixed
master(1.19) via 70f4c40f15f38ed404d8e031a08d534326535ced.
> TwoInputStreamTask pas
[
https://issues.apache.org/jira/browse/FLINK-30906?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-30906:
---
Fix Version/s: 1.19.0
> TwoInputStreamTask passes wrong configuration object when creating input
>
[
https://issues.apache.org/jira/browse/FLINK-33052?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski updated FLINK-33052:
---
Priority: Blocker (was: Critical)
> codespeed server is down
>
>
>
TanYuxin-tyx commented on PR #23404:
URL: https://github.com/apache/flink/pull/23404#issuecomment-1717364731
Thanks @reswqa for fixing the bug. LGTM now.
--
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-33052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17764581#comment-17764581
]
Piotr Nowojski edited comment on FLINK-33052 at 9/13/23 10:28 AM:
reswqa commented on PR #23404:
URL: https://github.com/apache/flink/pull/23404#issuecomment-1717367967
Thanks for the review! Squashed the fix-up commit. I will merge this if
pipeline passed.
--
This is an automated message from the Apache Git Service.
To respond to the message, please lo
[
https://issues.apache.org/jira/browse/FLINK-33084?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lijie Wang reassigned FLINK-33084:
--
Assignee: Junrui Li
> Migrate globalJobParameter in ExecutionConfig to configuration instance
[
https://issues.apache.org/jira/browse/FLINK-33084?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-33084:
---
Labels: pull-request-available (was: )
> Migrate globalJobParameter in ExecutionConfig to c
JunRuiLee opened a new pull request, #23409:
URL: https://github.com/apache/flink/pull/23409
## What is the purpose of the change
Migrate globalJobParameter to configuration.
## Brief change log
Migrate globalJobParameter to configuration.
## Verifying
wangzzu commented on code in PR #23399:
URL: https://github.com/apache/flink/pull/23399#discussion_r1324344461
##
docs/content/docs/deployment/advanced/failure_enrichers.md:
##
@@ -42,7 +42,7 @@ To implement a custom FailureEnricher plugin, you need to:
Then, create a jar whi
flinkbot commented on PR #23409:
URL: https://github.com/apache/flink/pull/23409#issuecomment-1717412004
## CI report:
* 20e1f350e3ef6dd6a37701317ea7a9feccab9b0e UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-21949?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiabao Sun updated FLINK-21949:
---
Summary: Support ARRAY_AGG aggregate function (was: Support collect to
array aggregate function)
>
Yunhong Zheng created FLINK-33085:
-
Summary: Improve the error message when the invalidate
lookupTableSource without primary key is used as temporal join table
Key: FLINK-33085
URL: https://issues.apache.org/jira/
[
https://issues.apache.org/jira/browse/FLINK-33011?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora closed FLINK-33011.
--
Fix Version/s: kubernetes-operator-1.7.0
Resolution: Fixed
merged to main 82739f62adda33e686da7
swuferhong opened a new pull request, #23410:
URL: https://github.com/apache/flink/pull/23410
## What is the purpose of the change
Improve the error message when the invalidate `lookupTableSource` without
primary key is used as temporal join table. This pr can check the legal
[
https://issues.apache.org/jira/browse/FLINK-33085?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-33085:
---
Labels: pull-request-available (was: )
> Improve the error message when the invalidate look
lindong28 commented on PR #248:
URL: https://github.com/apache/flink-ml/pull/248#issuecomment-1717534003
Thanks for the update! 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
lindong28 merged PR #248:
URL: https://github.com/apache/flink-ml/pull/248
--
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: issues-unsubscr...@flink.apac
[
https://issues.apache.org/jira/browse/FLINK-32704?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin reassigned FLINK-32704:
Assignee: Jiang Xin
> Supports spilling to disk when feedback channel memory buffer is full
> ---
[
https://issues.apache.org/jira/browse/FLINK-32704?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17764635#comment-17764635
]
Dong Lin commented on FLINK-32704:
--
Merged to apache/flink-ml master branch 865404910ca
flinkbot commented on PR #23410:
URL: https://github.com/apache/flink/pull/23410#issuecomment-1717541375
## CI report:
* a5f93f4153d0b8430d836a35a6f79b80caa76457 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-33053?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17764640#comment-17764640
]
Yangze Guo commented on FLINK-33053:
JFYI, I'm still investigating the root cause of
dongwoo6kim commented on PR #671:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/671#issuecomment-1717548787
Thanks @mbalassi. I have updated the docs
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
hejufang commented on PR #23403:
URL: https://github.com/apache/flink/pull/23403#issuecomment-1717554816
@masteryhx Thank you for your suggestion. I have adjusted the precision of
checkpoint related time. please review. cc @KarmaGYZ

> Support ARRAY_AGG aggregate function
> ---
[
https://issues.apache.org/jira/browse/FLINK-21949?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17764658#comment-17764658
]
Jiabao Sun commented on FLINK-21949:
The pull request is ready for review now.
This
flinkbot commented on PR #23411:
URL: https://github.com/apache/flink/pull/23411#issuecomment-1717597767
## CI report:
* 10081ad9bdba84b3dac22fb7a6137994cc79622b UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-33083?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17764666#comment-17764666
]
Yunhong Zheng commented on FLINK-33083:
---
It looks like this is a planner bug, and
[
https://issues.apache.org/jira/browse/FLINK-33083?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dawid Wysakowicz reassigned FLINK-33083:
Assignee: Dawid Wysakowicz
> SupportsReadingMetadata is not applied when loading
[
https://issues.apache.org/jira/browse/FLINK-28758?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17764673#comment-17764673
]
Piotr Nowojski commented on FLINK-28758:
I will try to take care of that
> Flin
[
https://issues.apache.org/jira/browse/FLINK-28758?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski reassigned FLINK-28758:
--
Assignee: Piotr Nowojski (was: Mark Cho)
> FlinkKafkaConsumer fails to stop with sav
[
https://issues.apache.org/jira/browse/FLINK-31966?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17764674#comment-17764674
]
Gyula Fora commented on FLINK-31966:
[~tagarr] I think that sounds reasonable. I thi
[
https://issues.apache.org/jira/browse/FLINK-33052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17764675#comment-17764675
]
Yuan Mei commented on FLINK-33052:
--
# I think this issue is very critical as you mentio
[
https://issues.apache.org/jira/browse/FLINK-33052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17764675#comment-17764675
]
Yuan Mei edited comment on FLINK-33052 at 9/13/23 1:30 PM:
---
He
[
https://issues.apache.org/jira/browse/FLINK-33052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17764675#comment-17764675
]
Yuan Mei edited comment on FLINK-33052 at 9/13/23 1:31 PM:
---
He
[
https://issues.apache.org/jira/browse/FLINK-33052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17764675#comment-17764675
]
Yuan Mei edited comment on FLINK-33052 at 9/13/23 1:31 PM:
---
He
[
https://issues.apache.org/jira/browse/FLINK-33052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17764675#comment-17764675
]
Yuan Mei edited comment on FLINK-33052 at 9/13/23 1:31 PM:
---
He
boring-cyborg[bot] commented on PR #48:
URL:
https://github.com/apache/flink-connector-kafka/pull/48#issuecomment-1717647945
Thanks for opening this pull request! Please check out our contributing
guidelines. (https://flink.apache.org/contributing/how-to-contribute.html)
--
This is a
[
https://issues.apache.org/jira/browse/FLINK-28758?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-28758:
---
Labels: pull-request-available (was: )
> FlinkKafkaConsumer fails to stop with savepoint
>
[
https://issues.apache.org/jira/browse/FLINK-33052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17764675#comment-17764675
]
Yuan Mei edited comment on FLINK-33052 at 9/13/23 1:35 PM:
---
He
[
https://issues.apache.org/jira/browse/FLINK-33052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17764675#comment-17764675
]
Yuan Mei edited comment on FLINK-33052 at 9/13/23 1:35 PM:
---
He
[
https://issues.apache.org/jira/browse/FLINK-33052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17764675#comment-17764675
]
Yuan Mei edited comment on FLINK-33052 at 9/13/23 1:39 PM:
---
He
[
https://issues.apache.org/jira/browse/FLINK-33052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17764675#comment-17764675
]
Yuan Mei edited comment on FLINK-33052 at 9/13/23 1:41 PM:
---
He
[
https://issues.apache.org/jira/browse/FLINK-33052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17764675#comment-17764675
]
Yuan Mei edited comment on FLINK-33052 at 9/13/23 1:44 PM:
---
He
mxm commented on code in PR #672:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/672#discussion_r1324308777
##
flink-kubernetes-operator-autoscaler/src/main/java/org/apache/flink/kubernetes/operator/autoscaler/JobAutoScalerImpl.java:
##
@@ -74,6 +76,36 @@ public
[
https://issues.apache.org/jira/browse/FLINK-33053?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17764702#comment-17764702
]
Zili Chen commented on FLINK-33053:
---
I noticed that the {{TreeCache}}'s close call {{r
[
https://issues.apache.org/jira/browse/FLINK-33052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17764675#comment-17764675
]
Yuan Mei edited comment on FLINK-33052 at 9/13/23 2:14 PM:
---
He
dawidwys opened a new pull request, #23412:
URL: https://github.com/apache/flink/pull/23412
## What is the purpose of the change
The PR fixes creating a TableSourceScan to also include a proper
ReadingMetadataSpec which has been applied on the source.
## Brief change log
[
https://issues.apache.org/jira/browse/FLINK-33083?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-33083:
---
Labels: pull-request-available (was: )
> SupportsReadingMetadata is not applied when loadin
flinkbot commented on PR #23412:
URL: https://github.com/apache/flink/pull/23412#issuecomment-1717739419
## CI report:
* 75b651538a1fa083c211ab8c4020822590b89043 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-33053?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17764721#comment-17764721
]
Zili Chen commented on FLINK-33053:
---
See https://lists.apache.org/thread/3b9hn9j4c05yf
[
https://issues.apache.org/jira/browse/FLINK-33053?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17764723#comment-17764723
]
Zili Chen commented on FLINK-33053:
---
But we don't have other shared watchers so we can
sbrother commented on PR #668:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/668#issuecomment-1717779633
No problem, I just requested an Apache Jira account.
And yes, I think that's what I mean. I had created a Flink Session
Controller using a basic FlinkDeployment ma
1 - 100 of 157 matches
Mail list logo