[jira] [Commented] (FLINK-17584) disableAutoTypeRegistration option does not work with Streaming API, only with Batch

[ https://issues.apache.org/jira/browse/FLINK-17584?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17110091#comment-17110091 ] Aljoscha Krettek commented on FLINK-17584: -- I think you shouldn't wait for that

[GitHub] [flink] JingsongLi commented on a change in pull request #12212: [FLINK-17626][fs-connector] Fs connector should use FLIP-122 format options style

JingsongLi commented on a change in pull request #12212: URL: https://github.com/apache/flink/pull/12212#discussion_r426499466 ## File path: flink-formats/flink-parquet/src/main/java/org/apache/flink/formats/parquet/ParquetFileSystemFormatFactory.java ## @@ -23,137 +23,104 @@

[jira] [Created] (FLINK-17798) Align the behavior between the new and legacy JDBC table source

Jark Wu created FLINK-17798: --- Summary: Align the behavior between the new and legacy JDBC table source Key: FLINK-17798 URL: https://issues.apache.org/jira/browse/FLINK-17798 Project: Flink Issue

[GitHub] [flink] zentol merged pull request #12214: [FLINK-17618][flink-dist] Update the outdated comments in log4j2 configuration files

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

[jira] [Updated] (FLINK-17797) Align the behavior between the new and legacy HBase table source

[ https://issues.apache.org/jira/browse/FLINK-17797?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-17797: Component/s: Connectors / JDBC > Align the behavior between the new and legacy HBase table source > --

[GitHub] [flink] aljoscha commented on pull request #12059: [FLINK-17602][docs] Corrected method name in dev/stream/broadcast_sta…

aljoscha commented on pull request #12059: URL: https://github.com/apache/flink/pull/12059#issuecomment-630071918 Thanks! I merged this. This is an automated message from the Apache Git Service. To respond to the message, ple

[GitHub] [flink] aljoscha closed pull request #12059: [FLINK-17602][docs] Corrected method name in dev/stream/broadcast_sta…

aljoscha closed pull request #12059: URL: https://github.com/apache/flink/pull/12059 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to

[jira] [Closed] (FLINK-17618) Update the outdated comments in the log4j properties files

[ https://issues.apache.org/jira/browse/FLINK-17618?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-17618. Resolution: Fixed master: dc3efe1943d8347bbafffcbf7b98ae53363384b6 > Update the outdated

[jira] [Updated] (FLINK-17797) Align the behavior between the new and legacy HBase table source

[ https://issues.apache.org/jira/browse/FLINK-17797?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-17797: Component/s: (was: Connectors / JDBC) Connectors / HBase > Align the behavior between

[jira] [Assigned] (FLINK-17797) Align the behavior between the new and legacy HBase table source

[ https://issues.apache.org/jira/browse/FLINK-17797?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-17797: --- Assignee: Jark Wu > Align the behavior between the new and legacy HBase table source >

[jira] [Updated] (FLINK-17798) Align the behavior between the new and legacy JDBC table source

[ https://issues.apache.org/jira/browse/FLINK-17798?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-17798: Fix Version/s: 1.11.0 > Align the behavior between the new and legacy JDBC table source >

[jira] [Updated] (FLINK-17797) Align the behavior between the new and legacy HBase table source

[ https://issues.apache.org/jira/browse/FLINK-17797?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-17797: Fix Version/s: 1.11.0 > Align the behavior between the new and legacy HBase table source > ---

[jira] [Closed] (FLINK-17602) Documentation for broadcast state correction

[ https://issues.apache.org/jira/browse/FLINK-17602?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-17602. Resolution: Fixed master: 98186e77e0784b83807d1d032f74152a40941d00 > Documentation for br

[GitHub] [flink] aljoscha commented on pull request #12084: [FLINK-17617] Fix SQL Client autocomplete

aljoscha commented on pull request #12084: URL: https://github.com/apache/flink/pull/12084#issuecomment-630073975 This looks good to merge! You think you can still use your committer powers? 😉 This is an automated message fr

[jira] [Commented] (FLINK-17619) Only set offset commit if group id is configured for Kafka Table source

[ https://issues.apache.org/jira/browse/FLINK-17619?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17110096#comment-17110096 ] Aljoscha Krettek commented on FLINK-17619: -- Sounds legit, yes. > Only set offs

[jira] [Commented] (FLINK-15813) Set default value of jobmanager.execution.failover-strategy to region

[ https://issues.apache.org/jira/browse/FLINK-15813?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17110095#comment-17110095 ] Till Rohrmann commented on FLINK-15813: --- Great, thanks. Let me know when it is ope

[jira] [Commented] (FLINK-17798) Align the behavior between the new and legacy JDBC table source

[ https://issues.apache.org/jira/browse/FLINK-17798?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17110097#comment-17110097 ] Flavio Pompermaier commented on FLINK-17798: Is this related to FLINK-17358?

[jira] [Commented] (FLINK-17619) Only set offset commit if group id is configured for Kafka Table source

[ https://issues.apache.org/jira/browse/FLINK-17619?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17110099#comment-17110099 ] Gyula Fora commented on FLINK-17619: Seems like Jira did not pick up the PR: [https:

[GitHub] [flink] dawidwys closed pull request #12149: [FLINK-17681] Correct type when converting Row, Map, Array to RexNodes

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

[GitHub] [flink] gyfora commented on pull request #12084: [FLINK-17617] Fix SQL Client autocomplete

gyfora commented on pull request #12084: URL: https://github.com/apache/flink/pull/12084#issuecomment-630077613 I think my powers still work :) Thanks for checking it, will merge it! This is an automated message from the Apac

[GitHub] [flink] wuchong opened a new pull request #12221: [FLINK-17797][FLINK-17798][hbase][jdbc] Align the behavior between the new and legacy HBase/JDBC table source

wuchong opened a new pull request #12221: URL: https://github.com/apache/flink/pull/12221 ## What is the purpose of the change The legacy JDBC and HBase table source support projection push down. In order to make the user experience consistent. We should align the behavior an

[jira] [Updated] (FLINK-17797) Align the behavior between the new and legacy HBase table source

[ https://issues.apache.org/jira/browse/FLINK-17797?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-17797: --- Labels: pull-request-available (was: ) > Align the behavior between the new and legacy HBas

[GitHub] [flink] zhuzhurk commented on pull request #12193: [FLINK-17759][runtime] Remove unused RestartIndividualStrategy

zhuzhurk commented on pull request #12193: URL: https://github.com/apache/flink/pull/12193#issuecomment-630079861 The failed test `PerformUnalignedCheckpointOnParallelRemoteChannel` is unrelated. (see FLINK-17768) This is an

[GitHub] [flink] wanglijie95 commented on pull request #12181: [FLINK-17645][runtime] Fix SafetyNetCloseableRegistry constructor bug.

wanglijie95 commented on pull request #12181: URL: https://github.com/apache/flink/pull/12181#issuecomment-630079550 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message, ple

[GitHub] [flink] kl0u commented on pull request #12132: [FLINK-17593][Connectors/FileSystem] Support arbitrary recovery mechanism for PartFileWriter

kl0u commented on pull request #12132: URL: https://github.com/apache/flink/pull/12132#issuecomment-630081189 @guoweiM did you manage to have a look at the renamings? This is an automated message from the Apache Git Service.

[GitHub] [flink] guoweiM commented on pull request #12132: [FLINK-17593][Connectors/FileSystem] Support arbitrary recovery mechanism for PartFileWriter

guoweiM commented on pull request #12132: URL: https://github.com/apache/flink/pull/12132#issuecomment-630081895 I am looking on it now. thanks This is an automated message from the Apache Git Service. To respond to the messa

[GitHub] [flink] leonardBang commented on a change in pull request #12212: [FLINK-17626][fs-connector] Fs connector should use FLIP-122 format options style

leonardBang commented on a change in pull request #12212: URL: https://github.com/apache/flink/pull/12212#discussion_r426514957 ## File path: flink-formats/flink-parquet/src/main/java/org/apache/flink/formats/parquet/ParquetFileSystemFormatFactory.java ## @@ -23,137 +23,104 @@

[GitHub] [flink] kl0u commented on pull request #12132: [FLINK-17593][Connectors/FileSystem] Support arbitrary recovery mechanism for PartFileWriter

kl0u commented on pull request #12132: URL: https://github.com/apache/flink/pull/12132#issuecomment-630085068 No problem! Thanks for working on this @guoweiM ! This is an automated message from the Apache Git Service. To resp

[jira] [Closed] (FLINK-17681) TableEnvironment fromValues not work with map type and SQL

[ https://issues.apache.org/jira/browse/FLINK-17681?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-17681. Resolution: Fixed Fixed in 6de4f4a675e37ba7fd34a2c9114400fa2e5d25ad > TableEnvironment fr

[GitHub] [flink] flinkbot edited a comment on pull request #12132: [FLINK-17593][Connectors/FileSystem] Support arbitrary recovery mechanism for PartFileWriter

flinkbot edited a comment on pull request #12132: URL: https://github.com/apache/flink/pull/12132#issuecomment-628151415 ## CI report: * 10ef0c696350fcd84866fde27f19ed2a0312ee4b Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #12139: [FLINK-16076] Translate "Queryable State" page into Chinese

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

[GitHub] [flink] flinkbot edited a comment on pull request #12215: [FLINK-17565][k8s] Bump fabric8 version from 4.5.2 to 4.9.1

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

[GitHub] [flink] flinkbot edited a comment on pull request #12217: [FLINK-17786][sql-client] Remove dialect from ExecutionEntry

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

[GitHub] [flink] flinkbot commented on pull request #12218: [FLINK-16160][table] Fix proctime()/rowtime() doesn't work for TableE…

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

[GitHub] [flink] flinkbot edited a comment on pull request #12216: [FLINK-17788][scala-shell] scala shell in yarn mode is broken

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

[GitHub] [flink] asfgit closed pull request #12084: [FLINK-17617] Fix SQL Client autocomplete

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

[jira] [Commented] (FLINK-17730) HadoopS3RecoverableWriterITCase.testRecoverAfterMultiplePersistsStateWithMultiPart times out

[ https://issues.apache.org/jira/browse/FLINK-17730?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17110113#comment-17110113 ] Aljoscha Krettek commented on FLINK-17730: -- That's a very long runtime, though.

[jira] [Closed] (FLINK-17378) KafkaProducerExactlyOnceITCase>KafkaProducerTestBase.testExactlyOnceCustomOperator unstable

[ https://issues.apache.org/jira/browse/FLINK-17378?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-17378. Resolution: Duplicate > KafkaProducerExactlyOnceITCase>KafkaProducerTestBase.testExactlyOn

[GitHub] [flink] azagrebin commented on pull request #11245: [FLINK-15794][Kubernetes] Generate the Kubernetes default image version

azagrebin commented on pull request #11245: URL: https://github.com/apache/flink/pull/11245#issuecomment-630093521 @nielsbasjes is there plan to rebase on #11592 and update this PR? This is an automated message from the A

[jira] [Commented] (FLINK-16704) Document has some error for connect.md

[ https://issues.apache.org/jira/browse/FLINK-16704?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17110117#comment-17110117 ] hehuiyuan commented on FLINK-16704: --- [~jark] , understand. > Document has some error

[GitHub] [flink-shaded] zentol commented on a change in pull request #87: [FLINK-17685] Remove flink-shaded-hadoop-2* modules

zentol commented on a change in pull request #87: URL: https://github.com/apache/flink-shaded/pull/87#discussion_r426521847 ## File path: README.md ## @@ -23,7 +23,7 @@ This repository contains a number of shaded dependencies for the [Apache Flink]( The purpose of these dep

[GitHub] [flink] wangyang0918 opened a new pull request #12222: [FLINK-17796] Respect user specified classpath for application mode

wangyang0918 opened a new pull request #1: URL: https://github.com/apache/flink/pull/1 ## What is the purpose of the change Currently, when we deploy a Flink application cluster(e.g. Yarn, K8s), C/-classpath could not work properly. Since we override the PipelineOpt

[jira] [Updated] (FLINK-17796) Application mode should respect user specified classpath configuration

[ https://issues.apache.org/jira/browse/FLINK-17796?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-17796: --- Labels: pull-request-available (was: ) > Application mode should respect user specified cla

[GitHub] [flink] zhuzhurk opened a new pull request #12223: [FLINK-15813][runtime] Set default value of config “jobmanager.execution.failover-strategy” to “region”

zhuzhurk opened a new pull request #12223: URL: https://github.com/apache/flink/pull/12223 ## What is the purpose of the change This PR is to set the default value of jobmanager.execution.failover-strategy to region. The DefaultScheduler now already uses "region" as the default va

[jira] [Updated] (FLINK-15813) Set default value of jobmanager.execution.failover-strategy to region

[ https://issues.apache.org/jira/browse/FLINK-15813?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-15813: --- Labels: pull-request-available usability (was: usability) > Set default value of jobmanager

[jira] [Commented] (FLINK-17077) FLINK_CONF_DIR environment variable to locate flink-conf.yaml in Docker container

[ https://issues.apache.org/jira/browse/FLINK-17077?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17110128#comment-17110128 ] Andrey Zagrebin commented on FLINK-17077: - What if you mount flink-conf.yaml wit

[jira] [Comment Edited] (FLINK-17077) FLINK_CONF_DIR environment variable to locate flink-conf.yaml in Docker container

[ https://issues.apache.org/jira/browse/FLINK-17077?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17110128#comment-17110128 ] Andrey Zagrebin edited comment on FLINK-17077 at 5/18/20, 10:37 AM: --

[jira] [Assigned] (FLINK-17675) Resolve CVE-2019-11358 from jquery

[ https://issues.apache.org/jira/browse/FLINK-17675?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-17675: -- Assignee: Robert Metzger > Resolve CVE-2019-11358 from jquery > -

[GitHub] [flink] lirui-apache commented on a change in pull request #12197: [FLINK-17357][table-planner-blink] add 'DROP catalog' DDL to blink pl…

lirui-apache commented on a change in pull request #12197: URL: https://github.com/apache/flink/pull/12197#discussion_r426532648 ## File path: flink-table/flink-sql-parser/src/main/java/org/apache/flink/sql/parser/ddl/SqlDropCatalog.java ## @@ -0,0 +1,72 @@ +/* + * Licensed to

[jira] [Commented] (FLINK-15813) Set default value of jobmanager.execution.failover-strategy to region

[ https://issues.apache.org/jira/browse/FLINK-15813?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17110130#comment-17110130 ] Gary Yao commented on FLINK-15813: -- This issue is probably only for the documentation p

[GitHub] [flink] gaoyunhaii opened a new pull request #12224: [FLINK-17594][filesystem] Support Hadoop path-based part-file writer.

gaoyunhaii opened a new pull request #12224: URL: https://github.com/apache/flink/pull/12224 ## What is the purpose of the change ***This PR is a re-pick of https://github.com/apache/flink/pull/12134 and rebased it to the latest master for merging again.*** This PR

[jira] [Commented] (FLINK-15813) Set default value of jobmanager.execution.failover-strategy to region

[ https://issues.apache.org/jira/browse/FLINK-15813?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17110134#comment-17110134 ] Zhu Zhu commented on FLINK-15813: - [~gjy] you are right. I made a mistake. We can move o

[GitHub] [flink-shaded] rmetzger commented on pull request #87: [FLINK-17685] Remove flink-shaded-hadoop-2* modules

rmetzger commented on pull request #87: URL: https://github.com/apache/flink-shaded/pull/87#issuecomment-630102665 Thanks for the review! This is an automated message from the Apache Git Service. To respond to the message, pl

[GitHub] [flink-shaded] rmetzger merged pull request #87: [FLINK-17685] Remove flink-shaded-hadoop-2* modules

rmetzger merged pull request #87: URL: https://github.com/apache/flink-shaded/pull/87 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 t

[jira] [Comment Edited] (FLINK-15813) Set default value of jobmanager.execution.failover-strategy to region

[ https://issues.apache.org/jira/browse/FLINK-15813?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17110134#comment-17110134 ] Zhu Zhu edited comment on FLINK-15813 at 5/18/20, 10:50 AM:

[jira] [Closed] (FLINK-17685) Remove flink-shaded-hadoop-2-parent and submodules

[ https://issues.apache.org/jira/browse/FLINK-17685?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger closed FLINK-17685. -- Release Note: flink-shaded-hadoop-2 has been removed from flink-shaded. Starting from Flink 1.

[GitHub] [flink] StephanEwen opened a new pull request #12225: [FLINK-17781][coordination] Use Scheduler and MainThreadExecutor in OperatorCoordinator.Context

StephanEwen opened a new pull request #12225: URL: https://github.com/apache/flink/pull/12225 ## What is the purpose of the change This PR makes it possible to use safely use spawned threads in the `OperatorCoordinator` ### The Previous Issue Before, calls on the `Conte

[jira] [Updated] (FLINK-17781) OperatorCoordinator Context must support calls from thread other than JobMaster Main Thread

[ https://issues.apache.org/jira/browse/FLINK-17781?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-17781: --- Labels: pull-request-available (was: ) > OperatorCoordinator Context must support calls fro

[GitHub] [flink] flinkbot commented on pull request #12223: [FLINK-15813][runtime] Set default value of config “jobmanager.execution.failover-strategy” to “region”

flinkbot commented on pull request #12223: URL: https://github.com/apache/flink/pull/12223#issuecomment-630109130 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] flinkbot commented on pull request #12224: [FLINK-17594][filesystem] Support Hadoop path-based part-file writer.

flinkbot commented on pull request #12224: URL: https://github.com/apache/flink/pull/12224#issuecomment-630108869 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] flinkbot commented on pull request #12225: [FLINK-17781][coordination] Use Scheduler and MainThreadExecutor in OperatorCoordinator.Context

flinkbot commented on pull request #12225: URL: https://github.com/apache/flink/pull/12225#issuecomment-630108694 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] flinkbot commented on pull request #12222: [FLINK-17796] Respect user specified classpath for application mode

flinkbot commented on pull request #1: URL: https://github.com/apache/flink/pull/1#issuecomment-630109277 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] flinkbot commented on pull request #12221: [FLINK-17797][FLINK-17798][hbase][jdbc] Align the behavior between the new and legacy HBase/JDBC table source

flinkbot commented on pull request #12221: URL: https://github.com/apache/flink/pull/12221#issuecomment-630109415 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] GJL commented on pull request #12192: [FLINK-17758][runtime] Remove unused AdaptedRestartPipelinedRegionStrategyNG

GJL commented on pull request #12192: URL: https://github.com/apache/flink/pull/12192#issuecomment-630110751 The test failure on Azure seems unrelated. This is an automated message from the Apache Git Service. To respond to t

[GitHub] [flink] aljoscha commented on pull request #12084: [FLINK-17617] Fix SQL Client autocomplete

aljoscha commented on pull request #12084: URL: https://github.com/apache/flink/pull/12084#issuecomment-630112963 ☕ This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

[GitHub] [flink] liuyongvs commented on pull request #12144: [FLINK-17384][flink-dist] support read hbase conf dir from flink.conf.

liuyongvs commented on pull request #12144: URL: https://github.com/apache/flink/pull/12144#issuecomment-630113024 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message, pleas

[GitHub] [flink] zhuzhurk commented on pull request #12193: [FLINK-17759][runtime] Remove unused RestartIndividualStrategy

zhuzhurk commented on pull request #12193: URL: https://github.com/apache/flink/pull/12193#issuecomment-630113338 Thanks for reviewing! @GJL Merging. This is an automated message from the Apache Git Service. To respond to

[GitHub] [flink] zhuzhurk closed pull request #12193: [FLINK-17759][runtime] Remove unused RestartIndividualStrategy

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

[GitHub] [flink] zhuzhurk closed pull request #12192: [FLINK-17758][runtime] Remove unused AdaptedRestartPipelinedRegionStrategyNG

zhuzhurk closed pull request #12192: URL: https://github.com/apache/flink/pull/12192 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to

[jira] [Closed] (FLINK-17758) Remove AdaptedRestartPipelinedRegionStrategyNG

[ https://issues.apache.org/jira/browse/FLINK-17758?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-17758. --- Fix Version/s: 1.11.0 Resolution: Fixed Done via fd051c9964a6193034dcf15c51f78b6b7f0bae90 > Remove A

[jira] [Closed] (FLINK-17759) Remove RestartIndividualStrategy

[ https://issues.apache.org/jira/browse/FLINK-17759?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-17759. --- Fix Version/s: 1.11.0 Resolution: Fixed Done via 729ed6e4fd5c90622aa5df021232e5b554a5bbf6 > Remove R

[jira] [Updated] (FLINK-17758) Remove AdaptedRestartPipelinedRegionStrategyNG

[ https://issues.apache.org/jira/browse/FLINK-17758?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-17758: Affects Version/s: 1.11.0 > Remove AdaptedRestartPipelinedRegionStrategyNG > -

[jira] [Updated] (FLINK-17759) Remove RestartIndividualStrategy

[ https://issues.apache.org/jira/browse/FLINK-17759?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-17759: Affects Version/s: 1.11.0 > Remove RestartIndividualStrategy > > >

[jira] [Assigned] (FLINK-17796) Application mode should respect user specified classpath configuration

[ https://issues.apache.org/jira/browse/FLINK-17796?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas reassigned FLINK-17796: -- Assignee: Yang Wang > Application mode should respect user specified classpath config

[jira] [Updated] (FLINK-17796) Application mode should respect user specified classpath configuration

[ https://issues.apache.org/jira/browse/FLINK-17796?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-17796: --- Affects Version/s: 1.11.0 > Application mode should respect user specified classpath configu

[jira] [Updated] (FLINK-17796) Application mode should respect user specified classpath configuration

[ https://issues.apache.org/jira/browse/FLINK-17796?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-17796: --- Component/s: Client / Job Submission > Application mode should respect user specified classp

[jira] [Updated] (FLINK-17758) Remove AdaptedRestartPipelinedRegionStrategyNG

[ https://issues.apache.org/jira/browse/FLINK-17758?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-17758: Affects Version/s: (was: 1.11.0) 1.10.0 > Remove AdaptedRestartPipelinedRegionS

[jira] [Updated] (FLINK-17759) Remove RestartIndividualStrategy

[ https://issues.apache.org/jira/browse/FLINK-17759?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-17759: Affects Version/s: (was: 1.10.0) 1.11.0 > Remove RestartIndividualStrategy > --

[jira] [Updated] (FLINK-17758) Remove AdaptedRestartPipelinedRegionStrategyNG

[ https://issues.apache.org/jira/browse/FLINK-17758?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-17758: Affects Version/s: (was: 1.10.0) 1.11.0 > Remove AdaptedRestartPipelinedRegionS

[jira] [Updated] (FLINK-17796) Application mode should respect user specified classpath configuration

[ https://issues.apache.org/jira/browse/FLINK-17796?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-17796: --- Fix Version/s: 1.11.0 > Application mode should respect user specified classpath configurati

[jira] [Updated] (FLINK-17759) Remove RestartIndividualStrategy

[ https://issues.apache.org/jira/browse/FLINK-17759?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-17759: Affects Version/s: (was: 1.11.0) 1.10.0 > Remove RestartIndividualStrategy > --

[jira] [Updated] (FLINK-16430) FLIP-119 Pipelined Region Scheduling

[ https://issues.apache.org/jira/browse/FLINK-16430?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-16430: Fix Version/s: (was: 1.11.0) 1.12.0 > FLIP-119 Pipelined Region Scheduling > --

[jira] [Updated] (FLINK-17579) Set the resource id of taskexecutor according to environment variable if exist in standalone mode

[ https://issues.apache.org/jira/browse/FLINK-17579?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo updated FLINK-17579: --- Fix Version/s: 1.12.0 > Set the resource id of taskexecutor according to environment variable if >

[jira] [Updated] (FLINK-17019) Implement FIFO Physical Slot Assignment in SlotPoolImpl

[ https://issues.apache.org/jira/browse/FLINK-17019?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-17019: Fix Version/s: (was: 1.11.0) 1.12.0 > Implement FIFO Physical Slot Assignment in Sl

[jira] [Updated] (FLINK-17295) Refactor the ExecutionAttemptID to consist of ExecutionVertexID and attemptNumber

[ https://issues.apache.org/jira/browse/FLINK-17295?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo updated FLINK-17295: --- Fix Version/s: 1.12.0 > Refactor the ExecutionAttemptID to consist of ExecutionVertexID and > attem

[jira] [Updated] (FLINK-17017) Implement Bulk Slot Allocation

[ https://issues.apache.org/jira/browse/FLINK-17017?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-17017: Fix Version/s: (was: 1.11.0) 1.12.0 > Implement Bulk Slot Allocation >

[jira] [Updated] (FLINK-17016) Use PipelinedRegionSchedulingStrategy in DefaultScheduler (for Blink Planner)

[ https://issues.apache.org/jira/browse/FLINK-17016?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-17016: Fix Version/s: (was: 1.11.0) 1.12.0 > Use PipelinedRegionSchedulingStrategy in Defa

[jira] [Updated] (FLINK-17298) Log the lineage information between SlotRequestID and AllocationID

[ https://issues.apache.org/jira/browse/FLINK-17298?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo updated FLINK-17298: --- Fix Version/s: 1.11.0 > Log the lineage information between SlotRequestID and AllocationID > ---

[jira] [Updated] (FLINK-16548) Expose consistent environment variable to identify the component name and resource id of jm/tm

[ https://issues.apache.org/jira/browse/FLINK-16548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo updated FLINK-16548: --- Fix Version/s: 1.12.0 > Expose consistent environment variable to identify the component name and >

[jira] [Updated] (FLINK-17297) Log the lineage information between ExecutionAttemptID and SlotRequestID

[ https://issues.apache.org/jira/browse/FLINK-17297?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo updated FLINK-17297: --- Fix Version/s: 1.11.0 > Log the lineage information between ExecutionAttemptID and SlotRequestID > -

[jira] [Updated] (FLINK-17018) DefaultExecutionSlotAllocator allocates slots in bulks ignoring slot sharing

[ https://issues.apache.org/jira/browse/FLINK-17018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-17018: Fix Version/s: (was: 1.11.0) 1.12.0 > DefaultExecutionSlotAllocator allocates slots

[jira] [Updated] (FLINK-15448) Log host informations for TaskManager failures.

[ https://issues.apache.org/jira/browse/FLINK-15448?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo updated FLINK-15448: --- Fix Version/s: 1.12.0 > Log host informations for TaskManager failures. > --

[jira] [Closed] (FLINK-14460) Active Kubernetes integration phase 2 - Advanced Features

[ https://issues.apache.org/jira/browse/FLINK-14460?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang closed FLINK-14460. - Resolution: Fixed > Active Kubernetes integration phase 2 - Advanced Features >

[jira] [Updated] (FLINK-17300) Log the lineage information between ExecutionAttemptID and AllocationID

[ https://issues.apache.org/jira/browse/FLINK-17300?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo updated FLINK-17300: --- Fix Version/s: 1.11.0 > Log the lineage information between ExecutionAttemptID and AllocationID > --

[jira] [Updated] (FLINK-17542) Unify slot request timeout handling for streaming and batch tasks

[ https://issues.apache.org/jira/browse/FLINK-17542?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-17542: Fix Version/s: (was: 1.11.0) 1.12.0 > Unify slot request timeout handling for strea

[jira] [Updated] (FLINK-17330) Avoid scheduling deadlocks caused by cyclic input dependencies between regions

[ https://issues.apache.org/jira/browse/FLINK-17330?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-17330: Fix Version/s: (was: 1.11.0) 1.12.0 > Avoid scheduling deadlocks caused by cyclic i

[jira] [Updated] (FLINK-17208) Reduce redundant data available notification of PipelinedSubpartition

[ https://issues.apache.org/jira/browse/FLINK-17208?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yingjie Cao updated FLINK-17208: Fix Version/s: (was: 1.11.0) 1.12.0 > Reduce redundant data available notif

[GitHub] [flink] flinkbot edited a comment on pull request #8693: [FLINK-8871] Support to cancel checkpoing via notification

flinkbot edited a comment on pull request #8693: URL: https://github.com/apache/flink/pull/8693#issuecomment-542518065 ## CI report: * 01016af81f4aca6c28525ef1fe896986bf60592c Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results

[jira] [Updated] (FLINK-16077) Translate "Custom State Serialization" page into Chinese

[ https://issues.apache.org/jira/browse/FLINK-16077?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Congxian Qiu(klion26) updated FLINK-16077: -- Fix Version/s: (was: 1.11.0) 1.12.0 > Translate "Custom

[jira] [Updated] (FLINK-15626) Remove legacy scheduler

[ https://issues.apache.org/jira/browse/FLINK-15626?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-15626: Fix Version/s: (was: 1.11.0) 1.12.0 > Remove legacy scheduler > ---

<    1   2   3   4   5   6   7   8   9   >