[GitHub] [flink] xuyangzhong commented on a change in pull request #17652: [FLINK-24717][table-planner]Push down partitions before filters

xuyangzhong commented on a change in pull request #17652: URL: https://github.com/apache/flink/pull/17652#discussion_r741632375 ## File path: flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/rules/FlinkBatchRuleSets.scala ## @@ -176,13

[GitHub] [flink] xuyangzhong commented on a change in pull request #17652: [FLINK-24717][table-planner]Push down partitions before filters

xuyangzhong commented on a change in pull request #17652: URL: https://github.com/apache/flink/pull/17652#discussion_r741632375 ## File path: flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/rules/FlinkBatchRuleSets.scala ## @@ -176,13

[GitHub] [flink] curcur edited a comment on pull request #17229: [FLINK-23381][state] Back-pressure on reaching state change to upload limit

curcur edited a comment on pull request #17229: URL: https://github.com/apache/flink/pull/17229#issuecomment-958666854 Hey folks, I’ve spent some time reading through the `FsStateChangelogWriter` and related `DFS` uploading implementation. Now I have a bit better understanding but with

[GitHub] [flink] curcur edited a comment on pull request #17229: [FLINK-23381][state] Back-pressure on reaching state change to upload limit

curcur edited a comment on pull request #17229: URL: https://github.com/apache/flink/pull/17229#issuecomment-958666854 Hey folks, I’ve spent some time reading through the `FsStateChangelogWriter` and related `DFS` uploading implementation. Now I have a bit better understanding but with

[GitHub] [flink] flinkbot edited a comment on pull request #17532: [FLINK-22096][tests] Fix port conflict for ServerTransportErrorHandlingTest#testRemoteClose

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

[GitHub] [flink] wsry commented on pull request #17532: [FLINK-22096][tests] Fix port conflict for ServerTransportErrorHandlingTest#testRemoteClose

wsry commented on pull request #17532: URL: https://github.com/apache/flink/pull/17532#issuecomment-958667123 @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 specific

[GitHub] [flink] curcur commented on pull request #17229: [FLINK-23381][state] Back-pressure on reaching state change to upload limit

curcur commented on pull request #17229: URL: https://github.com/apache/flink/pull/17229#issuecomment-958666854 Hey folks, I’ve spent some time reading through the `FsStateChangelogWriter` and related `DFS` uploading implementation. Now I have a bit better understanding but with more

[jira] [Updated] (FLINK-24713) Postpone resourceManager serving after the recovery phase has finished

[ https://issues.apache.org/jira/browse/FLINK-24713?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aitozi updated FLINK-24713: --- Description: When ResourceManager started, JobManger will connect to the ResourceManager, this means the

[jira] [Comment Edited] (FLINK-24001) Support evaluating individual window table-valued function in runtime

[ https://issues.apache.org/jira/browse/FLINK-24001?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17437733#comment-17437733 ] JING ZHANG edited comment on FLINK-24001 at 11/3/21, 5:08 AM: -- After

[jira] [Commented] (FLINK-24001) Support evaluating individual window table-valued function in runtime

[ https://issues.apache.org/jira/browse/FLINK-24001?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17437733#comment-17437733 ] JING ZHANG commented on FLINK-24001: After discussion with [~lzljs3620320] [~jark], it seems we have

[jira] [Comment Edited] (FLINK-24001) Support evaluating individual window table-valued function in runtime

[ https://issues.apache.org/jira/browse/FLINK-24001?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17412517#comment-17412517 ] JING ZHANG edited comment on FLINK-24001 at 11/3/21, 5:06 AM: -- This pr aims

[jira] [Comment Edited] (FLINK-24001) Support evaluating individual window table-valued function in runtime

[ https://issues.apache.org/jira/browse/FLINK-24001?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17412517#comment-17412517 ] JING ZHANG edited comment on FLINK-24001 at 11/3/21, 5:02 AM: -- This pr aims

[GitHub] [flink] KurtYoung commented on a change in pull request #17652: [FLINK-24717][table-planner]Push down partitions before filters

KurtYoung commented on a change in pull request #17652: URL: https://github.com/apache/flink/pull/17652#discussion_r741613565 ## File path: flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/rules/FlinkBatchRuleSets.scala ## @@ -176,13 +176,13

[GitHub] [flink] flinkbot edited a comment on pull request #17652: [FLINK-24717][table-planner]Push down partitions before filters

flinkbot edited a comment on pull request #17652: URL: https://github.com/apache/flink/pull/17652#issuecomment-958647607 ## CI report: * f6bd3590036c9bdd760751c7ca9640cc0b1a071a Azure:

[GitHub] [flink] flinkbot commented on pull request #17652: [FLINK-24717][table-planner]Push down partitions before filters

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

[GitHub] [flink] flinkbot commented on pull request #17652: [FLINK-24717][table-planner]Push down partitions before filters

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

[jira] [Updated] (FLINK-24717) Push down partitions before filters

[ https://issues.apache.org/jira/browse/FLINK-24717?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-24717: --- Labels: pull-request-available (was: ) > Push down partitions before filters >

[GitHub] [flink] xuyangzhong opened a new pull request #17652: [FLINK-24717][table-planner]Push down partitions before filters

xuyangzhong opened a new pull request #17652: URL: https://github.com/apache/flink/pull/17652 ## What is the purpose of the change In the optimized period, put the rule PushPartitionsDown before the rule PushFiltersDown to avoid PushFiltersDown consumes all filters and cause that

[GitHub] [flink] flinkbot edited a comment on pull request #17525: [FLINK-24597][state] fix the problem that RocksStateKeysAndNamespaceIterator would return duplicate data

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

[GitHub] [flink] KurtYoung commented on pull request #17638: [FLINK-24728][table-runtime] Close output stream in batch SQL file sink

KurtYoung commented on pull request #17638: URL: https://github.com/apache/flink/pull/17638#issuecomment-958645030 If such issue already caused a bug, i'd prefer to at least add a test when we trying to fix it. Even the change itself looks tiny, but given it already causes real issue,

[jira] [Commented] (FLINK-24001) Support evaluating individual window table-valued function in runtime

[ https://issues.apache.org/jira/browse/FLINK-24001?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17437723#comment-17437723 ] JING ZHANG commented on FLINK-24001: [~icshuo] Session window belongs to set-semantic window which

[jira] [Commented] (FLINK-21543) when using FIFO compaction, I found sst being deleted on the first checkpoint

[ https://issues.apache.org/jira/browse/FLINK-21543?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17437722#comment-17437722 ] Yun Tang commented on FLINK-21543: -- [~Ming Li], you could refer to RocksDB's documentation:

[GitHub] [flink] flinkbot edited a comment on pull request #17651: [FLINK-24656][docs] Add documentation for window deduplication

flinkbot edited a comment on pull request #17651: URL: https://github.com/apache/flink/pull/17651#issuecomment-958639580 ## CI report: * 526b8eddd977adbcf7a839722374995b24d446be Azure:

[jira] [Updated] (FLINK-24000) window aggregate support allow lateness

[ https://issues.apache.org/jira/browse/FLINK-24000?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] JING ZHANG updated FLINK-24000: --- Affects Version/s: (was: 1.15.0) > window aggregate support allow lateness >

[jira] [Updated] (FLINK-24002) Support count window with the window TVF

[ https://issues.apache.org/jira/browse/FLINK-24002?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] JING ZHANG updated FLINK-24002: --- Affects Version/s: (was: 1.15.0) > Support count window with the window TVF >

[jira] [Updated] (FLINK-24024) Support session Window TVF

[ https://issues.apache.org/jira/browse/FLINK-24024?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] JING ZHANG updated FLINK-24024: --- Affects Version/s: (was: 1.15.0) > Support session Window TVF > --- >

[GitHub] [flink] flinkbot commented on pull request #17651: [FLINK-24656][docs] Add documentation for window deduplication

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

[GitHub] [flink] Myasuka commented on a change in pull request #17645: [FLINK-24667][runtime] Fix error handling in ChannelStateCheckpointWriter

Myasuka commented on a change in pull request #17645: URL: https://github.com/apache/flink/pull/17645#discussion_r741606981 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/state/ttl/mock/MockKeyedStateBackend.java ## @@ -221,9 +226,11 @@ public void

[GitHub] [flink] flinkbot commented on pull request #17651: [FLINK-24656][docs] Add documentation for window deduplication

flinkbot commented on pull request #17651: URL: https://github.com/apache/flink/pull/17651#issuecomment-958639580 ## CI report: * 526b8eddd977adbcf7a839722374995b24d446be UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #17650: [FLINK-24475] Remove no longer used NestedMap* classes

flinkbot edited a comment on pull request #17650: URL: https://github.com/apache/flink/pull/17650#issuecomment-958638599 ## CI report: * 150b5f9f464913cc83756cbadd233cdb279db0c7 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17605: [FLINK-24704][table] Fix exception when the input record loses monotonicity on the sort key field of UpdatableTopNFunction

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

[GitHub] [flink] flinkbot commented on pull request #17650: [FLINK-24475] Remove no longer used NestedMap* classes

flinkbot commented on pull request #17650: URL: https://github.com/apache/flink/pull/17650#issuecomment-958639127 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] [Updated] (FLINK-24656) Add user document for Window Deduplication

[ https://issues.apache.org/jira/browse/FLINK-24656?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-24656: --- Labels: pull-request-available (was: ) > Add user document for Window Deduplication >

[GitHub] [flink] beyond1920 opened a new pull request #17651: [FLINK-24656][docs] Add documentation for window deduplication

beyond1920 opened a new pull request #17651: URL: https://github.com/apache/flink/pull/17651 ## What is the purpose of the change The pr adds documentation for Window deduplication. ## Brief change log Window-deduplication.md ## Verifying this change This

[GitHub] [flink] flinkbot commented on pull request #17650: [FLINK-24475] Remove no longer used NestedMap* classes

flinkbot commented on pull request #17650: URL: https://github.com/apache/flink/pull/17650#issuecomment-958638599 ## CI report: * 150b5f9f464913cc83756cbadd233cdb279db0c7 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] JingsongLi commented on pull request #17569: [FLINK-24648] CEIL and FLOOR should support DECADE, CENTURY, MILLENNIUM

JingsongLi commented on pull request #17569: URL: https://github.com/apache/flink/pull/17569#issuecomment-958638514 Hi @snuyanzin , I'm a little confused. Is the beginning of the era 00 or 01? Have you investigated the behavior of other databases? -- This is an automated message from

[GitHub] [flink] flinkbot edited a comment on pull request #17605: [FLINK-24704][table] Fix exception when the input record loses monotonicity on the sort key field of UpdatableTopNFunction

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

[jira] [Updated] (FLINK-24475) Remove no longer used NestedMap* classes

[ https://issues.apache.org/jira/browse/FLINK-24475?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-24475: --- Labels: pull-request-available (was: ) > Remove no longer used NestedMap* classes >

[GitHub] [flink] Zakelly opened a new pull request #17650: [FLINK-24475] Remove no longer used NestedMap* classes

Zakelly opened a new pull request #17650: URL: https://github.com/apache/flink/pull/17650 ## What is the purpose of the change Since NestedStateMap is no longer used in production code after FLINK-21935, this PR removes all NestedMap* classes. ## Brief change log -

[GitHub] [flink] JingsongLi commented on a change in pull request #17569: [FLINK-24648] CEIL and FLOOR should support DECADE, CENTURY, MILLENNIUM

JingsongLi commented on a change in pull request #17569: URL: https://github.com/apache/flink/pull/17569#discussion_r741603842 ## File path: flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/expressions/TemporalTypesTest.scala ## @@ -890,14 +890,24

[GitHub] [flink] lincoln-lil commented on a change in pull request #17605: [FLINK-24704][table] Fix exception when the input record loses monotonicity on the sort key field of UpdatableTopNFunction

lincoln-lil commented on a change in pull request #17605: URL: https://github.com/apache/flink/pull/17605#discussion_r741603426 ## File path: flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/rank/UpdatableTopNFunction.java ## @@ -312,6

[GitHub] [flink] lincoln-lil commented on a change in pull request #17605: [FLINK-24704][table] Fix exception when the input record loses monotonicity on the sort key field of UpdatableTopNFunction

lincoln-lil commented on a change in pull request #17605: URL: https://github.com/apache/flink/pull/17605#discussion_r741602604 ## File path: flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/rank/UpdatableTopNFunction.java ## @@ -75,6

[jira] [Assigned] (FLINK-24728) Batch SQL file sink forgets to close the output stream

[ https://issues.apache.org/jira/browse/FLINK-24728?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-24728: Assignee: Caizhi Weng > Batch SQL file sink forgets to close the output stream >

[jira] [Updated] (FLINK-24728) Batch SQL file sink forgets to close the output stream

[ https://issues.apache.org/jira/browse/FLINK-24728?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-24728: - Priority: Major (was: Critical) > Batch SQL file sink forgets to close the output stream >

[GitHub] [flink] JingsongLi merged pull request #17638: [FLINK-24728][table-runtime] Close output stream in batch SQL file sink

JingsongLi merged pull request #17638: URL: https://github.com/apache/flink/pull/17638 -- 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] Myasuka commented on a change in pull request #17525: [FLINK-24597][state] fix the problem that RocksStateKeysAndNamespaceIterator would return duplicate data

Myasuka commented on a change in pull request #17525: URL: https://github.com/apache/flink/pull/17525#discussion_r741597480 ## File path:

[jira] [Commented] (FLINK-24689) Add log file's time info in loglist

[ https://issues.apache.org/jira/browse/FLINK-24689?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17437715#comment-17437715 ] Fei Feng commented on FLINK-24689: -- Hi @[~trohrmann] , I will add field called "Last Modify Time" in

[GitHub] [flink] tsreaper commented on a change in pull request #17605: [FLINK-24704][table] Fix exception when the input record loses monotonicity on the sort key field of UpdatableTopNFunction

tsreaper commented on a change in pull request #17605: URL: https://github.com/apache/flink/pull/17605#discussion_r741595404 ## File path: flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/rank/UpdatableTopNFunction.java ## @@ -312,6

[jira] [Updated] (FLINK-24689) Add log file's time info in loglist

[ https://issues.apache.org/jira/browse/FLINK-24689?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fei Feng updated FLINK-24689: - Attachment: image-2021-11-03-11-22-36-220.png > Add log file's time info in loglist >

[GitHub] [flink] flinkbot edited a comment on pull request #17632: [FLINK-23014][table-planner] Support streaming window Deduplicate in planner

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

[GitHub] [flink] flinkbot edited a comment on pull request #17632: [FLINK-23014][table-planner] Support streaming window Deduplicate in planner

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

[GitHub] [flink] flinkbot edited a comment on pull request #17509: [FLINK-24501][table-runtime] Stores window progress into state in order to check whether an input element is late or not for window-t

flinkbot edited a comment on pull request #17509: URL: https://github.com/apache/flink/pull/17509#issuecomment-945571594 ## CI report: * 47e6223322b4e409c54080919c7954507f27fea1 Azure:

[jira] [Closed] (FLINK-23015) Implement streaming window Deduplicate operator

[ https://issues.apache.org/jira/browse/FLINK-23015?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-23015. Resolution: Fixed master: 59d6a189b0aa4d8ccbbc39abb73fe317f0abfcf1 > Implement streaming window

[GitHub] [flink] flinkbot edited a comment on pull request #17509: [FLINK-24501][table-runtime] Stores window progress into state in order to check whether an input element is late or not for window-t

flinkbot edited a comment on pull request #17509: URL: https://github.com/apache/flink/pull/17509#issuecomment-945571594 ## CI report: * 47e6223322b4e409c54080919c7954507f27fea1 Azure:

[GitHub] [flink] JingsongLi commented on pull request #17571: [FLINK-23015][table-runtime-blink] Implement streaming window Deduplicate operator

JingsongLi commented on pull request #17571: URL: https://github.com/apache/flink/pull/17571#issuecomment-958618670 Minor: @beyond1920 We don't need add "blink" in the commit message, blink planner is the only planner. -- This is an automated message from the Apache Git Service. To

[GitHub] [flink] JingsongLi merged pull request #17571: [FLINK-23015][table-runtime-blink] Implement streaming window Deduplicate operator

JingsongLi merged pull request #17571: URL: https://github.com/apache/flink/pull/17571 -- 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 #17638: [FLINK-24728][table-runtime] Close output stream in batch SQL file sink

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

[GitHub] [flink] flinkbot edited a comment on pull request #17649: [FLINK-24742][table][docs] Add info about SQL client key strokes to docs

flinkbot edited a comment on pull request #17649: URL: https://github.com/apache/flink/pull/17649#issuecomment-958288236 ## CI report: * 7081987de10cb9601d16a1292862fb062cf002d5 Azure:

[jira] [Updated] (FLINK-24726) Hive Lookup Join SQL: decimal type UnsupportedOperationException

[ https://issues.apache.org/jira/browse/FLINK-24726?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zongwen Li updated FLINK-24726: --- Description: exception trace: {code:java} java.lang.UnsupportedOperationException:

[GitHub] [flink] flinkbot edited a comment on pull request #17525: [FLINK-24597][state] fix the problem that RocksStateKeysAndNamespaceIterator would return duplicate data

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

[GitHub] [flink] flinkbot edited a comment on pull request #17525: [FLINK-24597][state] fix the problem that RocksStateKeysAndNamespaceIterator would return duplicate data

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

[GitHub] [flink] mayuehappy commented on pull request #17525: [FLINK-24597][state] fix the problem that RocksStateKeysAndNamespaceIterator would return duplicate data

mayuehappy commented on pull request #17525: URL: https://github.com/apache/flink/pull/17525#issuecomment-958606761 @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 #17638: [FLINK-24728][table-runtime] Close output stream in batch SQL file sink

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

[GitHub] [flink] flinkbot edited a comment on pull request #17638: [FLINK-24728][table-runtime] Close output stream in batch SQL file sink

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

[GitHub] [flink] tsreaper commented on pull request #17638: [FLINK-24728][table-runtime] Close output stream in batch SQL file sink

tsreaper commented on pull request #17638: URL: https://github.com/apache/flink/pull/17638#issuecomment-958603402 @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 #16962: [FLINK-15352][connector-jdbc] Develop MySQLCatalog to connect Flink with MySQL tables and ecosystem.

flinkbot edited a comment on pull request #16962: URL: https://github.com/apache/flink/pull/16962#issuecomment-904541061 ## CI report: * fd4ec5a34a3b9004f0571c5a77795cb4a0cd5931 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16962: [FLINK-15352][connector-jdbc] Develop MySQLCatalog to connect Flink with MySQL tables and ecosystem.

flinkbot edited a comment on pull request #16962: URL: https://github.com/apache/flink/pull/16962#issuecomment-904541061 ## CI report: * fd4ec5a34a3b9004f0571c5a77795cb4a0cd5931 Azure:

[jira] [Closed] (FLINK-24725) Update Cython to the latest version

[ https://issues.apache.org/jira/browse/FLINK-24725?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-24725. --- Fix Version/s: 1.15.0 Assignee: Martijn Visser Resolution: Fixed Merged to master via 

[GitHub] [flink] dianfu closed pull request #17644: [FLINK-24725] Update Cython to the latest version

dianfu closed pull request #17644: URL: https://github.com/apache/flink/pull/17644 -- 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] JingsongLi commented on a change in pull request #17605: [FLINK-24704][table] Fix exception when the input record loses monotonicity on the sort key field of UpdatableTopNFunction

JingsongLi commented on a change in pull request #17605: URL: https://github.com/apache/flink/pull/17605#discussion_r741566910 ## File path: flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/rank/UpdatableTopNFunction.java ## @@ -75,6

[jira] [Updated] (FLINK-24730) Support prompt in SqlCli

[ https://issues.apache.org/jira/browse/FLINK-24730?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yubin Li updated FLINK-24730: - Description: prompt is a very popular function in cli of traditional database like mysql, help users

[GitHub] [flink] flinkbot edited a comment on pull request #17646: [FLINK-24740] Update testcontainers dependency to the latest version

flinkbot edited a comment on pull request #17646: URL: https://github.com/apache/flink/pull/17646#issuecomment-957837700 ## CI report: * 1772423646c8d93b4cb288e1b32233c87eabf80e Azure:

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

flinkbot edited a comment on pull request #17345: URL: https://github.com/apache/flink/pull/17345#issuecomment-926109717 ## CI report: * 7be470868e14bdfc6c424041cfb0edddf8f5b124 Azure:

[jira] [Updated] (FLINK-19053) Flink Kafka Connector Dependency Error

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

[jira] [Updated] (FLINK-19065) java.lang.IllegalStateException: Auto generated UIDs have been disabled on join

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

[jira] [Updated] (FLINK-19059) Support to consume retractions for OVER WINDOW operator

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

[jira] [Updated] (FLINK-19113) Add support for checkpointing with selectable inputs

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

[jira] [Updated] (FLINK-19202) HadoopS3FileSystemITCase.testSimpleFileWriteAndRead failed with "FileNotFoundException: No such file or directory: s3://***/temp/tests-7ebc11df-9160-4403-85a7-c484da44f3

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

[jira] [Updated] (FLINK-19153) FLIP-131: Consolidate the user-facing Dataflow SDKs/APIs (and deprecate the DataSet API)

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

[jira] [Updated] (FLINK-19132) Failed to start jobs for consuming Secure Kafka after cluster restart

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

[jira] [Updated] (FLINK-19104) how to run Fraud Detection walkthrough in Eclipse

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

[jira] [Updated] (FLINK-19127) Provide a replacement of StreamExecutionEnvironment.createRemoteEnvironment for TableEnvironment

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

[jira] [Updated] (FLINK-19063) Support join late event from dimension table side in temporal table join

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

[jira] [Updated] (FLINK-19204) Improve warning during a Table.execute()

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

[GitHub] [flink] flinkbot edited a comment on pull request #17649: [FLINK-24742][table][docs] Add info about SQL client key strokes to docs

flinkbot edited a comment on pull request #17649: URL: https://github.com/apache/flink/pull/17649#issuecomment-958288236 ## CI report: * 7081987de10cb9601d16a1292862fb062cf002d5 Azure:

[GitHub] [flink] flinkbot commented on pull request #17649: [FLINK-24742][table][docs] Add info about SQL client key strokes to docs

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

[GitHub] [flink] flinkbot commented on pull request #17649: [FLINK-24742][table][docs] Add info about SQL client key strokes to docs

flinkbot commented on pull request #17649: URL: https://github.com/apache/flink/pull/17649#issuecomment-958288236 ## CI report: * 7081987de10cb9601d16a1292862fb062cf002d5 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Updated] (FLINK-24742) SQL client add info about key strokes to docs

[ https://issues.apache.org/jira/browse/FLINK-24742?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-24742: --- Labels: pull-request-available (was: ) > SQL client add info about key strokes to docs >

[GitHub] [flink] snuyanzin opened a new pull request #17649: [FLINK-24742][table][docs] Add info about SQL client key strokes to docs

snuyanzin opened a new pull request #17649: URL: https://github.com/apache/flink/pull/17649 ## What is the purpose of the change The PR adds info about key-strokes in SQL client to docs ## Does this pull request potentially affect one of the following parts: -

[GitHub] [flink] flinkbot edited a comment on pull request #17646: [FLINK-24740] Update testcontainers dependency to the latest version

flinkbot edited a comment on pull request #17646: URL: https://github.com/apache/flink/pull/17646#issuecomment-957837700 ## CI report: * 1772423646c8d93b4cb288e1b32233c87eabf80e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17646: [FLINK-24740] Update testcontainers dependency to the latest version

flinkbot edited a comment on pull request #17646: URL: https://github.com/apache/flink/pull/17646#issuecomment-957837700 ## CI report: * 1772423646c8d93b4cb288e1b32233c87eabf80e Azure:

[GitHub] [flink] MartijnVisser commented on pull request #17646: [FLINK-24740] Update testcontainers dependency to the latest version

MartijnVisser commented on pull request #17646: URL: https://github.com/apache/flink/pull/17646#issuecomment-958266041 @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

[jira] [Created] (FLINK-24742) SQL client add info about key strokes to docs

Sergey Nuyanzin created FLINK-24742: --- Summary: SQL client add info about key strokes to docs Key: FLINK-24742 URL: https://issues.apache.org/jira/browse/FLINK-24742 Project: Flink Issue

[GitHub] [flink] flinkbot edited a comment on pull request #17646: [FLINK-24740] Update testcontainers dependency to the latest version

flinkbot edited a comment on pull request #17646: URL: https://github.com/apache/flink/pull/17646#issuecomment-957837700 ## CI report: * 1772423646c8d93b4cb288e1b32233c87eabf80e Azure:

[GitHub] [flink] twalthr closed pull request #17579: [FLINK-24454][table-planner][tests] Consolidate cast tests

twalthr closed pull request #17579: URL: https://github.com/apache/flink/pull/17579 -- 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] pnowojski merged pull request #17628: [FLINK-15550][runtime] Don't ignore the interruption for testCancelTa…

pnowojski merged pull request #17628: URL: https://github.com/apache/flink/pull/17628 -- 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] echauchot edited a comment on pull request #17641: [FLINK-21407][doc][formats] Add formats to DataStream connectors doc

echauchot edited a comment on pull request #17641: URL: https://github.com/apache/flink/pull/17641#issuecomment-957268928 R: @AHeise as discussed :slightly_smiling_face: -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

[GitHub] [flink] twalthr commented on a change in pull request #17624: [FLINK-24714][table-api-java] Validate partition keys for ResolvedCatalogTable

twalthr commented on a change in pull request #17624: URL: https://github.com/apache/flink/pull/17624#discussion_r740854369 ## File path: flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/catalog/CatalogManager.java ## @@ -874,7 +876,24 @@ public

[GitHub] [flink] tillrohrmann closed pull request #17426: [FLINK-24167][Runtime]Add default HeartbeatReceiver and HeartbeatSend…

tillrohrmann closed pull request #17426: URL: https://github.com/apache/flink/pull/17426 -- 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 commented on pull request #17645: [FLINK-24667][runtime] Fix error handling in ChannelStateCheckpointWriter

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

  1   2   3   4   5   6   7   8   >