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

2020-11-18 Thread Xintong Song (Jira)
[ 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

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

2020-11-18 Thread Dian Fu (Jira)
[ 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] [Updated] (FLINK-19177) FLIP-141: Intra-Slot Managed Memory Sharing

2020-11-18 Thread Dian Fu (Jira)
[ 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

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

2020-11-18 Thread GitBox
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

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

2020-11-18 Thread GitBox
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

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

2020-11-18 Thread Jun Qin (Jira)
[ 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

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

2020-11-18 Thread Zhu Zhu (Jira)
[ 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 > -- > >

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

2020-11-18 Thread GitBox
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] [Updated] (FLINK-20098) Don't add flink-connector-files to flink-dist, make dependencies explicit

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

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

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

2020-11-18 Thread Robert Metzger (Jira)
[ 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-20233) DataGeneratorSource should increment serialVersionUID

2020-11-18 Thread Jingsong Lee (Jira)
[ 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] [Updated] (FLINK-18735) Enhance DataGen source to support more types

2020-11-18 Thread Jingsong Lee (Jira)
[ 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] [Created] (FLINK-20233) DataGeneratorSource should increment serialVersionUID

2020-11-18 Thread Jingsong Lee (Jira)
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] [Commented] (FLINK-20190) A New Window Trigger that can trigger window operation both by event time interval、event count for DataStream API

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

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

2020-11-18 Thread GitBox
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-19181) Make python processes respect the calculated managed memory fraction

2020-11-18 Thread Dian Fu (Jira)
[ 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

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

2020-11-18 Thread Zhu Zhu (Jira)
[ 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-19177) FLIP-141: Intra-Slot Managed Memory Sharing

2020-11-18 Thread Zhu Zhu (Jira)
[ 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

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

2020-11-18 Thread GitBox
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] [Updated] (FLINK-20232) Handle object reuse properly in the operators of Python DataStream API

2020-11-18 Thread ASF GitHub Bot (Jira)
[ 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] shuiqiangchen opened a new pull request #14127: [FLINK-20232][python] Handle object reuse properly in the operators of Python DataStream API.

2020-11-18 Thread GitBox
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] [Comment Edited] (FLINK-19181) Make python processes respect the calculated managed memory fraction

2020-11-18 Thread Zhu Zhu (Jira)
[ 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:

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

2020-11-18 Thread Robert Metzger (Jira)
[ 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] [Commented] (FLINK-19181) Make python processes respect the calculated managed memory fraction

2020-11-18 Thread Zhu Zhu (Jira)
[ 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] [Commented] (FLINK-20113) Test K8s High Availability Service

2020-11-18 Thread Robert Metzger (Jira)
[ 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] [Assigned] (FLINK-17096) Mini-batch group aggregation doesn't expire state even if state ttl is enabled

2020-11-18 Thread Jark Wu (Jira)
[ 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] [Assigned] (FLINK-17096) Mini-batch group aggregation doesn't expire state even if state ttl is enabled

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

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

2020-11-18 Thread GitBox
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

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

2020-11-18 Thread GitBox
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

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

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

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

2020-11-18 Thread Junning Liang (Jira)
[ 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

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

2020-11-18 Thread GitBox
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

2020-11-18 Thread GitBox
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] [Updated] (FLINK-20232) Handle object reuse properly in the operators of Python DataStream API

2020-11-18 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20232?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-20232: Description: Currently, it doesn't consider object reuse in PythonTimestampsAndWatermarksOperator. We shou

[jira] [Closed] (FLINK-20137) Handle the timestamp of element properly in Python DataStream API

2020-11-18 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20137?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-20137. --- Resolution: Fixed Fixed in master(1.12.0) via 492965cb09f3be7432c88194920a0e54a340af02 > Handle the timesta

[jira] [Updated] (FLINK-20137) Handle the timestamp of element properly in Python DataStream API

2020-11-18 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20137?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-20137: --- Labels: pull-request-available (was: ) > Handle the timestamp of element properly in Python

[GitHub] [flink] dianfu closed pull request #14068: [FLINK-20137][python] Handle the timestamp of element properly in Python DataStream API

2020-11-18 Thread GitBox
dianfu closed pull request #14068: URL: https://github.com/apache/flink/pull/14068 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] wuchong commented on pull request #14126: [FLINK-20204][docs-zh] Translate page 'upsert-kafka Connector' into Chinese

2020-11-18 Thread GitBox
wuchong commented on pull request #14126: URL: https://github.com/apache/flink/pull/14126#issuecomment-730144107 cc @fsk119 , could you help to review this? This is an automated message from the Apache Git Service. To respond

[jira] [Updated] (FLINK-16585) Table program cannot be compiled.Cannot determine simple type name "com"

2020-11-18 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16585?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-16585: Fix Version/s: (was: 1.11.4) (was: 1.10.3) (was: 1.12.0)

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

2020-11-18 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17235182#comment-17235182 ] Jark Wu commented on FLINK-20231: - I see, I think this is a known issue because the dige

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

2020-11-18 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17235180#comment-17235180 ] Jark Wu commented on FLINK-20231: - [~Akihito Liang] could you share a full example which

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

2020-11-18 Thread Dian Fu (Jira)
Dian Fu created FLINK-20232: --- Summary: Handle object reuse properly in the operators of Python DataStream API Key: FLINK-20232 URL: https://issues.apache.org/jira/browse/FLINK-20232 Project: Flink

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

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

[jira] [Updated] (FLINK-20137) Handle the timestamp of element properly in Python DataStream API

2020-11-18 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20137?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-20137: Summary: Handle the timestamp of element properly in Python DataStream API (was: User cannot obtain the t

[jira] [Updated] (FLINK-20137) User cannot obtain the timestamp of current processing element in the ProcessFunction of Python DataStream API

2020-11-18 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20137?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-20137: Description: Currently, the timestamp of the element isn't handled correctly and will be dropped after by

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

2020-11-18 Thread GitBox
flinkbot commented on pull request #14126: URL: https://github.com/apache/flink/pull/14126#issuecomment-730132466 ## CI report: * 338b02c0b3c6a220ebba45f2b0553bb4bce8863e UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

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

2020-11-18 Thread GitBox
flinkbot commented on pull request #14126: URL: https://github.com/apache/flink/pull/14126#issuecomment-730126658 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-20204) Translate page 'upsert-kafka Connector' into Chinese

2020-11-18 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20204?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-20204: --- Labels: pull-request-available (was: ) > Translate page 'upsert-kafka Connector' into Chine

[GitHub] [flink] caozhen1937 opened a new pull request #14126: [FLINK-20204][docs-zh] Translate page 'upsert-kafka Connector' into Chinese

2020-11-18 Thread GitBox
caozhen1937 opened a new pull request #14126: URL: https://github.com/apache/flink/pull/14126 ## What is the purpose of the change Translate page 'upsert-kafka Connector' into Chinese. ## Brief change log *docs/dev/table/connectors/upsert-kafka.zh.md* *docs/de

[jira] [Updated] (FLINK-20230) PARTITIONED TABLE, INSERT INTO EMPTY VALUES, THROW FileNotFoundException

2020-11-18 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20230?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-20230: Fix Version/s: 1.12.0 > PARTITIONED TABLE, INSERT INTO EMPTY VALUES, THROW FileNotFoundException > --

[jira] [Updated] (FLINK-20230) PARTITIONED TABLE, INSERT INTO EMPTY VALUES, THROW FileNotFoundException

2020-11-18 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20230?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-20230: Component/s: (was: API / DataStream) (was: API / DataSet) Table S

[jira] [Closed] (FLINK-16585) Table program cannot be compiled.Cannot determine simple type name "com"

2020-11-18 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16585?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang closed FLINK-16585. - Resolution: Fixed > Table program cannot be compiled.Cannot determine simple type name "com" > -

[jira] [Commented] (FLINK-16585) Table program cannot be compiled.Cannot determine simple type name "com"

2020-11-18 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16585?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17235170#comment-17235170 ] Shengkai Fang commented on FLINK-16585: --- I have reproduced the bug in release-1.10

[GitHub] [flink-docker] Myasuka commented on a change in pull request #43: [FLINK-19125] Adopt Jemalloc as default memory allocator to avoid memory leak

2020-11-18 Thread GitBox
Myasuka commented on a change in pull request #43: URL: https://github.com/apache/flink-docker/pull/43#discussion_r526583917 ## File path: docker-entrypoint.sh ## @@ -93,21 +94,41 @@ prepare_job_manager_start() { envsubst < "${CONF_FILE}" > "${CONF_FILE}.tmp" && mv "${CONF

[GitHub] [flink] guoweiM commented on pull request #14120: [FLINK-19984][core] Add TypeSerializerTestCoverageTest to check whether tests based on SerializerTestBase and TypeSerializerUpgradeTestBase

2020-11-18 Thread GitBox
guoweiM commented on pull request #14120: URL: https://github.com/apache/flink/pull/14120#issuecomment-730115130 Thanks @SteNicholas for opening this pr. In general the pr is good to me. I just have some minor comments. 1. Provide more precise filtering. Currently it is fine that we

[jira] [Updated] (FLINK-20208) Remove outdated in-progress files in StreamingFileSink

2020-11-18 Thread Alexander Trushev (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20208?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexander Trushev updated FLINK-20208: -- Description: Assume a job has StreamingFileSink with OnCheckpointRollingPolicy In the

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

2020-11-18 Thread Junning Liang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17235159#comment-17235159 ] Junning Liang commented on FLINK-20231: --- [~jark] i used StreamTable to execute the

[GitHub] [flink] flinkbot edited a comment on pull request #14099: [Flink-20190][API/DataStream]A New Window Trigger that can trigger window operation both by event time interval、event count

2020-11-18 Thread GitBox
flinkbot edited a comment on pull request #14099: URL: https://github.com/apache/flink/pull/14099#issuecomment-728904723 ## CI report: * 58186e803854f0131df6eece718be8f64adc559d Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

2020-11-18 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17235157#comment-17235157 ] Jark Wu commented on FLINK-20231: - How do you execute these two INSERT INTO statement? D

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

2020-11-18 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20231?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-20231: Component/s: Table SQL / Planner > Sql UDTF subplan reuse on correlate > -

[jira] [Closed] (FLINK-20187) FactoryUtil#createTableSource will be confused by a table source and a table sink factory with same identifier

2020-11-18 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20187?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-20187. --- Resolution: Fixed Fixed in master (1.12.0): b4d885dc9cfc28d7a6cb2f58925cf072dc916b0b > FactoryUtil#createTa

[GitHub] [flink] wuchong merged pull request #14105: [FLINK-20187][table-common] Fix factory discovering fails when source and sink factories are not implemented in one class

2020-11-18 Thread GitBox
wuchong merged pull request #14105: URL: https://github.com/apache/flink/pull/14105 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] wuchong commented on pull request #14105: [FLINK-20187][table-common] Fix factory discovering fails when source and sink factories are not implemented in one class

2020-11-18 Thread GitBox
wuchong commented on pull request #14105: URL: https://github.com/apache/flink/pull/14105#issuecomment-730109204 Thanks @godfreyhe , this is another issue and has been tracked by FLINK-20186. I think Timo has already been working on this. Will merge this PR then.

[jira] [Closed] (FLINK-20218) AttributeError: module 'urllib' has no attribute 'parse'

2020-11-18 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20218?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-20218. --- Resolution: Fixed Fixed in release-1.10 via 2fbef47bed73d3847fd88a292802551fcef64050 > AttributeError: modu

[GitHub] [flink] dianfu merged pull request #14125: [FLINK-20218][python] Import urllib.parse before importing apache-beam

2020-11-18 Thread GitBox
dianfu merged pull request #14125: URL: https://github.com/apache/flink/pull/14125 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] flinkbot edited a comment on pull request #14124: [FLINK-20229][docs]remove duplicate "for"

2020-11-18 Thread GitBox
flinkbot edited a comment on pull request #14124: URL: https://github.com/apache/flink/pull/14124#issuecomment-730073761 ## CI report: * ba1a5763fe0ecf2635e970d14d930bee75ac9265 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

2020-11-18 Thread Junning Liang (Jira)
Junning Liang created FLINK-20231: - Summary: Sql UDTF subplan reuse on correlate Key: FLINK-20231 URL: https://issues.apache.org/jira/browse/FLINK-20231 Project: Flink Issue Type: Improvement

[GitHub] [flink] flinkbot edited a comment on pull request #14125: [FLINK-20218][python] Import urllib.parse before importing apache-beam

2020-11-18 Thread GitBox
flinkbot edited a comment on pull request #14125: URL: https://github.com/apache/flink/pull/14125#issuecomment-730091045 ## CI report: * 8affa1758f97c6ff6a02e0fe9f815556820d864f Travis: [PENDING](https://travis-ci.com/github/flink-ci/flink/builds/202621275) Bot comman

[GitHub] [flink] flinkbot commented on pull request #14125: [FLINK-20218][python] Import urllib.parse before importing apache-beam

2020-11-18 Thread GitBox
flinkbot commented on pull request #14125: URL: https://github.com/apache/flink/pull/14125#issuecomment-730091045 ## CI report: * 8affa1758f97c6ff6a02e0fe9f815556820d864f UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

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

2020-11-18 Thread GitBox
godfreyhe commented on a change in pull request #13291: URL: https://github.com/apache/flink/pull/13291#discussion_r526553328 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/rules/logical/CorrelateSortToRankRule.scala ## @

[jira] [Commented] (FLINK-20221) DelimitedInputFormat does not restore compressed filesplits correctly leading to dataloss

2020-11-18 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20221?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17235133#comment-17235133 ] Xintong Song commented on FLINK-20221: -- [~gyfora], thanks for reporting the issue.

[jira] [Assigned] (FLINK-20218) AttributeError: module 'urllib' has no attribute 'parse'

2020-11-18 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20218?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-20218: --- Assignee: Huang Xingbo > AttributeError: module 'urllib' has no attribute 'parse' > ---

[jira] [Comment Edited] (FLINK-20218) AttributeError: module 'urllib' has no attribute 'parse'

2020-11-18 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20218?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17235132#comment-17235132 ] Dian Fu edited comment on FLINK-20218 at 11/19/20, 2:36 AM:

[jira] [Commented] (FLINK-20218) AttributeError: module 'urllib' has no attribute 'parse'

2020-11-18 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20218?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17235132#comment-17235132 ] Dian Fu commented on FLINK-20218: - [~hxbks2ks] Thanks a lot for the investigation. +1 to

[jira] [Updated] (FLINK-20221) DelimitedInputFormat does not restore compressed filesplits correctly leading to dataloss

2020-11-18 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20221?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-20221: - Fix Version/s: 1.11.3 1.10.3 1.12.0 > DelimitedInputFormat

[jira] [Commented] (FLINK-19940) Task names on web UI should change when an operator chain is chained with sources

2020-11-18 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19940?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17235129#comment-17235129 ] Caizhi Weng commented on FLINK-19940: - [~roman_khachatryan] This is what is currentl

[jira] [Commented] (FLINK-20062) ContinuousHiveSplitEnumerator should be lock-free

2020-11-18 Thread Rui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20062?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17235127#comment-17235127 ] Rui Li commented on FLINK-20062: Thanks [~lzljs3620320] for merging the PR. I think the

[GitHub] [flink] flinkbot commented on pull request #14125: [FLINK-20218][python] Import urllib.parse before importing apache-beam

2020-11-18 Thread GitBox
flinkbot commented on pull request #14125: URL: https://github.com/apache/flink/pull/14125#issuecomment-730084932 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-20218) AttributeError: module 'urllib' has no attribute 'parse'

2020-11-18 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20218?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-20218: --- Labels: pull-request-available (was: ) > AttributeError: module 'urllib' has no attribute '

[GitHub] [flink] flinkbot edited a comment on pull request #14124: [FLINK-20229][docs]remove duplicate "for"

2020-11-18 Thread GitBox
flinkbot edited a comment on pull request #14124: URL: https://github.com/apache/flink/pull/14124#issuecomment-730073761 ## CI report: * ba1a5763fe0ecf2635e970d14d930bee75ac9265 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14099: [Flink-20190][API/DataStream]A New Window Trigger that can trigger window operation both by event time interval、event count

2020-11-18 Thread GitBox
flinkbot edited a comment on pull request #14099: URL: https://github.com/apache/flink/pull/14099#issuecomment-728904723 ## CI report: * 14881fe955909c3b715720a66d1b41b78fe98a36 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14068: [FLINK-200137][python] Emit timestamps of current records to downstream in PythonFunctionOperator.

2020-11-18 Thread GitBox
flinkbot edited a comment on pull request #14068: URL: https://github.com/apache/flink/pull/14068#issuecomment-726851708 ## CI report: * 0ce46be8b552e937db8fb1c193efe43c8ff1e477 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] HuangXingBo opened a new pull request #14125: [FLINK-20218][python] Import urllib.parse before importing apache-beam

2020-11-18 Thread GitBox
HuangXingBo opened a new pull request #14125: URL: https://github.com/apache/flink/pull/14125 ## What is the purpose of the change *This pull request will import `urllib.parse` before importing `apache-beam`* ## Brief change log - *import `urllib.parse` before impo

[jira] [Closed] (FLINK-20062) ContinuousHiveSplitEnumerator should be lock-free

2020-11-18 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20062?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-20062. Assignee: Rui Li Resolution: Fixed master (1.12): cd833c2584810102723c49e6f0c5eb3b3f79311f

[jira] [Updated] (FLINK-19940) Task names on web UI should change when an operator chain is chained with sources

2020-11-18 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19940?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng updated FLINK-19940: Attachment: multi-web-ui.png > Task names on web UI should change when an operator chain is chaine

[GitHub] [flink] JingsongLi merged pull request #13998: [FLINK-20062][hive] ContinuousHiveSplitEnumerator should be lock-free

2020-11-18 Thread GitBox
JingsongLi merged pull request #13998: URL: https://github.com/apache/flink/pull/13998 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

[jira] [Closed] (FLINK-19949) Unescape CSV format line and field delimiter character

2020-11-18 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19949?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-19949. --- Resolution: Fixed Fixed in master (1.12.0): - afb239e311aad2a8237e8be001a12d8af102e2b2 - 8b2d0ace9b56f2639

[GitHub] [flink] wuchong merged pull request #13900: [FLINK-19949][csv] Unescape CSV format line delimiter character

2020-11-18 Thread GitBox
wuchong merged pull request #13900: URL: https://github.com/apache/flink/pull/13900 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] [Updated] (FLINK-20230) PARTITIONED TABLE, INSERT INTO EMPTY VALUES, THROW FileNotFoundException

2020-11-18 Thread liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20230?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] liu updated FLINK-20230: Description: if table has PARTITIONED, USE SQL "INSERT INTO VALUES", WHEN THE VALUES IS NULL, AND IT WILL THROW F

[jira] [Updated] (FLINK-20230) PARTITIONED TABLE, INSERT INTO EMPTY VALUES, THROW FileNotFoundException

2020-11-18 Thread liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20230?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] liu updated FLINK-20230: Environment: TABLE DDL: CREATE TABLE IF NOT EXISTS test1 ( uid string, truename string, dt string ) ROW FORM

[jira] [Created] (FLINK-20230) PARTITIONED TABLE, INSERT INTO EMPTY VALUES, THROW FileNotFoundException

2020-11-18 Thread liu (Jira)
liu created FLINK-20230: --- Summary: PARTITIONED TABLE, INSERT INTO EMPTY VALUES, THROW FileNotFoundException Key: FLINK-20230 URL: https://issues.apache.org/jira/browse/FLINK-20230 Project: Flink Issu

[jira] [Commented] (FLINK-20218) AttributeError: module 'urllib' has no attribute 'parse'

2020-11-18 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20218?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17235109#comment-17235109 ] Huang Xingbo commented on FLINK-20218: -- The reason for the problem through investig

[jira] [Updated] (FLINK-20218) AttributeError: module 'urllib' has no attribute 'parse'

2020-11-18 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20218?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-20218: Affects Version/s: (was: 1.10.2) 1.10.3 > AttributeError: module 'urllib' has n

[GitHub] [flink] flinkbot commented on pull request #14124: [FLINK-20229][docs]remove duplicate "for"

2020-11-18 Thread GitBox
flinkbot commented on pull request #14124: URL: https://github.com/apache/flink/pull/14124#issuecomment-730073761 ## CI report: * ba1a5763fe0ecf2635e970d14d930bee75ac9265 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot edited a comment on pull request #14099: [Flink-20190][API/DataStream]A New Window Trigger that can trigger window operation both by event time interval、event count

2020-11-18 Thread GitBox
flinkbot edited a comment on pull request #14099: URL: https://github.com/apache/flink/pull/14099#issuecomment-728904723 ## CI report: * 14881fe955909c3b715720a66d1b41b78fe98a36 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-19687) Support to get execution plan in `StatementSet`

2020-11-18 Thread xiaozilong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19687?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17235107#comment-17235107 ] xiaozilong commented on FLINK-19687: [~jark] Thanks~ > Support to get execution pla

[GitHub] [flink] flinkbot edited a comment on pull request #14068: [FLINK-200137][python] Emit timestamps of current records to downstream in PythonFunctionOperator.

2020-11-18 Thread GitBox
flinkbot edited a comment on pull request #14068: URL: https://github.com/apache/flink/pull/14068#issuecomment-726851708 ## CI report: * 0ce46be8b552e937db8fb1c193efe43c8ff1e477 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

2020-11-18 Thread GaryGao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17235101#comment-17235101 ] GaryGao commented on FLINK-20190: - Hi, [~aljoscha],[~rmetzger],would you please spare so

[jira] [Commented] (FLINK-17827) scala-shell.sh should fail early if no mode is specified, or have default logging settings

2020-11-18 Thread Thomas Thornton (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17827?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17235100#comment-17235100 ] Thomas Thornton commented on FLINK-17827: - Hi, [~chesnay], I want to gain consen

  1   2   3   4   5   >