flinkbot edited a comment on pull request #17387:
URL: https://github.com/apache/flink/pull/17387#issuecomment-930245327
## CI report:
* a89506ce35582d88432cd6ceecbf2caea233f0ac Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
guoweiM commented on pull request #17532:
URL: https://github.com/apache/flink/pull/17532#issuecomment-960500530
Thanks @TanYuxin-tyx for invest this problem. I looks good to me. Please go
ahead
--
This is an automated message from the Apache Git Service.
To respond to the message, pleas
TanYuxin-tyx commented on pull request #17532:
URL: https://github.com/apache/flink/pull/17532#issuecomment-960498172
As shown above, I have reproduced the above exceptions. I added a new piece
of code to print this exception.
```java
System.out.println("e instanceof B
zhuzhurk commented on a change in pull request #15229:
URL: https://github.com/apache/flink/pull/15229#discussion_r742571287
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/DefaultScheduler.java
##
@@ -103,6 +104,10 @@
private final Time rpc
flinkbot edited a comment on pull request #17655:
URL: https://github.com/apache/flink/pull/17655#issuecomment-958717470
## CI report:
* cbb562453f733959c1f7e4ca96f4c74309f1ee81 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #17655:
URL: https://github.com/apache/flink/pull/17655#issuecomment-958717470
## CI report:
* cbb562453f733959c1f7e4ca96f4c74309f1ee81 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
Myasuka commented on a change in pull request #17525:
URL: https://github.com/apache/flink/pull/17525#discussion_r742568528
##
File path:
flink-runtime/src/test/java/org/apache/flink/runtime/state/StateBackendTestBase.java
##
@@ -460,22 +461,66 @@ public void testGetKeysAndNam
zhuzhurk commented on a change in pull request #15229:
URL: https://github.com/apache/flink/pull/15229#discussion_r742567127
##
File path:
flink-tests/src/test/java/org/apache/flink/test/runtime/SchedulingLocalRecoveryITCase.java
##
@@ -0,0 +1,227 @@
+/*
+ * Licensed to the Ap
zhuzhurk commented on a change in pull request #15229:
URL: https://github.com/apache/flink/pull/15229#discussion_r742567127
##
File path:
flink-tests/src/test/java/org/apache/flink/test/runtime/SchedulingLocalRecoveryITCase.java
##
@@ -0,0 +1,227 @@
+/*
+ * Licensed to the Ap
flinkbot edited a comment on pull request #17532:
URL: https://github.com/apache/flink/pull/17532#issuecomment-948251540
## CI report:
* 633084a4927bccc3958373c12ccd3441d303be68 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
zhuzhurk commented on a change in pull request #15229:
URL: https://github.com/apache/flink/pull/15229#discussion_r742562840
##
File path:
flink-tests/src/test/java/org/apache/flink/test/runtime/SchedulingLocalRecoveryITCase.java
##
@@ -0,0 +1,227 @@
+/*
+ * Licensed to the Ap
zhuzhurk commented on a change in pull request #15229:
URL: https://github.com/apache/flink/pull/15229#discussion_r742562840
##
File path:
flink-tests/src/test/java/org/apache/flink/test/runtime/SchedulingLocalRecoveryITCase.java
##
@@ -0,0 +1,227 @@
+/*
+ * Licensed to the Ap
flinkbot edited a comment on pull request #17665:
URL: https://github.com/apache/flink/pull/17665#issuecomment-960462017
## CI report:
* 4d46a90b64d13546a93cc5a9f540575d6a38e0d9 Azure:
[PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot commented on pull request #17665:
URL: https://github.com/apache/flink/pull/17665#issuecomment-960462017
## CI report:
* 4d46a90b64d13546a93cc5a9f540575d6a38e0d9 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot r
flinkbot commented on pull request #17665:
URL: https://github.com/apache/flink/pull/17665#issuecomment-960461887
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
mincwang opened a new pull request #17665:
URL: https://github.com/apache/flink/pull/17665
## 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 o
flinkbot edited a comment on pull request #17532:
URL: https://github.com/apache/flink/pull/17532#issuecomment-948251540
## CI report:
* Unknown: [CANCELED](TBD)
* 633084a4927bccc3958373c12ccd3441d303be68 Azure:
[PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620
flinkbot edited a comment on pull request #17652:
URL: https://github.com/apache/flink/pull/17652#issuecomment-958647607
## CI report:
* 2821a77a60feefd959cdf1f54e336ab4fcaa1a71 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #17605:
URL: https://github.com/apache/flink/pull/17605#issuecomment-954693023
## CI report:
* 0056d2cc65fb1d0ff971c0394a32fd65972ff148 Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #17532:
URL: https://github.com/apache/flink/pull/17532#issuecomment-948251540
## CI report:
* Unknown: [CANCELED](TBD)
* 633084a4927bccc3958373c12ccd3441d303be68 UNKNOWN
Bot commands
The @flinkbot bot supports the fol
TanYuxin-tyx removed a comment on pull request #17532:
URL: https://github.com/apache/flink/pull/17532#issuecomment-958978355
--
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.
TanYuxin-tyx commented on pull request #17532:
URL: https://github.com/apache/flink/pull/17532#issuecomment-960456231
@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 spec
flinkbot edited a comment on pull request #17652:
URL: https://github.com/apache/flink/pull/17652#issuecomment-958647607
## CI report:
* 2821a77a60feefd959cdf1f54e336ab4fcaa1a71 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #17605:
URL: https://github.com/apache/flink/pull/17605#issuecomment-954693023
## CI report:
* 0056d2cc65fb1d0ff971c0394a32fd65972ff148 Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
xuyangzhong commented on a change in pull request #17652:
URL: https://github.com/apache/flink/pull/17652#discussion_r742532909
##
File path:
flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/rules/FlinkBatchRuleSets.scala
##
@@ -246,77 +260,80
xuyangzhong commented on a change in pull request #17652:
URL: https://github.com/apache/flink/pull/17652#discussion_r742535921
##
File path:
flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/plan/batch/sql/PartitionableSourceTest.scala
##
@@ -76,30
[
https://issues.apache.org/jira/browse/FLINK-24759?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Caizhi Weng updated FLINK-24759:
Description:
I'm running a yarn-per-job streaming job (submitted via SQL client) which reads
a la
[
https://issues.apache.org/jira/browse/FLINK-24759?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Caizhi Weng updated FLINK-24759:
Description:
I'm running a yarn-per-job streaming job (submitted via SQL client) which reads
a la
Caizhi Weng created FLINK-24759:
---
Summary: Metrics on web UI is not correct in a filesystem source
to filesystem sink streaming job
Key: FLINK-24759
URL: https://issues.apache.org/jira/browse/FLINK-24759
[
https://issues.apache.org/jira/browse/FLINK-24759?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Caizhi Weng updated FLINK-24759:
Description:
I'm running a yarn-per-job streaming job which reads a large csv file
(flights.csv i
xuyangzhong commented on a change in pull request #17652:
URL: https://github.com/apache/flink/pull/17652#discussion_r742532909
##
File path:
flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/rules/FlinkBatchRuleSets.scala
##
@@ -246,77 +260,80
flinkbot edited a comment on pull request #17635:
URL: https://github.com/apache/flink/pull/17635#issuecomment-956476981
## CI report:
* 052d2a12ed9a10c86db344dad25b292cbb1a Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #17646:
URL: https://github.com/apache/flink/pull/17646#issuecomment-957837700
## CI report:
* b90ca62a59048e9ea369de6942203139e372533e Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
[
https://issues.apache.org/jira/browse/FLINK-24758?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee updated FLINK-24758:
-
Description:
Now, only supports -mm-dd hh:mm:ss, we can add a new time-extractor kind to
su
[
https://issues.apache.org/jira/browse/FLINK-24758?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee updated FLINK-24758:
-
Summary: filesystem sink: partition.time-extractor.kind support "MMdd"
(was: partition.time
Jingsong Lee created FLINK-24758:
Summary: partition.time-extractor.kind support "MMdd"
Key: FLINK-24758
URL: https://issues.apache.org/jira/browse/FLINK-24758
Project: Flink
Issue Type:
zhuzhurk commented on a change in pull request #15229:
URL: https://github.com/apache/flink/pull/15229#discussion_r742527302
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/DefaultScheduler.java
##
@@ -669,6 +704,11 @@ public SchedulingTopology get
[
https://issues.apache.org/jira/browse/FLINK-24757?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Caizhi Weng updated FLINK-24757:
Description:
I've seen this problem for about three times in the user mailing thread
(previously
[
https://issues.apache.org/jira/browse/FLINK-24757?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Caizhi Weng updated FLINK-24757:
Description:
I've seen this problem for about three times in the user mailing thread
(previously
zhuzhurk commented on a change in pull request #15229:
URL: https://github.com/apache/flink/pull/15229#discussion_r742521923
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/DefaultSchedulerComponents.java
##
@@ -124,9 +126,19 @@ private static Slot
[
https://issues.apache.org/jira/browse/FLINK-24757?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Caizhi Weng updated FLINK-24757:
Description:
I've seen this problem for about three times in the user mailing thread
(previously
[
https://issues.apache.org/jira/browse/FLINK-24757?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Caizhi Weng updated FLINK-24757:
Description:
I've seen this problem for about three times in the user mailing thread
(previously
Caizhi Weng created FLINK-24757:
---
Summary: Yarn application is not terminated after the job finishes
when submitting a yarn-per-job insert job with SQL client
Key: FLINK-24757
URL: https://issues.apache.org/jira/bro
flinkbot edited a comment on pull request #17650:
URL: https://github.com/apache/flink/pull/17650#issuecomment-958638599
## CI report:
* 150b5f9f464913cc83756cbadd233cdb279db0c7 Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #17655:
URL: https://github.com/apache/flink/pull/17655#issuecomment-958717470
## CI report:
* cbb562453f733959c1f7e4ca96f4c74309f1ee81 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #17655:
URL: https://github.com/apache/flink/pull/17655#issuecomment-958717470
## CI report:
* cbb562453f733959c1f7e4ca96f4c74309f1ee81 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #17655:
URL: https://github.com/apache/flink/pull/17655#issuecomment-958717470
## CI report:
* cbb562453f733959c1f7e4ca96f4c74309f1ee81 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #17655:
URL: https://github.com/apache/flink/pull/17655#issuecomment-958717470
## CI report:
* cbb562453f733959c1f7e4ca96f4c74309f1ee81 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #17655:
URL: https://github.com/apache/flink/pull/17655#issuecomment-958717470
## CI report:
* cbb562453f733959c1f7e4ca96f4c74309f1ee81 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #17655:
URL: https://github.com/apache/flink/pull/17655#issuecomment-958717470
## CI report:
* cbb562453f733959c1f7e4ca96f4c74309f1ee81 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
meetjunsu commented on pull request #17542:
URL: https://github.com/apache/flink/pull/17542#issuecomment-960418603
rebase onto latest master branch to fix python tests error
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
tsreaper commented on a change in pull request #17605:
URL: https://github.com/apache/flink/pull/17605#discussion_r742497844
##
File path:
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/rank/UpdatableTopNFunction.java
##
@@ -312,6 +357,3
flinkbot edited a comment on pull request #17655:
URL: https://github.com/apache/flink/pull/17655#issuecomment-958717470
## CI report:
* cbb562453f733959c1f7e4ca96f4c74309f1ee81 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #17643:
URL: https://github.com/apache/flink/pull/17643#issuecomment-957416596
## CI report:
* a4275b6ff459651c730cce9ddb48216dad635197 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
meetjunsu commented on pull request #17654:
URL: https://github.com/apache/flink/pull/17654#issuecomment-960417686
> @meetjunsu Thanks for the PR! Would this also make it possible to support
this for DataStream API users?
As far as I know `ParquetColumnarRowInputFormat` is a subclass
flinkbot edited a comment on pull request #17655:
URL: https://github.com/apache/flink/pull/17655#issuecomment-958717470
## CI report:
* cbb562453f733959c1f7e4ca96f4c74309f1ee81 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #17643:
URL: https://github.com/apache/flink/pull/17643#issuecomment-957416596
## CI report:
* a4275b6ff459651c730cce9ddb48216dad635197 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
[
https://issues.apache.org/jira/browse/FLINK-24751?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17438463#comment-17438463
]
tao.yang03 commented on FLINK-24751:
thanks 。 I add env.java.opts.taskmanager= '-X
[
https://issues.apache.org/jira/browse/FLINK-24751?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
tao.yang03 updated FLINK-24751:
---
Attachment: image-2021-11-04-11-03-22-937.png
> flink SQL comile failed cause by: java.lang.StackO
flinkbot edited a comment on pull request #17655:
URL: https://github.com/apache/flink/pull/17655#issuecomment-958717470
## CI report:
* cbb562453f733959c1f7e4ca96f4c74309f1ee81 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
wsz94 commented on a change in pull request #17643:
URL: https://github.com/apache/flink/pull/17643#discussion_r742503458
##
File path:
flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/reader/split/PulsarPartitionSplitReaderBase.java
#
flinkbot edited a comment on pull request #17655:
URL: https://github.com/apache/flink/pull/17655#issuecomment-958717470
## CI report:
* cbb562453f733959c1f7e4ca96f4c74309f1ee81 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
[
https://issues.apache.org/jira/browse/FLINK-24728?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Caizhi Weng updated FLINK-24728:
Affects Version/s: (was: 1.13.4)
(was: 1.14.1)
syhily commented on pull request #17643:
URL: https://github.com/apache/flink/pull/17643#issuecomment-960414913
> > @wsz94 I have created a patch by using `consumer.receive(timeout,
timeunit)`. Can you confirm this fix works?
> >
[gist.github.com/syhily/fbf47b581257f94869c59660002bbfa1]
lincoln-lil commented on a change in pull request #17605:
URL: https://github.com/apache/flink/pull/17605#discussion_r742502402
##
File path:
flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/runtime/harness/RankHarnessTest.scala
##
@@ -220,4 +221,7
lincoln-lil commented on a change in pull request #17605:
URL: https://github.com/apache/flink/pull/17605#discussion_r742502276
##
File path:
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/rank/UpdatableTopNFunction.java
##
@@ -312,6 +35
flinkbot edited a comment on pull request #17655:
URL: https://github.com/apache/flink/pull/17655#issuecomment-958717470
## CI report:
* cbb562453f733959c1f7e4ca96f4c74309f1ee81 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
syhily commented on a change in pull request #17643:
URL: https://github.com/apache/flink/pull/17643#discussion_r742501504
##
File path:
flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/reader/split/PulsarPartitionSplitReaderBase.java
tsreaper commented on a change in pull request #17605:
URL: https://github.com/apache/flink/pull/17605#discussion_r742501383
##
File path:
flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/runtime/harness/RankHarnessTest.scala
##
@@ -220,4 +221,74 @
flinkbot edited a comment on pull request #17655:
URL: https://github.com/apache/flink/pull/17655#issuecomment-958717470
## CI report:
* cbb562453f733959c1f7e4ca96f4c74309f1ee81 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
lincoln-lil commented on a change in pull request #17605:
URL: https://github.com/apache/flink/pull/17605#discussion_r742500845
##
File path:
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/rank/UpdatableTopNFunction.java
##
@@ -312,6 +35
flinkbot edited a comment on pull request #17655:
URL: https://github.com/apache/flink/pull/17655#issuecomment-958717470
## CI report:
* cbb562453f733959c1f7e4ca96f4c74309f1ee81 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #17650:
URL: https://github.com/apache/flink/pull/17650#issuecomment-958638599
## CI report:
* 150b5f9f464913cc83756cbadd233cdb279db0c7 Azure:
[PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #17650:
URL: https://github.com/apache/flink/pull/17650#issuecomment-958638599
## CI report:
* 150b5f9f464913cc83756cbadd233cdb279db0c7 Azure:
[PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #17655:
URL: https://github.com/apache/flink/pull/17655#issuecomment-958717470
## CI report:
* cbb562453f733959c1f7e4ca96f4c74309f1ee81 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
Zakelly commented on pull request #17650:
URL: https://github.com/apache/flink/pull/17650#issuecomment-960404229
@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
flinkbot edited a comment on pull request #17655:
URL: https://github.com/apache/flink/pull/17655#issuecomment-958717470
## CI report:
* cbb562453f733959c1f7e4ca96f4c74309f1ee81 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
tsreaper commented on a change in pull request #17605:
URL: https://github.com/apache/flink/pull/17605#discussion_r742497844
##
File path:
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/rank/UpdatableTopNFunction.java
##
@@ -312,6 +357,3
flinkbot edited a comment on pull request #17655:
URL: https://github.com/apache/flink/pull/17655#issuecomment-958717470
## CI report:
* cbb562453f733959c1f7e4ca96f4c74309f1ee81 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #17655:
URL: https://github.com/apache/flink/pull/17655#issuecomment-958717470
## CI report:
* cbb562453f733959c1f7e4ca96f4c74309f1ee81 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
tsreaper commented on a change in pull request #17605:
URL: https://github.com/apache/flink/pull/17605#discussion_r742494069
##
File path:
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/rank/UpdatableTopNFunction.java
##
@@ -312,6 +357,3
flinkbot edited a comment on pull request #17655:
URL: https://github.com/apache/flink/pull/17655#issuecomment-958717470
## CI report:
* cbb562453f733959c1f7e4ca96f4c74309f1ee81 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
tsreaper commented on a change in pull request #17605:
URL: https://github.com/apache/flink/pull/17605#discussion_r742492674
##
File path:
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/rank/UpdatableTopNFunction.java
##
@@ -312,6 +357,3
[
https://issues.apache.org/jira/browse/FLINK-24687?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17438460#comment-17438460
]
Jingsong Lee commented on FLINK-24687:
--
I think it should be possible, because the
flinkbot edited a comment on pull request #17655:
URL: https://github.com/apache/flink/pull/17655#issuecomment-958717470
## CI report:
* cbb562453f733959c1f7e4ca96f4c74309f1ee81 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
[
https://issues.apache.org/jira/browse/FLINK-24713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17438459#comment-17438459
]
Yangze Guo commented on FLINK-24713:
[~aitozi] I second Till's proposal. A configura
flinkbot edited a comment on pull request #17655:
URL: https://github.com/apache/flink/pull/17655#issuecomment-958717470
## CI report:
* cbb562453f733959c1f7e4ca96f4c74309f1ee81 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #17655:
URL: https://github.com/apache/flink/pull/17655#issuecomment-958717470
## CI report:
* cbb562453f733959c1f7e4ca96f4c74309f1ee81 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #17655:
URL: https://github.com/apache/flink/pull/17655#issuecomment-958717470
## CI report:
* cbb562453f733959c1f7e4ca96f4c74309f1ee81 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #17655:
URL: https://github.com/apache/flink/pull/17655#issuecomment-958717470
## CI report:
* cbb562453f733959c1f7e4ca96f4c74309f1ee81 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #17655:
URL: https://github.com/apache/flink/pull/17655#issuecomment-958717470
## CI report:
* cbb562453f733959c1f7e4ca96f4c74309f1ee81 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #17655:
URL: https://github.com/apache/flink/pull/17655#issuecomment-958717470
## CI report:
* cbb562453f733959c1f7e4ca96f4c74309f1ee81 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
wenlong88 commented on a change in pull request #17509:
URL: https://github.com/apache/flink/pull/17509#discussion_r742482235
##
File path:
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/window/slicing/SlicingWindowOperator.java
##
@@ -1
[
https://issues.apache.org/jira/browse/FLINK-16833?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17438452#comment-17438452
]
Lijie Wang commented on FLINK-16833:
Hi [~MartijnVisser] , sorry for the late reply.
slinkydeveloper commented on a change in pull request #17658:
URL: https://github.com/apache/flink/pull/17658#discussion_r742034054
##
File path:
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/functions/casting/rules/AbstractCodeGeneratorCastRule.java
###
mans2singh commented on pull request #17661:
URL: https://github.com/apache/flink/pull/17661#issuecomment-959384274
@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 specif
[
https://issues.apache.org/jira/browse/FLINK-24755?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17438169#comment-17438169
]
Aitozi edited comment on FLINK-24755 at 11/4/21, 2:01 AM:
--
[~ch
wsz94 edited a comment on pull request #17643:
URL: https://github.com/apache/flink/pull/17643#issuecomment-959583041
> @wsz94 I have created a patch by using `consumer.receive(timeout,
timeunit)`. Can you confirm this fix works?
>
> https://gist.github.com/syhily/fbf47b581257f94869c
tsreaper commented on pull request #17520:
URL: https://github.com/apache/flink/pull/17520#issuecomment-959002265
@slinkydeveloper @fapaul @JingGe
I've done some benchmarking on a testing yarn cluster.
* Test data: The [Kaggle flight delay
data](https://www.kaggle.com/usdot/fl
flinkbot commented on pull request #17651:
URL: https://github.com/apache/flink/pull/17651#issuecomment-958639580
--
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 unsubsc
1 - 100 of 1075 matches
Mail list logo
