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

[ https://issues.apache.org/jira/browse/FLINK-18830?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17208780#comment-17208780 ] liupengcheng commented on FLINK-18830: -- [~aljoscha] [~jark] Thanks for clarification, yes, I think

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

[ https://issues.apache.org/jira/browse/FLINK-18830?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17202114#comment-17202114 ] liupengcheng commented on FLINK-18830: -- hi，[~aljoscha] I think you've missed some information, the

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

[ https://issues.apache.org/jira/browse/FLINK-18830?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17194313#comment-17194313 ] liupengcheng commented on FLINK-18830: -- Hi, [~aljoscha] It's about both of them. I'm thinking about

[jira] [Commented] (FLINK-7865) Remove predicate restrictions on TableFunction left outer join

[ https://issues.apache.org/jira/browse/FLINK-7865?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17177423#comment-17177423 ] liupengcheng commented on FLINK-7865: - [~xccui] Thanks for your work! I just met this issue when

[jira] [Commented] (FLINK-7865) Remove predicate restrictions on TableFunction left outer join

[ https://issues.apache.org/jira/browse/FLINK-7865?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17176268#comment-17176268 ] liupengcheng commented on FLINK-7865: - [~xccui] any progress? I think currently the blocker is

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

[ https://issues.apache.org/jira/browse/FLINK-18852?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17175958#comment-17175958 ] liupengcheng commented on FLINK-18852: -- hi [~jark], yes, I only tested the legacy planner, and the

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

[ https://issues.apache.org/jira/browse/FLINK-18830?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17175288#comment-17175288 ] liupengcheng commented on FLINK-18830: -- cc [~aljoscha] [~dwysakowicz] > JoinCoGroupFunction and

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

[ https://issues.apache.org/jira/browse/FLINK-18830?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17174370#comment-17174370 ] liupengcheng commented on FLINK-18830: -- The above plan allows evaluating user defined functions(may

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

[ https://issues.apache.org/jira/browse/FLINK-18830?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17172797#comment-17172797 ] liupengcheng edited comment on FLINK-18830 at 8/9/20, 1:01 PM: --- First, I

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

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

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

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

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

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

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

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

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

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

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

[ https://issues.apache.org/jira/browse/FLINK-18830?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17172797#comment-17172797 ] liupengcheng edited comment on FLINK-18830 at 8/7/20, 9:41 AM: --- First, I

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

[ https://issues.apache.org/jira/browse/FLINK-18830?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17172797#comment-17172797 ] liupengcheng commented on FLINK-18830: -- First, I think we can create a new functionalInterface,

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

[ https://issues.apache.org/jira/browse/FLINK-18830?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] liupengcheng updated FLINK-18830: - Description: Currently, The `JoinCoGroupFunction` and `FlatJoinCoGroupFunction` in

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

liupengcheng created FLINK-18830: Summary: JoinCoGroupFunction and FlatJoinCoGroupFunction work incorrectly for outer join when one side of coGroup is empty Key: FLINK-18830 URL:

[jira] [Commented] (FLINK-15906) physical memory exceeded causing being killed by yarn

[ https://issues.apache.org/jira/browse/FLINK-15906?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17039661#comment-17039661 ] liupengcheng commented on FLINK-15906: -- [~fly_in_gis] Thanks for giving this link, I've planed to

[jira] [Comment Edited] (FLINK-15906) physical memory exceeded causing being killed by yarn

[ https://issues.apache.org/jira/browse/FLINK-15906?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17039657#comment-17039657 ] liupengcheng edited comment on FLINK-15906 at 2/19/20 2:37 AM: ---

[jira] [Comment Edited] (FLINK-15906) physical memory exceeded causing being killed by yarn

[ https://issues.apache.org/jira/browse/FLINK-15906?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17039657#comment-17039657 ] liupengcheng edited comment on FLINK-15906 at 2/19/20 2:33 AM: ---

[jira] [Commented] (FLINK-15906) physical memory exceeded causing being killed by yarn

[ https://issues.apache.org/jira/browse/FLINK-15906?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17039657#comment-17039657 ] liupengcheng commented on FLINK-15906: -- [~fly_in_gis][~xintongsong]This issue happens quite often

[jira] [Created] (FLINK-15906) physical memory exceeded causing being killed by yarn

liupengcheng created FLINK-15906: Summary: physical memory exceeded causing being killed by yarn Key: FLINK-15906 URL: https://issues.apache.org/jira/browse/FLINK-15906 Project: Flink Issue

[jira] [Created] (FLINK-15848) Support both fixed allocator and dynamic allocator in flink

liupengcheng created FLINK-15848: Summary: Support both fixed allocator and dynamic allocator in flink Key: FLINK-15848 URL: https://issues.apache.org/jira/browse/FLINK-15848 Project: Flink

[jira] [Created] (FLINK-15702) Make sqlClient classloader aligned with other components

liupengcheng created FLINK-15702: Summary: Make sqlClient classloader aligned with other components Key: FLINK-15702 URL: https://issues.apache.org/jira/browse/FLINK-15702 Project: Flink

[jira] [Commented] (FLINK-12362) Remove legacy container number config option for Flink on yarn

[ https://issues.apache.org/jira/browse/FLINK-12362?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17018857#comment-17018857 ] liupengcheng commented on FLINK-12362: -- [~trohrmann] Thanks, till, can I create a Jira for this? I

[jira] [Commented] (FLINK-12362) Remove legacy container number config option for Flink on yarn

[ https://issues.apache.org/jira/browse/FLINK-12362?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17014840#comment-17014840 ] liupengcheng commented on FLINK-12362: -- [~trohrmann] [~yanghua] I still wondering how to set the a

[jira] [Closed] (FLINK-15392) SqlClient throws exception 'Table already exists' when repeated submit a same query

[ https://issues.apache.org/jira/browse/FLINK-15392?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] liupengcheng closed FLINK-15392. Resolution: Duplicate > SqlClient throws exception 'Table already exists' when repeated submit a

[jira] [Commented] (FLINK-15392) SqlClient throws exception 'Table already exists' when repeated submit a same query

[ https://issues.apache.org/jira/browse/FLINK-15392?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17005205#comment-17005205 ] liupengcheng commented on FLINK-15392: -- [~jark] Thanks, I think  FLINK-15073. already fix it. I'll

[jira] [Commented] (FLINK-15392) SqlClient throws exception 'Table already exists' when repeated submit a same query

[ https://issues.apache.org/jira/browse/FLINK-15392?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17003213#comment-17003213 ] liupengcheng commented on FLINK-15392: -- I will try to create an PR for it later. > SqlClient

[jira] [Updated] (FLINK-15392) SqlClient throws exception 'Table already exists' when repeated submit a same query

[ https://issues.apache.org/jira/browse/FLINK-15392?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] liupengcheng updated FLINK-15392: - Component/s: Table SQL / Client Affects Version/s: 1.10.0 Description: When

[jira] [Created] (FLINK-15392) SqlClient

liupengcheng created FLINK-15392: Summary: SqlClient Key: FLINK-15392 URL: https://issues.apache.org/jira/browse/FLINK-15392 Project: Flink Issue Type: Bug Reporter:

[jira] [Comment Edited] (FLINK-15175) syntax not supported in SQLClient for TPCDS queries

[ https://issues.apache.org/jira/browse/FLINK-15175?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16998876#comment-16998876 ] liupengcheng edited comment on FLINK-15175 at 12/18/19 7:29 AM:

[jira] [Commented] (FLINK-15175) syntax not supported in SQLClient for TPCDS queries

[ https://issues.apache.org/jira/browse/FLINK-15175?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16998876#comment-16998876 ] liupengcheng commented on FLINK-15175: -- [~ykt836] [~lzljs3620320] I've create an tempory fix

[jira] [Commented] (FLINK-15175) syntax not supported in SQLClient for TPCDS queries

[ https://issues.apache.org/jira/browse/FLINK-15175?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16993155#comment-16993155 ] liupengcheng commented on FLINK-15175: -- Thanks for reply, [~ykt836] [~lzljs3620320], Can you assign

[jira] [Created] (FLINK-15175) syntax not supported in SQLClient for TPCDS queries

liupengcheng created FLINK-15175: Summary: syntax not supported in SQLClient for TPCDS queries Key: FLINK-15175 URL: https://issues.apache.org/jira/browse/FLINK-15175 Project: Flink Issue

[jira] [Created] (FLINK-14876) Putting xercesImpl related classes into alwaysParentFirstLoaderPatterns

liupengcheng created FLINK-14876: Summary: Putting xercesImpl related classes into alwaysParentFirstLoaderPatterns Key: FLINK-14876 URL: https://issues.apache.org/jira/browse/FLINK-14876 Project:

[jira] [Commented] (FLINK-14037) Deserializing the input/output formats failed: unread block data

[ https://issues.apache.org/jira/browse/FLINK-14037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16970738#comment-16970738 ] liupengcheng commented on FLINK-14037: -- Can I continue working on it? [~chesnay] > Deserializing

[jira] [Commented] (FLINK-14037) Deserializing the input/output formats failed: unread block data

[ https://issues.apache.org/jira/browse/FLINK-14037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16970690#comment-16970690 ] liupengcheng commented on FLINK-14037: -- [~chesnay] hi, I notice that this Jira is closed as

[jira] [Commented] (FLINK-14429) Wrong app final status when running batch job on yarn with non-detached mode

[ https://issues.apache.org/jira/browse/FLINK-14429?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16956946#comment-16956946 ] liupengcheng commented on FLINK-14429: -- Thanks [~trohrmann] [~aljoscha] , I got it! >Conceptually,

[jira] [Commented] (FLINK-14429) Wrong app final status when running batch job on yarn with non-detached mode

[ https://issues.apache.org/jira/browse/FLINK-14429?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16956159#comment-16956159 ] liupengcheng commented on FLINK-14429: -- [~trohrmann] In the current impl, the client will polling

[jira] [Updated] (FLINK-14123) Lower the default value of taskmanager.memory.fraction

[ https://issues.apache.org/jira/browse/FLINK-14123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] liupengcheng updated FLINK-14123: - Summary: Lower the default value of taskmanager.memory.fraction (was: Change

[jira] [Commented] (FLINK-14429) Wrong app final status when running batch job on yarn with non-detached mode

[ https://issues.apache.org/jira/browse/FLINK-14429?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16955702#comment-16955702 ] liupengcheng commented on FLINK-14429: -- Hi, [~trohrmann], it will throw exceptions when job

[jira] [Commented] (FLINK-14429) Wrong app final status when running batch job on yarn with non-detached mode

[ https://issues.apache.org/jira/browse/FLINK-14429?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16953618#comment-16953618 ] liupengcheng commented on FLINK-14429: -- [~trohrmann] Even for multi part jobs, we should fail the

[jira] [Updated] (FLINK-14429) Wrong app final status when running batch job on yarn with non-detached mode

[ https://issues.apache.org/jira/browse/FLINK-14429?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] liupengcheng updated FLINK-14429: - Summary: Wrong app final status when running batch job on yarn with non-detached mode (was:

[jira] [Created] (FLINK-14429) Wrong app final status when running yarn-cluster in non-detached mode

liupengcheng created FLINK-14429: Summary: Wrong app final status when running yarn-cluster in non-detached mode Key: FLINK-14429 URL: https://issues.apache.org/jira/browse/FLINK-14429 Project: Flink

[jira] [Commented] (FLINK-14123) Change taskmanager.memory.fraction default value to 0.6

[ https://issues.apache.org/jira/browse/FLINK-14123?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16952874#comment-16952874 ] liupengcheng commented on FLINK-14123: -- [~trohrmann] Thanks! I will update these docs in this PR.

[jira] [Commented] (FLINK-14123) Change taskmanager.memory.fraction default value to 0.6

[ https://issues.apache.org/jira/browse/FLINK-14123?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16951816#comment-16951816 ] liupengcheng commented on FLINK-14123: -- Thanks [~xintongsong], I also tend to agree with Till too

[jira] [Commented] (FLINK-14123) Change taskmanager.memory.fraction default value to 0.6

[ https://issues.apache.org/jira/browse/FLINK-14123?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16950063#comment-16950063 ] liupengcheng commented on FLINK-14123: -- [~xintongsong] I think it's a common case, because I just

[jira] [Commented] (FLINK-14123) Change taskmanager.memory.fraction default value to 0.6

[ https://issues.apache.org/jira/browse/FLINK-14123?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16950006#comment-16950006 ] liupengcheng commented on FLINK-14123: -- [~xintongsong] I still have some doubt about your opinion,

[jira] [Commented] (FLINK-14123) Change taskmanager.memory.fraction default value to 0.6

[ https://issues.apache.org/jira/browse/FLINK-14123?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16948071#comment-16948071 ] liupengcheng commented on FLINK-14123: -- [~xintongsong] Thanks, I got it! maybe we can have more

[jira] [Created] (FLINK-14341) Flink-python builds with failure: no such option: --prefix

liupengcheng created FLINK-14341: Summary: Flink-python builds with failure: no such option: --prefix Key: FLINK-14341 URL: https://issues.apache.org/jira/browse/FLINK-14341 Project: Flink

[jira] [Commented] (FLINK-14123) Change taskmanager.memory.fraction default value to 0.6

[ https://issues.apache.org/jira/browse/FLINK-14123?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16946446#comment-16946446 ] liupengcheng commented on FLINK-14123: -- [~xintongsong] Hi, thanks for your comment to let me know

[jira] [Created] (FLINK-14292) Provide terasort examples

liupengcheng created FLINK-14292: Summary: Provide terasort examples Key: FLINK-14292 URL: https://issues.apache.org/jira/browse/FLINK-14292 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-14123) Change taskmanager.memory.fraction default value to 0.6

[ https://issues.apache.org/jira/browse/FLINK-14123?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16940610#comment-16940610 ] liupengcheng commented on FLINK-14123: -- [~StephanEwen] Thanks for your reply, I tested the app with

[jira] [Commented] (FLINK-14037) Deserializing the input/output formats failed: unread block data

[ https://issues.apache.org/jira/browse/FLINK-14037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16934315#comment-16934315 ] liupengcheng commented on FLINK-14037: -- [~zhuzh] I retest my case, I enabled `-verbose:class` in

[jira] [Commented] (FLINK-14123) Change taskmanager.memory.fraction default value to 0.6

[ https://issues.apache.org/jira/browse/FLINK-14123?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16934283#comment-16934283 ] liupengcheng commented on FLINK-14123: -- [~StephanEwen] Yes, you are right, we are using jdk8, and

[jira] [Commented] (FLINK-14038) ExecutionGraph deploy failed due to akka timeout

[ https://issues.apache.org/jira/browse/FLINK-14038?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16933289#comment-16933289 ] liupengcheng commented on FLINK-14038: -- [~trohrmann] This is an example of the JVM GC logger logs: 

[jira] [Commented] (FLINK-14123) Change taskmanager.memory.fraction default value to 0.6

[ https://issues.apache.org/jira/browse/FLINK-14123?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16933272#comment-16933272 ] liupengcheng commented on FLINK-14123: -- [~StephanEwen] Yes, I tested terasort with changed value on

[jira] [Updated] (FLINK-14123) Change taskmanager.memory.fraction default value to 0.6

[ https://issues.apache.org/jira/browse/FLINK-14123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] liupengcheng updated FLINK-14123: - Description: Currently, we are testing flink batch task, such as terasort, however, it started

[jira] [Created] (FLINK-14123) Change taskmanager.memory.fraction default value to 0.6

liupengcheng created FLINK-14123: Summary: Change taskmanager.memory.fraction default value to 0.6 Key: FLINK-14123 URL: https://issues.apache.org/jira/browse/FLINK-14123 Project: Flink

[jira] [Commented] (FLINK-14037) Deserializing the input/output formats failed: unread block data

[ https://issues.apache.org/jira/browse/FLINK-14037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16933087#comment-16933087 ] liupengcheng commented on FLINK-14037: -- [~zhuzh]  Yes, that's weird, Maybe I think your test is

[jira] [Commented] (FLINK-14038) ExecutionGraph deploy failed due to akka timeout

[ https://issues.apache.org/jira/browse/FLINK-14038?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16932982#comment-16932982 ] liupengcheng commented on FLINK-14038: -- [~zhuzh] [~trohrmann] This PR not only provide gc logs, but

[jira] [Commented] (FLINK-14038) ExecutionGraph deploy failed due to akka timeout

[ https://issues.apache.org/jira/browse/FLINK-14038?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16932192#comment-16932192 ] liupengcheng commented on FLINK-14038: -- Currently, this PR does not show this gc log in UI, maybe

[jira] [Commented] (FLINK-14038) ExecutionGraph deploy failed due to akka timeout

[ https://issues.apache.org/jira/browse/FLINK-14038?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16932185#comment-16932185 ] liupengcheng commented on FLINK-14038: -- Thank you [~zhuzh] [~StephanEwen], I finally verified that

[jira] [Commented] (FLINK-14037) Deserializing the input/output formats failed: unread block data

[ https://issues.apache.org/jira/browse/FLINK-14037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16932153#comment-16932153 ] liupengcheng commented on FLINK-14037: -- [~zhuzh] I think you are right, the base class will always

[jira] [Commented] (FLINK-14037) Deserializing the input/output formats failed: unread block data

[ https://issues.apache.org/jira/browse/FLINK-14037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16932012#comment-16932012 ] liupengcheng commented on FLINK-14037: -- [~zhuzh] Can you share your test code? Do you include

[jira] [Comment Edited] (FLINK-14037) Deserializing the input/output formats failed: unread block data

[ https://issues.apache.org/jira/browse/FLINK-14037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16931080#comment-16931080 ] liupengcheng edited comment on FLINK-14037 at 9/17/19 4:42 AM: --- [~zhuzh] 

[jira] [Commented] (FLINK-14037) Deserializing the input/output formats failed: unread block data

[ https://issues.apache.org/jira/browse/FLINK-14037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16931080#comment-16931080 ] liupengcheng commented on FLINK-14037: -- [~zhuzh]  >However, I'm not sure whether this should be

[jira] [Commented] (FLINK-14037) Deserializing the input/output formats failed: unread block data

[ https://issues.apache.org/jira/browse/FLINK-14037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16930345#comment-16930345 ] liupengcheng commented on FLINK-14037: -- I enabled `-verbose:class` and this following output is the

[jira] [Commented] (FLINK-14037) Deserializing the input/output formats failed: unread block data

[ https://issues.apache.org/jira/browse/FLINK-14037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16930343#comment-16930343 ] liupengcheng commented on FLINK-14037: -- [~zhuzh] Yes, the version of the libs you metioned are

[jira] [Commented] (FLINK-14037) Deserializing the input/output formats failed: unread block data

[ https://issues.apache.org/jira/browse/FLINK-14037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16926550#comment-16926550 ] liupengcheng commented on FLINK-14037: -- [~zhuzh] Yes, I tried deploying pre-bundled hadoop jar, but

[jira] [Created] (FLINK-14038) ExecutionGraph deploy failed due to akka timeout

liupengcheng created FLINK-14038: Summary: ExecutionGraph deploy failed due to akka timeout Key: FLINK-14038 URL: https://issues.apache.org/jira/browse/FLINK-14038 Project: Flink Issue Type:

[jira] [Created] (FLINK-14037) Deserializing the input/output formats failed: unread block data

liupengcheng created FLINK-14037: Summary: Deserializing the input/output formats failed: unread block data Key: FLINK-14037 URL: https://issues.apache.org/jira/browse/FLINK-14037 Project: Flink