[jira] [Commented] (FLINK-13910) Many serializable classes have no explicit 'serialVersionUID'

[ https://issues.apache.org/jira/browse/FLINK-13910?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1789#comment-1789 ] Timo Walther commented on FLINK-13910: -- Thanks for the explanation [~yunta]. For a major version,

[GitHub] [flink] tillrohrmann opened a new pull request #10635: [WIP][FLINK-XXXX] Move zookeeper to runtime

tillrohrmann opened a new pull request #10635: [WIP][FLINK-] Move zookeeper to runtime URL: https://github.com/apache/flink/pull/10635 WIP for moving ZooKeeper dependency into flink-runtime. This is an automated message

[jira] [Commented] (FLINK-13910) Many serializable classes have no explicit 'serialVersionUID'

[ https://issues.apache.org/jira/browse/FLINK-13910?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17000116#comment-17000116 ] Dawid Wysakowicz commented on FLINK-13910: -- I partially agree and partially not. Actually we

[jira] [Commented] (FLINK-15333) Using FlinkCostFactory rather than RelOptCostImpl in blink planner

[ https://issues.apache.org/jira/browse/FLINK-15333?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17000120#comment-17000120 ] Leonard Xu commented on FLINK-15333: CC: [~godfreyhe] > Using FlinkCostFactory rather than

[jira] [Closed] (FLINK-15149) Merge InputTypeStrategy and InputTypeValidator

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

[jira] [Comment Edited] (FLINK-13910) Many serializable classes have no explicit 'serialVersionUID'

[ https://issues.apache.org/jira/browse/FLINK-13910?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1786#comment-1786 ] Yun Tang edited comment on FLINK-13910 at 12/19/19 1:49 PM: [~twalthr]  #

[jira] [Closed] (FLINK-15285) Resuming Externalized Checkpoint (file, async, no parallelism change) E2E test fails on Travis

[ https://issues.apache.org/jira/browse/FLINK-15285?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-15285. -- Resolution: Duplicate > Resuming Externalized Checkpoint (file, async, no parallelism change)

[jira] [Commented] (FLINK-15285) Resuming Externalized Checkpoint (file, async, no parallelism change) E2E test fails on Travis

[ https://issues.apache.org/jira/browse/FLINK-15285?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17000141#comment-17000141 ] Arvid Heise commented on FLINK-15285: - Duplicate of

[jira] [Updated] (FLINK-15309) Execute sql appear "NumberFormatException: Zero length BigInteger"

[ https://issues.apache.org/jira/browse/FLINK-15309?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-15309: Fix Version/s: 1.10.0 > Execute sql appear "NumberFormatException: Zero length BigInteger" >

[jira] [Updated] (FLINK-15326) Add document description for DECIMAL(38, 18) when the sink table uses json schema

[ https://issues.apache.org/jira/browse/FLINK-15326?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-15326: Component/s: Table SQL / Planner > Add document description for DECIMAL(38, 18) when the sink table uses

[jira] [Updated] (FLINK-15326) Add document description for DECIMAL(38, 18) when the sink table uses json schema

[ https://issues.apache.org/jira/browse/FLINK-15326?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-15326: Fix Version/s: 1.10.0 > Add document description for DECIMAL(38, 18) when the sink table uses json >

[jira] [Updated] (FLINK-15332) Jepsen tests are broken due to copying un-relocated flink-s3-fs-hadoop* into lib

[ https://issues.apache.org/jira/browse/FLINK-15332?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-15332: --- Labels: pull-request-available test-stability (was: test-stability) > Jepsen tests are

[jira] [Commented] (FLINK-13910) Many serializable classes have no explicit 'serialVersionUID'

[ https://issues.apache.org/jira/browse/FLINK-13910?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17000103#comment-17000103 ] Yun Tang commented on FLINK-13910: -- [~dwysakowicz] I just edited my previous reply before noticing your

[jira] [Created] (FLINK-15335) add-dependencies-for-IDEA not working anymore and dangerous in general

Nico Kruber created FLINK-15335: --- Summary: add-dependencies-for-IDEA not working anymore and dangerous in general Key: FLINK-15335 URL: https://issues.apache.org/jira/browse/FLINK-15335 Project: Flink

[GitHub] [flink] wsry opened a new pull request #10636: [FLINK-15311][runtime] Remove shade of org.lz4:lz4-java to make lz4 block compression use native implementation by default.

wsry opened a new pull request #10636: [FLINK-15311][runtime] Remove shade of org.lz4:lz4-java to make lz4 block compression use native implementation by default. URL: https://github.com/apache/flink/pull/10636 ## What is the purpose of the change Currently, org.lz4:lz4-java library is

[jira] [Updated] (FLINK-15311) Lz4BlockCompressionFactory should use native compressor instead of java unsafe

[ https://issues.apache.org/jira/browse/FLINK-15311?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-15311: --- Labels: pull-request-available (was: ) > Lz4BlockCompressionFactory should use native

[jira] [Created] (FLINK-15331) Create a table from a changelog

Timo Walther created FLINK-15331: Summary: Create a table from a changelog Key: FLINK-15331 URL: https://issues.apache.org/jira/browse/FLINK-15331 Project: Flink Issue Type: New Feature

[jira] [Closed] (FLINK-15317) State TTL Heap backend end-to-end test fails on Travis

[ https://issues.apache.org/jira/browse/FLINK-15317?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-15317. -- Resolution: Fixed merged commit 36aff23 to master merged commit 08d63a7 to release-1.10 >

[jira] [Created] (FLINK-15332) Jepsen tests are broken due to copying un-relocated flink-s3-fs-hadoop* into lib

Till Rohrmann created FLINK-15332: - Summary: Jepsen tests are broken due to copying un-relocated flink-s3-fs-hadoop* into lib Key: FLINK-15332 URL: https://issues.apache.org/jira/browse/FLINK-15332

[jira] [Comment Edited] (FLINK-13910) Many serializable classes have no explicit 'serialVersionUID'

[ https://issues.apache.org/jira/browse/FLINK-13910?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1786#comment-1786 ] Yun Tang edited comment on FLINK-13910 at 12/19/19 2:05 PM: [~twalthr]  #

[jira] [Commented] (FLINK-13910) Many serializable classes have no explicit 'serialVersionUID'

[ https://issues.apache.org/jira/browse/FLINK-13910?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1792#comment-1792 ] Dawid Wysakowicz commented on FLINK-13910: -- I agree with [~twalthr] and [~aljoscha]. Moreover

[GitHub] [flink] tillrohrmann opened a new pull request #10634: [FLINK-15332][jepsen] Copy flink-s3-fs-hadoop* into /plugins directory instead of lib

tillrohrmann opened a new pull request #10634: [FLINK-15332][jepsen] Copy flink-s3-fs-hadoop* into /plugins directory instead of lib URL: https://github.com/apache/flink/pull/10634 ## What is the purpose of the change We can no longer copy the flink-s3-fs-hadoop* jars into lib as

[jira] [Created] (FLINK-15333) Using FlinkCostFactory rather than RelOptCostImpl in blink planner

Leonard Xu created FLINK-15333: -- Summary: Using FlinkCostFactory rather than RelOptCostImpl in blink planner Key: FLINK-15333 URL: https://issues.apache.org/jira/browse/FLINK-15333 Project: Flink

[jira] [Comment Edited] (FLINK-13910) Many serializable classes have no explicit 'serialVersionUID'

[ https://issues.apache.org/jira/browse/FLINK-13910?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17000116#comment-17000116 ] Dawid Wysakowicz edited comment on FLINK-13910 at 12/19/19 2:52 PM:

[jira] [Created] (FLINK-15334) Fix schemaValidator because properties mapping may change if user defined generated columns before custom columns

Leonard Xu created FLINK-15334: -- Summary: Fix schemaValidator because properties mapping may change if user defined generated columns before custom columns Key: FLINK-15334 URL:

[jira] [Commented] (FLINK-13613) Update state migration tests for Flink 1.9

[ https://issues.apache.org/jira/browse/FLINK-13613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17000146#comment-17000146 ] vinoyang commented on FLINK-13613: -- Hi [~trohrmann] Since Flink 1.10's feature has been frozen. Do you

[jira] [Commented] (FLINK-13910) Many serializable classes have no explicit 'serialVersionUID'

[ https://issues.apache.org/jira/browse/FLINK-13910?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1786#comment-1786 ] Yun Tang commented on FLINK-13910: -- [~twalthr]  # If we do not add serialVersionUID, we actually

[jira] [Commented] (FLINK-15268) Shaded Hadoop S3A end-to-end test fails on travis

[ https://issues.apache.org/jira/browse/FLINK-15268?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1794#comment-1794 ] Till Rohrmann commented on FLINK-15268: --- Another instance:

[jira] [Assigned] (FLINK-15268) Shaded Hadoop S3A end-to-end test fails on travis

[ https://issues.apache.org/jira/browse/FLINK-15268?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-15268: - Assignee: Arvid Heise > Shaded Hadoop S3A end-to-end test fails on travis >

[jira] [Commented] (FLINK-15268) Shaded Hadoop S3A end-to-end test fails on travis

[ https://issues.apache.org/jira/browse/FLINK-15268?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17000117#comment-17000117 ] Till Rohrmann commented on FLINK-15268: --- Arvid will take a look at the problem. > Shaded Hadoop

[jira] [Created] (FLINK-15336) Support temporal table function outer joins

Timo Walther created FLINK-15336: Summary: Support temporal table function outer joins Key: FLINK-15336 URL: https://issues.apache.org/jira/browse/FLINK-15336 Project: Flink Issue Type: New

[jira] [Closed] (FLINK-15168) Exception is thrown when using kafka source connector with flink planner

[ https://issues.apache.org/jira/browse/FLINK-15168?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-15168. Resolution: Fixed Fixed in master: 39b7992db59fb55d5408b5528d17c924dfce649e 1.10:

[jira] [Closed] (FLINK-14683) RemoteStreamEnvironment's construction function has a wrong method

[ https://issues.apache.org/jira/browse/FLINK-14683?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-14683. -- Fix Version/s: 1.10.0 1.9.2 Resolution: Fixed Merged on master with

[GitHub] [flink] wsry opened a new pull request #10639: [FLINK-15311][runtime] Remove shade of org.lz4:lz4-java to make lz4 block compression use native implementation by default.

wsry opened a new pull request #10639: [FLINK-15311][runtime] Remove shade of org.lz4:lz4-java to make lz4 block compression use native implementation by default. URL: https://github.com/apache/flink/pull/10639 ## What is the purpose of the change Currently, org.lz4:lz4-java library is

[jira] [Closed] (FLINK-14311) Streaming File Sink end-to-end test failed on Travis

[ https://issues.apache.org/jira/browse/FLINK-14311?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Li closed FLINK-14311. - Resolution: Cannot Reproduce Close the issue since cannot reproduce according to above comments. Thanks

[jira] [Comment Edited] (FLINK-14311) Streaming File Sink end-to-end test failed on Travis

[ https://issues.apache.org/jira/browse/FLINK-14311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17000624#comment-17000624 ] Yu Li edited comment on FLINK-14311 at 12/20/19 5:06 AM: - Close the issue since

[jira] [Created] (FLINK-15339) Correct the terminology of "Time-windowed Join" to "Interval Join" in Table API & SQL

Jark Wu created FLINK-15339: --- Summary: Correct the terminology of "Time-windowed Join" to "Interval Join" in Table API & SQL Key: FLINK-15339 URL: https://issues.apache.org/jira/browse/FLINK-15339 Project:

[jira] [Commented] (FLINK-15339) Correct the terminology of "Time-windowed Join" to "Interval Join" in Table API & SQL

[ https://issues.apache.org/jira/browse/FLINK-15339?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17000655#comment-17000655 ] Jark Wu commented on FLINK-15339: - cc [~twalthr] > Correct the terminology of "Time-windowed Join" to

[jira] [Updated] (FLINK-15334) Fix schemaValidator because properties mapping may change if user defined generated columns before custom columns

[ https://issues.apache.org/jira/browse/FLINK-15334?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-15334: --- Description: If user defined a DDL like: "CREATE TABLE orders (\n" + " order_id

[jira] [Assigned] (FLINK-11767) Update TypeSerializerSnapshotMigrationTestBase and subclasses for 1.8

[ https://issues.apache.org/jira/browse/FLINK-11767?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-11767: Assignee: Aljoscha Krettek (was: Tzu-Li (Gordon) Tai) > Update

[jira] [Assigned] (FLINK-13613) Update state migration tests for Flink 1.9

[ https://issues.apache.org/jira/browse/FLINK-13613?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-13613: Assignee: Aljoscha Krettek (was: vinoyang) > Update state migration tests for

[jira] [Created] (FLINK-15341) Reset context classload in PackagedProgramUtils#createJobGraph

Zili Chen created FLINK-15341: - Summary: Reset context classload in PackagedProgramUtils#createJobGraph Key: FLINK-15341 URL: https://issues.apache.org/jira/browse/FLINK-15341 Project: Flink

[jira] [Updated] (FLINK-15337) Add vendor table to documentation

[ https://issues.apache.org/jira/browse/FLINK-15337?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman updated FLINK-15337: - Description:

[jira] [Updated] (FLINK-15152) Job running without periodic checkpoint for stop failed at the beginning

[ https://issues.apache.org/jira/browse/FLINK-15152?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Feng Jiajie updated FLINK-15152: Priority: Critical (was: Major) > Job running without periodic checkpoint for stop failed at the

[jira] [Assigned] (FLINK-15259) HiveInspector.toInspectors() should convert Flink constant to Hive constant

[ https://issues.apache.org/jira/browse/FLINK-15259?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li reassigned FLINK-15259: Assignee: Rui Li (was: Rui Li) > HiveInspector.toInspectors() should convert Flink constant to

[jira] [Commented] (FLINK-15259) HiveInspector.toInspectors() should convert Flink constant to Hive constant

[ https://issues.apache.org/jira/browse/FLINK-15259?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17000621#comment-17000621 ] Bowen Li commented on FLINK-15259: -- [~lirui] glad you added profile picture. It helps! >

[jira] [Updated] (FLINK-15259) HiveInspector.toInspectors() should convert Flink constant to Hive constant

[ https://issues.apache.org/jira/browse/FLINK-15259?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-15259: - Priority: Blocker (was: Major) > HiveInspector.toInspectors() should convert Flink constant to Hive

[jira] [Commented] (FLINK-15307) Subclasses of FailoverStrategy are easily confused with implementation classes of RestartStrategy

[ https://issues.apache.org/jira/browse/FLINK-15307?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17000653#comment-17000653 ] Zili Chen commented on FLINK-15307: --- cc [~zhuzh] what do you think of this? > Subclasses of

[jira] [Resolved] (FLINK-15266) NPE in blink planner code gen

[ https://issues.apache.org/jira/browse/FLINK-15266?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu resolved FLINK-15266. - Resolution: Fixed 1.11.0: 5f86f2d1ae608a4d2259bfcf637d97b490dbd328 1.10.0:

[GitHub] [flink] TisonKun opened a new pull request #10641: [FLINK-15341][client] Reset context classload in PackagedProgramUtils#createJobGraph

TisonKun opened a new pull request #10641: [FLINK-15341][client] Reset context classload in PackagedProgramUtils#createJobGraph URL: https://github.com/apache/flink/pull/10641 It happens we don't reset context classload in PackagedProgramUtils#createJobGraph. For fixing this, we can just

[jira] [Commented] (FLINK-15331) Create a table from a changelog

[ https://issues.apache.org/jira/browse/FLINK-15331?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17000553#comment-17000553 ] Danny Chen commented on FLINK-15331: +1, thanks for firing this, [~twalthr] > Create a table from a

[GitHub] [flink] wsry opened a new pull request #10638: [FLINK-15308][runtime] Remove data compression for pipelined shuffle.

wsry opened a new pull request #10638: [FLINK-15308][runtime] Remove data compression for pipelined shuffle. URL: https://github.com/apache/flink/pull/10638 ## What is the purpose of the change This PR removes data compression for pipelined shuffle mode. The feature may be added in the

[jira] [Commented] (FLINK-15317) State TTL Heap backend end-to-end test fails on Travis

[ https://issues.apache.org/jira/browse/FLINK-15317?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17000585#comment-17000585 ] Yu Li commented on FLINK-15317: --- Thanks for the further confirmation and quick fix [~pnowojski]! > State

[jira] [Resolved] (FLINK-15050) DataFormatConverters should support any TIMESTAMP WITHOUT TIME ZONE types

[ https://issues.apache.org/jira/browse/FLINK-15050?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu resolved FLINK-15050. - Resolution: Fixed 1.11.0: 6053e7ad39e6c3aa4427803f50c4ee828bcd1f59 1.10.0:

[jira] [Created] (FLINK-15340) Remove the executor of pipelined compression benchmark

zhijiang created FLINK-15340: Summary: Remove the executor of pipelined compression benchmark Key: FLINK-15340 URL: https://issues.apache.org/jira/browse/FLINK-15340 Project: Flink Issue Type:

[jira] [Created] (FLINK-15338) TM Metaspace memory leak when submitting PyFlink UDF jobs multiple times

sunjincheng created FLINK-15338: --- Summary: TM Metaspace memory leak when submitting PyFlink UDF jobs multiple times Key: FLINK-15338 URL: https://issues.apache.org/jira/browse/FLINK-15338 Project:

[jira] [Updated] (FLINK-15338) TM Metaspace memory leak when submitting PyFlink UDF jobs multiple times

[ https://issues.apache.org/jira/browse/FLINK-15338?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-15338: Component/s: (was: Runtime / Task) > TM Metaspace memory leak when submitting PyFlink UDF

[jira] [Updated] (FLINK-15338) TM Metaspace memory leak when submitting PyFlink UDF jobs multiple times

[ https://issues.apache.org/jira/browse/FLINK-15338?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-15338: Fix Version/s: 1.10.0 > TM Metaspace memory leak when submitting PyFlink UDF jobs multiple times

[jira] [Updated] (FLINK-15262) kafka connector doesn't read from beginning immediately when 'connector.startup-mode' = 'earliest-offset'

[ https://issues.apache.org/jira/browse/FLINK-15262?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-15262: - Description: I created a kafka table in Flink to read from my kakfa topic (already has messages in it)

[jira] [Commented] (FLINK-15262) kafka connector doesn't read from beginning immediately when 'connector.startup-mode' = 'earliest-offset'

[ https://issues.apache.org/jira/browse/FLINK-15262?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17000615#comment-17000615 ] Bowen Li commented on FLINK-15262: -- [~becket_qin] I added some steps > kafka connector doesn't read

[GitHub] [flink] bowenli86 opened a new pull request #10640: [hotfix][doc] add section for various optimizations of reading Hive tables

bowenli86 opened a new pull request #10640: [hotfix][doc] add section for various optimizations of reading Hive tables URL: https://github.com/apache/flink/pull/10640 ## What is the purpose of the change add section for various optimizations of reading Hive tables ## Brief

[jira] [Commented] (FLINK-15307) Subclasses of FailoverStrategy are easily confused with implementation classes of RestartStrategy

[ https://issues.apache.org/jira/browse/FLINK-15307?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17000660#comment-17000660 ] Zhu Zhu commented on FLINK-15307: - Agreed that we can change the class name to avoid confusion to

[jira] [Updated] (FLINK-15273) Complete and Update Documentation for 1.10

[ https://issues.apache.org/jira/browse/FLINK-15273?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Li updated FLINK-15273: -- Labels: documentaion (was: docuentation) Priority: Blocker (was: Major) Marking as blocker as per

[jira] [Commented] (FLINK-15307) Subclasses of FailoverStrategy are easily confused with implementation classes of RestartStrategy

[ https://issues.apache.org/jira/browse/FLINK-15307?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17000666#comment-17000666 ] andrew.D.lin commented on FLINK-15307: -- [~zhuzh]  [~tison]   > Subclasses of FailoverStrategy are

[jira] [Issue Comment Deleted] (FLINK-15307) Subclasses of FailoverStrategy are easily confused with implementation classes of RestartStrategy

[ https://issues.apache.org/jira/browse/FLINK-15307?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] andrew.D.lin updated FLINK-15307: - Comment: was deleted (was: [~zhuzh]  [~tison]  ) > Subclasses of FailoverStrategy are easily

[jira] [Commented] (FLINK-15249) Improve PipelinedRegions calculation with Union Set

[ https://issues.apache.org/jira/browse/FLINK-15249?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17000686#comment-17000686 ] Zhu Zhu commented on FLINK-15249: - Hi [~nppoly], sorry but I'm still busy with some 1.10 release

[jira] [Updated] (FLINK-15337) Add vendor table to documentation

[ https://issues.apache.org/jira/browse/FLINK-15337?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman updated FLINK-15337: - Component/s: Documentation > Add vendor table to documentation >

[jira] [Created] (FLINK-15337) Add vendor table to documentation

Seth Wiesman created FLINK-15337: Summary: Add vendor table to documentation Key: FLINK-15337 URL: https://issues.apache.org/jira/browse/FLINK-15337 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-15319) flink-end-to-end-tests-common-kafka fails due to timeout

[ https://issues.apache.org/jira/browse/FLINK-15319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17000564#comment-17000564 ] Zheng Hu commented on FLINK-15319: -- I guess it was timeout to download the kafka binary packages

[jira] [Commented] (FLINK-15338) TM Metaspace memory leak when submitting PyFlink UDF jobs multiple times

[ https://issues.apache.org/jira/browse/FLINK-15338?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17000577#comment-17000577 ] sunjincheng commented on FLINK-15338: - We dumped the heap and found that there are two places which

[jira] [Comment Edited] (FLINK-15338) TM Metaspace memory leak when submitting PyFlink UDF jobs multiple times

[ https://issues.apache.org/jira/browse/FLINK-15338?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17000577#comment-17000577 ] sunjincheng edited comment on FLINK-15338 at 12/20/19 3:17 AM: --- We dumped

[jira] [Commented] (FLINK-15338) TM Metaspace memory leak when submitting PyFlink UDF jobs multiple times

[ https://issues.apache.org/jira/browse/FLINK-15338?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17000579#comment-17000579 ] Xintong Song commented on FLINK-15338: -- Is this the same issue as FLINK-15239? > TM Metaspace

[jira] [Commented] (FLINK-15262) kafka connector doesn't read from beginning immediately when 'connector.startup-mode' = 'earliest-offset'

[ https://issues.apache.org/jira/browse/FLINK-15262?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17000592#comment-17000592 ] Jiangjie Qin commented on FLINK-15262: -- [~phoenixjiangnan] I was trying to reproduce the issue in

[jira] [Commented] (FLINK-14177) Bump Curator From 2.12.0 to 4.2.0

[ https://issues.apache.org/jira/browse/FLINK-14177?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17000645#comment-17000645 ] lamber-ken commented on FLINK-14177: It took me a long time to care about this pr(opened at on

[jira] [Assigned] (FLINK-15334) Fix schemaValidator because properties mapping may change if user defined generated columns before custom columns

[ https://issues.apache.org/jira/browse/FLINK-15334?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-15334: --- Assignee: Leonard Xu > Fix schemaValidator because properties mapping may change if user defined

[jira] [Commented] (FLINK-15334) Fix schemaValidator because properties mapping may change if user defined generated columns before custom columns

[ https://issues.apache.org/jira/browse/FLINK-15334?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17000656#comment-17000656 ] Leonard Xu commented on FLINK-15334: [~jark] I update the description make it more clear, Could you

[jira] [Resolved] (FLINK-15269) Fix hive dialect limitation to overwrite and partition syntax

[ https://issues.apache.org/jira/browse/FLINK-15269?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu resolved FLINK-15269. - Resolution: Fixed 1.11.0: b692d101e086ee2596d3c53a5ceec0a26c74ca3d 1.10.0:

[jira] [Commented] (FLINK-15307) Subclasses of FailoverStrategy are easily confused with implementation classes of RestartStrategy

[ https://issues.apache.org/jira/browse/FLINK-15307?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17000664#comment-17000664 ] Zhu Zhu commented on FLINK-15307: - Sure, I can ping him here after the pre-requisites are ready. >

[jira] [Commented] (FLINK-15307) Subclasses of FailoverStrategy are easily confused with implementation classes of RestartStrategy

[ https://issues.apache.org/jira/browse/FLINK-15307?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17000662#comment-17000662 ] Zili Chen commented on FLINK-15307: --- Thanks for your reply [~zhuzh]. Could you guide [~andrew_lin] for

[jira] [Assigned] (FLINK-15307) Subclasses of FailoverStrategy are easily confused with implementation classes of RestartStrategy

[ https://issues.apache.org/jira/browse/FLINK-15307?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen reassigned FLINK-15307: - Assignee: andrew.D.lin > Subclasses of FailoverStrategy are easily confused with

[jira] [Updated] (FLINK-15341) Reset context classload in PackagedProgramUtils#createJobGraph

[ https://issues.apache.org/jira/browse/FLINK-15341?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-15341: --- Labels: pull-request-available (was: ) > Reset context classload in

[GitHub] [flink] wangyang0918 opened a new pull request #10642: [FLINK-10938] enable e2e test on travis

wangyang0918 opened a new pull request #10642: [FLINK-10938] enable e2e test on travis URL: https://github.com/apache/flink/pull/10642 Enable e2e test for FLINK-10938 on travis. The changes is same with #10602. This PR is only to trigger e2e test.

[jira] [Commented] (FLINK-15331) Create a table from a changelog

[ https://issues.apache.org/jira/browse/FLINK-15331?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17000543#comment-17000543 ] Kurt Young commented on FLINK-15331: +10086 > Create a table from a changelog >

[jira] [Updated] (FLINK-15337) Add vendor table to documentation

[ https://issues.apache.org/jira/browse/FLINK-15337?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman updated FLINK-15337: - Affects Version/s: 1.11.0 > Add vendor table to documentation >

[jira] [Updated] (FLINK-15319) flink-end-to-end-tests-common-kafka fails due to timeout

[ https://issues.apache.org/jira/browse/FLINK-15319?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-15319: --- Labels: pull-request-available (was: ) > flink-end-to-end-tests-common-kafka fails due to

[GitHub] [flink] openinx opened a new pull request #10637: [FLINK-15319][e2e] flink-end-to-end-tests-common-kafka fails due to t…

openinx opened a new pull request #10637: [FLINK-15319][e2e] flink-end-to-end-tests-common-kafka fails due to t… URL: https://github.com/apache/flink/pull/10637 ## What is the purpose of the change Make the e2e package download timeout to be configurable. For example, we can tuning

[jira] [Commented] (FLINK-13910) Many serializable classes have no explicit 'serialVersionUID'

[ https://issues.apache.org/jira/browse/FLINK-13910?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17000590#comment-17000590 ] Yun Tang commented on FLINK-13910: -- [~dwysakowicz] [~twalthr], thanks for your suggestions. Since you

[jira] [Commented] (FLINK-15334) Fix schemaValidator because properties mapping may change if user defined generated columns before custom columns

[ https://issues.apache.org/jira/browse/FLINK-15334?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17000637#comment-17000637 ] Jark Wu commented on FLINK-15334: - Hi [~Leonard Xu], could you list the wrong properties? > Fix

[jira] [Assigned] (FLINK-15333) Using FlinkCostFactory rather than RelOptCostImpl in blink planner

[ https://issues.apache.org/jira/browse/FLINK-15333?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-15333: --- Assignee: godfrey he > Using FlinkCostFactory rather than RelOptCostImpl in blink planner >

[jira] [Closed] (FLINK-14177) Bump Curator From 2.12.0 to 4.2.0

[ https://issues.apache.org/jira/browse/FLINK-14177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lamber-ken closed FLINK-14177. -- Resolution: Won't Fix > Bump Curator From 2.12.0 to 4.2.0 > - > >

[jira] [Commented] (FLINK-15307) Subclasses of FailoverStrategy are easily confused with implementation classes of RestartStrategy

[ https://issues.apache.org/jira/browse/FLINK-15307?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17000673#comment-17000673 ] andrew.D.lin commented on FLINK-15307: -- Hi [~zhuzh], [~tison]  OK, I am willing to do this.

[jira] [Created] (FLINK-15342) Verify querying Hive view

Rui Li created FLINK-15342: -- Summary: Verify querying Hive view Key: FLINK-15342 URL: https://issues.apache.org/jira/browse/FLINK-15342 Project: Flink Issue Type: Test Components:

[jira] [Updated] (FLINK-13910) Many serializable classes have no explicit 'serialVersionUID'

[ https://issues.apache.org/jira/browse/FLINK-13910?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-13910: - Attachment: serializable-classes-without-uid-5249249 > Many serializable classes have no explicit

[jira] [Commented] (FLINK-15338) TM Metaspace memory leak when submitting PyFlink UDF jobs multiple times

[ https://issues.apache.org/jira/browse/FLINK-15338?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17000584#comment-17000584 ] sunjincheng commented on FLINK-15338: - The causes are similar, i.e. the user classloader could not

[jira] [Commented] (FLINK-15318) RocksDBWriteBatchPerformanceTest.benchMark fails on ppc64le

[ https://issues.apache.org/jira/browse/FLINK-15318?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17000605#comment-17000605 ] Siddhesh Ghadi commented on FLINK-15318: I verified it with master, release-1.10, release-1.9 &

[jira] [Updated] (FLINK-15307) Subclasses of FailoverStrategy are easily confused with implementation classes of RestartStrategy

[ https://issues.apache.org/jira/browse/FLINK-15307?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen updated FLINK-15307: -- Affects Version/s: (was: 1.9.1) (was: 1.10.0)

[jira] [Updated] (FLINK-15307) Subclasses of FailoverStrategy are easily confused with implementation classes of RestartStrategy

[ https://issues.apache.org/jira/browse/FLINK-15307?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen updated FLINK-15307: -- Fix Version/s: 1.11.0 > Subclasses of FailoverStrategy are easily confused with implementation >

[jira] [Closed] (FLINK-15323) SQL Client end-to-end test (Old planner) failed on travis

[ https://issues.apache.org/jira/browse/FLINK-15323?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-15323. Resolution: Duplicate > SQL Client end-to-end test (Old planner) failed on travis >

[jira] [Commented] (FLINK-15308) Job failed when enable pipelined-shuffle.compression and numberOfTaskSlots > 1

[ https://issues.apache.org/jira/browse/FLINK-15308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16999868#comment-16999868 ] Yingjie Cao commented on FLINK-15308: - The problem is cause by race of multi netty threads. The

[jira] [Commented] (FLINK-14311) Streaming File Sink end-to-end test failed on Travis

[ https://issues.apache.org/jira/browse/FLINK-14311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16999871#comment-16999871 ] PengFei Li commented on FLINK-14311: I have been running the test on travis, and still can't

  1   2   3   >