[jira] [Updated] (FLINK-15205) add doc and exmaple of INSERT OVERWRITE and insert into partitioned table for Hive connector

[ https://issues.apache.org/jira/browse/FLINK-15205?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-15205: - Fix Version/s: (was: 1.11.0) > add doc and exmaple of INSERT OVERWRITE and insert into partitioned

[jira] [Updated] (FLINK-15234) hive table created from flink catalog table shouldn't have null properties in parameters

[ https://issues.apache.org/jira/browse/FLINK-15234?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-15234: - Fix Version/s: (was: 1.11.0) > hive table created from flink catalog table shouldn't have null

[jira] [Updated] (FLINK-15240) is_generic key is missing for Flink table stored in HiveCatalog

[ https://issues.apache.org/jira/browse/FLINK-15240?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-15240: - Fix Version/s: (was: 1.11.0) > is_generic key is missing for Flink table stored in HiveCatalog >

[jira] [Commented] (FLINK-15256) unable to drop table in HiveCatalogITCase

[ https://issues.apache.org/jira/browse/FLINK-15256?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16999063#comment-16999063 ] Gary Yao commented on FLINK-15256: -- Is this issue completed? The PR was merged but Status is "Open" and

[jira] [Updated] (FLINK-15257) convert HiveCatalogITCase.testCsvTableViaAPI() to use blink planner

[ https://issues.apache.org/jira/browse/FLINK-15257?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-15257: - Fix Version/s: (was: 1.11.0) > convert HiveCatalogITCase.testCsvTableViaAPI() to use blink planner

[jira] [Comment Edited] (FLINK-9009) Error| You are creating too many HashedWheelTimer instances. HashedWheelTimer is a shared resource that must be reused across the application, so that only a few

[ https://issues.apache.org/jira/browse/FLINK-9009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16999056#comment-16999056 ] Subramanyam Ramanathan edited comment on FLINK-9009 at 12/18/19 11:33 AM:

[jira] [Updated] (FLINK-15256) unable to drop table in HiveCatalogITCase

[ https://issues.apache.org/jira/browse/FLINK-15256?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-15256: - Fix Version/s: (was: 1.11.0) > unable to drop table in HiveCatalogITCase >

[jira] [Commented] (FLINK-15254) modules in SQL CLI yaml should preserve order

[ https://issues.apache.org/jira/browse/FLINK-15254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16999061#comment-16999061 ] Gary Yao commented on FLINK-15254: -- At this point we should set fix version only to 1.10 because 1.10

[jira] [Comment Edited] (FLINK-15263) add dedicated page for HiveCatalog

[ https://issues.apache.org/jira/browse/FLINK-15263?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16999058#comment-16999058 ] Gary Yao edited comment on FLINK-15263 at 12/18/19 11:32 AM: - At this point

[jira] [Updated] (FLINK-15254) modules in SQL CLI yaml should preserve order

[ https://issues.apache.org/jira/browse/FLINK-15254?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-15254: - Fix Version/s: (was: 1.11.0) > modules in SQL CLI yaml should preserve order >

[jira] [Commented] (FLINK-15263) add dedicated page for HiveCatalog

[ https://issues.apache.org/jira/browse/FLINK-15263?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16999058#comment-16999058 ] Gary Yao commented on FLINK-15263: -- At this point we should set fix version only to 1.10 because 1.10

[jira] [Updated] (FLINK-15263) add dedicated page for HiveCatalog

[ https://issues.apache.org/jira/browse/FLINK-15263?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-15263: - Fix Version/s: (was: 1.11.0) > add dedicated page for HiveCatalog >

[jira] [Commented] (FLINK-9009) Error| You are creating too many HashedWheelTimer instances. HashedWheelTimer is a shared resource that must be reused across the application, so that only a few insta

[ https://issues.apache.org/jira/browse/FLINK-9009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16999056#comment-16999056 ] Subramanyam Ramanathan commented on FLINK-9009: --- Hi, I'm seeing a similar issue when using

[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=16999051#comment-16999051 ] Gary Yao commented on FLINK-15317: -- Same root cause as FLINK-15285 > State TTL Heap backend

[jira] [Assigned] (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 ] Gary Yao reassigned FLINK-15317: Assignee: Arvid Heise > State TTL Heap backend end-to-end test fails on Travis >

[jira] [Assigned] (FLINK-15012) Checkpoint directory not cleaned up

[ https://issues.apache.org/jira/browse/FLINK-15012?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhijiang reassigned FLINK-15012: Assignee: Yun Tang > Checkpoint directory not cleaned up > --- >

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

Gary Yao created FLINK-15317: Summary: State TTL Heap backend end-to-end test fails on Travis Key: FLINK-15317 URL: https://issues.apache.org/jira/browse/FLINK-15317 Project: Flink Issue Type:

[jira] [Updated] (FLINK-15316) SQL Client end-to-end test (Old planner) failed on Travis

[ https://issues.apache.org/jira/browse/FLINK-15316?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-15316: - Labels: test-stability (was: ) > SQL Client end-to-end test (Old planner) failed on Travis >

[jira] [Created] (FLINK-15316) SQL Client end-to-end test (Old planner) failed on Travis

Gary Yao created FLINK-15316: Summary: SQL Client end-to-end test (Old planner) failed on Travis Key: FLINK-15316 URL: https://issues.apache.org/jira/browse/FLINK-15316 Project: Flink Issue

[jira] [Created] (FLINK-15315) Add test case for rest

lining created FLINK-15315: -- Summary: Add test case for rest Key: FLINK-15315 URL: https://issues.apache.org/jira/browse/FLINK-15315 Project: Flink Issue Type: Improvement Components:

[jira] [Created] (FLINK-15314) To refactor duplicated code in TaskManagerDetailsHandler#createTaskManagerMetricsInfo

lining created FLINK-15314: -- Summary: To refactor duplicated code in TaskManagerDetailsHandler#createTaskManagerMetricsInfo Key: FLINK-15314 URL: https://issues.apache.org/jira/browse/FLINK-15314 Project:

[jira] [Updated] (FLINK-14223) Kafka010ProducerITCase>KafkaProducerTestBase.testCustomPartitioning fails on Travis

[ https://issues.apache.org/jira/browse/FLINK-14223?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Li updated FLINK-14223: -- Priority: Major (was: Critical) Lower the priority according to above analysis, and thanks for the efforts

[jira] [Closed] (FLINK-12283) Table API does not allow non-static inner class as UDF

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

[jira] [Commented] (FLINK-15313) Can not insert decimal with precision into sink using TypeInformation

[ https://issues.apache.org/jira/browse/FLINK-15313?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16998988#comment-16998988 ] Jingsong Lee commented on FLINK-15313: -- CC: [~jark] > Can not insert decimal with precision into

[jira] [Created] (FLINK-15313) Can not insert decimal with precision into sink using TypeInformation

Jingsong Lee created FLINK-15313: Summary: Can not insert decimal with precision into sink using TypeInformation Key: FLINK-15313 URL: https://issues.apache.org/jira/browse/FLINK-15313 Project: Flink

[jira] [Updated] (FLINK-15312) Remove PlanExposingEnvironment

[ https://issues.apache.org/jira/browse/FLINK-15312?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen updated FLINK-15312: -- Component/s: Tests > Remove PlanExposingEnvironment > -- > >

[jira] [Created] (FLINK-15312) Remove PlanExposingEnvironment

Zili Chen created FLINK-15312: - Summary: Remove PlanExposingEnvironment Key: FLINK-15312 URL: https://issues.apache.org/jira/browse/FLINK-15312 Project: Flink Issue Type: Sub-task

[GitHub] [flink] JingsongLi commented on issue #10620: [FLINK-15239][table-planner-blink] TM Metaspace memory leak

JingsongLi commented on issue #10620: [FLINK-15239][table-planner-blink] TM Metaspace memory leak URL: https://github.com/apache/flink/pull/10620#issuecomment-566939603 Worried about cache size, will be a lot of classes...

[jira] [Commented] (FLINK-15258) HiveModuleFactory should take hive-version as property

[ https://issues.apache.org/jira/browse/FLINK-15258?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16998961#comment-16998961 ] Till Rohrmann commented on FLINK-15258: --- Another comment, the commit you referenced here has a a

[GitHub] [flink] flinkbot commented on issue #10620: [FLINK-15239][table-planner-blink] TM Metaspace memory leak

flinkbot commented on issue #10620: [FLINK-15239][table-planner-blink] TM Metaspace memory leak URL: https://github.com/apache/flink/pull/10620#issuecomment-566939479 ## CI report: * 3df54cc407edd9bf81f5ba3a418789d478ed79db UNKNOWN Bot commands The @flinkbot bot

[GitHub] [flink] flinkbot edited a comment on issue #10619: [FLINK-15175]Fix CTES not supported in SQL CLI

flinkbot edited a comment on issue #10619: [FLINK-15175]Fix CTES not supported in SQL CLI URL: https://github.com/apache/flink/pull/10619#issuecomment-566919711 ## CI report: * 6a8566b5b33bb07c0277da8842b511f6b4722f10 Travis:

[GitHub] [flink] lirui-apache commented on a change in pull request #10618: [FLINK-15287][hive] Disable hive orc optimization for version less than 2.3

lirui-apache commented on a change in pull request #10618: [FLINK-15287][hive] Disable hive orc optimization for version less than 2.3 URL: https://github.com/apache/flink/pull/10618#discussion_r359222595 ## File path: docs/dev/table/hive/read_write_hive.md ## @@ -141,11

[GitHub] [flink] flinkbot edited a comment on issue #10617: [FLINK-15021][network] Remove setting of netty channel watermark and logic of writability changed

flinkbot edited a comment on issue #10617: [FLINK-15021][network] Remove setting of netty channel watermark and logic of writability changed URL: https://github.com/apache/flink/pull/10617#issuecomment-566861496 ## CI report: * 6e5bf2f53eb76820e08f0ed5f823c2b0f2670da7 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10613: [FLINK-14944][python] Fix pip install ConnectionResetError

flinkbot edited a comment on issue #10613: [FLINK-14944][python] Fix pip install ConnectionResetError URL: https://github.com/apache/flink/pull/10613#issuecomment-566837415 ## CI report: * 6e71f5bdfb17354a0e182c25ebab67108aa39727 Travis:

[jira] [Commented] (FLINK-15258) HiveModuleFactory should take hive-version as property

[ https://issues.apache.org/jira/browse/FLINK-15258?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16998959#comment-16998959 ] Till Rohrmann commented on FLINK-15258: --- In the future I would appreciate if you could add a bit

[GitHub] [flink] twalthr commented on a change in pull request #10503: [FLINK-15137][avro] Improve schema derivation for Avro format

twalthr commented on a change in pull request #10503: [FLINK-15137][avro] Improve schema derivation for Avro format URL: https://github.com/apache/flink/pull/10503#discussion_r359213028 ## File path:

[GitHub] [flink] twalthr commented on a change in pull request #10503: [FLINK-15137][avro] Improve schema derivation for Avro format

twalthr commented on a change in pull request #10503: [FLINK-15137][avro] Improve schema derivation for Avro format URL: https://github.com/apache/flink/pull/10503#discussion_r359214883 ## File path:

[GitHub] [flink] twalthr commented on a change in pull request #10503: [FLINK-15137][avro] Improve schema derivation for Avro format

twalthr commented on a change in pull request #10503: [FLINK-15137][avro] Improve schema derivation for Avro format URL: https://github.com/apache/flink/pull/10503#discussion_r359213626 ## File path:

[GitHub] [flink] twalthr commented on a change in pull request #10503: [FLINK-15137][avro] Improve schema derivation for Avro format

twalthr commented on a change in pull request #10503: [FLINK-15137][avro] Improve schema derivation for Avro format URL: https://github.com/apache/flink/pull/10503#discussion_r359216153 ## File path:

[GitHub] [flink] twalthr commented on a change in pull request #10503: [FLINK-15137][avro] Improve schema derivation for Avro format

twalthr commented on a change in pull request #10503: [FLINK-15137][avro] Improve schema derivation for Avro format URL: https://github.com/apache/flink/pull/10503#discussion_r359212649 ## File path:

[GitHub] [flink] twalthr commented on a change in pull request #10503: [FLINK-15137][avro] Improve schema derivation for Avro format

twalthr commented on a change in pull request #10503: [FLINK-15137][avro] Improve schema derivation for Avro format URL: https://github.com/apache/flink/pull/10503#discussion_r359209793 ## File path:

[GitHub] [flink] twalthr commented on a change in pull request #10503: [FLINK-15137][avro] Improve schema derivation for Avro format

twalthr commented on a change in pull request #10503: [FLINK-15137][avro] Improve schema derivation for Avro format URL: https://github.com/apache/flink/pull/10503#discussion_r359216053 ## File path:

[jira] [Commented] (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:comment-tabpanel=16998946#comment-16998946 ] Yingjie Cao commented on FLINK-15311: - [~lzljs3620320] Thanks for reporting this issue. I will check

[jira] [Commented] (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:comment-tabpanel=16998943#comment-16998943 ] Jingsong Lee commented on FLINK-15311: -- CC: [~kevin.cyj] > Lz4BlockCompressionFactory should use

[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 ] Jingsong Lee updated FLINK-15311: - Description: According to: [https://lz4.github.io/lz4-java/1.7.0/lz4-compression-benchmark/]

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

Jingsong Lee created FLINK-15311: Summary: Lz4BlockCompressionFactory should use native compressor instead of java unsafe Key: FLINK-15311 URL: https://issues.apache.org/jira/browse/FLINK-15311

[GitHub] [flink] danny0405 commented on issue #10595: [Flink-13197] Fix Hive view row type mismatch when expanding in planner

danny0405 commented on issue #10595: [Flink-13197] Fix Hive view row type mismatch when expanding in planner URL: https://github.com/apache/flink/pull/10595#issuecomment-566934013 Oops, there was check-style error, let me fix it.

[jira] [Updated] (FLINK-15310) A timestamp result get by a select sql and a csvsink sql is different

[ https://issues.apache.org/jira/browse/FLINK-15310?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xiaojin.wy updated FLINK-15310: --- Description: *The sql is:* CREATE TABLE `orders` ( rowtime TIMESTAMP, id INT,

[jira] [Updated] (FLINK-15310) A timestamp result get by a select sql and a csvsink sql is different

[ https://issues.apache.org/jira/browse/FLINK-15310?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xiaojin.wy updated FLINK-15310: --- Description: *The sql is:* CREATE TABLE `orders` ( rowtime TIMESTAMP, id INT,

[jira] [Commented] (FLINK-15310) A timestamp result get by a select sql and a csvsink sql is different

[ https://issues.apache.org/jira/browse/FLINK-15310?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16998938#comment-16998938 ] xiaojin.wy commented on FLINK-15310: [~danny0405] > A timestamp result get by a select sql and a

[jira] [Created] (FLINK-15310) A timestamp result get by a select sql and a csvsink sql is different

xiaojin.wy created FLINK-15310: -- Summary: A timestamp result get by a select sql and a csvsink sql is different Key: FLINK-15310 URL: https://issues.apache.org/jira/browse/FLINK-15310 Project: Flink

[jira] [Comment Edited] (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=16998931#comment-16998931 ] Feng Jiajie edited comment on FLINK-15308 at 12/18/19 8:35 AM: --- Here is my

[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=16998934#comment-16998934 ] Yingjie Cao commented on FLINK-15308: - [~fengjiajie] Thanks for reporting the issue and sharing the

[jira] [Comment Edited] (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=16998931#comment-16998931 ] Feng Jiajie edited comment on FLINK-15308 at 12/18/19 8:30 AM: ---

[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=16998931#comment-16998931 ] Feng Jiajie commented on FLINK-15308: -

[GitHub] [flink] flinkbot edited a comment on issue #10619: [FLINK-15175]Fix CTES not supported in SQL CLI

flinkbot edited a comment on issue #10619: [FLINK-15175]Fix CTES not supported in SQL CLI URL: https://github.com/apache/flink/pull/10619#issuecomment-566919711 ## CI report: * 6a8566b5b33bb07c0277da8842b511f6b4722f10 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10617: [FLINK-15021][network] Remove setting of netty channel watermark and logic of writability changed

flinkbot edited a comment on issue #10617: [FLINK-15021][network] Remove setting of netty channel watermark and logic of writability changed URL: https://github.com/apache/flink/pull/10617#issuecomment-566861496 ## CI report: * 6e5bf2f53eb76820e08f0ed5f823c2b0f2670da7 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10613: [FLINK-14944][python] Fix pip install ConnectionResetError

flinkbot edited a comment on issue #10613: [FLINK-14944][python] Fix pip install ConnectionResetError URL: https://github.com/apache/flink/pull/10613#issuecomment-566837415 ## CI report: * 6e71f5bdfb17354a0e182c25ebab67108aa39727 Travis:

[GitHub] [flink] lirui-apache commented on issue #10620: [FLINK-15239][table-planner-blink] TM Metaspace memory leak

lirui-apache commented on issue #10620: [FLINK-15239][table-planner-blink] TM Metaspace memory leak URL: https://github.com/apache/flink/pull/10620#issuecomment-566928997 cc @JingsongLi @KurtYoung Please let me know if you think the change makes sense. Thank you.

[GitHub] [flink] lirui-apache commented on issue #10620: [FLINK-15239][table-planner-blink] TM Metaspace memory leak

lirui-apache commented on issue #10620: [FLINK-15239][table-planner-blink] TM Metaspace memory leak URL: https://github.com/apache/flink/pull/10620#issuecomment-566928696 I changed the key and value type of this cache because guava will use identity comparison to determine equality of

[GitHub] [flink] flinkbot edited a comment on issue #10572: [FLINK-15249] Improve PipelinedRegions calculation performance

flinkbot edited a comment on issue #10572: [FLINK-15249] Improve PipelinedRegions calculation performance URL: https://github.com/apache/flink/pull/10572#issuecomment-565476705 ## CI report: * d42e975c447f30b11799293255dde585f4b7b48f Travis:

[jira] [Commented] (FLINK-15264) Job Manager TASK_SLOTS_TOTAL metrics does not shows the Job ID

[ https://issues.apache.org/jira/browse/FLINK-15264?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16998927#comment-16998927 ] xiaogang zhou commented on FLINK-15264: --- As There is  JobID jobId attribute in the 

[jira] [Commented] (FLINK-15239) TM Metaspace memory leak

[ https://issues.apache.org/jira/browse/FLINK-15239?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16998925#comment-16998925 ] Rui Li commented on FLINK-15239: I tried moving the Hadoop dependencies to parent class loader. While it

[GitHub] [flink] flinkbot commented on issue #10620: [FLINK-15239][table-planner-blink] TM Metaspace memory leak

flinkbot commented on issue #10620: [FLINK-15239][table-planner-blink] TM Metaspace memory leak URL: https://github.com/apache/flink/pull/10620#issuecomment-566927079 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your

[jira] [Updated] (FLINK-15239) TM Metaspace memory leak

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

[GitHub] [flink] lirui-apache opened a new pull request #10620: [FLINK-15239][table-planner-blink] TM Metaspace memory leak

lirui-apache opened a new pull request #10620: [FLINK-15239][table-planner-blink] TM Metaspace memory leak URL: https://github.com/apache/flink/pull/10620 ## What is the purpose of the change Fix the metaspace memory leak of TM. ## Brief change log - Use

[GitHub] [flink] JingsongLi commented on issue #10619: [FLINK-15175]Fix CTES not supported in SQL CLI

JingsongLi commented on issue #10619: [FLINK-15175]Fix CTES not supported in SQL CLI URL: https://github.com/apache/flink/pull/10619#issuecomment-566926207 > We should be careful with introducing new SQL syntax. Is this official SQL standard? Are other vendors (like Oracle, Hive,

[jira] [Updated] (FLINK-15161) Introduce TypeTransformation interface and basic transformations

[ https://issues.apache.org/jira/browse/FLINK-15161?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-15161: Fix Version/s: (was: 1.11.0) 1.10.0 > Introduce TypeTransformation interface and

[jira] [Commented] (FLINK-15161) Introduce TypeTransformation interface and basic transformations

[ https://issues.apache.org/jira/browse/FLINK-15161?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16998916#comment-16998916 ] Jark Wu commented on FLINK-15161: - Cherry-pick to 1.10.0: 208de7c29f2ca71b526f98f603cf4a55103c5520

[jira] [Assigned] (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:all-tabpanel ] zhijiang reassigned FLINK-15308: Assignee: Yingjie Cao > Job failed when enable pipelined-shuffle.compression and

[jira] [Closed] (FLINK-1275) Add support to compress network I/O

[ https://issues.apache.org/jira/browse/FLINK-1275?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhijiang closed FLINK-1275. --- Resolution: Duplicate This issue was already done via 

[GitHub] [flink] KarmaGYZ commented on a change in pull request #10602: [FLINK-10938] Add e2e test for natively running flink session cluster on kubernetes

KarmaGYZ commented on a change in pull request #10602: [FLINK-10938] Add e2e test for natively running flink session cluster on kubernetes URL: https://github.com/apache/flink/pull/10602#discussion_r359199916 ## File path: tools/travis/splits/split_container.sh ## @@

[GitHub] [flink] KarmaGYZ commented on a change in pull request #10602: [FLINK-10938] Add e2e test for natively running flink session cluster on kubernetes

KarmaGYZ commented on a change in pull request #10602: [FLINK-10938] Add e2e test for natively running flink session cluster on kubernetes URL: https://github.com/apache/flink/pull/10602#discussion_r359200529 ## File path:

[jira] [Updated] (FLINK-14944) Unstable test FlinkFnExecutionSyncTests.test_flink_fn_execution_pb2_synced

[ https://issues.apache.org/jira/browse/FLINK-14944?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-14944: Fix Version/s: 1.10.0 > Unstable test

[GitHub] [flink] wuchong commented on issue #10500: [FLINK-15161][table-common] Introduce TypeTransformation interface and basic transformations

wuchong commented on issue #10500: [FLINK-15161][table-common] Introduce TypeTransformation interface and basic transformations URL: https://github.com/apache/flink/pull/10500#issuecomment-566922341 Thanks. Then I will check pick it to release-1.10 branch, as FLINK-15289 may requires

[GitHub] [flink] dawidwys commented on a change in pull request #10595: [Flink-13197] Fix Hive view row type mismatch when expanding in planner

dawidwys commented on a change in pull request #10595: [Flink-13197] Fix Hive view row type mismatch when expanding in planner URL: https://github.com/apache/flink/pull/10595#discussion_r359201610 ## File path:

[GitHub] [flink] hequn8128 commented on issue #10613: [FLINK-14944][python] Fix pip install ConnectionResetError

hequn8128 commented on issue #10613: [FLINK-14944][python] Fix pip install ConnectionResetError URL: https://github.com/apache/flink/pull/10613#issuecomment-566921426 Thanks for the update. Will merge this once Travis passed

[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 ] xiaojin.wy updated FLINK-15309: --- Description: *The sql is:* CREATE TABLE `src` ( key bigint, v varchar ) WITH (

<    1   2