[jira] [Commented] (FLINK-18938) Throw better exception message for quering sink-only connector

[ https://issues.apache.org/jira/browse/FLINK-18938?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17181631#comment-17181631 ] liufangliang commented on FLINK-18938: -- [~jark] , Yes , please assign it to me. > Throw better

[GitHub] [flink] flinkbot edited a comment on pull request #13211: [FLINK-18941][docs-zh] Correct typos in \docs\ops\memory\mem_setup_jobmanager.zh.md

flinkbot edited a comment on pull request #13211: URL: https://github.com/apache/flink/pull/13211#issuecomment-678027386 ## CI report: * 5b25d83956ef609b5e0c4d6edc38389182074425 Azure:

[jira] [Commented] (FLINK-18938) Throw better exception message for quering sink-only connector

[ https://issues.apache.org/jira/browse/FLINK-18938?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17181622#comment-17181622 ] Jark Wu commented on FLINK-18938: - [~liufangliang] sounds good to me. Do you want to take this issue?

[GitHub] [flink-docker] zhuzhurk opened a new pull request #39: Update Dockerfiles for 1.10.2 release

zhuzhurk opened a new pull request #39: URL: https://github.com/apache/flink-docker/pull/39 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

[GitHub] [flink-docker] zhuzhurk commented on pull request #38: Add GPG key for 1.10.2 release and update test script

zhuzhurk commented on pull request #38: URL: https://github.com/apache/flink-docker/pull/38#issuecomment-678042799 @rmetzger would you help to take a look at this pull request? This is an automated message from the Apache

[GitHub] [flink-docker] zhuzhurk opened a new pull request #38: Add GPG key for 1.10.2 release and update test script

zhuzhurk opened a new pull request #38: URL: https://github.com/apache/flink-docker/pull/38 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

[jira] [Commented] (FLINK-18938) Throw better exception message for quering sink-only connector

[ https://issues.apache.org/jira/browse/FLINK-18938?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17181601#comment-17181601 ] liufangliang commented on FLINK-18938: -- [~jark] The judgment method is consistent with the judgment

[GitHub] [flink] flinkbot edited a comment on pull request #13211: [FLINK-18941][docs-zh] Correct typos in \docs\ops\memory\mem_setup_jobmanager.zh.md

flinkbot edited a comment on pull request #13211: URL: https://github.com/apache/flink/pull/13211#issuecomment-678027386 ## CI report: * 5b25d83956ef609b5e0c4d6edc38389182074425 Azure:

[GitHub] [flink] flinkbot commented on pull request #13211: [FLINK-18941][docs-zh] Correct typos in \docs\ops\memory\mem_setup_jobmanager.zh.md

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

[GitHub] [flink] flinkbot edited a comment on pull request #13089: [FLINK-18813][docs-zh] Translate the 'Local Installation' page of 'Try Flink' into Chinese

flinkbot edited a comment on pull request #13089: URL: https://github.com/apache/flink/pull/13089#issuecomment-670624464 ## CI report: * 726ffd0069727a6d8ad080e7eb43ac60702eb462 UNKNOWN * 593b3f8aa3746261620e359db1eb390a6d557297 Azure:

[jira] [Updated] (FLINK-19011) Parallelize the restore operation in OperatorStateBackend

[ https://issues.apache.org/jira/browse/FLINK-19011?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiayi Liao updated FLINK-19011: --- Summary: Parallelize the restore operation in OperatorStateBackend (was: Parallelize the

[jira] [Updated] (FLINK-19011) Parallelize the restoreOperation in OperatorStateBackend

[ https://issues.apache.org/jira/browse/FLINK-19011?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiayi Liao updated FLINK-19011: --- Component/s: Runtime / Checkpointing > Parallelize the restoreOperation in OperatorStateBackend >

[jira] [Created] (FLINK-19011) Parallelize the restoreOperation in OperatorStateBackend

Jiayi Liao created FLINK-19011: -- Summary: Parallelize the restoreOperation in OperatorStateBackend Key: FLINK-19011 URL: https://issues.apache.org/jira/browse/FLINK-19011 Project: Flink Issue

[GitHub] [flink] flinkbot commented on pull request #13211: [FLINK-18941][docs-zh] Correct typos in \docs\ops\memory\mem_setup_jobmanager.zh.md

flinkbot commented on pull request #13211: URL: https://github.com/apache/flink/pull/13211#issuecomment-678023515 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] Littlebus opened a new pull request #13211: [FLINK-18941][docs-zh] Correct typos in \docs\ops\memory\mem_setup_jobmanager.zh.md

Littlebus opened a new pull request #13211: URL: https://github.com/apache/flink/pull/13211 ## What is the purpose of the change Correct typos in Chinese docs. ## Brief change log + Correct \docs\ops\memory\mem_setup_jobmanager.zh.md. ## Does this

[GitHub] [flink] Littlebus closed pull request #13210: [FLINK-18941][docs-zh] Correct typos in \docs\ops\memory\mem_setup_jobmanager.zh.md

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

[GitHub] [flink] flinkbot commented on pull request #13210: [FLINK-18941][docs-zh] Correct typos in \docs\ops\memory\mem_setup_jobmanager.zh.md

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

[GitHub] [flink] flinkbot commented on pull request #13210: [FLINK-18941][docs-zh] Correct typos in \docs\ops\memory\mem_setup_jobmanager.zh.md

flinkbot commented on pull request #13210: URL: https://github.com/apache/flink/pull/13210#issuecomment-678016572 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-18941) There are some typos in "Set up JobManager Memory"

[ https://issues.apache.org/jira/browse/FLINK-18941?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-18941: --- Labels: pull-request-available (was: ) > There are some typos in "Set up JobManager

[GitHub] [flink] Littlebus opened a new pull request #13210: [FLINK-18941][docs-zh] Correct typos in \docs\ops\memory\mem_setup_jobmanager.zh.md

Littlebus opened a new pull request #13210: URL: https://github.com/apache/flink/pull/13210 ## What is the purpose of the change Correct typos in Chinese docs. ## Brief change log + Correct \docs\ops\memory\mem_setup_jobmanager.zh.md. ## Does this

[GitHub] [flink] flinkbot edited a comment on pull request #13089: [FLINK-18813][docs-zh] Translate the 'Local Installation' page of 'Try Flink' into Chinese

flinkbot edited a comment on pull request #13089: URL: https://github.com/apache/flink/pull/13089#issuecomment-670624464 ## CI report: * 726ffd0069727a6d8ad080e7eb43ac60702eb462 UNKNOWN * a683764a06c231cbc4c16cc070dbde71d5961e3a Azure:

[jira] [Commented] (FLINK-19010) Add a system metric to show the checkpoint restore time

[ https://issues.apache.org/jira/browse/FLINK-19010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17181557#comment-17181557 ] harold.miao commented on FLINK-19010: - yes, this metric get obvious significance,  we develop a

[GitHub] [flink] flinkbot edited a comment on pull request #13121: [FLINK-15793][k8s] Replace kubernetes-entry.sh with unified docker-entrypoint.sh

flinkbot edited a comment on pull request #13121: URL: https://github.com/apache/flink/pull/13121#issuecomment-672466655 ## CI report: * 8c486a2bf8f9b604acddc6ea5b3d81413aa300b3 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13121: [FLINK-15793][k8s] Replace kubernetes-entry.sh with unified docker-entrypoint.sh

flinkbot edited a comment on pull request #13121: URL: https://github.com/apache/flink/pull/13121#issuecomment-672466655 ## CI report: * 8c486a2bf8f9b604acddc6ea5b3d81413aa300b3 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13089: [FLINK-18813][docs-zh] Translate the 'Local Installation' page of 'Try Flink' into Chinese

flinkbot edited a comment on pull request #13089: URL: https://github.com/apache/flink/pull/13089#issuecomment-670624464 ## CI report: * 726ffd0069727a6d8ad080e7eb43ac60702eb462 UNKNOWN * a683764a06c231cbc4c16cc070dbde71d5961e3a Azure:

[jira] [Closed] (FLINK-18933) Delete the old Python Table API document section

[ https://issues.apache.org/jira/browse/FLINK-18933?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-18933. --- Assignee: (was: Wei Zhong) Resolution: Invalid already supported in FLINK-18910 > Delete the old

[jira] [Updated] (FLINK-18933) Delete the old Python Table API document section

[ https://issues.apache.org/jira/browse/FLINK-18933?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-18933: Parent: (was: FLINK-18775) Issue Type: Improvement (was: Sub-task) > Delete the old Python

[jira] [Assigned] (FLINK-18914) Move the "Python DataTypes" document from the old Python Table API documentation to the "Python API" -> "User Guide" -> "Table API" section with a new name "DataTypes"

[ https://issues.apache.org/jira/browse/FLINK-18914?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-18914: --- Assignee: (was: Wei Zhong) > Move the "Python DataTypes" document from the old Python Table

[jira] [Updated] (FLINK-18914) Move the "Python DataTypes" document from the old Python Table API documentation to the "Python API" -> "User Guide" -> "Table API" section with a new name "DataTypes"

[ https://issues.apache.org/jira/browse/FLINK-18914?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-18914: Parent: (was: FLINK-18775) Issue Type: Improvement (was: Sub-task) > Move the "Python

[jira] [Closed] (FLINK-18914) Move the "Python DataTypes" document from the old Python Table API documentation to the "Python API" -> "User Guide" -> "Table API" section with a new name "DataTypes"

[ https://issues.apache.org/jira/browse/FLINK-18914?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-18914. --- Resolution: Invalid already supported in FLINK-18910 > Move the "Python DataTypes" document from the old

[GitHub] [flink] wangyang0918 commented on pull request #13121: [FLINK-15793][k8s] Replace kubernetes-entry.sh with unified docker-entrypoint.sh

wangyang0918 commented on pull request #13121: URL: https://github.com/apache/flink/pull/13121#issuecomment-678007862 @rmetzger Thanks for your nice text suggestion. I have integrated these comments and force pushed. This

[jira] [Updated] (FLINK-18925) Move the "Configuration" document from the old Python Table API documentation to the "Python API" -> "User Guide" -> "Table API" section

[ https://issues.apache.org/jira/browse/FLINK-18925?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-18925: Parent: (was: FLINK-18775) Issue Type: Improvement (was: Sub-task) > Move the

[jira] [Updated] (FLINK-18919) Move the "User Defined Functions" document and "Vectorized User Defined Functions" document from the old Python Table API documentation to the "Python API" -> "User Guid

[ https://issues.apache.org/jira/browse/FLINK-18919?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-18919: Parent: (was: FLINK-18775) Issue Type: Improvement (was: Sub-task) > Move the "User Defined

[jira] [Closed] (FLINK-18919) Move the "User Defined Functions" document and "Vectorized User Defined Functions" document from the old Python Table API documentation to the "Python API" -> "User Guide

[ https://issues.apache.org/jira/browse/FLINK-18919?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-18919. --- Assignee: (was: Wei Zhong) Resolution: Invalid already done in FLINK-18910 > Move the "User

[jira] [Updated] (FLINK-18924) Move the "Metrics" document from the old Python Table API documentation to the "Python API" -> "User Guide" -> "Table API" section

[ https://issues.apache.org/jira/browse/FLINK-18924?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-18924: Parent: (was: FLINK-18775) Issue Type: Improvement (was: Sub-task) > Move the "Metrics"

[jira] [Closed] (FLINK-18925) Move the "Configuration" document from the old Python Table API documentation to the "Python API" -> "User Guide" -> "Table API" section

[ https://issues.apache.org/jira/browse/FLINK-18925?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-18925. --- Assignee: (was: Wei Zhong) Resolution: Invalid already done in FLINK-18910 > Move the

[jira] [Updated] (FLINK-18928) Move the "Common Questions" document from the old Python Table API documentation to the "Python API" section with a new name "FAQ"

[ https://issues.apache.org/jira/browse/FLINK-18928?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-18928: Parent: (was: FLINK-18775) Issue Type: Improvement (was: Sub-task) > Move the "Common

[jira] [Closed] (FLINK-18924) Move the "Metrics" document from the old Python Table API documentation to the "Python API" -> "User Guide" -> "Table API" section

[ https://issues.apache.org/jira/browse/FLINK-18924?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-18924. --- Assignee: (was: Wei Zhong) Resolution: Invalid already done in FLINK-18910 > Move the "Metrics"

[jira] [Closed] (FLINK-18928) Move the "Common Questions" document from the old Python Table API documentation to the "Python API" section with a new name "FAQ"

[ https://issues.apache.org/jira/browse/FLINK-18928?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-18928. --- Assignee: (was: Wei Zhong) Resolution: Invalid already done in FLINK-18910 > Move the "Common

[jira] [Updated] (FLINK-18911) Move the "Installation" document from the old Python Table API documentation to the "Python API" -> "GettingStart" section

[ https://issues.apache.org/jira/browse/FLINK-18911?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-18911: Parent: (was: FLINK-18775) Issue Type: Bug (was: Sub-task) > Move the "Installation"

[jira] [Closed] (FLINK-18911) Move the "Installation" document from the old Python Table API documentation to the "Python API" -> "GettingStart" section

[ https://issues.apache.org/jira/browse/FLINK-18911?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-18911. --- Assignee: (was: Wei Zhong) Resolution: Invalid Already done in FLINK-18910 > Move the

[jira] [Assigned] (FLINK-18941) There are some typos in "Set up JobManager Memory"

[ https://issues.apache.org/jira/browse/FLINK-18941?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reassigned FLINK-18941: Assignee: Kecheng Xiao (was: Xintong Song) > There are some typos in "Set up JobManager

[jira] [Commented] (FLINK-18938) Throw better exception message for quering sink-only connector

[ https://issues.apache.org/jira/browse/FLINK-18938?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17181540#comment-17181540 ] Jark Wu commented on FLINK-18938: - [~liufangliang] How do you infer whether the connector supports

[GitHub] [flink] RocMarshal commented on a change in pull request #13089: [FLINK-18813][docs-zh] Translate the 'Local Installation' page of 'Try Flink' into Chinese

RocMarshal commented on a change in pull request #13089: URL: https://github.com/apache/flink/pull/13089#discussion_r474373999 ## File path: docs/try-flink/local_installation.zh.md ## @@ -64,10 +63,11 @@ Starting standalonesession daemon on host. Starting taskexecutor daemon

[GitHub] [flink] flinkbot edited a comment on pull request #13050: [FLINK-18750][table] SqlValidatorException thrown when select from a …

flinkbot edited a comment on pull request #13050: URL: https://github.com/apache/flink/pull/13050#issuecomment-667904442 ## CI report: * 870f73394bfc42e740891a6262e1bfd97efdba56 Azure:

[jira] [Closed] (FLINK-18912) Add a Table API tutorial link(linked to try-flink/python_table_api.md) under the "Python API" -> "GettingStart" -> "Tutorial" section

[ https://issues.apache.org/jira/browse/FLINK-18912?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-18912. --- Fix Version/s: 1.11.2 1.12.0 Resolution: Fixed > Add a Table API tutorial

[jira] [Commented] (FLINK-18912) Add a Table API tutorial link(linked to try-flink/python_table_api.md) under the "Python API" -> "GettingStart" -> "Tutorial" section

[ https://issues.apache.org/jira/browse/FLINK-18912?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17181531#comment-17181531 ] Dian Fu commented on FLINK-18912: - release-1.11: b6d53fb1717023faafb79948a305b8dc1e3de2c4 > Add a Table

[jira] [Issue Comment Deleted] (FLINK-18974) Translate the 'User-Defined Functions' page of "Application Development's DataStream API" into Chinese

[ https://issues.apache.org/jira/browse/FLINK-18974?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ChaojianZhang updated FLINK-18974: -- Comment: was deleted (was: Hi [~RocMarshal], I want to take this job, can you assign it to

[jira] [Commented] (FLINK-18974) Translate the 'User-Defined Functions' page of "Application Development's DataStream API" into Chinese

[ https://issues.apache.org/jira/browse/FLINK-18974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17181530#comment-17181530 ] ChaojianZhang commented on FLINK-18974: --- Hi [~RocMarshal], I want to take this job, can you assign

[jira] [Created] (FLINK-19010) Add a system metric to show the checkpoint restore time

Zhinan Cheng created FLINK-19010: Summary: Add a system metric to show the checkpoint restore time Key: FLINK-19010 URL: https://issues.apache.org/jira/browse/FLINK-19010 Project: Flink

[GitHub] [flink] wangzzu commented on pull request #13024: [FLINK-18742][flink-clients] Some configuration args do not take effect at client

wangzzu commented on pull request #13024: URL: https://github.com/apache/flink/pull/13024#issuecomment-677998342 @kl0u I have modified it, can you help review this again? This is an automated message from the Apache Git

[GitHub] [flink] flinkbot edited a comment on pull request #13050: [FLINK-18750][table] SqlValidatorException thrown when select from a …

flinkbot edited a comment on pull request #13050: URL: https://github.com/apache/flink/pull/13050#issuecomment-667904442 ## CI report: * 870f73394bfc42e740891a6262e1bfd97efdba56 Azure:

[jira] [Created] (FLINK-19009) wrong way to calculate the "downtime" metric

Zhinan Cheng created FLINK-19009: Summary: wrong way to calculate the "downtime" metric Key: FLINK-19009 URL: https://issues.apache.org/jira/browse/FLINK-19009 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-17274) Maven: Premature end of Content-Length delimited message body

[ https://issues.apache.org/jira/browse/FLINK-17274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17181522#comment-17181522 ] Dian Fu commented on FLINK-17274: -

[GitHub] [flink] TisonKun commented on a change in pull request #13188: [hotfix][docs] Translate building.md to building.zh.md

TisonKun commented on a change in pull request #13188: URL: https://github.com/apache/flink/pull/13188#discussion_r474345363 ## File path: docs/flinkDev/building.zh.md ## @@ -22,129 +22,132 @@ specific language governing permissions and limitations under the License. -->

[GitHub] [flink] TisonKun commented on a change in pull request #13188: [hotfix][docs] Translate building.md to building.zh.md

TisonKun commented on a change in pull request #13188: URL: https://github.com/apache/flink/pull/13188#discussion_r474345172 ## File path: docs/flinkDev/building.zh.md ## @@ -22,129 +22,132 @@ specific language governing permissions and limitations under the License. -->

[GitHub] [flink] TisonKun commented on a change in pull request #13188: [hotfix][docs] Translate building.md to building.zh.md

TisonKun commented on a change in pull request #13188: URL: https://github.com/apache/flink/pull/13188#discussion_r474344827 ## File path: docs/flinkDev/building.zh.md ## @@ -22,129 +22,132 @@ specific language governing permissions and limitations under the License. -->

[GitHub] [flink] TisonKun commented on a change in pull request #13188: [hotfix][docs] Translate building.md to building.zh.md

TisonKun commented on a change in pull request #13188: URL: https://github.com/apache/flink/pull/13188#discussion_r474344827 ## File path: docs/flinkDev/building.zh.md ## @@ -22,129 +22,132 @@ specific language governing permissions and limitations under the License. -->

[GitHub] [flink] TisonKun commented on a change in pull request #13188: [hotfix][docs] Translate building.md to building.zh.md

TisonKun commented on a change in pull request #13188: URL: https://github.com/apache/flink/pull/13188#discussion_r474344537 ## File path: docs/flinkDev/building.zh.md ## @@ -22,129 +22,132 @@ specific language governing permissions and limitations under the License. -->

[GitHub] [flink] TisonKun commented on a change in pull request #13188: [hotfix][docs] Translate building.md to building.zh.md

TisonKun commented on a change in pull request #13188: URL: https://github.com/apache/flink/pull/13188#discussion_r474344108 ## File path: docs/flinkDev/building.zh.md ## @@ -22,129 +22,132 @@ specific language governing permissions and limitations under the License. -->

[GitHub] [flink] TisonKun commented on a change in pull request #13188: [hotfix][docs] Translate building.md to building.zh.md

TisonKun commented on a change in pull request #13188: URL: https://github.com/apache/flink/pull/13188#discussion_r474343892 ## File path: docs/flinkDev/building.zh.md ## @@ -22,62 +22,63 @@ specific language governing permissions and limitations under the License. -->

[GitHub] [flink] lvhuyen commented on pull request #6613: [FLINK-9940] [API/DataStream][File source] out-of-order files were missed in continuous monitoring

lvhuyen commented on pull request #6613: URL: https://github.com/apache/flink/pull/6613#issuecomment-677969037 Thank you Kostas.I have been waiting for Guowei's reply on the Jira ticket as it might render my PR redundant. BTW, may I ask how you monitor the activeness of a PR? My PR

[jira] [Updated] (FLINK-19008) Flink Job runs slow after restore + downscale from an incremental checkpoint (rocksdb)

[ https://issues.apache.org/jira/browse/FLINK-19008?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Qin updated FLINK-19008: Labels: perfomance usability (was: ) > Flink Job runs slow after restore + downscale from an incremental

[jira] [Updated] (FLINK-19008) Flink Job runs slow after restore + downscale from an incremental checkpoint (rocksdb)

[ https://issues.apache.org/jira/browse/FLINK-19008?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Qin updated FLINK-19008: Description: A customer runs a Flink job with RocksDB state backend. Checkpoints are retained and done

[jira] [Created] (FLINK-19008) Flink Job runs slow after restore + downscale from an incremental checkpoint (rocksdb)

Jun Qin created FLINK-19008: --- Summary: Flink Job runs slow after restore + downscale from an incremental checkpoint (rocksdb) Key: FLINK-19008 URL: https://issues.apache.org/jira/browse/FLINK-19008

[GitHub] [flink] flinkbot edited a comment on pull request #13024: [FLINK-18742][flink-clients] Some configuration args do not take effect at client

flinkbot edited a comment on pull request #13024: URL: https://github.com/apache/flink/pull/13024#issuecomment-666148245 ## CI report: * eb611d5b39f997fa3e986b5d163cb65a44b4b0ba UNKNOWN * e505da81c290c0ab3f21defb1ef0f3a3f7be69eb Azure:

[jira] [Updated] (FLINK-19007) Automatically set presto staging directory to io.tmp.dirs

[ https://issues.apache.org/jira/browse/FLINK-19007?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-19007: - Labels: usability (was: ) > Automatically set presto staging directory to io.tmp.dirs

[GitHub] [flink] azagrebin commented on a change in pull request #13205: [FLINK-17330[runtime] Merge cyclic dependent pipelined regions into one region

azagrebin commented on a change in pull request #13205: URL: https://github.com/apache/flink/pull/13205#discussion_r474212420 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/failover/flip1/StronglyConnectedComponentsComputeUtils.java ## @@

[GitHub] [flink] walterddr commented on a change in pull request #13163: [FLINK-16789][runtime] Support JMX RMI random port assign

walterddr commented on a change in pull request #13163: URL: https://github.com/apache/flink/pull/13163#discussion_r474217701 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/management/JMXService.java ## @@ -85,6 +86,9 @@ private static JMXServer

[jira] [Created] (FLINK-19007) Automatically set presto staging directory to io.tmp.dirs

Chesnay Schepler created FLINK-19007: Summary: Automatically set presto staging directory to io.tmp.dirs Key: FLINK-19007 URL: https://issues.apache.org/jira/browse/FLINK-19007 Project: Flink

[jira] [Updated] (FLINK-19007) Automatically set presto staging directory to io.tmp.dirs

[ https://issues.apache.org/jira/browse/FLINK-19007?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-19007: - Description: The presto S3 filesystem uses a staging directory on the local disk (for

[GitHub] [flink] flinkbot edited a comment on pull request #13209: [FLINK-18832][datastream] Add compatible check for blocking partition with buffer timeout

flinkbot edited a comment on pull request #13209: URL: https://github.com/apache/flink/pull/13209#issuecomment-677744672 ## CI report: * 92b731b4954f21979b22765e84725974942273e3 Azure:

[GitHub] [flink-statefun] sjwiesman commented on pull request #134: [FLINK-18518] Add AsyncRequestReplyHandler for the Python SDK

sjwiesman commented on pull request #134: URL: https://github.com/apache/flink-statefun/pull/134#issuecomment-677802701 #docs This is an automated message from the Apache Git Service. To respond to the message, please log

[GitHub] [flink-statefun] sjwiesman commented on pull request #132: [FLINK-18979][docs] Update docs to better emphasize remote functions

sjwiesman commented on pull request #132: URL: https://github.com/apache/flink-statefun/pull/132#issuecomment-677803065 @tzulitai / @morsapaes when you get a chance I've updated the homepage based on the above discussion.

[GitHub] [flink-statefun] sjwiesman commented on pull request #133: [FLINK-19001] Add data stream api interoperability

sjwiesman commented on pull request #133: URL: https://github.com/apache/flink-statefun/pull/133#issuecomment-677802607 #docs This is an automated message from the Apache Git Service. To respond to the message, please log

[GitHub] [flink] AHeise commented on a change in pull request #13175: [FLINK-18955][Checkpointing] Add checkpoint path to job startup/restore message

AHeise commented on a change in pull request #13175: URL: https://github.com/apache/flink/pull/13175#discussion_r474154852 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CompletedCheckpoint.java ## @@ -320,6 +320,12 @@ void

[GitHub] [flink] flinkbot edited a comment on pull request #13024: [FLINK-18742][flink-clients] Some configuration args do not take effect at client

flinkbot edited a comment on pull request #13024: URL: https://github.com/apache/flink/pull/13024#issuecomment-666148245 ## CI report: * eb611d5b39f997fa3e986b5d163cb65a44b4b0ba UNKNOWN * 047cc5ec9e12641f2787ac6fa4a3525fd6fc7d70 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13208: [FLINK-18676] [FileSystem] Bump s3 aws version

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

[GitHub] [flink] flinkbot edited a comment on pull request #13024: [FLINK-18742][flink-clients] Some configuration args do not take effect at client

flinkbot edited a comment on pull request #13024: URL: https://github.com/apache/flink/pull/13024#issuecomment-666148245 ## CI report: * eb611d5b39f997fa3e986b5d163cb65a44b4b0ba UNKNOWN * 047cc5ec9e12641f2787ac6fa4a3525fd6fc7d70 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13209: [FLINK-18832][datastream] Add compatible check for blocking partition with buffer timeout

flinkbot edited a comment on pull request #13209: URL: https://github.com/apache/flink/pull/13209#issuecomment-677744672 ## CI report: * 92b731b4954f21979b22765e84725974942273e3 Azure:

[GitHub] [flink] flinkbot commented on pull request #13209: [FLINK-18832][datastream] Add compatible check for blocking partition with buffer timeout

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

[GitHub] [flink] wangzzu commented on pull request #13024: [FLINK-18742][flink-clients] Some configuration args do not take effect at client

wangzzu commented on pull request #13024: URL: https://github.com/apache/flink/pull/13024#issuecomment-677744117 @kl0u Thanks for your suggestion, I will modify it. This is an automated message from the Apache Git Service.

[jira] [Assigned] (FLINK-17260) StreamingKafkaITCase failure on Azure

[ https://issues.apache.org/jira/browse/FLINK-17260?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-17260: Assignee: (was: Chesnay Schepler) > StreamingKafkaITCase failure on Azure >

[GitHub] [flink] flinkbot commented on pull request #13209: [FLINK-18832][datastream] Add compatible check for blocking partition with buffer timeout

flinkbot commented on pull request #13209: URL: https://github.com/apache/flink/pull/13209#issuecomment-677737839 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] kl0u edited a comment on pull request #13024: [FLINK-18742][flink-clients] Some configuration args do not take effect at client

kl0u edited a comment on pull request #13024: URL: https://github.com/apache/flink/pull/13024#issuecomment-677730660 @wangzzu In your testing code you seem to "replicate" the code of the `CliFrontend.run()` method. This is pretty fragile because if someone changes the order of the calls

[GitHub] [flink] zhijiangW opened a new pull request #13209: [FLINK-18832][datastream] Add compatible check for blocking partition with buffer timeout

zhijiangW opened a new pull request #13209: URL: https://github.com/apache/flink/pull/13209 ## What is the purpose of the change The current BoundedBlockingSubpartition in runtime does not support positive flush timeout setting by design based on the current scheduler strategy. So

[jira] [Updated] (FLINK-18832) BoundedBlockingSubpartition does not work with StreamTask

[ https://issues.apache.org/jira/browse/FLINK-18832?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-18832: --- Labels: pull-request-available (was: ) > BoundedBlockingSubpartition does not work with

[GitHub] [flink] kl0u edited a comment on pull request #13024: [FLINK-18742][flink-clients] Some configuration args do not take effect at client

kl0u edited a comment on pull request #13024: URL: https://github.com/apache/flink/pull/13024#issuecomment-677730660 @wangzzu In your testing code you seem to "replicate" the code of the `CliFrontend.run()` method. This is pretty fragile because if someone changes the order of the calls

[GitHub] [flink] flinkbot edited a comment on pull request #13024: [FLINK-18742][flink-clients] Some configuration args do not take effect at client

flinkbot edited a comment on pull request #13024: URL: https://github.com/apache/flink/pull/13024#issuecomment-666148245 ## CI report: * eb611d5b39f997fa3e986b5d163cb65a44b4b0ba UNKNOWN * 047cc5ec9e12641f2787ac6fa4a3525fd6fc7d70 Azure:

[GitHub] [flink] kl0u commented on pull request #13024: [FLINK-18742][flink-clients] Some configuration args do not take effect at client

kl0u commented on pull request #13024: URL: https://github.com/apache/flink/pull/13024#issuecomment-677730660 @wangzzu In your testing code you seem to "replicate" the code of the `CliFrontend.run()` method. This is pretty fragile because if someone changes the order of the calls in the

[GitHub] [flink] flinkbot edited a comment on pull request #13050: [FLINK-18750][table] SqlValidatorException thrown when select from a …

flinkbot edited a comment on pull request #13050: URL: https://github.com/apache/flink/pull/13050#issuecomment-667904442 ## CI report: * 870f73394bfc42e740891a6262e1bfd97efdba56 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13024: [FLINK-18742][flink-clients] Some configuration args do not take effect at client

flinkbot edited a comment on pull request #13024: URL: https://github.com/apache/flink/pull/13024#issuecomment-666148245 ## CI report: * eb611d5b39f997fa3e986b5d163cb65a44b4b0ba UNKNOWN * a5db01bd0f63289039dfcdae41eaf099ed28a812 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13050: [FLINK-18750][table] SqlValidatorException thrown when select from a …

flinkbot edited a comment on pull request #13050: URL: https://github.com/apache/flink/pull/13050#issuecomment-667904442 ## CI report: * 0358a12e3524d251396cca950c7403eee205f0d6 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13207: [FLINK-18952][python][docs] Add 10 minutes to DataStream API documentation

flinkbot edited a comment on pull request #13207: URL: https://github.com/apache/flink/pull/13207#issuecomment-677643498 ## CI report: * 371eaa2083054d66ef256a9a0ef7a90e116fee0d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13050: [FLINK-18750][table] SqlValidatorException thrown when select from a …

flinkbot edited a comment on pull request #13050: URL: https://github.com/apache/flink/pull/13050#issuecomment-667904442 ## CI report: * 0358a12e3524d251396cca950c7403eee205f0d6 Azure:

[jira] [Commented] (FLINK-18850) Add late records dropped metric for row time over windows

[ https://issues.apache.org/jira/browse/FLINK-18850?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17181215#comment-17181215 ] Benchao Li commented on FLINK-18850: [~ZhuShang] Do you still want to take this issue? > Add late

[GitHub] [flink] flinkbot edited a comment on pull request #13206: [FLINK-18948][python] Add end to end test for Python DataStream API.

flinkbot edited a comment on pull request #13206: URL: https://github.com/apache/flink/pull/13206#issuecomment-677500353 ## CI report: * bea57ee386d4ffdd264e3cc0116a653454103c42 Azure:

[jira] [Comment Edited] (FLINK-19005) used metaspace grow on every execution

[ https://issues.apache.org/jira/browse/FLINK-19005?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17181205#comment-17181205 ] Matthias edited comment on FLINK-19005 at 8/20/20, 1:57 PM: Hi Guillermo,

[jira] [Closed] (FLINK-19005) used metaspace grow on every execution

[ https://issues.apache.org/jira/browse/FLINK-19005?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias closed FLINK-19005. Assignee: Matthias Resolution: Information Provided I close this issue. Feel free to move the

[jira] [Commented] (FLINK-19005) used metaspace grow on every execution

[ https://issues.apache.org/jira/browse/FLINK-19005?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17181205#comment-17181205 ] Matthias commented on FLINK-19005: -- Hi Robert, this looks like a Metaspace leak. The memory used for

  1   2   3   >