[GitHub] [flink] flinkbot edited a comment on pull request #14126: [FLINK-20204][docs-zh] Translate page 'upsert-kafka Connector' into Chinese

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

[GitHub] [flink] flinkbot edited a comment on pull request #14123: [FLINK-19653][hive] Reduce our dependency on hive runner for tests

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

[jira] [Commented] (FLINK-20231) Sql UDTF subplan reuse on correlate

[ https://issues.apache.org/jira/browse/FLINK-20231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17235201#comment-17235201 ] Junning Liang commented on FLINK-20231: --- [~jark] yes, I saw this is because it get

[jira] [Commented] (FLINK-20231) Sql UDTF subplan reuse on correlate

[ https://issues.apache.org/jira/browse/FLINK-20231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17235204#comment-17235204 ] Jark Wu commented on FLINK-20231: - I think we don't have a solution yet. [~godfreyhe], d

[GitHub] [flink] Fin-chan closed pull request #13268: [FLINK-19053][hotfix][doc] Fix Flink Kafka Connector Dependency Error

Fin-chan closed pull request #13268: URL: https://github.com/apache/flink/pull/13268 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to

[GitHub] [flink] flinkbot edited a comment on pull request #14123: [FLINK-19653][hive] Reduce our dependency on hive runner for tests

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

[jira] [Assigned] (FLINK-17096) Mini-batch group aggregation doesn't expire state even if state ttl is enabled

[ https://issues.apache.org/jira/browse/FLINK-17096?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-17096: --- Assignee: Jark Wu (was: dalongliu) > Mini-batch group aggregation doesn't expire state even if sta

[jira] [Assigned] (FLINK-17096) Mini-batch group aggregation doesn't expire state even if state ttl is enabled

[ https://issues.apache.org/jira/browse/FLINK-17096?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-17096: --- Assignee: dalongliu (was: Jark Wu) > Mini-batch group aggregation doesn't expire state even if sta

[jira] [Commented] (FLINK-20113) Test K8s High Availability Service

[ https://issues.apache.org/jira/browse/FLINK-20113?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17235209#comment-17235209 ] Robert Metzger commented on FLINK-20113: Thanks a lot for the detailed test repo

[jira] [Commented] (FLINK-19181) Make python processes respect the calculated managed memory fraction

[ https://issues.apache.org/jira/browse/FLINK-19181?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17235210#comment-17235210 ] Zhu Zhu commented on FLINK-19181: - [~dian.fu] shall we announce in release notes that th

[jira] [Updated] (FLINK-20081) ExecutorNotifier should run handler in the main thread when receive an exception from the callable.

[ https://issues.apache.org/jira/browse/FLINK-20081?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-20081: --- Priority: Blocker (was: Critical) > ExecutorNotifier should run handler in the main thread

[jira] [Comment Edited] (FLINK-19181) Make python processes respect the calculated managed memory fraction

[ https://issues.apache.org/jira/browse/FLINK-19181?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17235210#comment-17235210 ] Zhu Zhu edited comment on FLINK-19181 at 11/19/20, 7:01 AM:

[GitHub] [flink] shuiqiangchen opened a new pull request #14127: [FLINK-20232][python] Handle object reuse properly in the operators of Python DataStream API.

shuiqiangchen opened a new pull request #14127: URL: https://github.com/apache/flink/pull/14127 ## What is the purpose of the change Currently, it doesn't consider object reuse in the operators of Python DataStream API. ## Brief change log - *Added object reuse

[jira] [Updated] (FLINK-20232) Handle object reuse properly in the operators of Python DataStream API

[ https://issues.apache.org/jira/browse/FLINK-20232?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-20232: --- Labels: pull-request-available (was: ) > Handle object reuse properly in the operators of P

[GitHub] [flink] flinkbot commented on pull request #14127: [FLINK-20232][python] Handle object reuse properly in the operators of Python DataStream API.

flinkbot commented on pull request #14127: URL: https://github.com/apache/flink/pull/14127#issuecomment-730177644 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-19177) FLIP-141: Intra-Slot Managed Memory Sharing

[ https://issues.apache.org/jira/browse/FLINK-19177?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17235216#comment-17235216 ] Zhu Zhu commented on FLINK-19177: - [~xintongsong] [~dian.fu] Do you think we should intr

[jira] [Comment Edited] (FLINK-19177) FLIP-141: Intra-Slot Managed Memory Sharing

[ https://issues.apache.org/jira/browse/FLINK-19177?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17235216#comment-17235216 ] Zhu Zhu edited comment on FLINK-19177 at 11/19/20, 7:16 AM:

[jira] [Commented] (FLINK-19181) Make python processes respect the calculated managed memory fraction

[ https://issues.apache.org/jira/browse/FLINK-19181?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17235219#comment-17235219 ] Dian Fu commented on FLINK-19181: - [~zhuzh] Yes, we should do that. Thanks for the remin

[GitHub] [flink] flinkbot commented on pull request #14127: [FLINK-20232][python] Handle object reuse properly in the operators of Python DataStream API.

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

[jira] [Commented] (FLINK-20190) A New Window Trigger that can trigger window operation both by event time interval、event count for DataStream API

[ https://issues.apache.org/jira/browse/FLINK-20190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17235221#comment-17235221 ] Robert Metzger commented on FLINK-20190: Thanks a lot for opening a ticket. Plea

[jira] [Created] (FLINK-20233) DataGeneratorSource should increment serialVersionUID

Jingsong Lee created FLINK-20233: Summary: DataGeneratorSource should increment serialVersionUID Key: FLINK-20233 URL: https://issues.apache.org/jira/browse/FLINK-20233 Project: Flink Issue T

[jira] [Updated] (FLINK-18735) Enhance DataGen source to support more types

[ https://issues.apache.org/jira/browse/FLINK-18735?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-18735: - Fix Version/s: 1.12.0 > Enhance DataGen source to support more types > -

[jira] [Updated] (FLINK-20233) DataGeneratorSource should increment serialVersionUID

[ https://issues.apache.org/jira/browse/FLINK-20233?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-20233: - Priority: Critical (was: Major) > DataGeneratorSource should increment serialVersionUID > -

[jira] [Commented] (FLINK-10615) Cancel with savepoint can fail the job

[ https://issues.apache.org/jira/browse/FLINK-10615?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17235222#comment-17235222 ] Robert Metzger commented on FLINK-10615: Thanks for your assessment! I'm closing

[jira] [Closed] (FLINK-10615) Cancel with savepoint can fail the job

[ https://issues.apache.org/jira/browse/FLINK-10615?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger closed FLINK-10615. -- Resolution: Duplicate > Cancel with savepoint can fail the job > -

[jira] [Updated] (FLINK-20098) Don't add flink-connector-files to flink-dist, make dependencies explicit

[ https://issues.apache.org/jira/browse/FLINK-20098?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-20098: --- Priority: Blocker (was: Critical) > Don't add flink-connector-files to flink-dist, make dep

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

danny0405 commented on a change in pull request #13291: URL: https://github.com/apache/flink/pull/13291#discussion_r526648244 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/rules/logical/CorrelateSortToRankRule.scala ## @

[jira] [Assigned] (FLINK-20122) Test Small file compaction

[ https://issues.apache.org/jira/browse/FLINK-20122?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu reassigned FLINK-20122: --- Assignee: Yun Gao (was: Guowei Ma) > Test Small file compaction > -- > >

[jira] [Commented] (FLINK-15514) Bump Elasticsearch version from 6.3.1 to 6.8.6 for es6 connector

[ https://issues.apache.org/jira/browse/FLINK-15514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17235227#comment-17235227 ] Jun Qin commented on FLINK-15514: - Flink’s elasticsearch 6 connector depends on elastics

[GitHub] [flink] flinkbot edited a comment on pull request #13291: [FLINK-18988][table] Continuous query with LATERAL and LIMIT produces…

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

[GitHub] [flink] flinkbot edited a comment on pull request #14127: [FLINK-20232][python] Handle object reuse properly in the operators of Python DataStream API.

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

[jira] [Updated] (FLINK-19177) FLIP-141: Intra-Slot Managed Memory Sharing

[ https://issues.apache.org/jira/browse/FLINK-19177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-19177: Release Note: The configuration python.fn-execution.buffer.memory.size and python.fn-execution.framework.m

[jira] [Commented] (FLINK-19181) Make python processes respect the calculated managed memory fraction

[ https://issues.apache.org/jira/browse/FLINK-19181?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17235228#comment-17235228 ] Dian Fu commented on FLINK-19181: - Added release note in the umbrella JIRA FLINK-19177.

[jira] [Commented] (FLINK-19177) FLIP-141: Intra-Slot Managed Memory Sharing

[ https://issues.apache.org/jira/browse/FLINK-19177?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17235230#comment-17235230 ] Xintong Song commented on FLINK-19177: -- [~zhuzh], There's barely any suggestions f

<    1   2   3   4   5