[jira] [Commented] (FLINK-17091) AvroRow(De)SerializationSchema doesn't support new Timestamp conversion classes

2020-05-11 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17091?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17105140#comment-17105140 ] Dawid Wysakowicz commented on FLINK-17091: -- Hi [~Paul Lin] what you are suggest

[jira] [Assigned] (FLINK-17614) Add project ITCase for partition table in filesystem connector

2020-05-11 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17614?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-17614: Assignee: Jingsong Lee > Add project ITCase for partition table in filesystem connector

[jira] [Commented] (FLINK-17600) Blink Planner fails to generate RowtimeAttribute based on TableSource's DefinedRowtimeAttributes implementation

2020-05-11 Thread Yuval Itzchakov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17600?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17105135#comment-17105135 ] Yuval Itzchakov commented on FLINK-17600: - [~jark] Is someone actively working o

[jira] [Commented] (FLINK-17091) AvroRow(De)SerializationSchema doesn't support new Timestamp conversion classes

2020-05-11 Thread Paul Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17091?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17105131#comment-17105131 ] Paul Lin commented on FLINK-17091: -- cc [~dwysakowicz] [~twalthr]  > AvroRow(De)Seriali

[jira] [Created] (FLINK-17626) Migrate format properties to new FLIP-122

2020-05-11 Thread Jingsong Lee (Jira)
Jingsong Lee created FLINK-17626: Summary: Migrate format properties to new FLIP-122 Key: FLINK-17626 URL: https://issues.apache.org/jira/browse/FLINK-17626 Project: Flink Issue Type: Sub-tas

[jira] [Comment Edited] (FLINK-17611) Support unix domain sockets for sidecar communication in Stateful Functions

2020-05-11 Thread Tzu-Li (Gordon) Tai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17611?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17105121#comment-17105121 ] Tzu-Li (Gordon) Tai edited comment on FLINK-17611 at 5/12/20, 6:23 AM: ---

[jira] [Comment Edited] (FLINK-17611) Support unix domain sockets for sidecar communication in Stateful Functions

2020-05-11 Thread Tzu-Li (Gordon) Tai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17611?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17105121#comment-17105121 ] Tzu-Li (Gordon) Tai edited comment on FLINK-17611 at 5/12/20, 6:22 AM: ---

[jira] [Commented] (FLINK-17611) Support unix domain sockets for sidecar communication in Stateful Functions

2020-05-11 Thread Tzu-Li (Gordon) Tai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17611?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17105121#comment-17105121 ] Tzu-Li (Gordon) Tai commented on FLINK-17611: - I like this a lot, +1. And th

[jira] [Closed] (FLINK-17573) There is duplicate source data in ProcessWindowFunction

2020-05-11 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17573?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger closed FLINK-17573. -- Resolution: Not A Bug > There is duplicate source data in ProcessWindowFunction >

[jira] [Commented] (FLINK-17592) flink-table-planner doesn't compile on Scala 2.12

2020-05-11 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17592?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17105096#comment-17105096 ] Robert Metzger commented on FLINK-17592: Another case: https://dev.azure.com/ap

[jira] [Commented] (FLINK-17623) Elasticsearch sink should support user resource cleanup

2020-05-11 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17623?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17105082#comment-17105082 ] Yangze Guo commented on FLINK-17623: I think it could be a valid demand. Not sure do

[jira] [Commented] (FLINK-17274) Maven: Premature end of Content-Length delimited message body

2020-05-11 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17105083#comment-17105083 ] Robert Metzger commented on FLINK-17274: https://dev.azure.com/apache-flink/apac

[jira] [Commented] (FLINK-17623) Elasticsearch sink should support user resource cleanup

2020-05-11 Thread Yun Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17623?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17105055#comment-17105055 ] Yun Wang commented on FLINK-17623: -- [~karmagyz] Ah I was using {{RestHighLevelClient}}

[jira] [Commented] (FLINK-17625) Fix ArrayIndexOutOfBoundsException in AppendOnlyTopNFunction

2020-05-11 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17625?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17105050#comment-17105050 ] dalongliu commented on FLINK-17625: --- [~jark] Ok, thanks for your advice. > Fix ArrayI

[jira] [Closed] (FLINK-13682) Translate "Code Style - Scala Guide" page into Chinese

2020-05-11 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13682?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-13682. --- Fix Version/s: 1.11.0 Resolution: Fixed flink-web: e33628ea470918116bb75aaa4e5580d1cc8edaff > Transl

[jira] [Commented] (FLINK-17625) Fix ArrayIndexOutOfBoundsException in AppendOnlyTopNFunction

2020-05-11 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17625?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17105041#comment-17105041 ] Jark Wu commented on FLINK-17625: - Sure. Assigned to you [~lsy]. It would be better to h

[jira] [Assigned] (FLINK-17625) Fix ArrayIndexOutOfBoundsException in AppendOnlyTopNFunction

2020-05-11 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17625?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-17625: --- Assignee: dalongliu > Fix ArrayIndexOutOfBoundsException in AppendOnlyTopNFunction > --

[jira] [Commented] (FLINK-17625) Fix ArrayIndexOutOfBoundsException in AppendOnlyTopNFunction

2020-05-11 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17625?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17105039#comment-17105039 ] dalongliu commented on FLINK-17625: --- [~jark] Can I help to fix this bug? > Fix ArrayI

[jira] [Assigned] (FLINK-17609) Execute the script directly when user specified the entry script with "-py" rather than run as module.

2020-05-11 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17609?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-17609: --- Assignee: shuiqiangchen > Execute the script directly when user specified the entry script with "-p

[jira] [Updated] (FLINK-17606) Introduce DataGen connector in table

2020-05-11 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17606?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-17606: - Description: {code:java} CREATE TABLE user (     id BIGINT,     age INT,     description STRING

[jira] [Created] (FLINK-17625) Fix ArrayIndexOutOfBoundsException in AppendOnlyTopNFunction

2020-05-11 Thread Jark Wu (Jira)
Jark Wu created FLINK-17625: --- Summary: Fix ArrayIndexOutOfBoundsException in AppendOnlyTopNFunction Key: FLINK-17625 URL: https://issues.apache.org/jira/browse/FLINK-17625 Project: Flink Issue Typ

[jira] [Updated] (FLINK-17624) "TPC-DS end-to-end test (Blink planner)" is unstable

2020-05-11 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17624?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-17624: --- Component/s: (was: Table SQL / Planner) Runtime / Network > "TPC-DS end-to-end

[jira] [Commented] (FLINK-17600) Blink Planner fails to generate RowtimeAttribute based on TableSource's DefinedRowtimeAttributes implementation

2020-05-11 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17600?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17105019#comment-17105019 ] Jark Wu commented on FLINK-17600: - Thanks for the investigation, yes, this is a bug and

[jira] [Commented] (FLINK-17493) Possible direct memory leak in cassandra sink

2020-05-11 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17105018#comment-17105018 ] Xintong Song commented on FLINK-17493: -- [~nobleyd], Thanks for reporting this issue

[jira] [Updated] (FLINK-17624) "TPC-DS end-to-end test (Blink planner)" is unstable

2020-05-11 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17624?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang updated FLINK-17624: -- Summary: "TPC-DS end-to-end test (Blink planner)" is unstable (was: "TPC-DS end-to-end test (Blink pl

[jira] [Created] (FLINK-17624) "TPC-DS end-to-end test (Blink planner)' is unstable

2020-05-11 Thread Yang Wang (Jira)
Yang Wang created FLINK-17624: - Summary: "TPC-DS end-to-end test (Blink planner)' is unstable Key: FLINK-17624 URL: https://issues.apache.org/jira/browse/FLINK-17624 Project: Flink Issue Type: Bu

[jira] [Resolved] (FLINK-16845) Implement SourceReaderOperator which runs the SourceReader.

2020-05-11 Thread Jiangjie Qin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16845?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin resolved FLINK-16845. -- Fix Version/s: 1.11.0 Resolution: Implemented Merged to master:  aa1ede9835192b28324789

[jira] [Commented] (FLINK-17606) Introduce DataGen connector in table

2020-05-11 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17606?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17105013#comment-17105013 ] Jingsong Lee commented on FLINK-17606: -- Hi [~knaufk], yes, it should be a public(Pu

[jira] [Commented] (FLINK-17606) Introduce DataGen connector in table

2020-05-11 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17606?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17105010#comment-17105010 ] Jark Wu commented on FLINK-17606: - Yes. I think we will expose it as a public API and us

[jira] [Updated] (FLINK-17606) Introduce DataGen connector in table

2020-05-11 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17606?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-17606: Description: {code:java} CREATE TABLE user (     id BIGINT,     age INT,     description STRING ) WITH (  

[jira] [Commented] (FLINK-17573) There is duplicate source data in ProcessWindowFunction

2020-05-11 Thread Tammy zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17573?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17105007#comment-17105007 ] Tammy zhang commented on FLINK-17573: - ok, i will post the question on the  u...@fli

[jira] [Commented] (FLINK-17623) Elasticsearch sink should support user resource cleanup

2020-05-11 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17623?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17105003#comment-17105003 ] Yangze Guo commented on FLINK-17623: It seems the {{RestHighLevelClient}} is closed

[jira] [Closed] (FLINK-17252) supports SELECT statement in TableEnvironment#executeSql and Table#execute api

2020-05-11 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17252?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-17252. -- Resolution: Fixed master: 2160c3294ef87143ab9a4e8138cb618651499792 > supports SELECT statement in Tab

[jira] [Updated] (FLINK-16225) Metaspace Out Of Memory should be handled as Fatal Error in TaskManager

2020-05-11 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16225?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-16225: Fix Version/s: (was: 1.10.1) 1.10.2 > Metaspace Out Of Memory should be handled as

[jira] [Commented] (FLINK-17600) Blink Planner fails to generate RowtimeAttribute based on TableSource's DefinedRowtimeAttributes implementation

2020-05-11 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17600?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17104996#comment-17104996 ] Leonard Xu commented on FLINK-17600: This should not be related to  [https://github.

[jira] [Updated] (FLINK-17623) Elasticsearch sink should support user resource cleanup

2020-05-11 Thread Yun Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17623?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Wang updated FLINK-17623: - Description: There should be a way for an [ElasticsearchSinkFunction|[https://github.com/apache/flink/b

[jira] [Comment Edited] (FLINK-7267) Add support for lists of hosts to connect

2020-05-11 Thread Austin Cawley-Edwards (Jira)
[ https://issues.apache.org/jira/browse/FLINK-7267?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17104943#comment-17104943 ] Austin Cawley-Edwards edited comment on FLINK-7267 at 5/11/20, 11:46 PM: --

[jira] [Issue Comment Deleted] (FLINK-7267) Add support for lists of hosts to connect

2020-05-11 Thread Austin Cawley-Edwards (Jira)
[ https://issues.apache.org/jira/browse/FLINK-7267?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Austin Cawley-Edwards updated FLINK-7267: - Comment: was deleted (was: It might also be worth adding a common base class for

[jira] [Commented] (FLINK-7267) Add support for lists of hosts to connect

2020-05-11 Thread Austin Cawley-Edwards (Jira)
[ https://issues.apache.org/jira/browse/FLINK-7267?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17104972#comment-17104972 ] Austin Cawley-Edwards commented on FLINK-7267: -- It might also be worth addin

[jira] [Comment Edited] (FLINK-17529) Replace Deprecated RMQ QueueingConsumer

2020-05-11 Thread Austin Cawley-Edwards (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17529?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17104955#comment-17104955 ] Austin Cawley-Edwards edited comment on FLINK-17529 at 5/11/20, 11:01 PM:

[jira] [Commented] (FLINK-17529) Replace Deprecated RMQ QueueingConsumer

2020-05-11 Thread Austin Cawley-Edwards (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17529?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17104955#comment-17104955 ] Austin Cawley-Edwards commented on FLINK-17529: --- After more investigation,

[jira] [Comment Edited] (FLINK-7267) Add support for lists of hosts to connect

2020-05-11 Thread Austin Cawley-Edwards (Jira)
[ https://issues.apache.org/jira/browse/FLINK-7267?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17104943#comment-17104943 ] Austin Cawley-Edwards edited comment on FLINK-7267 at 5/11/20, 10:33 PM: --

[jira] [Commented] (FLINK-7267) Add support for lists of hosts to connect

2020-05-11 Thread Austin Cawley-Edwards (Jira)
[ https://issues.apache.org/jira/browse/FLINK-7267?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17104943#comment-17104943 ] Austin Cawley-Edwards commented on FLINK-7267: -- This seems like a reasonable

[jira] [Updated] (FLINK-17623) Elasticsearch sink should support user resource cleanup

2020-05-11 Thread Yun Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17623?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Wang updated FLINK-17623: - Description: There should be a way for an [[ElasticsearchSinkFunction||#L61] [https://github.com/apache

[jira] [Updated] (FLINK-17623) Elasticsearch sink should support user resource cleanup

2020-05-11 Thread Yun Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17623?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Wang updated FLINK-17623: - Description: There should be a way for an [[ElasticsearchSinkFunction|[https://github.com/apache/flink/

[jira] [Updated] (FLINK-17623) Elasticsearch sink should support user resource cleanup

2020-05-11 Thread Yun Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17623?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Wang updated FLINK-17623: - Description: There should be a way for an [ElasticsearchSinkFunction|[https://github.com/apache/flink/b

[jira] [Updated] (FLINK-17623) Elasticsearch sink should support user resource cleanup

2020-05-11 Thread Yun Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17623?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Wang updated FLINK-17623: - Description: There should be a way for an [ElasticsearchSinkFunction|#L61]] implementation to use resou

[jira] [Updated] (FLINK-17623) Elasticsearch sink should support user resource cleanup

2020-05-11 Thread Yun Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17623?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Wang updated FLINK-17623: - Description: There should be a way for an [ElasticsearchSinkFunction|#L61]] implementation to use resou

[jira] [Updated] (FLINK-17623) Elasticsearch sink should support user resource cleanup

2020-05-11 Thread Yun Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17623?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Wang updated FLINK-17623: - Description: There should be a way for an [ElasticsearchSinkFunction|#L61]] implementation to use resou

[jira] [Updated] (FLINK-17623) Elasticsearch sink should support user resource cleanup

2020-05-11 Thread Yun Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17623?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Wang updated FLINK-17623: - Description: There should be a way for an [ElasticsearchSinkFunction|#L61]] implementation to use resou

[jira] [Updated] (FLINK-17623) Elasticsearch sink should support user resource cleanup

2020-05-11 Thread Yun Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17623?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Wang updated FLINK-17623: - Description: There should be a way for an [ElasticsearchSinkFunction|#L61]] implementation to use resou

[jira] [Updated] (FLINK-17623) Elasticsearch sink should support user resource cleanup

2020-05-11 Thread Yun Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17623?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Wang updated FLINK-17623: - Description: There should be a way for an [ElasticsearchSinkFunction|#L61]] implementation to use resou

[jira] [Created] (FLINK-17623) Elasticsearch sink should support user resource cleanup

2020-05-11 Thread Yun Wang (Jira)
Yun Wang created FLINK-17623: Summary: Elasticsearch sink should support user resource cleanup Key: FLINK-17623 URL: https://issues.apache.org/jira/browse/FLINK-17623 Project: Flink Issue Type: I

[jira] [Closed] (FLINK-17608) Add TM log and stdout page back

2020-05-11 Thread Gary Yao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17608?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao closed FLINK-17608. Resolution: Fixed master: 7cfcd33e983c6e07eedf8c0d5514450a565710ff > Add TM log and stdout page back > --

[jira] [Commented] (FLINK-17575) KafkaException: Received exception when fetching the next record from XXX-14. If needed, please seek past the record to continue consumption.

2020-05-11 Thread Maxim Malykhin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17575?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17104896#comment-17104896 ] Maxim Malykhin commented on FLINK-17575: I apologize for my English and for the

[jira] [Created] (FLINK-17622) Remove useless switch for decimal in PostresCatalog

2020-05-11 Thread Flavio Pompermaier (Jira)
Flavio Pompermaier created FLINK-17622: -- Summary: Remove useless switch for decimal in PostresCatalog Key: FLINK-17622 URL: https://issues.apache.org/jira/browse/FLINK-17622 Project: Flink

[jira] [Updated] (FLINK-17608) Add TM log and stdout page back

2020-05-11 Thread Gary Yao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17608?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-17608: - Description: According to the discussion in [https://github.com/apache/flink/pull/11731#issuecomment-62

[jira] [Commented] (FLINK-17575) KafkaException: Received exception when fetching the next record from XXX-14. If needed, please seek past the record to continue consumption.

2020-05-11 Thread Maxim Malykhin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17575?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17104874#comment-17104874 ] Maxim Malykhin commented on FLINK-17575: kafka-streams has DeserializationExcept

[jira] [Commented] (FLINK-17575) KafkaException: Received exception when fetching the next record from XXX-14. If needed, please seek past the record to continue consumption.

2020-05-11 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17575?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17104866#comment-17104866 ] Robert Metzger commented on FLINK-17575: In your case, it seems that offset "224

[jira] [Resolved] (FLINK-16921) "kubernetes session test" is unstable

2020-05-11 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16921?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan resolved FLINK-16921. --- Resolution: Fixed Thanks for the clarification [~fly_in_gis] > "kubernetes session

[jira] [Commented] (FLINK-15347) ZooKeeperDefaultDispatcherRunnerTest.testResourceCleanupUnderLeadershipChange failed on Travis

2020-05-11 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15347?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17104769#comment-17104769 ] Robert Metzger commented on FLINK-15347: https://dev.azure.com/rmetzger/Flink/_b

[jira] [Commented] (FLINK-9043) Introduce a friendly way to resume the job from externalized checkpoints automatically

2020-05-11 Thread Teng Fei Liao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-9043?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17104750#comment-17104750 ] Teng Fei Liao commented on FLINK-9043: -- Hey, any more thoughts here? Another case th

[jira] [Commented] (FLINK-17469) Support override of DEFAULT_JOB_NAME with system property for StreamExecutionEnvironment

2020-05-11 Thread Roey Shem Tov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17104727#comment-17104727 ] Roey Shem Tov commented on FLINK-17469: --- Adding to this conversation, i am agree w

[jira] [Commented] (FLINK-17575) KafkaException: Received exception when fetching the next record from XXX-14. If needed, please seek past the record to continue consumption.

2020-05-11 Thread Maxim Malykhin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17575?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17104722#comment-17104722 ] Maxim Malykhin commented on FLINK-17575: I didn't find a way to tell the kafka c

[jira] [Commented] (FLINK-17575) KafkaException: Received exception when fetching the next record from XXX-14. If needed, please seek past the record to continue consumption.

2020-05-11 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17575?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17104715#comment-17104715 ] Robert Metzger commented on FLINK-17575: I don't think Flink can do much. Kafka

[jira] [Commented] (FLINK-17575) KafkaException: Received exception when fetching the next record from XXX-14. If needed, please seek past the record to continue consumption.

2020-05-11 Thread Maxim Malykhin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17575?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17104709#comment-17104709 ] Maxim Malykhin commented on FLINK-17575: Yes, the task was faulty and restored f

[jira] [Commented] (FLINK-17575) KafkaException: Received exception when fetching the next record from XXX-14. If needed, please seek past the record to continue consumption.

2020-05-11 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17575?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17104702#comment-17104702 ] Robert Metzger commented on FLINK-17575: Okay, then the exception is known to Fl

[jira] [Comment Edited] (FLINK-17575) KafkaException: Received exception when fetching the next record from XXX-14. If needed, please seek past the record to continue consumption.

2020-05-11 Thread Maxim Malykhin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17575?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17104690#comment-17104690 ] Maxim Malykhin edited comment on FLINK-17575 at 5/11/20, 5:17 PM:

[jira] [Commented] (FLINK-17575) KafkaException: Received exception when fetching the next record from XXX-14. If needed, please seek past the record to continue consumption.

2020-05-11 Thread Maxim Malykhin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17575?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17104690#comment-17104690 ] Maxim Malykhin commented on FLINK-17575: this a "root execption" copied from fli

[jira] [Commented] (FLINK-17336) MVN exited with EXIT CODE: 143. in "libraries" test job

2020-05-11 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17336?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17104678#comment-17104678 ] Robert Metzger commented on FLINK-17336: I opened a PR: https://github.com/apach

[jira] [Closed] (FLINK-17580) NPE in unaligned checkpoint for EndOfPartition events

2020-05-11 Thread Arvid Heise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17580?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise closed FLINK-17580. --- Resolution: Fixed > NPE in unaligned checkpoint for EndOfPartition events >

[jira] [Closed] (FLINK-17523) Add call expression with a class of UDF

2020-05-11 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17523?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-17523. Resolution: Implemented > Add call expression with a class of UDF > -

[jira] [Reopened] (FLINK-17523) Add call expression with a class of UDF

2020-05-11 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17523?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz reopened FLINK-17523: -- > Add call expression with a class of UDF > > >

[jira] [Closed] (FLINK-17523) Add call expression with a class of UDF

2020-05-11 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17523?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-17523. Resolution: Fixed Implemented in 3561adf03deb88bff540773b5a2037c8576c09f8 > Add call expr

[jira] [Commented] (FLINK-10443) Flink Yarn CLI hanging after unsuccessful deployment

2020-05-11 Thread Theo Diefenthal (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10443?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17104557#comment-17104557 ] Theo Diefenthal commented on FLINK-10443: - At least, in Flink 1.9.1 it's still a

[jira] [Commented] (FLINK-17487) Do not delete old checkpoints when stop the job.

2020-05-11 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17104553#comment-17104553 ] Robert Metzger commented on FLINK-17487: Are retained checkpoints what you are l

[jira] [Commented] (FLINK-17606) Introduce DataGen connector in table

2020-05-11 Thread Konstantin Knauf (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17606?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17104549#comment-17104549 ] Konstantin Knauf commented on FLINK-17606: -- [~jark] I think, it is good additio

[jira] [Commented] (FLINK-17591) TableEnvironmentITCase.testExecuteSqlAndToDataStream failed

2020-05-11 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17591?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17104547#comment-17104547 ] Robert Metzger commented on FLINK-17591: Also on my personal azure account: htt

[jira] [Updated] (FLINK-17550) set a retract switch

2020-05-11 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17550?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-17550: --- Component/s: Table SQL / API > set a retract switch > > >

[jira] [Updated] (FLINK-17562) Monitoring REST API page has duplicate items

2020-05-11 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17562?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-17562: --- Component/s: Runtime / Web Frontend > Monitoring REST API page has duplicate items > ---

[jira] [Commented] (FLINK-17563) YARN Setup page has a broken link

2020-05-11 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17563?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17104535#comment-17104535 ] Robert Metzger commented on FLINK-17563: You are right, this link is broken. It

[jira] [Updated] (FLINK-17563) YARN Setup page has a broken link

2020-05-11 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17563?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-17563: --- Component/s: Project Website > YARN Setup page has a broken link > -

[jira] [Commented] (FLINK-17573) There is duplicate source data in ProcessWindowFunction

2020-05-11 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17573?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17104532#comment-17104532 ] Robert Metzger commented on FLINK-17573: Thank you for opening a ticket. Can yo

[jira] [Updated] (FLINK-17573) There is duplicate source data in ProcessWindowFunction

2020-05-11 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17573?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-17573: --- Priority: Major (was: Blocker) > There is duplicate source data in ProcessWindowFunction >

[jira] [Updated] (FLINK-17573) There is duplicate source data in ProcessWindowFunction

2020-05-11 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17573?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-17573: --- Component/s: API / DataStream > There is duplicate source data in ProcessWindowFunction > --

[jira] [Commented] (FLINK-17575) KafkaException: Received exception when fetching the next record from XXX-14. If needed, please seek past the record to continue consumption.

2020-05-11 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17575?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17104531#comment-17104531 ] Robert Metzger commented on FLINK-17575: Thank you for this bug report. Is this

[jira] [Commented] (FLINK-17529) Replace Deprecated RMQ QueueingConsumer

2020-05-11 Thread Austin Cawley-Edwards (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17529?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17104529#comment-17104529 ] Austin Cawley-Edwards commented on FLINK-17529: --- That would be great, than

[jira] [Assigned] (FLINK-17602) Documentation for broadcast state correction

2020-05-11 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17602?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-17602: -- Assignee: Mans Singh > Documentation for broadcast state correction > ---

[jira] [Updated] (FLINK-17602) Documentation for broadcast state correction

2020-05-11 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17602?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-17602: --- Component/s: API / DataStream > Documentation for broadcast state correction > -

[jira] [Commented] (FLINK-17274) Maven: Premature end of Content-Length delimited message body

2020-05-11 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17104519#comment-17104519 ] Robert Metzger commented on FLINK-17274: https://dev.azure.com/apache-flink/apac

[jira] [Commented] (FLINK-17606) Introduce DataGen connector in table

2020-05-11 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17606?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17104520#comment-17104520 ] Jark Wu commented on FLINK-17606: - Thanks for the updating. Hi [~knaufk], what do you t

[jira] [Created] (FLINK-17621) Use default akka.ask.timeout in TPC-DS e2e test

2020-05-11 Thread Gary Yao (Jira)
Gary Yao created FLINK-17621: Summary: Use default akka.ask.timeout in TPC-DS e2e test Key: FLINK-17621 URL: https://issues.apache.org/jira/browse/FLINK-17621 Project: Flink Issue Type: Task

[jira] [Updated] (FLINK-17610) Align the behavior of result of internal map state to return empty iterator

2020-05-11 Thread Yu Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17610?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Li updated FLINK-17610: -- Fix Version/s: 1.11.0 > Align the behavior of result of internal map state to return empty iterator >

[jira] [Assigned] (FLINK-17610) Align the behavior of result of internal map state to return empty iterator

2020-05-11 Thread Yu Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17610?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Li reassigned FLINK-17610: - Assignee: Nicholas Jiang > Align the behavior of result of internal map state to return empty iterator

[jira] [Created] (FLINK-17620) Rename StandaloneJobClusterEntryPoint to StandaloneApplicationClusterEntryPoint

2020-05-11 Thread Kostas Kloudas (Jira)
Kostas Kloudas created FLINK-17620: -- Summary: Rename StandaloneJobClusterEntryPoint to StandaloneApplicationClusterEntryPoint Key: FLINK-17620 URL: https://issues.apache.org/jira/browse/FLINK-17620 P

[jira] [Commented] (FLINK-17336) MVN exited with EXIT CODE: 143. in "libraries" test job

2020-05-11 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17336?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17104453#comment-17104453 ] Robert Metzger commented on FLINK-17336: I think I understood of build #965 (the

[jira] [Comment Edited] (FLINK-17336) MVN exited with EXIT CODE: 143. in "libraries" test job

2020-05-11 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17336?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17104453#comment-17104453 ] Robert Metzger edited comment on FLINK-17336 at 5/11/20, 1:28 PM:

[jira] [Assigned] (FLINK-17336) MVN exited with EXIT CODE: 143. in "libraries" test job

2020-05-11 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17336?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-17336: -- Assignee: Robert Metzger > MVN exited with EXIT CODE: 143. in "libraries" test job >

[jira] [Commented] (FLINK-17336) MVN exited with EXIT CODE: 143. in "libraries" test job

2020-05-11 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17336?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17104429#comment-17104429 ] Robert Metzger commented on FLINK-17336: https://dev.azure.com/apache-flink/apac

[jira] [Commented] (FLINK-16572) CheckPubSubEmulatorTest is flaky on Azure

2020-05-11 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16572?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17104428#comment-17104428 ] Robert Metzger commented on FLINK-16572: https://dev.azure.com/apache-flink/apac

  1   2   3   4   5   >