[GitHub] [flink] zekai-li commented on pull request #17365: [hotfix][web]Modify the configuration of prettier

zekai-li commented on pull request #17365: URL: https://github.com/apache/flink/pull/17365#issuecomment-929145942 @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

[GitHub] [flink] flinkbot edited a comment on pull request #17367: [FLINK-24382][metrics] Do not compute recordsOut metric in SinkOperat…

flinkbot edited a comment on pull request #17367: URL: https://github.com/apache/flink/pull/17367#issuecomment-928966227 ## CI report: * 82ee22fc68368972162785a3d390b0d39bfe0cfd Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17365: [hotfix][web]Modify the configuration of prettier

flinkbot edited a comment on pull request #17365: URL: https://github.com/apache/flink/pull/17365#issuecomment-928705859 ## CI report: * d35102d44dd7a89b1fb54e2ffad73ecc61f3df37 Azure:

[GitHub] [flink] flinkbot commented on pull request #17374: [FLINK-24327][connectors/elasticsearch] Add Elasticsearch 7 sink for table API

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

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

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

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

zentol commented on pull request #14544: URL: https://github.com/apache/flink/pull/14544#issuecomment-929130616 > The scala 2.12 profile in flink-end-to-end-tests, flink-avro can be removed. This point was not addressed. -- This is an automated message from the Apache Git

[jira] [Closed] (FLINK-7156) Re-enabled external jar ScalaShellITCase

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

[jira] [Updated] (FLINK-24327) Integrate Elasticsearch 7 sink with Table API

[ https://issues.apache.org/jira/browse/FLINK-24327?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-24327: --- Labels: pull-request-available (was: ) > Integrate Elasticsearch 7 sink with Table API >

[GitHub] [flink] alpreu opened a new pull request #17374: [FLINK-24327][connectors/elasticsearch] Add Elasticsearch 7 sink for table API

alpreu opened a new pull request #17374: URL: https://github.com/apache/flink/pull/17374 ## What is the purpose of the change Integrate the Elasticsearch 7 sink based on the new sink framework with the table API 1dc297a and f466b35 need no review as they will be part of

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

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

[jira] [Commented] (FLINK-24396) Add @Public annotations to Table & SQL API classes

[ https://issues.apache.org/jira/browse/FLINK-24396?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17421346#comment-17421346 ] Ingo Bürk commented on FLINK-24396: --- If we can get FLINK-24138 in before this, we could use that to

[jira] [Updated] (FLINK-24122) Add support to do clean in history server

[ https://issues.apache.org/jira/browse/FLINK-24122?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zlzhang0122 updated FLINK-24122: Description: Now, the history server can clean history jobs by two means: # if users have

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

NickBurkard commented on pull request #14544: URL: https://github.com/apache/flink/pull/14544#issuecomment-929111051 Thanks for the feedback @MartijnVisser & @zentol. I addressed each point, although I was hesitant to start removing methods from `JavaScalaConversionUtil` as its comment

[GitHub] [flink] flinkbot edited a comment on pull request #17365: [hotfix][web]Modify the configuration of prettier

flinkbot edited a comment on pull request #17365: URL: https://github.com/apache/flink/pull/17365#issuecomment-928705859 ## CI report: * d35102d44dd7a89b1fb54e2ffad73ecc61f3df37 Azure:

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

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

[GitHub] [flink] Airblader commented on pull request #17133: [Proof of Concept][FLINK-24138] Architectural tests

Airblader commented on pull request #17133: URL: https://github.com/apache/flink/pull/17133#issuecomment-929095947 FWIW, ensuring that all classes have such an annotation is something that, if at all, I'd do in Checkstyle because you really want that to be immediate feedback to reduce

[GitHub] [flink] Airblader commented on pull request #17133: [Proof of Concept][FLINK-24138] Architectural tests

Airblader commented on pull request #17133: URL: https://github.com/apache/flink/pull/17133#issuecomment-929092061 > Because of that I'm worried that we'd just end up slapping @PublicEvolving on everything While I understand what you're getting at, this is a human problem that

[GitHub] [flink-web] StephanEwen commented on pull request #468: Release blog post 1.14 draft iteration

StephanEwen commented on pull request #468: URL: https://github.com/apache/flink-web/pull/468#issuecomment-929091219 Thanks for all the comments. For the sake of getting this done, I will take the existing comments, but close this for new comments. -- This is an automated message from

[jira] [Updated] (FLINK-24394) Refactor scalar function testing infrastructure to allow testing multiple columns

[ https://issues.apache.org/jira/browse/FLINK-24394?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-24394: --- Labels: pull-request-available (was: ) > Refactor scalar function testing infrastructure

[GitHub] [flink] flinkbot edited a comment on pull request #17373: [hotfix] [docs-zh] Add auxiliary words to make the sentence flow smoothly

flinkbot edited a comment on pull request #17373: URL: https://github.com/apache/flink/pull/17373#issuecomment-929059546 ## CI report: * 7087c01013007684ad17ece6883636cd4c1db0d7 Azure:

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

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

[jira] [Assigned] (FLINK-24397) Reduce TableSchema usage in Table API connectors

[ https://issues.apache.org/jira/browse/FLINK-24397?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Paul reassigned FLINK-24397: --- Assignee: Fabian Paul > Reduce TableSchema usage in Table API connectors >

[jira] [Created] (FLINK-24397) Reduce TableSchema usage in Table API connectors

Fabian Paul created FLINK-24397: --- Summary: Reduce TableSchema usage in Table API connectors Key: FLINK-24397 URL: https://issues.apache.org/jira/browse/FLINK-24397 Project: Flink Issue Type:

[jira] [Commented] (FLINK-24387) Support a "to JSON" function

[ https://issues.apache.org/jira/browse/FLINK-24387?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17421319#comment-17421319 ] Ingo Bürk commented on FLINK-24387: --- I wasn't clear on that on the issue, but the name "TO_JSON"

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

dmvk commented on a change in pull request #468: URL: https://github.com/apache/flink-web/pull/468#discussion_r717460048 ## File path: _config.yml ## @@ -55,6 +55,27 @@ FLINK_STATEFUN_GITHUB_REPO_NAME: flink-statefun # md1_url:

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

dmvk commented on a change in pull request #468: URL: https://github.com/apache/flink-web/pull/468#discussion_r717459887 ## File path: _config.yml ## @@ -55,6 +55,27 @@ FLINK_STATEFUN_GITHUB_REPO_NAME: flink-statefun # md1_url:

[jira] [Commented] (FLINK-20714) Hive delegation token is not obtained when using `kinit` to submit Yarn per-job

[ https://issues.apache.org/jira/browse/FLINK-20714?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17421315#comment-17421315 ] Peidian Li commented on FLINK-20714: [~lirui] [~jackwangcs] Is there a conclusion on this question？ 

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

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

[jira] [Closed] (FLINK-24374) ManualCheckpointITCase.testTriggeringWhenPeriodicDisabled fails on azure

[ https://issues.apache.org/jira/browse/FLINK-24374?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-24374. Resolution: Fixed Fixed in 1261d66350dd3980eea41aa90cb155e304be2783 >

[GitHub] [flink] dawidwys merged pull request #17366: [FLINK-24374] Retry querying for checkpoint stats

dawidwys merged pull request #17366: URL: https://github.com/apache/flink/pull/17366 -- 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-24396) Add @Public annotations to Table & SQL API classes

[ https://issues.apache.org/jira/browse/FLINK-24396?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-24396: - Summary: Add @Public annotations to Table & SQL API classes (was: Add @Public annotations to

[jira] [Created] (FLINK-24396) Add @Public annotations to Table & SQL API

Timo Walther created FLINK-24396: Summary: Add @Public annotations to Table & SQL API Key: FLINK-24396 URL: https://issues.apache.org/jira/browse/FLINK-24396 Project: Flink Issue Type: New

[jira] [Updated] (FLINK-24392) Upgrade presto s3 fs implementation to Trino >= 348

[ https://issues.apache.org/jira/browse/FLINK-24392?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-24392: --- Description: The Presto s3 filesystem implementation currently shipped with Flink doesn't

[jira] [Updated] (FLINK-24392) Upgrade presto s3 fs implementation to Trino >= 348

[ https://issues.apache.org/jira/browse/FLINK-24392?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-24392: --- Summary: Upgrade presto s3 fs implementation to Trino >= 348 (was: Upgrade presto s3 fs

[GitHub] [flink] zentol commented on pull request #17133: [Proof of Concept][FLINK-24138] Architectural tests

zentol commented on pull request #17133: URL: https://github.com/apache/flink/pull/17133#issuecomment-929064318 > Would it make sense to enforce that all **public** classes are required to have a visibility annotation I'm not sure. On the one hand it forces the dev to make a

[jira] [Updated] (FLINK-24395) Checkpoint trigger time difference between log statement and web frontend

[ https://issues.apache.org/jira/browse/FLINK-24395?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-24395: --- Description: Consider this checkpoint (68) {code} 2021-09-28 10:14:43,644 INFO

[jira] [Created] (FLINK-24395) Checkpoint trigger time difference between log statement and web frontend

Robert Metzger created FLINK-24395: -- Summary: Checkpoint trigger time difference between log statement and web frontend Key: FLINK-24395 URL: https://issues.apache.org/jira/browse/FLINK-24395

[jira] [Updated] (FLINK-24395) Checkpoint trigger time difference between log statement and web frontend

[ https://issues.apache.org/jira/browse/FLINK-24395?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-24395: --- Issue Type: Bug (was: Improvement) > Checkpoint trigger time difference between log

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

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

[jira] [Updated] (FLINK-14383) Support python UDFs with constant value of time interval types

[ https://issues.apache.org/jira/browse/FLINK-14383?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-14383: - Fix Version/s: (was: 1.14.0) 1.15.0 > Support python UDFs with constant

[jira] [Created] (FLINK-24394) Refactor scalar function testing infrastructure to allow testing multiple columns

Marios Trivyzas created FLINK-24394: --- Summary: Refactor scalar function testing infrastructure to allow testing multiple columns Key: FLINK-24394 URL: https://issues.apache.org/jira/browse/FLINK-24394

[jira] [Updated] (FLINK-16154) Translate "Operator/Join" into Chinese

[ https://issues.apache.org/jira/browse/FLINK-16154?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-16154: - Fix Version/s: (was: 1.14.0) 1.15.0 > Translate "Operator/Join" into

[jira] [Updated] (FLINK-16388) Bump orc-core to 1.4.5

[ https://issues.apache.org/jira/browse/FLINK-16388?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-16388: - Fix Version/s: (was: 1.14.0) 1.15.0 > Bump orc-core to 1.4.5 >

[jira] [Updated] (FLINK-16153) Translate "Operator/windows" into Chinese

[ https://issues.apache.org/jira/browse/FLINK-16153?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-16153: - Fix Version/s: (was: 1.14.0) 1.15.0 > Translate "Operator/windows" into

[jira] [Updated] (FLINK-16155) Translate "Operator/Process Function" into Chinese

[ https://issues.apache.org/jira/browse/FLINK-16155?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-16155: - Fix Version/s: (was: 1.14.0) 1.15.0 > Translate "Operator/Process

[jira] [Updated] (FLINK-16152) Translate "Operator/index" into Chinese

[ https://issues.apache.org/jira/browse/FLINK-16152?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-16152: - Fix Version/s: (was: 1.14.0) 1.15.0 > Translate "Operator/index" into

[jira] [Updated] (FLINK-16126) Translate all connector related pages into Chinese

[ https://issues.apache.org/jira/browse/FLINK-16126?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-16126: - Fix Version/s: (was: 1.14.0) 1.15.0 > Translate all connector related

[jira] [Updated] (FLINK-16137) Translate all DataStream API related pages into Chinese

[ https://issues.apache.org/jira/browse/FLINK-16137?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-16137: - Fix Version/s: (was: 1.14.0) 1.15.0 > Translate all DataStream API

[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 ] Xintong Song updated FLINK-16077: - Fix Version/s: (was: 1.14.0) 1.15.0 > Translate "Custom State

[jira] [Updated] (FLINK-16078) Translate "Tuning Checkpoints and Large State" page into Chinese

[ https://issues.apache.org/jira/browse/FLINK-16078?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-16078: - Fix Version/s: (was: 1.14.0) 1.15.0 > Translate "Tuning Checkpoints and

[jira] [Updated] (FLINK-16073) Translate "State & Fault Tolerance" pages into Chinese

[ https://issues.apache.org/jira/browse/FLINK-16073?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-16073: - Fix Version/s: (was: 1.14.0) 1.15.0 > Translate "State & Fault

[jira] [Updated] (FLINK-15532) Enable strict capacity limit for memory usage for RocksDB

[ https://issues.apache.org/jira/browse/FLINK-15532?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-15532: - Fix Version/s: (was: 1.14.0) 1.15.0 > Enable strict capacity limit for

[jira] [Updated] (FLINK-15507) Activate local recovery for RocksDB backends by default

[ https://issues.apache.org/jira/browse/FLINK-15507?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-15507: - Fix Version/s: (was: 1.14.0) 1.15.0 > Activate local recovery for

[jira] [Updated] (FLINK-15493) FlinkKafkaInternalProducerITCase.testProducerWhenCommitEmptyPartitionsToOutdatedTxnCoordinator failed on travis

[ https://issues.apache.org/jira/browse/FLINK-15493?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-15493: - Fix Version/s: (was: 1.14.0) 1.14.1 >

[jira] [Updated] (FLINK-15123) remove uniqueKeys from FlinkStatistic in blink planner

[ https://issues.apache.org/jira/browse/FLINK-15123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-15123: - Fix Version/s: 1.15.0 > remove uniqueKeys from FlinkStatistic in blink planner >

[jira] [Updated] (FLINK-15123) remove uniqueKeys from FlinkStatistic in blink planner

[ https://issues.apache.org/jira/browse/FLINK-15123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-15123: - Fix Version/s: (was: 1.14.0) > remove uniqueKeys from FlinkStatistic in blink planner >

[jira] [Updated] (FLINK-14920) Set up environment to run performance e2e tests

[ https://issues.apache.org/jira/browse/FLINK-14920?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-14920: - Fix Version/s: (was: 1.14.0) 1.15.0 > Set up environment to run

[jira] [Updated] (FLINK-14971) Make all the non-IO operations in CheckpointCoordinator single-threaded

[ https://issues.apache.org/jira/browse/FLINK-14971?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-14971: - Fix Version/s: (was: 1.14.0) 1.15.0 > Make all the non-IO operations in

[jira] [Updated] (FLINK-14471) Hide error message when metric api failed

[ https://issues.apache.org/jira/browse/FLINK-14471?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-14471: - Fix Version/s: (was: 1.14.0) 1.15.0 > Hide error message when metric api

[jira] [Updated] (FLINK-14918) Add performance e2e test module and scripts

[ https://issues.apache.org/jira/browse/FLINK-14918?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-14918: - Fix Version/s: (was: 1.14.0) 1.15.0 > Add performance e2e test module

[jira] [Updated] (FLINK-14222) Optimize for Python UDFs with all parameters are constant values

[ https://issues.apache.org/jira/browse/FLINK-14222?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-14222: - Fix Version/s: (was: 1.14.0) 1.15.0 > Optimize for Python UDFs with all

[jira] [Commented] (FLINK-24387) Support a "to JSON" function

[ https://issues.apache.org/jira/browse/FLINK-24387?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17421294#comment-17421294 ] Francesco Guardiani commented on FLINK-24387: - Perhaps the name should be just JSON or

[jira] [Created] (FLINK-24393) Add tests for all currently supported cast combinations

Marios Trivyzas created FLINK-24393: --- Summary: Add tests for all currently supported cast combinations Key: FLINK-24393 URL: https://issues.apache.org/jira/browse/FLINK-24393 Project: Flink

[jira] [Updated] (FLINK-14122) Extend State Processor API to read ListCheckpointed operator state

[ https://issues.apache.org/jira/browse/FLINK-14122?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-14122: - Fix Version/s: (was: 1.14.0) 1.15.0 > Extend State Processor API to read

[jira] [Updated] (FLINK-14028) Support to configure the log level of the Python user-defined functions

[ https://issues.apache.org/jira/browse/FLINK-14028?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-14028: - Fix Version/s: (was: 1.14.0) 1.15.0 > Support to configure the log level

[jira] [Updated] (FLINK-14148) Investigate pushing predicate/projection to underlying Hive input format

[ https://issues.apache.org/jira/browse/FLINK-14148?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-14148: - Fix Version/s: (was: 1.14.0) 1.15.0 > Investigate pushing

[jira] [Updated] (FLINK-12692) Support disk spilling in HeapKeyedStateBackend

[ https://issues.apache.org/jira/browse/FLINK-12692?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-12692: - Fix Version/s: (was: 1.14.0) 1.15.0 > Support disk spilling in

[jira] [Updated] (FLINK-14023) Support accessing job parameters in Python user-defined functions

[ https://issues.apache.org/jira/browse/FLINK-14023?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-14023: - Fix Version/s: (was: 1.14.0) 1.15.0 > Support accessing job parameters

[jira] [Updated] (FLINK-11937) Resolve small file problem in RocksDB incremental checkpoint

[ https://issues.apache.org/jira/browse/FLINK-11937?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-11937: - Fix Version/s: (was: 1.14.0) 1.15.0 > Resolve small file problem in

[jira] [Updated] (FLINK-12352) [FLIP-36] [Phase 1] Support cache() / invalidateCache() in Table with default ShuffleService and NetworkStack

[ https://issues.apache.org/jira/browse/FLINK-12352?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-12352: - Fix Version/s: (was: 1.14.0) 1.15.0 > [FLIP-36] [Phase 1] Support

[jira] [Updated] (FLINK-24241) test_table_environment_api.py fail with NPE

[ https://issues.apache.org/jira/browse/FLINK-24241?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-24241: - Fix Version/s: (was: 1.14.0) 1.14.1 > test_table_environment_api.py fail

[jira] [Updated] (FLINK-24038) DispatcherResourceManagerComponent fails to deregister application if no leading ResourceManager

[ https://issues.apache.org/jira/browse/FLINK-24038?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-24038: - Fix Version/s: 1.14.1 > DispatcherResourceManagerComponent fails to deregister application if

[jira] [Updated] (FLINK-9477) FLIP-90: Support SQL 2016 JSON functions in Flink SQL

[ https://issues.apache.org/jira/browse/FLINK-9477?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-9477: Fix Version/s: (was: 1.14.0) 1.15.0 > FLIP-90: Support SQL 2016 JSON

[jira] [Updated] (FLINK-24038) DispatcherResourceManagerComponent fails to deregister application if no leading ResourceManager

[ https://issues.apache.org/jira/browse/FLINK-24038?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-24038: - Fix Version/s: (was: 1.14.0) 1.15.0 > DispatcherResourceManagerComponent

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

[ https://issues.apache.org/jira/browse/FLINK-23944?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-23944: - Fix Version/s: (was: 1.14.0) 1.14.1 >

[jira] [Updated] (FLINK-23932) KafkaTableITKafkaTableITCase.testKafkaSourceSinkWithKeyAndPartialValue hangs on AzureCase

[ https://issues.apache.org/jira/browse/FLINK-23932?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-23932: - Fix Version/s: (was: 1.14.0) 1.14.1 1.15.0 >

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

[ https://issues.apache.org/jira/browse/FLINK-23828?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-23828: - Fix Version/s: (was: 1.14.0) 1.14.1 1.15.0 >

[jira] [Updated] (FLINK-23843) Exceptions during "SplitEnumeratorContext.runInCoordinatorThread()" should cause Global Failure instead of Process Kill

[ https://issues.apache.org/jira/browse/FLINK-23843?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-23843: - Fix Version/s: (was: 1.14.0) 1.15.0 > Exceptions during

[jira] [Updated] (FLINK-22735) HiveTableSourceITCase.testStreamPartitionReadByCreateTime failed because of times out

[ https://issues.apache.org/jira/browse/FLINK-22735?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-22735: - Fix Version/s: (was: 1.14.0) 1.14.1 1.15.0 >

[jira] [Updated] (FLINK-23778) UpsertKafkaTableITCase.testKafkaSourceSinkWithKeyAndFullValue hangs on Azure

[ https://issues.apache.org/jira/browse/FLINK-23778?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-23778: - Fix Version/s: (was: 1.14.0) 1.14.1 1.15.0 >

[jira] [Updated] (FLINK-20498) SQLClientSchemaRegistryITCase.testReading test timed out after 120000 milliseconds

[ https://issues.apache.org/jira/browse/FLINK-20498?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-20498: - Fix Version/s: (was: 1.14.0) 1.14.1 1.15.0 >

[jira] [Updated] (FLINK-22113) UniqueKey constraint is lost with multiple sources join in SQL

[ https://issues.apache.org/jira/browse/FLINK-22113?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-22113: - Fix Version/s: (was: 1.14.0) 1.14.1 1.15.0 >

[jira] [Updated] (FLINK-20928) KafkaSourceReaderTest.testOffsetCommitOnCheckpointComplete:189->pollUntil:270 » Timeout

[ https://issues.apache.org/jira/browse/FLINK-20928?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-20928: - Fix Version/s: (was: 1.14.0) 1.14.1 1.15.0 >

[jira] [Updated] (FLINK-18356) Exit code 137 returned from process

[ https://issues.apache.org/jira/browse/FLINK-18356?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-18356: - Fix Version/s: (was: 1.14.0) 1.14.1 1.15.0 > Exit

[GitHub] [flink] flinkbot commented on pull request #17373: [hotfix] [docs-zh] Add auxiliary words to make the sentence flow smoothly

flinkbot commented on pull request #17373: URL: https://github.com/apache/flink/pull/17373#issuecomment-929038094 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] LB-Yu opened a new pull request #17373: [hotfix] [docs-zh] Add auxiliary words to make the sentence flow smoothly

LB-Yu opened a new pull request #17373: URL: https://github.com/apache/flink/pull/17373 ## What is the purpose of the change The first sentence of the flink Chinese document homepage is not fluent, and an auxiliary word is added to make it fluent. ## Brief change

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

CrynetLogistics closed pull request #17349: URL: https://github.com/apache/flink/pull/17349 -- 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] CrynetLogistics commented on pull request #17349: [FLINK-24370][documentation] Added documentation for Asynchronous Sin…

CrynetLogistics commented on pull request #17349: URL: https://github.com/apache/flink/pull/17349#issuecomment-929036278 Wonderful, we have consensus. Thank you @sjwiesman, @MartijnVisser and @infoverload for your comments. I am happy to add this information to a blog post and JavaDocs.

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

infoverload commented on pull request #17349: URL: https://github.com/apache/flink/pull/17349#issuecomment-929033854 After reading through the issue and the changes, I also think that a combination of JavaDocs and creating a blog post is a good idea -- This is an automated message from

[GitHub] [flink] flinkbot commented on pull request #17371: [BP-1.13][FLINK-24380][k8s] Terminate the pod if it failed

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

[GitHub] [flink] flinkbot commented on pull request #17372: [BP-1.13][FLINK-24377][runtime] Fix TM potentially not released after heartbeat timeout.

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

[GitHub] [flink] flinkbot commented on pull request #17370: [BP-1.14][FLINK-24380][k8s] Terminate the pod if it failed

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

[GitHub] [flink] flinkbot commented on pull request #17369: [FLINK-19792][table-planner] Fix IntervalJoin with time equality predicate

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

[GitHub] [flink] flinkbot commented on pull request #17368: [hotfix] Add a docs page with module specific guides for flink contributors

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

[GitHub] [flink] slinkydeveloper edited a comment on pull request #17368: [hotfix] Add a docs page with module specific guides for flink contributors

slinkydeveloper edited a comment on pull request #17368: URL: https://github.com/apache/flink/pull/17368#issuecomment-929022468 @Airblader yep it seems like, perhaps I can modify the page you linked to be more "generic", and not specific to code style? Or do you have something else in

[GitHub] [flink] slinkydeveloper commented on pull request #17368: [hotfix] Add a docs page with module specific guides for flink contributors

slinkydeveloper commented on pull request #17368: URL: https://github.com/apache/flink/pull/17368#issuecomment-929022468 @Airblader yep it seems like, perhaps I can modify the page you linked to be more "generic", and not specific to code style? -- This is an automated message from the

[GitHub] [flink] flinkbot commented on pull request #17372: [BP-1.13][FLINK-24377][runtime] Fix TM potentially not released after heartbeat timeout.

flinkbot commented on pull request #17372: URL: https://github.com/apache/flink/pull/17372#issuecomment-929019851 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 #17370: [BP-1.14][FLINK-24380][k8s] Terminate the pod if it failed

flinkbot commented on pull request #17370: URL: https://github.com/apache/flink/pull/17370#issuecomment-929018048 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 #17371: [BP-1.13][FLINK-24380][k8s] Terminate the pod if it failed

flinkbot commented on pull request #17371: URL: https://github.com/apache/flink/pull/17371#issuecomment-929018020 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] KarmaGYZ opened a new pull request #17371: [BP-1.13][FLINK-24380][k8s] Terminate the pod if it failed

KarmaGYZ opened a new pull request #17371: URL: https://github.com/apache/flink/pull/17371 ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob server, rather than through RPC. That way we avoid re-transferring them

<    3   4   5   6   7   8   9   >