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

[ https://issues.apache.org/jira/browse/FLINK-24568?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17429531#comment-17429531 ] Zhao Yihao commented on FLINK-24568: I can fix it! haha (: > Configuration equals m

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

[ https://issues.apache.org/jira/browse/FLINK-24568?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17429536#comment-17429536 ] Yihao Zhao commented on FLINK-24568: I can fix it ! > Configuration equals method

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

[ https://issues.apache.org/jira/browse/FLINK-24568?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yihao Zhao updated FLINK-24568: --- Comment: was deleted (was: I can fix it ! ) > Configuration equals method does not properly check

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

[ https://issues.apache.org/jira/browse/FLINK-22315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17429247#comment-17429247 ] Yuepeng Pan edited comment on FLINK-22315 at 10/16/21, 9:48 AM: --

[jira] [Commented] (FLINK-24489) The size of entryCache & eventsBufferCache in the SharedBuffer should be defined with a threshold to limit the number of the elements in the cache

[ https://issues.apache.org/jira/browse/FLINK-24489?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17429565#comment-17429565 ] Yuepeng Pan commented on FLINK-24489: - Hi, [~dwysakowicz], [~airblader], [~twalthr].

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

[ https://issues.apache.org/jira/browse/FLINK-22315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17429566#comment-17429566 ] Jark Wu commented on FLINK-22315: - [~RocMarshal] yes, it should support. > Support ADD

[GitHub] [flink-ml] lindong28 commented on a change in pull request #10: [FLINK-24354][FLIP-174] Improve the WithParams interface

lindong28 commented on a change in pull request #10: URL: https://github.com/apache/flink-ml/pull/10#discussion_r730194806 ## File path: flink-ml-api/src/main/java/org/apache/flink/ml/api/core/Pipeline.java ## @@ -97,17 +100,17 @@ public PipelineModel fit(Table... inputs) {

[GitHub] [flink] SteNicholas opened a new pull request #17500: [FLINK-24564][formats] Change the default compression to snappy for parquet, orc, avro in table

SteNicholas opened a new pull request #17500: URL: https://github.com/apache/flink/pull/17500 ## What is the purpose of the change *According to the experience of other frameworks, snappy compression is recommended by default, which will reduce the file size.This does not affect rea

[GitHub] [flink] flinkbot edited a comment on pull request #17499: [FLINK-24480][table-planner] Reduce number of fields in test

flinkbot edited a comment on pull request #17499: URL: https://github.com/apache/flink/pull/17499#issuecomment-944260234 -- 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

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

[ https://issues.apache.org/jira/browse/FLINK-24564?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-24564: --- Labels: pull-request-available (was: ) > Change the default compression to snappy for parqu

[GitHub] [flink] flinkbot edited a comment on pull request #17502: [FLINK-24538][runtime][tests] Fix ZooKeeperLeaderElectionTest.testLeaderShouldBeCorrectedWhenOverwritten fails with NPE

flinkbot edited a comment on pull request #17502: URL: https://github.com/apache/flink/pull/17502#issuecomment-944431678 -- 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

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

[ https://issues.apache.org/jira/browse/FLINK-24538?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-24538: --- Labels: pull-request-available test-stability (was: test-stability) > ZooKeeperLeaderElecti

[GitHub] [flink] flinkbot edited a comment on pull request #17474: [FLINK-18312][WIP]

flinkbot edited a comment on pull request #17474: URL: https://github.com/apache/flink/pull/17474#issuecomment-943148500 -- 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

[GitHub] [flink] Airblader opened a new pull request #17499: [FLINK-24480][table-planner] Reduce number of fields in test

Airblader opened a new pull request #17499: URL: https://github.com/apache/flink/pull/17499 ## What is the purpose of the change The affected test was written due to a 64kB compilation issue. While that issue is fixed, there seems to be a limitation in Janino that can trigger a fals

[GitHub] [flink] flinkbot edited a comment on pull request #17345: [FLINK-24227][connectors] FLIP-171: Added Kinesis Data Streams Sink i…

flinkbot edited a comment on pull request #17345: URL: https://github.com/apache/flink/pull/17345#issuecomment-926109717 -- 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

[GitHub] [flink] flinkbot edited a comment on pull request #17443: [FLINK-9465][Runtime/Checkpointing] Specify a separate savepoint timeout option via CLI and REST API

flinkbot edited a comment on pull request #17443: URL: https://github.com/apache/flink/pull/17443#issuecomment-939267795 -- 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

[GitHub] [flink] flinkbot edited a comment on pull request #17482: [FLINK-24546][docs]fix miss Acknowledged description on Monitoring Ch…

flinkbot edited a comment on pull request #17482: URL: https://github.com/apache/flink/pull/17482#issuecomment-943277366 ## CI report: * 602af52c64a2dc57ff6e656253dd64b45cd53335 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] xmarker opened a new pull request #17502: [FLINK-24538][runtime][tests] Fix ZooKeeperLeaderElectionTest.testLeaderShouldBeCorrectedWhenOverwritten fails with NPE

xmarker opened a new pull request #17502: URL: https://github.com/apache/flink/pull/17502 ## What is the purpose of the change *Fix ZooKeeperLeaderElectionTest.testLeaderShouldBeCorrectedWhenOverwritten fails with NPE* ## Brief change log - *Use a loca

[jira] [Updated] (FLINK-14954) Publish OpenAPI specification of REST Monitoring API

[ https://issues.apache.org/jira/browse/FLINK-14954?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14954: --- Labels: pull-request-available (was: ) > Publish OpenAPI specification of REST Monitoring A

[GitHub] [flink] sjwiesman commented on a change in pull request #17487: [FLINK-24516][archetype] Modernize Maven Archetypes

sjwiesman commented on a change in pull request #17487: URL: https://github.com/apache/flink/pull/17487#discussion_r729896428 ## File path: flink-quickstart/flink-quickstart-java/src/main/resources/archetype-resources/src/main/java/DataStreamJob.java ## @@ -21,44 +21,45 @@ im

[GitHub] [flink] flinkbot edited a comment on pull request #17473: [FLINK-24470][runtime] EMA calculation move to BufferDebloater

flinkbot edited a comment on pull request #17473: URL: https://github.com/apache/flink/pull/17473#issuecomment-943109733 -- 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

[jira] [Updated] (FLINK-24516) Modernize Maven Archetype

[ https://issues.apache.org/jira/browse/FLINK-24516?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-24516: --- Labels: pull-request-available (was: ) > Modernize Maven Archetype > --

[GitHub] [flink] flinkbot edited a comment on pull request #17488: [FLINK-20928] Fix flaky test by retrying notifyCheckpointComplete until either commit success or timeout

flinkbot edited a comment on pull request #17488: URL: https://github.com/apache/flink/pull/17488#issuecomment-943918958 ## CI report: * 0982a65fe89288ee43368a852d8b7f3deca6a12a Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17466: [FLINK-24535] Update Glue Schema Registry with the lastest version

flinkbot edited a comment on pull request #17466: URL: https://github.com/apache/flink/pull/17466#issuecomment-942744642 ## CI report: * 5126c857d00a33ed34a3b1a8b610b89e4e9193d7 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] zoltar9264 commented on pull request #17443: [FLINK-9465][Runtime/Checkpointing] Specify a separate savepoint timeout option via CLI and REST API

zoltar9264 commented on pull request #17443: URL: https://github.com/apache/flink/pull/17443#issuecomment-944241791 -- 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 unsub

[GitHub] [flink] flinkbot edited a comment on pull request #17501: [Draft][FLINK-21406][RecordFormat] build AvroParquetRecordFormat for the new FileSource

flinkbot edited a comment on pull request #17501: URL: https://github.com/apache/flink/pull/17501#issuecomment-944297212 -- 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

[GitHub] [flink] flinkbot edited a comment on pull request #17497: [FLINK-24563][table-planner] Fix NullPointerException when comparing timestamp_ltz with random string

flinkbot edited a comment on pull request #17497: URL: https://github.com/apache/flink/pull/17497#issuecomment-944172373 ## CI report: * 3889238f09abd6c6e58c8c57ad03c8bea5ea10eb Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Updated] (FLINK-21406) Add AvroParquetFileRecordFormat

[ https://issues.apache.org/jira/browse/FLINK-21406?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-21406: --- Labels: auto-deprioritized-major pull-request-available (was: auto-deprioritized-major) >

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

[ https://issues.apache.org/jira/browse/FLINK-24563?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-24563: --- Labels: pull-request-available (was: ) > Comparing timstamp_ltz with random string throws N

[GitHub] [flink-ml] gaoyunhaii commented on a change in pull request #18: [FLINK-24279] Support withBroadcast in DataStream by caching in static variables

gaoyunhaii commented on a change in pull request #18: URL: https://github.com/apache/flink-ml/pull/18#discussion_r730201843 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/common/broadcast/BroadcastUtils.java ## @@ -0,0 +1,142 @@ +/* + * Licensed to the Apache Sof

[GitHub] [flink] CrynetLogistics commented on a change in pull request #17345: [FLINK-24227][connectors] FLIP-171: Added Kinesis Data Streams Sink i…

CrynetLogistics commented on a change in pull request #17345: URL: https://github.com/apache/flink/pull/17345#discussion_r729783117 ## File path: flink-connectors/flink-connector-aws/src/main/java/org/apache/flink/streaming/connectors/kinesis/async/KinesisDataStreamsSinkWriter.java ##

[GitHub] [flink] flinkbot edited a comment on pull request #17498: [FLINK-14954][rest] Add OpenAPI spec generator

flinkbot edited a comment on pull request #17498: URL: https://github.com/apache/flink/pull/17498#issuecomment-944209637 -- 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

[GitHub] [flink] flinkbot edited a comment on pull request #17487: [FLINK-24516][archetype] Modernize Maven Archetypes

flinkbot edited a comment on pull request #17487: URL: https://github.com/apache/flink/pull/17487#issuecomment-943762621 -- 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

[GitHub] [flink] flinkbot edited a comment on pull request #17481: [FLINK-24387][table-planner] Support JSON_STRING.

flinkbot edited a comment on pull request #17481: URL: https://github.com/apache/flink/pull/17481#issuecomment-943273916 ## CI report: * 9f452d38c5cc26fb1388e4e96ef0acc2d3e50b57 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17500: [FLINK-24564][formats] Change the default compression to snappy for parquet, orc, avro in table

flinkbot edited a comment on pull request #17500: URL: https://github.com/apache/flink/pull/17500#issuecomment-944278328 -- 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

[GitHub] [flink-statefun] sjwiesman commented on a change in pull request #276: [FLINK-24534] Use the async transport if transport is not specified.

sjwiesman commented on a change in pull request #276: URL: https://github.com/apache/flink-statefun/pull/276#discussion_r729895780 ## File path: statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/nettyclient/NettyClient.java ## @@ -94,6 +91,2

[GitHub] [flink] flinkbot commented on pull request #17500: [FLINK-24564][formats] Change the default compression to snappy for parquet, orc, avro in table

flinkbot commented on pull request #17500: URL: https://github.com/apache/flink/pull/17500#issuecomment-944278328 -- 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 unsubsc

[GitHub] [flink] JingGe opened a new pull request #17501: [Draft][FLINK-21406][RecordFormat] build AvroParquetRecordFormat for the new FileSource

JingGe opened a new pull request #17501: URL: https://github.com/apache/flink/pull/17501 ## What is the purpose of the change The goal of this PR to provide AvroParquetRecordFormat implementation to read avro GenericRecords from parquet via the new Flink FileSource. This is t

[GitHub] [flink] flinkbot commented on pull request #17498: [FLINK-14954][rest] Add OpenAPI spec generator

flinkbot commented on pull request #17498: URL: https://github.com/apache/flink/pull/17498#issuecomment-944211479 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 pro

[GitHub] [flink] flinkbot commented on pull request #17499: [FLINK-24480][table-planner] Reduce number of fields in test

flinkbot commented on pull request #17499: URL: https://github.com/apache/flink/pull/17499#issuecomment-944260008 -- 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 unsubsc

[GitHub] [flink] xhumanoid commented on pull request #16190: [FLINK-23027] Move chill dependency to flink-scala

xhumanoid commented on pull request #16190: URL: https://github.com/apache/flink/pull/16190#issuecomment-944283253 @zentol during migration java files `FlinkChillPackageRegistrar.java` and `PriorityQueueSerializer.java` was moved in incorrect `src/main/scala` folder -- This is an automat

[GitHub] [flink] flinkbot edited a comment on pull request #17496: [FLINK-24562][yarn] YarnResourceManagerDriverTest should not use ContainerStatusPBImpl.newInstance

flinkbot edited a comment on pull request #17496: URL: https://github.com/apache/flink/pull/17496#issuecomment-944116990 ## CI report: * dbf464b6017b241d4862402caba14a7681b64335 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot commented on pull request #17501: [Draft][FLINK-21406][RecordFormat] build AvroParquetRecordFormat for the new FileSource

flinkbot commented on pull request #17501: URL: https://github.com/apache/flink/pull/17501#issuecomment-944297212 -- 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 unsubsc

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

[ https://issues.apache.org/jira/browse/FLINK-24562?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-24562: --- Labels: pull-request-available (was: ) > YarnResourceManagerDriverTest should not use Conta

[GitHub] [flink] flinkbot edited a comment on pull request #17411: [FLINK-17914][hs] Keep archives if listStatus fails

flinkbot edited a comment on pull request #17411: URL: https://github.com/apache/flink/pull/17411#issuecomment-933425378 ## CI report: * 13188c09af0fd707f0c15a83819ebc899fbaeb6a Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] RocMarshal commented on pull request #17463: [Hotfix][docs-zh] Fix typo in the 'SHOW COLUMNS' section.

RocMarshal commented on pull request #17463: URL: https://github.com/apache/flink/pull/17463#issuecomment-944947844 Hi, @dianfu , here is a minor typo. Would you like to help me to check it ? Thank you very much. -- This is an automated message from the Apache Git Service. To respond to

[GitHub] [flink] flinkbot edited a comment on pull request #17465: [FLINK-24488][connectors/kafka] KafkaRecordSerializationSchemaBuilder does not forward timestamp

flinkbot edited a comment on pull request #17465: URL: https://github.com/apache/flink/pull/17465#issuecomment-942425244 ## CI report: * e501f19931561b4c685f5064857794c690ff1d28 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] sjwiesman commented on pull request #17487: [FLINK-24516][archetype] Modernize Maven Archetypes

sjwiesman commented on pull request #17487: URL: https://github.com/apache/flink/pull/17487#issuecomment-944371238 Updated with E2E fixes -- 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 spe

[GitHub] [flink] flinkbot commented on pull request #17502: [FLINK-24538][runtime][tests] Fix ZooKeeperLeaderElectionTest.testLeaderShouldBeCorrectedWhenOverwritten fails with NPE

flinkbot commented on pull request #17502: URL: https://github.com/apache/flink/pull/17502#issuecomment-944431248 -- 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 unsubsc

[GitHub] [flink-ml] zhipeng93 commented on a change in pull request #18: [FLINK-24279] Support withBroadcast in DataStream by caching in static variables

zhipeng93 commented on a change in pull request #18: URL: https://github.com/apache/flink-ml/pull/18#discussion_r730339576 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/common/broadcast/BroadcastContext.java ## @@ -0,0 +1,123 @@ +/* + * Licensed to the Apache So

[GitHub] [flink-ml] zhipeng93 commented on a change in pull request #18: [FLINK-24279] Support withBroadcast in DataStream by caching in static variables

zhipeng93 commented on a change in pull request #18: URL: https://github.com/apache/flink-ml/pull/18#discussion_r730340195 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/common/broadcast/operator/OneInputBroadcastWrapperOperator.java ## @@ -0,0 +1,170 @@ +/* + *

[GitHub] [flink-ml] zhipeng93 commented on a change in pull request #18: [FLINK-24279] Support withBroadcast in DataStream by caching in static variables

zhipeng93 commented on a change in pull request #18: URL: https://github.com/apache/flink-ml/pull/18#discussion_r730340233 ## File path: flink-ml-lib/pom.xml ## @@ -65,6 +71,44 @@ under the License. core 1.1.2 + + org.apache.flink + flink-clien

[GitHub] [flink-ml] zhipeng93 commented on a change in pull request #18: [FLINK-24279] Support withBroadcast in DataStream by caching in static variables

zhipeng93 commented on a change in pull request #18: URL: https://github.com/apache/flink-ml/pull/18#discussion_r730340268 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/common/broadcast/BroadcastUtils.java ## @@ -0,0 +1,142 @@ +/* + * Licensed to the Apache Soft

[GitHub] [flink-ml] zhipeng93 commented on a change in pull request #18: [FLINK-24279] Support withBroadcast in DataStream by caching in static variables

zhipeng93 commented on a change in pull request #18: URL: https://github.com/apache/flink-ml/pull/18#discussion_r730340287 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/common/broadcast/BroadcastUtils.java ## @@ -0,0 +1,142 @@ +/* + * Licensed to the Apache Soft

[GitHub] [flink-ml] zhipeng93 commented on a change in pull request #18: [FLINK-24279] Support withBroadcast in DataStream by caching in static variables

zhipeng93 commented on a change in pull request #18: URL: https://github.com/apache/flink-ml/pull/18#discussion_r730340357 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/common/broadcast/BroadcastUtils.java ## @@ -0,0 +1,142 @@ +/* + * Licensed to the Apache Soft