WencongLiu commented on PR #22341:
URL: https://github.com/apache/flink/pull/22341#issuecomment-1652958163
The CI has passed and pull request is ready for review now.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use
[
https://issues.apache.org/jira/browse/FLINK-32698?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17747772#comment-17747772
]
Rui Fan commented on FLINK-32698:
-
bq. I found the sink operator in `Paimon` is a
[
https://issues.apache.org/jira/browse/FLINK-32674?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lincoln lee resolved FLINK-32674.
-
Resolution: Fixed
fixed in master:65f200b819e47800ff31cad55d4fe5c4a31706c7
> Add documentation
[
https://issues.apache.org/jira/browse/FLINK-32674?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lincoln lee closed FLINK-32674.
---
> Add documentation for the new Context.getTargetColumns
>
[
https://issues.apache.org/jira/browse/FLINK-25015?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fang Yong updated FLINK-25015:
--
Parent: FLINK-25318
Issue Type: Sub-task (was: Improvement)
> job name should not always be
[
https://issues.apache.org/jira/browse/FLINK-25015?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17747763#comment-17747763
]
Fang Yong commented on FLINK-25015:
---
[~zouyunhe] What's the progress of this issue, there're conflicts
lincoln-lil merged PR #23075:
URL: https://github.com/apache/flink/pull/23075
--
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-32679?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17747762#comment-17747762
]
grandfisher commented on FLINK-32679:
-
It's not the same question. I think FLINK-28753 is fix
Jacky Lau created FLINK-32699:
-
Summary: select typeof(proctime()); throw exception in sql-client
Key: FLINK-32699
URL: https://issues.apache.org/jira/browse/FLINK-32699
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-32679?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17747739#comment-17747739
]
Benchao Li commented on FLINK-32679:
In FLINK-28753 (merged in 1.16.0), we have supported this,
[
https://issues.apache.org/jira/browse/FLINK-32698?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17747738#comment-17747738
]
Zhu Zhu commented on FLINK-32698:
-
Thanks for the proposal. [~Ming Li]
Flink tends to avoid expose
[
https://issues.apache.org/jira/browse/FLINK-32698?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17747737#comment-17747737
]
Fang Yong commented on FLINK-32698:
---
[~Ming Li] `ManagedSnapshotContext` is a `public` interface and
[
https://issues.apache.org/jira/browse/FLINK-32698?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ming Li updated FLINK-32698:
Description:
Currently only {{checkpointID}} and {{checkpointTimestamp}} information are
provided in
flinkbot commented on PR #23086:
URL: https://github.com/apache/flink/pull/23086#issuecomment-1652865213
## CI report:
* bac4b2c25121c38f2d0ba2dbe1e1de801e32691c UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-32686?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17747733#comment-17747733
]
Wencong Liu edited comment on FLINK-32686 at 7/27/23 3:42 AM:
--
Thanks for
[
https://issues.apache.org/jira/browse/FLINK-32686?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-32686:
---
Labels: pull-request-available (was: )
> Performance regression on startScheduling.BATCH
WencongLiu opened a new pull request, #23086:
URL: https://github.com/apache/flink/pull/23086
## What is the purpose of the change
*Avoid creating tiered internal shuffle master before enabling the tiered
storage.*
## Brief change log
- *Avoid creating tiered
Ming Li created FLINK-32698:
---
Summary: Add getCheckpointOptions interface in
ManagedSnapshotContext
Key: FLINK-32698
URL: https://issues.apache.org/jira/browse/FLINK-32698
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-32650?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
李精卫 updated FLINK-32650:
Fix Version/s: 1.18.0
(was: 1.17.0)
> Added the ability to split flink-protobuf codegen
[
https://issues.apache.org/jira/browse/FLINK-32686?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17747733#comment-17747733
]
Wencong Liu commented on FLINK-32686:
-
Thanks for reporting this. The second regression since 07.24
[
https://issues.apache.org/jira/browse/FLINK-32650?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
李精卫 updated FLINK-32650:
Affects Version/s: 1.18.0
(was: 1.17.0)
> Added the ability to split flink-protobuf
[
https://issues.apache.org/jira/browse/FLINK-32650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17747732#comment-17747732
]
李精卫 commented on FLINK-32650:
-
[~libenchao] I don't know much about the specific implementation and usage
flinkbot commented on PR #23085:
URL: https://github.com/apache/flink/pull/23085#issuecomment-1652832579
## CI report:
* d09ca1560ad0cd2b452de8205af4a9ea5f3e3569 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-32680?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-32680:
---
Labels: pull-request-available (was: )
> Job vertex names get messed up once there is a
JunRuiLee opened a new pull request, #23085:
URL: https://github.com/apache/flink/pull/23085
## What is the purpose of the change
There is a bug in generating the JobVertex name when the source nodes are
chained with a MultipleInput node, resulting in a messed up
[
https://issues.apache.org/jira/browse/FLINK-32697?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunyanyong updated FLINK-32697:
---
Description:
When using JDBC to insert data into the oracle database, if the target field is
sunyanyong created FLINK-32697:
--
Summary: When using JDBC to insert data into the oracle database,
an error will be reported if the target field is lowercase,
Key: FLINK-32697
URL:
[
https://issues.apache.org/jira/browse/FLINK-32402?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17747719#comment-17747719
]
Fang Yong commented on FLINK-32402:
---
[~knaufk] Currently I think it's better to add this in
luoyuxia merged PR #23076:
URL: https://github.com/apache/flink/pull/23076
--
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-32460?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia resolved FLINK-32460.
--
Fix Version/s: 1.18.0
Resolution: Fixed
master:
3c452de8922784d58e0ebd68f5303e9459cc1d58
>
lindong28 commented on code in PR #23021:
URL: https://github.com/apache/flink/pull/23021#discussion_r1275633566
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/common/CommonExecTableSourceScan.java:
##
@@ -103,56 +106,63 @@
lindong28 commented on code in PR #23021:
URL: https://github.com/apache/flink/pull/23021#discussion_r1275633566
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/common/CommonExecTableSourceScan.java:
##
@@ -103,56 +106,63 @@
luoyuxia commented on code in PR #23075:
URL: https://github.com/apache/flink/pull/23075#discussion_r1275626333
##
docs/content/docs/dev/table/sql/insert.md:
##
@@ -208,7 +208,9 @@ column_list:
**COLUMN LIST**
Given a table T(a INT, b INT, c INT), Flink supports INSERT INTO
lincoln-lil commented on code in PR #23075:
URL: https://github.com/apache/flink/pull/23075#discussion_r1274924840
##
docs/content/docs/dev/table/sql/insert.md:
##
@@ -208,7 +208,9 @@ column_list:
**COLUMN LIST**
Given a table T(a INT, b INT, c INT), Flink supports INSERT
lincoln-lil commented on code in PR #23075:
URL: https://github.com/apache/flink/pull/23075#discussion_r1274924840
##
docs/content/docs/dev/table/sql/insert.md:
##
@@ -208,7 +208,9 @@ column_list:
**COLUMN LIST**
Given a table T(a INT, b INT, c INT), Flink supports INSERT
[
https://issues.apache.org/jira/browse/FLINK-32628?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin closed FLINK-32628.
---
> build_wheels_on_macos fails on AZP
> --
>
>
[
https://issues.apache.org/jira/browse/FLINK-32628?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin updated FLINK-32628:
Fix Version/s: 1.18.0
1.16.3
1.17.2
>
[
https://issues.apache.org/jira/browse/FLINK-32628?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin resolved FLINK-32628.
-
Resolution: Fixed
> build_wheels_on_macos fails on AZP
>
[
https://issues.apache.org/jira/browse/FLINK-32628?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17747689#comment-17747689
]
Sergey Nuyanzin commented on FLINK-32628:
-
Merged to 1.16:
[
https://issues.apache.org/jira/browse/FLINK-32628?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin reassigned FLINK-32628:
---
Assignee: Sergey Nuyanzin
> build_wheels_on_macos fails on AZP
>
hanyuzheng7 commented on PR #22842:
URL: https://github.com/apache/flink/pull/22842#issuecomment-1652682664
@snuyanzin ci test pass 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 go to the
[
https://issues.apache.org/jira/browse/FLINK-28045?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17747665#comment-17747665
]
Alexander Fedulov commented on FLINK-28045:
---
[~danny.cranmer] I see that Kinesis Source V2
[
https://issues.apache.org/jira/browse/FLINK-28045?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Fedulov updated FLINK-28045:
--
Summary: [umbrella] Blockers for SourceFunction API (in Flink 2.0) (was:
[umbrella]
[
https://issues.apache.org/jira/browse/FLINK-28045?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Fedulov updated FLINK-28045:
--
Summary: [umbrella] Blockers for SourceFunction API removal (in Flink 2.0)
(was:
[
https://issues.apache.org/jira/browse/FLINK-28045?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Fedulov updated FLINK-28045:
--
Description:
This ticket should only contain items where SourceFunction is already
Alexander Fedulov created FLINK-32696:
-
Summary: Promote Kinesis connector support to PublicEvolving
Key: FLINK-32696
URL: https://issues.apache.org/jira/browse/FLINK-32696
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-28045?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Fedulov updated FLINK-28045:
--
Description:
This ticket should only contain items where SourceFunction is already
[
https://issues.apache.org/jira/browse/FLINK-32695?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Fedulov updated FLINK-32695:
--
Summary: Migrate SourceFunction in Tests to Source V2 API (was: Migrate
[
https://issues.apache.org/jira/browse/FLINK-32692?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Fedulov updated FLINK-32692:
--
Description: See also FLINK-28045 (was: See also
[
https://issues.apache.org/jira/browse/FLINK-28045?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Fedulov updated FLINK-28045:
--
Description: This ticket should only contain items where SourceFunction is
already
[
https://issues.apache.org/jira/browse/FLINK-32692?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Fedulov updated FLINK-32692:
--
Description: See also https://issues.apache.org/jira/browse/FLINK-28045
> [umbrella]
[
https://issues.apache.org/jira/browse/FLINK-28051?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Fedulov updated FLINK-28051:
--
Summary: Introduce Source API alternative to ExternallyInducedSource (was:
Introduce
[
https://issues.apache.org/jira/browse/FLINK-28045?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Fedulov updated FLINK-28045:
--
Description: This ticket should only contain items where SourceFunction is
already
[
https://issues.apache.org/jira/browse/FLINK-28045?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Fedulov updated FLINK-28045:
--
Description: Should only contain items where SourceFunction is used in the
existing
[
https://issues.apache.org/jira/browse/FLINK-28045?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Fedulov updated FLINK-28045:
--
Description: This ticket should only contain items where SourceFunction is
used in
gyfora commented on PR #639:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/639#issuecomment-1652453972
cc @mxm
--
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
Alexander Fedulov created FLINK-32695:
-
Summary: Migrate SourceFunction in Tests to Source API
Key: FLINK-32695
URL: https://issues.apache.org/jira/browse/FLINK-32695
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-28048?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Fedulov updated FLINK-28048:
--
Description: This also has to verify that Iceberg connector tests mentioned
in
Alexander Fedulov created FLINK-32694:
-
Summary: Cascade deprecation to classes that implement
ParallelSourceFunction
Key: FLINK-32694
URL: https://issues.apache.org/jira/browse/FLINK-32694
[
https://issues.apache.org/jira/browse/FLINK-32693?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Fedulov updated FLINK-32693:
--
Description:
* SocketTextStreamFunction
[
https://issues.apache.org/jira/browse/FLINK-32693?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Fedulov reassigned FLINK-32693:
-
Assignee: Alexander Fedulov
> Cascade deprecation to classes that directly
[
https://issues.apache.org/jira/browse/FLINK-32693?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Fedulov updated FLINK-32693:
--
Description:
* SocketTextStreamFunction
Alexander Fedulov created FLINK-32693:
-
Summary: Cascade deprecation to classes that directly implement
SourceFunction
Key: FLINK-32693
URL: https://issues.apache.org/jira/browse/FLINK-32693
[
https://issues.apache.org/jira/browse/FLINK-28050?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Fedulov updated FLINK-28050:
--
Summary: Introduce Source API alternative to
SourceExecutionContext#fromElements(*)
[
https://issues.apache.org/jira/browse/FLINK-28054?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Fedulov updated FLINK-28054:
--
Parent: (was: FLINK-28045)
Issue Type: Improvement (was: Sub-task)
>
[
https://issues.apache.org/jira/browse/FLINK-28056?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Fedulov updated FLINK-28056:
--
Parent: FLINK-32692
Issue Type: Sub-task (was: Improvement)
> Introduce high
[
https://issues.apache.org/jira/browse/FLINK-28056?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Fedulov updated FLINK-28056:
--
Parent: (was: FLINK-28045)
Issue Type: Improvement (was: Sub-task)
>
[
https://issues.apache.org/jira/browse/FLINK-28049?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Fedulov updated FLINK-28049:
--
Parent: FLINK-32692
Issue Type: Sub-task (was: Improvement)
> Introduce
[
https://issues.apache.org/jira/browse/FLINK-28049?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Fedulov updated FLINK-28049:
--
Parent: (was: FLINK-28045)
Issue Type: Improvement (was: Sub-task)
>
Alexander Fedulov created FLINK-32692:
-
Summary: [umbrella] Nice-to-haves for SourceFunction API removal
Key: FLINK-32692
URL: https://issues.apache.org/jira/browse/FLINK-32692
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-28045?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Fedulov updated FLINK-28045:
--
Summary: [umbrella] Blockers for SourceFunction API removal (was:
[umbrella]
flinkbot commented on PR #23084:
URL: https://github.com/apache/flink/pull/23084#issuecomment-1652312270
## CI report:
* 4d3ccc527fcb655ddb5df44797819c1ee1684fe9 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-32691?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-32691:
---
Labels: pull-request-available (was: )
> SELECT fcn does not work with an unset catalog or
jnh5y opened a new pull request, #23084:
URL: https://github.com/apache/flink/pull/23084
## What is the purpose of the change
This commit addresses FLINK-32691 by having function lookup skip looking for
functions in catalog / database specific locations when the catalog and/or
Jim Hughes created FLINK-32691:
--
Summary: SELECT fcn does not work with an unset catalog or database
Key: FLINK-32691
URL: https://issues.apache.org/jira/browse/FLINK-32691
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-32690?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-32690:
---
Labels: pull-request-available (was: )
> Report Double.NAN instead of null for missing
morhidi opened a new pull request, #639:
URL: https://github.com/apache/flink-kubernetes-operator/pull/639
## What is the purpose of the change
Change null values to Double.NAN for autoscaler metrics during blackout
periods when no data is gathered. This appears to be a more common
patricklucas commented on PR #22987:
URL: https://github.com/apache/flink/pull/22987#issuecomment-1652189416
Great, I'll get to this tomorrow, thanks for the reviews @XComp.
Regarding the commit organization, I'm happy to break out another hotfix
commit—wasn't sure if the branch
patricklucas commented on code in PR #22987:
URL: https://github.com/apache/flink/pull/22987#discussion_r1275249702
##
flink-runtime/src/test/java/org/apache/flink/runtime/rest/RestClientTest.java:
##
@@ -207,6 +218,120 @@ public void testRestClientClosedHandling() throws
Matyas Orhidi created FLINK-32690:
-
Summary: Report Double.NAN instead of null for missing autoscaler
metrics
Key: FLINK-32690
URL: https://issues.apache.org/jira/browse/FLINK-32690
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-31611?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matyas Orhidi reassigned FLINK-31611:
-
Assignee: (was: Matyas Orhidi)
> Add delayed restart to failed jobs
>
[
https://issues.apache.org/jira/browse/FLINK-32684?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-32684:
--
Description:
FLINK-32468 introduced Apache Pekko as an replacement for Akka. This involved
[
https://issues.apache.org/jira/browse/FLINK-32684?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-32684:
--
Description:
FLINK-32468 introduced Apache Pekko as an replacement for Akka. This involved
[
https://issues.apache.org/jira/browse/FLINK-32684?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-32684:
--
Description:
FLINK-32468 introduced Apache Pekko as an replacement for Akka. This involved
[
https://issues.apache.org/jira/browse/FLINK-32684?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-32684:
--
Description:
FLINK-32468 introduced Apache Pekko as an replacement for Akka. This involved
hanyuzheng7 commented on PR #22842:
URL: https://github.com/apache/flink/pull/22842#issuecomment-1652083503
@flinkbot run azure
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific
[
https://issues.apache.org/jira/browse/FLINK-32684?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17747575#comment-17747575
]
Chesnay Schepler commented on FLINK-32684:
--
Related to FLINK-14052.
> Renaming AkkaOptions
[
https://issues.apache.org/jira/browse/FLINK-32689?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17747559#comment-17747559
]
Timo Walther commented on FLINK-32689:
--
Update: I could confirm it with this program
{code}
[
https://issues.apache.org/jira/browse/FLINK-32689?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17747557#comment-17747557
]
Timo Walther commented on FLINK-32689:
--
[~leonard] Could you give more context why FLINK-22349 was
Timo Walther created FLINK-32689:
Summary: Insufficient validation for table.local-time-zone
Key: FLINK-32689
URL: https://issues.apache.org/jira/browse/FLINK-32689
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-32119?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora updated FLINK-32119:
---
Fix Version/s: (was: kubernetes-operator-1.6.0)
> Revise source partition skew logic
>
[
https://issues.apache.org/jira/browse/FLINK-31867?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora updated FLINK-31867:
---
Fix Version/s: (was: kubernetes-operator-1.6.0)
> Enforce a minimum number of observations
[
https://issues.apache.org/jira/browse/FLINK-32120?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora updated FLINK-32120:
---
Fix Version/s: (was: kubernetes-operator-1.6.0)
> Add autoscaler config option to disable
[
https://issues.apache.org/jira/browse/FLINK-31998?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora updated FLINK-31998:
---
Fix Version/s: (was: kubernetes-operator-1.6.0)
> Flink Operator Deadlock on run job Failure
>
[
https://issues.apache.org/jira/browse/FLINK-31400?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora updated FLINK-31400:
---
Fix Version/s: (was: kubernetes-operator-1.6.0)
> Add autoscaler integration for Iceberg source
[
https://issues.apache.org/jira/browse/FLINK-29281?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17747553#comment-17747553
]
Claude Warren commented on FLINK-29281:
---
Pekko v1.0.1 was just released.
[
https://issues.apache.org/jira/browse/FLINK-32687?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser closed FLINK-32687.
--
Resolution: Not A Problem
> Performance regression on
[
https://issues.apache.org/jira/browse/FLINK-32682?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dawid Wysakowicz reassigned FLINK-32682:
Assignee: Dawid Wysakowicz
> Introduce option for choosing time function
[
https://issues.apache.org/jira/browse/FLINK-32687?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17747539#comment-17747539
]
Martijn Visser commented on FLINK-32687:
[~huwh] Thanks for the explainer, let's close it then
flinkbot commented on PR #23083:
URL: https://github.com/apache/flink/pull/23083#issuecomment-1651874232
## CI report:
* 259010ae232c9677a1aff9d7c2103bb73c477db1 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
1 - 100 of 189 matches
Mail list logo
