1996fanrui commented on code in PR #23635:
URL: https://github.com/apache/flink/pull/23635#discussion_r1405313903
##
flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/TaskBalancedPreferredSlotSharingStrategyTest.java:
##
@@ -0,0 +1,248 @@
+/*
+ * Licensed to the
JingGe commented on code in PR #23807:
URL: https://github.com/apache/flink/pull/23807#discussion_r1405358365
##
docs/content.zh/docs/dev/datastream/fault-tolerance/checkpointing.md:
##
@@ -71,7 +74,13 @@ Checkpoint 其他的属性包括：
- *externalized checkpoints*: 你可以配置周期存储
JingGe commented on code in PR #23807:
URL: https://github.com/apache/flink/pull/23807#discussion_r1405358365
##
docs/content.zh/docs/dev/datastream/fault-tolerance/checkpointing.md:
##
@@ -71,7 +74,13 @@ Checkpoint 其他的属性包括：
- *externalized checkpoints*: 你可以配置周期存储
[
https://issues.apache.org/jira/browse/FLINK-33301?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jing Ge closed FLINK-33301.
---
Resolution: Won't Fix
> Add Java and Maven version checks in the bash script of Flink release process
>
RocMarshal created FLINK-33653:
--
Summary: Introduce a benchmark for balanced tasks scheduling
Key: FLINK-33653
URL: https://issues.apache.org/jira/browse/FLINK-33653
Project: Flink
Issue Type:
1996fanrui commented on code in PR #23807:
URL: https://github.com/apache/flink/pull/23807#discussion_r1405351938
##
docs/content.zh/docs/dev/datastream/fault-tolerance/checkpointing.md:
##
@@ -71,7 +74,13 @@ Checkpoint 其他的属性包括：
- *externalized checkpoints*: 你可以配置周期存储
1996fanrui commented on code in PR #23807:
URL: https://github.com/apache/flink/pull/23807#discussion_r1405361586
##
docs/content.zh/docs/dev/datastream/fault-tolerance/checkpointing.md:
##
@@ -71,7 +74,13 @@ Checkpoint 其他的属性包括：
- *externalized checkpoints*: 你可以配置周期存储
1996fanrui merged PR #23806:
URL: https://github.com/apache/flink/pull/23806
--
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:
1996fanrui commented on code in PR #23635:
URL: https://github.com/apache/flink/pull/23635#discussion_r1405352714
##
flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/TaskBalancedPreferredSlotSharingStrategyTest.java:
##
@@ -0,0 +1,248 @@
+/*
+ * Licensed to the
Pranav Sharma created FLINK-33652:
-
Summary: First Steps documentation is having empty page link
Key: FLINK-33652
URL: https://issues.apache.org/jira/browse/FLINK-33652
Project: Flink
Issue
snuyanzin commented on code in PR #23805:
URL: https://github.com/apache/flink/pull/23805#discussion_r1405381059
##
docs/content/docs/dev/table/functions/udfs.md:
##
@@ -227,6 +227,20 @@ env.from("MyTable").select(call(classOf[MyConcatFunction],
$"a", $"b", $"c"));
{{< /tab
surendralilhore commented on PR #23768:
URL: https://github.com/apache/flink/pull/23768#issuecomment-1826843398
There is one more Jira to fix this issue in better way :
[FLINK-33548](https://issues.apache.org/jira/browse/FLINK-33548)
--
This is an automated message from the Apache Git
surendralilhore closed pull request #23768: [FLINK-33609] Take into account the
resource limit specified in the pod template.
URL: https://github.com/apache/flink/pull/23768
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
JingGe merged PR #23807:
URL: https://github.com/apache/flink/pull/23807
--
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-33443?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17789859#comment-17789859
]
huiyang chi commented on FLINK-33443:
-
Hi Martijn : I can understand that currently this problem is
Sergey Nuyanzin created FLINK-33655:
---
Summary:
ScalaSerializersMigrationTest#testStableAnonymousClassnameGeneration fails with
jdk21
Key: FLINK-33655
URL: https://issues.apache.org/jira/browse/FLINK-33655
[
https://issues.apache.org/jira/browse/FLINK-33655?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin updated FLINK-33655:
Description:
ASM 9.5 (which has support for java 21[1]) came only with ArchUnit 1.1.0 [2]
[
https://issues.apache.org/jira/browse/FLINK-33655?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-33655:
---
Labels: pull-request-available (was: )
> Upgrade Archunit to 1.1.0+
>
snuyanzin opened a new pull request, #23808:
URL: https://github.com/apache/flink/pull/23808
## What is the purpose of the change
The minimum ArchUnit supporting java 21 is 1.1.0 so need to bump ArchUnit to
support java 21
## Verifying this change
This change is a
flinkbot commented on PR #23808:
URL: https://github.com/apache/flink/pull/23808#issuecomment-1826929519
## CI report:
* 2a21eee935d0b0d9db3195d3b2ac02d18e42e348 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
snuyanzin commented on code in PR #23786:
URL: https://github.com/apache/flink/pull/23786#discussion_r1405421318
##
flink-table/flink-sql-client/src/test/java/org/apache/flink/table/client/cli/CliTableauResultViewTest.java:
##
@@ -226,7 +222,7 @@ void testBatchResult() {
snuyanzin commented on code in PR #23786:
URL: https://github.com/apache/flink/pull/23786#discussion_r1405421199
##
flink-table/flink-sql-client/src/test/java/org/apache/flink/table/client/cli/CliTableauResultViewTest.java:
##
@@ -226,7 +222,7 @@ void testBatchResult() {
snuyanzin commented on code in PR #23786:
URL: https://github.com/apache/flink/pull/23786#discussion_r1405421199
##
flink-table/flink-sql-client/src/test/java/org/apache/flink/table/client/cli/CliTableauResultViewTest.java:
##
@@ -226,7 +222,7 @@ void testBatchResult() {
JingGe commented on PR #23786:
URL: https://github.com/apache/flink/pull/23786#issuecomment-1826828710
good catch! Thanks!
--
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.
JingGe merged PR #23805:
URL: https://github.com/apache/flink/pull/23805
--
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-33654?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jing Ge reassigned FLINK-33654:
---
Assignee: Jing Ge
> deprecate DummyStreamExecutionEnvironment
>
Jing Ge created FLINK-33654:
---
Summary: deprecate DummyStreamExecutionEnvironment
Key: FLINK-33654
URL: https://issues.apache.org/jira/browse/FLINK-33654
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-33609?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Surendra Singh Lilhore resolved FLINK-33609.
Resolution: Duplicate
There is one more Jira to fix this issue in better
snuyanzin commented on PR #23662:
URL: https://github.com/apache/flink/pull/23662#issuecomment-1826886015
Thanks for taking a look
--
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
JingGe commented on PR #23786:
URL: https://github.com/apache/flink/pull/23786#issuecomment-1826886399
Thanks @snuyanzin for the review!
--
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-33655?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin updated FLINK-33655:
Summary: Upgrade archunit to 1.1.0+ (was:
[
https://issues.apache.org/jira/browse/FLINK-33655?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin updated FLINK-33655:
Summary: Upgrade Archunit to 1.1.0+ (was: Upgrade archunit to 1.1.0+)
> Upgrade Archunit
JingGe commented on PR #23805:
URL: https://github.com/apache/flink/pull/23805#issuecomment-1826798523
@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.
snuyanzin commented on PR #23786:
URL: https://github.com/apache/flink/pull/23786#issuecomment-1826815890
Thanks for driving this
i would suggest to replace 2 more same occurrences e.g. at
[
https://issues.apache.org/jira/browse/FLINK-33651?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jing Ge resolved FLINK-33651.
-
Resolution: Fixed
> Update the Chinese version checkpointing doc in fault tolerance
>
[
https://issues.apache.org/jira/browse/FLINK-33651?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17789845#comment-17789845
]
Jing Ge commented on FLINK-33651:
-
master: db0403c3f39ccd60f0c0a59f12caa63c521e1d17
> Update the
[
https://issues.apache.org/jira/browse/FLINK-33655?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin updated FLINK-33655:
Description:
ASM 9.5 (which has support for java 21[1]) came only with ArchUnit 1.1.0 [2]
JingGe commented on PR #23805:
URL: https://github.com/apache/flink/pull/23805#issuecomment-1826797827
Thanks @snuyanzin for the review!
--
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-33457?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin closed FLINK-33457.
---
> FlinkImageBuilder checks for Java 21
>
>
>
snuyanzin merged PR #23662:
URL: https://github.com/apache/flink/pull/23662
--
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-33457?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin resolved FLINK-33457.
-
Fix Version/s: 1.19.0
Resolution: Fixed
> FlinkImageBuilder checks for Java 21
>
[
https://issues.apache.org/jira/browse/FLINK-33457?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17789844#comment-17789844
]
Sergey Nuyanzin commented on FLINK-33457:
-
Merged to master as
JingGe commented on code in PR #23807:
URL: https://github.com/apache/flink/pull/23807#discussion_r1405404799
##
docs/content.zh/docs/dev/datastream/fault-tolerance/checkpointing.md:
##
@@ -71,7 +74,13 @@ Checkpoint 其他的属性包括：
- *externalized checkpoints*: 你可以配置周期存储
1996fanrui commented on PR #23807:
URL: https://github.com/apache/flink/pull/23807#issuecomment-1826810102
Hey @JingGe , would you mind squashing all commits in advance? Or squash and
merge it is fine.
--
This is an automated message from the Apache Git Service.
To respond to the
snuyanzin commented on code in PR #23786:
URL: https://github.com/apache/flink/pull/23786#discussion_r1405469301
##
flink-table/flink-sql-client/src/test/java/org/apache/flink/table/client/cli/CliTableauResultViewTest.java:
##
@@ -240,6 +232,16 @@ void testBatchResult() {
[
https://issues.apache.org/jira/browse/FLINK-33655?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin updated FLINK-33655:
Description:
ASM 9.5 (which has support for java 21) came only with ArchUnit 1.1.0
With
[
https://issues.apache.org/jira/browse/FLINK-32667?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17789941#comment-17789941
]
Yangze Guo commented on FLINK-32667:
FYI, since FLINK-33033 has been merged and proves the benefit
JingGe opened a new pull request, #23809:
URL: https://github.com/apache/flink/pull/23809
## What is the purpose of the change
print the query time cost for batch query in cli
## Brief change log
- define new table config to swtich the display the query time cost
[
https://issues.apache.org/jira/browse/FLINK-33643?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weihua Hu reassigned FLINK-33643:
-
Assignee: Matt Wang (was: Weihua Hu)
> Allow StreamExecutionEnvironment's executeAsync API to
[
https://issues.apache.org/jira/browse/FLINK-33638?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17789889#comment-17789889
]
Yubin Li commented on FLINK-33638:
--
[~lincoln] thanks very much!
> Support variable-length data
masteryhx commented on code in PR #21635:
URL: https://github.com/apache/flink/pull/21635#discussion_r1405573786
##
flink-core/src/main/java/org/apache/flink/api/common/typeutils/CompositeTypeSerializerUtil.java:
##
@@ -34,21 +34,21 @@ public class CompositeTypeSerializerUtil {
KarmaGYZ commented on code in PR #23635:
URL: https://github.com/apache/flink/pull/23635#discussion_r1405582679
##
flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/TaskBalancedPreferredSlotSharingStrategyTest.java:
##
@@ -0,0 +1,115 @@
+/*
+ * Licensed to the
[
https://issues.apache.org/jira/browse/FLINK-27681?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17789903#comment-17789903
]
Hangxiang Yu commented on FLINK-27681:
--
[~pnowojski] [~fanrui] Thanks for joining in the
JingGe merged PR #23799:
URL: https://github.com/apache/flink/pull/23799
--
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-33600?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-33600:
---
Labels: pull-request-available (was: )
> Print cost time for batch queries in SQL Client
>
flinkbot commented on PR #23809:
URL: https://github.com/apache/flink/pull/23809#issuecomment-1827310156
## CI report:
* 20ebdff8ebda287f1640c770a3bbe164a29f2be8 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-32667?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yangze Guo reassigned FLINK-32667:
--
Assignee: Yangze Guo (was: Fang Yong)
> Use standalone store and embedding writer for jobs
masteryhx commented on PR #21635:
URL: https://github.com/apache/flink/pull/21635#issuecomment-1827061892
> Thanks @masteryhx for the contribution!
>
> I didn't finish the review, and left some minor comments. Please take a
look in your free time, thanks~
Thanks a lot for your
mayuehappy commented on code in PR #23765:
URL: https://github.com/apache/flink/pull/23765#discussion_r1405583287
##
flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/snapshot/RocksIncrementalSnapshotStrategy.java:
##
@@
[
https://issues.apache.org/jira/browse/FLINK-27681?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17789903#comment-17789903
]
Hangxiang Yu edited comment on FLINK-27681 at 11/27/23 4:33 AM:
[
https://issues.apache.org/jira/browse/FLINK-33656?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
duke updated FLINK-33656:
-
Attachment: image-2023-11-27-14-00-04-672.png
> If json.ignose-parse-errors =true is configured and Array
[
https://issues.apache.org/jira/browse/FLINK-33656?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
duke updated FLINK-33656:
-
Attachment: image-2023-11-27-14-00-41-176.png
> If json.ignose-parse-errors =true is configured and Array
[
https://issues.apache.org/jira/browse/FLINK-33656?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
duke updated FLINK-33656:
-
Attachment: image-2023-11-27-13-59-42-066.png
> If json.ignose-parse-errors =true is configured and Array
JingGe merged PR #23786:
URL: https://github.com/apache/flink/pull/23786
--
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-27681?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17789892#comment-17789892
]
Yue Ma commented on FLINK-27681:
Hi [~pnowojski] and [~fanrui] , thanks for your repiles.
{quote}If
masteryhx commented on code in PR #23253:
URL: https://github.com/apache/flink/pull/23253#discussion_r1403926743
##
flink-clients/src/main/java/org/apache/flink/client/cli/CliFrontendParser.java:
##
@@ -157,6 +157,14 @@ public class CliFrontendParser {
[
https://issues.apache.org/jira/browse/FLINK-33656?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
duke updated FLINK-33656:
-
Description: Flink SQL If json.ignose-parse-errors =true is configured and
Array parsing errors occur, other
[
https://issues.apache.org/jira/browse/FLINK-33656?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
duke updated FLINK-33656:
-
Attachment: image-2023-11-27-13-58-22-513.png
> If json.ignose-parse-errors =true is configured and Array
snuyanzin commented on PR #76:
URL:
https://github.com/apache/flink-connector-jdbc/pull/76#issuecomment-1826937228
ok, let's merge it
--
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
huwh commented on code in PR #23794:
URL: https://github.com/apache/flink/pull/23794#discussion_r1405565272
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment/StreamExecutionEnvironment.java:
##
@@ -2213,12 +2211,24 @@ public final JobClient
[
https://issues.apache.org/jira/browse/FLINK-33656?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
duke updated FLINK-33656:
-
Attachment: image-2023-11-27-14-01-12-187.png
> If json.ignose-parse-errors =true is configured and Array
KarmaGYZ commented on code in PR #23635:
URL: https://github.com/apache/flink/pull/23635#discussion_r1405582679
##
flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/TaskBalancedPreferredSlotSharingStrategyTest.java:
##
@@ -0,0 +1,115 @@
+/*
+ * Licensed to the
snuyanzin merged PR #76:
URL: https://github.com/apache/flink-connector-jdbc/pull/76
--
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-33378?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin updated FLINK-33378:
Summary: Prepare actions for flink version 1.18 (was: Bump flink version
on
[
https://issues.apache.org/jira/browse/FLINK-33378?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin resolved FLINK-33378.
-
Fix Version/s: jdbc-3.2.0
Resolution: Fixed
> Prepare actions for flink version
[
https://issues.apache.org/jira/browse/FLINK-33378?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17789866#comment-17789866
]
Sergey Nuyanzin commented on FLINK-33378:
-
Merged as
[
https://issues.apache.org/jira/browse/FLINK-33643?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weihua Hu reassigned FLINK-33643:
-
Assignee: Weihua Hu
> Allow StreamExecutionEnvironment's executeAsync API to use default
[
https://issues.apache.org/jira/browse/FLINK-31275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17789890#comment-17789890
]
Fang Yong commented on FLINK-31275:
---
[~mobuchowski] Sorry for the late reply.
What does the `DataSet`
xiangforever2014 commented on PR #23253:
URL: https://github.com/apache/flink/pull/23253#issuecomment-1827056077
@masteryhx hope to get your reply, many thanks~
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
[
https://issues.apache.org/jira/browse/FLINK-31449?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weihua Hu reassigned FLINK-31449:
-
Assignee: Weihua Hu
> Remove DeclarativeSlotManager related logic
>
duke created FLINK-33656:
Summary: If json.ignose-parse-errors =true is configured and Array
parsing errors occur, other columns will be empty
Key: FLINK-33656
URL: https://issues.apache.org/jira/browse/FLINK-33656
[
https://issues.apache.org/jira/browse/FLINK-33656?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
duke updated FLINK-33656:
-
Description:
If json.ignore-parse-errors is set to true and Array parsing errors occur, the
fields following
[
https://issues.apache.org/jira/browse/FLINK-33656?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
duke updated FLINK-33656:
-
Attachment: image-2023-11-27-14-02-01-252.png
> If json.ignose-parse-errors =true is configured and Array
[
https://issues.apache.org/jira/browse/FLINK-33656?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
duke updated FLINK-33656:
-
Attachment: image-2023-11-27-14-02-30-666.png
> If json.ignose-parse-errors =true is configured and Array
[
https://issues.apache.org/jira/browse/FLINK-33656?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
duke updated FLINK-33656:
-
Attachment: image-2023-11-27-14-02-52-065.png
> If json.ignose-parse-errors =true is configured and Array
[
https://issues.apache.org/jira/browse/FLINK-33656?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
duke updated FLINK-33656:
-
Attachment: image-2023-11-27-14-03-10-885.png
> If json.ignose-parse-errors =true is configured and Array
86 matches
Mail list logo
