[jira] [Closed] (FLINK-22600) TableSourceTable: extraDigests should be consistent with abilitySpecs

[ https://issues.apache.org/jira/browse/FLINK-22600?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-22600. Resolution: Duplicate > TableSourceTable: extraDigests should be consistent with abilitySpecs > --

[GitHub] [flink] Airblader commented on a change in pull request #17011: [FLINK-23663][table-planner] Reduce state size of ChangelogNormalize

Airblader commented on a change in pull request #17011: URL: https://github.com/apache/flink/pull/17011#discussion_r697805528 ## File path: flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/factories/TableFactoryHarness.java ## @@ -0,0 +1,336 @@ +/*

[GitHub] [flink] wuchong commented on a change in pull request #16997: [FLINK-23287][docs][table] Create user document for Window Join in SQL

wuchong commented on a change in pull request #16997: URL: https://github.com/apache/flink/pull/16997#discussion_r698233811 ## File path: docs/content.zh/docs/dev/table/sql/queries/window-join.md ## @@ -0,0 +1,192 @@ +--- +title: "窗口关联" +weight: 10 +type: docs +--- + + +# Windo

[GitHub] [flink] flinkbot commented on pull request #17047: [FLINK-24027][filesystems] Remove excessive dependencies from NOTICE files

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

[jira] [Updated] (FLINK-24027) FileSystems list excessive dependencies in NOTICE

[ https://issues.apache.org/jira/browse/FLINK-24027?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-24027: --- Labels: pull-request-available (was: ) > FileSystems list excessive dependencies in NOTICE

[GitHub] [flink] wuchong commented on a change in pull request #16997: [FLINK-23287][docs][table] Create user document for Window Join in SQL

wuchong commented on a change in pull request #16997: URL: https://github.com/apache/flink/pull/16997#discussion_r698231900 ## File path: docs/content.zh/docs/dev/table/sql/queries/window-join.md ## @@ -0,0 +1,192 @@ +--- +title: "窗口关联" +weight: 10 +type: docs +--- + + +# Windo

[GitHub] [flink] Airblader opened a new pull request #17047: [FLINK-24027][filesystems] Remove excessive dependencies from NOTICE files

Airblader opened a new pull request #17047: URL: https://github.com/apache/flink/pull/17047 ## What is the purpose of the change This removes some entries from NOTICE files which are no longer included. ## Verifying this change This change is a trivial rework / code clea

[GitHub] [flink] flinkbot commented on pull request #17046: [FLINK-24049][python] Handle properly for field types need conversion in TupleTypeInfo

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

[GitHub] [flink] wuchong commented on pull request #16949: [FLINK-23242][docs-zh] Translate the page of "Handling Application Parameters" into Chinese

wuchong commented on pull request #16949: URL: https://github.com/apache/flink/pull/16949#issuecomment-908073082 @PatrickRen , do you have other concerns about this PR? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use

[jira] [Updated] (FLINK-24049) TupleTypeInfo doesn't handle correctly for data types need conversion

[ https://issues.apache.org/jira/browse/FLINK-24049?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-24049: --- Labels: pull-request-available (was: ) > TupleTypeInfo doesn't handle correctly for data ty

[jira] [Closed] (FLINK-24026) Fix FLIP-XXX link can't be recognized correctly by IDEA

[ https://issues.apache.org/jira/browse/FLINK-24026?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-24026. --- Fix Version/s: 1.15.0 1.14.0 Resolution: Fixed Fixed in - master: 6f86a02207e984

[GitHub] [flink] dianfu opened a new pull request #17046: [FLINK-24049][python] Handle properly for field types need conversion in TupleTypeInfo

dianfu opened a new pull request #17046: URL: https://github.com/apache/flink/pull/17046 ## What is the purpose of the change *This pull request fixes TupleTypeInfo to handle properly for field types need conversion.* ## Verifying this change This change updated

[GitHub] [flink] flinkbot edited a comment on pull request #17010: [FLINK-24003][python] Fix lookback mode doesn't work when mixing use of Python Table API and Python DataStream API

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

[GitHub] [flink] flinkbot edited a comment on pull request #16997: [FLINK-23287][docs][table] Create user document for Window Join in SQL

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

[GitHub] [flink] flinkbot edited a comment on pull request #16983: [FLINK-23750][docs][table] Add documentation for Window Top-N after Windowing TVF.

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

[GitHub] [flink] wuchong merged pull request #17021: [FLINK-24026][misc] Fix FLIP-XXX link can't be recognized correctly by IDEA

wuchong merged pull request #17021: URL: https://github.com/apache/flink/pull/17021 -- 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: issues-unsubsc

[GitHub] [flink] twalthr commented on a change in pull request #16980: [FLINK-23111][runtime-web] Fix monaco editor async setup

twalthr commented on a change in pull request #16980: URL: https://github.com/apache/flink/pull/16980#discussion_r698223738 ## File path: flink-runtime-web/web-dashboard/src/app/share/common/monaco-editor/monaco-editor.component.ts ## @@ -74,7 +74,7 @@ export class MonacoEdito

[GitHub] [flink] dmvk commented on a change in pull request #17000: [FLINK-23946][clients] Application mode should shutdown gracefully on…

dmvk commented on a change in pull request #17000: URL: https://github.com/apache/flink/pull/17000#discussion_r698223817 ## File path: flink-clients/src/main/java/org/apache/flink/client/deployment/application/ApplicationDispatcherBootstrap.java ## @@ -147,35 +146,34 @@ public

[jira] [Created] (FLINK-24049) TupleTypeInfo doesn't handle correctly for data types need conversion

Dian Fu created FLINK-24049: --- Summary: TupleTypeInfo doesn't handle correctly for data types need conversion Key: FLINK-24049 URL: https://issues.apache.org/jira/browse/FLINK-24049 Project: Flink

[jira] [Closed] (FLINK-23917) Project metadata columns to apply to sources which do not implement projection pushdown

[ https://issues.apache.org/jira/browse/FLINK-23917?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-23917. Fix Version/s: 1.15.0 1.14.0 Resolution: Fixed Fixed in master: 73230f70

[GitHub] [flink] twalthr closed pull request #16984: [FLINK-23917][table-planner] Project metadata before push-down even if projection push-down is not supported

twalthr closed pull request #16984: URL: https://github.com/apache/flink/pull/16984 -- 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: issues-unsubsc

[GitHub] [flink] RocMarshal commented on pull request #17023: [FLINK-24043][runtime] Reuse the code of 'check savepoint preconditions'.

RocMarshal commented on pull request #17023: URL: https://github.com/apache/flink/pull/17023#issuecomment-908068160 Hi, @gaoyunhaii Could you help me to review this PR ? Thank you. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to Gi

[GitHub] [flink] AHeise commented on a change in pull request #16966: [FLINK-23875][connectors/kafka] Snapshot reduceBuffer of ReducingUpse…

AHeise commented on a change in pull request #16966: URL: https://github.com/apache/flink/pull/16966#discussion_r698218675 ## File path: flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/CompoundReducingUpsertWriterState.java ##

[GitHub] [flink] dmvk commented on a change in pull request #17000: [FLINK-23946][clients] Application mode should shutdown gracefully on…

dmvk commented on a change in pull request #17000: URL: https://github.com/apache/flink/pull/17000#discussion_r698217809 ## File path: flink-tests/src/test/java/org/apache/flink/test/runtime/leaderelection/ZooKeeperLeaderElectionITCase.java ## @@ -121,38 +145,39 @@ public void

[jira] [Comment Edited] (FLINK-24005) Resource requirements declaration may be incorrect if JobMaster disconnects with a TaskManager with available slots in the SlotPool

[ https://issues.apache.org/jira/browse/FLINK-24005?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17406577#comment-17406577 ] Zhu Zhu edited comment on FLINK-24005 at 8/30/21, 6:20 AM: --- Th

[jira] [Commented] (FLINK-24005) Resource requirements declaration may be incorrect if JobMaster disconnects with a TaskManager with available slots in the SlotPool

[ https://issues.apache.org/jira/browse/FLINK-24005?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17406577#comment-17406577 ] Zhu Zhu commented on FLINK-24005: - Thanks for the explanation! [~trohrmann] [~chesnay] I

[GitHub] [flink] cshuo commented on pull request #16979: [FLINK-23962][table-planner] Fix updateKind trait propagating problem…

cshuo commented on pull request #16979: URL: https://github.com/apache/flink/pull/16979#issuecomment-908063197 the following improvement JIRA: https://issues.apache.org/jira/browse/FLINK-24048 -- This is an automated message from the Apache Git Service. To respond to the message, please

[jira] [Updated] (FLINK-24048) Move changeLog inference out of optimizing phase

[ https://issues.apache.org/jira/browse/FLINK-24048?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shuo Cheng updated FLINK-24048: --- Description: Currently, when there are multiple sinks in a sql job, the DAG is split into multiple

[jira] [Updated] (FLINK-24048) Move changeLog inference out of optimizing phase

[ https://issues.apache.org/jira/browse/FLINK-24048?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shuo Cheng updated FLINK-24048: --- Description: Currently, when there are multiple sinks in a sql job, the DAG is split into multiple

[jira] [Created] (FLINK-24048) Move changeLog inference out of optimizing phase

Shuo Cheng created FLINK-24048: -- Summary: Move changeLog inference out of optimizing phase Key: FLINK-24048 URL: https://issues.apache.org/jira/browse/FLINK-24048 Project: Flink Issue Type: Impr

[GitHub] [flink] flinkbot edited a comment on pull request #17030: [FLINK-24035][network] Notify the buffer listeners when the local buffer pool receives available notification from the global pool

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

[jira] [Resolved] (FLINK-23796) UnalignedCheckpointRescaleITCase JVM crash on Azure

[ https://issues.apache.org/jira/browse/FLINK-23796?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise resolved FLINK-23796. - Resolution: Fixed > UnalignedCheckpointRescaleITCase JVM crash on Azure > --

[jira] [Commented] (FLINK-23913) UnalignedCheckpointITCase fails with exit code 137 (kernel oom) on Azure VMs

[ https://issues.apache.org/jira/browse/FLINK-23913?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17406575#comment-17406575 ] Arvid Heise commented on FLINK-23913: - Note that this failure predates the fix in FL

[jira] [Resolved] (FLINK-23913) UnalignedCheckpointITCase fails with exit code 137 (kernel oom) on Azure VMs

[ https://issues.apache.org/jira/browse/FLINK-23913?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise resolved FLINK-23913. - Resolution: Fixed > UnalignedCheckpointITCase fails with exit code 137 (kernel oom) on Azure VMs

[jira] [Commented] (FLINK-23796) UnalignedCheckpointRescaleITCase JVM crash on Azure

[ https://issues.apache.org/jira/browse/FLINK-23796?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17406573#comment-17406573 ] Arvid Heise commented on FLINK-23796: - Note that this failure predates the fix in FL

[GitHub] [flink] flinkbot edited a comment on pull request #17023: [FLINK-24043][runtime] Reuse the code of 'check savepoint preconditions'.

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

[jira] [Commented] (FLINK-24044) Errors are output when compiling flink-runtime-web

[ https://issues.apache.org/jira/browse/FLINK-24044?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17406571#comment-17406571 ] Ingo Bürk commented on FLINK-24044: --- The logs themselves are completely fine, this is

[jira] [Assigned] (FLINK-23113) Linting for Flink UI

[ https://issues.apache.org/jira/browse/FLINK-23113?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ingo Bürk reassigned FLINK-23113: - Assignee: Ingo Bürk (was: Junhan Yang) > Linting for Flink UI > > >

[jira] [Assigned] (FLINK-23113) Linting for Flink UI

[ https://issues.apache.org/jira/browse/FLINK-23113?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ingo Bürk reassigned FLINK-23113: - Assignee: Junhan Yang (was: Ingo Bürk) > Linting for Flink UI > > >

[jira] [Assigned] (FLINK-23113) Linting for Flink UI

[ https://issues.apache.org/jira/browse/FLINK-23113?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ingo Bürk reassigned FLINK-23113: - Assignee: Junhan Yang > Linting for Flink UI > > > Key: FL

[GitHub] [flink] flinkbot edited a comment on pull request #17043: [FLINK-23976] [Runtime / Metrics] Add additional availability timing metrics to Job lifecycle events

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

[GitHub] [flink] flinkbot edited a comment on pull request #16963: [FLINK-23582][docs][table] Add documentation for session window tvf.

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

[GitHub] [flink] flinkbot edited a comment on pull request #17045: [FLINK-23924][python][examples] Add PyFlink examples

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

[GitHub] [flink] flinkbot edited a comment on pull request #17042: [FLINK-24042] Updated javadoc to indicate printToErr writes to standard error stream

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

[GitHub] [flink] flinkbot edited a comment on pull request #16963: [FLINK-23582][docs][table] Add documentation for session window tvf.

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

[jira] [Closed] (FLINK-23899) Translate the "Elastic Scaling" page into chinese

[ https://issues.apache.org/jira/browse/FLINK-23899?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-23899. --- Fix Version/s: 1.15.0 1.14.0 Resolution: Fixed Fixed in - master: 9e7773c57bf8ef9

[GitHub] [flink] wuchong merged pull request #16928: [FLINK-23899][docs-zh] Translate the "Elastic Scaling" page into Chinese

wuchong merged pull request #16928: URL: https://github.com/apache/flink/pull/16928 -- 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: issues-unsubsc

[GitHub] [flink] wuchong commented on pull request #16928: [FLINK-23899][docs-zh] Translate the "Elastic Scaling" page into Chinese

wuchong commented on pull request #16928: URL: https://github.com/apache/flink/pull/16928#issuecomment-908020889 Thanks for the work @predatorray , @link3280 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL ab

[GitHub] [flink] wuchong commented on a change in pull request #16928: [FLINK-23899][docs-zh] Translate the "Elastic Scaling" page into Chinese

wuchong commented on a change in pull request #16928: URL: https://github.com/apache/flink/pull/16928#discussion_r698166541 ## File path: docs/content.zh/docs/deployment/elastic_scaling.md ## @@ -23,134 +23,132 @@ specific language governing permissions and limitations under t

[jira] [Commented] (FLINK-13448) Support ARM architecture

[ https://issues.apache.org/jira/browse/FLINK-13448?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17406553#comment-17406553 ] Yu Li commented on FLINK-13448: --- Thanks for the feedback [~wangxiyuan], and thanks for ana

[GitHub] [flink] flinkbot commented on pull request #17045: [FLINK-23924][python][examples] Add PyFlink examples

flinkbot commented on pull request #17045: URL: https://github.com/apache/flink/pull/17045#issuecomment-908007478 ## CI report: * 77e0e48a0f9c3f2f62e6e19ca5f4253060c13b07 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot edited a comment on pull request #17044: [FLINK-24010][connector/common] HybridSourceReader/Enumerator delegate checkpoint notifications

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

[GitHub] [flink] flinkbot edited a comment on pull request #17038: [FLINK-24024][table-planner] Fix syntax mistake in session Window TVF

flinkbot edited a comment on pull request #17038: URL: https://github.com/apache/flink/pull/17038#issuecomment-907732897 ## CI report: * c6982f9e3518e2908a4c206d0aad363d22fab2d7 UNKNOWN * 39dc4d3785190b252f4b9deae7885b9d87acad42 Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #17019: [FLINK-23854][connectors/Kafka] Ensure lingering Kafka transactions are aborted reliably.

flinkbot edited a comment on pull request #17019: URL: https://github.com/apache/flink/pull/17019#issuecomment-907120059 ## CI report: * fa25b27d642ab7e6af356ca1e9738a006d48 UNKNOWN * 6120b584b4b4ee9286f4998065f122c9a7de Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] beyond1920 commented on pull request #16963: [FLINK-23582][docs][table] Add documentation for session window tvf.

beyond1920 commented on pull request #16963: URL: https://github.com/apache/flink/pull/16963#issuecomment-908005906 @wuchong Jark, I've updated the pr to add an example to show a partitioned session window and rebase, please have a look again. -- This is an automated message from the Apa

[GitHub] [flink] beyond1920 commented on a change in pull request #16963: [FLINK-23582][docs][table] Add documentation for session window tvf.

beyond1920 commented on a change in pull request #16963: URL: https://github.com/apache/flink/pull/16963#discussion_r698156109 ## File path: docs/content/docs/dev/table/sql/queries/window-tvf.md ## @@ -282,4 +282,64 @@ Here is an example invocation on the Bid table: +-

[jira] [Commented] (FLINK-24043) Reuse the code of 'check savepoint preconditions'.

[ https://issues.apache.org/jira/browse/FLINK-24043?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17406549#comment-17406549 ] Jark Wu commented on FLINK-24043: - Maybe someone from runtime component could help to re

[jira] [Commented] (FLINK-23828) KafkaSourceITCase.testIdleReader fails on azure

[ https://issues.apache.org/jira/browse/FLINK-23828?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17406548#comment-17406548 ] Xintong Song commented on FLINK-23828: -- https://dev.azure.com/apache-flink/apache-f

[jira] [Created] (FLINK-24047) SavepointITCase.testStopWithSavepointWithDrainCallsFinishBeforeSnapshotState fails due to 'Service temporarily unavailable due to an ongoing leader election.'

Xintong Song created FLINK-24047: Summary: SavepointITCase.testStopWithSavepointWithDrainCallsFinishBeforeSnapshotState fails due to 'Service temporarily unavailable due to an ongoing leader election.' Key: FLINK-24047

[jira] [Commented] (FLINK-22885) Support 'SHOW COLUMNS'.

[ https://issues.apache.org/jira/browse/FLINK-22885?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17406547#comment-17406547 ] Roc Marshal commented on FLINK-22885: - Could someone help me to review this PR ? :)

[jira] [Commented] (FLINK-24043) Reuse the code of 'check savepoint preconditions'.

[ https://issues.apache.org/jira/browse/FLINK-24043?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17406546#comment-17406546 ] Roc Marshal commented on FLINK-24043: - [~jark] [~dianfu]  Could you help me to revie

[jira] [Commented] (FLINK-23954) Queryable state (rocksdb) with TM restart end-to-end test fails on azure

[ https://issues.apache.org/jira/browse/FLINK-23954?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17406543#comment-17406543 ] Xintong Song commented on FLINK-23954: -- https://dev.azure.com/apache-flink/apache-f

[GitHub] [flink] Myasuka commented on a change in pull request #16964: [FLINK-23791] Enable RocksDB info log by default

Myasuka commented on a change in pull request #16964: URL: https://github.com/apache/flink/pull/16964#discussion_r698151241 ## File path: flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/PredefinedOptions.java ## @@ -61,7 +

[GitHub] [flink] Myasuka commented on a change in pull request #16964: [FLINK-23791] Enable RocksDB info log by default

Myasuka commented on a change in pull request #16964: URL: https://github.com/apache/flink/pull/16964#discussion_r698151241 ## File path: flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/PredefinedOptions.java ## @@ -61,7 +

[jira] [Commented] (FLINK-22889) JdbcExactlyOnceSinkE2eTest.testInsert hangs on azure

[ https://issues.apache.org/jira/browse/FLINK-22889?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17406541#comment-17406541 ] Xintong Song commented on FLINK-22889: -- https://dev.azure.com/apache-flink/apache-f

[jira] [Created] (FLINK-24046) Refactor the relationship bwtween PredefinedOptions and RocksDBConfigurableOptions

Yun Tang created FLINK-24046: Summary: Refactor the relationship bwtween PredefinedOptions and RocksDBConfigurableOptions Key: FLINK-24046 URL: https://issues.apache.org/jira/browse/FLINK-24046 Project: F

[jira] [Commented] (FLINK-23944) PulsarSourceITCase.testTaskManagerFailure is instable

[ https://issues.apache.org/jira/browse/FLINK-23944?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17406540#comment-17406540 ] Xintong Song commented on FLINK-23944: -- https://dev.azure.com/apache-flink/apache-f

[jira] [Commented] (FLINK-23971) PulsarSourceITCase.testIdleReader failed on azure

[ https://issues.apache.org/jira/browse/FLINK-23971?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17406539#comment-17406539 ] Xintong Song commented on FLINK-23971: -- [~ruanhang1993], Thanks for looking into th

[jira] [Commented] (FLINK-23971) PulsarSourceITCase.testIdleReader failed on azure

[ https://issues.apache.org/jira/browse/FLINK-23971?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17406538#comment-17406538 ] Xintong Song commented on FLINK-23971: -- https://dev.azure.com/apache-flink/apache-f

[jira] [Commented] (FLINK-23493) python tests hang on Azure

[ https://issues.apache.org/jira/browse/FLINK-23493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17406536#comment-17406536 ] Xintong Song commented on FLINK-23493: -- https://dev.azure.com/apache-flink/apache-f

[jira] [Commented] (FLINK-23983) JVM crash when running RocksDBStateBackend tests

[ https://issues.apache.org/jira/browse/FLINK-23983?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17406535#comment-17406535 ] Xintong Song commented on FLINK-23983: -- https://dev.azure.com/apache-flink/apache-f

[jira] [Updated] (FLINK-23944) PulsarSourceITCase.testTaskManagerFailure is instable

[ https://issues.apache.org/jira/browse/FLINK-23944?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-23944: - Priority: Blocker (was: Critical) > PulsarSourceITCase.testTaskManagerFailure is instable > ---

[jira] [Commented] (FLINK-23944) PulsarSourceITCase.testTaskManagerFailure is instable

[ https://issues.apache.org/jira/browse/FLINK-23944?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17406534#comment-17406534 ] Xintong Song commented on FLINK-23944: -- https://dev.azure.com/apache-flink/apache-f

[jira] [Updated] (FLINK-23960) StreamTaskTimerTest.checkScheduledTimestamps fails on azure

[ https://issues.apache.org/jira/browse/FLINK-23960?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-23960: - Priority: Critical (was: Major) > StreamTaskTimerTest.checkScheduledTimestamps fails on azure >

[GitHub] [flink] flinkbot commented on pull request #17045: [FLINK-23924][python][examples] Add PyFlink examples

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

[jira] [Updated] (FLINK-23960) StreamTaskTimerTest.checkScheduledTimestamps fails on azure

[ https://issues.apache.org/jira/browse/FLINK-23960?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-23960: - Affects Version/s: 1.15.0 > StreamTaskTimerTest.checkScheduledTimestamps fails on azure > --

[jira] [Commented] (FLINK-23960) StreamTaskTimerTest.checkScheduledTimestamps fails on azure

[ https://issues.apache.org/jira/browse/FLINK-23960?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17406533#comment-17406533 ] Xintong Song commented on FLINK-23960: -- https://dev.azure.com/apache-flink/apache-f

[jira] [Updated] (FLINK-23960) StreamTaskTimerTest.checkScheduledTimestamps fails on azure

[ https://issues.apache.org/jira/browse/FLINK-23960?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-23960: - Fix Version/s: 1.15.0 > StreamTaskTimerTest.checkScheduledTimestamps fails on azure > --

[jira] [Created] (FLINK-24045) KafkaTableITCase.testPerPartitionWatermarkKafka fails on azure

Xintong Song created FLINK-24045: Summary: KafkaTableITCase.testPerPartitionWatermarkKafka fails on azure Key: FLINK-24045 URL: https://issues.apache.org/jira/browse/FLINK-24045 Project: Flink

[jira] [Updated] (FLINK-23924) Distribution is lacking Python Datastream examples

[ https://issues.apache.org/jira/browse/FLINK-23924?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-23924: --- Labels: pull-request-available (was: ) > Distribution is lacking Python Datastream examples

[GitHub] [flink] dianfu opened a new pull request #17045: [FLINK-23924][python][examples] Add PyFlink examples

dianfu opened a new pull request #17045: URL: https://github.com/apache/flink/pull/17045 ## What is the purpose of the change *This pull request adds a few PyFlink examples* ## Verifying this change This change is a trivial rework without any test coverage. ##

[GitHub] [flink] flinkbot commented on pull request #17044: [FLINK-24010][connector/common] HybridSourceReader/Enumerator delegate checkpoint notifications

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

[GitHub] [flink] flinkbot edited a comment on pull request #17010: [FLINK-24003][python] Fix lookback mode doesn't work when mixing use of Python Table API and Python DataStream API

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

[GitHub] [flink] flinkbot edited a comment on pull request #16997: [FLINK-23287][docs][table] Create user document for Window Join in SQL

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

[GitHub] [flink] flinkbot edited a comment on pull request #16983: [FLINK-23750][docs][table] Add documentation for Window Top-N after Windowing TVF.

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

[jira] [Updated] (FLINK-23791) Enable RocksDB log again

[ https://issues.apache.org/jira/browse/FLINK-23791?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-23791: - Fix Version/s: (was: 1.14.0) 1.14.1 > Enable RocksDB log again >

[jira] [Commented] (FLINK-23954) Queryable state (rocksdb) with TM restart end-to-end test fails on azure

[ https://issues.apache.org/jira/browse/FLINK-23954?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17406530#comment-17406530 ] Xintong Song commented on FLINK-23954: -- https://dev.azure.com/apache-flink/apache-f

[jira] [Commented] (FLINK-23721) Flink SQL state TTL has no effect when using non-incremental RocksDBStateBackend

[ https://issues.apache.org/jira/browse/FLINK-23721?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17406527#comment-17406527 ] Yun Tang commented on FLINK-23721: -- [~lmagics] could you share the code example to repr

[jira] [Commented] (FLINK-23796) UnalignedCheckpointRescaleITCase JVM crash on Azure

[ https://issues.apache.org/jira/browse/FLINK-23796?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17406526#comment-17406526 ] Xintong Song commented on FLINK-23796: -- https://dev.azure.com/apache-flink/apache-f

[jira] [Updated] (FLINK-23983) JVM crash when running RocksDBStateBackend tests

[ https://issues.apache.org/jira/browse/FLINK-23983?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-23983: - Summary: JVM crash when running RocksDBStateBackend tests (was: JVM crash when running RocksDBStateBack

[jira] [Commented] (FLINK-23983) JVM crash when running RocksDBStateBackendConfigTest

[ https://issues.apache.org/jira/browse/FLINK-23983?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17406525#comment-17406525 ] Xintong Song commented on FLINK-23983: -- https://dev.azure.com/apache-flink/apache-f

[jira] [Commented] (FLINK-22198) KafkaTableITCase hang.

[ https://issues.apache.org/jira/browse/FLINK-22198?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17406524#comment-17406524 ] Xintong Song commented on FLINK-22198: -- https://dev.azure.com/apache-flink/apache-f

[GitHub] [flink] flinkbot commented on pull request #17044: [FLINK-24010][connector/common] HybridSourceReader/Enumerator delegate checkpoint notifications

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

[jira] [Commented] (FLINK-24010) HybridSourceReader needs to forward checkpoint notifications

[ https://issues.apache.org/jira/browse/FLINK-24010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17406521#comment-17406521 ] Xintong Song commented on FLINK-24010: -- [~thw] FYI, the new branch `release-1.14` h

[GitHub] [flink] tweise opened a new pull request #17044: [FLINK-24010][connector/common] HybridSourceReader/Enumerator delegate checkpoint notifications

tweise opened a new pull request #17044: URL: https://github.com/apache/flink/pull/17044 cherry pick https://github.com/apache/flink/pull/17006 -- 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 th

[jira] [Created] (FLINK-24044) Errors are output when compiling flink-runtime-web

Zhilong Hong created FLINK-24044: Summary: Errors are output when compiling flink-runtime-web Key: FLINK-24044 URL: https://issues.apache.org/jira/browse/FLINK-24044 Project: Flink Issue Type

[jira] [Commented] (FLINK-23055) Add document for Window TVF offset

[ https://issues.apache.org/jira/browse/FLINK-23055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17406520#comment-17406520 ] Jark Wu commented on FLINK-23055: - [~xtsong], yes, I just found that. > Add document f

[jira] [Updated] (FLINK-23055) Add document for Window TVF offset

[ https://issues.apache.org/jira/browse/FLINK-23055?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-23055: Fix Version/s: 1.15.0 > Add document for Window TVF offset > -- > >

[jira] [Comment Edited] (FLINK-23055) Add document for Window TVF offset

[ https://issues.apache.org/jira/browse/FLINK-23055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17406515#comment-17406515 ] Jark Wu edited comment on FLINK-23055 at 8/30/21, 3:21 AM: --- Fi

[jira] [Commented] (FLINK-23055) Add document for Window TVF offset

[ https://issues.apache.org/jira/browse/FLINK-23055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17406519#comment-17406519 ] Xintong Song commented on FLINK-23055: -- [~jark], The branch `release-1.14` has been

  1   2   3   >