dannycranmer merged PR #23840:
URL: https://github.com/apache/flink/pull/23840
--
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:
dannycranmer merged PR #23841:
URL: https://github.com/apache/flink/pull/23841
--
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:
dannycranmer merged PR #23839:
URL: https://github.com/apache/flink/pull/23839
--
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:
luoyuxia commented on PR #5:
URL:
https://github.com/apache/flink-connector-hive/pull/5#issuecomment-1842010718
@snuyanzin Hi, I also found some
pages(https://nightlies.apache.org/flink/flink-docs-master/docs/dev/table/hive-compatibility/hive-dialect/overview/
,
[
https://issues.apache.org/jira/browse/FLINK-24819?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Tang resolved FLINK-24819.
--
Resolution: Fixed
> Higher APIServer cpu load after using SharedIndexInformer replaced naked
>
[
https://issues.apache.org/jira/browse/FLINK-24819?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Tang updated FLINK-24819:
-
Fix Version/s: 1.19.0
1.18.1
1.17.3
> Higher APIServer cpu load
[
https://issues.apache.org/jira/browse/FLINK-32028?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17793492#comment-17793492
]
Weijie Guo commented on FLINK-32028:
Thanks for taking this, I will take a look at this PR.
> Error
[
https://issues.apache.org/jira/browse/FLINK-32028?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo reassigned FLINK-32028:
--
Assignee: Peter Schulz
> Error handling for the new Elasticsearch sink
>
tweise commented on PR #18304:
URL: https://github.com/apache/flink/pull/18304#issuecomment-1842026548
@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.
tweise commented on PR #18304:
URL: https://github.com/apache/flink/pull/18304#issuecomment-1842032773
@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.
zhengzhili333 opened a new pull request, #23880:
URL: https://github.com/apache/flink/pull/23880
## What is the purpose of the change
*Currently, submitting a job starts with storing the JobGraph (in HA setups)
in the JobGraphStore. This includes writing the file to S3 (or some other
WencongLiu commented on PR #23863:
URL: https://github.com/apache/flink/pull/23863#issuecomment-1842037511
> Thanks for the update, I'm + 1 for this one. Could you please also align
commit message with the title of this PR.
Done.
--
This is an automated message from the Apache Git
JunRuiLee commented on PR #23848:
URL: https://github.com/apache/flink/pull/23848#issuecomment-1842040305
Hi @zhuzhurk , thanks for your feedback. I have updated the pull request
based on your comments. Please take a look when you have a moment.
--
This is an automated message from the
flinkbot commented on PR #23880:
URL: https://github.com/apache/flink/pull/23880#issuecomment-1842042843
## CI report:
* db9949a710f0dcf6d317053732a0e96b75568944 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-25857?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo reopened FLINK-25857:
Re-open this per discuss in mail-list.
> Add committer metrics to track the status of committables
>
[
https://issues.apache.org/jira/browse/FLINK-27291?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17793496#comment-17793496
]
韩宏旭 commented on FLINK-27291:
-
Hey Chengkai Yang,Cason
I am experienced in flink. I have seen this issue is
[ https://issues.apache.org/jira/browse/FLINK-27291 ]
韩宏旭 deleted comment on FLINK-27291:
-
was (Author: maomao):
Hey Chengkai Yang,Cason
I am experienced in flink. I have seen this issue is created at 18/Apr/22 19:51
and Updated at 27/Mar/23 11:34.
[
https://issues.apache.org/jira/browse/FLINK-27291?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17793497#comment-17793497
]
hongxu han commented on FLINK-27291:
Hey Chengkai Yang,Cason
I am experienced in flink. I have seen
[ https://issues.apache.org/jira/browse/FLINK-27291 ]
hongxu han deleted comment on FLINK-27291:
was (Author: maomao):
Hey Chengkai Yang,Cason
I am experienced in flink. I have seen this issue is created at 18/Apr/22 19:51
and Updated at
tweise commented on PR #18304:
URL: https://github.com/apache/flink/pull/18304#issuecomment-1841618310
@cuibo01 @MartijnVisser I just run into this issue (Flink 1.17) and was
happy to find this PR. Any reason this stalled? Can I help get this to the
finish line?
--
This is an automated
Jim Hughes created FLINK-33757:
--
Summary: Implement restore tests for Rank node
Key: FLINK-33757
URL: https://issues.apache.org/jira/browse/FLINK-33757
Project: Flink
Issue Type: Sub-task
jnh5y opened a new pull request, #23878:
URL: https://github.com/apache/flink/pull/23878
## What is the purpose of the change
Implement restore tests for Rank node
## Verifying this change
This change added tests and can be verified as follows:
* Added restore
[
https://issues.apache.org/jira/browse/FLINK-33724?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiaxing Chen closed FLINK-33724.
Resolution: Done
> Application mode doesn't support multiple lines argument
>
[
https://issues.apache.org/jira/browse/FLINK-33724?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17793478#comment-17793478
]
Jiaxing Chen commented on FLINK-33724:
--
Noticed that this issue has been mentioned in FLIP-366，and
[
https://issues.apache.org/jira/browse/FLINK-25593?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia updated FLINK-25593:
-
Fix Version/s: 1.19.0
> A redundant scan could be skipped if it is an input of join and the other
>
[
https://issues.apache.org/jira/browse/FLINK-25593?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia reopened FLINK-25593:
--
> A redundant scan could be skipped if it is an input of join and the other
> input is empty after
[
https://issues.apache.org/jira/browse/FLINK-25593?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia closed FLINK-25593.
Resolution: Fixed
> A redundant scan could be skipped if it is an input of join and the other
> input is
swuferhong commented on code in PR #23828:
URL: https://github.com/apache/flink/pull/23828#discussion_r1416555940
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/rules/physical/batch/PushLocalSortAggWithSortAndCalcIntoScanRule.java:
##
@@
swuferhong commented on code in PR #23828:
URL: https://github.com/apache/flink/pull/23828#discussion_r1416564050
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/rules/physical/batch/PushLocalSortAggWithCalcIntoScanRule.java:
##
@@ -74,9
zhuzhurk commented on code in PR #23848:
URL: https://github.com/apache/flink/pull/23848#discussion_r1416568345
##
flink-core/src/main/java/org/apache/flink/api/common/functions/util/AbstractRuntimeUDFContext.java:
##
@@ -83,10 +86,27 @@ public AbstractRuntimeUDFContext(
}
zhuzhurk commented on code in PR #23848:
URL: https://github.com/apache/flink/pull/23848#discussion_r1416568345
##
flink-core/src/main/java/org/apache/flink/api/common/functions/util/AbstractRuntimeUDFContext.java:
##
@@ -83,10 +86,27 @@ public AbstractRuntimeUDFContext(
}
fsk119 commented on code in PR #23868:
URL: https://github.com/apache/flink/pull/23868#discussion_r1416572012
##
flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/cli/CliTableauResultView.java:
##
@@ -114,6 +108,30 @@ public void displayResults() throws
swuferhong commented on code in PR #23828:
URL: https://github.com/apache/flink/pull/23828#discussion_r1416573713
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/rules/physical/batch/PushLocalSortAggWithSortAndCalcIntoScanRule.java:
##
@@
tweise commented on PR #18304:
URL: https://github.com/apache/flink/pull/18304#issuecomment-1841996519
@cuibo01 thanks, I resolved conflicts and pushed the merge for testing -
will do a rebase after we see tests pass.
--
This is an automated message from the Apache Git Service.
To
zoudan commented on code in PR #23849:
URL: https://github.com/apache/flink/pull/23849#discussion_r1416588553
##
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/internal/ResultProvider.java:
##
@@ -59,4 +59,7 @@ public interface ResultProvider {
zoudan commented on code in PR #23849:
URL: https://github.com/apache/flink/pull/23849#discussion_r1416588553
##
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/internal/ResultProvider.java:
##
@@ -59,4 +59,7 @@ public interface ResultProvider {
1996fanrui commented on code in PR #721:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/721#discussion_r1416590912
##
flink-kubernetes-operator/src/test/java/org/apache/flink/kubernetes/operator/autoscaler/KubernetesScalingRealizerTest.java:
##
@@ -30,12 +31,23
[
https://issues.apache.org/jira/browse/FLINK-31659?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia closed FLINK-31659.
Fix Version/s: 1.18.0
Resolution: Invalid
Should be fixed after
luoyuxia commented on code in PR #5:
URL:
https://github.com/apache/flink-connector-hive/pull/5#discussion_r1416565534
##
flink-connector-hive/src/test/java/org/apache/flink/connectors/hive/HiveTableSinkITCase.java:
##
@@ -0,0 +1,1000 @@
+/*
+ * Licensed to the Apache Software
[
https://issues.apache.org/jira/browse/FLINK-27681?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17793488#comment-17793488
]
Yue Ma commented on FLINK-27681:
[~masteryhx] [~pnowojski] [~fanrui] Thanks for the discussion
So,
Jim Hughes created FLINK-33758:
--
Summary: Implement restore tests for TemporalSort node
Key: FLINK-33758
URL: https://issues.apache.org/jira/browse/FLINK-33758
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-33758?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jim Hughes reassigned FLINK-33758:
--
Assignee: Jim Hughes
> Implement restore tests for TemporalSort node
>
jnh5y opened a new pull request, #23879:
URL: https://github.com/apache/flink/pull/23879
## What is the purpose of the change
Implement restore tests for TemporalSort node
## Verifying this change
This change added tests and can be verified as follows:
* Added
[
https://issues.apache.org/jira/browse/FLINK-33758?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-33758:
---
Labels: pull-request-available (was: )
> Implement restore tests for TemporalSort node
>
cuibo01 commented on PR #18304:
URL: https://github.com/apache/flink/pull/18304#issuecomment-1841927134
@tweise , Of course you can, thx
--
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
flinkbot commented on PR #23879:
URL: https://github.com/apache/flink/pull/23879#issuecomment-1841777502
## CI report:
* 3a3ae47704eb419e33eb8ffc643c83f83befcb43 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-33545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17793457#comment-17793457
]
Mason Chen commented on FLINK-33545:
The reason why you don't find any synchronization is because
[
https://issues.apache.org/jira/browse/FLINK-33545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17793457#comment-17793457
]
Mason Chen edited comment on FLINK-33545 at 12/5/23 11:40 PM:
--
The reason
zhengzhili333 closed pull request #23866: [FLINK-33500][Runtime] Run storing
the JobGraph an asynchronous operation
URL: https://github.com/apache/flink/pull/23866
--
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-33734?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17793505#comment-17793505
]
Zakelly Lan commented on FLINK-33734:
-
hi [~Feifan Wang] ,
I'm wondering if this proposal aims
1996fanrui merged PR #23873:
URL: https://github.com/apache/flink/pull/23873
--
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-33759?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Cai Liuyang updated FLINK-33759:
Description: When we use flink-parquet format wirte Map[]
type (which will be read by spark job),
Cai Liuyang created FLINK-33759:
---
Summary: flink parquet writer support write nested array or map
type
Key: FLINK-33759
URL: https://issues.apache.org/jira/browse/FLINK-33759
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-33759?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Cai Liuyang updated FLINK-33759:
Description:
When we use flink-parquet format wirte Map[] type (which will
be read by spark
[
https://issues.apache.org/jira/browse/FLINK-33759?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Cai Liuyang updated FLINK-33759:
Description:
When we use flink-parquet format wirte Map[] type (which will
be read by spark
[
https://issues.apache.org/jira/browse/FLINK-33759?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Cai Liuyang updated FLINK-33759:
Description:
When we use flink-parquet format wirte Map[] type (which will
be read by spark
[
https://issues.apache.org/jira/browse/FLINK-33752?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17793517#comment-17793517
]
Rui Fan commented on FLINK-33752:
-
Merged to
master<1.19> via: 9b61b137bdc7eff773847b84e5cde116e6280c1d
[
https://issues.apache.org/jira/browse/FLINK-33752?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan resolved FLINK-33752.
-
Resolution: Fixed
> When Duration is greater than or equal to 1 day, the display unit is ms.
>
[
https://issues.apache.org/jira/browse/FLINK-33759?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Cai Liuyang updated FLINK-33759:
Description:
When we use flink-parquet format wirte Map[] type (which will
be read by spark
caodizhou commented on PR #23842:
URL: https://github.com/apache/flink/pull/23842#issuecomment-1842126287
@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
LoveHeat opened a new pull request, #23881:
URL: https://github.com/apache/flink/pull/23881
## What is the purpose of the change
see: [FLINK-33759](https://issues.apache.org/jira/browse/FLINK-33759)
## Brief change log
*(for example:)*
- *The TaskInfo is
[
https://issues.apache.org/jira/browse/FLINK-33759?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-33759:
---
Labels: pull-request-available (was: )
> flink parquet writer support write nested array
flinkbot commented on PR #23881:
URL: https://github.com/apache/flink/pull/23881#issuecomment-1842150254
## CI report:
* beeb17b4d54d2c2ed0ea61df6e07892bc792e2e0 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
xuyang created FLINK-33760:
--
Summary: Group Window agg has different result when only consuming
-D records while using or not using minibatch
Key: FLINK-33760
URL: https://issues.apache.org/jira/browse/FLINK-33760
jeyhunkarimov commented on PR #23877:
URL: https://github.com/apache/flink/pull/23877#issuecomment-1842153994
Hi @twalthr could you please review this PR?
--
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
swuferhong opened a new pull request, #23882:
URL: https://github.com/apache/flink/pull/23882
## What is the purpose of the change
When reading the code about json format, I found the test classes
`JsonRowDeserializationSchemaTest` and `JsonRowSerializationSchemaTest`
flinkbot commented on PR #23882:
URL: https://github.com/apache/flink/pull/23882#issuecomment-1842175348
## CI report:
* bf391fd5e7547df3e574138b264cb7802f150c62 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
tweise commented on PR #18304:
URL: https://github.com/apache/flink/pull/18304#issuecomment-1842179446
@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.
xiangforever2014 commented on code in PR #23253:
URL: https://github.com/apache/flink/pull/23253#discussion_r1416745308
##
flink-clients/src/main/java/org/apache/flink/client/program/ClusterClient.java:
##
@@ -188,6 +207,21 @@ CompletableFuture triggerSavepoint(
*/
xiangforever2014 commented on PR #23253:
URL: https://github.com/apache/flink/pull/23253#issuecomment-1842188948
> Hi @xiangforever2014 @masteryhx sorry for jumping in... And I'm wondering
if we could use the capital '-D' for short option? Or I suggest we do not leave
any short option for
zhengzhili333 commented on PR #23866:
URL: https://github.com/apache/flink/pull/23866#issuecomment-1840210958
@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-33663?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dawid Wysakowicz closed FLINK-33663.
Resolution: Implemented
Implemented in bc6c2cec37c45f021ae22a2a7b5ab9537b8506cd
>
masteryhx commented on code in PR #23253:
URL: https://github.com/apache/flink/pull/23253#discussion_r1415222035
##
docs/content.zh/docs/deployment/cli.md:
##
@@ -125,6 +125,43 @@ Lastly, you can optionally provide what should be the
[binary format]({{< ref "d
The path to
gaborgsomogyi commented on PR #23865:
URL: https://github.com/apache/flink/pull/23865#issuecomment-1840452321
Thanks for the explanation!
> In terms of the source / binary compatibility, the main reason we do not
provide binary compatibility in minor releases for any API stability
[
https://issues.apache.org/jira/browse/FLINK-33751?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
shuaiqi.guo updated FLINK-33751:
Attachment: FLINK-33751.patch
> use modules correctly when deserializing json plan
>
shuaiqi.guo created FLINK-33751:
---
Summary: use modules correctly when deserializing json plan
Key: FLINK-33751
URL: https://issues.apache.org/jira/browse/FLINK-33751
Project: Flink
Issue Type:
WencongLiu commented on code in PR #23863:
URL: https://github.com/apache/flink/pull/23863#discussion_r1415495161
##
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/tier/disk/DiskTierProducerAgent.java:
##
@@ -223,9 +228,16 @@ private
zoudan commented on code in PR #23849:
URL: https://github.com/apache/flink/pull/23849#discussion_r1415242114
##
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/internal/ResultProvider.java:
##
@@ -59,4 +59,7 @@ public interface ResultProvider {
zhuzhurk closed pull request #23847: [FLINK-33669][doc] Update the
documentation for RestartStrategy, Checkpoint Storage, and State Backend.
URL: https://github.com/apache/flink/pull/23847
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on
[
https://issues.apache.org/jira/browse/FLINK-33669?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu closed FLINK-33669.
---
Fix Version/s: 1.19.0
Resolution: Done
master:
e27f8a3a0783d551457a2f424b01267bd1c8c2c2
JingGe commented on PR #23859:
URL: https://github.com/apache/flink/pull/23859#issuecomment-1840309252
@PatrickRen Thanks for the review. I have address your suggestion and add
1.16.x column back. Would you please check it again?
--
This is an automated message from the Apache Git
[
https://issues.apache.org/jira/browse/FLINK-33670?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17793232#comment-17793232
]
Jeyhun Karimov commented on FLINK-33670:
Hi [~zicat] I tried with Flink master branch, below is
Prabhu Joseph created FLINK-33753:
-
Summary: ContinuousFileReaderOperator consume records as mini batch
Key: FLINK-33753
URL: https://issues.apache.org/jira/browse/FLINK-33753
Project: Flink
Rui Fan created FLINK-33752:
---
Summary: When Duration is greater than or equal to 1 day, the
display unit is ms.
Key: FLINK-33752
URL: https://issues.apache.org/jira/browse/FLINK-33752
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-33752?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan updated FLINK-33752:
Description:
When the default value of Duration is 24 hours or 1 day, the display unit is
ms. (8640
gyfora commented on PR #23872:
URL: https://github.com/apache/flink/pull/23872#issuecomment-1840282229
I understand that this may be confusing for you but unfortunately we cannot
merge this PR in this form. Let's work on the operator side to solve this
properly as seen in the linked lira
dawidwys merged PR #23811:
URL: https://github.com/apache/flink/pull/23811
--
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-28229?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-28229.
Fix Version/s: 1.19.0
Resolution: Fixed
master:
WencongLiu commented on code in PR #23863:
URL: https://github.com/apache/flink/pull/23863#discussion_r1415504026
##
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/tier/disk/DiskTierProducerAgent.java:
##
@@ -223,9 +228,16 @@ private
[
https://issues.apache.org/jira/browse/FLINK-27681?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17793189#comment-17793189
]
Hangxiang Yu commented on FLINK-27681:
--
Sorry for the late reply.
{quote}However, the job must
Sucran commented on PR #23872:
URL: https://github.com/apache/flink/pull/23872#issuecomment-1840275371
> -1 from my side based on previous community discussion:
>
> Please see the discussion in
https://lists.apache.org/thread/6p5tk6obmk1qxf169so498z4vk8cg969 and the
ticket:
masteryhx commented on code in PR #23253:
URL: https://github.com/apache/flink/pull/23253#discussion_r1415217180
##
flink-clients/src/main/java/org/apache/flink/client/cli/CliFrontendParser.java:
##
@@ -157,6 +157,14 @@ public class CliFrontendParser {
zentol merged PR #23558:
URL: https://github.com/apache/flink/pull/23558
--
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:
libenchao commented on PR #23779:
URL: https://github.com/apache/flink/pull/23779#issuecomment-1840508653
@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-33752?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-33752:
---
Labels: pull-request-available (was: )
> When Duration is greater than or equal to 1 day,
[
https://issues.apache.org/jira/browse/FLINK-8?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17793246#comment-17793246
]
Yanfei Lei commented on FLINK-8:
[~mayuehappy]/[~pnowojski] Some updates:
I first released a
flinkbot commented on PR #23873:
URL: https://github.com/apache/flink/pull/23873#issuecomment-1840670193
## CI report:
* 3bbbddd74077c28f009567d49f99e6277223c03b UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
jeyhunkarimov commented on PR #23586:
URL: https://github.com/apache/flink/pull/23586#issuecomment-1840305544
Does it make any difference? yes and no IMHO.
Yes, because imagine `test1()` executes the statement
`createTemporarySystemFunction("add", new TestAddWithOpen)` (also
Zakelly commented on code in PR #23514:
URL: https://github.com/apache/flink/pull/23514#discussion_r1415294769
##
flink-runtime/src/main/java/org/apache/flink/runtime/state/filesystem/FileMergingCheckpointStateOutputStream.java:
##
@@ -0,0 +1,255 @@
+/*
+ * Licensed to the
Zakelly commented on PR #23514:
URL: https://github.com/apache/flink/pull/23514#issuecomment-1840444858
> Thanks @fredia and @Zakelly for your comments. Sorry for the late reply. I
have addressed your comments. Would you please take another look?
Thanks for your effort. I have no
1 - 100 of 185 matches
Mail list logo
