[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=17173585#comment-17173585 ] Piotr Nowojski commented on FLINK-18808: Great, thanks > Task-level numRecordsO

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

[ https://issues.apache.org/jira/browse/FLINK-18808?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reassigned FLINK-18808: -- Assignee: ming li > Task-level numRecordsOut metric may be underestimated > -

[GitHub] [flink] flinkbot edited a comment on pull request #13090: [FLINK-18822] [umbrella] Improve and complete Change Data Capture formats

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

[jira] [Commented] (FLINK-18855) Translate the "Cluster Execution" page of "Application Development's DataSet API" into Chinese

[ https://issues.apache.org/jira/browse/FLINK-18855?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17173571#comment-17173571 ] Roc Marshal commented on FLINK-18855: - Hi, [~alpinegizmo]        Could you assign t

[jira] [Commented] (FLINK-18854) Translate the 'API Migration Guides' page of 'Application Development' into Chinese

[ https://issues.apache.org/jira/browse/FLINK-18854?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17173570#comment-17173570 ] Roc Marshal commented on FLINK-18854: - Hi, [~alpinegizmo]        Could you assign t

[jira] [Created] (FLINK-18855) Translate the "Cluster Execution" page of "Application Development's DataSet API" into Chinese

Roc Marshal created FLINK-18855: --- Summary: Translate the "Cluster Execution" page of "Application Development's DataSet API" into Chinese Key: FLINK-18855 URL: https://issues.apache.org/jira/browse/FLINK-18855

[jira] [Created] (FLINK-18854) Translate the 'API Migration Guides' page of 'Application Development' into Chinese

Roc Marshal created FLINK-18854: --- Summary: Translate the 'API Migration Guides' page of 'Application Development' into Chinese Key: FLINK-18854 URL: https://issues.apache.org/jira/browse/FLINK-18854 Pro

[GitHub] [flink] flinkbot commented on pull request #13090: [FLINK-18822] [umbrella] Improve and complete Change Data Capture formats

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

[GitHub] [flink] flinkbot commented on pull request #13090: [FLINK-18822] [umbrella] Improve and complete Change Data Capture formats

flinkbot commented on pull request #13090: URL: https://github.com/apache/flink/pull/13090#issuecomment-670817878 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-18822) [umbrella] Improve and complete Change Data Capture formats

[ https://issues.apache.org/jira/browse/FLINK-18822?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-18822: --- Labels: pull-request-available (was: ) > [umbrella] Improve and complete Change Data Captur

[GitHub] [flink] lonelyGhostisdog opened a new pull request #13090: [FLINK-18822] [umbrella] Improve and complete Change Data Capture formats

lonelyGhostisdog opened a new pull request #13090: URL: https://github.com/apache/flink/pull/13090 ## What is the purpose of the change *support maxwell-json for Maxwell binlog collector* ## Brief change log - *add DeserializationSchema for deserialize byte

[jira] [Comment Edited] (FLINK-18830) JoinCoGroupFunction and FlatJoinCoGroupFunction work incorrectly for outer join when one side of coGroup is empty

[ https://issues.apache.org/jira/browse/FLINK-18830?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17172797#comment-17172797 ] liupengcheng edited comment on FLINK-18830 at 8/8/20, 1:24 AM: ---

[jira] [Comment Edited] (FLINK-18830) JoinCoGroupFunction and FlatJoinCoGroupFunction work incorrectly for outer join when one side of coGroup is empty

[ https://issues.apache.org/jira/browse/FLINK-18830?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17172797#comment-17172797 ] liupengcheng edited comment on FLINK-18830 at 8/8/20, 1:08 AM: ---

[jira] [Comment Edited] (FLINK-18830) JoinCoGroupFunction and FlatJoinCoGroupFunction work incorrectly for outer join when one side of coGroup is empty

[ https://issues.apache.org/jira/browse/FLINK-18830?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17172797#comment-17172797 ] liupengcheng edited comment on FLINK-18830 at 8/8/20, 1:07 AM: ---

[GitHub] [flink] RocMarshal commented on pull request #13089: [FLINK-18813][docs-zh] Translate the 'Local Installation' page of 'Try Flink' into Chinese

RocMarshal commented on pull request #13089: URL: https://github.com/apache/flink/pull/13089#issuecomment-670787821 Hi, @klion26 . Could you help me to review this PR if you have free time? Thank you. This is an automat

[GitHub] [flink] RocMarshal commented on pull request #13088: [FLINK-18814][docs-zh] Translate the 'Side Outputs' page of 'DataStream API' into Chinese

RocMarshal commented on pull request #13088: URL: https://github.com/apache/flink/pull/13088#issuecomment-670787752 Hi, @XBaith . Could you help me to review this PR if you have free time? Thank you. This is an automat

[GitHub] [flink] RocMarshal commented on pull request #13087: [hotfix][docs] Fix the link-tags in the 'Side Outputs' page of 'DataStream API'

RocMarshal commented on pull request #13087: URL: https://github.com/apache/flink/pull/13087#issuecomment-670787535 Hi, @wuchong . I made a hotfix. Please take a look. Thank you. This is an automated message from the Ap

[GitHub] [flink] flinkbot edited a comment on pull request #13086: [FLINK-17503][runtime] [logs] Refactored log output.

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

[GitHub] [flink] rmetzger commented on pull request #12962: [FLINK-18694] Add unaligned checkpoint config to web ui

rmetzger commented on pull request #12962: URL: https://github.com/apache/flink/pull/12962#issuecomment-670660866 > We could, of course, also think about back-porting this PR and the ticket to 1.11. I guess it's small enough to not count as a feature, but it's also not a bugfix. WDYT @rmet

[jira] [Closed] (FLINK-18702) Flink elasticsearch connector leaks threads and classloaders thereof

[ https://issues.apache.org/jira/browse/FLINK-18702?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger closed FLINK-18702. -- Fix Version/s: 1.10.2 Resolution: Fixed > Flink elasticsearch connector leaks threads a

[GitHub] [flink] flinkbot edited a comment on pull request #13031: [FLINK-18773][runtime] Enables parallel user-code and plugin class loader.

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

[GitHub] [flink] flinkbot edited a comment on pull request #13088: [FLINK-18814][docs-zh] Translate the 'Side Outputs' page of 'DataStream API' into Chinese

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

[GitHub] [flink] flinkbot edited a comment on pull request #13089: [FLINK-18813][docs-zh] Translate the 'Local Installation' page of 'Try Flink' into Chinese

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

[jira] [Commented] (FLINK-7289) Memory allocation of RocksDB can be problematic in container environments

[ https://issues.apache.org/jira/browse/FLINK-7289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17173355#comment-17173355 ] Harsh Singh commented on FLINK-7289: [~yunta] By the way, I am facing the other issue

[jira] [Commented] (FLINK-7289) Memory allocation of RocksDB can be problematic in container environments

[ https://issues.apache.org/jira/browse/FLINK-7289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17173351#comment-17173351 ] Harsh Singh commented on FLINK-7289: [~yunta] Yes managed to figure it out. It was ju

[GitHub] [flink] flinkbot commented on pull request #13089: [FLINK-18813][docs-zh] Translate the 'Local Installation' page of 'Try Flink' into Chinese

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

[GitHub] [flink] flinkbot commented on pull request #13088: [FLINK-18814][docs-zh] Translate the 'Side Outputs' page of 'DataStream API' into Chinese

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

[GitHub] [flink] flinkbot edited a comment on pull request #13087: [hotfix][docs] Fix the link-tags in the 'Side Outputs' page of 'DataStream API'

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

[jira] [Commented] (FLINK-7289) Memory allocation of RocksDB can be problematic in container environments

[ https://issues.apache.org/jira/browse/FLINK-7289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17173320#comment-17173320 ] Yun Tang commented on FLINK-7289: - [~itsharshonly], you could call [DBOptions#setUseDire

[jira] [Updated] (FLINK-18814) Translate the 'Side Outputs' page of 'DataStream API' into Chinese

[ https://issues.apache.org/jira/browse/FLINK-18814?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-18814: --- Labels: documentation pull-request-available (was: documentation) > Translate the 'Side Out

[GitHub] [flink] flinkbot commented on pull request #13089: [FLINK-18813][docs-zh] Translate the 'Local Installation' page of 'Try Flink' into Chinese

flinkbot commented on pull request #13089: URL: https://github.com/apache/flink/pull/13089#issuecomment-670619481 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-18813) Translate the 'Local Installation' page of 'Try Flink' into Chinese

[ https://issues.apache.org/jira/browse/FLINK-18813?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-18813: --- Labels: documentaion pull-request-available (was: documentaion) > Translate the 'Local Inst

[GitHub] [flink] RocMarshal opened a new pull request #13089: [FLINK-18813][docs-zh] Translate the 'Local Installation' page of 'Try Flink' into Chinese

RocMarshal opened a new pull request #13089: URL: https://github.com/apache/flink/pull/13089 ## What is the purpose of the change *Translate the 'Local Installation' page of 'Try Flink' into Chinese* ## Brief change log *Translate the 'Local Installation' pag

[GitHub] [flink] flinkbot commented on pull request #13088: [FLINK-18814][docs-zh] Translate the 'Side Outputs' page of 'DataStream API' into Chinese

flinkbot commented on pull request #13088: URL: https://github.com/apache/flink/pull/13088#issuecomment-670618141 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] RocMarshal opened a new pull request #13088: [FLINK-18814][docs-zh] Translate the 'Side Outputs' page of 'DataStream API' into Chinese

RocMarshal opened a new pull request #13088: URL: https://github.com/apache/flink/pull/13088 ## What is the purpose of the change *Translate the 'Side Outputs' page of 'DataStream API' into Chinese* ## Brief change log *Translate the 'Side Outputs' page of 'D

[GitHub] [flink] flinkbot commented on pull request #13087: [hotfix][docs] Fix the link-tags in the 'Side Outputs' page of 'DataStream API'

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

[GitHub] [flink] flinkbot edited a comment on pull request #13078: [FLINK-18659][hive][orc] Fix streaming write for Hive 1.x Orc table

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

[jira] [Updated] (FLINK-18814) Translate the 'Side Outputs' page of 'DataStream API' into Chinese

[ https://issues.apache.org/jira/browse/FLINK-18814?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roc Marshal updated FLINK-18814: Summary: Translate the 'Side Outputs' page of 'DataStream API' into Chinese (was: Translate 'Side

[jira] [Updated] (FLINK-18813) Translate the 'Local Installation' page of 'Try Flink' into Chinese

[ https://issues.apache.org/jira/browse/FLINK-18813?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roc Marshal updated FLINK-18813: Summary: Translate the 'Local Installation' page of 'Try Flink' into Chinese (was: Translate 'Loc

[GitHub] [flink] flinkbot commented on pull request #13087: [hotfix][docs] Fix the link-tags in the 'Side Outputs' page of 'DataStream API'

flinkbot commented on pull request #13087: URL: https://github.com/apache/flink/pull/13087#issuecomment-670611800 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] RocMarshal opened a new pull request #13087: [hotfix][docs] Fix the link-tags in the 'Side Outputs' page of 'DataStream API'

RocMarshal opened a new pull request #13087: URL: https://github.com/apache/flink/pull/13087 ## What is the purpose of the change *Fix the link-tags in the 'Side Outputs' page of 'DataStream API'* ## Brief change log *Fix the link-tags in the 'Side Outputs' p

[GitHub] [flink] flinkbot edited a comment on pull request #13086: [FLINK-17503][runtime] [logs] Refactored log output.

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

[GitHub] [flink] flinkbot edited a comment on pull request #10939: [FLINK-15750][network] Moving output flushing to the mailbox

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

[GitHub] [flink] flinkbot commented on pull request #13086: [FLINK-17503][runtime] [logs] Refactored log output.

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

[jira] [Updated] (FLINK-16419) Avoid to recommit transactions which are known committed successfully to Kafka upon recovery

[ https://issues.apache.org/jira/browse/FLINK-16419?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-16419: -- Component/s: Runtime / Checkpointing > Avoid to recommit transactions which are known committe

[GitHub] [flink] flinkbot edited a comment on pull request #10939: [FLINK-15750][network] Moving output flushing to the mailbox

flinkbot edited a comment on pull request #10939: URL: https://github.com/apache/flink/pull/10939#issuecomment-578098092 ## CI report: * 5978349776ae9c87fef872887df47ee880ab12af Travis: [FAILURE](https://travis-ci.com/flink-ci/flink/builds/145957617) Azure: [FAILURE](https://dev

[GitHub] [flink] flinkbot commented on pull request #13086: [FLINK-17503][runtime] [logs] Refactored log output.

flinkbot commented on pull request #13086: URL: https://github.com/apache/flink/pull/13086#issuecomment-670596210 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] XComp commented on pull request #13086: [FLINK-17503][runtime] [logs] Refactored log output.

XComp commented on pull request #13086: URL: https://github.com/apache/flink/pull/13086#issuecomment-670595829 @tillrohrmann Here's the code change for FLINK-17503 (log enhancement). This is an automated message from the Apac

[jira] [Updated] (FLINK-17503) Make memory configuration logging more user-friendly

[ https://issues.apache.org/jira/browse/FLINK-17503?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-17503: --- Labels: pull-request-available usability (was: usability) > Make memory configuration loggi

[GitHub] [flink] XComp opened a new pull request #13086: [FLINK-17503][runtime] [logs] Refactored log output.

XComp opened a new pull request #13086: URL: https://github.com/apache/flink/pull/13086 The log output was cleaned up: - Only the key of the option is logged out instead of the whole instance's toString() method. - A new utility method was introduce that adapts the log output i

[GitHub] [flink] flinkbot edited a comment on pull request #13066: [FLINK-18765][python] Support map() and flat_map() for Python DataStream API.

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

[GitHub] [flink] flinkbot edited a comment on pull request #10939: [FLINK-15750][network] Moving output flushing to the mailbox

flinkbot edited a comment on pull request #10939: URL: https://github.com/apache/flink/pull/10939#issuecomment-578098092 ## CI report: * 5978349776ae9c87fef872887df47ee880ab12af Travis: [FAILURE](https://travis-ci.com/flink-ci/flink/builds/145957617) Azure: [FAILURE](https://dev

[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=17173221#comment-17173221 ] ming li commented on FLINK-18808: - Hi,[~pnowojski]. Thank you for your reply. Can this b

[GitHub] [flink] AHeise commented on pull request #12962: [FLINK-18694] Add unaligned checkpoint config to web ui

AHeise commented on pull request #12962: URL: https://github.com/apache/flink/pull/12962#issuecomment-670578906 > Great! Sorry I chose “Not enabled” as I thought “Disabled” may have a user thinking it’s optimal to enable it, will change. When is the freeze? I can try at it this weekend.

[jira] [Comment Edited] (FLINK-18631) Serializer for scala sealed trait hierarchies

[ https://issues.apache.org/jira/browse/FLINK-18631?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17173207#comment-17173207 ] Yun Gao edited comment on FLINK-18631 at 8/7/20, 3:24 PM: -- Hi [

[jira] [Comment Edited] (FLINK-18631) Serializer for scala sealed trait hierarchies

[ https://issues.apache.org/jira/browse/FLINK-18631?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17173207#comment-17173207 ] Yun Gao edited comment on FLINK-18631 at 8/7/20, 3:24 PM: -- Hi [

[jira] [Commented] (FLINK-18631) Serializer for scala sealed trait hierarchies

[ https://issues.apache.org/jira/browse/FLINK-18631?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17173207#comment-17173207 ] Yun Gao commented on FLINK-18631: - Hi [~rgrebennikov], very thanks for the PR and very s

[GitHub] [flink] kbohinski commented on pull request #12962: [FLINK-18694] Add unaligned checkpoint config to web ui

kbohinski commented on pull request #12962: URL: https://github.com/apache/flink/pull/12962#issuecomment-670567902 Great! Sorry I chose “Not enabled” as I thought “Disabled” may have a user thinking it’s optimal to enable it, will change. When is the freeze? I can try at it this weekend.

[jira] [Commented] (FLINK-18800) Avro serialization schema doesn't support Kafka key/value serialization

[ https://issues.apache.org/jira/browse/FLINK-18800?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17173194#comment-17173194 ] Mohammad Hossein Gerami commented on FLINK-18800: - [~aljoscha] can you h

[GitHub] [flink] flinkbot edited a comment on pull request #13066: [FLINK-18765][python] Support map() and flat_map() for Python DataStream API.

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

[jira] [Commented] (FLINK-7289) Memory allocation of RocksDB can be problematic in container environments

[ https://issues.apache.org/jira/browse/FLINK-7289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17173178#comment-17173178 ] Harsh Singh commented on FLINK-7289: Hi, this doesnt seem to address the issue Vinay

[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=17173177#comment-17173177 ] Piotr Nowojski edited comment on FLINK-18808 at 8/7/20, 2:37 PM: -

[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=17173177#comment-17173177 ] Piotr Nowojski commented on FLINK-18808: +1 to what was written above. It looks

[GitHub] [flink] pnowojski commented on a change in pull request #13044: [FLINK-18641][checkpointing] Fix CheckpointCoordinator to work with ExternallyInducedSource

pnowojski commented on a change in pull request #13044: URL: https://github.com/apache/flink/pull/13044#discussion_r466961539 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinator.java ## @@ -530,15 +530,22 @@ private void startTr

[GitHub] [flink] pnowojski commented on a change in pull request #13044: [FLINK-18641][checkpointing] Fix CheckpointCoordinator to work with ExternallyInducedSource

pnowojski commented on a change in pull request #13044: URL: https://github.com/apache/flink/pull/13044#discussion_r466961539 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinator.java ## @@ -530,15 +530,22 @@ private void startTr

[GitHub] [flink] flinkbot edited a comment on pull request #13031: [FLINK-18773][runtime] Enables parallel user-code and plugin class loader.

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

[GitHub] [flink] pnowojski commented on a change in pull request #13044: [FLINK-18641][checkpointing] Fix CheckpointCoordinator to work with ExternallyInducedSource

pnowojski commented on a change in pull request #13044: URL: https://github.com/apache/flink/pull/13044#discussion_r467068535 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinator.java ## @@ -576,7 +583,22 @@ private void startTri

[GitHub] [flink] flinkbot edited a comment on pull request #13031: [FLINK-18773][runtime] Enables parallel user-code and plugin class loader.

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

[GitHub] [flink] flinkbot edited a comment on pull request #13051: [FLINK-18760][runtime] Redundant task managers should be released when there's no job running in session cluster

flinkbot edited a comment on pull request #13051: URL: https://github.com/apache/flink/pull/13051#issuecomment-667970728 ## CI report: * b387eae159be898230e9b5a410a295f9960dabb1 UNKNOWN * 8234d87e7f9215067cd88ccd848958b5fd652a61 Azure: [SUCCESS](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #12988: [FLINK-18678][hive][doc] Update doc about setting hive version

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

[jira] [Created] (FLINK-18853) Supports properties from flink-conf.yaml for SET command in sql client

godfrey he created FLINK-18853: -- Summary: Supports properties from flink-conf.yaml for SET command in sql client Key: FLINK-18853 URL: https://issues.apache.org/jira/browse/FLINK-18853 Project: Flink

[GitHub] [flink] flinkbot edited a comment on pull request #13078: [FLINK-18659][hive][orc] Fix streaming write for Hive 1.x Orc table

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

[GitHub] [flink] flinkbot edited a comment on pull request #12994: [FLINK-18728][network] Make initialCredit of RemoteInputChannel final

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

[jira] [Commented] (FLINK-18702) Flink elasticsearch connector leaks threads and classloaders thereof

[ https://issues.apache.org/jira/browse/FLINK-18702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17173144#comment-17173144 ] Jun Qin commented on FLINK-18702: - This has been merged into master. See: [https://gith

[GitHub] [flink] flinkbot edited a comment on pull request #12988: [FLINK-18678][hive][doc] Update doc about setting hive version

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

[jira] [Updated] (FLINK-16419) Avoid to recommit transactions which are known committed successfully to Kafka upon recovery

[ https://issues.apache.org/jira/browse/FLINK-16419?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Qin updated FLINK-16419: Labels: usability (was: ) > Avoid to recommit transactions which are known committed successfully to > K

[jira] [Updated] (FLINK-18852) StreamScan should keep the same parallelism as the input

[ https://issues.apache.org/jira/browse/FLINK-18852?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] liupengcheng updated FLINK-18852: - Description: Currently, the parallelism for StreamTableSourceScan/DataStreamScan is not inherit

[jira] [Created] (FLINK-18852) StreamScan should keep the same parallelism as the input

liupengcheng created FLINK-18852: Summary: StreamScan should keep the same parallelism as the input Key: FLINK-18852 URL: https://issues.apache.org/jira/browse/FLINK-18852 Project: Flink Issu

[GitHub] [flink] flinkbot edited a comment on pull request #13071: [FLINK-18751][Coordination] Implement SlotSharingExecutionSlotAllocator

flinkbot edited a comment on pull request #13071: URL: https://github.com/apache/flink/pull/13071#issuecomment-669310861 ## CI report: * 2233727954b8a6272c4a772a03bccc08b5e97720 UNKNOWN * 07fd40233580c1641fda58742e015144d767c2fe UNKNOWN * 97ee7a057155f9317a7890d405cb1f2ad363

[GitHub] [flink] flinkbot edited a comment on pull request #13078: [FLINK-18659][hive][orc] Fix streaming write for Hive 1.x Orc table

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

[jira] [Created] (FLINK-18851) Add checkpoint type to checkpoint history entries in Web UI

Arvid Heise created FLINK-18851: --- Summary: Add checkpoint type to checkpoint history entries in Web UI Key: FLINK-18851 URL: https://issues.apache.org/jira/browse/FLINK-18851 Project: Flink Is

[jira] [Closed] (FLINK-18522) ZKCheckpointIDCounterMultiServersTest.testRecoveredAfterConnectionLoss failed with "Address already in use"

[ https://issues.apache.org/jira/browse/FLINK-18522?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-18522. - Resolution: Won't Fix > ZKCheckpointIDCounterMultiServersTest.testRecoveredAfterConnectionLoss f

[GitHub] [flink] flinkbot edited a comment on pull request #13085: [FLINK-18849][docs] Improve the code tabs of the Flink documents.

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

[GitHub] [flink] flinkbot edited a comment on pull request #12881: [FLINK-18512][kinesis] Introducing RecordPublisher. Refactor ShardConsumer to use PollingRecordPublisher

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

[jira] [Commented] (FLINK-18522) ZKCheckpointIDCounterMultiServersTest.testRecoveredAfterConnectionLoss failed with "Address already in use"

[ https://issues.apache.org/jira/browse/FLINK-18522?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17173126#comment-17173126 ] Matthias commented on FLINK-18522: -- ZooKeepers TestServer is implemented in a way that

[jira] [Comment Edited] (FLINK-17503) Make memory configuration logging more user-friendly

[ https://issues.apache.org/jira/browse/FLINK-17503?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17173113#comment-17173113 ] Till Rohrmann edited comment on FLINK-17503 at 8/7/20, 12:58 PM: -

[GitHub] [flink] flinkbot commented on pull request #13085: [FLINK-18849][docs] Improve the code tabs of the Flink documents.

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

[jira] [Commented] (FLINK-17503) Make memory configuration logging more user-friendly

[ https://issues.apache.org/jira/browse/FLINK-17503?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17173113#comment-17173113 ] Till Rohrmann commented on FLINK-17503: --- [~manish.c.ghildi...@gmail.com] [~mapohl]

[jira] [Assigned] (FLINK-17503) Make memory configuration logging more user-friendly

[ https://issues.apache.org/jira/browse/FLINK-17503?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-17503: - Assignee: Matthias (was: Manish Ghildiyal) > Make memory configuration logging more us

[jira] [Created] (FLINK-18850) Add late records dropped metric for row time over windows

Benchao Li created FLINK-18850: -- Summary: Add late records dropped metric for row time over windows Key: FLINK-18850 URL: https://issues.apache.org/jira/browse/FLINK-18850 Project: Flink Issue T

[GitHub] [flink] flinkbot commented on pull request #13085: [FLINK-18849][docs] Improve the code tabs of the Flink documents.

flinkbot commented on pull request #13085: URL: https://github.com/apache/flink/pull/13085#issuecomment-670492600 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-18849) Improve the code tabs of the Flink documents

[ https://issues.apache.org/jira/browse/FLINK-18849?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-18849: --- Labels: pull-request-available (was: ) > Improve the code tabs of the Flink documents > ---

[GitHub] [flink] WeiZhong94 opened a new pull request #13085: [FLINK-18849][docs] Improve the code tabs of the Flink documents.

WeiZhong94 opened a new pull request #13085: URL: https://github.com/apache/flink/pull/13085 ## What is the purpose of the change *This pull request modifies the `flink.js` to improve the code tabs of the Flink documents.* ## Brief change log - *Split the code tab lab

[GitHub] [flink] flinkbot edited a comment on pull request #13066: [FLINK-18765][python] Support map() and flat_map() for Python DataStream API.

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

[GitHub] [flink] flinkbot edited a comment on pull request #12880: [FLINK-18555][table sql/api] Make TableConfig options can be configur…

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

[GitHub] [flink] libenchao commented on pull request #13081: [FLINK-18590][json] Support json array explode to multi messages

libenchao commented on pull request #13081: URL: https://github.com/apache/flink/pull/13081#issuecomment-670486025 the ci failure is not relevant with this pr, it's passing on my private ci: https://dev.azure.com/libenchao/flink.benchao/_build/results?buildId=32&view=results ---

[GitHub] [flink] flinkbot edited a comment on pull request #13071: [FLINK-18751][Coordination] Implement SlotSharingExecutionSlotAllocator

flinkbot edited a comment on pull request #13071: URL: https://github.com/apache/flink/pull/13071#issuecomment-669310861 ## CI report: * 2233727954b8a6272c4a772a03bccc08b5e97720 UNKNOWN * 07fd40233580c1641fda58742e015144d767c2fe UNKNOWN * 7a70b16f8bed0bd3e18df37ef11e05612eaa

[GitHub] [flink] zentol commented on a change in pull request #13031: [FLINK-18773][runtime] Enables parallel user-code and plugin class loader.

zentol commented on a change in pull request #13031: URL: https://github.com/apache/flink/pull/13031#discussion_r466998507 ## File path: flink-core/src/main/java/org/apache/flink/util/ChildFirstClassLoader.java ## @@ -73,9 +71,7 @@ public ChildFirstClassLoader(

[GitHub] [flink] flinkbot edited a comment on pull request #12881: [FLINK-18512][kinesis] Introducing RecordPublisher. Refactor ShardConsumer to use PollingRecordPublisher

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

[GitHub] [flink] zentol commented on a change in pull request #13027: [FLINK-16245] Decoupling user classloader from context classloader.

zentol commented on a change in pull request #13027: URL: https://github.com/apache/flink/pull/13027#discussion_r466997734 ## File path: flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/HiveTableSink.java ## @@ -241,12 +242,14 @@ public fina

  1   2   3   >