[
https://issues.apache.org/jira/browse/FLINK-33863?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yanfei Lei closed FLINK-33863.
--
> Compressed Operator state restore failed
>
>
>
[
https://issues.apache.org/jira/browse/FLINK-33863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17800702#comment-17800702
]
Yanfei Lei commented on FLINK-33863:
Merged via
[
https://issues.apache.org/jira/browse/FLINK-33863?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yanfei Lei resolved FLINK-33863.
Fix Version/s: 1.19.0
Resolution: Fixed
> Compressed Operator state restore failed
>
[
https://issues.apache.org/jira/browse/FLINK-33938?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xintong Song reassigned FLINK-33938:
Assignee: Ao Yuchen
> Correct implicit coercions in relational operators to adopt
syhily commented on PR #72:
URL:
https://github.com/apache/flink-connector-pulsar/pull/72#issuecomment-1870006920
The license file version should also be bumped in the mean time.
--
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-33009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17800696#comment-17800696
]
Wencong Liu edited comment on FLINK-33009 at 12/27/23 6:43 AM:
---
Hi
[
https://issues.apache.org/jira/browse/FLINK-33009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17800696#comment-17800696
]
Wencong Liu edited comment on FLINK-33009 at 12/27/23 6:42 AM:
---
Hi
flinkbot commented on PR #23998:
URL: https://github.com/apache/flink/pull/23998#issuecomment-1869997869
## CI report:
* a99046290254b2056258bd8023fc3c89edff3735 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-33682?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhanghao Chen closed FLINK-33682.
-
Resolution: Abandoned
> Reuse source operator input records/bytes metrics for
[
https://issues.apache.org/jira/browse/FLINK-33682?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17800697#comment-17800697
]
Zhanghao Chen commented on FLINK-33682:
---
Closing this ticket as we found a better unified
[
https://issues.apache.org/jira/browse/FLINK-33681?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-33681:
---
Labels: pull-request-available (was: )
> Display source/sink numRecordsIn/Out &
X-czh opened a new pull request, #23998:
URL: https://github.com/apache/flink/pull/23998
## What is the purpose of the change
Currently, the numRecordsIn & numBytesIn metrics for sources and the
numRecordsOut & numBytesOut metrics for sinks are always 0 on the Flink web
[
https://issues.apache.org/jira/browse/FLINK-33009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17800696#comment-17800696
]
Wencong Liu commented on FLINK-33009:
-
Hi [~mapohl] , I've encountered the same issue once more when
[
https://issues.apache.org/jira/browse/FLINK-33949?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Wencong Liu updated FLINK-33949:
Description:
Currently I'm trying to refactor some APIs annotated by @Public in [FLIP-382:
[
https://issues.apache.org/jira/browse/FLINK-33949?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Wencong Liu updated FLINK-33949:
Description:
Currently I'm trying to refactor some APIs annotated by @Public in [FLIP-382:
Wencong Liu created FLINK-33949:
---
Summary: METHOD_ABSTRACT_NOW_DEFAULT should be both source
compatible and binary compatible
Key: FLINK-33949
URL: https://issues.apache.org/jira/browse/FLINK-33949
[
https://issues.apache.org/jira/browse/FLINK-33943?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17800694#comment-17800694
]
Vijay commented on FLINK-33943:
---
Thanks [~wanglijie] for your inputs.
> Apache flink: Issues after
[
https://issues.apache.org/jira/browse/FLINK-33944?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17800692#comment-17800692
]
Vijay commented on FLINK-33944:
---
[~wanglijie] Do you have any input on this information request for
flinkbot commented on PR #23997:
URL: https://github.com/apache/flink/pull/23997#issuecomment-1869927270
## CI report:
* 9c4b58a6a3e15d468b983b97f27f8266bcfb3036 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
Zakelly commented on PR #83:
URL: https://github.com/apache/flink-benchmarks/pull/83#issuecomment-1869926898
@Myasuka I fixed a compile error and now it's OK. Maybe this repo needs a CI
process validating the compilation.
Please let me know if you have any other concern on this PR.
flinkbot commented on PR #23996:
URL: https://github.com/apache/flink/pull/23996#issuecomment-1869925513
## CI report:
* 8b708faea30bb078f8114bc3faf9e46e7b6ae775 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-33945?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-33945:
---
Labels: pull-request-available (was: )
> Cleanup usage of deprecated
>
liuyongvs opened a new pull request, #23997:
URL: https://github.com/apache/flink/pull/23997
## What is the purpose of the change
*Cleanup usage of deprecated Cleanup usage of deprecated
org.apache.flink.table.api.dataview.ListView#ListView*
## Brief change log
[
https://issues.apache.org/jira/browse/FLINK-33948?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-33948:
---
Labels: pull-request-available (was: )
> Cleanup usage of
liuyongvs opened a new pull request, #23996:
URL: https://github.com/apache/flink/pull/23996
…le.api.dataview.MapView#MapView
## What is the purpose of the change
*(For example: This pull request makes task deployment go through the blob
server, rather than through
Jacky Lau created FLINK-33948:
-
Summary: Cleanup usage of
org.apache.flink.table.api.dataview.MapView#MapView
Key: FLINK-33948
URL: https://issues.apache.org/jira/browse/FLINK-33948
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-33944?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Vijay updated FLINK-33944:
--
Description:
We are using Flink (1.18) version for our Flink cluster. The job manager has
been deployed in
[
https://issues.apache.org/jira/browse/FLINK-33947?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan updated FLINK-33947:
Fix Version/s: 1.19.0
1.17.3
1.18.2
> Fix bugs in
[
https://issues.apache.org/jira/browse/FLINK-33947?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan reassigned FLINK-33947:
---
Assignee: RocMarshal
> Fix bugs in DelegatingConfiguration missed the prefix mapping
>
[
https://issues.apache.org/jira/browse/FLINK-33856?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17800683#comment-17800683
]
Hangxiang Yu commented on FLINK-33856:
--
[~Weijie Guo] Thanks for pinging me here.
[~hejufang001]
RocMarshal commented on PR #23994:
URL: https://github.com/apache/flink/pull/23994#issuecomment-1869917144
> It's indeed a bug. The removeConfig and removeKey of
DelegatingConfiguration missed the prefix as well. I didn't notice them in the
beginning. Would you like to fix it? If yes, feel
RocMarshal created FLINK-33947:
--
Summary: Fix bugs in DelegatingConfiguration missed the prefix
mapping
Key: FLINK-33947
URL: https://issues.apache.org/jira/browse/FLINK-33947
Project: Flink
Yue Ma created FLINK-33946:
--
Summary: RocksDb sets setAvoidFlushDuringShutdown to true to speed
up Task Cancel
Key: FLINK-33946
URL: https://issues.apache.org/jira/browse/FLINK-33946
Project: Flink
Jacky Lau created FLINK-33945:
-
Summary: Cleanup usage of deprecated
org.apache.flink.table.api.dataview.ListView#ListView
Key: FLINK-33945
URL: https://issues.apache.org/jira/browse/FLINK-33945
Project:
1996fanrui commented on PR #23994:
URL: https://github.com/apache/flink/pull/23994#issuecomment-1869905090
Thanks @RocMarshal for the quick review!
> if we run the followed case, will be our expected results consistent with
the current fixed results?
>
> ```
> @Test
[
https://issues.apache.org/jira/browse/FLINK-33943?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17800679#comment-17800679
]
Lijie Wang commented on FLINK-33943:
Maybe you can see the comments in FLINK-19358 and
[
https://issues.apache.org/jira/browse/FLINK-32881?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hangxiang Yu resolved FLINK-32881.
--
Resolution: Fixed
merged into master via 81598f8a...d0dbd51c
> Client supports making
[
https://issues.apache.org/jira/browse/FLINK-33943?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17800677#comment-17800677
]
Vijay edited comment on FLINK-33943 at 12/27/23 2:48 AM:
-
[~wanglijie] Thanks
[
https://issues.apache.org/jira/browse/FLINK-33943?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17800677#comment-17800677
]
Vijay edited comment on FLINK-33943 at 12/27/23 2:48 AM:
-
[~wanglijie] Thanks
[
https://issues.apache.org/jira/browse/FLINK-33943?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17800677#comment-17800677
]
Vijay edited comment on FLINK-33943 at 12/27/23 2:48 AM:
-
[~wanglijie] Thanks
masteryhx closed pull request #23253: [FLINK-32881][checkpoint] Support
triggering savepoint in detach mode for CLI and dumping all pending savepoint
ids by rest api
URL: https://github.com/apache/flink/pull/23253
--
This is an automated message from the Apache Git Service.
To respond to
[
https://issues.apache.org/jira/browse/FLINK-33943?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17800677#comment-17800677
]
Vijay commented on FLINK-33943:
---
Thanks for the prompt update. Is there a plan to support of HA
[
https://issues.apache.org/jira/browse/FLINK-33943?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lijie Wang closed FLINK-33943.
--
Resolution: Not A Bug
> Apache flink: Issues after configuring HA (using zookeeper setting)
>
[
https://issues.apache.org/jira/browse/FLINK-33943?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17800676#comment-17800676
]
Lijie Wang commented on FLINK-33943:
I 'll close this issue because it's not a bug. cc
[
https://issues.apache.org/jira/browse/FLINK-33944?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Vijay updated FLINK-33944:
--
Description:
We are using Flink (1.18) version for our Flink cluster. The job manager has
been deployed in
Vijay created FLINK-33944:
-
Summary: Apache Flink: Process to restore more than one job on job
manager startup from the respective savepoints
Key: FLINK-33944
URL: https://issues.apache.org/jira/browse/FLINK-33944
[
https://issues.apache.org/jira/browse/FLINK-33943?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Vijay updated FLINK-33943:
--
Description:
Hi Team,
*Note:* Not sure whether I have picked the right component while raising the
issue.
RocMarshal commented on code in PR #23994:
URL: https://github.com/apache/flink/pull/23994#discussion_r1436698086
##
flink-core/src/test/java/org/apache/flink/configuration/DelegatingConfigurationTest.java:
##
@@ -136,15 +136,65 @@ public void
[
https://issues.apache.org/jira/browse/FLINK-33943?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17800671#comment-17800671
]
Lijie Wang commented on FLINK-33943:
[~vrang...@in.ibm.com] I think it should work if you use
[
https://issues.apache.org/jira/browse/FLINK-33943?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17800670#comment-17800670
]
Vijay edited comment on FLINK-33943 at 12/27/23 2:22 AM:
-
[~wanglijie] Is the HA
[
https://issues.apache.org/jira/browse/FLINK-33943?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17800670#comment-17800670
]
Vijay commented on FLINK-33943:
---
[~wanglijie] Is the HA in session mode support execution of multiple
[
https://issues.apache.org/jira/browse/FLINK-33943?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17800669#comment-17800669
]
Vijay commented on FLINK-33943:
---
The issue can be reproduced by enabling high-availability.type:
[
https://issues.apache.org/jira/browse/FLINK-33943?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17800668#comment-17800668
]
Lijie Wang commented on FLINK-33943:
Hi [~vrang...@in.ibm.com], currently, HA in Application Mode is
Vijay created FLINK-33943:
-
Summary: Apache flink: Issues after configuring HA (using
zookeeper setting)
Key: FLINK-33943
URL: https://issues.apache.org/jira/browse/FLINK-33943
Project: Flink
Issue
flinkbot commented on PR #23995:
URL: https://github.com/apache/flink/pull/23995#issuecomment-1869708699
## CI report:
* c6fd1da2aee1519c4dd2d41c2c8212185f4bbab2 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
Shrey-Viradiya opened a new pull request, #23995:
URL: https://github.com/apache/flink/pull/23995
## What is the purpose of the change
*(For example: This pull request makes task deployment go through the blob
server, rather than through RPC. That way we avoid re-transferring
[
https://issues.apache.org/jira/browse/FLINK-32849?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan resolved FLINK-32849.
-
Fix Version/s: 1.19.0
Resolution: Fixed
> [JUnit5 Migration] The resourcemanager package of
[
https://issues.apache.org/jira/browse/FLINK-32849?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17800504#comment-17800504
]
Rui Fan commented on FLINK-32849:
-
Merged to master(1.19) via : 11cdf7e7adacfe64d961a48844841a24b918257a
1996fanrui merged PR #23973:
URL: https://github.com/apache/flink/pull/23973
--
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:
RocXing commented on code in PR #23635:
URL: https://github.com/apache/flink/pull/23635#discussion_r1436413745
##
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/TaskBalancedPreferredSlotSharingStrategy.java:
##
@@ -0,0 +1,344 @@
+/*
+ * Licensed to the Apache
[
https://issues.apache.org/jira/browse/FLINK-20281?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu reassigned FLINK-20281:
---
Assignee: xuyang
> Window aggregation supports changelog stream input
>
flinkbot commented on PR #23994:
URL: https://github.com/apache/flink/pull/23994#issuecomment-1869458088
## CI report:
* 19de85716cc7962c47836d5d11859c333d4d454b UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-33942?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-33942:
---
Labels: pull-request-available (was: )
> DelegatingConfiguration misses the perfix for
1996fanrui opened a new pull request, #23994:
URL: https://github.com/apache/flink/pull/23994
## What is the purpose of the change
DelegatingConfiguration misses the perfix for some methods, such as:
-
[
https://issues.apache.org/jira/browse/FLINK-33942?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan updated FLINK-33942:
Description:
DelegatingConfiguration misses the perfix for some methods, such as:
*
hunter-cloud09 commented on PR #740:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/740#issuecomment-1869390002
hi, @gyfora, I added test case. PTAL.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
RocMarshal commented on PR #23973:
URL: https://github.com/apache/flink/pull/23973#issuecomment-1869379533
Hi， Thanks so much for @1996fanrui your review and patience.
I updated it based on your comments.
And I triggered about 4 times ci-flink-bot by modifying commit(--amend). Its
Rui Fan created FLINK-33942:
---
Summary: DelegatingConfiguration misses the perfix for some methods
Key: FLINK-33942
URL: https://issues.apache.org/jira/browse/FLINK-33942
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-33942?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan updated FLINK-33942:
Fix Version/s: 1.19.0
1.17.3
1.18.2
> DelegatingConfiguration
1996fanrui commented on code in PR #728:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/728#discussion_r1436336459
##
flink-autoscaler/src/main/java/org/apache/flink/autoscaler/config/AutoScalerOptions.java:
##
@@ -72,6 +72,21 @@ private static
flashJd commented on code in PR #728:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/728#discussion_r143629
##
flink-autoscaler/src/main/java/org/apache/flink/autoscaler/config/AutoScalerOptions.java:
##
@@ -72,6 +72,21 @@ private static
[
https://issues.apache.org/jira/browse/FLINK-33940?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17800444#comment-17800444
]
Zhanghao Chen commented on FLINK-33940:
---
Thanks [~gyfora] for pointing that. We also observe some
[
https://issues.apache.org/jira/browse/FLINK-20281?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17800443#comment-17800443
]
xuyang commented on FLINK-20281:
Can I take this Jira?
> Window aggregation supports changelog stream
[
https://issues.apache.org/jira/browse/FLINK-33938?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17800439#comment-17800439
]
Ao Yuchen commented on FLINK-33938:
---
Would you like to take a look at this ticket? [~simplejason]
>
74 matches
Mail list logo
