[GitHub] [flink] flinkbot edited a comment on pull request #13402: [FLINK-19262][API/DataStream] Can not setParallelism for FLIP-27 source

flinkbot edited a comment on pull request #13402: URL: https://github.com/apache/flink/pull/13402#issuecomment-693424540 ## CI report: * f4a438df036bada30853b6450931e5b116dce9a1 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #13398: [FLINK-18604][connectors/HBase] HBase ConnectorDescriptor can not work in Table API

flinkbot edited a comment on pull request #13398: URL: https://github.com/apache/flink/pull/13398#issuecomment-693384597 ## CI report: * 09f58aeb9ac653be17d8a9b5b6eaaee02e415ad2 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #13322: [FLINK-17480][kubernetes] Support running PyFlink on Kubernetes.

flinkbot edited a comment on pull request #13322: URL: https://github.com/apache/flink/pull/13322#issuecomment-686859976 ## CI report: * 2a006a5c9494d9ff910acb2ebbf135e4adc22029 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #13313: [FLINK-18722][mesos] Migrate MesosResourceManager to the new MesosResourceManagerDriver

flinkbot edited a comment on pull request #13313: URL: https://github.com/apache/flink/pull/13313#issuecomment-686326763 ## CI report: * c5d95b9560a4288f9a8248c66bef45531c685e56 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Updated] (FLINK-18974) Translate the 'User-Defined Functions' page of "Application Development's DataStream API" into Chinese

[ https://issues.apache.org/jira/browse/FLINK-18974?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-18974: --- Fix Version/s: 1.12.0 > Translate the 'User-Defined Functions' page of "Application Developm

[jira] [Commented] (FLINK-18974) Translate the 'User-Defined Functions' page of "Application Development's DataStream API" into Chinese

[ https://issues.apache.org/jira/browse/FLINK-18974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17197403#comment-17197403 ] Robert Metzger commented on FLINK-18974: Thanks a lot for the contribution. Merg

[jira] [Closed] (FLINK-18974) Translate the 'User-Defined Functions' page of "Application Development's DataStream API" into Chinese

[ https://issues.apache.org/jira/browse/FLINK-18974?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger closed FLINK-18974. -- Resolution: Fixed > Translate the 'User-Defined Functions' page of "Application Development's

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

rmetzger merged pull request #13225: URL: https://github.com/apache/flink/pull/13225 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

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

rmetzger commented on pull request #13225: URL: https://github.com/apache/flink/pull/13225#issuecomment-693925440 Thanks for the review! Merging ... This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink] klion26 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

klion26 commented on a change in pull request #13225: URL: https://github.com/apache/flink/pull/13225#discussion_r489984016 ## File path: docs/dev/user_defined_functions.zh.md ## @@ -147,95 +153,78 @@ data.map (new RichMapFunction[String, Int] { -Rich functions provide, i

[GitHub] [flink] flinkbot edited a comment on pull request #13404: [FLINK-16100][docs-zh]Translate "Reading & Writing Hive Tables" page …

flinkbot edited a comment on pull request #13404: URL: https://github.com/apache/flink/pull/13404#issuecomment-693785870 ## CI report: * c9569f50a4707d5fbd27ff15e2745e078d92e39d Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #13397: [FLINK-19178][runtime] Extend managed memory weight/fraction interfaces for various use cases.

flinkbot edited a comment on pull request #13397: URL: https://github.com/apache/flink/pull/13397#issuecomment-693261990 ## CI report: * b8e95c022986da9f0b0d1b18e205f7cbc05f51ab Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #13358: [FLINK-11779] CLI ignores -m parameter if high-availability is ZOOKEEPER

flinkbot edited a comment on pull request #13358: URL: https://github.com/apache/flink/pull/13358#issuecomment-689274090 ## CI report: * 30192c3868c507f128d525cfe4db23f573c9f22a Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-18222) "Avro Confluent Schema Registry nightly end-to-end test" unstable with "Kafka cluster did not start after 120 seconds"

[ https://issues.apache.org/jira/browse/FLINK-18222?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17197385#comment-17197385 ] Robert Metzger commented on FLINK-18222: I backported the fix to "release-1.11"

[jira] [Updated] (FLINK-18222) "Avro Confluent Schema Registry nightly end-to-end test" unstable with "Kafka cluster did not start after 120 seconds"

[ https://issues.apache.org/jira/browse/FLINK-18222?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-18222: --- Fix Version/s: 1.11.3 > "Avro Confluent Schema Registry nightly end-to-end test" unstable wi

[GitHub] [flink-web] zhuzhurk commented on pull request #377: Add Apache Flink release 1.11.2

zhuzhurk commented on pull request #377: URL: https://github.com/apache/flink-web/pull/377#issuecomment-693882177 Thanks for reviewing! @dianfu @zhijiangW The date is updated. Merging. This is an automated message from th

[GitHub] [flink-web] zhuzhurk merged pull request #377: Add Apache Flink release 1.11.2

zhuzhurk merged pull request #377: URL: https://github.com/apache/flink-web/pull/377 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

[GitHub] [flink] flinkbot edited a comment on pull request #13397: [FLINK-19178][runtime] Extend managed memory weight/fraction interfaces for various use cases.

flinkbot edited a comment on pull request #13397: URL: https://github.com/apache/flink/pull/13397#issuecomment-693261990 ## CI report: * b8e95c022986da9f0b0d1b18e205f7cbc05f51ab Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #13358: [FLINK-11779] CLI ignores -m parameter if high-availability is ZOOKEEPER

flinkbot edited a comment on pull request #13358: URL: https://github.com/apache/flink/pull/13358#issuecomment-689274090 ## CI report: * 30192c3868c507f128d525cfe4db23f573c9f22a Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #13397: [FLINK-19178][runtime] Extend managed memory weight/fraction interfaces for various use cases.

flinkbot edited a comment on pull request #13397: URL: https://github.com/apache/flink/pull/13397#issuecomment-693261990 ## CI report: * b8e95c022986da9f0b0d1b18e205f7cbc05f51ab Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #13311: [FLINK-18721] Migrate YarnResourceManager to the new YarnResourceManagerDriver

flinkbot edited a comment on pull request #13311: URL: https://github.com/apache/flink/pull/13311#issuecomment-686196434 ## CI report: * b7660009b48d48261b767855d8973c63741ab493 UNKNOWN * f16d78f22d3d66e763f5629a377936bcb20b80c4 UNKNOWN * c9a880c2279b909d953bdef26a5f532a4fd6

[GitHub] [flink] flinkbot edited a comment on pull request #13375: [FLINK-18815][filesystems][tests] Join SafetyNetCloseableRegistry's reaper thread before assertion

flinkbot edited a comment on pull request #13375: URL: https://github.com/apache/flink/pull/13375#issuecomment-691410175 ## CI report: * 0e3916e68d38b432ebc33248d3a1ce7f7213b1f8 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] danny0405 commented on pull request #13291: [FLINK-18988][table] Continuous query with LATERAL and LIMIT produces…

danny0405 commented on pull request #13291: URL: https://github.com/apache/flink/pull/13291#issuecomment-693799225 > I'm trying to base an example on this PR. But the results differ between batch and streaming mode. It seems that the batch mode now outputs the global maximum. The pa

[GitHub] [flink] flinkbot edited a comment on pull request #13402: [FLINK-19262][API/DataStream] Can not setParallelism for FLIP-27 source

flinkbot edited a comment on pull request #13402: URL: https://github.com/apache/flink/pull/13402#issuecomment-693424540 ## CI report: * 4b7f5b86b91caffdb8436913467d165254000745 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #13311: [FLINK-18721] Migrate YarnResourceManager to the new YarnResourceManagerDriver

flinkbot edited a comment on pull request #13311: URL: https://github.com/apache/flink/pull/13311#issuecomment-686196434 ## CI report: * b7660009b48d48261b767855d8973c63741ab493 UNKNOWN * f16d78f22d3d66e763f5629a377936bcb20b80c4 UNKNOWN * c9a880c2279b909d953bdef26a5f532a4fd6

[jira] [Commented] (FLINK-19264) Identical jobs cannot be run concurrently

[ https://issues.apache.org/jira/browse/FLINK-19264?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17197360#comment-17197360 ] Zhu Zhu commented on FLINK-19264: - Thanks for reporting and investigating this issue! I

[GitHub] [flink] flinkbot edited a comment on pull request #13404: [FLINK-16100][docs-zh]Translate "Reading & Writing Hive Tables" page …

flinkbot edited a comment on pull request #13404: URL: https://github.com/apache/flink/pull/13404#issuecomment-693785870 ## CI report: * c9569f50a4707d5fbd27ff15e2745e078d92e39d Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #13397: [FLINK-19178][runtime] Extend managed memory weight/fraction interfaces for various use cases.

flinkbot edited a comment on pull request #13397: URL: https://github.com/apache/flink/pull/13397#issuecomment-693261990 ## CI report: * 1e0209f0df58ecdc3460d426262fc89d035b83f6 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #13371: [FLINK-17879][python] update Python row serializer to support RowKind

flinkbot edited a comment on pull request #13371: URL: https://github.com/apache/flink/pull/13371#issuecomment-690084042 ## CI report: * 6aaa5136a260683572b62d428f54678d9454e0c1 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Comment Edited] (FLINK-19265) Simplify handling of 'NoMoreSplitsEvent'

[ https://issues.apache.org/jira/browse/FLINK-19265?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17197346#comment-17197346 ] Jiangjie Qin edited comment on FLINK-19265 at 9/17/20, 3:32 AM: --

[jira] [Commented] (FLINK-19265) Simplify handling of 'NoMoreSplitsEvent'

[ https://issues.apache.org/jira/browse/FLINK-19265?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17197346#comment-17197346 ] Jiangjie Qin commented on FLINK-19265: -- Thanks for the suggestion, Stephan. I think

[GitHub] [flink] flinkbot commented on pull request #13404: [FLINK-16100][docs-zh]Translate "Reading & Writing Hive Tables" page …

flinkbot commented on pull request #13404: URL: https://github.com/apache/flink/pull/13404#issuecomment-693785870 ## CI report: * c9569f50a4707d5fbd27ff15e2745e078d92e39d UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot edited a comment on pull request #13398: [FLINK-18604][connectors/HBase] HBase ConnectorDescriptor can not work in Table API

flinkbot edited a comment on pull request #13398: URL: https://github.com/apache/flink/pull/13398#issuecomment-693384597 ## CI report: * 462b148cfa64be886adaa5d3bdd1b8b01ba258b2 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #13402: [FLINK-19262][API/DataStream] Can not setParallelism for FLIP-27 source

flinkbot edited a comment on pull request #13402: URL: https://github.com/apache/flink/pull/13402#issuecomment-693424540 ## CI report: * 4b7f5b86b91caffdb8436913467d165254000745 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #13397: [FLINK-19178][runtime] Extend managed memory weight/fraction interfaces for various use cases.

flinkbot edited a comment on pull request #13397: URL: https://github.com/apache/flink/pull/13397#issuecomment-693261990 ## CI report: * 1e0209f0df58ecdc3460d426262fc89d035b83f6 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #13371: [FLINK-17879][python] update Python row serializer to support RowKind

flinkbot edited a comment on pull request #13371: URL: https://github.com/apache/flink/pull/13371#issuecomment-690084042 ## CI report: * 6aaa5136a260683572b62d428f54678d9454e0c1 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Assigned] (FLINK-19179) Implement the managed memory fraction calculation logic

[ https://issues.apache.org/jira/browse/FLINK-19179?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reassigned FLINK-19179: Assignee: Xintong Song > Implement the managed memory fraction calculation logic > --

[GitHub] [flink] meiminda353690383 commented on pull request #11911: [FLINK-16100][docs-zh]Translate "Reading & Writing Hive Tables" page …

meiminda353690383 commented on pull request #11911: URL: https://github.com/apache/flink/pull/11911#issuecomment-693783938 I have resubmitted a pull request https://github.com/apache/flink/pull/13404/commits This is an autom

[GitHub] [flink] meiminda353690383 closed pull request #11911: [FLINK-16100][docs-zh]Translate "Reading & Writing Hive Tables" page …

meiminda353690383 closed pull request #11911: URL: https://github.com/apache/flink/pull/11911 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

[GitHub] [flink] flinkbot commented on pull request #13404: [FLINK-16100][docs-zh]Translate "Reading & Writing Hive Tables" page …

flinkbot commented on pull request #13404: URL: https://github.com/apache/flink/pull/13404#issuecomment-693782320 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] meiminda353690383 opened a new pull request #13404: [FLINK-16100][docs-zh]Translate "Reading & Writing Hive Tables" page …

meiminda353690383 opened a new pull request #13404: URL: https://github.com/apache/flink/pull/13404 …of "Hive Integration" into Chinese ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob server, rather than t

[GitHub] [flink] xintongsong commented on pull request #13397: [FLINK-19178][runtime] Extend managed memory weight/fraction interfaces for various use cases.

xintongsong commented on pull request #13397: URL: https://github.com/apache/flink/pull/13397#issuecomment-693780307 Thanks for the review, @KarmaGYZ. Comments addressed. This is an automated message from the Apache Git Servi

[GitHub] [flink] xintongsong commented on a change in pull request #13397: [FLINK-19178][runtime] Extend managed memory weight/fraction interfaces for various use cases.

xintongsong commented on a change in pull request #13397: URL: https://github.com/apache/flink/pull/13397#discussion_r489915944 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamingJobGraphGenerator.java ## @@ -849,26 +843,23 @@ privat

[GitHub] [flink] pyscala commented on a change in pull request #13402: [FLINK-19262][API/DataStream] Can not setParallelism for FLIP-27 source

pyscala commented on a change in pull request #13402: URL: https://github.com/apache/flink/pull/13402#discussion_r489915990 ## File path: flink-streaming-java/src/test/java/org/apache/flink/streaming/api/datastream/DataStreamSourceTest.java ## @@ -0,0 +1,53 @@ +/* + * Licensed

[jira] [Created] (FLINK-19267) Calculate managed memory fractions for fine grained resource specs

Xintong Song created FLINK-19267: Summary: Calculate managed memory fractions for fine grained resource specs Key: FLINK-19267 URL: https://issues.apache.org/jira/browse/FLINK-19267 Project: Flink

[GitHub] [flink] flinkbot edited a comment on pull request #13402: [FLINK-19262][API/DataStream] Can not setParallelism for FLIP-27 source

flinkbot edited a comment on pull request #13402: URL: https://github.com/apache/flink/pull/13402#issuecomment-693424540 ## CI report: * 4b7f5b86b91caffdb8436913467d165254000745 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #13398: [FLINK-18604][connectors/HBase] HBase ConnectorDescriptor can not work in Table API

flinkbot edited a comment on pull request #13398: URL: https://github.com/apache/flink/pull/13398#issuecomment-693384597 ## CI report: * 462b148cfa64be886adaa5d3bdd1b8b01ba258b2 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] xintongsong commented on a change in pull request #13397: [FLINK-19178][runtime] Extend managed memory weight/fraction interfaces for various use cases.

xintongsong commented on a change in pull request #13397: URL: https://github.com/apache/flink/pull/13397#discussion_r489912221 ## File path: flink-core/src/main/java/org/apache/flink/configuration/TaskManagerOptions.java ## @@ -401,6 +403,22 @@ .withDe

[GitHub] [flink] flinkbot edited a comment on pull request #11911: [FLINK-16100][docs-zh]Translate "Reading & Writing Hive Tables" page …

flinkbot edited a comment on pull request #11911: URL: https://github.com/apache/flink/pull/11911#issuecomment-619396940 ## CI report: * 52876598cd1fc4df85c3bc8f15063897be98feb6 UNKNOWN * 77d2fcaf3976761d009dd25e657601222521388e UNKNOWN * cb944914a96f89f90317456c5d153340a0e1

[jira] [Assigned] (FLINK-19258) Fix the wrong example of "csv.line-delimiter" in CSV documentation

[ https://issues.apache.org/jira/browse/FLINK-19258?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-19258: --- Assignee: dalongliu > Fix the wrong example of "csv.line-delimiter" in CSV documentation >

[jira] [Commented] (FLINK-19098) Make Rowdata converters public

[ https://issues.apache.org/jira/browse/FLINK-19098?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17197335#comment-17197335 ] Jark Wu commented on FLINK-19098: - Thanks for the reminder and sorry for the delay [~Bri

[GitHub] [flink] flinkbot edited a comment on pull request #13402: [FLINK-19262][API/DataStream] Can not setParallelism for FLIP-27 source

flinkbot edited a comment on pull request #13402: URL: https://github.com/apache/flink/pull/13402#issuecomment-693424540 ## CI report: * 4b7f5b86b91caffdb8436913467d165254000745 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] xintongsong commented on a change in pull request #13397: [FLINK-19178][runtime] Extend managed memory weight/fraction interfaces for various use cases.

xintongsong commented on a change in pull request #13397: URL: https://github.com/apache/flink/pull/13397#discussion_r489903233 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamNode.java ## @@ -49,6 +48,8 @@ @Internal public class S

[GitHub] [flink] pyscala removed a comment on pull request #13398: [FLINK-18604][connectors/HBase] HBase ConnectorDescriptor can not work in Table API

pyscala removed a comment on pull request #13398: URL: https://github.com/apache/flink/pull/13398#issuecomment-693351525 cc @JingsongLi , Looking forward to your reply This is an automated message from the Apache Git Service.

[GitHub] [flink] leonardBang commented on pull request #13128: [FLINK-18795][hbase] Support for HBase 2

leonardBang commented on pull request #13128: URL: https://github.com/apache/flink/pull/13128#issuecomment-693772490 > We will run some further cluster tests with this and after that I would like to merge it tomorrow if no other objections. > @leonardBang do you have time to review it?

[GitHub] [flink] xintongsong commented on a change in pull request #13397: [FLINK-19178][runtime] Extend managed memory weight/fraction interfaces for various use cases.

xintongsong commented on a change in pull request #13397: URL: https://github.com/apache/flink/pull/13397#discussion_r489895561 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamingJobGraphGenerator.java ## @@ -177,11 +178,13 @@ privat

[jira] [Commented] (FLINK-16947) ArtifactResolutionException: Could not transfer artifact. Entry [...] has not been leased from this pool

[ https://issues.apache.org/jira/browse/FLINK-16947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17197332#comment-17197332 ] Dian Fu commented on FLINK-16947: - https://dev.azure.com/apache-flink/apache-flink/_buil

[jira] [Commented] (FLINK-18222) "Avro Confluent Schema Registry nightly end-to-end test" unstable with "Kafka cluster did not start after 120 seconds"

[ https://issues.apache.org/jira/browse/FLINK-18222?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17197331#comment-17197331 ] Dian Fu commented on FLINK-18222: - Instance on 1.11: [https://dev.azure.com/apache-flink

[GitHub] [flink] JingsongLi commented on a change in pull request #13402: [FLINK-19262][API/DataStream] Can not setParallelism for FLIP-27 source

JingsongLi commented on a change in pull request #13402: URL: https://github.com/apache/flink/pull/13402#discussion_r489892921 ## File path: flink-streaming-java/src/test/java/org/apache/flink/streaming/api/datastream/DataStreamSourceTest.java ## @@ -0,0 +1,53 @@ +/* + * Licen

[GitHub] [flink] pyscala commented on a change in pull request #13402: [FLINK-19262][API/DataStream] Can not setParallelism for FLIP-27 source

pyscala commented on a change in pull request #13402: URL: https://github.com/apache/flink/pull/13402#discussion_r489892331 ## File path: flink-streaming-java/src/test/java/org/apache/flink/streaming/api/datastream/DataStreamSourceTest.java ## @@ -0,0 +1,53 @@ +/* + * Licensed

[GitHub] [flink] flinkbot edited a comment on pull request #13313: [FLINK-18722][mesos] Migrate MesosResourceManager to the new MesosResourceManagerDriver

flinkbot edited a comment on pull request #13313: URL: https://github.com/apache/flink/pull/13313#issuecomment-686326763 ## CI report: * 33ea3fa14ddf2ead07a9f0b29ad60a057a474a75 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] xintongsong commented on a change in pull request #13397: [FLINK-19178][runtime] Extend managed memory weight/fraction interfaces for various use cases.

xintongsong commented on a change in pull request #13397: URL: https://github.com/apache/flink/pull/13397#discussion_r489890377 ## File path: flink-core/src/main/java/org/apache/flink/api/dag/Transformation.java ## @@ -139,12 +142,12 @@ public static int getNewNodeId() {

[GitHub] [flink] xintongsong commented on a change in pull request #13397: [FLINK-19178][runtime] Extend managed memory weight/fraction interfaces for various use cases.

xintongsong commented on a change in pull request #13397: URL: https://github.com/apache/flink/pull/13397#discussion_r489890553 ## File path: flink-core/src/main/java/org/apache/flink/api/dag/Transformation.java ## @@ -139,12 +142,12 @@ public static int getNewNodeId() {

[GitHub] [flink] lsyldliu commented on pull request #11830: [FLINK-17096] [table] Support state ttl for Mini-Batch Group Agg using StateTtlConfig

lsyldliu commented on pull request #11830: URL: https://github.com/apache/flink/pull/11830#issuecomment-693767869 @wuchong I have updated the code, azure test passed, you can help review it again! This is an automated messag

[GitHub] [flink] xintongsong commented on a change in pull request #13397: [FLINK-19178][runtime] Extend managed memory weight/fraction interfaces for various use cases.

xintongsong commented on a change in pull request #13397: URL: https://github.com/apache/flink/pull/13397#discussion_r489886220 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamingJobGraphGenerator.java ## @@ -849,26 +843,23 @@ privat

[jira] [Commented] (FLINK-19264) Identical jobs cannot be run concurrently

[ https://issues.apache.org/jira/browse/FLINK-19264?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17197326#comment-17197326 ] Yangze Guo commented on FLINK-19264: Thanks for the analysis and suggestion, [~chesn

[GitHub] [flink] flinkbot edited a comment on pull request #13313: [FLINK-18722][mesos] Migrate MesosResourceManager to the new MesosResourceManagerDriver

flinkbot edited a comment on pull request #13313: URL: https://github.com/apache/flink/pull/13313#issuecomment-686326763 ## CI report: * 33ea3fa14ddf2ead07a9f0b29ad60a057a474a75 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-17295) Refactor the ExecutionAttemptID to consist of ExecutionVertexID and attemptNumber

[ https://issues.apache.org/jira/browse/FLINK-17295?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17197322#comment-17197322 ] Yangze Guo commented on FLINK-17295: Thanks for the pointer, [~sewen]. I think inclu

[GitHub] [flink] xintongsong commented on pull request #13313: [FLINK-18722][mesos] Migrate MesosResourceManager to the new MesosResourceManagerDriver

xintongsong commented on pull request #13313: URL: https://github.com/apache/flink/pull/13313#issuecomment-693760238 Rebase to resolve conflicts. This is an automated message from the Apache Git Service. To respond to the mes

[GitHub] [flink] flinkbot edited a comment on pull request #13403: [Hotfix][Docs] Update rest_v1_dispathcer.html

flinkbot edited a comment on pull request #13403: URL: https://github.com/apache/flink/pull/13403#issuecomment-693610429 ## CI report: * 0f52d8c1b46c31f08e710a157822b93d15027b48 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Assigned] (FLINK-19184) Add Batch Physical Pandas Group Aggregate Rule and RelNode

[ https://issues.apache.org/jira/browse/FLINK-19184?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-19184: --- Assignee: Huang Xingbo > Add Batch Physical Pandas Group Aggregate Rule and RelNode > -

[jira] [Assigned] (FLINK-19186) Add Python building blocks to make sure the basic functionality of Pandas Batch Group Aggregation could work

[ https://issues.apache.org/jira/browse/FLINK-19186?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-19186: --- Assignee: Huang Xingbo > Add Python building blocks to make sure the basic functionality of Pandas

[jira] [Closed] (FLINK-19173) Add Pandas Batch Group Aggregation Function Operator

[ https://issues.apache.org/jira/browse/FLINK-19173?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-19173. --- Resolution: Fixed master: 7925647e3ae67a0a8914b4eb1644c318023eeb88 > Add Pandas Batch Group Aggregation Fun

[GitHub] [flink] dianfu closed pull request #13369: [FLINK-19173][python] Introduce BatchArrowPythonGroupAggregateFunctionOperator

dianfu closed pull request #13369: URL: https://github.com/apache/flink/pull/13369 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

[jira] [Commented] (FLINK-19098) Make Rowdata converters public

[ https://issues.apache.org/jira/browse/FLINK-19098?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17197312#comment-17197312 ] Brian Zhou commented on FLINK-19098: I have raised a PR and left open for a week. It

[GitHub] [flink] flinkbot edited a comment on pull request #13357: [FLINK-19165] Refactor the UnilateralSortMerger

flinkbot edited a comment on pull request #13357: URL: https://github.com/apache/flink/pull/13357#issuecomment-689034696 ## CI report: * 756d84832df46992d406a579bd154dfc92c83e37 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #13375: [FLINK-18815][filesystems][tests] Join SafetyNetCloseableRegistry's reaper thread before assertion

flinkbot edited a comment on pull request #13375: URL: https://github.com/apache/flink/pull/13375#issuecomment-691410175 ## CI report: * c10af2d6ed4136ff9a8ae30ab0841343635bf0f4 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #13403: [Hotfix][Docs] Update rest_v1_dispathcer.html

flinkbot edited a comment on pull request #13403: URL: https://github.com/apache/flink/pull/13403#issuecomment-693610429 ## CI report: * 0f52d8c1b46c31f08e710a157822b93d15027b48 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #13375: [FLINK-18815][filesystems][tests] Join SafetyNetCloseableRegistry's reaper thread before assertion

flinkbot edited a comment on pull request #13375: URL: https://github.com/apache/flink/pull/13375#issuecomment-691410175 ## CI report: * c10af2d6ed4136ff9a8ae30ab0841343635bf0f4 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #13403: [Hotfix][Docs] Update rest_v1_dispathcer.html

flinkbot edited a comment on pull request #13403: URL: https://github.com/apache/flink/pull/13403#issuecomment-693610429 ## CI report: * 0f52d8c1b46c31f08e710a157822b93d15027b48 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] wangxlong commented on pull request #13403: [Hotfix][Docs] Update rest_v1_dispathcer.html

wangxlong commented on pull request #13403: URL: https://github.com/apache/flink/pull/13403#issuecomment-693720997 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message, pleas

[GitHub] [flink] flinkbot edited a comment on pull request #13357: [FLINK-19165] Refactor the UnilateralSortMerger

flinkbot edited a comment on pull request #13357: URL: https://github.com/apache/flink/pull/13357#issuecomment-689034696 ## CI report: * f48774d7b5e0a14f1e7270591481cc2f83316854 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #13357: [FLINK-19165] Refactor the UnilateralSortMerger

flinkbot edited a comment on pull request #13357: URL: https://github.com/apache/flink/pull/13357#issuecomment-689034696 ## CI report: * 87c7f63785dda33d0a9bd210ff4d49962abbe638 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #13392: [FLINK-18713][table-planner-blink] Change duration configOption to duration type

flinkbot edited a comment on pull request #13392: URL: https://github.com/apache/flink/pull/13392#issuecomment-692540614 ## CI report: * f3af04d02472f93c5d49e0262ce7957cdd910707 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #13228: [FLINK-19026][network] Improve threading model of CheckpointBarrierUnaligner

flinkbot edited a comment on pull request #13228: URL: https://github.com/apache/flink/pull/13228#issuecomment-679099456 ## CI report: * d141f10ef060063162dc073b1cd66729f5f75a3b UNKNOWN * 89b0550c7b223f304b67a6f64dfc4252509eb76e UNKNOWN * 834c28da93d4b24e562e017979b483e288db

[GitHub] [flink] flinkbot edited a comment on pull request #13357: [FLINK-19165] Refactor the UnilateralSortMerger

flinkbot edited a comment on pull request #13357: URL: https://github.com/apache/flink/pull/13357#issuecomment-689034696 ## CI report: * 87c7f63785dda33d0a9bd210ff4d49962abbe638 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #13228: [FLINK-19026][network] Improve threading model of CheckpointBarrierUnaligner

flinkbot edited a comment on pull request #13228: URL: https://github.com/apache/flink/pull/13228#issuecomment-679099456 ## CI report: * d141f10ef060063162dc073b1cd66729f5f75a3b UNKNOWN * 89b0550c7b223f304b67a6f64dfc4252509eb76e UNKNOWN * a1fb1c3114305ed5fce898dfcc03abed4d69

[GitHub] [flink] flinkbot edited a comment on pull request #13403: [Hotfix][Docs] Update rest_v1_dispathcer.html

flinkbot edited a comment on pull request #13403: URL: https://github.com/apache/flink/pull/13403#issuecomment-693610429 ## CI report: * 0f52d8c1b46c31f08e710a157822b93d15027b48 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #13357: [FLINK-19165] Refactor the UnilateralSortMerger

flinkbot edited a comment on pull request #13357: URL: https://github.com/apache/flink/pull/13357#issuecomment-689034696 ## CI report: * 05cef2abaec734dddea631576862d7c374e320c7 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #13357: [FLINK-19165] Refactor the UnilateralSortMerger

flinkbot edited a comment on pull request #13357: URL: https://github.com/apache/flink/pull/13357#issuecomment-689034696 ## CI report: * 54ee6987c7054a42fa52d04ec61fae74a816792c Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #11830: [FLINK-17096] [table] Support state ttl for Mini-Batch Group Agg using StateTtlConfig

flinkbot edited a comment on pull request #11830: URL: https://github.com/apache/flink/pull/11830#issuecomment-616574921 ## CI report: * e1eaf8cc2cd85ba3bf7ee684663001783809c719 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-15467) Should wait for the end of the source thread during the Task cancellation

[ https://issues.apache.org/jira/browse/FLINK-15467?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17197216#comment-17197216 ] Jun Qin commented on FLINK-15467: - Great! Thanks [~AHeise] > Should wait for the end of

[GitHub] [flink] flinkbot edited a comment on pull request #13357: [FLINK-19165] Refactor the UnilateralSortMerger

flinkbot edited a comment on pull request #13357: URL: https://github.com/apache/flink/pull/13357#issuecomment-689034696 ## CI report: * 54ee6987c7054a42fa52d04ec61fae74a816792c Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #13403: [Hotfix][Docs] Update rest_v1_dispathcer.html

flinkbot edited a comment on pull request #13403: URL: https://github.com/apache/flink/pull/13403#issuecomment-693610429 ## CI report: * 0f52d8c1b46c31f08e710a157822b93d15027b48 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Resolved] (FLINK-15467) Should wait for the end of the source thread during the Task cancellation

[ https://issues.apache.org/jira/browse/FLINK-15467?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise resolved FLINK-15467. - Resolution: Fixed > Should wait for the end of the source thread during the Task cancellation >

[jira] [Assigned] (FLINK-15467) Should wait for the end of the source thread during the Task cancellation

[ https://issues.apache.org/jira/browse/FLINK-15467?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise reassigned FLINK-15467: --- Assignee: Roman Khachatryan > Should wait for the end of the source thread during the Task

[GitHub] [flink] flinkbot commented on pull request #13403: [Hotfix][Docs] Update rest_v1_dispathcer.html

flinkbot commented on pull request #13403: URL: https://github.com/apache/flink/pull/13403#issuecomment-693610429 ## CI report: * 0f52d8c1b46c31f08e710a157822b93d15027b48 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot edited a comment on pull request #13392: [FLINK-18713][table-planner-blink] Change duration configOption to duration type

flinkbot edited a comment on pull request #13392: URL: https://github.com/apache/flink/pull/13392#issuecomment-692540614 ## CI report: * Unknown: [CANCELED](TBD) * f3af04d02472f93c5d49e0262ce7957cdd910707 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620

[jira] [Commented] (FLINK-15467) Should wait for the end of the source thread during the Task cancellation

[ https://issues.apache.org/jira/browse/FLINK-15467?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17197200#comment-17197200 ] Arvid Heise commented on FLINK-15467: - Merged to release-1.10 a20fb4a796d8df91e4ebbc

[jira] [Updated] (FLINK-15467) Should wait for the end of the source thread during the Task cancellation

[ https://issues.apache.org/jira/browse/FLINK-15467?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-15467: Fix Version/s: 1.10.3 > Should wait for the end of the source thread during the Task cancellation

  1   2   3   4   >