flinkbot edited a comment on pull request #14591:
URL: https://github.com/apache/flink/pull/14591#issuecomment-756825239
## CI report:
* 35947579b06f3b4d67e151e2fc38565813076008 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
[
https://issues.apache.org/jira/browse/FLINK-20663?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kurt Young updated FLINK-20663:
---
Priority: Critical (was: Major)
> Managed memory may not be released in time when operators use man
[
https://issues.apache.org/jira/browse/FLINK-20663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17276114#comment-17276114
]
Caizhi Weng commented on FLINK-20663:
-
Hi,
I've tested the patch [~xintongsong] pro
[
https://issues.apache.org/jira/browse/FLINK-21150?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
godfrey he reassigned FLINK-21150:
--
Assignee: godfrey he
> Introduce ExecEdge to connect two ExecNodes
>
wuchong commented on a change in pull request #14822:
URL: https://github.com/apache/flink/pull/14822#discussion_r567614908
##
File path:
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/common/CommonExecSink.java
##
@@ -123,6
godfrey he created FLINK-21224:
--
Summary: Remove BatchExecExchange and StreamExecExchange, and
replace their functionality with ExecEdge
Key: FLINK-21224
URL: https://issues.apache.org/jira/browse/FLINK-21224
wuchong commented on a change in pull request #14822:
URL: https://github.com/apache/flink/pull/14822#discussion_r567614908
##
File path:
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/common/CommonExecSink.java
##
@@ -123,6
wuchong commented on a change in pull request #14822:
URL: https://github.com/apache/flink/pull/14822#discussion_r567610927
##
File path:
flink-table/flink-table-common/src/main/java/org/apache/flink/table/connector/sink/SinkProvider.java
##
@@ -0,0 +1,36 @@
+/*
+ * Licensed t
wuchong commented on a change in pull request #14822:
URL: https://github.com/apache/flink/pull/14822#discussion_r567610927
##
File path:
flink-table/flink-table-common/src/main/java/org/apache/flink/table/connector/sink/SinkProvider.java
##
@@ -0,0 +1,36 @@
+/*
+ * Licensed t
dianfu merged pull request #14825:
URL: https://github.com/apache/flink/pull/14825
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 t
flinkbot edited a comment on pull request #14826:
URL: https://github.com/apache/flink/pull/14826#issuecomment-770627972
## CI report:
* ce1c42b9e4162b61553f3fadd02d30107047f91d Azure:
[PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #14647:
URL: https://github.com/apache/flink/pull/14647#issuecomment-760154591
## CI report:
* 80e3121418e741d9bebf3e849817a0c4225a86dd Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
[
https://issues.apache.org/jira/browse/FLINK-21221?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias updated FLINK-21221:
-
Labels: starter (was: )
> Deduplication of ResourceCounter
>
>
>
[
https://issues.apache.org/jira/browse/FLINK-21220?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias updated FLINK-21220:
-
Labels: starter (was: )
> Change the type of cpuCores in ResourceProfile to CPUResource
> -
Dian Fu created FLINK-21223:
---
Summary: Support to specify the input/output types of Python UDFs
via string
Key: FLINK-21223
URL: https://issues.apache.org/jira/browse/FLINK-21223
Project: Flink
Is
[
https://issues.apache.org/jira/browse/FLINK-16224?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17276104#comment-17276104
]
Matthias commented on FLINK-16224:
--
Hi [~jackwangcs], I don't know of any plans to work
flinkbot commented on pull request #14826:
URL: https://github.com/apache/flink/pull/14826#issuecomment-770627972
## CI report:
* ce1c42b9e4162b61553f3fadd02d30107047f91d UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot r
flinkbot edited a comment on pull request #14823:
URL: https://github.com/apache/flink/pull/14823#issuecomment-770437030
## CI report:
* f0ba4a5828295c651491d7b031dd6c894375234b UNKNOWN
* e97b4de046ec8231040f2c88b851a3fd69bf647b Azure:
[FAILURE](https://dev.azure.com/apache-fl
flinkbot edited a comment on pull request #14678:
URL: https://github.com/apache/flink/pull/14678#issuecomment-761905721
## CI report:
* cade20e85b29ca63c51383dca04976c1d9801042 UNKNOWN
* 12652d9c7829d2d26d41f61185cbd7ab8f4ad505 Azure:
[SUCCESS](https://dev.azure.com/apache-fl
flinkbot edited a comment on pull request #14647:
URL: https://github.com/apache/flink/pull/14647#issuecomment-760154591
## CI report:
* 80e3121418e741d9bebf3e849817a0c4225a86dd Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
Dian Fu created FLINK-21222:
---
Summary: Support loopback mode to allow Python UDF worker and
client reuse the same Python VM
Key: FLINK-21222
URL: https://issues.apache.org/jira/browse/FLINK-21222
Project: F
flinkbot commented on pull request #14826:
URL: https://github.com/apache/flink/pull/14826#issuecomment-770608140
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
[
https://issues.apache.org/jira/browse/FLINK-21215?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski reassigned FLINK-21215:
--
Assignee: Piotr Nowojski
> UnalignedCheckpointITCase.execute Failed
> ---
[
https://issues.apache.org/jira/browse/FLINK-21045?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17276088#comment-17276088
]
Jark Wu commented on FLINK-21045:
-
Thanks [~qingyue] for the nice summary. Let's continu
[
https://issues.apache.org/jira/browse/FLINK-12358?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-12358:
---
Labels: pull-request-available (was: )
> Verify whether rest documenation needs to be updat
wuchong commented on a change in pull request #14813:
URL: https://github.com/apache/flink/pull/14813#discussion_r567589468
##
File path:
flink-formats/flink-csv/src/test/java/org/apache/flink/formats/csv/CsvFormatFactoryTest.java
##
@@ -206,6 +206,29 @@ public void testDeseri
Myasuka opened a new pull request #14826:
URL: https://github.com/apache/flink/pull/14826
## What is the purpose of the change
Include method/path/query parameter description in the
`rest_api_v1.snapshot` so that we could follow the description check.
Add IT case `RestOptionsDocsC
[
https://issues.apache.org/jira/browse/FLINK-14256?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17276084#comment-17276084
]
Zili Chen commented on FLINK-14256:
---
Plz update FLIP status correspondingly [~lzljs362
[
https://issues.apache.org/jira/browse/FLINK-20722?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17276080#comment-17276080
]
Jark Wu commented on FLINK-20722:
-
Sorry, but shouldn't this be fixed in
{{multipleinpu
flinkbot edited a comment on pull request #14823:
URL: https://github.com/apache/flink/pull/14823#issuecomment-770437030
## CI report:
* f0ba4a5828295c651491d7b031dd6c894375234b UNKNOWN
* e97b4de046ec8231040f2c88b851a3fd69bf647b Azure:
[FAILURE](https://dev.azure.com/apache-fl
[
https://issues.apache.org/jira/browse/FLINK-21203?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17276078#comment-17276078
]
wangpeibin commented on FLINK-21203:
+1 for Jark's suggestion
> Don’t collect -U&+
[
https://issues.apache.org/jira/browse/FLINK-20216?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu closed FLINK-20216.
---
Fix Version/s: (was: 1.13.0)
1.12.0
Resolution: Fixed
> Move "Configuration" a
wuchong commented on a change in pull request #14813:
URL: https://github.com/apache/flink/pull/14813#discussion_r567584364
##
File path:
flink-formats/flink-csv/src/test/java/org/apache/flink/formats/csv/CsvFormatFactoryTest.java
##
@@ -206,6 +206,29 @@ public void testDeseri
KarmaGYZ commented on a change in pull request #14647:
URL: https://github.com/apache/flink/pull/14647#discussion_r567581423
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/slotmanager/FineGrainedSlotManager.java
##
@@ -0,0 +1,790 @@
+/*
+ *
flinkbot edited a comment on pull request #14825:
URL: https://github.com/apache/flink/pull/14825#issuecomment-770581870
## CI report:
* 291f6797c35037d17e9aeb8ab67da557d5c35b87 Azure:
[PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #14824:
URL: https://github.com/apache/flink/pull/14824#issuecomment-770512589
## CI report:
* e434ce611d8c12cceb749d22ea24f3e6fb650aeb Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
[
https://issues.apache.org/jira/browse/FLINK-20495?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17276069#comment-17276069
]
Xintong Song commented on FLINK-20495:
--
https://dev.azure.com/apache-flink/apache-f
[
https://issues.apache.org/jira/browse/FLINK-21171?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai closed FLINK-21171.
---
Resolution: Fixed
flink-statefun/master: 69c658ec361682fb3bef50bd810f0646d7332a0c
>
tzulitai closed pull request #195:
URL: https://github.com/apache/flink-statefun/pull/195
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
[
https://issues.apache.org/jira/browse/FLINK-21203?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17276066#comment-17276066
]
Jark Wu commented on FLINK-21203:
-
I think we may not need the configuration. Group Aggr
flinkbot commented on pull request #14825:
URL: https://github.com/apache/flink/pull/14825#issuecomment-770581870
## CI report:
* 291f6797c35037d17e9aeb8ab67da557d5c35b87 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot r
flinkbot commented on pull request #14825:
URL: https://github.com/apache/flink/pull/14825#issuecomment-770576435
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
[
https://issues.apache.org/jira/browse/FLINK-21216?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-21216:
---
Labels: pull-request-available test-stability (was: test-stability)
> StreamPandasConversio
HuangXingBo opened a new pull request #14825:
URL: https://github.com/apache/flink/pull/14825
## What is the purpose of the change
*This pull request fix numpy version in setup.py. Currently
pyarrow>=0.15.1,<0.18.0 and numpy==1.20.0 have compatibility problem in Python
3.7.*
flinkbot edited a comment on pull request #13912:
URL: https://github.com/apache/flink/pull/13912#issuecomment-721398037
## CI report:
* dfd5c341320f3ccb7291c5833ae52a3d3f1632f1 Azure:
[CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
curcur commented on a change in pull request #14799:
URL: https://github.com/apache/flink/pull/14799#discussion_r567563070
##
File path:
flink-core/src/main/java/org/apache/flink/configuration/CheckpointingOptions.java
##
@@ -44,6 +44,15 @@
.noDefaultValue
curcur commented on a change in pull request #14799:
URL: https://github.com/apache/flink/pull/14799#discussion_r567556094
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/state/proxy/ProxyKeyedStateBackend.java
##
@@ -0,0 +1,306 @@
+/*
+ * Licensed to the Ap
flinkbot edited a comment on pull request #14823:
URL: https://github.com/apache/flink/pull/14823#issuecomment-770437030
## CI report:
* f0ba4a5828295c651491d7b031dd6c894375234b UNKNOWN
* e97b4de046ec8231040f2c88b851a3fd69bf647b Azure:
[FAILURE](https://dev.azure.com/apache-fl
sharkdtu commented on a change in pull request #14813:
URL: https://github.com/apache/flink/pull/14813#discussion_r567551672
##
File path:
flink-formats/flink-csv/src/test/java/org/apache/flink/formats/csv/CsvFormatFactoryTest.java
##
@@ -206,6 +206,29 @@ public void testDeser
sharkdtu commented on a change in pull request #14813:
URL: https://github.com/apache/flink/pull/14813#discussion_r567551672
##
File path:
flink-formats/flink-csv/src/test/java/org/apache/flink/formats/csv/CsvFormatFactoryTest.java
##
@@ -206,6 +206,29 @@ public void testDeser
sharkdtu commented on a change in pull request #14813:
URL: https://github.com/apache/flink/pull/14813#discussion_r567551672
##
File path:
flink-formats/flink-csv/src/test/java/org/apache/flink/formats/csv/CsvFormatFactoryTest.java
##
@@ -206,6 +206,29 @@ public void testDeser
curcur commented on a change in pull request #14799:
URL: https://github.com/apache/flink/pull/14799#discussion_r567551460
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/state/proxy/ProxyKeyedStateBackend.java
##
@@ -0,0 +1,306 @@
+/*
+ * Licensed to the Ap
curcur commented on a change in pull request #14799:
URL: https://github.com/apache/flink/pull/14799#discussion_r567551460
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/state/proxy/ProxyKeyedStateBackend.java
##
@@ -0,0 +1,306 @@
+/*
+ * Licensed to the Ap
curcur commented on pull request #14799:
URL: https://github.com/apache/flink/pull/14799#issuecomment-770546162
Thank you so much for reviewing, @rkhachatryan !
This is an automated message from the Apache Git Service.
To res
[
https://issues.apache.org/jira/browse/FLINK-21221?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17276044#comment-17276044
]
Yangze Guo commented on FLINK-21221:
cc: [~trohrmann] [~chesnay]
> Deduplication of
Yangze Guo created FLINK-21221:
--
Summary: Deduplication of ResourceCounter
Key: FLINK-21221
URL: https://issues.apache.org/jira/browse/FLINK-21221
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-21207?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-21207:
Component/s: Table SQL / Ecosystem
Formats (JSON, Avro, Parquet, ORC, SequenceFile)
> 'cs
wuchong commented on a change in pull request #14813:
URL: https://github.com/apache/flink/pull/14813#discussion_r567548368
##
File path:
flink-formats/flink-csv/src/test/java/org/apache/flink/formats/csv/CsvFormatFactoryTest.java
##
@@ -206,6 +206,29 @@ public void testDeseri
[
https://issues.apache.org/jira/browse/FLINK-21216?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17276042#comment-17276042
]
Guowei Ma edited comment on FLINK-21216 at 2/1/21, 3:37 AM:
[
https://issues.apache.org/jira/browse/FLINK-21203?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17276043#comment-17276043
]
Leonard Xu commented on FLINK-21203:
+1 for the ticket, [~wangpeibin]
About the con
[
https://issues.apache.org/jira/browse/FLINK-21216?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17276042#comment-17276042
]
Guowei Ma commented on FLINK-21216:
---
https://dev.azure.com/apache-flink/apache-flink/_
[
https://issues.apache.org/jira/browse/FLINK-21215?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17276041#comment-17276041
]
Guowei Ma commented on FLINK-21215:
---
https://dev.azure.com/apache-flink/apache-flink/_
flinkbot edited a comment on pull request #14823:
URL: https://github.com/apache/flink/pull/14823#issuecomment-770437030
## CI report:
* f0ba4a5828295c651491d7b031dd6c894375234b UNKNOWN
* fe9b0d8824da2e50712f599978a4586bfe8f28a4 Azure:
[SUCCESS](https://dev.azure.com/apache-fl
KarmaGYZ commented on a change in pull request #14647:
URL: https://github.com/apache/flink/pull/14647#discussion_r567546171
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/WorkerResourceSpec.java
##
@@ -70,6 +71,17 @@ public static WorkerRes
Yangze Guo created FLINK-21220:
--
Summary: Change the type of cpuCores in ResourceProfile to
CPUResource
Key: FLINK-21220
URL: https://issues.apache.org/jira/browse/FLINK-21220
Project: Flink
Is
guoweiM commented on a change in pull request #14734:
URL: https://github.com/apache/flink/pull/14734#discussion_r567541421
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinator.java
##
@@ -563,7 +554,7 @@ private void
startTrigge
guoweiM commented on a change in pull request #14734:
URL: https://github.com/apache/flink/pull/14734#discussion_r567528797
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointBriefCalculator.java
##
@@ -0,0 +1,127 @@
+/*
+ * Licensed to the
[
https://issues.apache.org/jira/browse/FLINK-21207?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-21207:
Description:
source table with 'csv.disable-quote-character' = 'true' can not take effect.
{code}
Cause
[
https://issues.apache.org/jira/browse/FLINK-21203?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu reassigned FLINK-21203:
---
Assignee: wangpeibin
> Don’t collect -U&+U Row When they are equals In the LastRowFunction
>
[
https://issues.apache.org/jira/browse/FLINK-21203?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17276038#comment-17276038
]
Jark Wu commented on FLINK-21203:
-
Sounds good to me.
What do you think [~Leonard Xu]
[
https://issues.apache.org/jira/browse/FLINK-18312?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17139087#comment-17139087
]
Yu Wang edited comment on FLINK-18312 at 2/1/21, 3:04 AM:
--
[~ch
flinkbot edited a comment on pull request #14823:
URL: https://github.com/apache/flink/pull/14823#issuecomment-770437030
## CI report:
* f0ba4a5828295c651491d7b031dd6c894375234b UNKNOWN
* fe9b0d8824da2e50712f599978a4586bfe8f28a4 Azure:
[SUCCESS](https://dev.azure.com/apache-fl
HuangZhenQiu commented on pull request #14823:
URL: https://github.com/apache/flink/pull/14823#issuecomment-770523596
@xintongsong
Thanks. Your changes are reasonable and needed.
This is an automated message from the Apa
flinkbot edited a comment on pull request #14678:
URL: https://github.com/apache/flink/pull/14678#issuecomment-761905721
## CI report:
* cade20e85b29ca63c51383dca04976c1d9801042 UNKNOWN
* 11651466eb13c5c05d2cd0eed0ac08b9bf617185 Azure:
[FAILURE](https://dev.azure.com/apache-fl
flinkbot edited a comment on pull request #14824:
URL: https://github.com/apache/flink/pull/14824#issuecomment-770512589
## CI report:
* e434ce611d8c12cceb749d22ea24f3e6fb650aeb Azure:
[PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
[
https://issues.apache.org/jira/browse/FLINK-16224?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17276033#comment-17276033
]
jackwangcs commented on FLINK-16224:
Hi [~rongr] and [~mapohl], is there any progres
[
https://issues.apache.org/jira/browse/FLINK-21216?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17276030#comment-17276030
]
Huang Xingbo commented on FLINK-21216:
--
I will take a look asap.
> StreamPandasCon
flinkbot commented on pull request #14824:
URL: https://github.com/apache/flink/pull/14824#issuecomment-770512589
## CI report:
* e434ce611d8c12cceb749d22ea24f3e6fb650aeb UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot r
flinkbot commented on pull request #14824:
URL: https://github.com/apache/flink/pull/14824#issuecomment-770502976
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
tweise opened a new pull request #14824:
URL: https://github.com/apache/flink/pull/14824
Backport of https://github.com/apache/flink/pull/14783
This is an automated message from the Apache Git Service.
To respond to t
flinkbot edited a comment on pull request #14678:
URL: https://github.com/apache/flink/pull/14678#issuecomment-761905721
## CI report:
* cade20e85b29ca63c51383dca04976c1d9801042 UNKNOWN
* 11651466eb13c5c05d2cd0eed0ac08b9bf617185 Azure:
[FAILURE](https://dev.azure.com/apache-fl
[
https://issues.apache.org/jira/browse/FLINK-21169?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Thomas Weise resolved FLINK-21169.
--
Fix Version/s: 1.13.0
Resolution: Fixed
> Kafka flink-connector-base dependency should
tweise merged pull request #14783:
URL: https://github.com/apache/flink/pull/14783
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 t
tweise commented on pull request #14783:
URL: https://github.com/apache/flink/pull/14783#issuecomment-770499151
> Hello @tweise and @becketqin ~ I think putting flink-connector-base JAR
under lib directory of Flink distribution might be a better choice. After
eventually all connectors are
[
https://issues.apache.org/jira/browse/FLINK-21214?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guowei Ma updated FLINK-21214:
--
Affects Version/s: 1.11.0
> FlinkKafkaProducerITCase.testScaleDownBeforeFirstCheckpoint Failed
> -
[
https://issues.apache.org/jira/browse/FLINK-21214?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17276021#comment-17276021
]
Guowei Ma commented on FLINK-21214:
---
https://dev.azure.com/apache-flink/apache-flink/_
[
https://issues.apache.org/jira/browse/FLINK-21219?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17276020#comment-17276020
]
Dominik Wosiński commented on FLINK-21219:
--
I would like to work on that.
>
[
https://issues.apache.org/jira/browse/FLINK-10407?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17276016#comment-17276016
]
John Phelan commented on FLINK-10407:
-
hi [~rmetzger] [~trohrmann] is there some wor
Dominik Wosiński created FLINK-21219:
Summary: FlinkKafkaConsumer ignores offset overrides for new
topics when restoring from savepoint.
Key: FLINK-21219
URL: https://issues.apache.org/jira/browse/FLINK-21219
flinkbot edited a comment on pull request #13912:
URL: https://github.com/apache/flink/pull/13912#issuecomment-721398037
## CI report:
* e7dbab13079f1a1f2350320930cc216c8ed42759 Azure:
[CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
flinkbot edited a comment on pull request #13912:
URL: https://github.com/apache/flink/pull/13912#issuecomment-721398037
## CI report:
* e7dbab13079f1a1f2350320930cc216c8ed42759 Azure:
[CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
flinkbot edited a comment on pull request #14823:
URL: https://github.com/apache/flink/pull/14823#issuecomment-770437030
## CI report:
* f0ba4a5828295c651491d7b031dd6c894375234b UNKNOWN
* fe9b0d8824da2e50712f599978a4586bfe8f28a4 Azure:
[SUCCESS](https://dev.azure.com/apache-fl
[
https://issues.apache.org/jira/browse/FLINK-20417?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17276004#comment-17276004
]
Emilien Kenler edited comment on FLINK-20417 at 1/31/21, 10:37 PM:
---
[
https://issues.apache.org/jira/browse/FLINK-20417?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17276004#comment-17276004
]
Emilien Kenler commented on FLINK-20417:
This issue happens event when the APISe
[
https://issues.apache.org/jira/browse/FLINK-20417?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17276004#comment-17276004
]
Emilien Kenler edited comment on FLINK-20417 at 1/31/21, 10:36 PM:
---
flinkbot edited a comment on pull request #14823:
URL: https://github.com/apache/flink/pull/14823#issuecomment-770437030
## CI report:
* f0ba4a5828295c651491d7b031dd6c894375234b UNKNOWN
* fe9b0d8824da2e50712f599978a4586bfe8f28a4 Azure:
[PENDING](https://dev.azure.com/apache-fl
flinkbot edited a comment on pull request #14823:
URL: https://github.com/apache/flink/pull/14823#issuecomment-770437030
## CI report:
* f0ba4a5828295c651491d7b031dd6c894375234b UNKNOWN
* fe9b0d8824da2e50712f599978a4586bfe8f28a4 UNKNOWN
Bot commands
The @flinkbo
[
https://issues.apache.org/jira/browse/FLINK-21139?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17275963#comment-17275963
]
Zhenqiu Huang commented on FLINK-21139:
---
[~xintongsong]
Make sense. Just created t
flinkbot commented on pull request #14823:
URL: https://github.com/apache/flink/pull/14823#issuecomment-770437030
## CI report:
* f0ba4a5828295c651491d7b031dd6c894375234b UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot r
flinkbot commented on pull request #14823:
URL: https://github.com/apache/flink/pull/14823#issuecomment-770435644
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
1 - 100 of 132 matches
Mail list logo