[jira] [Commented] (FLINK-24568) Configuration equals method does not properly check equality

2021-10-15 Thread viczkdong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24568?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17429510#comment-17429510 ] viczkdong commented on FLINK-24568: --- Can i fixed it?? Replied Message Jessie Anderson

[jira] [Commented] (FLINK-24538) ZooKeeperLeaderElectionTest.testLeaderShouldBeCorrectedWhenOverwritten fails with NPE

2021-10-15 Thread xmarker (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17429363#comment-17429363 ] xmarker commented on FLINK-24538: - I have push some code( [https://github.com/apache/flink/pull/17502] )

[jira] [Comment Edited] (FLINK-24538) ZooKeeperLeaderElectionTest.testLeaderShouldBeCorrectedWhenOverwritten fails with NPE

2021-10-15 Thread xmarker (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17429345#comment-17429345 ] xmarker edited comment on FLINK-24538 at 10/15/21, 3:57 PM: I investigate

[jira] [Created] (FLINK-24568) Configuration equals method does not properly check equality

2021-10-15 Thread Jessie Anderson (Jira)
Jessie Anderson created FLINK-24568: --- Summary: Configuration equals method does not properly check equality Key: FLINK-24568 URL: https://issues.apache.org/jira/browse/FLINK-24568 Project: Flink

[jira] [Commented] (FLINK-24538) ZooKeeperLeaderElectionTest.testLeaderShouldBeCorrectedWhenOverwritten fails with NPE

2021-10-15 Thread xmarker (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17429345#comment-17429345 ] xmarker commented on FLINK-24538: - I investigate the issue related code and i think the issue may be

[jira] [Commented] (FLINK-9465) Specify a separate savepoint timeout option via CLI

2021-10-15 Thread Feifan Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-9465?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17429326#comment-17429326 ] Feifan Wang commented on FLINK-9465: I still work on this [~flink-jira-bot]. > Specify a separate

[jira] [Commented] (FLINK-24459) Performance improvement of file sink on Nexmark

2021-10-15 Thread Arvid Heise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24459?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17429260#comment-17429260 ] Arvid Heise commented on FLINK-24459: - [~ykt836] shouldn't we also have backports for the change? >

[jira] [Commented] (FLINK-24480) EqualiserCodeGeneratorTest fails on azure

2021-10-15 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-24480?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17429259#comment-17429259 ] Ingo Bürk commented on FLINK-24480: --- I've opened a PR that works around this by reducing the number of

[jira] [Comment Edited] (FLINK-22315) Support ADD column/constraint/watermark for ALTER TABLE statement

2021-10-15 Thread Yuepeng Pan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17429247#comment-17429247 ] Yuepeng Pan edited comment on FLINK-22315 at 10/15/21, 12:27 PM: - 'alter

[jira] [Commented] (FLINK-24567) Support create tables using CatalogView defination

2021-10-15 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-24567?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17429257#comment-17429257 ] Ingo Bürk commented on FLINK-24567: --- I don't understand what this is supposed to mean / how it should

[jira] [Comment Edited] (FLINK-24544) Failure when using Kafka connector in Table API with Avro and Confluent schema registry

2021-10-15 Thread Peter Schrott (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17429243#comment-17429243 ] Peter Schrott edited comment on FLINK-24544 at 10/15/21, 12:04 PM: --- I

[jira] [Commented] (FLINK-22315) Support ADD column/constraint/watermark for ALTER TABLE statement

2021-10-15 Thread Yuepeng Pan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17429247#comment-17429247 ] Yuepeng Pan commented on FLINK-22315: - 'alter table add constraint' syntax is availiable

[jira] [Commented] (FLINK-24493) Introduce DemultiplexingSink to Support Dynamic Sink Routing

2021-10-15 Thread Arvid Heise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17429245#comment-17429245 ] Arvid Heise commented on FLINK-24493: - Hi Rion, unfortunately documentation is still lacking. Have

[jira] [Commented] (FLINK-24544) Failure when using Kafka connector in Table API with Avro and Confluent schema registry

2021-10-15 Thread Peter Schrott (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17429243#comment-17429243 ] Peter Schrott commented on FLINK-24544: --- I was wondering about the message of the exception: 

[jira] [Updated] (FLINK-24567) Support create tables using CatalogView defination

2021-10-15 Thread Xianxun Ye (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24567?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xianxun Ye updated FLINK-24567: --- Description: Now when we run this sql will throw a ValidationException {code:java} sql("create view

[jira] [Created] (FLINK-24567) Support create tables using CatalogView defination

2021-10-15 Thread Xianxun Ye (Jira)
Xianxun Ye created FLINK-24567: -- Summary: Support create tables using CatalogView defination Key: FLINK-24567 URL: https://issues.apache.org/jira/browse/FLINK-24567 Project: Flink Issue Type:

[jira] [Commented] (FLINK-24554) Support metadata columns for format-json

2021-10-15 Thread WangMinChao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24554?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17429228#comment-17429228 ] WangMinChao commented on FLINK-24554: -  I think FLINK-24547  is what I want, thanks for

[jira] [Comment Edited] (FLINK-10230) Support 'SHOW CREATE VIEW' syntax to print the query of a view

2021-10-15 Thread Yuepeng Pan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10230?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17425935#comment-17425935 ] Yuepeng Pan edited comment on FLINK-10230 at 10/15/21, 10:24 AM: - Could

[jira] [Commented] (FLINK-24535) Update with the latest AWS Glue Schema Registry version

2021-10-15 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24535?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17429220#comment-17429220 ] Danny Cranmer commented on FLINK-24535: --- [~linyu] thanks for the contribution. I will take a look

[jira] [Assigned] (FLINK-24535) Update with the latest AWS Glue Schema Registry version

2021-10-15 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24535?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer reassigned FLINK-24535: - Assignee: Linyu Yao > Update with the latest AWS Glue Schema Registry version >

[jira] [Assigned] (FLINK-22315) Support ADD column/constraint/watermark for ALTER TABLE statement

2021-10-15 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-22315: --- Assignee: Yuepeng Pan > Support ADD column/constraint/watermark for ALTER TABLE statement >

[jira] [Updated] (FLINK-24563) Comparing timstamp_ltz with random string throws NullPointerException

2021-10-15 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24563?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng updated FLINK-24563: Description: Add the following test case to

[jira] [Updated] (FLINK-24563) Comparing timstamp_ltz with random string throws NullPointerException

2021-10-15 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24563?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng updated FLINK-24563: Summary: Comparing timstamp_ltz with random string throws NullPointerException (was: Comparing

[jira] [Commented] (FLINK-22315) Support ADD column/constraint/watermark for ALTER TABLE statement

2021-10-15 Thread Yuepeng Pan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17429218#comment-17429218 ] Yuepeng Pan commented on FLINK-22315: - Hi, [~jark], I'm interested in this pr. Could you assign

[jira] [Commented] (FLINK-24348) KafkaTableITCase fail with "ContainerLaunch Container startup failed"

2021-10-15 Thread Matthias (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24348?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17429217#comment-17429217 ] Matthias commented on FLINK-24348: -- Same issue was observed on VVP's Flink 1.14 fork:

[jira] [Commented] (FLINK-24351) translate "JSON Function" pages into Chinese

2021-10-15 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24351?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17429216#comment-17429216 ] Jark Wu commented on FLINK-24351: - [~monster#12] where is the pull request? Please use add the JIRA ID

[jira] [Comment Edited] (FLINK-24536) flink sql where condition is not supported != writing

2021-10-15 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24536?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17429211#comment-17429211 ] Jark Wu edited comment on FLINK-24536 at 10/15/21, 9:38 AM: I'm fine with

[jira] [Comment Edited] (FLINK-24554) Support metadata columns for format-json

2021-10-15 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24554?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17429208#comment-17429208 ] Jark Wu edited comment on FLINK-24554 at 10/15/21, 9:30 AM: >From my

[jira] [Commented] (FLINK-24536) flink sql where condition is not supported != writing

2021-10-15 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24536?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17429211#comment-17429211 ] Jark Wu commented on FLINK-24536: - I'm fine with this feature. Calcite already supports this syntax

[jira] [Commented] (FLINK-24554) Support metadata columns for format-json

2021-10-15 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24554?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17429208#comment-17429208 ] Jark Wu commented on FLINK-24554: - >From my knowledge, there is no metadata information for JSON data,

[jira] [Closed] (FLINK-24554) Support metadata columns for format-json

2021-10-15 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24554?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-24554. --- Resolution: Won't Fix > Support metadata columns for format-json >

[jira] [Updated] (FLINK-24566) Remove CsvFileSystemFormatFactory

2021-10-15 Thread Francesco Guardiani (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24566?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Francesco Guardiani updated FLINK-24566: Component/s: Table SQL / Ecosystem Formats (JSON, Avro, Parquet,

[jira] [Updated] (FLINK-24565) Port Avro FileSystemFormatFactory to StreamFormat

2021-10-15 Thread Francesco Guardiani (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24565?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Francesco Guardiani updated FLINK-24565: Component/s: Formats (JSON, Avro, Parquet, ORC, SequenceFile) > Port Avro

[jira] [Updated] (FLINK-24565) Port Avro FileSystemFormatFactory to StreamFormat

2021-10-15 Thread Francesco Guardiani (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24565?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Francesco Guardiani updated FLINK-24565: Component/s: Table SQL / Ecosystem > Port Avro FileSystemFormatFactory to

[jira] [Commented] (FLINK-24562) YarnResourceManagerDriverTest should not use ContainerStatusPBImpl.newInstance

2021-10-15 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24562?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17429202#comment-17429202 ] Yangze Guo commented on FLINK-24562: [~trohrmann] Would you like to assign this ticket to Feifan? >

[jira] [Commented] (FLINK-24547) A function named row_kind() can get row_kind

2021-10-15 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24547?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17429200#comment-17429200 ] Jark Wu commented on FLINK-24547: - Actually, I have some concerns about this feature, because users may

[jira] [Commented] (FLINK-24562) YarnResourceManagerDriverTest should not use ContainerStatusPBImpl.newInstance

2021-10-15 Thread Feifan Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24562?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17429191#comment-17429191 ] Feifan Wang commented on FLINK-24562: - Hi [~karmagyz], I open a

[jira] [Closed] (FLINK-23704) FLIP-27 sources are not generating LatencyMarkers

2021-10-15 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23704?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-23704. -- Fix Version/s: 1.14.1 1.15.0 1.13.3

[jira] [Created] (FLINK-24566) Remove CsvFileSystemFormatFactory

2021-10-15 Thread Francesco Guardiani (Jira)
Francesco Guardiani created FLINK-24566: --- Summary: Remove CsvFileSystemFormatFactory Key: FLINK-24566 URL: https://issues.apache.org/jira/browse/FLINK-24566 Project: Flink Issue Type:

[jira] [Created] (FLINK-24565) Port Avro FileSystemFormatFactory to StreamFormat

2021-10-15 Thread Francesco Guardiani (Jira)
Francesco Guardiani created FLINK-24565: --- Summary: Port Avro FileSystemFormatFactory to StreamFormat Key: FLINK-24565 URL: https://issues.apache.org/jira/browse/FLINK-24565 Project: Flink

[jira] [Commented] (FLINK-24562) YarnResourceManagerDriverTest should not use ContainerStatusPBImpl.newInstance

2021-10-15 Thread Feifan Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24562?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17429171#comment-17429171 ] Feifan Wang commented on FLINK-24562: - Thanks for reply [~karmagyz], I'm glad to open a PR for it.

[jira] [Created] (FLINK-24564) Change the default compression to snappy for parquet, orc, avro in table

2021-10-15 Thread Jingsong Lee (Jira)
Jingsong Lee created FLINK-24564: Summary: Change the default compression to snappy for parquet, orc, avro in table Key: FLINK-24564 URL: https://issues.apache.org/jira/browse/FLINK-24564 Project:

[jira] [Commented] (FLINK-19845) Migrate all FileSystemFormatFactory implementations

2021-10-15 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19845?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17429163#comment-17429163 ] Caizhi Weng commented on FLINK-19845: - Hi [~slinkydeveloper]! I’m also working on that format these

[jira] [Commented] (FLINK-24562) YarnResourceManagerDriverTest should not use ContainerStatusPBImpl.newInstance

2021-10-15 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24562?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17429156#comment-17429156 ] Yangze Guo commented on FLINK-24562: I think it is a valid issue. Would you like to prepare a PR for

[jira] [Commented] (FLINK-24480) EqualiserCodeGeneratorTest fails on azure

2021-10-15 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-24480?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17429152#comment-17429152 ] Ingo Bürk commented on FLINK-24480: --- OK, so we seem to be running into an issue with Janino. Spark had

[jira] [Commented] (FLINK-24536) flink sql where condition is not supported != writing

2021-10-15 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24536?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17429151#comment-17429151 ] Martijn Visser commented on FLINK-24536: I can understand that this would be a nice to have

[jira] [Commented] (FLINK-24536) flink sql where condition is not supported != writing

2021-10-15 Thread simenliuxing (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24536?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17429150#comment-17429150 ] simenliuxing commented on FLINK-24536: -- [~matriv] Okay, I see Because of the influence of

[jira] [Commented] (FLINK-24480) EqualiserCodeGeneratorTest fails on azure

2021-10-15 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24480?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17429148#comment-17429148 ] Dawid Wysakowicz commented on FLINK-24480: --

[jira] [Commented] (FLINK-23493) python tests hang on Azure

2021-10-15 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17429146#comment-17429146 ] Dawid Wysakowicz commented on FLINK-23493: --

[jira] [Updated] (FLINK-24484) Support manual cleanup of async operation results

2021-10-15 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24484?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-24484: - Description: The REST API state for asynchronous operations results is currently kept

[jira] [Commented] (FLINK-24216) org.apache.flink.test.scheduling.AdaptiveSchedulerITCase#testStopWithSavepointFailOnFirstSavepointSucceedOnSecond blocked on azure

2021-10-15 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24216?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17429144#comment-17429144 ] Dawid Wysakowicz commented on FLINK-24216: --

[jira] [Commented] (FLINK-19845) Migrate all FileSystemFormatFactory implementations

2021-10-15 Thread Francesco Guardiani (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19845?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17429145#comment-17429145 ] Francesco Guardiani commented on FLINK-19845: - I'm working on the avro porting > Migrate

[jira] [Updated] (FLINK-19142) Local recovery can be broken if slot hijacking happened during a full restart

2021-10-15 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-19142: Summary: Local recovery can be broken if slot hijacking happened during a full restart (was: Local

[jira] [Updated] (FLINK-19142) Local recovery can be broken if slot hijacking happened during restarting

2021-10-15 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-19142: Issue Type: Bug (was: Improvement) > Local recovery can be broken if slot hijacking happened during

[jira] [Updated] (FLINK-19142) Local recovery can be broken if slot hijacking happened during restarting

2021-10-15 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-19142: Description: The ticket originates from [this PR

[jira] [Updated] (FLINK-19142) Local recovery can be broken if slot hijacking happened during restarting

2021-10-15 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-19142: Summary: Local recovery can be broken if slot hijacking happened during restarting (was: Investigate

[jira] [Commented] (FLINK-24554) Support metadata columns for format-json

2021-10-15 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-24554?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17429140#comment-17429140 ] Ingo Bürk commented on FLINK-24554: --- The only one mentioned now is RowKind, and for this there is

[jira] [Commented] (FLINK-6573) Flink MongoDB Connector

2021-10-15 Thread Jiabao Sun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-6573?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17429139#comment-17429139 ] Jiabao Sun commented on FLINK-6573: --- Can I take this ticket? > Flink MongoDB Connector >

[jira] [Created] (FLINK-24563) Comparing timstamp_ltz with result of date_format with specific format throws NullPointerException

2021-10-15 Thread Caizhi Weng (Jira)
Caizhi Weng created FLINK-24563: --- Summary: Comparing timstamp_ltz with result of date_format with specific format throws NullPointerException Key: FLINK-24563 URL: https://issues.apache.org/jira/browse/FLINK-24563

[jira] [Created] (FLINK-24562) YarnResourceManagerDriverTest should not use ContainerStatusPBImpl.newInstance

2021-10-15 Thread Feifan Wang (Jira)
Feifan Wang created FLINK-24562: --- Summary: YarnResourceManagerDriverTest should not use ContainerStatusPBImpl.newInstance Key: FLINK-24562 URL: https://issues.apache.org/jira/browse/FLINK-24562

[jira] [Closed] (FLINK-24540) Fix Resource leak due to Files.list

2021-10-15 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24540?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-24540. Assignee: lujie Resolution: Fixed master: d1425bebd9ae5e326a381baf06227f42a128a47a

[jira] [Updated] (FLINK-24540) Fix Resource leak due to Files.list

2021-10-15 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24540?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-24540: - Affects Version/s: 1.13.0 > Fix Resource leak due to Files.list >

[jira] [Updated] (FLINK-24540) Fix Resource leak due to Files.list

2021-10-15 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24540?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-24540: - Fix Version/s: 1.15.0 > Fix Resource leak due to Files.list >

[jira] [Updated] (FLINK-24540) Fix Resource leak due to Files.list

2021-10-15 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24540?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-24540: - Summary: Fix Resource leak due to Files.list (was: Fix Resocue leak due to Files.list

[jira] [Updated] (FLINK-24540) Fix Resource leak due to Files.list

2021-10-15 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24540?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-24540: - Priority: Minor (was: Major) > Fix Resource leak due to Files.list >

[jira] [Updated] (FLINK-24540) Fix Resource leak due to Files.list

2021-10-15 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24540?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-24540: - Issue Type: Bug (was: Improvement) > Fix Resource leak due to Files.list >

[jira] [Commented] (FLINK-21289) Application mode ignores the pipeline.classpaths configuration

2021-10-15 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17429126#comment-17429126 ] Yang Wang commented on FLINK-21289: --- [~PChou] It is really a pity that your PR is not merged

[jira] [Updated] (FLINK-21289) Application mode ignores the pipeline.classpaths configuration

2021-10-15 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21289?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang updated FLINK-21289: -- Fix Version/s: (was: 1.12.3) (was: 1.11.4) (was:

[jira] [Updated] (FLINK-21289) Application mode ignores the pipeline.classpaths configuration

2021-10-15 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21289?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang updated FLINK-21289: -- Fix Version/s: 1.15.0 > Application mode ignores the pipeline.classpaths configuration >

[jira] [Reopened] (FLINK-21289) Application mode ignores the pipeline.classpaths configuration

2021-10-15 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21289?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang reopened FLINK-21289: --- This ticket is not resolved since the PR is never reviewed and merged. > Application mode ignores the

[jira] [Updated] (FLINK-24554) Support metadata columns for format-json

2021-10-15 Thread WangMinChao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24554?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] WangMinChao updated FLINK-24554: Description: * Currently, Flink-CDC already supports reading cdc RowData metadata columns in

[jira] [Updated] (FLINK-24554) Support metadata columns for format-json

2021-10-15 Thread WangMinChao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24554?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] WangMinChao updated FLINK-24554: Description: * Currently, Flink-CDC already supports reading cdc RowData metadata columns in

[jira] [Created] (FLINK-24561) Build archetype jars in compile phase

2021-10-15 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-24561: Summary: Build archetype jars in compile phase Key: FLINK-24561 URL: https://issues.apache.org/jira/browse/FLINK-24561 Project: Flink Issue Type:

[jira] [Updated] (FLINK-24554) Support metadata columns for format-json

2021-10-15 Thread WangMinChao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24554?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] WangMinChao updated FLINK-24554: Description: * Currently, Flink-CDC already supports reading cdc RowData metadata columns in

[jira] [Updated] (FLINK-24554) Support metadata columns for format-json

2021-10-15 Thread WangMinChao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24554?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] WangMinChao updated FLINK-24554: Description: Currently, Flink-CDC already supports reading cdc data metadata columns in the PR.

[jira] [Updated] (FLINK-24554) Support metadata columns for format-json

2021-10-15 Thread WangMinChao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24554?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] WangMinChao updated FLINK-24554: Description: * Currently, Flink-CDC already supports reading cdc RowData metadata columns in

[jira] [Updated] (FLINK-24554) Support metadata columns for format-json

2021-10-15 Thread WangMinChao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24554?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] WangMinChao updated FLINK-24554: Description: Currently, Flink-CDC already supports reading metadata columns from the cdc data in

[jira] [Updated] (FLINK-24560) flink-yarn-tests should copy examples after package phase

2021-10-15 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24560?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-24560: - Issue Type: Technical Debt (was: Bug) > flink-yarn-tests should copy examples after

[jira] [Commented] (FLINK-24554) Support metadata columns for format-json

2021-10-15 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-24554?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17429121#comment-17429121 ] Ingo Bürk commented on FLINK-24554: --- [~wangminchao] Can you please extend this ticket with some