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

2021-09-24 Thread GitBox
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 

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

2021-09-24 Thread GitBox
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] [Updated] (FLINK-24373) Remove BETA Tag from FLIP-27 Source Docs

2021-09-24 Thread ASF GitHub Bot (Jira)
[ 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] flinkbot edited a comment on pull request #17353: [FLINK-24373][docs] Remove BETA Tag from FLIP-27 Source Docs

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

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

2021-09-24 Thread GitBox
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] flinkbot edited a comment on pull request #17353: [FLINK-24373][docs] Remove BETA Tag from FLIP-27 Source Docs

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

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

2021-09-24 Thread Seth Wiesman (Jira)
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:

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

2021-09-24 Thread ASF GitHub Bot (Jira)
[ 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] flinkbot edited a comment on pull request #17351: [FLINK-24371][datastream] Call preCommit on SinkWriter although no committer is available

2021-09-24 Thread GitBox
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 #17352: [FLINK-10230][table] Support 'SHOW CREATE VIEW' syntax to print the query of a view

2021-09-24 Thread GitBox
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 commented on pull request #17354: [FLINK-24200][streaming] Calculating maximum alignment time rather than using the constant value

2021-09-24 Thread GitBox
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

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

2021-09-24 Thread GitBox
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 #14544: [FLINK-20845] Drop Scala 2.11 support

2021-09-24 Thread GitBox
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

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

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

2021-09-24 Thread GitBox
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] flinkbot commented on pull request #17353: [FLINK-24373][docs] Remove BETA Tag from FLIP-27 Source Docs

2021-09-24 Thread GitBox
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 edited a comment on pull request #17352: [FLINK-10230][table] Support 'SHOW CREATE VIEW' syntax to print the query of a view

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

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

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

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

2021-09-24 Thread Yuri Gusev (Jira)
[ 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

2021-09-24 Thread Yuri Gusev (Jira)
[ 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 commented on pull request #17353: [FLINK-24373][docs] Remove BETA Tag from FLIP-27 Source Docs

2021-09-24 Thread GitBox
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] StephanEwen merged pull request #17347: [hotfix][docs] Remove flink-connector-base as required dependency fro…

2021-09-24 Thread GitBox
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 edited a comment on pull request #17354: [FLINK-24200][streaming] Calculating maximum alignment time rather than using the constant value

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

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

2021-09-24 Thread Yuri Gusev (Jira)
[ 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

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

2021-09-24 Thread GitBox
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

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

2021-09-24 Thread ASF GitHub Bot (Jira)
[ 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] NickBurkard commented on pull request #14544: [FLINK-20845] Drop Scala 2.11 support

2021-09-24 Thread GitBox
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 #17352: [FLINK-10230][table] Support 'SHOW CREATE VIEW' syntax to print the query of a view

2021-09-24 Thread GitBox
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 #17344: [FLINK-20895] [flink-table-planner] support local aggregate push down in table planner

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

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

2021-09-24 Thread Flink Jira Bot (Jira)
[ 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

2021-09-24 Thread Flink Jira Bot (Jira)
[ 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

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

2021-09-24 Thread Flink Jira Bot (Jira)
[ 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-23647) UnalignedCheckpointStressITCase crashed on azure

2021-09-24 Thread Flink Jira Bot (Jira)
[ 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

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

2021-09-24 Thread GitBox
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

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

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

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

[GitHub] [flink] matriv commented on pull request #17341: [hotfix][test] Refactor BuiltInFunctions IT Tests

2021-09-24 Thread GitBox
matriv commented on pull request #17341: URL: https://github.com/apache/flink/pull/17341#issuecomment-926370810 @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] skyguard1 closed pull request #17169: [FLINK-24177][runtime/network] Add epoll available check exception

2021-09-24 Thread GitBox
skyguard1 closed pull request #17169: URL: https://github.com/apache/flink/pull/17169 -- 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:

[jira] [Updated] (FLINK-16908) FlinkKafkaProducerITCase testScaleUpAfterScalingDown Timeout expired while initializing transactional state in 60000ms.

2021-09-24 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16908?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-16908: - Affects Version/s: 1.13.2 > FlinkKafkaProducerITCase testScaleUpAfterScalingDown

[jira] [Commented] (FLINK-16908) FlinkKafkaProducerITCase testScaleUpAfterScalingDown Timeout expired while initializing transactional state in 60000ms.

2021-09-24 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16908?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17419600#comment-17419600 ] Dawid Wysakowicz commented on FLINK-16908: --

[GitHub] [flink] dawidwys closed pull request #17278: [FLINK-24280] Support manual checkpoints triggering from a MiniCluster

2021-09-24 Thread GitBox
dawidwys closed pull request #17278: URL: https://github.com/apache/flink/pull/17278 -- 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-web] xintongsong commented on a change in pull request #468: Release blog post 1.14 draft iteration

2021-09-24 Thread GitBox
xintongsong commented on a change in pull request #468: URL: https://github.com/apache/flink-web/pull/468#discussion_r715293758 ## File path: _posts/2021-09-21-release-1.14.0.md ## @@ -0,0 +1,274 @@ +--- +layout: post +title: "Apache Flink 1.14.0 Release Announcement" +date:

[jira] [Commented] (FLINK-24346) Flink on yarn application mode,LinkageError

2021-09-24 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-24346?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17419639#comment-17419639 ] 李伟高 commented on FLINK-24346: - :(,This may be a bug in application mode. The code I tested has been put on

[GitHub] [flink-web] xintongsong commented on a change in pull request #468: Release blog post 1.14 draft iteration

2021-09-24 Thread GitBox
xintongsong commented on a change in pull request #468: URL: https://github.com/apache/flink-web/pull/468#discussion_r715411477 ## File path: _posts/2021-09-21-release-1.14.0.md ## @@ -0,0 +1,274 @@ +--- +layout: post +title: "Apache Flink 1.14.0 Release Announcement" +date:

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

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

[jira] [Commented] (FLINK-24350) Resuming Savepoint (hashmap, sync, scale up) end-to-end test fails due to ask timeout

2021-09-24 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24350?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17419654#comment-17419654 ] Chesnay Schepler commented on FLINK-24350: -- The logs aren't really conclusive on the cause.

[jira] [Commented] (FLINK-23933) flink-json formats support a option to parse nested json as a String

2021-09-24 Thread Francesco Guardiani (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23933?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17419655#comment-17419655 ] Francesco Guardiani commented on FLINK-23933: - > Can't this issue also just be solved by

[GitHub] [flink] flinkbot edited a comment on pull request #17342: [FLINK-20928] Fix flaky test by retrying notifyCheckpointComplete until either commit success or timeout

2021-09-24 Thread GitBox
flinkbot edited a comment on pull request #17342: URL: https://github.com/apache/flink/pull/17342#issuecomment-925923633 ## CI report: * a6fc28471416a1371dc3ba5b83e1fcf59061ba7b Azure:

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

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

[jira] [Updated] (FLINK-24320) Show in the Job / Checkpoints / Configuration if checkpoints are incremental

2021-09-24 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24320?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-24320: --- Description: It would be nice if the Configuration page would also show if incremental

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

2021-09-24 Thread Christopher Rost (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22530?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17419619#comment-17419619 ] Christopher Rost commented on FLINK-22530: -- Hi [~twalthr] , we still have this issue. We tried

[jira] [Created] (FLINK-24367) Add a fallback AkkaRpcSystemLoader for tests in the IDE

2021-09-24 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-24367: Summary: Add a fallback AkkaRpcSystemLoader for tests in the IDE Key: FLINK-24367 URL: https://issues.apache.org/jira/browse/FLINK-24367 Project: Flink

[jira] [Created] (FLINK-24368) Collect logs of Flink container in e2e source test suite

2021-09-24 Thread Fabian Paul (Jira)
Fabian Paul created FLINK-24368: --- Summary: Collect logs of Flink container in e2e source test suite Key: FLINK-24368 URL: https://issues.apache.org/jira/browse/FLINK-24368 Project: Flink Issue

[GitHub] [flink] fapaul opened a new pull request #17347: [hotfix][docs] Remove flink-connector-base as required dependency fro…

2021-09-24 Thread GitBox
fapaul opened a new pull request #17347: URL: https://github.com/apache/flink/pull/17347 …m the kafka connector ## What is the purpose of the change `flink-connector-base` is not a required dependency of the kafka connector therefore therefore we do not have to

[jira] [Commented] (FLINK-24320) Show in the Job / Checkpoints / Configuration if checkpoints are incremental

2021-09-24 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24320?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17419607#comment-17419607 ] Robert Metzger commented on FLINK-24320: Sorry, I clarified the description. I meant the

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

2021-09-24 Thread GitBox
flinkbot commented on pull request #17347: URL: https://github.com/apache/flink/pull/17347#issuecomment-926425915 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 #17348: [BP-1.14][hotfix][docs] Remove flink-connector-base as required dependency fro…

2021-09-24 Thread GitBox
flinkbot commented on pull request #17348: URL: https://github.com/apache/flink/pull/17348#issuecomment-926425897 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] lirui-apache commented on a change in pull request #17245: [FLINK-23316][Table SQL/Ecosystem] Add tests for custom PartitionCommitPolicy

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

[jira] [Created] (FLINK-24369) Resource Leak may happen if flink cluster runs abnormally and repeatedly retry

2021-09-24 Thread turtlebin (Jira)
turtlebin created FLINK-24369: - Summary: Resource Leak may happen if flink cluster runs abnormally and repeatedly retry Key: FLINK-24369 URL: https://issues.apache.org/jira/browse/FLINK-24369 Project:

[jira] [Commented] (FLINK-23933) flink-json formats support a option to parse nested json as a String

2021-09-24 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-23933?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17419670#comment-17419670 ] Ingo Bürk commented on FLINK-23933: --- {quote}This should already work {quote} That's not what I meant.

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

2021-09-24 Thread GitBox
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 edited a comment on pull request #17344: [FLINK-20895] [flink-table-planner] support local aggregate push down in table planner

2021-09-24 Thread GitBox
flinkbot edited a comment on pull request #17344: URL: https://github.com/apache/flink/pull/17344#issuecomment-925952696 ## CI report: * 0fa36f90cd26e229c5e0f7dfa66a756d4817007b Azure:

[GitHub] [flink] fapaul commented on pull request #17346: [hotfix][docs] Remove the explicit requirement of flink-connector-base in pulsar connector document

2021-09-24 Thread GitBox
fapaul commented on pull request #17346: URL: https://github.com/apache/flink/pull/17346#issuecomment-926471371 I just was told that we still require the dependency I'll see that I clarify the situation -- This is an automated message from the Apache Git Service. To respond to the

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

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

[jira] [Commented] (FLINK-16201) Support JSON_VALUE

2021-09-24 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16201?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17419593#comment-17419593 ] Jingsong Lee commented on FLINK-16201: -- [~airblader] Thanks, I see "Non-scalar values cannot be

[jira] [Closed] (FLINK-24280) Support manual checkpoints triggering from a MiniCluster

2021-09-24 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24280?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-24280. Resolution: Implemented Implemented in

[GitHub] [flink] flinkbot edited a comment on pull request #17342: [FLINK-20928] Fix flaky test by retrying notifyCheckpointComplete until either commit success or timeout

2021-09-24 Thread GitBox
flinkbot edited a comment on pull request #17342: URL: https://github.com/apache/flink/pull/17342#issuecomment-925923633 ## CI report: * 32ad8a3f2031380b116ef47c7394103efb9102c2 Azure:

[GitHub] [flink] fapaul commented on a change in pull request #17346: [hotfix][docs] Remove the explicit requirement of flink-connector-base in pulsar connector document

2021-09-24 Thread GitBox
fapaul commented on a change in pull request #17346: URL: https://github.com/apache/flink/pull/17346#discussion_r715376157 ## File path: docs/content/docs/connectors/datastream/pulsar.md ## @@ -244,6 +240,10 @@ Built-in start cursors include: ```java

[GitHub] [flink] fapaul opened a new pull request #17348: [BP-1.14][hotfix][docs] Remove flink-connector-base as required dependency fro…

2021-09-24 Thread GitBox
fapaul opened a new pull request #17348: URL: https://github.com/apache/flink/pull/17348 Unchanged backport of #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

[jira] [Comment Edited] (FLINK-24346) Flink on yarn application mode,LinkageError

2021-09-24 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-24346?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17419639#comment-17419639 ] 李伟高 edited comment on FLINK-24346 at 9/24/21, 8:25 AM: --- :(,This may be a bug in

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

2021-09-24 Thread GitBox
flinkbot commented on pull request #17348: URL: https://github.com/apache/flink/pull/17348#issuecomment-926447846 ## CI report: * d0d5f2e050ed54a1f8d9eaeb209ce4bb16a5ec34 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

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

2021-09-24 Thread GitBox
flinkbot edited a comment on pull request #17344: URL: https://github.com/apache/flink/pull/17344#issuecomment-925952696 ## CI report: * 0fa36f90cd26e229c5e0f7dfa66a756d4817007b Azure:

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

2021-09-24 Thread GitBox
flinkbot commented on pull request #17347: URL: https://github.com/apache/flink/pull/17347#issuecomment-926447737 ## CI report: * d7ae1c1b86aaa3e6a1f515671a3611d94fe83be8 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Updated] (FLINK-24369) Resource Leak may happen if flink cluster runs abnormally and repeatedly retry

2021-09-24 Thread turtlebin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24369?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] turtlebin updated FLINK-24369: -- Flags: Important Description: I encountered a problem in the process of

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

2021-09-24 Thread GitBox
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.

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

2021-09-24 Thread Martijn Visser (Jira)
[ 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 >

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

2021-09-24 Thread Martijn Visser (Jira)
[ 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-5744) Check remote connection in Flink-shell

2021-09-24 Thread Martijn Visser (Jira)
[ 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

2021-09-24 Thread Martijn Visser (Jira)
[ 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-18285) solution for 'For input string: “0x100” ' make bash command 'reset' fail to work

2021-09-24 Thread Martijn Visser (Jira)
[ 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 >

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

2021-09-24 Thread GitBox
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

2021-09-24 Thread GitBox
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-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

2021-09-24 Thread GitBox
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] [Commented] (FLINK-20895) Support LocalAggregatePushDown in Blink planner

2021-09-24 Thread Peng Yu (Jira)
[ 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] slinkydeveloper opened a new pull request #17350: [FLINK-24359][table-runtime] Use ResolvedSchema in AbstractFileSystemTable

2021-09-24 Thread GitBox
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

[GitHub] [flink] JackWangCS commented on a change in pull request #17245: [FLINK-23316][Table SQL/Ecosystem] Add tests for custom PartitionCommitPolicy

2021-09-24 Thread GitBox
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 @@

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

2021-09-24 Thread GitBox
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] todd5167 commented on a change in pull request #15755: [FLINK-22318][table] Support RENAME column name for ALTER TABLE state…

2021-09-24 Thread GitBox
todd5167 commented on a change in pull request #15755: URL: https://github.com/apache/flink/pull/15755#discussion_r622333275 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/utils/OperationConverterUtils.java ## @@ -144,6

[jira] [Updated] (FLINK-24370) [FLIP-171] Documentation for Generic AsyncSinkBase

2021-09-24 Thread Zichen Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24370?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zichen Liu updated FLINK-24370: --- Description: h2. Motivation To write documentation for FLIP-171 Async Sink Base. This will help

[jira] [Created] (FLINK-24370) [FLIP-171] Documentation for Generic AsyncSinkBase

2021-09-24 Thread Zichen Liu (Jira)
Zichen Liu created FLINK-24370: -- Summary: [FLIP-171] Documentation for Generic AsyncSinkBase Key: FLINK-24370 URL: https://issues.apache.org/jira/browse/FLINK-24370 Project: Flink Issue Type:

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

2021-09-24 Thread GitBox
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-10911) Enable flink-scala-shell with Scala 2.12

2021-09-24 Thread Chesnay Schepler (Jira)
[ 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 >

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

2021-09-24 Thread Fabian Paul (Jira)
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

[GitHub] [flink] zentol merged pull request #17340: [FLINK-24360] Drop Scala Shell

2021-09-24 Thread GitBox
zentol merged pull request #17340: URL: https://github.com/apache/flink/pull/17340 -- 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:

[jira] [Closed] (FLINK-24360) Drop Scala Shell

2021-09-24 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24360?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-24360. Fix Version/s: 1.15.0 Release Note: The Scala Shell/REPL has been removed. (was: The

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

2021-09-24 Thread GitBox
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] flinkbot commented on pull request #17349: [FLINK-24370][documentation] Added documentation for Asynchronous Sin…

2021-09-24 Thread GitBox
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

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

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

2021-09-24 Thread Martijn Visser (Jira)
[ 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 >

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

2021-09-24 Thread GitBox
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? --

  1   2   >