[GitHub] [flink] flinkbot commented on pull request #18469: [FLINK-25485][connector/jdbc] Append default JDBC URL option of batch writing in MySQL.

2022-01-24 Thread GitBox
flinkbot commented on pull request #18469: URL: https://github.com/apache/flink/pull/18469#issuecomment-1020006554 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

[GitHub] [flink] flinkbot edited a comment on pull request #18412: [FLINK-25696][datastream] Introduce MetadataPublisher interface to SinkWriter

2022-01-24 Thread GitBox
flinkbot edited a comment on pull request #18412: URL: https://github.com/apache/flink/pull/18412#issuecomment-1017147201 ## CI report: * b42032867fb8a31ac9dd068ec1ae0f35f477952c Azure:

[jira] [Updated] (FLINK-25485) JDBC connector implicitly append url options when use mysql

2022-01-24 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25485?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-25485: --- Labels: pull-request-available (was: ) > JDBC connector implicitly append url options when

[GitHub] [flink] deadwind4 opened a new pull request #18469: [FLINK-25485][connector/jdbc] Append default JDBC URL option of batch writing in MySQL.

2022-01-24 Thread GitBox
deadwind4 opened a new pull request #18469: URL: https://github.com/apache/flink/pull/18469 ## What is the purpose of the change When we directly use buffer-flush options of the mysql sink (sink.buffer-flush.max-rows and sink.buffer-flush.interval) can not increase throughput.

[GitHub] [flink] flinkbot edited a comment on pull request #18465: [FLINK-24978][build] Upgrade ASM to 9.2

2022-01-24 Thread GitBox
flinkbot edited a comment on pull request #18465: URL: https://github.com/apache/flink/pull/18465#issuecomment-1019940899 ## CI report: * 266cba85df1039bc02981c3eea798612fd3cc489 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18466: [FLINK-25016][build] Upgrade to Netty 4.1.70

2022-01-24 Thread GitBox
flinkbot edited a comment on pull request #18466: URL: https://github.com/apache/flink/pull/18466#issuecomment-1019948477 ## CI report: * ebdb481af2a582c4095ee7214a2292e56248be80 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18397: [FLINK-25702][Kafka] Use the configure feature provided by the kafka Serializer/Deserializer.

2022-01-24 Thread GitBox
flinkbot edited a comment on pull request #18397: URL: https://github.com/apache/flink/pull/18397#issuecomment-1015848205 ## CI report: * 5b2d44dfea90aa64e7f9c2e65307604abb5ad556 Azure:

[jira] [Created] (FLINK-25780) Reduce the maximum number of data output buffers for sort-shuffle

2022-01-24 Thread Yingjie Cao (Jira)
Yingjie Cao created FLINK-25780: --- Summary: Reduce the maximum number of data output buffers for sort-shuffle Key: FLINK-25780 URL: https://issues.apache.org/jira/browse/FLINK-25780 Project: Flink

[GitHub] [flink] flinkbot edited a comment on pull request #18466: [FLINK-25016][build] Upgrade to Netty 4.1.70

2022-01-24 Thread GitBox
flinkbot edited a comment on pull request #18466: URL: https://github.com/apache/flink/pull/18466#issuecomment-1019948477 ## CI report: * ebdb481af2a582c4095ee7214a2292e56248be80 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18465: [FLINK-24978][build] Upgrade ASM to 9.2

2022-01-24 Thread GitBox
flinkbot edited a comment on pull request #18465: URL: https://github.com/apache/flink/pull/18465#issuecomment-1019940899 ## CI report: * 266cba85df1039bc02981c3eea798612fd3cc489 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18463: [FLINK-25773][build] Upgrade to flink-shaded 15.0

2022-01-24 Thread GitBox
flinkbot edited a comment on pull request #18463: URL: https://github.com/apache/flink/pull/18463#issuecomment-1019934385 ## CI report: * 9c73c9fb637ca689bf942810929f6d0661fbd5b9 Azure:

[jira] [Commented] (FLINK-25444) ClosureCleaner rejects ExecutionConfig as not be Serializable due to TextElement

2022-01-24 Thread Wen Zhou (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25444?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17481014#comment-17481014 ] Wen Zhou commented on FLINK-25444: -- If we intend to embed another engine like siddhi in flink and there

[GitHub] [flink] flinkbot edited a comment on pull request #18397: [FLINK-25702][Kafka] Use the configure feature provided by the kafka Serializer/Deserializer.

2022-01-24 Thread GitBox
flinkbot edited a comment on pull request #18397: URL: https://github.com/apache/flink/pull/18397#issuecomment-1015848205 ## CI report: * 5b2d44dfea90aa64e7f9c2e65307604abb5ad556 Azure:

[jira] [Commented] (FLINK-13550) Support for CPU FlameGraphs in web UI

2022-01-24 Thread Alexander Fedulov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13550?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17481013#comment-17481013 ] Alexander Fedulov commented on FLINK-13550: --- Hi [~jackylau], what kind of script is it? In

[jira] [Commented] (FLINK-25444) ClosureCleaner rejects ExecutionConfig as not be Serializable due to TextElement

2022-01-24 Thread Wen Zhou (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25444?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17481012#comment-17481012 ] Wen Zhou commented on FLINK-25444: -- In brief, flink-siddhi need to serialize flink data format to

[GitHub] [flink] flinkbot edited a comment on pull request #18466: [FLINK-25016][build] Upgrade to Netty 4.1.70

2022-01-24 Thread GitBox
flinkbot edited a comment on pull request #18466: URL: https://github.com/apache/flink/pull/18466#issuecomment-1019948477 ## CI report: * ebdb481af2a582c4095ee7214a2292e56248be80 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18465: [FLINK-24978][build] Upgrade ASM to 9.2

2022-01-24 Thread GitBox
flinkbot edited a comment on pull request #18465: URL: https://github.com/apache/flink/pull/18465#issuecomment-1019940899 ## CI report: * 266cba85df1039bc02981c3eea798612fd3cc489 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18463: [FLINK-25773][build] Upgrade to flink-shaded 15.0

2022-01-24 Thread GitBox
flinkbot edited a comment on pull request #18463: URL: https://github.com/apache/flink/pull/18463#issuecomment-1019934385 ## CI report: * 9c73c9fb637ca689bf942810929f6d0661fbd5b9 Azure:

[GitHub] [flink] matriv commented on a change in pull request #18464: [FLINK-25769][table] Add internal functions and basic function versioning

2022-01-24 Thread GitBox
matriv commented on a change in pull request #18464: URL: https://github.com/apache/flink/pull/18464#discussion_r790643329 ## File path: flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/BuiltInFunctionDefinition.java ## @@ -90,6 +110,18 @@ public

[GitHub] [flink] zentol commented on a change in pull request #18432: [FLINK-25739][dist] Include Changelog to flink-dist jar

2022-01-24 Thread GitBox
zentol commented on a change in pull request #18432: URL: https://github.com/apache/flink/pull/18432#discussion_r790640217 ## File path: flink-dist/pom.xml ## @@ -108,6 +108,18 @@ under the License. ${project.version} + +

[GitHub] [flink] flinkbot edited a comment on pull request #18466: [FLINK-25016][build] Upgrade to Netty 4.1.70

2022-01-24 Thread GitBox
flinkbot edited a comment on pull request #18466: URL: https://github.com/apache/flink/pull/18466#issuecomment-1019948477 ## CI report: * ebdb481af2a582c4095ee7214a2292e56248be80 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18465: [FLINK-24978][build] Upgrade ASM to 9.2

2022-01-24 Thread GitBox
flinkbot edited a comment on pull request #18465: URL: https://github.com/apache/flink/pull/18465#issuecomment-1019940899 ## CI report: * 266cba85df1039bc02981c3eea798612fd3cc489 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18463: [FLINK-25773][build] Upgrade to flink-shaded 15.0

2022-01-24 Thread GitBox
flinkbot edited a comment on pull request #18463: URL: https://github.com/apache/flink/pull/18463#issuecomment-1019934385 ## CI report: * 9c73c9fb637ca689bf942810929f6d0661fbd5b9 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18394: [FLINK-25520][Table SQL/API] Implement "ALTER TABLE ... COMPACT" SQL

2022-01-24 Thread GitBox
flinkbot edited a comment on pull request #18394: URL: https://github.com/apache/flink/pull/18394#issuecomment-1015323011 ## CI report: * 154b36442660ab9898943a3c3d34a2591023f312 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18376: [FLINK-25668][runtime] Support calcuate network memory for dynamic graph

2022-01-24 Thread GitBox
flinkbot edited a comment on pull request #18376: URL: https://github.com/apache/flink/pull/18376#issuecomment-1014266348 ## CI report: * 369e3ea1432e9b033e5660642ab0f86b03ab4d79 Azure:

[jira] [Comment Edited] (FLINK-25728) Protential memory leaks in StreamMultipleInputProcessor

2022-01-24 Thread pc wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17481008#comment-17481008 ] pc wang edited comment on FLINK-25728 at 1/24/22, 11:08 AM: Hi

[GitHub] [flink] matriv commented on a change in pull request #18464: [FLINK-25769][table] Add internal functions and basic function versioning

2022-01-24 Thread GitBox
matriv commented on a change in pull request #18464: URL: https://github.com/apache/flink/pull/18464#discussion_r790638239 ## File path: flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/BuiltInFunctionDefinition.java ## @@ -90,6 +110,18 @@ public

[GitHub] [flink] KarmaGYZ commented on a change in pull request #18360: [FLINK-25329][runtime] Support memory execution graph store in session cluster

2022-01-24 Thread GitBox
KarmaGYZ commented on a change in pull request #18360: URL: https://github.com/apache/flink/pull/18360#discussion_r790500376 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/FileExecutionGraphInfoStore.java ## @@ -242,23 +249,41 @@ public void

[jira] [Comment Edited] (FLINK-25444) ClosureCleaner rejects ExecutionConfig as not be Serializable due to TextElement

2022-01-24 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25444?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17481010#comment-17481010 ] Chesnay Schepler edited comment on FLINK-25444 at 1/24/22, 11:07 AM: -

[jira] [Commented] (FLINK-25444) ClosureCleaner rejects ExecutionConfig as not be Serializable due to TextElement

2022-01-24 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25444?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17481010#comment-17481010 ] Chesnay Schepler commented on FLINK-25444: -- ??ClosureCleanerLevel.RECURSIVE which would cause

[jira] [Comment Edited] (FLINK-25728) Protential memory leaks in StreamMultipleInputProcessor

2022-01-24 Thread pc wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17481008#comment-17481008 ] pc wang edited comment on FLINK-25728 at 1/24/22, 11:06 AM: I'm working on a

[jira] [Commented] (FLINK-25728) Protential memory leaks in StreamMultipleInputProcessor

2022-01-24 Thread pc wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17481008#comment-17481008 ] pc wang commented on FLINK-25728: - By the way, I'm working on a fix for the issue. Currently, it's

[GitHub] [flink] flinkbot edited a comment on pull request #18468: [FLINK-24905][connector/kinesis]Adding Kinesis data streams sql uber-jar and end to end test.

2022-01-24 Thread GitBox
flinkbot edited a comment on pull request #18468: URL: https://github.com/apache/flink/pull/18468#issuecomment-1019969068 ## CI report: * 4c5b4e65b42382c17bd98884f18e441e5a881e83 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18466: [FLINK-25016][build] Upgrade to Netty 4.1.70

2022-01-24 Thread GitBox
flinkbot edited a comment on pull request #18466: URL: https://github.com/apache/flink/pull/18466#issuecomment-1019948477 ## CI report: * ebdb481af2a582c4095ee7214a2292e56248be80 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18465: [FLINK-24978][build] Upgrade ASM to 9.2

2022-01-24 Thread GitBox
flinkbot edited a comment on pull request #18465: URL: https://github.com/apache/flink/pull/18465#issuecomment-1019940899 ## CI report: * 266cba85df1039bc02981c3eea798612fd3cc489 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18463: [FLINK-25773][build] Upgrade to flink-shaded 15.0

2022-01-24 Thread GitBox
flinkbot edited a comment on pull request #18463: URL: https://github.com/apache/flink/pull/18463#issuecomment-1019934385 ## CI report: * 9c73c9fb637ca689bf942810929f6d0661fbd5b9 Azure:

[jira] [Comment Edited] (FLINK-24038) DispatcherResourceManagerComponent fails to deregister application if no leading ResourceManager

2022-01-24 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24038?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17481006#comment-17481006 ] Matthias Pohl edited comment on FLINK-24038 at 1/24/22, 11:00 AM: -- I

[jira] [Comment Edited] (FLINK-24038) DispatcherResourceManagerComponent fails to deregister application if no leading ResourceManager

2022-01-24 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24038?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17481006#comment-17481006 ] Matthias Pohl edited comment on FLINK-24038 at 1/24/22, 11:00 AM: -- I

[jira] [Commented] (FLINK-24038) DispatcherResourceManagerComponent fails to deregister application if no leading ResourceManager

2022-01-24 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24038?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17481006#comment-17481006 ] Matthias Pohl commented on FLINK-24038: --- I changed the FLINK-25432 link from "blocks" to "relates

[GitHub] [flink] JingGe commented on a change in pull request #18397: [FLINK-25702][Kafka] Use the configure feature provided by the kafka Serializer/Deserializer.

2022-01-24 Thread GitBox
JingGe commented on a change in pull request #18397: URL: https://github.com/apache/flink/pull/18397#discussion_r790614226 ## File path:

[GitHub] [flink] flinkbot commented on pull request #18468: [FLINK-24905][connector/kinesis]Adding Kinesis data streams sql uber-jar and end to end test.

2022-01-24 Thread GitBox
flinkbot commented on pull request #18468: URL: https://github.com/apache/flink/pull/18468#issuecomment-1019969068 ## CI report: * 4c5b4e65b42382c17bd98884f18e441e5a881e83 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #18465: [FLINK-24978][build] Upgrade ASM to 9.2

2022-01-24 Thread GitBox
flinkbot edited a comment on pull request #18465: URL: https://github.com/apache/flink/pull/18465#issuecomment-1019940899 ## CI report: * 266cba85df1039bc02981c3eea798612fd3cc489 Azure:

[GitHub] [flink] flinkbot commented on pull request #18468: [FLINK-24905][connector/kinesis]Adding Kinesis data streams sql uber-jar and end to end test.

2022-01-24 Thread GitBox
flinkbot commented on pull request #18468: URL: https://github.com/apache/flink/pull/18468#issuecomment-1019968379 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

[GitHub] [flink] slinkydeveloper commented on pull request #18290: [FLINK-25391][connectors][formats] Update existing table factories/format factories for catalog table options forwarding

2022-01-24 Thread GitBox
slinkydeveloper commented on pull request #18290: URL: https://github.com/apache/flink/pull/18290#issuecomment-1019968434 Opened these 3 issues: * https://issues.apache.org/jira/browse/FLINK-25777 * https://issues.apache.org/jira/browse/FLINK-25778 *

[jira] [Comment Edited] (FLINK-25728) Protential memory leaks in StreamMultipleInputProcessor

2022-01-24 Thread pc wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17481002#comment-17481002 ] pc wang edited comment on FLINK-25728 at 1/24/22, 10:54 AM: Thanks. You can

[jira] [Commented] (FLINK-25728) Protential memory leaks in StreamMultipleInputProcessor

2022-01-24 Thread pc wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17481002#comment-17481002 ] pc wang commented on FLINK-25728: - Thanks. You could reproduce this issue using this [Test

[jira] [Updated] (FLINK-25779) Define ConfigOption for aws, scan and sink map in Kinesis

2022-01-24 Thread Francesco Guardiani (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25779?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Francesco Guardiani updated FLINK-25779: Summary: Define ConfigOption for aws, scan and sink map in Kinesis (was: Define

[jira] [Updated] (FLINK-25779) Define ConfigOption for aws map in Kinesis

2022-01-24 Thread Francesco Guardiani (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25779?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Francesco Guardiani updated FLINK-25779: Description: Now there is no {{ConfigOption}} definition of {{aws.*}}, {{scan.*}}

[GitHub] [flink] flinkbot edited a comment on pull request #18382: [FLINK-25524] Fix ChangelogStateBackend.notifyCheckpointComplete

2022-01-24 Thread GitBox
flinkbot edited a comment on pull request #18382: URL: https://github.com/apache/flink/pull/18382#issuecomment-1014709963 ## CI report: * ef6989575ebe74f5cba3cd5f6c363f465eaba709 Azure:

[jira] [Updated] (FLINK-25779) Define ConfigOption for properties map in Kinesis

2022-01-24 Thread Francesco Guardiani (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25779?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Francesco Guardiani updated FLINK-25779: Description: Now there is no {{ConfigOption}} definition of {{aws.*}} in Kinesis

[jira] [Updated] (FLINK-25779) Define ConfigOption for aws map in Kinesis

2022-01-24 Thread Francesco Guardiani (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25779?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Francesco Guardiani updated FLINK-25779: Summary: Define ConfigOption for aws map in Kinesis (was: Define ConfigOption

[jira] [Created] (FLINK-25779) Define ConfigOption for properties map in Kinesis

2022-01-24 Thread Francesco Guardiani (Jira)
Francesco Guardiani created FLINK-25779: --- Summary: Define ConfigOption for properties map in Kinesis Key: FLINK-25779 URL: https://issues.apache.org/jira/browse/FLINK-25779 Project: Flink

[jira] [Updated] (FLINK-25779) Define ConfigOption for aws map in Kinesis

2022-01-24 Thread Francesco Guardiani (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25779?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Francesco Guardiani updated FLINK-25779: Component/s: Connectors / Kinesis (was: Connectors / Kafka)

[jira] [Created] (FLINK-25778) Define ConfigOption for properties map in Kafka

2022-01-24 Thread Francesco Guardiani (Jira)
Francesco Guardiani created FLINK-25778: --- Summary: Define ConfigOption for properties map in Kafka Key: FLINK-25778 URL: https://issues.apache.org/jira/browse/FLINK-25778 Project: Flink

[GitHub] [flink] vahmed-hamdy opened a new pull request #18468: [FLINK-24905][connector/kinesis]Adding Kinesis data streams sql uber-jar and end to end test.

2022-01-24 Thread GitBox
vahmed-hamdy opened a new pull request #18468: URL: https://github.com/apache/flink/pull/18468 ## What is the purpose of the change This pull request adds SQL uber-jar for `KinesisStreams` table api and a respective end to end test to test it. ## Brief

[GitHub] [flink] flinkbot edited a comment on pull request #18467: [FLINK-25776][build] Sync netty versions

2022-01-24 Thread GitBox
flinkbot edited a comment on pull request #18467: URL: https://github.com/apache/flink/pull/18467#issuecomment-1019955976 ## CI report: * 84723426f04af40985a9fbc3a5e2b94704039e53 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18465: [FLINK-24978][build] Upgrade ASM to 9.2

2022-01-24 Thread GitBox
flinkbot edited a comment on pull request #18465: URL: https://github.com/apache/flink/pull/18465#issuecomment-1019940899 ## CI report: * 266cba85df1039bc02981c3eea798612fd3cc489 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18409: [hotfix][dist] Fix that flink-gs-fs-hadoop not included in flink-dist

2022-01-24 Thread GitBox
flinkbot edited a comment on pull request #18409: URL: https://github.com/apache/flink/pull/18409#issuecomment-1017132626 ## CI report: * 74c02f4b21ad4488b0466a748114e26f15495c4e Azure:

[GitHub] [flink] syhily commented on pull request #17235: [FLINK-24246][connector/pulsar] Bump pulsar client to latest 2.8.1 release

2022-01-24 Thread GitBox
syhily commented on pull request #17235: URL: https://github.com/apache/flink/pull/17235#issuecomment-1019962161 This feature has been moved to https://github.com/apache/flink/pull/17452. I plan to close this PR. -- This is an automated message from the Apache Git Service. To respond to

[GitHub] [flink] syhily closed pull request #17235: [FLINK-24246][connector/pulsar] Bump pulsar client to latest 2.8.1 release

2022-01-24 Thread GitBox
syhily closed pull request #17235: URL: https://github.com/apache/flink/pull/17235 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

[jira] [Commented] (FLINK-25444) ClosureCleaner rejects ExecutionConfig as not be Serializable due to TextElement

2022-01-24 Thread Wen Zhou (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25444?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17480993#comment-17480993 ] Wen Zhou commented on FLINK-25444: -- [~chesnay]   ClosureCleanerLevel.RECURSIVE  which would cause

[GitHub] [flink] flinkbot edited a comment on pull request #18388: [FLINK-25530][python][connector/pulsar] Support Pulsar source connector in Python DataStream API.

2022-01-24 Thread GitBox
flinkbot edited a comment on pull request #18388: URL: https://github.com/apache/flink/pull/18388#issuecomment-1015205179 ## CI report: * 11799600e83d55b8150cdb93ad90d1a55fd2651f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18382: [FLINK-25524] Fix ChangelogStateBackend.notifyCheckpointComplete

2022-01-24 Thread GitBox
flinkbot edited a comment on pull request #18382: URL: https://github.com/apache/flink/pull/18382#issuecomment-1014709963 ## CI report: * ef6989575ebe74f5cba3cd5f6c363f465eaba709 Azure:

[jira] [Created] (FLINK-25777) Generate documentation for Table factories (formats and connectors)

2022-01-24 Thread Francesco Guardiani (Jira)
Francesco Guardiani created FLINK-25777: --- Summary: Generate documentation for Table factories (formats and connectors) Key: FLINK-25777 URL: https://issues.apache.org/jira/browse/FLINK-25777

[GitHub] [flink] rkhachatryan commented on a change in pull request #18324: [FLINK-25557][checkpoint] Introduce incremental/full checkpoint size stats

2022-01-24 Thread GitBox
rkhachatryan commented on a change in pull request #18324: URL: https://github.com/apache/flink/pull/18324#discussion_r790617559 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/state/changelog/ChangelogStateBackendHandle.java ## @@ -113,6 +124,19 @@ public

[GitHub] [flink] twalthr commented on a change in pull request #18439: [hotfix][table-planner][test] Self union watermark propagation

2022-01-24 Thread GitBox
twalthr commented on a change in pull request #18439: URL: https://github.com/apache/flink/pull/18439#discussion_r790615977 ## File path: flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/common/CommonExecSinkITCase.java ## @@ -426,6

[GitHub] [flink] rkhachatryan commented on a change in pull request #18382: [FLINK-25524] Fix ChangelogStateBackend.notifyCheckpointComplete

2022-01-24 Thread GitBox
rkhachatryan commented on a change in pull request #18382: URL: https://github.com/apache/flink/pull/18382#discussion_r790615543 ## File path: flink-state-backends/flink-statebackend-changelog/src/main/java/org/apache/flink/state/changelog/ChangelogKeyedStateBackend.java ##

[GitHub] [flink] JingGe commented on a change in pull request #18397: [FLINK-25702][Kafka] Use the configure feature provided by the kafka Serializer/Deserializer.

2022-01-24 Thread GitBox
JingGe commented on a change in pull request #18397: URL: https://github.com/apache/flink/pull/18397#discussion_r790614226 ## File path:

[GitHub] [flink] rkhachatryan commented on a change in pull request #18382: [FLINK-25524] Fix ChangelogStateBackend.notifyCheckpointComplete

2022-01-24 Thread GitBox
rkhachatryan commented on a change in pull request #18382: URL: https://github.com/apache/flink/pull/18382#discussion_r790613550 ## File path: flink-state-backends/flink-statebackend-changelog/src/main/java/org/apache/flink/state/changelog/ChangelogKeyedStateBackend.java ##

[GitHub] [flink] flinkbot commented on pull request #18467: [FLINK-25776][build] Sync netty versions

2022-01-24 Thread GitBox
flinkbot commented on pull request #18467: URL: https://github.com/apache/flink/pull/18467#issuecomment-1019955976 ## CI report: * 84723426f04af40985a9fbc3a5e2b94704039e53 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] rkhachatryan commented on a change in pull request #18324: [FLINK-25557][checkpoint] Introduce incremental/full checkpoint size stats

2022-01-24 Thread GitBox
rkhachatryan commented on a change in pull request #18324: URL: https://github.com/apache/flink/pull/18324#discussion_r790604449 ## File path: flink-dstl/flink-dstl-dfs/src/main/java/org/apache/flink/changelog/fs/FsStateChangelogWriter.java ## @@ -302,14 +302,16 @@ public

[GitHub] [flink] flinkbot edited a comment on pull request #18465: [FLINK-24978][build] Upgrade ASM to 9.2

2022-01-24 Thread GitBox
flinkbot edited a comment on pull request #18465: URL: https://github.com/apache/flink/pull/18465#issuecomment-1019940899 ## CI report: * 266cba85df1039bc02981c3eea798612fd3cc489 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18466: [FLINK-25016][build] Upgrade to Netty 4.1.70

2022-01-24 Thread GitBox
flinkbot edited a comment on pull request #18466: URL: https://github.com/apache/flink/pull/18466#issuecomment-1019948477 ## CI report: * ebdb481af2a582c4095ee7214a2292e56248be80 Azure:

[GitHub] [flink] flinkbot commented on pull request #18467: [FLINK-25776][build] Sync netty versions

2022-01-24 Thread GitBox
flinkbot commented on pull request #18467: URL: https://github.com/apache/flink/pull/18467#issuecomment-1019955495 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

[GitHub] [flink] flinkbot edited a comment on pull request #18458: [FLINK-21789][network] Make FileChannelManagerImpl#getNextPathNum select data directories fairly

2022-01-24 Thread GitBox
flinkbot edited a comment on pull request #18458: URL: https://github.com/apache/flink/pull/18458#issuecomment-1019767867 ## CI report: * 572d143d54fb5f9c87c5e251e3c2e1816a0249ed Azure:

[GitHub] [flink] slinkydeveloper commented on a change in pull request #18464: [FLINK-25769][table] Add internal functions and basic function versioning

2022-01-24 Thread GitBox
slinkydeveloper commented on a change in pull request #18464: URL: https://github.com/apache/flink/pull/18464#discussion_r790604757 ## File path: flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/functions/sql/BuiltInSqlFunction.java ## @@ -0,0

[GitHub] [flink] twalthr closed pull request #18381: [hotfix][flink-annotations] Add v1.15 as the next Flink version to master

2022-01-24 Thread GitBox
twalthr closed pull request #18381: URL: https://github.com/apache/flink/pull/18381 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

[jira] [Updated] (FLINK-25776) Sync netty bugfix version across the project

2022-01-24 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25776?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-25776: --- Labels: pull-request-available (was: ) > Sync netty bugfix version across the project >

[GitHub] [flink] maosuhan commented on pull request #14376: [FLINK-18202][PB format] New Format of protobuf

2022-01-24 Thread GitBox
maosuhan commented on pull request #14376: URL: https://github.com/apache/flink/pull/14376#issuecomment-1019952384 @zhuzhengjun01 hi, there's no way to distinguish between default and missing values in proto3 I think. At least there's no such API exposed in protobuf. And How do you

[GitHub] [flink] zentol opened a new pull request #18467: [FLINK-25776][build] Sync netty versions

2022-01-24 Thread GitBox
zentol opened a new pull request #18467: URL: https://github.com/apache/flink/pull/18467 Syncs all netty versions across the project (excluding flink-shaded-netty) to 4.1.70, in line with the planned upgrade to flink-shaded-netty (#18466). This will ease maintenance. -- This is

[jira] [Created] (FLINK-25776) Sync netty bugfix version across the project

2022-01-24 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-25776: Summary: Sync netty bugfix version across the project Key: FLINK-25776 URL: https://issues.apache.org/jira/browse/FLINK-25776 Project: Flink Issue

[GitHub] [flink] flinkbot commented on pull request #18466: [FLINK-25016][build] Upgrade to Netty 4.1.70

2022-01-24 Thread GitBox
flinkbot commented on pull request #18466: URL: https://github.com/apache/flink/pull/18466#issuecomment-1019948477 ## CI report: * ebdb481af2a582c4095ee7214a2292e56248be80 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #18465: [FLINK-24978][build] Upgrade ASM to 9.2

2022-01-24 Thread GitBox
flinkbot edited a comment on pull request #18465: URL: https://github.com/apache/flink/pull/18465#issuecomment-1019940899 ## CI report: * 266cba85df1039bc02981c3eea798612fd3cc489 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18464: [FLINK-25769][table] Add internal functions and basic function versioning

2022-01-24 Thread GitBox
flinkbot edited a comment on pull request #18464: URL: https://github.com/apache/flink/pull/18464#issuecomment-1019940732 ## CI report: * 71e985936a4ce00e72cb88180100f4479e04b435 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18457: [FLINK-14902][code] Supports jdbc async lookup join

2022-01-24 Thread GitBox
flinkbot edited a comment on pull request #18457: URL: https://github.com/apache/flink/pull/18457#issuecomment-1019749225 ## CI report: * 1ff6b7fdc37a68de37d05a96a922ae4fb56055b0 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18456: [FLINK-21790][network] Shuffle data directories to make directory selection of different TaskManagers fairer

2022-01-24 Thread GitBox
flinkbot edited a comment on pull request #18456: URL: https://github.com/apache/flink/pull/18456#issuecomment-1019691654 ## CI report: * cd74a88227edf6a00098a9d651634e009ac3fe9f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18290: [FLINK-25391][connectors][formats] Update existing table factories/format factories for catalog table options forwarding

2022-01-24 Thread GitBox
flinkbot edited a comment on pull request #18290: URL: https://github.com/apache/flink/pull/18290#issuecomment-1006716199 ## CI report: * 35ffc4d144540ac24d28499395079ff34d32f4eb Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18157: [FLINK-17808] Rename checkpoint meta file to "_metadata" until it has…

2022-01-24 Thread GitBox
flinkbot edited a comment on pull request #18157: URL: https://github.com/apache/flink/pull/18157#issuecomment-998436589 ## CI report: * 7dcb2f8df322c2fb454f0e8aa0ef95d7bb696120 Azure:

[jira] [Created] (FLINK-25775) Document JavaScript SDK

2022-01-24 Thread Till Rohrmann (Jira)
Till Rohrmann created FLINK-25775: - Summary: Document JavaScript SDK Key: FLINK-25775 URL: https://issues.apache.org/jira/browse/FLINK-25775 Project: Flink Issue Type: Improvement

[GitHub] [flink] JingGe commented on a change in pull request #18397: [FLINK-25702][Kafka] Use the configure feature provided by the kafka Serializer/Deserializer.

2022-01-24 Thread GitBox
JingGe commented on a change in pull request #18397: URL: https://github.com/apache/flink/pull/18397#discussion_r790600948 ## File path: flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/sink/KafkaRecordSerializationSchemaBuilderTest.java

[GitHub] [flink] flinkbot commented on pull request #18466: [FLINK-25016][build] Upgrade to Netty 4.1.70

2022-01-24 Thread GitBox
flinkbot commented on pull request #18466: URL: https://github.com/apache/flink/pull/18466#issuecomment-1019943517 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

[GitHub] [flink] CrynetLogistics commented on a change in pull request #18449: [FLINK-25661] [flink-connector-base]- fatal exception handler

2022-01-24 Thread GitBox
CrynetLogistics commented on a change in pull request #18449: URL: https://github.com/apache/flink/pull/18449#discussion_r790586157 ## File path: flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/sink/AsyncSinkBaseBuilder.java ## @@ -37,6

[GitHub] [flink] CrynetLogistics commented on a change in pull request #18449: [FLINK-25661] [flink-connector-base]- fatal exception handler

2022-01-24 Thread GitBox
CrynetLogistics commented on a change in pull request #18449: URL: https://github.com/apache/flink/pull/18449#discussion_r790586157 ## File path: flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/sink/AsyncSinkBaseBuilder.java ## @@ -37,6

[GitHub] [flink] CrynetLogistics commented on a change in pull request #18449: [FLINK-25661] [flink-connector-base]- fatal exception handler

2022-01-24 Thread GitBox
CrynetLogistics commented on a change in pull request #18449: URL: https://github.com/apache/flink/pull/18449#discussion_r790586157 ## File path: flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/sink/AsyncSinkBaseBuilder.java ## @@ -37,6

[GitHub] [flink] flinkbot commented on pull request #18465: [FLINK-15736][build] Upgrade ASM to 9.2

2022-01-24 Thread GitBox
flinkbot commented on pull request #18465: URL: https://github.com/apache/flink/pull/18465#issuecomment-1019940899 ## CI report: * 266cba85df1039bc02981c3eea798612fd3cc489 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot commented on pull request #18464: [FLINK-25769][table] Add internal functions and basic function versioning

2022-01-24 Thread GitBox
flinkbot commented on pull request #18464: URL: https://github.com/apache/flink/pull/18464#issuecomment-1019940732 ## CI report: * 71e985936a4ce00e72cb88180100f4479e04b435 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #18463: [FLINK-25773][build] Upgrade to flink-shaded 15.0

2022-01-24 Thread GitBox
flinkbot edited a comment on pull request #18463: URL: https://github.com/apache/flink/pull/18463#issuecomment-1019934385 ## CI report: * 9c73c9fb637ca689bf942810929f6d0661fbd5b9 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18456: [FLINK-21790][network] Shuffle data directories to make directory selection of different TaskManagers fairer

2022-01-24 Thread GitBox
flinkbot edited a comment on pull request #18456: URL: https://github.com/apache/flink/pull/18456#issuecomment-1019691654 ## CI report: * cd74a88227edf6a00098a9d651634e009ac3fe9f Azure:

[jira] [Created] (FLINK-25774) Restrict the maximum number of buffers can be used per result partition for blocking shuffle

2022-01-24 Thread Yingjie Cao (Jira)
Yingjie Cao created FLINK-25774: --- Summary: Restrict the maximum number of buffers can be used per result partition for blocking shuffle Key: FLINK-25774 URL: https://issues.apache.org/jira/browse/FLINK-25774

[GitHub] [flink] flinkbot edited a comment on pull request #18290: [FLINK-25391][connectors][formats] Update existing table factories/format factories for catalog table options forwarding

2022-01-24 Thread GitBox
flinkbot edited a comment on pull request #18290: URL: https://github.com/apache/flink/pull/18290#issuecomment-1006716199 ## CI report: * 35ffc4d144540ac24d28499395079ff34d32f4eb Azure:

<    3   4   5   6   7   8   9   10   >