[GitHub] [flink] pnowojski commented on a change in pull request #18665: [FLINK-24440][source] Announce and combine latest watermarks across SourceOperators

pnowojski commented on a change in pull request #18665: URL: https://github.com/apache/flink/pull/18665#discussion_r802638272 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/source/coordinator/SourceCoordinator.java ## @@ -101,16 +115,71 @@ Licensed to the

[GitHub] [flink] zentol merged pull request #18682: [FLINK-26046][rest][docs] Fix link to OpenAPI spec

zentol merged pull request #18682: URL: https://github.com/apache/flink/pull/18682 -- 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:

[GitHub] [flink] flinkbot edited a comment on pull request #18684: [FLINK-26036] Only respond to TaskExecutor.freeSlot when running

flinkbot edited a comment on pull request #18684: URL: https://github.com/apache/flink/pull/18684#issuecomment-1033615903 ## CI report: * 9092b9acbfab888fe0d166a679065950750e0193 Azure:

[jira] [Updated] (FLINK-26051) row_number =1 and Subsequent SQL has "case when" and "where" statement : The window can only be ordered in ASCENDING mode

[ https://issues.apache.org/jira/browse/FLINK-26051?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] chuncheng wu updated FLINK-26051: - Description: hello,    i have 2 sqls. One  sql (sql0) is "select xx from ( ROW_NUMBER stament)

[GitHub] [flink] flinkbot edited a comment on pull request #18684: [FLINK-26036] Only respond to TaskExecutor.freeSlot when running

flinkbot edited a comment on pull request #18684: URL: https://github.com/apache/flink/pull/18684#issuecomment-1033615903 ## CI report: * 9092b9acbfab888fe0d166a679065950750e0193 Azure:

[jira] [Updated] (FLINK-26051) row_number =1 and Subsequent SQL has "case when" and "where" statement : The window can only be ordered in ASCENDING mode

[ https://issues.apache.org/jira/browse/FLINK-26051?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] chuncheng wu updated FLINK-26051: - Description: hello,    i have 2 sqls. One  sql (sql0) is "select xx from ( ROW_NUMBER stament)

[jira] [Updated] (FLINK-26051) row_number =1 and Subsequent SQL has "case when" and "where" statement : The window can only be ordered in ASCENDING mode

[ https://issues.apache.org/jira/browse/FLINK-26051?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] chuncheng wu updated FLINK-26051: - Description: hello,    i have 2 sqls. One  sql (sql0) is "select xx from ( ROW_NUMBER stament)

[GitHub] [flink] MartijnVisser commented on a change in pull request #18660: [FLINK-25975][docs] add document about AvroParquet format use cases

MartijnVisser commented on a change in pull request #18660: URL: https://github.com/apache/flink/pull/18660#discussion_r802629436 ## File path: docs/content/docs/connectors/datastream/formats/parquet.md ## @@ -100,3 +103,248 @@ final FileSource source = final DataStream

[jira] [Updated] (FLINK-26051) row_number =1 and Subsequent SQL has "case when" and "where" statement : The window can only be ordered in ASCENDING mode

[ https://issues.apache.org/jira/browse/FLINK-26051?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] chuncheng wu updated FLINK-26051: - Description: hello,    i have 2 sqls. One  sql (sql0) is "select xx from ( ROW_NUMBER stament)

[GitHub] [flink] tillrohrmann commented on pull request #18684: [FLINK-26036] Only respond to TaskExecutor.freeSlot when running

tillrohrmann commented on pull request #18684: URL: https://github.com/apache/flink/pull/18684#issuecomment-1033728956 I've added the `isRunning` check for the `freeInactiveSlots` call. -- This is an automated message from the Apache Git Service. To respond to the message, please log on

[GitHub] [flink] rkhachatryan commented on pull request #18609: [FLINK-25987][docs] Update gradle quickstart quide to gradle 7.3.3

rkhachatryan commented on pull request #18609: URL: https://github.com/apache/flink/pull/18609#issuecomment-1033728671 The issue number seems incorrect: I guess it should be 25897 instead of 25987. I've updated the links in jira manually. -- This is an automated message from the

[GitHub] [flink] tillrohrmann commented on a change in pull request #18684: [FLINK-26036] Only respond to TaskExecutor.freeSlot when running

tillrohrmann commented on a change in pull request #18684: URL: https://github.com/apache/flink/pull/18684#discussion_r802627308 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskExecutor.java ## @@ -1176,7 +1176,11 @@ private void

[GitHub] [flink] flinkbot edited a comment on pull request #18682: [FLINK-26046][rest][docs] Fix link to OpenAPI spec

flinkbot edited a comment on pull request #18682: URL: https://github.com/apache/flink/pull/18682#issuecomment-1033553081 ## CI report: * c7395b867b0bb61681e0afb8982e57b3534f0b22 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18648: [FLINK-25845][table] Introduce EXECUTE PLAN

flinkbot edited a comment on pull request #18648: URL: https://github.com/apache/flink/pull/18648#issuecomment-1031569879 ## CI report: * 88b2fd76ef673648b5462a7725efe11f7100c25e Azure:

[jira] [Updated] (FLINK-26051) row_number =1 and Subsequent SQL has "case when" and "where" statement : The window can only be ordered in ASCENDING mode

[ https://issues.apache.org/jira/browse/FLINK-26051?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] chuncheng wu updated FLINK-26051: - Description: hello,    i have 2 sqls. One  sql (sql0) is "select xx from ( ROW_NUMBER stament)

[GitHub] [flink] flinkbot edited a comment on pull request #18680: [FLINK-25583] Support compacting small files for FileSink.

flinkbot edited a comment on pull request #18680: URL: https://github.com/apache/flink/pull/18680#issuecomment-1033512635 ## CI report: * e50fb694ce8cf0ae952973693bcbf17b1cb75b25 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18648: [FLINK-25845][table] Introduce EXECUTE PLAN

flinkbot edited a comment on pull request #18648: URL: https://github.com/apache/flink/pull/18648#issuecomment-1031569879 ## CI report: * 88b2fd76ef673648b5462a7725efe11f7100c25e Azure:

[jira] [Updated] (FLINK-26051) row_number =1 and Subsequent SQL has "case when" and "where" statement : The window can only be ordered in ASCENDING mode

[ https://issues.apache.org/jira/browse/FLINK-26051?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] chuncheng wu updated FLINK-26051: - Description: hello,    i have 2 sqls. One  sql (sql0) is "select xx from ( ROW_NUMBER stament)

[jira] [Updated] (FLINK-26051) row_number =1 and Subsequent SQL has "case when" and "where" statement : The window can only be ordered in ASCENDING mode

[ https://issues.apache.org/jira/browse/FLINK-26051?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] chuncheng wu updated FLINK-26051: - Description: hello,    i have 2 sqls. One  sql (sql0) is "select xx from ( ROW_NUMBER stament)

[jira] [Updated] (FLINK-26051) row_number =1 and Subsequent SQL has "case when" and "where" statement : The window can only be ordered in ASCENDING mode

[ https://issues.apache.org/jira/browse/FLINK-26051?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] chuncheng wu updated FLINK-26051: - Description: hello,    i have 2 sqls. One  sql (No. sql0) is "select xx from ( ROW_NUMBER

[jira] [Created] (FLINK-26054) Enable maven-enforcer to disable table-planner and table-runtime as dependencies

Francesco Guardiani created FLINK-26054: --- Summary: Enable maven-enforcer to disable table-planner and table-runtime as dependencies Key: FLINK-26054 URL: https://issues.apache.org/jira/browse/FLINK-26054

[GitHub] [flink] slinkydeveloper commented on a change in pull request #18676: [FLINK-26035][build][planner] Add table-planner-loader-helper module

slinkydeveloper commented on a change in pull request #18676: URL: https://github.com/apache/flink/pull/18676#discussion_r802611037 ## File path: flink-table/README.md ## @@ -65,7 +66,8 @@ If you want to use Table API & SQL, check out the [documentation](https://nightl ###

[GitHub] [flink] flinkbot edited a comment on pull request #18681: [FLINK-26032][streaming] check explicit env allowed on StreamExecutionEnvironment own.

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

[GitHub] [flink] zentol commented on a change in pull request #18676: [FLINK-26035][build][planner] Add table-planner-loader-helper module

zentol commented on a change in pull request #18676: URL: https://github.com/apache/flink/pull/18676#discussion_r802608726 ## File path: flink-table/README.md ## @@ -65,7 +66,8 @@ If you want to use Table API & SQL, check out the [documentation](https://nightl ### Notes

[GitHub] [flink] flinkbot edited a comment on pull request #18531: [FLINK-24897] Enable application mode on YARN to use usrlib

flinkbot edited a comment on pull request #18531: URL: https://github.com/apache/flink/pull/18531#issuecomment-1022985542 ## CI report: * 59c6dfebd1f5bdd4ac17ede1c8270aa779afc252 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18434: [FLINK-25742][akka] Remove the serialization of rpc invocation at Fli…

flinkbot edited a comment on pull request #18434: URL: https://github.com/apache/flink/pull/18434#issuecomment-1018078894 ## CI report: * 972db53783b183c8f0f829b0510e599f140787af Azure:

[jira] [Created] (FLINK-26053) Fix parser generator warnings

Francesco Guardiani created FLINK-26053: --- Summary: Fix parser generator warnings Key: FLINK-26053 URL: https://issues.apache.org/jira/browse/FLINK-26053 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-25649) Scheduling jobs fails with org.apache.flink.runtime.jobmanager.scheduler.NoResourceAvailableException

[ https://issues.apache.org/jira/browse/FLINK-25649?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17489506#comment-17489506 ] Gil De Grove commented on FLINK-25649: -- Hello, We tested by increasing the value for the k8s HA,

[GitHub] [flink] flinkbot edited a comment on pull request #18434: [FLINK-25742][akka] Remove the serialization of rpc invocation at Fli…

flinkbot edited a comment on pull request #18434: URL: https://github.com/apache/flink/pull/18434#issuecomment-1018078894 ## CI report: * 972db53783b183c8f0f829b0510e599f140787af Azure:

[GitHub] [flink] jelly-1203 commented on pull request #18358: [FLINK-25651][docs] Update kafka.md

jelly-1203 commented on pull request #18358: URL: https://github.com/apache/flink/pull/18358#issuecomment-1033700656 Can someone help merge it? -- 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

[jira] [Updated] (FLINK-21513) Rethink up-/down-/restartingTime metrics

[ https://issues.apache.org/jira/browse/FLINK-21513?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-21513: - Fix Version/s: 1.16.0 > Rethink up-/down-/restartingTime metrics >

[GitHub] [flink] jelly-1203 removed a comment on pull request #18358: [FLINK-25651][docs] Update kafka.md

jelly-1203 removed a comment on pull request #18358: URL: https://github.com/apache/flink/pull/18358#issuecomment-1022805317 anyone? -- 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] zentol commented on pull request #18678: [FLINK-24474] Default rest.bind-address to localhost in flink-conf.yaml

zentol commented on pull request #18678: URL: https://github.com/apache/flink/pull/18678#issuecomment-1033697631 I merged the docker PR; so you could rebase it now. Maybe wait until the azure e2e issues have been resolved though. -- This is an automated message from the Apache Git

[GitHub] [flink] shouzuo1 removed a comment on pull request #18358: [FLINK-25651][docs] Update kafka.md

shouzuo1 removed a comment on pull request #18358: URL: https://github.com/apache/flink/pull/18358#issuecomment-1033697360 thanks -- 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] shouzuo1 commented on pull request #18358: [FLINK-25651][docs] Update kafka.md

shouzuo1 commented on pull request #18358: URL: https://github.com/apache/flink/pull/18358#issuecomment-1033697360 thanks -- 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] [Commented] (FLINK-24474) Standalone clusters should bind to localhost by default

[ https://issues.apache.org/jira/browse/FLINK-24474?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17489501#comment-17489501 ] Chesnay Schepler commented on FLINK-24474: -- docker-dev-master:

[GitHub] [flink-docker] zentol merged pull request #102: [FLINK-24474] Bind Rest endpoint addresses to 0.0.0.0 by default

zentol merged pull request #102: URL: https://github.com/apache/flink-docker/pull/102 -- 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:

[GitHub] [flink] slinkydeveloper commented on a change in pull request #18676: [FLINK-26035][build][planner] Add table-planner-loader-helper module

slinkydeveloper commented on a change in pull request #18676: URL: https://github.com/apache/flink/pull/18676#discussion_r802592252 ## File path: flink-table/README.md ## @@ -65,7 +66,8 @@ If you want to use Table API & SQL, check out the [documentation](https://nightl ###

[GitHub] [flink] flinkbot edited a comment on pull request #18651: [FLINK-25792][connectors] Only flushing the async sink base if it is …

flinkbot edited a comment on pull request #18651: URL: https://github.com/apache/flink/pull/18651#issuecomment-1031863806 ## CI report: * 695d860892a4e0919e5fbe2a16c63ba912673601 Azure:

[GitHub] [flink] wsry commented on pull request #18505: [FLINK-25796][network] Avoid record copy for result partition of sort-shuffle if there are enough buffers for better performance

wsry commented on pull request #18505: URL: https://github.com/apache/flink/pull/18505#issuecomment-1033686698 > Very thanks @wsry for the PR! I have left some comments. > > For the long run, I tend to we move the difference implementation to the implementation class, like the

[GitHub] [flink] flinkbot edited a comment on pull request #18669: [FLINK-25943][connector/common] Add buffered requests to snapshot state in AsyncSyncWriter.

flinkbot edited a comment on pull request #18669: URL: https://github.com/apache/flink/pull/18669#issuecomment-1033040800 ## CI report: * b33d774d6f9739ada14ba3f8c007684898f4c3fc Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18651: [FLINK-25792][connectors] Only flushing the async sink base if it is …

flinkbot edited a comment on pull request #18651: URL: https://github.com/apache/flink/pull/18651#issuecomment-1031863806 ## CI report: * 695d860892a4e0919e5fbe2a16c63ba912673601 Azure:

[jira] [Commented] (FLINK-26045) Document error status codes for the REST API

[ https://issues.apache.org/jira/browse/FLINK-26045?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17489493#comment-17489493 ] Chesnay Schepler commented on FLINK-26045: -- I thought we did, but I also couldn't find one. >

[jira] [Updated] (FLINK-25987) IllegalArgumentException thrown from FsStateChangelogWriter.truncate

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

[GitHub] [flink] zentol commented on a change in pull request #18609: [FLINK-25987][docs] Update gradle quickstart quide to gradle 7.3.3

zentol commented on a change in pull request #18609: URL: https://github.com/apache/flink/pull/18609#discussion_r802578833 ## File path: docs/content/docs/dev/datastream/project-configuration.md ## @@ -327,9 +318,8 @@ description = """Flink Quickstart Job""" ext {

[GitHub] [flink] wsry commented on a change in pull request #18505: [FLINK-25796][network] Avoid record copy for result partition of sort-shuffle if there are enough buffers for better performance

wsry commented on a change in pull request #18505: URL: https://github.com/apache/flink/pull/18505#discussion_r802580607 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/HashBasedPartitionSortedBuffer.java ## @@ -0,0 +1,309 @@ +/* + *

[GitHub] [flink] flinkbot edited a comment on pull request #18680: [FLINK-25583] Support compacting small files for FileSink.

flinkbot edited a comment on pull request #18680: URL: https://github.com/apache/flink/pull/18680#issuecomment-1033512635 ## CI report: * 90f534147b92bd17e9a653590c8cd1e98b6709aa Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18669: [FLINK-25943][connector/common] Add buffered requests to snapshot state in AsyncSyncWriter.

flinkbot edited a comment on pull request #18669: URL: https://github.com/apache/flink/pull/18669#issuecomment-1033040800 ## CI report: * b33d774d6f9739ada14ba3f8c007684898f4c3fc Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18651: [FLINK-25792][connectors] Only flushing the async sink base if it is …

flinkbot edited a comment on pull request #18651: URL: https://github.com/apache/flink/pull/18651#issuecomment-1031863806 ## CI report: * Unknown: [CANCELED](TBD) * 695d860892a4e0919e5fbe2a16c63ba912673601 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18605: [FLINK-25785][Connectors][JDBC] Upgrade com.h2database:h2 to 2.1.210

flinkbot edited a comment on pull request #18605: URL: https://github.com/apache/flink/pull/18605#issuecomment-1027887418 ## CI report: * 56d378844fb46ed0957fb6a96f800a949eb31f11 Azure:

[GitHub] [flink] wsry commented on a change in pull request #18505: [FLINK-25796][network] Avoid record copy for result partition of sort-shuffle if there are enough buffers for better performance

wsry commented on a change in pull request #18505: URL: https://github.com/apache/flink/pull/18505#discussion_r802577256 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/SortMergeResultPartition.java ## @@ -365,16 +392,17 @@ private void

[GitHub] [flink] CrynetLogistics commented on pull request #18669: [FLINK-25943][connector/common] Add buffered requests to snapshot state in AsyncSyncWriter.

CrynetLogistics commented on pull request #18669: URL: https://github.com/apache/flink/pull/18669#issuecomment-1033673731 -- 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] [Closed] (FLINK-25960) Distribute the data read buffers more fairly among result partitions for sort-shuffle

[ https://issues.apache.org/jira/browse/FLINK-25960?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao closed FLINK-25960. --- Resolution: Fixed > Distribute the data read buffers more fairly among result partitions for >

[jira] [Commented] (FLINK-25960) Distribute the data read buffers more fairly among result partitions for sort-shuffle

[ https://issues.apache.org/jira/browse/FLINK-25960?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17489487#comment-17489487 ] Yun Gao commented on FLINK-25960: - Merged on master via f8473728993e5e13ed980b67a549931ac99ef48f >

[GitHub] [flink] gaoyunhaii closed pull request #18631: [FLINK-25960][network] Distribute the data read buffers more fairly among result partitions for sort-shuffle

gaoyunhaii closed pull request #18631: URL: https://github.com/apache/flink/pull/18631 -- 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:

[GitHub] [flink] flinkbot edited a comment on pull request #18670: [FLINK-25999] Deprecate Per-Job Mode

flinkbot edited a comment on pull request #18670: URL: https://github.com/apache/flink/pull/18670#issuecomment-1033075650 ## CI report: * 6d2175a42d4b39eb15dd1edf3b6643792a05639c Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18667: [FLINK-25990][table] Expose uid generator for DataStream/Transformation providers

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

[GitHub] [flink] flinkbot edited a comment on pull request #18651: [FLINK-25792][connectors] Only flushing the async sink base if it is …

flinkbot edited a comment on pull request #18651: URL: https://github.com/apache/flink/pull/18651#issuecomment-1031863806 ## CI report: * Unknown: [CANCELED](TBD) * 695d860892a4e0919e5fbe2a16c63ba912673601 Azure:

[jira] [Updated] (FLINK-25943) Kinesis, Firehose Async Sink state serializer implementation

[ https://issues.apache.org/jira/browse/FLINK-25943?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-25943: -- Summary: Kinesis, Firehose Async Sink state serializer implementation (was: New Kinesis,

[GitHub] [flink] CrynetLogistics commented on pull request #18651: [FLINK-25792][connectors] Only flushing the async sink base if it is …

CrynetLogistics commented on pull request #18651: URL: https://github.com/apache/flink/pull/18651#issuecomment-1033663142 @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 the

[GitHub] [flink] flinkbot edited a comment on pull request #18680: [FLINK-25583] Support compacting small files for FileSink.

flinkbot edited a comment on pull request #18680: URL: https://github.com/apache/flink/pull/18680#issuecomment-1033512635 ## CI report: * 2ff898d8b0c5ba46e32e0ea26ac021cbaf29cb66 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18669: [FLINK-25943][connector/common] Add buffered requests to snapshot state in AsyncSyncWriter.

flinkbot edited a comment on pull request #18669: URL: https://github.com/apache/flink/pull/18669#issuecomment-1033040800 ## CI report: * c09bd68f357ba6dc0243892a4cbde5b0e4da05fe Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18660: [FLINK-25975][docs] add document about AvroParquet format use cases

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

[GitHub] [flink] flinkbot edited a comment on pull request #18651: [FLINK-25792][connectors] Only flushing the async sink base if it is …

flinkbot edited a comment on pull request #18651: URL: https://github.com/apache/flink/pull/18651#issuecomment-1031863806 ## CI report: * Unknown: [CANCELED](TBD) * 695d860892a4e0919e5fbe2a16c63ba912673601 Azure:

[jira] [Updated] (FLINK-26052) Update chinese documentation regarding FLIP-203

[ https://issues.apache.org/jira/browse/FLINK-26052?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-26052: - Labels: translation-zh (was: ) > Update chinese documentation regarding FLIP-203 >

[jira] [Created] (FLINK-26052) Update chinese documentation regarding FLIP-203

Dawid Wysakowicz created FLINK-26052: Summary: Update chinese documentation regarding FLIP-203 Key: FLINK-26052 URL: https://issues.apache.org/jira/browse/FLINK-26052 Project: Flink

[GitHub] [flink] CrynetLogistics commented on pull request #18651: [FLINK-25792][connectors] Only flushing the async sink base if it is …

CrynetLogistics commented on pull request #18651: URL: https://github.com/apache/flink/pull/18651#issuecomment-1033655445 @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 the

[GitHub] [flink] flinkbot edited a comment on pull request #18669: [FLINK-25943][connector/common] Add buffered requests to snapshot state in AsyncSyncWriter.

flinkbot edited a comment on pull request #18669: URL: https://github.com/apache/flink/pull/18669#issuecomment-1033040800 ## CI report: * c09bd68f357ba6dc0243892a4cbde5b0e4da05fe Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18680: [FLINK-25583] Support compacting small files for FileSink.

flinkbot edited a comment on pull request #18680: URL: https://github.com/apache/flink/pull/18680#issuecomment-1033512635 ## CI report: * 2ff898d8b0c5ba46e32e0ea26ac021cbaf29cb66 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18660: [FLINK-25975][docs] add document about AvroParquet format use cases

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

[jira] [Commented] (FLINK-25745) Support RocksDB incremental native savepoints

[ https://issues.apache.org/jira/browse/FLINK-25745?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17489478#comment-17489478 ] Dawid Wysakowicz commented on FLINK-25745: -- Added additional documentation in

[GitHub] [flink] flinkbot edited a comment on pull request #18651: [FLINK-25792][connectors] Only flushing the async sink base if it is …

flinkbot edited a comment on pull request #18651: URL: https://github.com/apache/flink/pull/18651#issuecomment-1031863806 ## CI report: * Unknown: [CANCELED](TBD) * 695d860892a4e0919e5fbe2a16c63ba912673601 Azure:

[GitHub] [flink] CrynetLogistics commented on pull request #18669: [FLINK-25943][connector/common] Add buffered requests to snapshot state in AsyncSyncWriter.

CrynetLogistics commented on pull request #18669: URL: https://github.com/apache/flink/pull/18669#issuecomment-1033653020 -- 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] CrynetLogistics commented on pull request #18651: [FLINK-25792][connectors] Only flushing the async sink base if it is …

CrynetLogistics commented on pull request #18651: URL: https://github.com/apache/flink/pull/18651#issuecomment-1033651977 @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 the

[GitHub] [flink] CrynetLogistics commented on pull request #18651: [FLINK-25792][connectors] Only flushing the async sink base if it is …

CrynetLogistics commented on pull request #18651: URL: https://github.com/apache/flink/pull/18651#issuecomment-1033651787 -- 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] JingGe commented on pull request #18660: [FLINK-25975][docs] add document about AvroParquet format use cases

JingGe commented on pull request #18660: URL: https://github.com/apache/flink/pull/18660#issuecomment-1033651701 Thanks @MartijnVisser for your effort! I have fixed all found issues. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

[GitHub] [flink] dannycranmer commented on a change in pull request #18553: [FLINK-25846][FLINK-25848] Async Sink does not gracefully shutdown on Cancel, KDS Sink does not fast fail when invalid confi

dannycranmer commented on a change in pull request #18553: URL: https://github.com/apache/flink/pull/18553#discussion_r802552483 ## File path: flink-connectors/flink-connector-aws-kinesis-firehose/src/test/java/org/apache/flink/connector/firehose/sink/KinesisFirehoseSinkITCase.java

[GitHub] [flink] flinkbot edited a comment on pull request #18680: [FLINK-25583] Support compacting small files for FileSink.

flinkbot edited a comment on pull request #18680: URL: https://github.com/apache/flink/pull/18680#issuecomment-1033512635 ## CI report: * 2ff898d8b0c5ba46e32e0ea26ac021cbaf29cb66 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18679: [FLINK-26039][table-runtime] Fix the incorrect value getter in map unnest table function

flinkbot edited a comment on pull request #18679: URL: https://github.com/apache/flink/pull/18679#issuecomment-1033477068 ## CI report: * 65fa5bc084b58cb9407aa9f8a8dac596a44ba871 Azure:

[GitHub] [flink] vahmed-hamdy commented on pull request #18669: [FLINK-25943][connector/common] Add buffered requests to snapshot state in AsyncSyncWriter.

vahmed-hamdy commented on pull request #18669: URL: https://github.com/apache/flink/pull/18669#issuecomment-1033648487 @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 the

[GitHub] [flink] flinkbot edited a comment on pull request #18669: [FLINK-25943][connector/common] Add buffered requests to snapshot state in AsyncSyncWriter.

flinkbot edited a comment on pull request #18669: URL: https://github.com/apache/flink/pull/18669#issuecomment-1033040800 ## CI report: * d025b76c02f35a4c6e56311a7dfed49b5d0dc9d6 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18664: [FLINK-25907][runtime][security] Add pluggable delegation token manager

flinkbot edited a comment on pull request #18664: URL: https://github.com/apache/flink/pull/18664#issuecomment-1032585099 ## CI report: * 323538b090554997be9ed691e37ebb2da221c7cb Azure:

[jira] [Assigned] (FLINK-25937) SQL Client end-to-end test e2e fails on AZP

[ https://issues.apache.org/jira/browse/FLINK-25937?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Morávek reassigned FLINK-25937: - Assignee: (was: David Morávek) > SQL Client end-to-end test e2e fails on AZP >

[GitHub] [flink] flinkbot edited a comment on pull request #18658: [FLINK-26002][tests] Added RestoreUpgradedJobITCase for checking situ…

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

[jira] [Commented] (FLINK-15867) LAST_VALUE and FIRST_VALUE aggregate function does not support time-related types

[ https://issues.apache.org/jira/browse/FLINK-15867?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17489473#comment-17489473 ] Piotr commented on FLINK-15867: --- Any updates when the issue will be fixed? > LAST_VALUE and FIRST_VALUE

[GitHub] [flink] dannycranmer commented on a change in pull request #18553: [FLINK-25846][FLINK-25848] Async Sink does not gracefully shutdown on Cancel, KDS Sink does not fast fail when invalid confi

dannycranmer commented on a change in pull request #18553: URL: https://github.com/apache/flink/pull/18553#discussion_r802549883 ## File path: flink-connectors/flink-connector-aws-base/src/main/java/org/apache/flink/connector/aws/util/AWSGeneralUtil.java ## @@ -369,4 +367,35

[GitHub] [flink] dannycranmer commented on a change in pull request #18553: [FLINK-25846][FLINK-25848] Async Sink does not gracefully shutdown on Cancel, KDS Sink does not fast fail when invalid confi

dannycranmer commented on a change in pull request #18553: URL: https://github.com/apache/flink/pull/18553#discussion_r802473682 ## File path: flink-connectors/flink-connector-aws-base/src/main/java/org/apache/flink/connector/aws/util/AWSGeneralUtil.java ## @@ -369,4 +367,35

[GitHub] [flink] JingGe commented on a change in pull request #18660: [FLINK-25975][docs] add document about AvroParquet format use cases

JingGe commented on a change in pull request #18660: URL: https://github.com/apache/flink/pull/18660#discussion_r802548281 ## File path: docs/content/docs/connectors/datastream/formats/parquet.md ## @@ -44,9 +44,11 @@ Thus, you can use this format in two ways: - Bounded read

[GitHub] [flink] flinkbot edited a comment on pull request #18680: [FLINK-25583] Support compacting small files for FileSink.

flinkbot edited a comment on pull request #18680: URL: https://github.com/apache/flink/pull/18680#issuecomment-1033512635 ## CI report: * 2ff898d8b0c5ba46e32e0ea26ac021cbaf29cb66 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18667: [FLINK-25990][table] Expose uid generator for DataStream/Transformation providers

flinkbot edited a comment on pull request #18667: URL: https://github.com/apache/flink/pull/18667#issuecomment-1032823071 ## CI report: * db2efa44c8ce08b800718535b5f9d21c1b16078d Azure:

[jira] [Updated] (FLINK-26051) row_number =1 and Subsequent SQL has "case when" and "where" statement : The window can only be ordered in ASCENDING mode

[ https://issues.apache.org/jira/browse/FLINK-26051?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] chuncheng wu updated FLINK-26051: - Description: hello,    i have 2 sqls. One sql has rn=1 and  the Subsequent SQL has "case when"

[GitHub] [flink] flinkbot edited a comment on pull request #18651: [FLINK-25792][connectors] Only flushing the async sink base if it is …

flinkbot edited a comment on pull request #18651: URL: https://github.com/apache/flink/pull/18651#issuecomment-1031863806 ## CI report: * Unknown: [CANCELED](TBD) * 695d860892a4e0919e5fbe2a16c63ba912673601 Azure:

[jira] [Updated] (FLINK-26051) row_number =1 and Subsequent SQL has "case when" and "where" statement : The window can only be ordered in ASCENDING mode

[ https://issues.apache.org/jira/browse/FLINK-26051?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] chuncheng wu updated FLINK-26051: - Description: hello,    i have 2 sqls. One sql has rn=1 and  the Subsequent SQL has "case when"

[jira] [Commented] (FLINK-26051) row_number =1 and Subsequent SQL has "case when" and "where" statement : The window can only be ordered in ASCENDING mode

[ https://issues.apache.org/jira/browse/FLINK-26051?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17489467#comment-17489467 ] chuncheng wu commented on FLINK-26051: -- the same problem in last comments:

[GitHub] [flink] dawidwys closed pull request #18645: [FLINK-25745] Document incremental savepoints in CLAIM mode limitation

dawidwys closed pull request #18645: URL: https://github.com/apache/flink/pull/18645 -- 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:

[GitHub] [flink] slinkydeveloper commented on pull request #18667: [FLINK-25990][table] Expose uid generator for DataStream/Transformation providers

slinkydeveloper commented on pull request #18667: URL: https://github.com/apache/flink/pull/18667#issuecomment-1033637343 @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 the

[GitHub] [flink] pltbkd commented on pull request #18680: [FLINK-25583] Support compacting small files for FileSink.

pltbkd commented on pull request #18680: URL: https://github.com/apache/flink/pull/18680#issuecomment-1033636620 The branch is force pushed to add a hotfix before all commits, to fix the bug in SinkTransformationTranslator that sets parallelism of transformations added in the per-commit

[GitHub] [flink] zuston commented on pull request #18220: [FLINK-25410] Flink CLI should exit when app is accepted with detach …

zuston commented on pull request #18220: URL: https://github.com/apache/flink/pull/18220#issuecomment-1033630975 The failure of CI looks unrelated. But i can't retrigger, could u help rerun @tillrohrmann Thanks :) -- This is an automated message from the Apache Git Service. To respond

[GitHub] [flink] flinkbot edited a comment on pull request #18651: [FLINK-25792][connectors] Only flushing the async sink base if it is …

flinkbot edited a comment on pull request #18651: URL: https://github.com/apache/flink/pull/18651#issuecomment-1031863806 ## CI report: * Unknown: [CANCELED](TBD) * 695d860892a4e0919e5fbe2a16c63ba912673601 UNKNOWN Bot commands The @flinkbot bot supports the

[GitHub] [flink] flinkbot edited a comment on pull request #18573: [FLINK-25841][table] Expose plan via TableEnvironment.compilePlanSql/executePlan

flinkbot edited a comment on pull request #18573: URL: https://github.com/apache/flink/pull/18573#issuecomment-1025878917 ## CI report: * 9a224d875c6cd1fe41339151caf3a288099eda77 Azure:

<    2   3   4   5   6   7   8   9   10   >