Aitozi created FLINK-24624:
--
Summary: Add clean up phase when kubernetes session start failed
Key: FLINK-24624
URL: https://issues.apache.org/jira/browse/FLINK-24624
Project: Flink
Issue Type: Impro
Aitozi created FLINK-24625:
--
Summary: Expose the required kubernetes permission from the shell
command
Key: FLINK-24625
URL: https://issues.apache.org/jira/browse/FLINK-24625
Project: Flink
Issue T
fsk119 commented on a change in pull request #17537:
URL: https://github.com/apache/flink/pull/17537#discussion_r735066347
##
File path:
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/common/CommonExecTableSourceScan.java
##
@@ -97
echauchot commented on pull request #17501:
URL: https://github.com/apache/flink/pull/17501#issuecomment-950315970
R:@echauchot
@JingGe thanks a lot for your work ! If I may, I'd like to review this PR as
I was the author of the `ParquetAvroInputFormat` for the older source.
--
This i
[
https://issues.apache.org/jira/browse/FLINK-24597?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17433432#comment-17433432
]
Congxian Qiu commented on FLINK-24597:
--
[~mayuehappy] thanks for reporting this iss
[
https://issues.apache.org/jira/browse/FLINK-23346?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17433434#comment-17433434
]
Congxian Qiu commented on FLINK-23346:
--
[~yunta] sorry for the late reply. we don't
lindong28 opened a new pull request #19:
URL: https://github.com/apache/flink-ml/pull/19
This PR removes the infra whose purpose, API and usage needs to be revisited.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use th
[
https://issues.apache.org/jira/browse/FLINK-24489?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17432915#comment-17432915
]
Yuepeng Pan edited comment on FLINK-24489 at 10/24/21, 2:04 PM:
--
RocMarshal opened a new pull request #17553:
URL: https://github.com/apache/flink/pull/17553
## 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 them
flinkbot commented on pull request #17553:
URL: https://github.com/apache/flink/pull/17553#issuecomment-950337501
## CI report:
* 078605c69cb264c9e212312b559f6fc2ec2f3114 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot r
flinkbot edited a comment on pull request #17553:
URL: https://github.com/apache/flink/pull/17553#issuecomment-950337501
## CI report:
* 078605c69cb264c9e212312b559f6fc2ec2f3114 Azure:
[PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot commented on pull request #17553:
URL: https://github.com/apache/flink/pull/17553#issuecomment-950337872
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review your pull request. We will use this comment to track the pro
RocMarshal commented on pull request #17553:
URL: https://github.com/apache/flink/pull/17553#issuecomment-950337942
@dianfu Could you help me to check it ? Thank you very much.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub
flinkbot edited a comment on pull request #17553:
URL: https://github.com/apache/flink/pull/17553#issuecomment-950337501
## CI report:
* 078605c69cb264c9e212312b559f6fc2ec2f3114 Azure:
[PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
RocMarshal edited a comment on pull request #17463:
URL: https://github.com/apache/flink/pull/17463#issuecomment-944947844
Hi, @klion26 , here is a minor typo. Would you like to help me to check it
? Thank you very much.
--
This is an automated message from the Apache Git Service.
To re
flinkbot edited a comment on pull request #17553:
URL: https://github.com/apache/flink/pull/17553#issuecomment-950337501
## CI report:
* 078605c69cb264c9e212312b559f6fc2ec2f3114 Azure:
[PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #17553:
URL: https://github.com/apache/flink/pull/17553#issuecomment-950337501
## CI report:
* 078605c69cb264c9e212312b559f6fc2ec2f3114 Azure:
[CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
flinkbot edited a comment on pull request #17553:
URL: https://github.com/apache/flink/pull/17553#issuecomment-950337501
## CI report:
* 078605c69cb264c9e212312b559f6fc2ec2f3114 Azure:
[CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
gaoyunhaii commented on pull request #5:
URL: https://github.com/apache/flink-ml/pull/5#issuecomment-950339981
Very thanks @guoweiM for the review! I updated the PR to fix the inline
comments.
Regarding the style of the api: during the discussion we indeed have another
possible opti
gaoyunhaii commented on a change in pull request #6:
URL: https://github.com/apache/flink-ml/pull/6#discussion_r735131743
##
File path:
flink-ml-iteration/src/main/java/org/apache/flink/iteration/broadcast/ChainingBroadcastOutput.java
##
@@ -0,0 +1,43 @@
+/*
+ * Licensed to th
gaoyunhaii commented on a change in pull request #6:
URL: https://github.com/apache/flink-ml/pull/6#discussion_r735131924
##
File path:
flink-ml-iteration/src/main/java/org/apache/flink/iteration/broadcast/ChainingBroadcastOutput.java
##
@@ -0,0 +1,43 @@
+/*
+ * Licensed to th
flinkbot edited a comment on pull request #17553:
URL: https://github.com/apache/flink/pull/17553#issuecomment-950337501
## CI report:
* 078605c69cb264c9e212312b559f6fc2ec2f3114 Azure:
[CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
gaoyunhaii commented on a change in pull request #6:
URL: https://github.com/apache/flink-ml/pull/6#discussion_r735132139
##
File path:
flink-ml-iteration/src/main/java/org/apache/flink/iteration/broadcast/CountingBroadcastOutput.java
##
@@ -0,0 +1,50 @@
+/*
+ * Licensed to th
flinkbot edited a comment on pull request #17553:
URL: https://github.com/apache/flink/pull/17553#issuecomment-950337501
## CI report:
* 078605c69cb264c9e212312b559f6fc2ec2f3114 Azure:
[CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
gaoyunhaii commented on pull request #6:
URL: https://github.com/apache/flink-ml/pull/6#issuecomment-950341636
Very thanks @guoweiM for the review! I updated the PR to address the inline
comments~
I also agree with we should push the broadcast functionality back to the
runtime. Cur
flinkbot edited a comment on pull request #17553:
URL: https://github.com/apache/flink/pull/17553#issuecomment-950337501
## CI report:
* 078605c69cb264c9e212312b559f6fc2ec2f3114 Azure:
[CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
[
https://issues.apache.org/jira/browse/FLINK-24624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17433448#comment-17433448
]
Aitozi commented on FLINK-24624:
After looking into the failure, It's caused by the lack
flinkbot edited a comment on pull request #17553:
URL: https://github.com/apache/flink/pull/17553#issuecomment-950337501
## CI report:
* 078605c69cb264c9e212312b559f6fc2ec2f3114 Azure:
[CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
flinkbot edited a comment on pull request #17553:
URL: https://github.com/apache/flink/pull/17553#issuecomment-950337501
## CI report:
* 078605c69cb264c9e212312b559f6fc2ec2f3114 Azure:
[CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
[
https://issues.apache.org/jira/browse/FLINK-24624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17433449#comment-17433449
]
Aitozi commented on FLINK-24624:
So the {{client.stopAndCleanupCluster(clusterId)}} shou
flinkbot edited a comment on pull request #17553:
URL: https://github.com/apache/flink/pull/17553#issuecomment-950337501
## CI report:
* 078605c69cb264c9e212312b559f6fc2ec2f3114 Azure:
[CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
flinkbot edited a comment on pull request #17553:
URL: https://github.com/apache/flink/pull/17553#issuecomment-950337501
## CI report:
* 078605c69cb264c9e212312b559f6fc2ec2f3114 Azure:
[CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
gaoyunhaii commented on a change in pull request #7:
URL: https://github.com/apache/flink-ml/pull/7#discussion_r735134932
##
File path:
flink-ml-iteration/src/test/java/org/apache/flink/iteration/typeinfo/IterationRecordSerializerTest.java
##
@@ -0,0 +1,83 @@
+/*
+ * Licensed
flinkbot edited a comment on pull request #17553:
URL: https://github.com/apache/flink/pull/17553#issuecomment-950337501
## CI report:
* 078605c69cb264c9e212312b559f6fc2ec2f3114 Azure:
[CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
gaoyunhaii commented on a change in pull request #8:
URL: https://github.com/apache/flink-ml/pull/8#discussion_r735135046
##
File path:
flink-ml-iteration/src/main/java/org/apache/flink/iteration/operator/AbstractWrapperOperator.java
##
@@ -0,0 +1,164 @@
+/*
+ * Licensed to th
flinkbot edited a comment on pull request #17553:
URL: https://github.com/apache/flink/pull/17553#issuecomment-950337501
## CI report:
* 078605c69cb264c9e212312b559f6fc2ec2f3114 Azure:
[CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
flinkbot edited a comment on pull request #17553:
URL: https://github.com/apache/flink/pull/17553#issuecomment-950337501
## CI report:
* 078605c69cb264c9e212312b559f6fc2ec2f3114 Azure:
[CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
flinkbot edited a comment on pull request #17553:
URL: https://github.com/apache/flink/pull/17553#issuecomment-950337501
## CI report:
* 078605c69cb264c9e212312b559f6fc2ec2f3114 Azure:
[CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
flinkbot edited a comment on pull request #17553:
URL: https://github.com/apache/flink/pull/17553#issuecomment-950337501
## CI report:
* 078605c69cb264c9e212312b559f6fc2ec2f3114 Azure:
[CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
gaoyunhaii commented on a change in pull request #8:
URL: https://github.com/apache/flink-ml/pull/8#discussion_r735137114
##
File path:
flink-ml-iteration/src/main/java/org/apache/flink/iteration/proxy/ProxyOutput.java
##
@@ -0,0 +1,111 @@
+/*
+ * Licensed to the Apache Softwa
[
https://issues.apache.org/jira/browse/FLINK-20578?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17433476#comment-17433476
]
Saad Ur Rahman commented on FLINK-20578:
As I understand the problem we would ne
[
https://issues.apache.org/jira/browse/FLINK-20578?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17433476#comment-17433476
]
Saad Ur Rahman edited comment on FLINK-20578 at 10/24/21, 5:55 PM:
---
flinkbot edited a comment on pull request #17553:
URL: https://github.com/apache/flink/pull/17553#issuecomment-950337501
## CI report:
* 033f02a5aa2654a6c9c82047a6077542b973756b Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
[
https://issues.apache.org/jira/browse/FLINK-24592?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17433499#comment-17433499
]
Sergey Nuyanzin commented on FLINK-24592:
-
Currently I have a version[1] support
[
https://issues.apache.org/jira/browse/FLINK-24592?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17433499#comment-17433499
]
Sergey Nuyanzin edited comment on FLINK-24592 at 10/24/21, 7:47 PM:
--
[
https://issues.apache.org/jira/browse/FLINK-24623?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17433513#comment-17433513
]
Till Rohrmann commented on FLINK-24623:
---
Thanks for creating this ticket [~Dario].
[
https://issues.apache.org/jira/browse/FLINK-24350?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-24350:
---
Labels: stale-assigned test-stability (was: test-stability)
I am the [Flink Jira Bot|https:
[
https://issues.apache.org/jira/browse/FLINK-20578?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17433476#comment-17433476
]
Saad Ur Rahman edited comment on FLINK-20578 at 10/24/21, 10:38 PM:
--
[
https://issues.apache.org/jira/browse/FLINK-20578?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17433476#comment-17433476
]
Saad Ur Rahman edited comment on FLINK-20578 at 10/24/21, 11:52 PM:
--
JingsongLi merged pull request #17543:
URL: https://github.com/apache/flink/pull/17543
--
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-unsu
[
https://issues.apache.org/jira/browse/FLINK-24613?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-24613.
Fix Version/s: 1.14.1
Resolution: Fixed
Fixed via:
master: 955bd585b618e841fe2ff3d3f69bf4f0
xuyangzhong commented on pull request #17546:
URL: https://github.com/apache/flink/pull/17546#issuecomment-950452711
@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 speci
flinkbot edited a comment on pull request #17546:
URL: https://github.com/apache/flink/pull/17546#issuecomment-949398959
## CI report:
* 51ffb83f52f0334094f425d86aa5dd178a107267 Azure:
[PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
[
https://issues.apache.org/jira/browse/FLINK-24605?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17433530#comment-17433530
]
Qingsheng Ren commented on FLINK-24605:
---
Thanks for reporting this [~a_talukdar] !
flinkbot edited a comment on pull request #17546:
URL: https://github.com/apache/flink/pull/17546#issuecomment-949398959
## CI report:
* 51ffb83f52f0334094f425d86aa5dd178a107267 Azure:
[PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
xuyangzhong commented on a change in pull request #17537:
URL: https://github.com/apache/flink/pull/17537#discussion_r735210503
##
File path:
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/common/CommonExecTableSourceScan.java
##
@
xuyangzhong commented on a change in pull request #17537:
URL: https://github.com/apache/flink/pull/17537#discussion_r735210571
##
File path:
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/factories/sinkfunction/CollectionWatermarkSinkFunction.java
##
xuyangzhong commented on a change in pull request #17537:
URL: https://github.com/apache/flink/pull/17537#discussion_r735212556
##
File path:
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/factories/sinkfunction/CollectionWatermarkSinkFunction.java
##
Kenyore created FLINK-24626:
---
Summary: Flink JDBC Sink may lose data in retract stream
Key: FLINK-24626
URL: https://issues.apache.org/jira/browse/FLINK-24626
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-24558?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
bai sui updated FLINK-24558:
Component/s: (was: API / DataStream)
Command Line Client
> dataStream can not use mul
[
https://issues.apache.org/jira/browse/FLINK-24626?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kenyore updated FLINK-24626:
Summary: Flink JDBC Sink may lose data in left join (was: Flink JDBC Sink
may lose data in retract stream
[
https://issues.apache.org/jira/browse/FLINK-24626?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kenyore updated FLINK-24626:
Description:
The JDBC sink will lose some data while using
TableBufferReducedStatementExecutor and left j
flinkbot edited a comment on pull request #17344:
URL: https://github.com/apache/flink/pull/17344#issuecomment-925952696
## CI report:
* 4ad29008075dc93463c07ce098cd7b1086104d7b Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #17344:
URL: https://github.com/apache/flink/pull/17344#issuecomment-925952696
## CI report:
* 4ad29008075dc93463c07ce098cd7b1086104d7b Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #17546:
URL: https://github.com/apache/flink/pull/17546#issuecomment-949398959
## CI report:
* 51ffb83f52f0334094f425d86aa5dd178a107267 Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
iyupeng commented on a change in pull request #17344:
URL: https://github.com/apache/flink/pull/17344#discussion_r735217760
##
File path:
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/abilities/source/AggregatePushDownSpec.java
##
@@ -0,0 +1
iyupeng commented on a change in pull request #17344:
URL: https://github.com/apache/flink/pull/17344#discussion_r735218053
##
File path:
flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/runtime/batch/sql/agg/LocalAggregatePushDownITCase.scala
##
@
baisui1981 commented on pull request #17521:
URL: https://github.com/apache/flink/pull/17521#issuecomment-950471638
@AHeise , thanks for your reply , by checking of git histories commit logs
, Maybe this issue is belong to `Command Line Client` more appropriate.
@kl0u could you help me
iyupeng commented on a change in pull request #17344:
URL: https://github.com/apache/flink/pull/17344#discussion_r735218756
##
File path:
flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/rules/FlinkBatchRuleSets.scala
##
@@ -446,6 +446,9 @@ ob
baisui1981 commented on pull request #17521:
URL: https://github.com/apache/flink/pull/17521#issuecomment-950471796
@AHeise , thanks for your reply , by checking of git histories commit logs
, Maybe this issue is belong to `Command Line Client` more appropriate.
@kl0u could you help me
baisui1981 removed a comment on pull request #17521:
URL: https://github.com/apache/flink/pull/17521#issuecomment-950471796
@AHeise , thanks for your reply , by checking of git histories commit logs
, Maybe this issue is belong to `Command Line Client` more appropriate.
@kl0u could you
iyupeng commented on a change in pull request #17344:
URL: https://github.com/apache/flink/pull/17344#discussion_r735219201
##
File path:
flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/schema/TableSourceTable.scala
##
@@ -131,4 +130,23 @@ cl
iyupeng commented on a change in pull request #17344:
URL: https://github.com/apache/flink/pull/17344#discussion_r735219348
##
File path:
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/factories/TestValuesTableFactory.java
##
@@ -867,27 +885,118 @
iyupeng commented on a change in pull request #17344:
URL: https://github.com/apache/flink/pull/17344#discussion_r735219717
##
File path:
flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/runtime/batch/sql/agg/LocalAggregatePushDownITCase.scala
##
@
iyupeng commented on a change in pull request #17344:
URL: https://github.com/apache/flink/pull/17344#discussion_r735221321
##
File path:
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/rules/physical/batch/PushLocalAggIntoTableSourceScanRuleTest.java
iyupeng commented on a change in pull request #17344:
URL: https://github.com/apache/flink/pull/17344#discussion_r735221462
##
File path:
flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/runtime/batch/sql/agg/LocalAggregatePushDownITCase.scala
##
@
iyupeng commented on a change in pull request #17344:
URL: https://github.com/apache/flink/pull/17344#discussion_r735222457
##
File path:
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/rules/physical/batch/PushLocalAggIntoTableSourceScanRuleTest.java
iyupeng commented on a change in pull request #17344:
URL: https://github.com/apache/flink/pull/17344#discussion_r735225200
##
File path:
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/rules/physical/batch/PushLocalAggIntoTableSourceScanRuleTest.java
[
https://issues.apache.org/jira/browse/FLINK-21327?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kurt Young updated FLINK-21327:
---
Fix Version/s: 1.15.0
> Support window TVF in batch mode
>
>
>
[
https://issues.apache.org/jira/browse/FLINK-23015?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kurt Young updated FLINK-23015:
---
Fix Version/s: 1.15.0
> Implement streaming window Deduplicate operator
> --
Hang Ruan created FLINK-24627:
-
Summary: Add some generic junit5 extensions to replace junit4 rules
Key: FLINK-24627
URL: https://issues.apache.org/jira/browse/FLINK-24627
Project: Flink
Issue Ty
xuyangzhong commented on a change in pull request #17537:
URL: https://github.com/apache/flink/pull/17537#discussion_r735241016
##
File path:
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/factories/source/TestValuesSource.java
##
@@ -0,0 +1,393 @
xuyangzhong commented on a change in pull request #17537:
URL: https://github.com/apache/flink/pull/17537#discussion_r735247142
##
File path:
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/factories/sinkfunction/CollectionWatermarkSinkFunction.java
##
guoweiM commented on a change in pull request #12:
URL: https://github.com/apache/flink-ml/pull/12#discussion_r735249190
##
File path:
flink-ml-iteration/src/test/java/org/apache/flink/iteration/IterationConstructionTest.java
##
@@ -0,0 +1,141 @@
+/*
+ * Licensed to the Apache
[
https://issues.apache.org/jira/browse/FLINK-23031?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17433561#comment-17433561
]
Aitozi commented on FLINK-23031:
Hi [~jark] [~godfreyhe] [~twalthr] anyone could help re
Airblader commented on a change in pull request #17332:
URL: https://github.com/apache/flink/pull/17332#discussion_r735267747
##
File path:
flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/dialect/JdbcDialect.java
##
@@ -142,4 +143,16 @@
Aitozi opened a new pull request #17554:
URL: https://github.com/apache/flink/pull/17554
## What is the purpose of the change
Make the exception try-catch cover the whole `deploySessionCluster` and
`deployApplicationCluster` to make sure the kubernetes objects will be cleaned
up aft
[
https://issues.apache.org/jira/browse/FLINK-24624?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-24624:
---
Labels: pull-request-available (was: )
> Add clean up phase when kubernetes session start f
RocMarshal commented on pull request #17548:
URL: https://github.com/apache/flink/pull/17548#issuecomment-950549753
Hi, @wuchong ,Could you help me to check this pr ?Thank you.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to Git
flinkbot commented on pull request #17554:
URL: https://github.com/apache/flink/pull/17554#issuecomment-950550174
## CI report:
* 77e1b9059149c986fc2e35516ce33e3309b61cad UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot r
flinkbot commented on pull request #17554:
URL: https://github.com/apache/flink/pull/17554#issuecomment-950550557
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review your pull request. We will use this comment to track the pro
flinkbot edited a comment on pull request #17554:
URL: https://github.com/apache/flink/pull/17554#issuecomment-950550174
## CI report:
* 77e1b9059149c986fc2e35516ce33e3309b61cad Azure:
[PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
[
https://issues.apache.org/jira/browse/FLINK-23935?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17433570#comment-17433570
]
Yao Zhang commented on FLINK-23935:
---
Could anyone help review this commit please?
> F
[
https://issues.apache.org/jira/browse/FLINK-24597?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17433569#comment-17433569
]
Yue Ma commented on FLINK-24597:
[~roman] could you please help to take a look at this i
flinkbot edited a comment on pull request #17549:
URL: https://github.com/apache/flink/pull/17549#issuecomment-949678124
## CI report:
* dd84b7ac9f4bcf38261f4c1932d83960dc943057 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #17549:
URL: https://github.com/apache/flink/pull/17549#issuecomment-949678124
## CI report:
* dd84b7ac9f4bcf38261f4c1932d83960dc943057 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #17554:
URL: https://github.com/apache/flink/pull/17554#issuecomment-950550174
## CI report:
* 77e1b9059149c986fc2e35516ce33e3309b61cad Azure:
[PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #17344:
URL: https://github.com/apache/flink/pull/17344#issuecomment-925952696
## CI report:
* 4e795eef112edd7a5f705596151cacee93d53c03 Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #17554:
URL: https://github.com/apache/flink/pull/17554#issuecomment-950550174
## CI report:
* 77e1b9059149c986fc2e35516ce33e3309b61cad Azure:
[PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #17554:
URL: https://github.com/apache/flink/pull/17554#issuecomment-950550174
## CI report:
* 77e1b9059149c986fc2e35516ce33e3309b61cad Azure:
[PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
1 - 100 of 123 matches
Mail list logo