[GitHub] [flink-training] alpinegizmo merged pull request #13: [FLINK-18630] Redo the LongRideAlerts solutions to cover a corner case

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

[GitHub] [flink] flinkbot edited a comment on pull request #13239: [FLINK-19021][network] Various cleanups and refactorings of the ResultPartition

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

[GitHub] [flink] zentol commented on a change in pull request #13163: [FLINK-16789][runtime] Support JMX RMI random port assign

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

[GitHub] [flink] AHeise commented on a change in pull request #13228: [FLINK-19026][network] Improve threading model of CheckpointBarrierUnaligner

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

[GitHub] [flink] AHeise commented on a change in pull request #13228: [FLINK-19026][network] Improve threading model of CheckpointBarrierUnaligner

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

[GitHub] [flink] AHeise commented on a change in pull request #13228: [FLINK-19026][network] Improve threading model of CheckpointBarrierUnaligner

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

[GitHub] [flink] AHeise commented on a change in pull request #13228: [FLINK-19026][network] Improve threading model of CheckpointBarrierUnaligner

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

[GitHub] [flink] AHeise commented on a change in pull request #13228: [FLINK-19026][network] Improve threading model of CheckpointBarrierUnaligner

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

[GitHub] [flink] AHeise commented on a change in pull request #13228: [FLINK-19026][network] Improve threading model of CheckpointBarrierUnaligner

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

[GitHub] [flink] AHeise commented on a change in pull request #13228: [FLINK-19026][network] Improve threading model of CheckpointBarrierUnaligner

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 @@ */

[GitHub] [flink] AHeise commented on a change in pull request #13228: [FLINK-19026][network] Improve threading model of CheckpointBarrierUnaligner

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

[GitHub] [flink] AHeise commented on a change in pull request #13228: [FLINK-19026][network] Improve threading model of CheckpointBarrierUnaligner

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 @@ */

[GitHub] [flink] AHeise commented on a change in pull request #13228: [FLINK-19026][network] Improve threading model of CheckpointBarrierUnaligner

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

[GitHub] [flink] AHeise commented on a change in pull request #13228: [FLINK-19026][network] Improve threading model of CheckpointBarrierUnaligner

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

[GitHub] [flink] morsapaes commented on a change in pull request #13203: [FLINK-18984][python][docs] Add tutorial documentation for Python DataStream API

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

[GitHub] [flink] AHeise commented on a change in pull request #13228: [FLINK-19026][network] Improve threading model of CheckpointBarrierUnaligner

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

[GitHub] [flink] AHeise commented on a change in pull request #13228: [FLINK-19026][network] Improve threading model of CheckpointBarrierUnaligner

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 @@

[GitHub] [flink] flinkbot edited a comment on pull request #13242: [FLINK-19009][metrics] Fixed the downtime metric issue and updated the comment

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

[jira] [Commented] (FLINK-18546) Upgrade to Kafka Schema Registry Client 5.5.0

[ 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

[jira] [Comment Edited] (FLINK-18192) Upgrade to Avro version 1.9.2 from 1.8.2

[ 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: --

[GitHub] [flink] walterddr commented on a change in pull request #13163: [FLINK-16789][runtime] Support JMX RMI random port assign

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

[GitHub] [flink] zentol commented on a change in pull request #13163: [FLINK-16789][runtime] Support JMX RMI random port assign

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

[GitHub] [flink] zentol commented on a change in pull request #13163: [FLINK-16789][runtime] Support JMX RMI random port assign

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

[GitHub] [flink] hequn8128 commented on pull request #13236: [FLINK-19041][python] Add dependency management for ConnectedStream i…

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

[GitHub] [flink] hequn8128 merged pull request #13236: [FLINK-19041][python] Add dependency management for ConnectedStream i…

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

[jira] [Closed] (FLINK-19041) Add dependency management for ConnectedStream in Python DataStream API.

[ 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. > ---

[jira] [Commented] (FLINK-19041) 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

[GitHub] [flink] xintongsong commented on a change in pull request #13186: [FLINK-18720][k8s] Migrate KubernetesResourceManager to the new KubernetesResourceManagerDriver

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

[GitHub] [flink] xintongsong commented on a change in pull request #13186: [FLINK-18720][k8s] Migrate KubernetesResourceManager to the new KubernetesResourceManagerDriver

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

[GitHub] [flink] xintongsong commented on a change in pull request #13186: [FLINK-18720][k8s] Migrate KubernetesResourceManager to the new KubernetesResourceManagerDriver

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

[GitHub] [flink] xintongsong commented on a change in pull request #13186: [FLINK-18720][k8s] Migrate KubernetesResourceManager to the new KubernetesResourceManagerDriver

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 @@ +/*

[GitHub] [flink] xintongsong commented on a change in pull request #13186: [FLINK-18720][k8s] Migrate KubernetesResourceManager to the new KubernetesResourceManagerDriver

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

[GitHub] [flink] xintongsong commented on a change in pull request #13186: [FLINK-18720][k8s] Migrate KubernetesResourceManager to the new KubernetesResourceManagerDriver

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

[GitHub] [flink] xintongsong commented on pull request #13186: [FLINK-18720][k8s] Migrate KubernetesResourceManager to the new KubernetesResourceManagerDriver

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. --

[jira] [Commented] (FLINK-19025) table sql write orc file but hive2.1.1 can not read

[ 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

[GitHub] [flink] flinkbot edited a comment on pull request #13186: [FLINK-18720][k8s] Migrate KubernetesResourceManager to the new KubernetesResourceManagerDriver

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

[jira] [Commented] (FLINK-19025) table sql write orc file but hive2.1.1 can not read

[ 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

[GitHub] [flink] Fin-chan opened a new pull request #13243: [FLINK-18992][table] Fix Table API renameColumns method annotation error

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

[jira] [Updated] (FLINK-18992) Table API renameColumns method annotation error

[ 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 >

[GitHub] [flink] flinkbot commented on pull request #13243: [FLINK-18992][table] Fix 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

[GitHub] [flink-benchmarks] zhijiangW commented on a change in pull request #2: [FLINK-19003][checkpointing] Add micro-benchmark for unaligned checkpoints

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

[GitHub] [flink] flinkbot commented on pull request #13243: [FLINK-18992][table] Fix Table API renameColumns method annotation error

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

[GitHub] [flink] flinkbot edited a comment on pull request #13186: [FLINK-18720][k8s] Migrate KubernetesResourceManager to the new KubernetesResourceManagerDriver

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

[GitHub] [flink-benchmarks] zhijiangW commented on a change in pull request #2: [FLINK-19003][checkpointing] Add micro-benchmark for unaligned checkpoints

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

[GitHub] [flink] flinkbot edited a comment on pull request #13243: [FLINK-18992][table] Fix Table API renameColumns method annotation error

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

[jira] [Updated] (FLINK-18333) UnsignedTypeConversionITCase failed caused by MariaDB4j "Asked to waitFor Program"

[ 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

[GitHub] [flink] leonardBang opened a new pull request #13244: [FLINK-18333][jdbc] UnsignedTypeConversionITCase failed caused by MariaDB4j "Asked to waitFor Program"

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

[GitHub] [flink] flinkbot commented on pull request #13244: [FLINK-18333][jdbc] UnsignedTypeConversionITCase failed caused by MariaDB4j "Asked to waitFor Program"

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

[GitHub] [flink] flinkbot commented on pull request #13244: [FLINK-18333][jdbc] UnsignedTypeConversionITCase failed caused by MariaDB4j "Asked to waitFor Program"

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

[GitHub] [flink] zhuxiaoshang commented on a change in pull request #13225: [FLINK-18974][docs-zh]Translate the 'User-Defined Functions' page of "Application Development's DataStream API" into Chinese

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

[GitHub] [flink] zhuxiaoshang commented on pull request #13225: [FLINK-18974][docs-zh]Translate the 'User-Defined Functions' page of "Application Development's DataStream API" into Chinese

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

[jira] [Commented] (FLINK-19025) table sql write orc file but hive2.1.1 can not read

[ 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

[GitHub] [flink] flinkbot edited a comment on pull request #13244: [FLINK-18333][jdbc] UnsignedTypeConversionITCase failed caused by MariaDB4j "Asked to waitFor Program"

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

[GitHub] [flink] flinkbot edited a comment on pull request #13225: [FLINK-18974][docs-zh]Translate the 'User-Defined Functions' page of "Application Development's DataStream API" into Chinese

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

[jira] [Commented] (FLINK-19022) AkkaRpcActor failed to start but no exception information

[ 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.

[GitHub] [flink] flinkbot edited a comment on pull request #13225: [FLINK-18974][docs-zh]Translate the 'User-Defined Functions' page of "Application Development's DataStream API" into Chinese

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

[jira] [Commented] (FLINK-19025) table sql write orc file but hive2.1.1 can not read

[ 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

[jira] [Commented] (FLINK-19025) table sql write orc file but hive2.1.1 can not read

[ 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

[GitHub] [flink-statefun] billyrrr commented on pull request #131: [FLINK-18968] Translate README.md to Chinese

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

[GitHub] [flink] flinkbot edited a comment on pull request #13225: [FLINK-18974][docs-zh]Translate the 'User-Defined Functions' page of "Application Development's DataStream API" into Chinese

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

[jira] [Closed] (FLINK-11712) Add cost model for both batch and streaming

[ 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 > -

[GitHub] [flink] klion26 commented on a change in pull request #13212: [FLINK-18973][docs-zh] Translate the 'History Server' page of 'Debugging & Monitoring' into Chinese

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. -->

[GitHub] [flink] leonardBang opened a new pull request #13245: [FLINK-17826][jdbc] Add missing custom query support on new jdbc connector

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

[jira] [Updated] (FLINK-17826) Add missing custom query support on new jdbc connector

[ 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

[GitHub] [flink] flinkbot commented on pull request #13245: [FLINK-17826][jdbc] Add missing custom query support on new jdbc connector

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

[jira] [Commented] (FLINK-18992) Table API renameColumns method annotation error

[ 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

[jira] [Comment Edited] (FLINK-14087) throws java.lang.ArrayIndexOutOfBoundsException when emiting the data using RebalancePartitioner.

[ 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

[GitHub] [flink] Fin-chan commented on pull request #13243: [FLINK-18992][table] Fix Table API renameColumns method annotation error

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!

[GitHub] [flink] flinkbot commented on pull request #13245: [FLINK-17826][jdbc] Add missing custom query support on new jdbc connector

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

[jira] [Commented] (FLINK-18695) Allow NettyBufferPool to allocate heap buffers

[ 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

[jira] [Commented] (FLINK-19025) table sql write orc file but hive2.1.1 can not read

[ 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

[GitHub] [flink] flinkbot edited a comment on pull request #13245: [FLINK-17826][jdbc] Add missing custom query support on new jdbc connector

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

[jira] [Updated] (FLINK-19037) Introduce proper IO executor in Dispatcher

[ 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 > -

<    1   2   3