alpinegizmo merged pull request #13:
URL: https://github.com/apache/flink-training/pull/13
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
flinkbot edited a comment on pull request #13239:
URL: https://github.com/apache/flink/pull/13239#issuecomment-679946229
## CI report:
* fbf7c39bb2d6cb79f52a93efabe310cb2bafdee9 Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
zentol commented on a change in pull request #13163:
URL: https://github.com/apache/flink/pull/13163#discussion_r476645574
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/management/JMXService.java
##
@@ -85,6 +86,9 @@ private static JMXServer
startJMXServe
AHeise commented on a change in pull request #13228:
URL: https://github.com/apache/flink/pull/13228#discussion_r476657231
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/PipelinedSubpartition.java
##
@@ -171,19 +175,42 @@ private void h
AHeise commented on a change in pull request #13228:
URL: https://github.com/apache/flink/pull/13228#discussion_r476659669
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/PipelinedSubpartition.java
##
@@ -171,19 +175,42 @@ private void h
AHeise commented on a change in pull request #13228:
URL: https://github.com/apache/flink/pull/13228#discussion_r476660921
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/SingleInputGate.java
##
@@ -621,61 +626,84 @@ public bool
AHeise commented on a change in pull request #13228:
URL: https://github.com/apache/flink/pull/13228#discussion_r476660758
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/CreditBasedSequenceNumberingViewReader.java
##
@@ -133,14 +136,14 @@ p
AHeise commented on a change in pull request #13228:
URL: https://github.com/apache/flink/pull/13228#discussion_r476662192
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/SingleInputGate.java
##
@@ -770,34 +808,50 @@ void trigge
AHeise commented on a change in pull request #13228:
URL: https://github.com/apache/flink/pull/13228#discussion_r476665640
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/RemoteInputChannel.java
##
@@ -195,28 +193,27 @@ void ret
AHeise commented on a change in pull request #13228:
URL: https://github.com/apache/flink/pull/13228#discussion_r476673355
##
File path:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/CheckpointedInputGate.java
##
@@ -63,9 +66,38 @@
*/
AHeise commented on a change in pull request #13228:
URL: https://github.com/apache/flink/pull/13228#discussion_r476674004
##
File path:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/CheckpointedInputGate.java
##
@@ -74,34 +106,34 @@ public Checkpoin
AHeise commented on a change in pull request #13228:
URL: https://github.com/apache/flink/pull/13228#discussion_r476675096
##
File path:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/CheckpointedInputGate.java
##
@@ -63,9 +66,38 @@
*/
AHeise commented on a change in pull request #13228:
URL: https://github.com/apache/flink/pull/13228#discussion_r476674004
##
File path:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/CheckpointedInputGate.java
##
@@ -74,34 +106,34 @@ public Checkpoin
AHeise commented on a change in pull request #13228:
URL: https://github.com/apache/flink/pull/13228#discussion_r476677925
##
File path:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/CheckpointedInputGate.java
##
@@ -74,34 +106,34 @@ public Checkpoin
morsapaes commented on a change in pull request #13203:
URL: https://github.com/apache/flink/pull/13203#discussion_r476650361
##
File path: docs/dev/python/getting-started/tutorial/datastream_tutorial.md
##
@@ -0,0 +1,126 @@
+---
+title: "Python DataStream API Tutorial"
+nav-pa
AHeise commented on a change in pull request #13228:
URL: https://github.com/apache/flink/pull/13228#discussion_r476678903
##
File path:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/StreamTaskNetworkInput.java
##
@@ -159,10 +158,12 @@ public InputSt
AHeise commented on a change in pull request #13228:
URL: https://github.com/apache/flink/pull/13228#discussion_r476683415
##
File path:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/CheckpointBarrierUnaligner.java
##
@@ -92,306 +90,173 @@
flinkbot edited a comment on pull request #13242:
URL: https://github.com/apache/flink/pull/13242#issuecomment-680108384
## CI report:
* fc6dc041ef06000c57767f9665c34ecc70cff6da Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
[
https://issues.apache.org/jira/browse/FLINK-18546?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17184742#comment-17184742
]
Chesnay Schepler commented on FLINK-18546:
--
How would this work in terms of bac
[
https://issues.apache.org/jira/browse/FLINK-18192?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17183877#comment-17183877
]
Chesnay Schepler edited comment on FLINK-18192 at 8/25/20, 9:31 PM:
--
walterddr commented on a change in pull request #13163:
URL: https://github.com/apache/flink/pull/13163#discussion_r476778503
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/management/JMXService.java
##
@@ -85,6 +86,9 @@ private static JMXServer
startJMXSe
zentol commented on a change in pull request #13163:
URL: https://github.com/apache/flink/pull/13163#discussion_r476645574
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/management/JMXService.java
##
@@ -85,6 +86,9 @@ private static JMXServer
startJMXServe
zentol commented on a change in pull request #13163:
URL: https://github.com/apache/flink/pull/13163#discussion_r476790261
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/management/JMXService.java
##
@@ -85,6 +86,9 @@ private static JMXServer
startJMXServe
hequn8128 commented on pull request #13236:
URL: https://github.com/apache/flink/pull/13236#issuecomment-680393618
@shuiqiangchen Thanks a lot for fixing the bug. LGTM.
This is an automated message from the Apache Git Service
hequn8128 merged pull request #13236:
URL: https://github.com/apache/flink/pull/13236
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 t
[
https://issues.apache.org/jira/browse/FLINK-19041?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hequn Cheng closed FLINK-19041.
---
Resolution: Resolved
> Add dependency management for ConnectedStream in Python DataStream API.
> ---
[
https://issues.apache.org/jira/browse/FLINK-19041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17184825#comment-17184825
]
Hequn Cheng commented on FLINK-19041:
-
Resolved in 1.12.0 via 66797ac6352c38c98e310f
xintongsong commented on a change in pull request #13186:
URL: https://github.com/apache/flink/pull/13186#discussion_r476973166
##
File path:
flink-kubernetes/src/main/java/org/apache/flink/kubernetes/KubernetesResourceManagerDriver.java
##
@@ -0,0 +1,325 @@
+/*
+ * Licensed t
xintongsong commented on a change in pull request #13186:
URL: https://github.com/apache/flink/pull/13186#discussion_r476973166
##
File path:
flink-kubernetes/src/main/java/org/apache/flink/kubernetes/KubernetesResourceManagerDriver.java
##
@@ -0,0 +1,325 @@
+/*
+ * Licensed t
xintongsong commented on a change in pull request #13186:
URL: https://github.com/apache/flink/pull/13186#discussion_r476975877
##
File path:
flink-kubernetes/src/main/java/org/apache/flink/kubernetes/KubernetesResourceManagerDriver.java
##
@@ -0,0 +1,301 @@
+/*
+ * Licensed t
xintongsong commented on a change in pull request #13186:
URL: https://github.com/apache/flink/pull/13186#discussion_r476986171
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/active/AbstractResourceManagerDriver.java
##
@@ -0,0 +1,76 @@
+/*
xintongsong commented on a change in pull request #13186:
URL: https://github.com/apache/flink/pull/13186#discussion_r476988674
##
File path:
flink-kubernetes/src/main/java/org/apache/flink/kubernetes/KubernetesResourceManagerDriver.java
##
@@ -0,0 +1,301 @@
+/*
+ * Licensed t
xintongsong commented on a change in pull request #13186:
URL: https://github.com/apache/flink/pull/13186#discussion_r476996403
##
File path:
flink-kubernetes/src/main/java/org/apache/flink/kubernetes/KubernetesResourceManagerDriver.java
##
@@ -0,0 +1,301 @@
+/*
+ * Licensed t
xintongsong commented on pull request #13186:
URL: https://github.com/apache/flink/pull/13186#issuecomment-680452263
Thanks for the review, @tillrohrmann.
I replied about the `flinkClientConfig`. The rest of the comments are
addressed.
--
[
https://issues.apache.org/jira/browse/FLINK-19025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17184885#comment-17184885
]
McClone commented on FLINK-19025:
-
Rui Li , Now i use hive connector , but flink-hive n
flinkbot edited a comment on pull request #13186:
URL: https://github.com/apache/flink/pull/13186#issuecomment-675299227
## CI report:
* 63c2f658cc309661c434451a5d8c0b38d2e748d3 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
[
https://issues.apache.org/jira/browse/FLINK-19025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17184887#comment-17184887
]
McClone commented on FLINK-19025:
-
It really has problems.Flink hive Code use some hive
Fin-chan opened a new pull request #13243:
URL: https://github.com/apache/flink/pull/13243
Fix Table API renameColumns method annotation error
## What is the purpose of the change
*(For example: This pull request makes task deployment go through the blob
server, rather tha
[
https://issues.apache.org/jira/browse/FLINK-18992?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-18992:
---
Labels: pull-request-available (was: )
> Table API renameColumns method annotation error
>
flinkbot commented on pull request #13243:
URL: https://github.com/apache/flink/pull/13243#issuecomment-680478070
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
zhijiangW commented on a change in pull request #2:
URL: https://github.com/apache/flink-benchmarks/pull/2#discussion_r477008616
##
File path:
src/main/java/org/apache/flink/benchmark/RemoteChannelThroughputBenchmark.java
##
@@ -48,6 +49,9 @@
private MiniCluster miniClu
flinkbot commented on pull request #13243:
URL: https://github.com/apache/flink/pull/13243#issuecomment-680489296
## CI report:
* 7abb7dec5769d7d9569b17de97c477c989f67ed2 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot r
flinkbot edited a comment on pull request #13186:
URL: https://github.com/apache/flink/pull/13186#issuecomment-675299227
## CI report:
* 63c2f658cc309661c434451a5d8c0b38d2e748d3 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
zhijiangW commented on a change in pull request #2:
URL: https://github.com/apache/flink-benchmarks/pull/2#discussion_r477009866
##
File path:
src/main/java/org/apache/flink/benchmark/RemoteChannelThroughputBenchmark.java
##
@@ -80,6 +84,7 @@ public void remoteRebalance(FlinkE
flinkbot edited a comment on pull request #13243:
URL: https://github.com/apache/flink/pull/13243#issuecomment-680489296
## CI report:
* 7abb7dec5769d7d9569b17de97c477c989f67ed2 Azure:
[PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
[
https://issues.apache.org/jira/browse/FLINK-18333?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-18333:
---
Labels: pull-request-available test-stability (was: test-stability)
> UnsignedTypeConversio
leonardBang opened a new pull request #13244:
URL: https://github.com/apache/flink/pull/13244
## What is the purpose of the change
* This pull request fix up unstable test UnsignedTypeConversionITCase.
## Brief change log
- Avoid using MariaDB4jRule to create a DB
flinkbot commented on pull request #13244:
URL: https://github.com/apache/flink/pull/13244#issuecomment-680526208
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 commented on pull request #13244:
URL: https://github.com/apache/flink/pull/13244#issuecomment-680535784
## CI report:
* f5fee133d28436ab73b03d05b1f6fadc8648f5d0 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot r
zhuxiaoshang commented on a change in pull request #13225:
URL: https://github.com/apache/flink/pull/13225#discussion_r477020865
##
File path: docs/dev/user_defined_functions.zh.md
##
@@ -147,95 +142,75 @@ data.map (new RichMapFunction[String, Int] {
-Rich functions provi
zhuxiaoshang commented on pull request #13225:
URL: https://github.com/apache/flink/pull/13225#issuecomment-680556966
Thanks for your review @RocMarshal.I have made some changes according to
your suggestions.
This is an auto
[
https://issues.apache.org/jira/browse/FLINK-19025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17184918#comment-17184918
]
Rui Li commented on FLINK-19025:
Hey [~McClone], are you writing streaming data into hiv
flinkbot edited a comment on pull request #13244:
URL: https://github.com/apache/flink/pull/13244#issuecomment-680535784
## CI report:
* f5fee133d28436ab73b03d05b1f6fadc8648f5d0 Azure:
[PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #13225:
URL: https://github.com/apache/flink/pull/13225#issuecomment-678953566
## CI report:
* 40658a82560ebc79ee2047a789db4fa003115099 Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
[
https://issues.apache.org/jira/browse/FLINK-19022?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17184921#comment-17184921
]
tartarus commented on FLINK-19022:
--
[~trohrmann] I want to confirm the little details.
flinkbot edited a comment on pull request #13225:
URL: https://github.com/apache/flink/pull/13225#issuecomment-678953566
## CI report:
* 40658a82560ebc79ee2047a789db4fa003115099 Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
[
https://issues.apache.org/jira/browse/FLINK-19025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17184946#comment-17184946
]
McClone commented on FLINK-19025:
-
Exception in thread "main" java.lang.NoClassDefFoundE
[
https://issues.apache.org/jira/browse/FLINK-19025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17184947#comment-17184947
]
Rui Li commented on FLINK-19025:
[~McClone] The stacktrace indicates you're writing stre
billyrrr commented on pull request #131:
URL: https://github.com/apache/flink-statefun/pull/131#issuecomment-680671983
Hi, @carp84 Thank you for the review.
I think that "stateful functions" should be translated to chinese to promote
communications within people who primarily speak
flinkbot edited a comment on pull request #13225:
URL: https://github.com/apache/flink/pull/13225#issuecomment-678953566
## CI report:
* 6bfd27b44774c770a2d28ee9ca1bde0e11bfbe29 Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
[
https://issues.apache.org/jira/browse/FLINK-11712?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
godfrey he closed FLINK-11712.
--
Resolution: Resolved
> Add cost model for both batch and streaming
> -
klion26 commented on a change in pull request #13212:
URL: https://github.com/apache/flink/pull/13212#discussion_r477046283
##
File path: docs/monitoring/historyserver.zh.md
##
@@ -22,62 +22,67 @@ specific language governing permissions and limitations
under the License.
-->
leonardBang opened a new pull request #13245:
URL: https://github.com/apache/flink/pull/13245
## What is the purpose of the change
* This pull request add `scan.query` option for dynamic JDBC connector.
## Brief change log
- introduce option `scan.query`
- use
[
https://issues.apache.org/jira/browse/FLINK-17826?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-17826:
---
Labels: pull-request-available (was: )
> Add missing custom query support on new jdbc conne
flinkbot commented on pull request #13245:
URL: https://github.com/apache/flink/pull/13245#issuecomment-680682091
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-18992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17184956#comment-17184956
]
Fin-Chan commented on FLINK-18992:
--
hello,i create the pull request,please assign to me
[
https://issues.apache.org/jira/browse/FLINK-14087?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17031354#comment-17031354
]
Yun Gao edited comment on FLINK-14087 at 8/26/20, 6:28 AM:
---
Hi
Fin-chan commented on pull request #13243:
URL: https://github.com/apache/flink/pull/13243#issuecomment-680687797
@rmetzger Hello,According to the code contribution guide,I sign up the flink
jira and comment FLINK-18992,please assign to me. Thanks!
flinkbot commented on pull request #13245:
URL: https://github.com/apache/flink/pull/13245#issuecomment-680688340
## CI report:
* e46b2611459d09da2c220cb3fe2e8658c930a78f UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot r
[
https://issues.apache.org/jira/browse/FLINK-18695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17184963#comment-17184963
]
Zhijiang commented on FLINK-18695:
--
If I understood correctly, there seems three option
[
https://issues.apache.org/jira/browse/FLINK-19025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17184967#comment-17184967
]
McClone commented on FLINK-19025:
-
When will version 1.11.2 be released
> table sql wri
flinkbot edited a comment on pull request #13245:
URL: https://github.com/apache/flink/pull/13245#issuecomment-680688340
## CI report:
* e46b2611459d09da2c220cb3fe2e8658c930a78f Azure:
[PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
[
https://issues.apache.org/jira/browse/FLINK-19037?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-19037:
--
Fix Version/s: 1.12.0
> Introduce proper IO executor in Dispatcher
> -
201 - 273 of 273 matches
Mail list logo