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

2020-08-14 Thread GitBox
flinkbot edited a comment on pull request #13151: URL: https://github.com/apache/flink/pull/13151#issuecomment-674350152 ## CI report: * 85ded7435e39bff6e7a54aa59b6314df8787bc91 Azure:

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

2020-08-14 Thread GitBox
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

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

2020-08-14 Thread GitBox
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

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

2020-08-14 Thread GitBox
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,

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

2020-08-14 Thread ASF GitHub Bot (Jira)
[ 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

2020-08-14 Thread GitBox
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

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

2020-08-14 Thread Hequn Cheng (Jira)
[ 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

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

2020-08-14 Thread Hequn Cheng (Jira)
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

2020-08-14 Thread Hequn Cheng (Jira)
[ 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

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

2020-08-14 Thread tartarus (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18202?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17178143#comment-17178143 ] tartarus commented on FLINK-18202: -- Hi, all A little suggestion, I think it is necessary to support

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

2020-08-14 Thread HK (Jira)
[ 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

2020-08-14 Thread GitBox
flinkbot edited a comment on pull request #11469: URL: https://github.com/apache/flink/pull/11469#issuecomment-601972922 ## CI report: * 47e6ef886af7cb5e2d43dfb6ce3e4f533457172d Azure:

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

2020-08-14 Thread GitBox
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:

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

2020-08-14 Thread Dian Fu (Jira)
[ 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"

2020-08-14 Thread Dian Fu (Jira)
Dian Fu created FLINK-18965: --- Summary: ExecutionContextTest.testCatalogs failed with "ClassNotFoundException: org.apache.hadoop.fs.BlockStoragePolicySpi" Key: FLINK-18965 URL:

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

2020-08-14 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17178132#comment-17178132 ] Dian Fu commented on FLINK-16947: -

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

2020-08-14 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17178131#comment-17178131 ] Dian Fu commented on FLINK-17274: -

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

2020-08-14 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17178130#comment-17178130 ] Dian Fu commented on FLINK-18634: - Another instance on 1.11:

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

2020-08-14 Thread Dian Fu (Jira)
[ 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: 

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

2020-08-14 Thread happylife (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=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

2020-08-14 Thread GitBox
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

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

2020-08-14 Thread GitBox
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

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

2020-08-14 Thread GitBox
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

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

2020-08-14 Thread GitBox
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,

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

2020-08-14 Thread GitBox
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

2020-08-14 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11086?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17178097#comment-17178097 ] Chesnay Schepler commented on FLINK-11086: -- [~satishsaley] Filesystems are supposed to be used

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

2020-08-14 Thread HK (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18389?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17178088#comment-17178088 ] HK commented on FLINK-18389: please assign to me, thanks:P > Translate all SQL connector pages into Chinese

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

2020-08-14 Thread Kenneth William Krugler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18961?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17178007#comment-17178007 ] Kenneth William Krugler commented on FLINK-18961: - Hi [~chesnay] - the exception is

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

2020-08-14 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15299?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17177993#comment-17177993 ] Zili Chen commented on FLINK-15299: --- OK. I will rebase the pull request in hours. > Move

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

2020-08-14 Thread Dawid Wysakowicz (Jira)
[ 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

2020-08-14 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18964?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17177967#comment-17177967 ] Dawid Wysakowicz commented on FLINK-18964: -- I assume you're getting the exception in an IDE

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

2020-08-14 Thread GitBox
flinkbot edited a comment on pull request #13150: URL: https://github.com/apache/flink/pull/13150#issuecomment-674082601 ## CI report: * a4648779ded68d31d674bc391842876e9c8483b1 Azure:

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

2020-08-14 Thread GitBox
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

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

2020-08-14 Thread Till Rohrmann (Jira)
[ 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

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

2020-08-14 Thread Till Rohrmann (Jira)
[ 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

2020-08-14 Thread Till Rohrmann (Jira)
[ 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

2020-08-14 Thread GitBox
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

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

2020-08-14 Thread GitBox
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

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

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

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

2020-08-14 Thread GitBox
flinkbot edited a comment on pull request #13149: URL: https://github.com/apache/flink/pull/13149#issuecomment-674064753 ## CI report: * a08ce39af35d7ac21eaaa9e3323a4c3bc46de184 Azure:

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

2020-08-14 Thread GitBox
flinkbot edited a comment on pull request #13111: URL: https://github.com/apache/flink/pull/13111#issuecomment-671602964 ## CI report: * ed988e8063763917fcb66436f509415eb2cbf174 Azure:

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

2020-08-14 Thread jiyong qin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-9054?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17177859#comment-17177859 ] jiyong qin commented on FLINK-9054: --- hi,i also have this exceptioin with flink1.6,do you solve it? >

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

2020-08-14 Thread weizihan (Jira)
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:

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

2020-08-14 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18849?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17177824#comment-17177824 ] Seth Wiesman commented on FLINK-18849: -- release-1.11: 0e2a7cc30a14c6338b4447cedb3383474b0a0d71 >

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

2020-08-14 Thread Jark Wu (Jira)
[ 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

2020-08-14 Thread GitBox
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

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

2020-08-14 Thread Matthias (Jira)
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:

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

2020-08-14 Thread GitBox
flinkbot edited a comment on pull request #13150: URL: https://github.com/apache/flink/pull/13150#issuecomment-674082601 ## CI report: * a4648779ded68d31d674bc391842876e9c8483b1 Azure:

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

2020-08-14 Thread ming li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18808?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17177788#comment-17177788 ] ming li commented on FLINK-18808: - Okay, I will fix it as soon as possible. Thank you for your reply. >

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

2020-08-14 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18808?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17177785#comment-17177785 ] Piotr Nowojski commented on FLINK-18808: Ok, maybe you can propose some solution in the PR and

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

2020-08-14 Thread GitBox
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

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

2020-08-14 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13598?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1718#comment-1718 ] Robert Metzger commented on FLINK-13598: Thanks again for your answers. Till, Andrey and I had

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

2020-08-14 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18940?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1715#comment-1715 ] Timo Walther commented on FLINK-18940: -- Thanks, this is definitely a bug. I'm currently working on

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

2020-08-14 Thread GitBox
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

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

2020-08-14 Thread ming li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18808?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1712#comment-1712 ] ming li commented on FLINK-18808: - {quote}{{And as an optimisation in {{AbstractStreamOperator}}, we

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

2020-08-14 Thread ASF GitHub Bot (Jira)
[ 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

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

2020-08-14 Thread GitBox
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

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

2020-08-14 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15299?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17177768#comment-17177768 ] Robert Metzger commented on FLINK-15299: +1 on addressing this. I was also confused by this. >

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

2020-08-14 Thread GitBox
flinkbot edited a comment on pull request #13149: URL: https://github.com/apache/flink/pull/13149#issuecomment-674064753 ## CI report: * a08ce39af35d7ac21eaaa9e3323a4c3bc46de184 Azure:

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

2020-08-14 Thread GitBox
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

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

2020-08-14 Thread GitBox
flinkbot edited a comment on pull request #13141: URL: https://github.com/apache/flink/pull/13141#issuecomment-673492124 ## CI report: * 09f938c175da27a7e2a50418259cf006f4794db6 Azure:

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

2020-08-14 Thread GitBox
flinkbot edited a comment on pull request #13146: URL: https://github.com/apache/flink/pull/13146#issuecomment-673990581 ## CI report: * 3c5b738e5708421d2e71edfeea579ae0a671fdb4 Azure:

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

2020-08-14 Thread GitBox
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

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

2020-08-14 Thread GitBox
flinkbot edited a comment on pull request #13111: URL: https://github.com/apache/flink/pull/13111#issuecomment-671602964 ## CI report: * e575fa045556a0420c79b58f6c0c5fc37b7b937e Azure:

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

2020-08-14 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18808?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17177753#comment-17177753 ] Piotr Nowojski commented on FLINK-18808: Ok, let's try to do that. Thanks for your patience

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

2020-08-14 Thread GitBox
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

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

2020-08-14 Thread GitBox
flinkbot edited a comment on pull request #13111: URL: https://github.com/apache/flink/pull/13111#issuecomment-671602964 ## CI report: * e575fa045556a0420c79b58f6c0c5fc37b7b937e Azure:

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

2020-08-14 Thread GitBox
flinkbot edited a comment on pull request #13141: URL: https://github.com/apache/flink/pull/13141#issuecomment-673492124 ## CI report: * ed47271c426abff4426ccf2d0fd5858e6f3d8390 Azure:

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

2020-08-14 Thread ASF GitHub Bot (Jira)
[ 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

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

2020-08-14 Thread GitBox
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

2020-08-14 Thread ming li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18808?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17177743#comment-17177743 ] ming li edited comment on FLINK-18808 at 8/14/20, 12:38 PM: {quote}I would

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

2020-08-14 Thread Timo Walther (Jira)
[ 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: 

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

2020-08-14 Thread GitBox
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

2020-08-14 Thread ming li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18808?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17177743#comment-17177743 ] ming li commented on FLINK-18808: - {quote}I would be afraid of this check adding too much computation

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

2020-08-14 Thread GitBox
flinkbot edited a comment on pull request #13141: URL: https://github.com/apache/flink/pull/13141#issuecomment-673492124 ## CI report: * ed47271c426abff4426ccf2d0fd5858e6f3d8390 Azure:

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

2020-08-14 Thread GitBox
flinkbot edited a comment on pull request #13075: URL: https://github.com/apache/flink/pull/13075#issuecomment-669675460 ## CI report: * 0c252f9105886ffbe9bd4911d6dfb2a1d795859c Azure:

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

2020-08-14 Thread GitBox
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

2020-08-14 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18685?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17177732#comment-17177732 ] Robert Metzger commented on FLINK-18685: Thanks. I assigned you. > JobClient.getAccumulators()

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

2020-08-14 Thread Robert Metzger (Jira)
[ 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

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

2020-08-14 Thread ZhuShang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18685?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17177731#comment-17177731 ] ZhuShang commented on FLINK-18685: -- hi,[~rmetzger] i'm interested in this issue,can you assign to me?

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

2020-08-14 Thread GitBox
flinkbot edited a comment on pull request #13075: URL: https://github.com/apache/flink/pull/13075#issuecomment-669675460 ## CI report: * 661f2d534b6eb4b6718bb86cbe6d34361c20758d Azure:

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

2020-08-14 Thread GitBox
flinkbot edited a comment on pull request #12966: URL: https://github.com/apache/flink/pull/12966#issuecomment-662861328 ## CI report: * 1790d93b79cfdfc3f65a7805e444699736f80d93 Azure:

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

2020-08-14 Thread Till Rohrmann (Jira)
[ 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

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

2020-08-14 Thread Till Rohrmann (Jira)
[ 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

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

2020-08-14 Thread Till Rohrmann (Jira)
[ 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

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

2020-08-14 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15116?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17177720#comment-17177720 ] Till Rohrmann commented on FLINK-15116: --- This change seems to cause another regression. When

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

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

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

2020-08-14 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18959?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17177719#comment-17177719 ] Till Rohrmann commented on FLINK-18959: --- Thanks a lot for reporting this issue [~Jiangang]. I

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

2020-08-14 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18808?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17177717#comment-17177717 ] Piotr Nowojski commented on FLINK-18808: {code:java} if

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

2020-08-14 Thread GitBox
flinkbot edited a comment on pull request #13115: URL: https://github.com/apache/flink/pull/13115#issuecomment-671776288 ## CI report: * 3a70e9874a3c3a84879251fb6402b8a329f3edf9 Azure:

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

2020-08-14 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18961?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17177710#comment-17177710 ] Chesnay Schepler commented on FLINK-18961: -- Isn't the exception pretty clear as is? > In the

[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

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

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

2020-08-14 Thread GitBox
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

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

2020-08-14 Thread GitBox
flinkbot edited a comment on pull request #13143: URL: https://github.com/apache/flink/pull/13143#issuecomment-673578366 ## CI report: * e3f355ba1e729543a1b902c6f3fba3c6836f5023 Azure:

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

2020-08-14 Thread GitBox
flinkbot edited a comment on pull request #13115: URL: https://github.com/apache/flink/pull/13115#issuecomment-671776288 ## CI report: * 7e9fb1af161e7e93a51ce0014552cfa2914bd6ea Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13147: [FLINK-18910][docs] Create the new document structure for Python documentation according to FLIP-133.

2020-08-14 Thread GitBox
flinkbot edited a comment on pull request #13147: URL: https://github.com/apache/flink/pull/13147#issuecomment-673990635 ## CI report: * 568e67dff31b0cc5967bcb10c1bcb02f5ae90d28 Azure:

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

2020-08-14 Thread Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18959?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17177706#comment-17177706 ] Liu commented on FLINK-18959: - Thank you, [~rmetzger] .The job is per-job and is running on yarn. I am using

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

2020-08-14 Thread Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18959?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liu updated FLINK-18959: Attachment: flink-debug-log > Fail to archiveExecutionGraph because job is not finished when dispatcher > close

[jira] [Commented] (FLINK-18960) flink sideoutput union

2020-08-14 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18960?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17177703#comment-17177703 ] Dawid Wysakowicz commented on FLINK-18960: -- English is the language used in JIRA tickets. Could

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

2020-08-14 Thread Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18959?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liu updated FLINK-18959: Description: When job is cancelled, we expect to see it in flink's history server. But I can not see my job

  1   2   3   >