[jira] [Commented] (FLINK-19903) Allow to read metadata in filesystem connector

[ https://issues.apache.org/jira/browse/FLINK-19903?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17225210#comment-17225210 ] Ruben Laguna commented on FLINK-19903: -- I would be good to take the opportunity and

[jira] [Updated] (FLINK-19903) Allow to read metadata in filesystem connector

[ https://issues.apache.org/jira/browse/FLINK-19903?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ruben Laguna updated FLINK-19903: - Attachment: image-2020-11-03-08-53-03-714.png > Allow to read metadata in filesystem connector >

[jira] [Closed] (FLINK-19760) Make the `GlobalCommitter` a standalone interface that does not extend the `Committer`

[ https://issues.apache.org/jira/browse/FLINK-19760?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-19760. -- Fix Version/s: 1.12.0 Resolution: Implemented master: 926e1bcec38668609c5d97b1978eb0448

[jira] [Closed] (FLINK-19833) Rename Sink API Writer interface to SinkWriter

[ https://issues.apache.org/jira/browse/FLINK-19833?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-19833. -- Resolution: Implemented master: 34d0a9c84fbb43b5c2fc77c0932ba1dd1c22dbf4 > Rename Sink API Wr

[jira] [Closed] (FLINK-19841) Rename GlobalStreamingCommitterOperator to StreamingGlobalCommitterOperator

[ https://issues.apache.org/jira/browse/FLINK-19841?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-19841. -- Fix Version/s: 1.12.0 Resolution: Implemented master: d3fdc176565194f6a1b184f0c46aada01

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

[ https://issues.apache.org/jira/browse/FLINK-19940?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-19940: --- Issue Type: Improvement (was: Bug) > Task names on web UI should change when an operator ch

[jira] [Commented] (FLINK-19903) Allow to read metadata in filesystem connector

[ https://issues.apache.org/jira/browse/FLINK-19903?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17225200#comment-17225200 ] Timo Walther commented on FLINK-19903: -- Thanks for proposing this [~ecerulm]. I agr

[jira] [Assigned] (FLINK-19941) Support sink parallelism configuration to Kafka connector

[ https://issues.apache.org/jira/browse/FLINK-19941?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-19941: Assignee: CloseRiver > Support sink parallelism configuration to Kafka connector > --

[jira] [Commented] (FLINK-19941) Support sink parallelism configuration to Kafka connector

[ https://issues.apache.org/jira/browse/FLINK-19941?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17225195#comment-17225195 ] Jingsong Lee commented on FLINK-19941: -- Assigned to you [~ZhuShang] > Support sink

[jira] [Updated] (FLINK-19941) Support sink parallelism configuration to Kafka connector

[ https://issues.apache.org/jira/browse/FLINK-19941?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-19941: - Fix Version/s: 1.12.0 > Support sink parallelism configuration to Kafka connector >

[jira] [Commented] (FLINK-19941) Support sink parallelism configuration to Kafka connector

[ https://issues.apache.org/jira/browse/FLINK-19941?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17225194#comment-17225194 ] CloseRiver commented on FLINK-19941: [~lzljs3620320],I'll from kafka first.plz assig

[jira] [Commented] (FLINK-19937) Support sink parallelism option for all connectors

[ https://issues.apache.org/jira/browse/FLINK-19937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17225193#comment-17225193 ] Lsw_aka_laplace commented on FLINK-19937: - [~ZhuShang] Thanks for creating subta

[jira] [Created] (FLINK-19947) Support sink parallelism configuration to Print connector

CloseRiver created FLINK-19947: -- Summary: Support sink parallelism configuration to Print connector Key: FLINK-19947 URL: https://issues.apache.org/jira/browse/FLINK-19947 Project: Flink Issue T

[jira] [Created] (FLINK-19945) Support sink parallelism configuration to FileSystem connector

CloseRiver created FLINK-19945: -- Summary: Support sink parallelism configuration to FileSystem connector Key: FLINK-19945 URL: https://issues.apache.org/jira/browse/FLINK-19945 Project: Flink I

[jira] [Created] (FLINK-19946) Support sink parallelism configuration to Hbase connector

CloseRiver created FLINK-19946: -- Summary: Support sink parallelism configuration to Hbase connector Key: FLINK-19946 URL: https://issues.apache.org/jira/browse/FLINK-19946 Project: Flink Issue T

[jira] [Created] (FLINK-19944) Support sink parallelism configuration to Hive connector

CloseRiver created FLINK-19944: -- Summary: Support sink parallelism configuration to Hive connector Key: FLINK-19944 URL: https://issues.apache.org/jira/browse/FLINK-19944 Project: Flink Issue Ty

[jira] [Commented] (FLINK-19937) Support sink parallelism option for all connectors

[ https://issues.apache.org/jira/browse/FLINK-19937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17225192#comment-17225192 ] CloseRiver commented on FLINK-19937: Got it. > Support sink parallelism option for

[jira] [Updated] (FLINK-19441) Performance regression on 24.09.2020

[ https://issues.apache.org/jira/browse/FLINK-19441?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-19441: --- Priority: Critical (was: Blocker) > Performance regression on 24.09.2020 >

[jira] [Created] (FLINK-19943) Support sink parallelism configuration to ElasticSearch connector

CloseRiver created FLINK-19943: -- Summary: Support sink parallelism configuration to ElasticSearch connector Key: FLINK-19943 URL: https://issues.apache.org/jira/browse/FLINK-19943 Project: Flink

[jira] [Commented] (FLINK-19441) Performance regression on 24.09.2020

[ https://issues.apache.org/jira/browse/FLINK-19441?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17225191#comment-17225191 ] Robert Metzger commented on FLINK-19441: I'm downgrading the ticket. > Performa

[jira] [Commented] (FLINK-19937) Support sink parallelism option for all connectors

[ https://issues.apache.org/jira/browse/FLINK-19937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17225190#comment-17225190 ] Jingsong Lee commented on FLINK-19937: -- For Hive and Filesystem, we can set paralle

[jira] [Created] (FLINK-19942) Support sink parallelism configuration to JDBC connector

CloseRiver created FLINK-19942: -- Summary: Support sink parallelism configuration to JDBC connector Key: FLINK-19942 URL: https://issues.apache.org/jira/browse/FLINK-19942 Project: Flink Issue Ty

[jira] [Updated] (FLINK-19942) Support sink parallelism configuration to JDBC connector

[ https://issues.apache.org/jira/browse/FLINK-19942?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] CloseRiver updated FLINK-19942: --- Component/s: Connectors / JDBC > Support sink parallelism configuration to JDBC connector >

[jira] [Created] (FLINK-19941) Support sink parallelism configuration to Kafka connector

CloseRiver created FLINK-19941: -- Summary: Support sink parallelism configuration to Kafka connector Key: FLINK-19941 URL: https://issues.apache.org/jira/browse/FLINK-19941 Project: Flink Issue T

[jira] [Commented] (FLINK-19937) Support sink parallelism option for all connectors

[ https://issues.apache.org/jira/browse/FLINK-19937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17225185#comment-17225185 ] CloseRiver commented on FLINK-19937: [~lzljs3620320],i notice that Hive and FileSyst

[jira] [Commented] (FLINK-16268) Failed to run rank over window with Hive built-in functions

[ https://issues.apache.org/jira/browse/FLINK-16268?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17225180#comment-17225180 ] Jingsong Lee commented on FLINK-16268: -- release-1.11: c677334727bc388fd9fd051c7aac0

[jira] [Comment Edited] (FLINK-19937) Support sink parallelism option for all connectors

[ https://issues.apache.org/jira/browse/FLINK-19937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17225168#comment-17225168 ] CloseRiver edited comment on FLINK-19937 at 11/3/20, 7:06 AM:

[jira] [Commented] (FLINK-18938) Throw better exception message for quering sink-only connector

[ https://issues.apache.org/jira/browse/FLINK-18938?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17225177#comment-17225177 ] Fangliang Liu commented on FLINK-18938: --- [~jark], understand. Thanks for your repl

[jira] [Commented] (FLINK-19937) Support sink parallelism option for all connectors

[ https://issues.apache.org/jira/browse/FLINK-19937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17225176#comment-17225176 ] Jingsong Lee commented on FLINK-19937: -- Hi [~ZhuShang], welcome, I think we can cre

[jira] [Updated] (FLINK-19937) Support sink parallelism option for all connectors

[ https://issues.apache.org/jira/browse/FLINK-19937?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-19937: - Parent: (was: FLINK-19719) Issue Type: New Feature (was: Sub-task) > Support sink p

[jira] [Comment Edited] (FLINK-19937) Support sink parallelism option for all connectors

[ https://issues.apache.org/jira/browse/FLINK-19937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17225168#comment-17225168 ] CloseRiver edited comment on FLINK-19937 at 11/3/20, 6:58 AM:

[jira] [Commented] (FLINK-18998) No watermark is shown on Flink UI when ProcessingTime is used

[ https://issues.apache.org/jira/browse/FLINK-18998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17225174#comment-17225174 ] Rainie Li commented on FLINK-18998: --- Hi Everyone, I am interested in this task. Can a

[jira] [Commented] (FLINK-19937) Support sink parallelism option for all connectors

[ https://issues.apache.org/jira/browse/FLINK-19937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17225168#comment-17225168 ] CloseRiver commented on FLINK-19937: Hi,[~neighborhood],[~lzljs3620320] Is all the

[jira] [Commented] (FLINK-19939) Remove redundant union from multiple input node

[ https://issues.apache.org/jira/browse/FLINK-19939?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17225164#comment-17225164 ] Caizhi Weng commented on FLINK-19939: - cc [~pnowojski] [~AHeise] > Remove redundant

[jira] [Issue Comment Deleted] (FLINK-19939) Remove redundant union from multiple input node

[ https://issues.apache.org/jira/browse/FLINK-19939?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng updated FLINK-19939: Comment: was deleted (was: cc [~pnowojski] [~AHeise]) > Remove redundant union from multiple inpu

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

[ https://issues.apache.org/jira/browse/FLINK-19940?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17225165#comment-17225165 ] Caizhi Weng commented on FLINK-19940: - cc [~pnowojski] [~AHeise] > Task names on we

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

Caizhi Weng created FLINK-19940: --- Summary: Task names on web UI should change when an operator chain is chained with sources Key: FLINK-19940 URL: https://issues.apache.org/jira/browse/FLINK-19940 Proje

[jira] [Updated] (FLINK-15325) Input location preference which affects task distribution may make certain job performance worse

[ https://issues.apache.org/jira/browse/FLINK-15325?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-15325: --- Fix Version/s: 1.12.0 > Input location preference which affects task distribution may make certain

[jira] [Closed] (FLINK-19861) Improve the document of now() function

[ https://issues.apache.org/jira/browse/FLINK-19861?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-19861. --- Assignee: hailong wang Resolution: Fixed Fixed in master: 0d7d8c8b965e8d6780cff43cd2a21e093ba6c43d >

[jira] [Created] (FLINK-19939) Remove redundant union from multiple input node

Caizhi Weng created FLINK-19939: --- Summary: Remove redundant union from multiple input node Key: FLINK-19939 URL: https://issues.apache.org/jira/browse/FLINK-19939 Project: Flink Issue Type: Imp

[jira] [Updated] (FLINK-19936) Make SinkITCase stable

[ https://issues.apache.org/jira/browse/FLINK-19936?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma updated FLINK-19936: -- Description: In the streaming execution mode there are two uncertain things: # The order of receiving

[jira] [Resolved] (FLINK-19701) Unaligned Checkpoint might misuse the number of buffers to persist from the previous barrier

[ https://issues.apache.org/jira/browse/FLINK-19701?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan resolved FLINK-19701. --- Resolution: Fixed > Unaligned Checkpoint might misuse the number of buffers to persi

[jira] [Assigned] (FLINK-19701) Unaligned Checkpoint might misuse the number of buffers to persist from the previous barrier

[ https://issues.apache.org/jira/browse/FLINK-19701?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan reassigned FLINK-19701: - Assignee: (was: Roman Khachatryan) > Unaligned Checkpoint might misuse the

[jira] [Commented] (FLINK-19701) Unaligned Checkpoint might misuse the number of buffers to persist from the previous barrier

[ https://issues.apache.org/jira/browse/FLINK-19701?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17225145#comment-17225145 ] Roman Khachatryan commented on FLINK-19701: --- Hi [~gaoyunhaii], thanks for doub

[jira] [Created] (FLINK-19938) Implement shuffle data read scheduling for sort-merge blocking shuffle

Yingjie Cao created FLINK-19938: --- Summary: Implement shuffle data read scheduling for sort-merge blocking shuffle Key: FLINK-19938 URL: https://issues.apache.org/jira/browse/FLINK-19938 Project: Flink

[jira] [Updated] (FLINK-19937) Support sink parallelism option for all connectors

[ https://issues.apache.org/jira/browse/FLINK-19937?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lsw_aka_laplace updated FLINK-19937: Summary: Support sink parallelism option for all connectors (was: Support sink parallelis

[jira] [Updated] (FLINK-19937) Support sink parallelism for all connectors

[ https://issues.apache.org/jira/browse/FLINK-19937?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lsw_aka_laplace updated FLINK-19937: Description: Since https://issues.apache.org/jira/browse/FLINK-19727 has been done. SINK_

[jira] [Updated] (FLINK-19937) Support sink parallelism for all connectors

[ https://issues.apache.org/jira/browse/FLINK-19937?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lsw_aka_laplace updated FLINK-19937: Description: Since https://issues.apache.org/jira/browse/FLINK-19727 has been done. SINK_

[jira] [Updated] (FLINK-19937) Support sink parallelism for all connectors

[ https://issues.apache.org/jira/browse/FLINK-19937?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lsw_aka_laplace updated FLINK-19937: Description: Since https://issues.apache.org/jira/browse/FLINK-19727 has been done. SINK_

[jira] [Updated] (FLINK-19937) Support sink parallelism for all connectors

[ https://issues.apache.org/jira/browse/FLINK-19937?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-19937: Component/s: Table SQL / Ecosystem > Support sink parallelism for all connectors > ---

[jira] [Commented] (FLINK-18938) Throw better exception message for quering sink-only connector

[ https://issues.apache.org/jira/browse/FLINK-18938?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17225140#comment-17225140 ] Jark Wu commented on FLINK-18938: - [~liufangliang] Sure, this is already in my review li

[jira] [Updated] (FLINK-19936) Make SinkITCase stable

[ https://issues.apache.org/jira/browse/FLINK-19936?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma updated FLINK-19936: -- Description: In the streaming execution mode there are two uncertain things: # The order of receiving

[jira] [Closed] (FLINK-19294) Support key and value formats in Kafka connector

[ https://issues.apache.org/jira/browse/FLINK-19294?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-19294. --- Fix Version/s: 1.12.0 Resolution: Fixed Implemented in master (1.12.0): 59d2a2dd9c4ade641793fecc9c208

[jira] [Updated] (FLINK-19937) Support sink parallelism for all connectors

[ https://issues.apache.org/jira/browse/FLINK-19937?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lsw_aka_laplace updated FLINK-19937: Description: Since https://issues.apache.org/jira/browse/FLINK-19727 has been done. SINK_

[jira] [Updated] (FLINK-19937) Support sink parallelism for all connectors

[ https://issues.apache.org/jira/browse/FLINK-19937?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lsw_aka_laplace updated FLINK-19937: Description: Since https://issues.apache.org/jira/browse/FLINK-19727 has been done. SINK_

[jira] [Updated] (FLINK-19937) Support sink parallelism for all connectors

[ https://issues.apache.org/jira/browse/FLINK-19937?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lsw_aka_laplace updated FLINK-19937: Description: Since https://issues.apache.org/jira/browse/FLINK-19727 has been done. SINK_

[jira] [Created] (FLINK-19937) Support sink parallelism for all connectors

Lsw_aka_laplace created FLINK-19937: --- Summary: Support sink parallelism for all connectors Key: FLINK-19937 URL: https://issues.apache.org/jira/browse/FLINK-19937 Project: Flink Issue Type:

[jira] [Updated] (FLINK-19936) Make SinkITCase stable

[ https://issues.apache.org/jira/browse/FLINK-19936?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma updated FLINK-19936: -- Description: In the streaming execution mode there are two uncertain things: # The order of receiving

[jira] [Commented] (FLINK-19235) Support mixed use with built-in aggs for Python UDAF

[ https://issues.apache.org/jira/browse/FLINK-19235?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17225134#comment-17225134 ] Dian Fu commented on FLINK-19235: - Merged the follow-up PR("Adding support of more built

[jira] [Updated] (FLINK-19936) Make SinkITCase stable

[ https://issues.apache.org/jira/browse/FLINK-19936?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma updated FLINK-19936: -- Description: In the streaming execution mode there are two uncertain things: # The order of receiving

[jira] [Created] (FLINK-19936) Make SinkITCase more stable

Guowei Ma created FLINK-19936: - Summary: Make SinkITCase more stable Key: FLINK-19936 URL: https://issues.apache.org/jira/browse/FLINK-19936 Project: Flink Issue Type: Sub-task Componen

[jira] [Updated] (FLINK-19936) Make SinkITCase stable

[ https://issues.apache.org/jira/browse/FLINK-19936?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma updated FLINK-19936: -- Summary: Make SinkITCase stable (was: Make SinkITCase more stable) > Make SinkITCase stable > ---

[jira] [Assigned] (FLINK-16268) Failed to run rank over window with Hive built-in functions

[ https://issues.apache.org/jira/browse/FLINK-16268?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-16268: Assignee: Rui Li > Failed to run rank over window with Hive built-in functions >

[jira] [Commented] (FLINK-19912) Support ignoreParseErrors option for json serializationSchema

[ https://issues.apache.org/jira/browse/FLINK-19912?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17225124#comment-17225124 ] Jark Wu commented on FLINK-19912: - I think we should first investigate how other system

[jira] [Commented] (FLINK-18938) Throw better exception message for quering sink-only connector

[ https://issues.apache.org/jira/browse/FLINK-18938?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17225119#comment-17225119 ] Fangliang Liu commented on FLINK-18938: --- [~jark], this issue has been finished. pl

[jira] [Commented] (FLINK-19872) Support to parse millisecond for TIME type in CSV format

[ https://issues.apache.org/jira/browse/FLINK-19872?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17225118#comment-17225118 ] Fangliang Liu commented on FLINK-19872: --- [~jark], this issue has been finished, pl

[jira] [Commented] (FLINK-19909) Flink application in attach mode could not terminate when the only job is canceled

[ https://issues.apache.org/jira/browse/FLINK-19909?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17225108#comment-17225108 ] Xintong Song commented on FLINK-19909: -- Hi folks, thanks for reporting this issue a

[jira] [Commented] (FLINK-19910) Table API & SQL Data Types Document error

[ https://issues.apache.org/jira/browse/FLINK-19910?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17225095#comment-17225095 ] ZiHaoDeng commented on FLINK-19910: --- hi, [~rmetzger] . can you assign this issues to m

[jira] [Updated] (FLINK-19910) Table API & SQL Data Types Document error

[ https://issues.apache.org/jira/browse/FLINK-19910?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ZiHaoDeng updated FLINK-19910: -- Component/s: (was: Table SQL / API) Documentation > Table API & SQL Data Types Do

[jira] [Updated] (FLINK-19910) Table API & SQL Data Types Document error

[ https://issues.apache.org/jira/browse/FLINK-19910?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ZiHaoDeng updated FLINK-19910: -- Component/s: (was: Documentation) Table SQL / API > Table API & SQL Data Types Do

[jira] [Comment Edited] (FLINK-17295) Refactor the ExecutionAttemptID to consist of ExecutionVertexID and attemptNumber

[ https://issues.apache.org/jira/browse/FLINK-17295?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17225077#comment-17225077 ] Yangze Guo edited comment on FLINK-17295 at 11/3/20, 2:38 AM:

[jira] [Created] (FLINK-19935) OOM error occur for sql-client sumit job without JVM heap setting

harold.miao created FLINK-19935: --- Summary: OOM error occur for sql-client sumit job without JVM heap setting Key: FLINK-19935 URL: https://issues.apache.org/jira/browse/FLINK-19935 Project: Flink

[jira] [Commented] (FLINK-17295) Refactor the ExecutionAttemptID to consist of ExecutionVertexID and attemptNumber

[ https://issues.apache.org/jira/browse/FLINK-17295?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17225077#comment-17225077 ] Yangze Guo commented on FLINK-17295: Thanks for the pointer [~rmetzger]. From my per

[jira] [Closed] (FLINK-19727) Implement ParallelismProvider for sink in blink planner

[ https://issues.apache.org/jira/browse/FLINK-19727?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-19727. Resolution: Fixed master (1.12): eee0d8e99b1efd3d69b9f3877f5de51667e1cb91 > Implement Parallelism

[jira] [Closed] (FLINK-19875) Integrate file compaction to filesystem connector

[ https://issues.apache.org/jira/browse/FLINK-19875?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-19875. Resolution: Fixed master (1.12): 0c7659ed668b0b0d35b08bf01e9d6d04b8833d43 > Integrate file compac

[jira] [Updated] (FLINK-19934) [FLIP-27 source] add new API: SplitEnumeratorContext.execute(Runnable)

[ https://issues.apache.org/jira/browse/FLINK-19934?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Steven Zhen Wu updated FLINK-19934: --- Description: Here is the motivation use case. We are implementing event-time alignment acro

[jira] [Created] (FLINK-19934) [FLIP-27 source] add new API: SplitEnumeratorContext.execute(Runnable)

Steven Zhen Wu created FLINK-19934: -- Summary: [FLIP-27 source] add new API: SplitEnumeratorContext.execute(Runnable) Key: FLINK-19934 URL: https://issues.apache.org/jira/browse/FLINK-19934 Project: F

[jira] [Comment Edited] (FLINK-19340) AggregateITCase.testListAggWithDistinct failed with "expected: but was:"

[ https://issues.apache.org/jira/browse/FLINK-19340?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17225051#comment-17225051 ] Dian Fu edited comment on FLINK-19340 at 11/3/20, 1:26 AM: --- An

[jira] [Commented] (FLINK-19340) AggregateITCase.testListAggWithDistinct failed with "expected: but was:"

[ https://issues.apache.org/jira/browse/FLINK-19340?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17225051#comment-17225051 ] Dian Fu commented on FLINK-19340: - Another instance: https://dev.azure.com/apache-flink

[jira] [Commented] (FLINK-19701) Unaligned Checkpoint might misuse the number of buffers to persist from the previous barrier

[ https://issues.apache.org/jira/browse/FLINK-19701?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17225034#comment-17225034 ] Yun Gao commented on FLINK-19701: - Hi [~roman_khachatryan] very thanks investigating the

[jira] [Commented] (FLINK-19448) CoordinatedSourceITCase.testEnumeratorReaderCommunication hangs

[ https://issues.apache.org/jira/browse/FLINK-19448?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17225024#comment-17225024 ] Kezhu Wang commented on FLINK-19448: [~sewen] Seems that [68c5c2ff779d82a1ff81ffaf6

[jira] [Updated] (FLINK-19926) Wrong results for join post tumble grouping

[ https://issues.apache.org/jira/browse/FLINK-19926?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Satyam Shekhar updated FLINK-19926: --- Description: I have a table T0 with the following schema - {{root}} {{      |-- amount: BIG

[jira] [Commented] (FLINK-19701) Unaligned Checkpoint might misuse the number of buffers to persist from the previous barrier

[ https://issues.apache.org/jira/browse/FLINK-19701?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17224913#comment-17224913 ] Roman Khachatryan commented on FLINK-19701: --- I looked at the code and it seems

[jira] [Commented] (FLINK-17482) KafkaITCase.testMultipleSourcesOnePartition unstable

[ https://issues.apache.org/jira/browse/FLINK-17482?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17224899#comment-17224899 ] Robert Metzger commented on FLINK-17482: https://dev.azure.com/apache-flink/apac

[jira] [Commented] (FLINK-19805) LeaderChangeClusterComponentsTest.testReelectionOfJobMaster is instable

[ https://issues.apache.org/jira/browse/FLINK-19805?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17224891#comment-17224891 ] Robert Metzger commented on FLINK-19805: I also ran this a variant on CI that th

[jira] [Created] (FLINK-19933) Execute and collect with limit fails on bounded datastream jobs

Seth Wiesman created FLINK-19933: Summary: Execute and collect with limit fails on bounded datastream jobs Key: FLINK-19933 URL: https://issues.apache.org/jira/browse/FLINK-19933 Project: Flink

[jira] [Closed] (FLINK-19865) YARN tests failed with "java.lang.NumberFormatException: For input string: "${env:MAX_LOG_FILE_NUMBER}"

[ https://issues.apache.org/jira/browse/FLINK-19865?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger closed FLINK-19865. -- Resolution: Fixed Resolved in https://github.com/apache/flink/commit/133593a396ea5f0c27a240cf

[jira] [Commented] (FLINK-19910) Table API & SQL Data Types Document error

[ https://issues.apache.org/jira/browse/FLINK-19910?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17224761#comment-17224761 ] ZiHaoDeng commented on FLINK-19910: --- Give it to me > Table API & SQL Data Types Docum

[jira] [Reopened] (FLINK-18117) "Kerberized YARN per-job on Docker test" fails with "Could not start hadoop cluster."

[ https://issues.apache.org/jira/browse/FLINK-18117?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reopened FLINK-18117: > "Kerberized YARN per-job on Docker test" fails with "Could not start hadoop > cluster." > -

[jira] [Commented] (FLINK-18117) "Kerberized YARN per-job on Docker test" fails with "Could not start hadoop cluster."

[ https://issues.apache.org/jira/browse/FLINK-18117?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17224736#comment-17224736 ] Robert Metzger commented on FLINK-18117: Now we have a failure on master, from t

[jira] [Commented] (FLINK-19912) Support ignoreParseErrors option for json serializationSchema

[ https://issues.apache.org/jira/browse/FLINK-19912?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17224729#comment-17224729 ] hailong wang commented on FLINK-19912: -- Hi [~jark], It is not a case occurred in my

[jira] [Commented] (FLINK-15325) Input location preference which affects task distribution may make certain job performance worse

[ https://issues.apache.org/jira/browse/FLINK-15325?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17224723#comment-17224723 ] Zhu Zhu commented on FLINK-15325: - I'd like to resume this discussion because it has bee

[jira] [Reopened] (FLINK-17295) Refactor the ExecutionAttemptID to consist of ExecutionVertexID and attemptNumber

[ https://issues.apache.org/jira/browse/FLINK-17295?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reopened FLINK-17295: Assignee: (was: Yangze Guo) I opened a PR to revert this change: https://github.com/

[jira] [Closed] (FLINK-11815) Support execution with static resources (Flip-6): E.g. spreading tasks across available set of TMs

[ https://issues.apache.org/jira/browse/FLINK-11815?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias closed FLINK-11815. Resolution: Fixed I talked to [~pnowojski]. He doesn't have anything to add. I'm gonna close the issue. T

[jira] [Commented] (FLINK-19927) ExecutionStateUpdateListener is only updated when legacy scheduling is enabled

[ https://issues.apache.org/jira/browse/FLINK-19927?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17224706#comment-17224706 ] Chesnay Schepler commented on FLINK-19927: -- There should definitely be a test t

[jira] [Updated] (FLINK-19932) Add "sanity-check" integration test for BATCH execution on DataStream API

[ https://issues.apache.org/jira/browse/FLINK-19932?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-19932: - Description: We should add a sanity check to ensure that BATCH execution on the DataStre

[jira] [Updated] (FLINK-19932) Add "sanity-check" integration test for BATCH execution on DataStream API

[ https://issues.apache.org/jira/browse/FLINK-19932?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-19932: - Summary: Add "sanity-check" integration test for BATCH execution on DataStream API (was

[jira] [Updated] (FLINK-19932) Add integration test for BATCH execution on DataStream API

[ https://issues.apache.org/jira/browse/FLINK-19932?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-19932: - Description: We should add a > Add integration test for BATCH execution on DataStream A

[jira] [Commented] (FLINK-19912) Support ignoreParseErrors option for json serializationSchema

[ https://issues.apache.org/jira/browse/FLINK-19912?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17224693#comment-17224693 ] Jark Wu commented on FLINK-19912: - [~hailong wang] could you share the query which gener

[jira] [Created] (FLINK-19932) Add integration test for BATCH execution on DataStream API

Aljoscha Krettek created FLINK-19932: Summary: Add integration test for BATCH execution on DataStream API Key: FLINK-19932 URL: https://issues.apache.org/jira/browse/FLINK-19932 Project: Flink

  1   2   3   >