[GitHub] [flink] flinkbot edited a comment on pull request #16207: [FLINK-23031][table-planner-blink]Support to emit window result perio…

flinkbot edited a comment on pull request #16207: URL: https://github.com/apache/flink/pull/16207#issuecomment-864350218 ## CI report: * 41f6378376a0aecec273853b4aaeaf8d09ddeb59 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16164: [FLINK-22987][ci] Fix scala suffix check

flinkbot edited a comment on pull request #16164: URL: https://github.com/apache/flink/pull/16164#issuecomment-861345742 ## CI report: * 4c138e0498036924cada4f7cc5e9acd46d76000b Azure:

[jira] [Commented] (FLINK-22781) Incorrect result for group window aggregate when mini-batch is enabled

[ https://issues.apache.org/jira/browse/FLINK-22781?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17365845#comment-17365845 ] JING ZHANG commented on FLINK-22781: [~flink-jira-bot] I'm still working on this. [~godfreyhe] Would

[jira] [Updated] (FLINK-22715) Implement streaming window assigner tablefunction operator

[ https://issues.apache.org/jira/browse/FLINK-22715?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] JING ZHANG updated FLINK-22715: --- Labels: (was: auto-unassigned) > Implement streaming window assigner tablefunction operator >

[GitHub] [flink] flinkbot edited a comment on pull request #16207: [FLINK-23031][table-planner-blink]Support to emit window result perio…

flinkbot edited a comment on pull request #16207: URL: https://github.com/apache/flink/pull/16207#issuecomment-864350218 ## CI report: * 41f6378376a0aecec273853b4aaeaf8d09ddeb59 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16206: [FLINK-18182][kinesis] Fixing bad shading of AWS SDK config file

flinkbot edited a comment on pull request #16206: URL: https://github.com/apache/flink/pull/16206#issuecomment-864189035 ## CI report: * 773bfcf7c143eea72b1c5284d6dd3dfe19c90c85 Azure:

[jira] [Comment Edited] (FLINK-22719) WindowJoinUtil.containsWindowStartEqualityAndEndEquality should not throw exception

[ https://issues.apache.org/jira/browse/FLINK-22719?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17365839#comment-17365839 ] JING ZHANG edited comment on FLINK-22719 at 6/19/21, 4:02 AM: -- [~twalthr] 

[GitHub] [flink] flinkbot commented on pull request #16207: [FLINK-23031][table-planner-blink]Support to emit window result perio…

flinkbot commented on pull request #16207: URL: https://github.com/apache/flink/pull/16207#issuecomment-864350218 ## CI report: * 41f6378376a0aecec273853b4aaeaf8d09ddeb59 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Commented] (FLINK-23031) Support to emit window result with periodic or non_periodic

[ https://issues.apache.org/jira/browse/FLINK-23031?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17365841#comment-17365841 ] Aitozi commented on FLINK-23031: I have made a implementation , could you help take a look  [~jark] ? In

[GitHub] [flink] flinkbot commented on pull request #16207: [FLINK-23031][table-planner-blink]Support to emit window result perio…

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

[jira] [Commented] (FLINK-22719) WindowJoinUtil.containsWindowStartEqualityAndEndEquality should not throw exception

[ https://issues.apache.org/jira/browse/FLINK-22719?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17365839#comment-17365839 ] JING ZHANG commented on FLINK-22719: [~twalthr] Sorry for late response. FLINK-22719 aims to

[jira] [Updated] (FLINK-23031) Support to emit window result with periodic or non_periodic

[ https://issues.apache.org/jira/browse/FLINK-23031?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-23031: --- Labels: pull-request-available (was: ) > Support to emit window result with periodic or

[GitHub] [flink] Aitozi opened a new pull request #16207: [FLINK-23031][table-planner-blink]Support to emit window result perio…

Aitozi opened a new pull request #16207: URL: https://github.com/apache/flink/pull/16207 …dic or non_periodic ## What is the purpose of the change As describe in issue, this pr is to support sql window to late/early trigger the emit periodic or non_periodic ##

[GitHub] [flink] mayuehappy commented on pull request #16171: [FLINK-22886][State Backends] fix Thread leak in RocksDBStateUploader

mayuehappy commented on pull request #16171: URL: https://github.com/apache/flink/pull/16171#issuecomment-864336463 @rkhachatryan Thx very much for your patience, I have updated the commit, PTAL -- This is an automated message from the Apache Git Service. To respond to the message,

[jira] [Updated] (FLINK-20574) Throttle number of remote invocation requests on startup or restores with large backlogs

[ https://issues.apache.org/jira/browse/FLINK-20574?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-20574: --- Labels: auto-deprioritized-major auto-unassigned pull-request-available (was:

[jira] [Updated] (FLINK-11401) Allow compression on ParquetBulkWriter

[ https://issues.apache.org/jira/browse/FLINK-11401?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-11401: --- Labels: auto-deprioritized-major auto-unassigned pull-request-available (was:

[GitHub] [flink] mans2singh commented on pull request #16103: [hotfix][docs] Corrected timezone name and column alignment

mans2singh commented on pull request #16103: URL: https://github.com/apache/flink/pull/16103#issuecomment-864306254 Thanks @leonardBang @wuchong @tisonkun @Airblader for your time. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

[jira] [Updated] (FLINK-22342) FlinkKafkaProducerITCase fails with producer leak

[ https://issues.apache.org/jira/browse/FLINK-22342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-22342: --- Labels: auto-deprioritized-critical stale-major test-stability (was:

[jira] [Updated] (FLINK-21877) Add E2E test for upsert-kafka connector

[ https://issues.apache.org/jira/browse/FLINK-21877?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-21877: --- Labels: auto-unassigned stale-major (was: auto-unassigned) I am the [Flink Jira

[jira] [Updated] (FLINK-22631) Metrics are incorrect when task finished

[ https://issues.apache.org/jira/browse/FLINK-22631?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-22631: --- Labels: stale-major (was: ) I am the [Flink Jira

[jira] [Updated] (FLINK-22705) SQL Client end-to-end test (Old planner) Elasticsearch (v7.5.1) failed due to fail to download the tar

[ https://issues.apache.org/jira/browse/FLINK-22705?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-22705: --- Labels: stale-major test-stability (was: test-stability) I am the [Flink Jira

[jira] [Updated] (FLINK-22306) KafkaITCase.testCollectingSchema failed on AZP

[ https://issues.apache.org/jira/browse/FLINK-22306?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-22306: --- Labels: auto-deprioritized-critical stale-major test-stability (was:

[jira] [Updated] (FLINK-21559) Python DataStreamTests::test_process_function failed on AZP

[ https://issues.apache.org/jira/browse/FLINK-21559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-21559: --- Labels: auto-deprioritized-critical stale-major test-stability (was:

[jira] [Updated] (FLINK-21876) Handle it properly when the returned value of Python UDF doesn't match the defined result type

[ https://issues.apache.org/jira/browse/FLINK-21876?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-21876: --- Labels: auto-unassigned stale-major (was: auto-unassigned) I am the [Flink Jira

[jira] [Updated] (FLINK-21153) yarn-per-job deployment target ignores yarn options

[ https://issues.apache.org/jira/browse/FLINK-21153?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-21153: --- Labels: auto-unassigned stale-major usability (was: auto-unassigned usability) I am the

[jira] [Updated] (FLINK-21538) Elasticsearch6DynamicSinkITCase.testWritingDocuments fails when submitting job

[ https://issues.apache.org/jira/browse/FLINK-21538?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-21538: --- Labels: auto-unassigned stale-major test-stability (was: auto-unassigned test-stability)

[jira] [Updated] (FLINK-22443) can not be execute an extreme long sql under batch mode

[ https://issues.apache.org/jira/browse/FLINK-22443?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-22443: --- I am the [Flink Jira Bot|https://github.com/apache/flink-jira-bot/] and I help the community

[jira] [Updated] (FLINK-22311) Flink JDBC XA connector need to set maxRetries to 0 to properly working

[ https://issues.apache.org/jira/browse/FLINK-22311?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-22311: --- Labels: pull-request-available stale-major (was: pull-request-available) I am the [Flink

[jira] [Updated] (FLINK-22190) no guarantee on Flink exactly_once sink to Kafka

[ https://issues.apache.org/jira/browse/FLINK-22190?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-22190: --- Labels: stale-major (was: ) I am the [Flink Jira

[jira] [Updated] (FLINK-11286) Support to send StreamStatus.IDLE for non-source operators

[ https://issues.apache.org/jira/browse/FLINK-11286?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-11286: --- Labels: auto-deprioritized-major auto-unassigned (was: auto-unassigned stale-major)

[jira] [Updated] (FLINK-21716)  Support higher precision for Data Type TIME(p)

[ https://issues.apache.org/jira/browse/FLINK-21716?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-21716: --- Labels: auto-unassigned stale-major (was: auto-unassigned) I am the [Flink Jira

[jira] [Updated] (FLINK-22388) KafkaITCase.testMetricsAndEndOfStream times out on topic creation

[ https://issues.apache.org/jira/browse/FLINK-22388?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-22388: --- Labels: auto-deprioritized-critical stale-major test-stability (was:

[jira] [Updated] (FLINK-22004) Translate Flink Roadmap to Chinese.

[ https://issues.apache.org/jira/browse/FLINK-22004?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-22004: --- Labels: auto-unassigned pull-request-available stale-major (was: auto-unassigned

[jira] [Updated] (FLINK-22605) Python UDF should only be created once regardless of how many times it is invoked

[ https://issues.apache.org/jira/browse/FLINK-22605?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-22605: --- Labels: stale-major (was: ) I am the [Flink Jira

[jira] [Updated] (FLINK-22710) ParquetProtoStreamingFileSinkITCase.testParquetProtoWriters failed

[ https://issues.apache.org/jira/browse/FLINK-22710?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-22710: --- Labels: stale-major test-stability (was: test-stability) I am the [Flink Jira

[jira] [Updated] (FLINK-11398) Add a dedicated phase to materialize time indicators for nodes produce updates

[ https://issues.apache.org/jira/browse/FLINK-11398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-11398: --- Labels: auto-deprioritized-major auto-unassigned (was: auto-unassigned stale-major)

[jira] [Updated] (FLINK-11313) [checkpoint] Introduce LZ4 compression for keyed state in full checkpoints and savepoints

[ https://issues.apache.org/jira/browse/FLINK-11313?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-11313: --- Labels: auto-deprioritized-major auto-unassigned pull-request-available (was:

[jira] [Updated] (FLINK-11372) Incorrect delegation of compatibility checks to new snapshots in CollectionSerializerConfigSnapshot

[ https://issues.apache.org/jira/browse/FLINK-11372?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-11372: --- Labels: auto-deprioritized-major auto-unassigned pull-request-available (was:

[jira] [Updated] (FLINK-11407) Allow providing reason messages for TypeSerializerSchemaCompatibility.incompatible()

[ https://issues.apache.org/jira/browse/FLINK-11407?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-11407: --- Labels: auto-deprioritized-major auto-unassigned (was: auto-unassigned stale-major)

[jira] [Updated] (FLINK-11442) Upgrade OSS SDK Version

[ https://issues.apache.org/jira/browse/FLINK-11442?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-11442: --- Labels: auto-deprioritized-major auto-unassigned pull-request-available (was:

[jira] [Updated] (FLINK-22532) Improve the support for remote functions in the DataStream integration

[ https://issues.apache.org/jira/browse/FLINK-22532?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-22532: --- Labels: auto-deprioritized-major (was: stale-major) Priority: Minor (was: Major)

[jira] [Updated] (FLINK-11374) See more failover and can filter by time range

[ https://issues.apache.org/jira/browse/FLINK-11374?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-11374: --- Labels: auto-deprioritized-major auto-unassigned (was: auto-unassigned stale-major)

[jira] [Updated] (FLINK-22441) In Flink v1.11.3 contains netty(version:3.10.6) netty(version:4.1.60) . There are many vulnerabilities, like CVE-2021-21409 etc. please confirm these version and fix. th

[ https://issues.apache.org/jira/browse/FLINK-22441?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-22441: --- Labels: auto-deprioritized-major (was: stale-major) Priority: Minor (was: Major)

[jira] [Updated] (FLINK-12692) Support disk spilling in HeapKeyedStateBackend

[ https://issues.apache.org/jira/browse/FLINK-12692?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-12692: --- Labels: pull-request-available stale-assigned (was: pull-request-available) I am the

[jira] [Updated] (FLINK-11421) Add compilation options to allow compiling generated code with JDK compiler

[ https://issues.apache.org/jira/browse/FLINK-11421?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-11421: --- Labels: auto-deprioritized-major auto-unassigned pull-request-available (was:

[jira] [Updated] (FLINK-22868) Update training exercises for 1.13

[ https://issues.apache.org/jira/browse/FLINK-22868?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-22868: --- Labels: pull-request-available stale-assigned (was: pull-request-available) I am the

[jira] [Updated] (FLINK-22054) Using a shared watcher for ConfigMap watching

[ https://issues.apache.org/jira/browse/FLINK-22054?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-22054: --- Labels: k8s-ha pull-request-available stale-assigned (was: k8s-ha pull-request-available)

[jira] [Updated] (FLINK-22626) KafkaITCase.testTimestamps fails on Azure

[ https://issues.apache.org/jira/browse/FLINK-22626?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-22626: --- Labels: auto-deprioritized-major test-stability (was: stale-major test-stability)

[jira] [Updated] (FLINK-21788) Throw PartitionNotFoundException if the partition file has been lost for blocking shuffle

[ https://issues.apache.org/jira/browse/FLINK-21788?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-21788: --- Labels: pull-request-available stale-assigned (was: pull-request-available) I am the

[jira] [Updated] (FLINK-19380) Add support for a gRPC transport for the RequestReply protocol.

[ https://issues.apache.org/jira/browse/FLINK-19380?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-19380: --- Labels: auto-deprioritized-major (was: stale-major) Priority: Minor (was: Major)

[jira] [Updated] (FLINK-22865) Optimize state serialize/deserialize in PyFlink

[ https://issues.apache.org/jira/browse/FLINK-22865?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-22865: --- Labels: pull-request-available stale-assigned (was: pull-request-available) I am the

[jira] [Updated] (FLINK-11425) Support of “Hash Teams” in Hybrid Hash Join

[ https://issues.apache.org/jira/browse/FLINK-11425?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-11425: --- Labels: auto-deprioritized-major auto-unassigned (was: auto-unassigned stale-major)

[jira] [Updated] (FLINK-22880) Remove "blink" term in code base

[ https://issues.apache.org/jira/browse/FLINK-22880?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-22880: --- Labels: stale-assigned (was: ) I am the [Flink Jira

[GitHub] [flink] flinkbot edited a comment on pull request #16171: [FLINK-22886][State Backends] fix Thread leak in RocksDBStateUploader

flinkbot edited a comment on pull request #16171: URL: https://github.com/apache/flink/pull/16171#issuecomment-862067374 ## CI report: * 8c57a59392bf2c56235af42bb2847e2f34e7ad34 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16206: [FLINK-18182][kinesis] Fixing bad shading of AWS SDK config file

flinkbot edited a comment on pull request #16206: URL: https://github.com/apache/flink/pull/16206#issuecomment-864189035 ## CI report: * 5d6da4236b40ed2a674b94dc92bebaba68a5d0f6 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16164: [FLINK-22987][ci] Fix scala suffix check

flinkbot edited a comment on pull request #16164: URL: https://github.com/apache/flink/pull/16164#issuecomment-861345742 ## CI report: * 6384b08bbfd45acd61033c757c1fd4dc6b04530c Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16164: [FLINK-22987][ci] Fix scala suffix check

flinkbot edited a comment on pull request #16164: URL: https://github.com/apache/flink/pull/16164#issuecomment-861345742 ## CI report: * 6384b08bbfd45acd61033c757c1fd4dc6b04530c Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16206: [FLINK-18182][kinesis] Fixing bad shading of AWS SDK config file

flinkbot edited a comment on pull request #16206: URL: https://github.com/apache/flink/pull/16206#issuecomment-864189035 ## CI report: * 5d6da4236b40ed2a674b94dc92bebaba68a5d0f6 Azure:

[GitHub] [flink] zentol merged pull request #16112: [FLINK-20891][metrics][tests] Check that thread is still alive

zentol merged pull request #16112: URL: https://github.com/apache/flink/pull/16112 -- 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. For queries about this service, please

[GitHub] [flink] zentol merged pull request #16075: [FLINK-22873][config][docs] Add ToC

zentol merged pull request #16075: URL: https://github.com/apache/flink/pull/16075 -- 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. For queries about this service, please

[GitHub] [flink] flinkbot edited a comment on pull request #16153: [FLINK-22678] Configurations and user APIs for ChangelogStateBackend

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

[GitHub] [flink] flinkbot edited a comment on pull request #16205: [FLINK-18464][Runtime] fix the bug voidnamespace cast to timewindow

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

[GitHub] [flink] iemre commented on a change in pull request #16187: [FLINK-23009][kinesis] Upgrade Guava for Flink Connector Kinesis

iemre commented on a change in pull request #16187: URL: https://github.com/apache/flink/pull/16187#discussion_r654254123 ## File path: flink-connectors/flink-sql-connector-kinesis/pom.xml ## @@ -35,17 +35,6 @@ under the License. jar - - -

[GitHub] [flink] flinkbot commented on pull request #16202: [FLINK-18182][kinesis] Updating to latest AWS SDK for Kinesis connector

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

[GitHub] [flink-statefun] austince edited a comment on pull request #240: [hotfix] Correct endpoint definition in docs

austince edited a comment on pull request #240: URL: https://github.com/apache/flink-statefun/pull/240#issuecomment-864066963 @igalshilman ah no worries! just a teeny change :) Thanks for the merge! -- This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [flink] xintongsong opened a new pull request #16197: [FLINK_22662][yarn][test] Add logs for YARNHighAvailabilityITCase

xintongsong opened a new pull request #16197: URL: https://github.com/apache/flink/pull/16197 ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob server, rather than through RPC. That way we avoid re-transferring

[GitHub] [flink] rmetzger merged pull request #16180: [FLINK-22980][tests] Set parallelism on job vertex required by adapti…

rmetzger merged pull request #16180: URL: https://github.com/apache/flink/pull/16180 -- 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. For queries about this service,

[GitHub] [flink] flinkbot commented on pull request #16195: [FLINK-23009][kinesis] Upgrade Guava for Flink Connector Kinesis (1.13)

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

[GitHub] [flink] flinkbot edited a comment on pull request #16174: [FLINK-22946][runtime] Recycle floating buffer outside the lock to avoid deadlock

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

[GitHub] [flink] mayuehappy commented on a change in pull request #16171: [FLINK-22886][State Backends] fix Thread leak in RocksDBStateUploader

mayuehappy commented on a change in pull request #16171: URL: https://github.com/apache/flink/pull/16171#discussion_r654567336 ## File path:

[GitHub] [flink] rkhachatryan commented on pull request #15420: [FLINK-21356] Implement incremental checkpointing and recovery using state changelog

rkhachatryan commented on pull request #15420: URL: https://github.com/apache/flink/pull/15420#issuecomment-864015793 Thanks for the review @Zakelly and @Myasuka . I've addressed your comments and rebased the PR: (#15200 was merged, #16035 not yet; please ignore the 1st commit `Log

[GitHub] [flink] flinkbot edited a comment on pull request #16122: [FLINK-21195][Connectors/FileSystem]LimitableBulkFormat is invalid wh…

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

[GitHub] [flink] flinkbot edited a comment on pull request #15924: [FLINK-22670][FLIP-150][connector/common] Hybrid source baseline

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

[jira] [Updated] (FLINK-22980) FileExecutionGraphInfoStoreTest hangs on azure

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

[GitHub] [flink] dannycranmer opened a new pull request #16202: [FLINK-18182][kinesis] Updating to latest AWS SDK for Kinesis connector

dannycranmer opened a new pull request #16202: URL: https://github.com/apache/flink/pull/16202 ## What is the purpose of the change Update AWS SDK v1 and DynamoDB Streams Kinesis adapter to latest version ## Brief change log Bumped: - AWS SDK v1 from `1.11.754` to

[GitHub] [flink] tillrohrmann closed pull request #16188: [FLINK-23024][rest] Make TaskManagerInfoWithSlots serializable

tillrohrmann closed pull request #16188: URL: https://github.com/apache/flink/pull/16188 -- 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. For queries about this service,

[GitHub] [flink] flinkbot edited a comment on pull request #16204: [FLINK-18182][kinesis] Updating to latest AWS SDK for Kinesis connector

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

[GitHub] [flink] rkhachatryan merged pull request #16035: [FLINK-22808][state/changelog] Log metadata

rkhachatryan merged pull request #16035: URL: https://github.com/apache/flink/pull/16035 -- 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. For queries about this service,

[GitHub] [flink] GuXiangFly opened a new pull request #16205: [FLINK-18464][Runtime] fix the bug voidnamespace cast to timewindow

GuXiangFly opened a new pull request #16205: URL: https://github.com/apache/flink/pull/16205 ## What is the purpose of the change This PR is to fix the following two issues only RocksDB: https://issues.apache.org/jira/browse/FLINK-18464

[GitHub] [flink] dannycranmer merged pull request #16187: [FLINK-23009][kinesis] Upgrade Guava for Flink Connector Kinesis

dannycranmer merged pull request #16187: URL: https://github.com/apache/flink/pull/16187 -- 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. For queries about this service,

[GitHub] [flink] KarmaGYZ commented on pull request #16188: [FLINK-23024][rest] Make TaskManagerInfoWithSlots serializable

KarmaGYZ commented on pull request #16188: URL: https://github.com/apache/flink/pull/16188#issuecomment-863710513 Verified in my local env. -- 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

[GitHub] [flink] flinkbot edited a comment on pull request #16135: [FLINK-22961][streaming] firstBarrierArrivalTime is recalculated when…

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

[GitHub] [flink] flinkbot commented on pull request #16203: [FLINK-18182][kinesis] Updating to latest AWS SDK for Kinesis connector

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

[GitHub] [flink] rkhachatryan commented on a change in pull request #16035: [FLINK-22808][state/changelog] Log metadata

rkhachatryan commented on a change in pull request #16035: URL: https://github.com/apache/flink/pull/16035#discussion_r654257598 ## File path: flink-state-backends/flink-statebackend-changelog/src/test/java/org/apache/flink/state/changelog/StateChangeLoggerTestBase.java ## @@

[GitHub] [flink] flinkbot edited a comment on pull request #16070: [FLINK-23028][docs] Improve documentation for pages of SQL.

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

[GitHub] [flink] wenlong88 opened a new pull request #16192: [Flink-22954][table-planner-blink] Rewrite Join on constant TableFunctionScan to Correlate

wenlong88 opened a new pull request #16192: URL: https://github.com/apache/flink/pull/16192 ## What is the purpose of the change this pr trying to fix FLINK-22954 by rewriting join on constant table function scan to Correlate. ## Brief change log - *add a new rewrite

[GitHub] [flink] dannycranmer commented on a change in pull request #16187: [FLINK-23009][kinesis] Upgrade Guava for Flink Connector Kinesis

dannycranmer commented on a change in pull request #16187: URL: https://github.com/apache/flink/pull/16187#discussion_r654255130 ## File path: flink-connectors/flink-sql-connector-kinesis/pom.xml ## @@ -35,17 +35,6 @@ under the License. jar - -

[GitHub] [flink] flinkbot edited a comment on pull request #16195: [FLINK-23009][kinesis] Upgrade Guava for Flink Connector Kinesis

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

[GitHub] [flink] chaplinthink opened a new pull request #16198: [hotfix] Improve tuple equal code logic

chaplinthink opened a new pull request #16198: URL: https://github.com/apache/flink/pull/16198 ## What is the purpose of the change *Make the tuple equals() method code logic simpler and improve readability* ## Brief change log *(for example:)* - *The

[GitHub] [flink] iemre opened a new pull request #16195: [FLINK-23009][kinesis] Upgrade Guava for Flink Connector Kinesis (1.13)

iemre opened a new pull request #16195: URL: https://github.com/apache/flink/pull/16195 ## What is the purpose of the change Upgrade Guava dependency for Flink Connector Kinesis. The connector was using Guava 18.0 which is quite old and has been flagged by some security

[GitHub] [flink] dannycranmer merged pull request #16185: [FLINK-18182][kinesis] Updating to latest AWS SDK for Kinesis connector

dannycranmer merged pull request #16185: URL: https://github.com/apache/flink/pull/16185 -- 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. For queries about this service,

[GitHub] [flink] twalthr closed pull request #16150: [FLINK-22878][core] Allow prefix syntax for ConfigOption.mapType

twalthr closed pull request #16150: URL: https://github.com/apache/flink/pull/16150 -- 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. For queries about this service,

[GitHub] [flink-statefun] igalshilman closed pull request #240: [hotfix] Correct endpoint definition in docs

igalshilman closed pull request #240: URL: https://github.com/apache/flink-statefun/pull/240 -- 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. For queries about this

[GitHub] [flink] dawidwys commented on pull request #16135: [FLINK-22961][streaming] firstBarrierArrivalTime is recalculated when…

dawidwys commented on pull request #16135: URL: https://github.com/apache/flink/pull/16135#issuecomment-863877226 -- 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. For

[GitHub] [flink] GuokuaiHuang removed a comment on pull request #16174: [FLINK-22946][runtime] Recycle floating buffer outside the lock to avoid deadlock

GuokuaiHuang removed a comment on pull request #16174: URL: https://github.com/apache/flink/pull/16174#issuecomment-862898471 @flinkbot run azure -- 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

[GitHub] [flink] zentol commented on pull request #16164: [FLINK-22987][ci] Fix scala suffix check

zentol commented on pull request #16164: URL: https://github.com/apache/flink/pull/16164#issuecomment-864223124 -- 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. For queries

[GitHub] [flink] dawidwys opened a new pull request #16200: [FLINK-23037][docs] Document limitations of unaligned checkpoints

dawidwys opened a new pull request #16200: URL: https://github.com/apache/flink/pull/16200 ## What is the purpose of the change Add limitations of UC. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the

[GitHub] [flink] iemre commented on pull request #16204: [FLINK-18182][kinesis] Updating to latest AWS SDK for Kinesis connector

iemre commented on pull request #16204: URL: https://github.com/apache/flink/pull/16204#issuecomment-864063410 @flinkbot approve all -- 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

[GitHub] [flink] dawidwys commented on a change in pull request #14820: [FLINK-21085][runtime][checkpoint] Allows triggering checkpoint for non-source tasks

dawidwys commented on a change in pull request #14820: URL: https://github.com/apache/flink/pull/14820#discussion_r654200272 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/MultipleInputStreamTask.java ## @@ -175,10 +176,23 @@

[GitHub] [flink] Zakelly commented on pull request #16153: [FLINK-22678] Configurations and user APIs for ChangelogStateBackend

Zakelly commented on pull request #16153: URL: https://github.com/apache/flink/pull/16153#issuecomment-863947779 @Myasuka , thanks for the review! Would you mind taking another look? Thanks. -- This is an automated message from the Apache Git Service. To respond to the message, please

  1   2   3   4   >