[GitHub] [flink] flinkbot edited a comment on pull request #13152: [FLINK-18945][python] Support CoFlatMap for Python DataStream API

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

[GitHub] [flink] flinkbot commented on pull request #13152: [FLINK-18945][python] Support CoFlatMap for Python DataStream API

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

[GitHub] [flink] flinkbot commented on pull request #13152: [FLINK-18945][python] Support CoFlatMap for Python DataStream API

flinkbot commented on pull request #13152: URL: https://github.com/apache/flink/pull/13152#issuecomment-674355686 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] [Updated] (FLINK-18945) Support CoFlatMap for Python DataStream API

[ https://issues.apache.org/jira/browse/FLINK-18945?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-18945: --- Labels: pull-request-available (was: ) > Support CoFlatMap for Python DataStream API >

[GitHub] [flink] hequn8128 opened a new pull request #13152: [FLINK-18945][python] Support CoFlatMap for Python DataStream API

hequn8128 opened a new pull request #13152: URL: https://github.com/apache/flink/pull/13152 ## What is the purpose of the change This pull request adds CoFlatMapFunction for Python DataStream API. ## Brief change log - Add CoFlatMapFunction on DataStream.

[GitHub] [flink] flinkbot edited a comment on pull request #13151: [FLINK-18943][python] Support CoMapFunction for Python DataStream API

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

[GitHub] [flink] flinkbot commented on pull request #13151: [FLINK-18943][python] Support CoMapFunction for Python DataStream API

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

[GitHub] [flink] flinkbot commented on pull request #13151: [FLINK-18943][python] Support CoMapFunction for Python DataStream API

flinkbot commented on pull request #13151: URL: https://github.com/apache/flink/pull/13151#issuecomment-674349520 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] hequn8128 commented on pull request #13151: [FLINK-18943][python] Support CoMapFunction for Python DataStream API

hequn8128 commented on pull request #13151: URL: https://github.com/apache/flink/pull/13151#issuecomment-674349319 CC @shuiqiangchen This is an automated message from the Apache Git Service. To respond to the message, please

[jira] [Updated] (FLINK-18943) Support CoMapFunction for Python DataStream API

[ https://issues.apache.org/jira/browse/FLINK-18943?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-18943: --- Labels: pull-request-available (was: ) > Support CoMapFunction for Python DataStream API >

[GitHub] [flink] hequn8128 opened a new pull request #13151: [FLINK-18943][python] Support CoMapFunction for Python DataStream API

hequn8128 opened a new pull request #13151: URL: https://github.com/apache/flink/pull/13151 ## What is the purpose of the change This pull request adds CoMapFunction for Python DataStream API. ## Brief change log - Add connect() on DataStream. - Add CoMapF

[jira] [Updated] (FLINK-18945) Support CoFlatMap for Python DataStream API

[ https://issues.apache.org/jira/browse/FLINK-18945?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-18945: Summary: Support CoFlatMap for Python DataStream API (was: Support key_by() on ConnectedStreams f

[jira] [Created] (FLINK-18966) Support key_by() on ConnectedStreams for Python DataStream API

Hequn Cheng created FLINK-18966: --- Summary: Support key_by() on ConnectedStreams for Python DataStream API Key: FLINK-18966 URL: https://issues.apache.org/jira/browse/FLINK-18966 Project: Flink

[jira] [Updated] (FLINK-18943) Support CoMapFunction for Python DataStream API

[ https://issues.apache.org/jira/browse/FLINK-18943?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-18943: Summary: Support CoMapFunction for Python DataStream API (was: Support connect() operation for Py

[jira] [Commented] (FLINK-18202) Introduce Protobuf format

[ https://issues.apache.org/jira/browse/FLINK-18202?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17178143#comment-17178143 ] tartarus commented on FLINK-18202: -- Hi, all A little suggestion, I think it is necessa

[jira] [Issue Comment Deleted] (FLINK-18389) Translate all SQL connector pages into Chinese

[ https://issues.apache.org/jira/browse/FLINK-18389?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] HK updated FLINK-18389: --- Comment: was deleted (was: please assign to me, thanks:P) > Translate all SQL connector pages into Chinese > --

[GitHub] [flink] flinkbot edited a comment on pull request #11469: [FLINK-15299][test] Move ClientUtils#submitJob & ClientUtils#submitJobAndWaitForResult to test scope

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

[GitHub] [flink] flinkbot edited a comment on pull request #11469: [FLINK-15299][test] Move ClientUtils#submitJob & ClientUtils#submitJobAndWaitForResult to test scope

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

[jira] [Updated] (FLINK-18965) ExecutionContextTest.testCatalogs failed with "ClassNotFoundException: org.apache.hadoop.fs.BlockStoragePolicySpi"

[ https://issues.apache.org/jira/browse/FLINK-18965?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-18965: Labels: test-stability (was: ) > ExecutionContextTest.testCatalogs failed with "ClassNotFoundException:

[jira] [Created] (FLINK-18965) ExecutionContextTest.testCatalogs failed with "ClassNotFoundException: org.apache.hadoop.fs.BlockStoragePolicySpi"

Dian Fu created FLINK-18965: --- Summary: ExecutionContextTest.testCatalogs failed with "ClassNotFoundException: org.apache.hadoop.fs.BlockStoragePolicySpi" Key: FLINK-18965 URL: https://issues.apache.org/jira/browse/FLINK

[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=17178132#comment-17178132 ] Dian Fu commented on FLINK-16947: - [https://dev.azure.com/apache-flink/apache-flink/_bui

[jira] [Commented] (FLINK-17274) Maven: Premature end of Content-Length delimited message body

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

[jira] [Commented] (FLINK-18634) FlinkKafkaProducerITCase.testRecoverCommittedTransaction failed with "Timeout expired after 60000milliseconds while awaiting InitProducerId"

[ https://issues.apache.org/jira/browse/FLINK-18634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17178130#comment-17178130 ] Dian Fu commented on FLINK-18634: - Another instance on 1.11: [https://dev.azure.com/apac

[jira] [Closed] (FLINK-18956) StreamTask.invoke should catch Throwable instead of Exception

[ https://issues.apache.org/jira/browse/FLINK-18956?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-18956. --- Resolution: Fixed master: 14665dd468a638b6d6c5f5f241455c8d81825b76 release-1.11: 792855277be38fafed27a7aaa7c

[jira] [Commented] (FLINK-18891) flink job failed but yarn application still running via yarn-per-job mode

[ https://issues.apache.org/jira/browse/FLINK-18891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17178128#comment-17178128 ] happylife commented on FLINK-18891: --- Hi Peng,I try to set execution.attached: false in

[GitHub] [flink] TisonKun commented on pull request #11469: [FLINK-15299][test] Move ClientUtils#submitJob & ClientUtils#submitJobAndWaitForResult to test scope

TisonKun commented on pull request #11469: URL: https://github.com/apache/flink/pull/11469#issuecomment-674331726 @zentol @rmetzger the pr was rebased. I'm not sure if the ci cycle triggered. PTAL. This is an automated messa

[GitHub] [flink] flinkbot edited a comment on pull request #11469: [FLINK-15299][test] Move ClientUtils#submitJob & ClientUtils#submitJobAndWaitForResult to test scope

flinkbot edited a comment on pull request #11469: URL: https://github.com/apache/flink/pull/11469#issuecomment-601972922 ## CI report: * Unknown: [CANCELED](TBD) * 47e6ef886af7cb5e2d43dfb6ce3e4f533457172d UNKNOWN Bot commands The @flinkbot bot supports the fol

[GitHub] [flink] dianfu closed pull request #13145: [FLINK-18956][task] StreamTask.invoke should catch Throwable

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

[GitHub] [flink] TisonKun commented on pull request #11469: [FLINK-15299][test] Move ClientUtils#submitJob & ClientUtils#submitJobAndWaitForResult to test scope

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

[GitHub] [flink] dianfu commented on pull request #13145: [FLINK-18956][task] StreamTask.invoke should catch Throwable

dianfu commented on pull request #13145: URL: https://github.com/apache/flink/pull/13145#issuecomment-674330868 @pnowojski Thanks for the review. The e2e tests timeout and I think it's not related to this PR. All the other tests have passed. Merging... ---

[jira] [Commented] (FLINK-11086) Add support for Hadoop 3

[ https://issues.apache.org/jira/browse/FLINK-11086?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17178097#comment-17178097 ] Chesnay Schepler commented on FLINK-11086: -- [~satishsaley] Filesystems are supp

[jira] [Commented] (FLINK-18389) Translate all SQL connector pages into Chinese

[ https://issues.apache.org/jira/browse/FLINK-18389?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17178088#comment-17178088 ] HK commented on FLINK-18389: please assign to me, thanks:P > Translate all SQL connector pa

[jira] [Commented] (FLINK-18961) In the case of FlatMap linking map, if map returns null, an exception will be thrown in FlatMap

[ https://issues.apache.org/jira/browse/FLINK-18961?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17178007#comment-17178007 ] Kenneth William Krugler commented on FLINK-18961: - Hi [~chesnay] - the e

[jira] [Commented] (FLINK-15299) Move ClientUtils#submitJob & ClientUtils#submitJobAndWaitForResult to test scope

[ https://issues.apache.org/jira/browse/FLINK-15299?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17177993#comment-17177993 ] Zili Chen commented on FLINK-15299: --- OK. I will rebase the pull request in hours. > M

[jira] [Closed] (FLINK-18964) package org.apache.flink.sql.parser.impl does not exist

[ https://issues.apache.org/jira/browse/FLINK-18964?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-18964. Resolution: Not A Problem > package org.apache.flink.sql.parser.impl does not exist >

[jira] [Commented] (FLINK-18964) package org.apache.flink.sql.parser.impl does not exist

[ https://issues.apache.org/jira/browse/FLINK-18964?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17177967#comment-17177967 ] Dawid Wysakowicz commented on FLINK-18964: -- I assume you're getting the excepti

[GitHub] [flink] flinkbot edited a comment on pull request #13150: [FLINK-18879][python] Support Row Serialization and Deserialization s…

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

[GitHub] [flink] tillrohrmann closed pull request #13111: [FLINK-18220][runtime] Extended OutOfMemoryError message.

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

[jira] [Closed] (FLINK-18220) Improve exception if finalizeOnmaster hits OOM

[ https://issues.apache.org/jira/browse/FLINK-18220?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-18220. - Resolution: Fixed Fixed via 56c016924aea3e56c29d6a3817d3276b71b05ab2 > Improve exception if fin

[jira] [Updated] (FLINK-18220) Improve exception if finalizeOnmaster hits OOM

[ https://issues.apache.org/jira/browse/FLINK-18220?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-18220: -- Fix Version/s: 1.12.0 > Improve exception if finalizeOnmaster hits OOM > -

[jira] [Closed] (FLINK-18935) CompletedOperationCache accepts new operations after closeAsync has been called

[ https://issues.apache.org/jira/browse/FLINK-18935?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-18935. - Resolution: Fixed Fixed via 61caf2ea139684f216df873ed3b864b6cb9d4a4f > CompletedOperationCache

[GitHub] [flink] tillrohrmann closed pull request #13139: [FLINK-18935] Reject CompletedOperationCache.registerOngoingOperation if cache is shutting down

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

[GitHub] [flink] tillrohrmann commented on pull request #13139: [FLINK-18935] Reject CompletedOperationCache.registerOngoingOperation if cache is shutting down

tillrohrmann commented on pull request #13139: URL: https://github.com/apache/flink/pull/13139#issuecomment-674188101 Thanks for the review @rmetzger. Merging this PR now. This is an automated message from the Apache Git Serv

[jira] [Commented] (FLINK-11086) Add support for Hadoop 3

[ https://issues.apache.org/jira/browse/FLINK-11086?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17177948#comment-17177948 ] Satish Saley commented on FLINK-11086: -- Hi [~rmetzger], was there a reason for not

[GitHub] [flink] flinkbot edited a comment on pull request #13149: [FLINK-18683][table-common] Support @DataTypeHint for table/aggregate function output types

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

[GitHub] [flink] flinkbot edited a comment on pull request #13111: [FLINK-18220][runtime] Extended OutOfMemoryError message.

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

[jira] [Commented] (FLINK-9054) IllegalStateException: Buffer pool is destroyed

[ https://issues.apache.org/jira/browse/FLINK-9054?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17177859#comment-17177859 ] jiyong qin commented on FLINK-9054: --- hi，i also have this exceptioin with flink1.6，do yo

[jira] [Created] (FLINK-18964) package org.apache.flink.sql.parser.impl does not exist

weizihan created FLINK-18964: Summary: package org.apache.flink.sql.parser.impl does not exist Key: FLINK-18964 URL: https://issues.apache.org/jira/browse/FLINK-18964 Project: Flink Issue Type: B

[jira] [Commented] (FLINK-18849) Improve the code tabs of the Flink documents

[ https://issues.apache.org/jira/browse/FLINK-18849?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17177824#comment-17177824 ] Seth Wiesman commented on FLINK-18849: -- release-1.11: 0e2a7cc30a14c6338b4447cedb338

[jira] [Assigned] (FLINK-18958) Lose column comment when create table

[ https://issues.apache.org/jira/browse/FLINK-18958?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-18958: --- Assignee: Shengkai Fang > Lose column comment when create table > -

[GitHub] [flink] wuchong commented on pull request #13141: [FLINK-18852] Fix StreamScan doesn't inherit parallelism from input in legacy planner

wuchong commented on pull request #13141: URL: https://github.com/apache/flink/pull/13141#issuecomment-674120246 There are some tests failed. Please have a look. This is an automated message from the Apache Git Service. To r

[jira] [Created] (FLINK-18963) Added Copyright information to coding style guide

Matthias created FLINK-18963: Summary: Added Copyright information to coding style guide Key: FLINK-18963 URL: https://issues.apache.org/jira/browse/FLINK-18963 Project: Flink Issue Type: Improve

[GitHub] [flink] flinkbot edited a comment on pull request #13150: [FLINK-18879][python] Support Row Serialization and Deserialization s…

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

[jira] [Commented] (FLINK-18808) Task-level numRecordsOut metric may be underestimated

[ https://issues.apache.org/jira/browse/FLINK-18808?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17177788#comment-17177788 ] ming li commented on FLINK-18808: - Okay, I will fix it as soon as possible. Thank you fo

[jira] [Commented] (FLINK-18808) Task-level numRecordsOut metric may be underestimated

[ https://issues.apache.org/jira/browse/FLINK-18808?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17177785#comment-17177785 ] Piotr Nowojski commented on FLINK-18808: Ok, maybe you can propose some solution

[GitHub] [flink] flinkbot commented on pull request #13150: [FLINK-18879][python] Support Row Serialization and Deserialization s…

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

[jira] [Commented] (FLINK-13598) frocksdb doesn't have arm release

[ https://issues.apache.org/jira/browse/FLINK-13598?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1718#comment-1718 ] Robert Metzger commented on FLINK-13598: Thanks again for your answers. Till, A

[jira] [Commented] (FLINK-18940) Cannot cast "org.apache.flink.table.data.RowData" to "org.apache.flink.table.data.binary.BinaryStringData"

[ https://issues.apache.org/jira/browse/FLINK-18940?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1715#comment-1715 ] Timo Walther commented on FLINK-18940: -- Thanks, this is definitely a bug. I'm curre

[GitHub] [flink] flinkbot commented on pull request #13150: [FLINK-18879][python] Support Row Serialization and Deserialization s…

flinkbot commented on pull request #13150: URL: https://github.com/apache/flink/pull/13150#issuecomment-674077626 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-18808) Task-level numRecordsOut metric may be underestimated

[ https://issues.apache.org/jira/browse/FLINK-18808?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1712#comment-1712 ] ming li commented on FLINK-18808: - {quote}{{And as an optimisation in {{AbstractStreamOp

[jira] [Updated] (FLINK-18879) Support Row Serialization and Deserialization schemas for DataStream source/sink

[ https://issues.apache.org/jira/browse/FLINK-18879?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-18879: --- Labels: pull-request-available (was: ) > Support Row Serialization and Deserialization sche

[GitHub] [flink] shuiqiangchen opened a new pull request #13150: [FLINK-18879][python] Support Row Serialization and Deserialization s…

shuiqiangchen opened a new pull request #13150: URL: https://github.com/apache/flink/pull/13150 ## What is the purpose of the change There are many built-in RowSerializationSchemas and RowDeserializationSchemas for DataStream Source and Sink, like JsonRow(De)SerializationSch

[jira] [Commented] (FLINK-15299) Move ClientUtils#submitJob & ClientUtils#submitJobAndWaitForResult to test scope

[ https://issues.apache.org/jira/browse/FLINK-15299?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17177768#comment-17177768 ] Robert Metzger commented on FLINK-15299: +1 on addressing this. I was also confu

[GitHub] [flink] flinkbot edited a comment on pull request #13149: [FLINK-18683][table-common] Support @DataTypeHint for table/aggregate function output types

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

[GitHub] [flink] lirui-apache commented on pull request #13144: [FLINK-15853][hive][table-planner-blink] Use the new type inference f…

lirui-apache commented on pull request #13144: URL: https://github.com/apache/flink/pull/13144#issuecomment-674072366 @twalthr Thanks for the review. Currently the input validation happens when inferring the result type of the UDF, i.e. an exception is thrown if we cannot find a proper Hiv

[GitHub] [flink] flinkbot edited a comment on pull request #13141: [FLINK-18852] Fix StreamScan doesn't inherit parallelism from input in legacy planner

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

[GitHub] [flink] flinkbot edited a comment on pull request #13146: [FLINK-18942][hive] HiveTableSink shouldn't try to create BulkWriter …

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

[GitHub] [flink] flinkbot commented on pull request #13149: [FLINK-18683][table-common] Support @DataTypeHint for table/aggregate function output types

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

[GitHub] [flink] flinkbot edited a comment on pull request #13111: [FLINK-18220][runtime] Extended OutOfMemoryError message.

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

[jira] [Commented] (FLINK-18808) Task-level numRecordsOut metric may be underestimated

[ https://issues.apache.org/jira/browse/FLINK-18808?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17177753#comment-17177753 ] Piotr Nowojski commented on FLINK-18808: Ok, let's try to do that. Thanks for yo

[GitHub] [flink] flinkbot commented on pull request #13149: [FLINK-18683][table-common] Support @DataTypeHint for table/aggregate function output types

flinkbot commented on pull request #13149: URL: https://github.com/apache/flink/pull/13149#issuecomment-674057997 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 edited a comment on pull request #13111: [FLINK-18220][runtime] Extended OutOfMemoryError message.

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

[GitHub] [flink] flinkbot edited a comment on pull request #13141: [FLINK-18852] Fix StreamScan doesn't inherit parallelism from input in legacy planner

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

[jira] [Updated] (FLINK-18683) Support @DataTypeHint for TableFunction output types

[ https://issues.apache.org/jira/browse/FLINK-18683?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-18683: --- Labels: pull-request-available (was: ) > Support @DataTypeHint for TableFunction output typ

[GitHub] [flink] twalthr opened a new pull request #13149: [FLINK-18683][table-common] Support @DataTypeHint for table/aggregate function output types

twalthr opened a new pull request #13149: URL: https://github.com/apache/flink/pull/13149 ## What is the purpose of the change Allows to use `@DataTypeHint(...)` as a synonym `@FunctionHint(output = @DataTypeHint(...))` for table and aggregate functions. ## Brief change log

[jira] [Comment Edited] (FLINK-18808) Task-level numRecordsOut metric may be underestimated

[ https://issues.apache.org/jira/browse/FLINK-18808?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17177743#comment-17177743 ] ming li edited comment on FLINK-18808 at 8/14/20, 12:38 PM:

[jira] [Closed] (FLINK-18936) Update documentation about user-defined aggregate functions

[ https://issues.apache.org/jira/browse/FLINK-18936?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-18936. Fix Version/s: 1.12.0 Resolution: Fixed Fixed in 1.12.0: 55072b557ddb8d5f986c3bf84fe9ac2841

[GitHub] [flink] twalthr closed pull request #13143: [FLINK-18936][docs] Update documentation around aggregate functions

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

[jira] [Commented] (FLINK-18808) Task-level numRecordsOut metric may be underestimated

[ https://issues.apache.org/jira/browse/FLINK-18808?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17177743#comment-17177743 ] ming li commented on FLINK-18808: - {quote}I would be afraid of this check adding too muc

[GitHub] [flink] flinkbot edited a comment on pull request #13141: [FLINK-18852] Fix StreamScan doesn't inherit parallelism from input in legacy planner

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

[GitHub] [flink] flinkbot edited a comment on pull request #13075: [FLINK-18833][doc][python] Improve the Python documentation about sql

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

[GitHub] [flink] tillrohrmann commented on a change in pull request #13111: [FLINK-18220][runtime] Extended OutOfMemoryError message.

tillrohrmann commented on a change in pull request #13111: URL: https://github.com/apache/flink/pull/13111#discussion_r470588260 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/entrypoint/ClusterEntryPointExceptionUtilsTest.java ## @@ -0,0 +1,48 @@ +package

[jira] [Commented] (FLINK-18685) JobClient.getAccumulators() blocks until streaming job has finished in local environment

[ https://issues.apache.org/jira/browse/FLINK-18685?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17177732#comment-17177732 ] Robert Metzger commented on FLINK-18685: Thanks. I assigned you. > JobClient.ge

[jira] [Assigned] (FLINK-18685) JobClient.getAccumulators() blocks until streaming job has finished in local environment

[ https://issues.apache.org/jira/browse/FLINK-18685?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-18685: -- Assignee: Zhu Shan > JobClient.getAccumulators() blocks until streaming job has finis

[jira] [Commented] (FLINK-18685) JobClient.getAccumulators() blocks until streaming job has finished in local environment

[ https://issues.apache.org/jira/browse/FLINK-18685?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17177731#comment-17177731 ] ZhuShang commented on FLINK-18685: -- hi,[~rmetzger] i'm interested in this issue,can yo

[GitHub] [flink] flinkbot edited a comment on pull request #13075: [FLINK-18833][doc][python] Improve the Python documentation about sql

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

[GitHub] [flink] flinkbot edited a comment on pull request #12966: [FLINK-17427][table sql/planner]Support SupportsPartitionPushDown in …

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

[jira] [Updated] (FLINK-18959) Fail to archiveExecutionGraph because job is not finished when dispatcher close

[ https://issues.apache.org/jira/browse/FLINK-18959?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-18959: -- Priority: Major (was: Minor) > Fail to archiveExecutionGraph because job is not finished when

[jira] [Updated] (FLINK-18959) Fail to archiveExecutionGraph because job is not finished when dispatcher close

[ https://issues.apache.org/jira/browse/FLINK-18959?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-18959: -- Affects Version/s: 1.12.0 1.11.1 > Fail to archiveExecutionGraph becaus

[jira] [Updated] (FLINK-18959) Fail to archiveExecutionGraph because job is not finished when dispatcher close

[ https://issues.apache.org/jira/browse/FLINK-18959?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-18959: -- Fix Version/s: 1.10.3 1.11.2 1.12.0 > Fail to archiveExe

[jira] [Commented] (FLINK-15116) Make JobClient stateless, remove AutoCloseable

[ https://issues.apache.org/jira/browse/FLINK-15116?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17177720#comment-17177720 ] Till Rohrmann commented on FLINK-15116: --- This change seems to cause another regres

[jira] [Comment Edited] (FLINK-15116) Make JobClient stateless, remove AutoCloseable

[ https://issues.apache.org/jira/browse/FLINK-15116?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17177720#comment-17177720 ] Till Rohrmann edited comment on FLINK-15116 at 8/14/20, 11:48 AM:

[jira] [Commented] (FLINK-18959) Fail to archiveExecutionGraph because job is not finished when dispatcher close

[ https://issues.apache.org/jira/browse/FLINK-18959?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17177719#comment-17177719 ] Till Rohrmann commented on FLINK-18959: --- Thanks a lot for reporting this issue [~J

[jira] [Commented] (FLINK-18808) Task-level numRecordsOut metric may be underestimated

[ https://issues.apache.org/jira/browse/FLINK-18808?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17177717#comment-17177717 ] Piotr Nowojski commented on FLINK-18808: {code:java} if (!nonChainedOutput.getOr

[GitHub] [flink] flinkbot edited a comment on pull request #13115: [FLINK-18219][runtime] Added OOM-enrichment for main method call in PackagedProgram.

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

[jira] [Commented] (FLINK-18961) In the case of FlatMap linking map, if map returns null, an exception will be thrown in FlatMap

[ https://issues.apache.org/jira/browse/FLINK-18961?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17177710#comment-17177710 ] Chesnay Schepler commented on FLINK-18961: -- Isn't the exception pretty clear as

[jira] [Commented] (FLINK-8580) No easy way (or issues when trying?) to handle multiple yarn sessions and choose at runtime the one to submit a ha streaming job

[ https://issues.apache.org/jira/browse/FLINK-8580?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17177709#comment-17177709 ] Arnaud Linz commented on FLINK-8580: Actually my cluster is a hadoop (yarn cluster),

[GitHub] [flink] rkhachatryan commented on pull request #13040: [FLINK-17073] [checkpointing] checkpointing backpressure if there are too many checkpoints to clean

rkhachatryan commented on pull request #13040: URL: https://github.com/apache/flink/pull/13040#issuecomment-674026613 Thanks for the update @echauchot I see there are some git conflicts now, can you rebase your branch to the latest master? Besides, there are some checkstyle violatio

[GitHub] [flink] flinkbot edited a comment on pull request #13143: [FLINK-18936][docs] Update documentation around aggregate functions

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

[GitHub] [flink] flinkbot edited a comment on pull request #13115: [FLINK-18219][runtime] Added OOM-enrichment for main method call in PackagedProgram.

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

  1   2   3   >