[GitHub] [flink] flinkbot edited a comment on pull request #17344: [FLINK-20895] [flink-table-planner] support local aggregate push down in table planner

flinkbot edited a comment on pull request #17344: URL: https://github.com/apache/flink/pull/17344#issuecomment-925952696 ## CI report: * 70104a7e1bb8b322a8044143de0eb700a761794c Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17344: [FLINK-20895] [flink-table-planner] support local aggregate push down in table planner

flinkbot edited a comment on pull request #17344: URL: https://github.com/apache/flink/pull/17344#issuecomment-925952696 ## CI report: * 70104a7e1bb8b322a8044143de0eb700a761794c Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14544: [FLINK-20845] Drop Scala 2.11 support

flinkbot edited a comment on pull request #14544: URL: https://github.com/apache/flink/pull/14544#issuecomment-753633967 ## CI report: * d03f03be594cbe205f649142c24d64cb99734479 Azure:

[jira] [Updated] (FLINK-23647) UnalignedCheckpointStressITCase crashed on azure

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

[jira] [Updated] (FLINK-20661) Elasticsearch6DynamicSinkITCase.testWritingDocuments test failed with ConnectException

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

[jira] [Updated] (FLINK-23425) The impact of cpu cores on test results for StreamingJobGraphGeneratorTest#testSlotSharingResourceConfigurationWithDefaultSlotSharingGroup

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

[jira] [Updated] (FLINK-23928) Test the buffer debloating

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

[GitHub] [flink] flinkbot edited a comment on pull request #17354: [FLINK-24200][streaming] Calculating maximum alignment time rather than using the constant value

flinkbot edited a comment on pull request #17354: URL: https://github.com/apache/flink/pull/17354#issuecomment-926820469 ## CI report: * 69a3d2f47018a277458a8798e02caa7e3abb5779 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14544: [FLINK-20845] Drop Scala 2.11 support

flinkbot edited a comment on pull request #14544: URL: https://github.com/apache/flink/pull/14544#issuecomment-753633967 ## CI report: * b1fe24bab5f3a3588e594ed41932c41cc87bd069 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17353: [FLINK-24373][docs] Remove BETA Tag from FLIP-27 Source Docs

flinkbot edited a comment on pull request #17353: URL: https://github.com/apache/flink/pull/17353#issuecomment-926797798 ## CI report: * 77814421493a2f8ec6d06a55ec74823b574694b6 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14544: [FLINK-20845] Drop Scala 2.11 support

flinkbot edited a comment on pull request #14544: URL: https://github.com/apache/flink/pull/14544#issuecomment-753633967 ## CI report: * b1fe24bab5f3a3588e594ed41932c41cc87bd069 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17352: [FLINK-10230][table] Support 'SHOW CREATE VIEW' syntax to print the query of a view

flinkbot edited a comment on pull request #17352: URL: https://github.com/apache/flink/pull/17352#issuecomment-926627700 ## CI report: * 471fd7fb6373ea0f2ebfe19d5ee1f7e097bc25b8 Azure:

[GitHub] [flink] NickBurkard commented on pull request #14544: [FLINK-20845] Drop Scala 2.11 support

NickBurkard commented on pull request #14544: URL: https://github.com/apache/flink/pull/14544#issuecomment-926845102 @MartijnVisser yep it should be unblocked now! I rebased with `master`, will let the CI suite run again to verify changes are good. -- This is an automated message from

[GitHub] [flink] flinkbot edited a comment on pull request #17354: [FLINK-24200][streaming] Calculating maximum alignment time rather than using the constant value

flinkbot edited a comment on pull request #17354: URL: https://github.com/apache/flink/pull/17354#issuecomment-926820469 ## CI report: * 69a3d2f47018a277458a8798e02caa7e3abb5779 Azure:

[GitHub] [flink] flinkbot commented on pull request #17354: [FLINK-24200][streaming] Calculating maximum alignment time rather than using the constant value

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

[GitHub] [flink] flinkbot edited a comment on pull request #17353: [FLINK-24373][docs] Remove BETA Tag from FLIP-27 Source Docs

flinkbot edited a comment on pull request #17353: URL: https://github.com/apache/flink/pull/17353#issuecomment-926797798 ## CI report: * 77814421493a2f8ec6d06a55ec74823b574694b6 Azure:

[GitHub] [flink] flinkbot commented on pull request #17353: [FLINK-24373][docs] Remove BETA Tag from FLIP-27 Source Docs

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

[GitHub] [flink] flinkbot commented on pull request #17354: [FLINK-24200][streaming] Calculating maximum alignment time rather than using the constant value

flinkbot commented on pull request #17354: URL: https://github.com/apache/flink/pull/17354#issuecomment-926796300 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-24200) CheckpointBarrierTrackerTest.testTwoLastBarriersOneByOne fails on azure

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

[GitHub] [flink] akalash opened a new pull request #17354: [FLINK-24200][streaming] Calculating maximum alignment time rather than using the constant value

akalash opened a new pull request #17354: URL: https://github.com/apache/flink/pull/17354 …an using the constant value ## What is the purpose of the change *This PR fixes the test* ## Brief change log - *Calculating maximum alignment time rather

[GitHub] [flink] StephanEwen merged pull request #17348: [BP-1.14][hotfix][docs] Remove flink-connector-base as required dependency fro…

StephanEwen merged pull request #17348: URL: https://github.com/apache/flink/pull/17348 -- 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] StephanEwen merged pull request #17347: [hotfix][docs] Remove flink-connector-base as required dependency fro…

StephanEwen merged pull request #17347: URL: https://github.com/apache/flink/pull/17347 -- 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 #17353: [FLINK-24373][docs] Remove BETA Tag from FLIP-27 Source Docs

flinkbot commented on pull request #17353: URL: https://github.com/apache/flink/pull/17353#issuecomment-926783072 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 edited a comment on pull request #17352: [FLINK-10230][table] Support 'SHOW CREATE VIEW' syntax to print the query of a view

flinkbot edited a comment on pull request #17352: URL: https://github.com/apache/flink/pull/17352#issuecomment-926627700 ## CI report: * 3af1ce2d14d61482fd59c55cd5cc9451cb1545ed Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17351: [FLINK-24371][datastream] Call preCommit on SinkWriter although no committer is available

flinkbot edited a comment on pull request #17351: URL: https://github.com/apache/flink/pull/17351#issuecomment-926586520 ## CI report: * 1e785b4db987fa9006c04077a5f5eb2050a338ab Azure:

[jira] [Updated] (FLINK-24230) Buffer debloating microbenchmark for single gate

[ https://issues.apache.org/jira/browse/FLINK-24230?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-24230: --- Labels: pull-request-available (was: ) > Buffer debloating microbenchmark for single gate

[GitHub] [flink-benchmarks] dawidwys opened a new pull request #32: [FLINK-24230] Buffer debloating microbenchmark for single gate

dawidwys opened a new pull request #32: URL: https://github.com/apache/flink-benchmarks/pull/32 Added a test that first does an environment setup. 1. Submits a job 2. Waits for it being backpressured 3. Waits some extra time for buffer debloating to stabilize The above steps are

[GitHub] [flink] sjwiesman commented on pull request #17353: [FLINK-24373][docs] Remove BETA Tag from FLIP-27 Source Docs

sjwiesman commented on pull request #17353: URL: https://github.com/apache/flink/pull/17353#issuecomment-926773281 cc @fapaul @wuchong or @leonardBang I feel pretty confident I deleted the relevant section from the translated page but would either of you mind double checking 

[jira] [Updated] (FLINK-24373) Remove BETA Tag from FLIP-27 Source Docs

[ https://issues.apache.org/jira/browse/FLINK-24373?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-24373: --- Labels: pull-request-available (was: ) > Remove BETA Tag from FLIP-27 Source Docs >

[GitHub] [flink] sjwiesman opened a new pull request #17353: [FLINK-24373][docs] Remove BETA Tag from FLIP-27 Source Docs

sjwiesman opened a new pull request #17353: URL: https://github.com/apache/flink/pull/17353 ## What is the purpose of the change Remove BETA Tag from FLIP-27 Source Docs. We will backport this to 1.14 release branch. ## Does this pull request potentially affect one of the

[jira] [Comment Edited] (FLINK-16504) Add a AWS DynamoDB sink

[ https://issues.apache.org/jira/browse/FLINK-16504?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17419874#comment-17419874 ] Yuri Gusev edited comment on FLINK-16504 at 9/24/21, 4:24 PM: -- Hi

[jira] [Comment Edited] (FLINK-16504) Add a AWS DynamoDB sink

[ https://issues.apache.org/jira/browse/FLINK-16504?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17419874#comment-17419874 ] Yuri Gusev edited comment on FLINK-16504 at 9/24/21, 4:23 PM: -- Hi

[jira] [Commented] (FLINK-16504) Add a AWS DynamoDB sink

[ https://issues.apache.org/jira/browse/FLINK-16504?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17419874#comment-17419874 ] Yuri Gusev commented on FLINK-16504: Hi [~gzheng], We finished integration tests implementation,

[GitHub] [flink] flinkbot edited a comment on pull request #17352: [FLINK-10230][table] Support 'SHOW CREATE VIEW' syntax to print the query of a view

flinkbot edited a comment on pull request #17352: URL: https://github.com/apache/flink/pull/17352#issuecomment-926627700 ## CI report: * 3af1ce2d14d61482fd59c55cd5cc9451cb1545ed Azure:

[jira] [Created] (FLINK-24373) Remove BETA Tag from FLIP-27 Source Docs

Seth Wiesman created FLINK-24373: Summary: Remove BETA Tag from FLIP-27 Source Docs Key: FLINK-24373 URL: https://issues.apache.org/jira/browse/FLINK-24373 Project: Flink Issue Type:

[GitHub] [flink] flinkbot edited a comment on pull request #17352: [FLINK-10230][table] Support 'SHOW CREATE VIEW' syntax to print the query of a view

flinkbot edited a comment on pull request #17352: URL: https://github.com/apache/flink/pull/17352#issuecomment-926627700 ## CI report: * 3af1ce2d14d61482fd59c55cd5cc9451cb1545ed Azure:

[GitHub] [flink] RocMarshal commented on a change in pull request #17352: [FLINK-10230][table] Support 'SHOW CREATE VIEW' syntax to print the query of a view

RocMarshal commented on a change in pull request #17352: URL: https://github.com/apache/flink/pull/17352#discussion_r715700515 ## File path: flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/internal/TableEnvironmentImpl.java ## @@ -1176,6 +1178,31 @@

[GitHub] [flink] RocMarshal commented on a change in pull request #17352: [FLINK-10230][table] Support 'SHOW CREATE VIEW' syntax to print the query of a view

RocMarshal commented on a change in pull request #17352: URL: https://github.com/apache/flink/pull/17352#discussion_r715696263 ## File path: flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/catalog/CatalogViewITCase.scala ## @@ -18,24 +18,24 @@

[GitHub] [flink] sjwiesman commented on a change in pull request #17349: [FLINK-24370][documentation] Added documentation for Asynchronous Sin…

sjwiesman commented on a change in pull request #17349: URL: https://github.com/apache/flink/pull/17349#discussion_r715670611 ## File path: docs/content/docs/connectors/datastream/async_base.md ## @@ -0,0 +1,135 @@ +--- +title: Async Base +weight: 5 +type: docs +aliases: + -

[GitHub] [flink] flinkbot edited a comment on pull request #17245: [FLINK-23316][Table SQL/Ecosystem] Add tests for custom PartitionCommitPolicy

flinkbot edited a comment on pull request #17245: URL: https://github.com/apache/flink/pull/17245#issuecomment-917600794 ## CI report: * a0309bd0dc7b478d7f761ee5cbbc4d214e576c2a Azure:

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

RocMarshal edited a comment on pull request #16962: URL: https://github.com/apache/flink/pull/16962#issuecomment-925446816 Hi, @MartijnVisser @Airblader @wuchong @twalthr , I made some changes based on your suggestions. Could you help me to review it ? Thank you so much for your

[GitHub] [flink] flinkbot edited a comment on pull request #17352: [FLINK-10230][table] Support 'SHOW CREATE VIEW' syntax to print the query of a view

flinkbot edited a comment on pull request #17352: URL: https://github.com/apache/flink/pull/17352#issuecomment-926627700 ## CI report: * 3af1ce2d14d61482fd59c55cd5cc9451cb1545ed Azure:

[GitHub] [flink] Airblader commented on a change in pull request #17350: [FLINK-24359][table-runtime] Use ResolvedSchema in AbstractFileSystemTable

Airblader commented on a change in pull request #17350: URL: https://github.com/apache/flink/pull/17350#discussion_r715632847 ## File path: flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/filesystem/AbstractFileSystemTable.java ## @@ -49,7 +54,11 @@

[jira] [Created] (FLINK-24372) Deprecate Elasticsearch Sinkfunctions

Fabian Paul created FLINK-24372: --- Summary: Deprecate Elasticsearch Sinkfunctions Key: FLINK-24372 URL: https://issues.apache.org/jira/browse/FLINK-24372 Project: Flink Issue Type: Sub-task

[GitHub] [flink] Airblader commented on a change in pull request #17352: [FLINK-10230][table] Support 'SHOW CREATE VIEW' syntax to print the query of a view

Airblader commented on a change in pull request #17352: URL: https://github.com/apache/flink/pull/17352#discussion_r715618204 ## File path: flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/internal/TableEnvironmentImpl.java ## @@ -1441,6 +1468,59 @@

[GitHub] [flink] flinkbot commented on pull request #17352: [FLINK-10230][table] Support 'SHOW CREATE VIEW' syntax to print the query of a view

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

[GitHub] [flink] flinkbot edited a comment on pull request #17350: [FLINK-24359][table-runtime] Use ResolvedSchema in AbstractFileSystemTable

flinkbot edited a comment on pull request #17350: URL: https://github.com/apache/flink/pull/17350#issuecomment-926550692 ## CI report: * 98fac3d3a2b3e3c79cbea8625625faee50b16de8 Azure:

[GitHub] [flink-ml] lindong28 commented on pull request #4: [FLINK-22915][FLIP-173] Update Flink ML API to support AlgoOperator with multiple input tables and multiple output tables

lindong28 commented on pull request #4: URL: https://github.com/apache/flink-ml/pull/4#issuecomment-926624833 @becketqin After looking into the package path issue, I think the CI is actually working correctly. Here is what I find: 1) I have tried `mvn package` with that

[jira] [Assigned] (FLINK-24200) CheckpointBarrierTrackerTest.testTwoLastBarriersOneByOne fails on azure

[ https://issues.apache.org/jira/browse/FLINK-24200?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Kalashnikov reassigned FLINK-24200: - Assignee: Anton Kalashnikov >

[GitHub] [flink-ml] lindong28 commented on pull request #4: [FLINK-22915][FLIP-173] Update Flink ML API to support AlgoOperator with multiple input tables and multiple output tables

lindong28 commented on pull request #4: URL: https://github.com/apache/flink-ml/pull/4#issuecomment-926613101 Thanks for the review @becketqin. I did `git clean -dfx && mvn package` locally on my local machine after fixing the package path. It works well without reporting any

[jira] [Commented] (FLINK-21582) COALESCE not works when cast a variable return null

[ https://issues.apache.org/jira/browse/FLINK-21582?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17419760#comment-17419760 ] Francesco Guardiani commented on FLINK-21582: - I tried the query in the issue description

[GitHub] [flink] flinkbot edited a comment on pull request #17351: [FLINK-24371][datastream] Call preCommit on SinkWriter although no committer is available

flinkbot edited a comment on pull request #17351: URL: https://github.com/apache/flink/pull/17351#issuecomment-926586520 ## CI report: * 1e785b4db987fa9006c04077a5f5eb2050a338ab Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17341: [hotfix][test] Refactor BuiltInFunctions IT Tests

flinkbot edited a comment on pull request #17341: URL: https://github.com/apache/flink/pull/17341#issuecomment-925901262 ## CI report: * f2c827b884fa646bae5f08c3d26a613a58a4ba3b UNKNOWN * 8e3d7edefa906fcb3950227aea7bfd0b8902aca7 Azure:

[GitHub] [flink-ml] lindong28 commented on a change in pull request #4: [FLINK-22915][FLIP-173] Update Flink ML API to support AlgoOperator with multiple input tables and multiple output tables

lindong28 commented on a change in pull request #4: URL: https://github.com/apache/flink-ml/pull/4#discussion_r715594298 ## File path: flink-ml-api/src/main/java/org/apache/flink/ml/api/core/PipelineModel.java ## @@ -0,0 +1,86 @@ +/* + * Licensed to the Apache Software

[GitHub] [flink] flinkbot edited a comment on pull request #16606: [FLINK-21357][runtime/statebackend]Periodic materialization for generalized incremental checkpoints

flinkbot edited a comment on pull request #16606: URL: https://github.com/apache/flink/pull/16606#issuecomment-887431748 ## CI report: * 264be5cc6a0485171413099e8b64b9e917d06e85 UNKNOWN * 1b7da8565a2ab9560f1aad65007930c91945087f UNKNOWN *

[GitHub] [flink-ml] lindong28 commented on a change in pull request #4: [FLINK-22915][FLIP-173] Update Flink ML API to support AlgoOperator with multiple input tables and multiple output tables

lindong28 commented on a change in pull request #4: URL: https://github.com/apache/flink-ml/pull/4#discussion_r715594171 ## File path: flink-ml-api/src/main/java/org/apache/flink/ml/api/core/PipelineModel.java ## @@ -0,0 +1,86 @@ +/* + * Licensed to the Apache Software

[GitHub] [flink-ml] lindong28 commented on a change in pull request #4: [FLINK-22915][FLIP-173] Update Flink ML API to support AlgoOperator with multiple input tables and multiple output tables

lindong28 commented on a change in pull request #4: URL: https://github.com/apache/flink-ml/pull/4#discussion_r715593065 ## File path: flink-ml-api/src/main/java/org/apache/flink/ml/api/core/Pipeline.java ## @@ -19,241 +19,101 @@ package org.apache.flink.ml.api.core;

[GitHub] [flink-ml] lindong28 commented on a change in pull request #4: [FLINK-22915][FLIP-173] Update Flink ML API to support AlgoOperator with multiple input tables and multiple output tables

lindong28 commented on a change in pull request #4: URL: https://github.com/apache/flink-ml/pull/4#discussion_r715591990 ## File path: flink-ml-api/src/main/java/org/apache/flink/ml/api/core/Pipeline.java ## @@ -19,241 +19,101 @@ package org.apache.flink.ml.api.core;

[GitHub] [flink] flinkbot commented on pull request #17352: [FLINK-10230][table] Support 'SHOW CREATE VIEW' syntax to print the query of a view

flinkbot commented on pull request #17352: URL: https://github.com/apache/flink/pull/17352#issuecomment-926602676 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] RocMarshal opened a new pull request #17352: [FLINK-10230][table] Support 'SHOW CREATE VIEW' syntax to print the query of a view

RocMarshal opened a new pull request #17352: URL: https://github.com/apache/flink/pull/17352 ## What is the purpose of the change *Support 'SHOW CREATE VIEW' syntax to print the query of a view* ## Brief change log *Support 'SHOW CREATE VIEW' syntax to print

[GitHub] [flink] flinkbot commented on pull request #17351: [FLINK-24371][datastream] Call preCommit on SinkWriter although no committer is available

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

[GitHub] [flink] flinkbot edited a comment on pull request #17349: [FLINK-24370][documentation] Added documentation for Asynchronous Sin…

flinkbot edited a comment on pull request #17349: URL: https://github.com/apache/flink/pull/17349#issuecomment-926517209 ## CI report: * fb869b349b7a692bc81b4d6dc6598369750655de Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16606: [FLINK-21357][runtime/statebackend]Periodic materialization for generalized incremental checkpoints

flinkbot edited a comment on pull request #16606: URL: https://github.com/apache/flink/pull/16606#issuecomment-887431748 ## CI report: * 264be5cc6a0485171413099e8b64b9e917d06e85 UNKNOWN * 1b7da8565a2ab9560f1aad65007930c91945087f UNKNOWN *

[jira] [Updated] (FLINK-24371) Support SinkWriter preCommit without the need of a committer

[ https://issues.apache.org/jira/browse/FLINK-24371?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-24371: --- Labels: pull-request-available (was: ) > Support SinkWriter preCommit without the need of

[GitHub] [flink] flinkbot commented on pull request #17351: [FLINK-24371][datastream] Call preCommit on SinkWriter although no committer is available

flinkbot commented on pull request #17351: URL: https://github.com/apache/flink/pull/17351#issuecomment-926571614 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 edited a comment on pull request #17350: [FLINK-24359][table-runtime] Use ResolvedSchema in AbstractFileSystemTable

flinkbot edited a comment on pull request #17350: URL: https://github.com/apache/flink/pull/17350#issuecomment-926550692 ## CI report: * 98fac3d3a2b3e3c79cbea8625625faee50b16de8 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17344: [FLINK-20895] [flink-table-planner] support local aggregate push down in table planner

flinkbot edited a comment on pull request #17344: URL: https://github.com/apache/flink/pull/17344#issuecomment-925952696 ## CI report: * 70104a7e1bb8b322a8044143de0eb700a761794c Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17245: [FLINK-23316][Table SQL/Ecosystem] Add tests for custom PartitionCommitPolicy

flinkbot edited a comment on pull request #17245: URL: https://github.com/apache/flink/pull/17245#issuecomment-917600794 ## CI report: * bc2102f6f4ddb7084ea717e3745cd9a97dcf4469 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16606: [FLINK-21357][runtime/statebackend]Periodic materialization for generalized incremental checkpoints

flinkbot edited a comment on pull request #16606: URL: https://github.com/apache/flink/pull/16606#issuecomment-887431748 ## CI report: * 264be5cc6a0485171413099e8b64b9e917d06e85 UNKNOWN * 1b7da8565a2ab9560f1aad65007930c91945087f UNKNOWN *

[GitHub] [flink] fapaul opened a new pull request #17351: Flink 24371

fapaul opened a new pull request #17351: URL: https://github.com/apache/flink/pull/17351 ## What is the purpose of the change Before this change, if no committer was after the SinkWriter in the pipeline preCommit was never called. With this change, preCommit is now called

[jira] [Updated] (FLINK-22530) RuntimeException after subsequent windowed grouping in TableAPI

[ https://issues.apache.org/jira/browse/FLINK-22530?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Christopher Rost updated FLINK-22530: - Labels: (was: auto-deprioritized-major) > RuntimeException after subsequent windowed

[GitHub] [flink] flinkbot commented on pull request #17350: [FLINK-24359][table-runtime] Use ResolvedSchema in AbstractFileSystemTable

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

[GitHub] [flink] flinkbot edited a comment on pull request #17245: [FLINK-23316][Table SQL/Ecosystem] Add tests for custom PartitionCommitPolicy

flinkbot edited a comment on pull request #17245: URL: https://github.com/apache/flink/pull/17245#issuecomment-917600794 ## CI report: * bc2102f6f4ddb7084ea717e3745cd9a97dcf4469 Azure:

[jira] [Assigned] (FLINK-24359) Migrate FileSystem connector to ResolvedSchema

[ https://issues.apache.org/jira/browse/FLINK-24359?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser reassigned FLINK-24359: -- Assignee: Francesco Guardiani > Migrate FileSystem connector to ResolvedSchema >

[GitHub] [flink] flinkbot edited a comment on pull request #17348: [BP-1.14][hotfix][docs] Remove flink-connector-base as required dependency fro…

flinkbot edited a comment on pull request #17348: URL: https://github.com/apache/flink/pull/17348#issuecomment-926447846 ## CI report: * d0d5f2e050ed54a1f8d9eaeb209ce4bb16a5ec34 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17349: [FLINK-24370][documentation] Added documentation for Asynchronous Sin…

flinkbot edited a comment on pull request #17349: URL: https://github.com/apache/flink/pull/17349#issuecomment-926517209 ## CI report: * fb869b349b7a692bc81b4d6dc6598369750655de Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17347: [hotfix][docs] Remove flink-connector-base as required dependency fro…

flinkbot edited a comment on pull request #17347: URL: https://github.com/apache/flink/pull/17347#issuecomment-926447737 ## CI report: * d7ae1c1b86aaa3e6a1f515671a3611d94fe83be8 Azure:

[GitHub] [flink] flinkbot commented on pull request #17350: [FLINK-24359][table-runtime] Use ResolvedSchema in AbstractFileSystemTable

flinkbot commented on pull request #17350: URL: https://github.com/apache/flink/pull/17350#issuecomment-926536168 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] JackWangCS commented on a change in pull request #17245: [FLINK-23316][Table SQL/Ecosystem] Add tests for custom PartitionCommitPolicy

JackWangCS commented on a change in pull request #17245: URL: https://github.com/apache/flink/pull/17245#discussion_r715516784 ## File path: flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/connectors/hive/HiveTableSinkITCase.java ## @@ -441,6 +470,93 @@

[jira] [Updated] (FLINK-24359) Migrate FileSystem connector to ResolvedSchema

[ https://issues.apache.org/jira/browse/FLINK-24359?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-24359: --- Labels: pull-request-available (was: ) > Migrate FileSystem connector to ResolvedSchema >

[GitHub] [flink] slinkydeveloper opened a new pull request #17350: [FLINK-24359][table-runtime] Use ResolvedSchema in AbstractFileSystemTable

slinkydeveloper opened a new pull request #17350: URL: https://github.com/apache/flink/pull/17350 Signed-off-by: slinkydeveloper ## What is the purpose of the change Migrate `AbstractFileSystemTable` to use the new `ResolvedSchema` APIs ## Brief change log

[jira] [Commented] (FLINK-20895) Support LocalAggregatePushDown in Blink planner

[ https://issues.apache.org/jira/browse/FLINK-20895?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17419721#comment-17419721 ] Peng Yu commented on FLINK-20895: - Hi [~jark], the new pull request

[GitHub] [flink-ml] becketqin commented on a change in pull request #4: [FLINK-22915][FLIP-173] Update Flink ML API to support AlgoOperator with multiple input tables and multiple output tables

becketqin commented on a change in pull request #4: URL: https://github.com/apache/flink-ml/pull/4#discussion_r715477933 ## File path: flink-ml-api/src/main/java/org/apache/flink/ml/api/core/Pipeline.java ## @@ -19,241 +19,101 @@ package org.apache.flink.ml.api.core;

[jira] [Assigned] (FLINK-24371) Support SinkWriter preCommit without the need of a committer

[ https://issues.apache.org/jira/browse/FLINK-24371?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Paul reassigned FLINK-24371: --- Assignee: Fabian Paul > Support SinkWriter preCommit without the need of a committer >

[jira] [Created] (FLINK-24371) Support SinkWriter preCommit without the need of a committer

Fabian Paul created FLINK-24371: --- Summary: Support SinkWriter preCommit without the need of a committer Key: FLINK-24371 URL: https://issues.apache.org/jira/browse/FLINK-24371 Project: Flink

[jira] [Closed] (FLINK-10911) Enable flink-scala-shell with Scala 2.12

[ https://issues.apache.org/jira/browse/FLINK-10911?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-10911. Resolution: Won't Fix > Enable flink-scala-shell with Scala 2.12 >

[GitHub] [flink] flinkbot commented on pull request #17349: [FLINK-24370][documentation] Added documentation for Asynchronous Sin…

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

[GitHub] [flink] flinkbot edited a comment on pull request #17341: [hotfix][test] Refactor BuiltInFunctions IT Tests

flinkbot edited a comment on pull request #17341: URL: https://github.com/apache/flink/pull/17341#issuecomment-925901262 ## CI report: * f2c827b884fa646bae5f08c3d26a613a58a4ba3b UNKNOWN * 1b6da15897e67037eb0b065776e8d67014011090 Azure:

[GitHub] [flink] MartijnVisser commented on pull request #14544: [FLINK-20845] Drop Scala 2.11 support

MartijnVisser commented on pull request #14544: URL: https://github.com/apache/flink/pull/14544#issuecomment-926509165 @NickBurkard Thanks to your work for dropping the Scala Shell via https://github.com/apache/flink/pull/17340, does this now also unblock you to complete this PR? --

[GitHub] [flink] Airblader commented on a change in pull request #17332: [FLINK-24349]Support customized Calalogs via JDBC

Airblader commented on a change in pull request #17332: URL: https://github.com/apache/flink/pull/17332#discussion_r715486971 ## File path: flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/dialect/JdbcDialect.java ## @@ -142,4 +143,16 @@

[jira] [Closed] (FLINK-18285) solution for 'For input string: “0x100” ' make bash command 'reset' fail to work

[ https://issues.apache.org/jira/browse/FLINK-18285?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-18285. -- Resolution: Won't Fix Closed due to https://issues.apache.org/jira/browse/FLINK-24360 >

[jira] [Closed] (FLINK-12596) Unify all kinds of cluster via ClusterClient in FlinkShell

[ https://issues.apache.org/jira/browse/FLINK-12596?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-12596. -- Resolution: Won't Fix Closed due to https://issues.apache.org/jira/browse/FLINK-24360 >

[jira] [Closed] (FLINK-5744) Check remote connection in Flink-shell

[ https://issues.apache.org/jira/browse/FLINK-5744?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-5744. - Resolution: Won't Fix Closed due to https://issues.apache.org/jira/browse/FLINK-24360 > Check

[jira] [Commented] (FLINK-10911) Enable flink-scala-shell with Scala 2.12

[ https://issues.apache.org/jira/browse/FLINK-10911?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17419698#comment-17419698 ] Martijn Visser commented on FLINK-10911: Closed due to

[jira] [Closed] (FLINK-2709) line editing in scala shell

[ https://issues.apache.org/jira/browse/FLINK-2709?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-2709. - Resolution: Won't Fix Closed due to https://issues.apache.org/jira/browse/FLINK-24360 > line

[jira] [Closed] (FLINK-11204) flink start-scala-shell.sh do not work in security mode with kerberos authentication.

[ https://issues.apache.org/jira/browse/FLINK-11204?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-11204. -- Resolution: Won't Fix Closed due to https://issues.apache.org/jira/browse/FLINK-24360 >

[GitHub] [flink] flinkbot commented on pull request #17349: [FLINK-24370][documentation] Added documentation for Asynchronous Sin…

flinkbot commented on pull request #17349: URL: https://github.com/apache/flink/pull/17349#issuecomment-926501118 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 edited a comment on pull request #17341: [hotfix][test] Refactor BuiltInFunctions IT Tests

flinkbot edited a comment on pull request #17341: URL: https://github.com/apache/flink/pull/17341#issuecomment-925901262 ## CI report: * f2c827b884fa646bae5f08c3d26a613a58a4ba3b UNKNOWN * 1b6da15897e67037eb0b065776e8d67014011090 Azure:

[GitHub] [flink] cuibo01 commented on a change in pull request #17332: [FLINK-24349]Support customized Calalogs via JDBC

cuibo01 commented on a change in pull request #17332: URL: https://github.com/apache/flink/pull/17332#discussion_r715475502 ## File path: flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/dialect/JdbcDialect.java ## @@ -142,4 +143,16 @@

[GitHub] [flink] CrynetLogistics opened a new pull request #17349: [FLINK-24370][documentation] Added documentation for Asynchronous Sin…

CrynetLogistics opened a new pull request #17349: URL: https://github.com/apache/flink/pull/17349 ## What is the purpose of the change *User stories:* * As a Flink user, I’d like to have some documentation for implementing my sink based atop the Asynchronous Sink Base.

  1   2   >