[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=17321383#comment-17321383 ] Flink Jira Bot commented on FLINK-17584: This issue and all of its Sub-Tasks have not been

[jira] [Updated] (FLINK-17588) Throw exception when hadoop jar is missing in flink scala's yarn mode.

[ https://issues.apache.org/jira/browse/FLINK-17588?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-17588: --- Labels: pull-request-available stale-minor (was: pull-request-available) > Throw exception

[jira] [Commented] (FLINK-16872) Flink UI shows server error on selecting back pressure on a batch job

[ https://issues.apache.org/jira/browse/FLINK-16872?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321391#comment-17321391 ] Flink Jira Bot commented on FLINK-16872: This issue and all of its Sub-Tasks have not been

[jira] [Commented] (FLINK-17409) SqlCreateView's SqlParserPos return wrong value

[ https://issues.apache.org/jira/browse/FLINK-17409?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321387#comment-17321387 ] Flink Jira Bot commented on FLINK-17409: This issue and all of its Sub-Tasks have not been

[jira] [Updated] (FLINK-16869) Flink UI does not show version

[ https://issues.apache.org/jira/browse/FLINK-16869?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-16869: --- Labels: stale-minor (was: ) > Flink UI does not show version >

[jira] [Updated] (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:all-tabpanel ] Flink Jira Bot updated FLINK-17584: --- Labels: stale-minor (was: ) > disableAutoTypeRegistration option does not work with

[jira] [Updated] (FLINK-17583) Allow option to store a savepoint's _metadata file separate from its data files

[ https://issues.apache.org/jira/browse/FLINK-17583?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-17583: --- Labels: stale-minor (was: ) > Allow option to store a savepoint's _metadata file separate

[jira] [Updated] (FLINK-17690) Python function wrapper omits docstr

[ https://issues.apache.org/jira/browse/FLINK-17690?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-17690: --- Labels: pull-request-available stale-minor (was: pull-request-available) > Python function

[jira] [Updated] (FLINK-17409) SqlCreateView's SqlParserPos return wrong value

[ https://issues.apache.org/jira/browse/FLINK-17409?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-17409: --- Labels: stale-minor (was: ) > SqlCreateView's SqlParserPos return wrong value >

[jira] [Commented] (FLINK-17884) package the codegen directory to flink-sql-parser jar

[ https://issues.apache.org/jira/browse/FLINK-17884?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321380#comment-17321380 ] Flink Jira Bot commented on FLINK-17884: This issue and all of its Sub-Tasks have not been

[jira] [Updated] (FLINK-16920) Flink UI cancel uses an undocumented rest api and uses GET rather than a mutating HTTP method

[ https://issues.apache.org/jira/browse/FLINK-16920?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-16920: --- Labels: stale-minor (was: ) > Flink UI cancel uses an undocumented rest api and uses GET

[jira] [Updated] (FLINK-17444) StreamingFileSink Azure HadoopRecoverableWriter class missing.

[ https://issues.apache.org/jira/browse/FLINK-17444?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-17444: --- Labels: stale-minor (was: ) > StreamingFileSink Azure HadoopRecoverableWriter class

[jira] [Updated] (FLINK-18221) SQL client YAML validation incomplete

[ https://issues.apache.org/jira/browse/FLINK-18221?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-18221: --- Labels: stale-minor (was: ) > SQL client YAML validation incomplete >

[jira] [Commented] (FLINK-17588) Throw exception when hadoop jar is missing in flink scala's yarn mode.

[ https://issues.apache.org/jira/browse/FLINK-17588?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321382#comment-17321382 ] Flink Jira Bot commented on FLINK-17588: This issue and all of its Sub-Tasks have not been

[jira] [Commented] (FLINK-17966) Documentation improvement of checkpointing API

[ https://issues.apache.org/jira/browse/FLINK-17966?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321379#comment-17321379 ] Flink Jira Bot commented on FLINK-17966: This issue and all of its Sub-Tasks have not been

[jira] [Commented] (FLINK-18054) Environment should provide API to resume from savepoint

[ https://issues.apache.org/jira/browse/FLINK-18054?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321378#comment-17321378 ] Flink Jira Bot commented on FLINK-18054: This issue and all of its Sub-Tasks have not been

[jira] [Updated] (FLINK-17966) Documentation improvement of checkpointing API

[ https://issues.apache.org/jira/browse/FLINK-17966?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-17966: --- Labels: stale-minor (was: ) > Documentation improvement of checkpointing API >

[jira] [Commented] (FLINK-18504) Mismatch between CsvTableSource constructor and builder params

[ https://issues.apache.org/jira/browse/FLINK-18504?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321375#comment-17321375 ] Flink Jira Bot commented on FLINK-18504: This issue and all of its Sub-Tasks have not been

[jira] [Updated] (FLINK-18054) Environment should provide API to resume from savepoint

[ https://issues.apache.org/jira/browse/FLINK-18054?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-18054: --- Labels: stale-minor (was: ) > Environment should provide API to resume from savepoint >

[jira] [Commented] (FLINK-17574) Deduplicate the process execution logic in Flink

[ https://issues.apache.org/jira/browse/FLINK-17574?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321385#comment-17321385 ] Flink Jira Bot commented on FLINK-17574: This issue and all of its Sub-Tasks have not been

[jira] [Commented] (FLINK-18095) Custom Execution Environment for TableEnvironment

[ https://issues.apache.org/jira/browse/FLINK-18095?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321377#comment-17321377 ] Flink Jira Bot commented on FLINK-18095: This issue and all of its Sub-Tasks have not been

[jira] [Updated] (FLINK-17324) Move the image we use to generate the docker official-images changes into flink-docker

[ https://issues.apache.org/jira/browse/FLINK-17324?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-17324: --- Labels: stale-minor (was: ) > Move the image we use to generate the docker official-images

[jira] [Updated] (FLINK-18095) Custom Execution Environment for TableEnvironment

[ https://issues.apache.org/jira/browse/FLINK-18095?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-18095: --- Labels: stale-minor (was: ) > Custom Execution Environment for TableEnvironment >

[jira] [Commented] (FLINK-17444) StreamingFileSink Azure HadoopRecoverableWriter class missing.

[ https://issues.apache.org/jira/browse/FLINK-17444?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321386#comment-17321386 ] Flink Jira Bot commented on FLINK-17444: This issue and all of its Sub-Tasks have not been

[jira] [Updated] (FLINK-18597) elasticsearch sql insert function cannot set documentid

[ https://issues.apache.org/jira/browse/FLINK-18597?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-18597: --- Labels: stale-minor (was: ) > elasticsearch sql insert function cannot set documentid >

[jira] [Commented] (FLINK-17690) Python function wrapper omits docstr

[ https://issues.apache.org/jira/browse/FLINK-17690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321381#comment-17321381 ] Flink Jira Bot commented on FLINK-17690: This issue and all of its Sub-Tasks have not been

[jira] [Updated] (FLINK-18504) Mismatch between CsvTableSource constructor and builder params

[ https://issues.apache.org/jira/browse/FLINK-18504?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-18504: --- Labels: stale-minor (was: ) > Mismatch between CsvTableSource constructor and builder

[jira] [Updated] (FLINK-17884) package the codegen directory to flink-sql-parser jar

[ https://issues.apache.org/jira/browse/FLINK-17884?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-17884: --- Labels: stale-minor (was: ) > package the codegen directory to flink-sql-parser jar >

[jira] [Updated] (FLINK-18609) The user-defined jdbc-source process before add window ,job finished early.

[ https://issues.apache.org/jira/browse/FLINK-18609?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-18609: --- Labels: stale-minor (was: ) > The user-defined jdbc-source process before add window ,job

[jira] [Commented] (FLINK-18597) elasticsearch sql insert function cannot set documentid

[ https://issues.apache.org/jira/browse/FLINK-18597?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321374#comment-17321374 ] Flink Jira Bot commented on FLINK-18597: This issue and all of its Sub-Tasks have not been

[jira] [Commented] (FLINK-18609) The user-defined jdbc-source process before add window ,job finished early.

[ https://issues.apache.org/jira/browse/FLINK-18609?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321373#comment-17321373 ] Flink Jira Bot commented on FLINK-18609: This issue and all of its Sub-Tasks have not been

[jira] [Commented] (FLINK-18221) SQL client YAML validation incomplete

[ https://issues.apache.org/jira/browse/FLINK-18221?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321376#comment-17321376 ] Flink Jira Bot commented on FLINK-18221: This issue and all of its Sub-Tasks have not been

[jira] [Commented] (FLINK-18645) Add community driven SDKs to StateFun documentations.

[ https://issues.apache.org/jira/browse/FLINK-18645?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321371#comment-17321371 ] Flink Jira Bot commented on FLINK-18645: This issue and all of its Sub-Tasks have not been

[jira] [Updated] (FLINK-18611) Include `m` as time unit expression for MINUTE in SQL

[ https://issues.apache.org/jira/browse/FLINK-18611?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-18611: --- Labels: stale-minor (was: ) > Include `m` as time unit expression for MINUTE in SQL >

[jira] [Commented] (FLINK-18611) Include `m` as time unit expression for MINUTE in SQL

[ https://issues.apache.org/jira/browse/FLINK-18611?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321372#comment-17321372 ] Flink Jira Bot commented on FLINK-18611: This issue and all of its Sub-Tasks have not been

[jira] [Updated] (FLINK-18645) Add community driven SDKs to StateFun documentations.

[ https://issues.apache.org/jira/browse/FLINK-18645?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-18645: --- Labels: stale-minor (was: ) > Add community driven SDKs to StateFun documentations. >

[jira] [Updated] (FLINK-19580) Creating PackagedProgram overwrites an actual job name with default JobName

[ https://issues.apache.org/jira/browse/FLINK-19580?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-19580: --- Labels: stale-minor (was: ) > Creating PackagedProgram overwrites an actual job name with

[jira] [Commented] (FLINK-18909) SequenceGenerator doesn't work as expected

[ https://issues.apache.org/jira/browse/FLINK-18909?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321368#comment-17321368 ] Flink Jira Bot commented on FLINK-18909: This issue and all of its Sub-Tasks have not been

[jira] [Updated] (FLINK-19198) Invalid default value for consume-start-offset in Hive streaming

[ https://issues.apache.org/jira/browse/FLINK-19198?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-19198: --- Labels: stale-minor (was: ) > Invalid default value for consume-start-offset in Hive

[jira] [Updated] (FLINK-18707) Calling remove() for RockDB ListState iterator does nothing

[ https://issues.apache.org/jira/browse/FLINK-18707?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-18707: --- Labels: stale-minor (was: ) > Calling remove() for RockDB ListState iterator does nothing

[jira] [Commented] (FLINK-19029) Collect mulitple jobs in 1 UI

[ https://issues.apache.org/jira/browse/FLINK-19029?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321367#comment-17321367 ] Flink Jira Bot commented on FLINK-19029: This issue and all of its Sub-Tasks have not been

[jira] [Updated] (FLINK-19164) Release scripts break other dependency versions unintentionally

[ https://issues.apache.org/jira/browse/FLINK-19164?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-19164: --- Labels: stale-minor (was: ) > Release scripts break other dependency versions

[jira] [Commented] (FLINK-18707) Calling remove() for RockDB ListState iterator does nothing

[ https://issues.apache.org/jira/browse/FLINK-18707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321370#comment-17321370 ] Flink Jira Bot commented on FLINK-18707: This issue and all of its Sub-Tasks have not been

[jira] [Updated] (FLINK-18909) SequenceGenerator doesn't work as expected

[ https://issues.apache.org/jira/browse/FLINK-18909?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-18909: --- Labels: stale-minor (was: ) > SequenceGenerator doesn't work as expected >

[jira] [Updated] (FLINK-19051) Exception message should be reserved in log When the Job Manager failed

[ https://issues.apache.org/jira/browse/FLINK-19051?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-19051: --- Labels: stale-minor (was: ) > Exception message should be reserved in log When the Job

[jira] [Commented] (FLINK-19051) Exception message should be reserved in log When the Job Manager failed

[ https://issues.apache.org/jira/browse/FLINK-19051?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321366#comment-17321366 ] Flink Jira Bot commented on FLINK-19051: This issue and all of its Sub-Tasks have not been

[jira] [Updated] (FLINK-19029) Collect mulitple jobs in 1 UI

[ https://issues.apache.org/jira/browse/FLINK-19029?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-19029: --- Labels: stale-minor (was: ) > Collect mulitple jobs in 1 UI >

[jira] [Commented] (FLINK-19283) Allow subclasses to override/extend FlinkKafkaConsumerBase checkpoint methods

[ https://issues.apache.org/jira/browse/FLINK-19283?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321361#comment-17321361 ] Flink Jira Bot commented on FLINK-19283: This issue and all of its Sub-Tasks have not been

[jira] [Commented] (FLINK-19139) flink-conf.yml read values from environment variables

[ https://issues.apache.org/jira/browse/FLINK-19139?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321365#comment-17321365 ] Flink Jira Bot commented on FLINK-19139: This issue and all of its Sub-Tasks have not been

[jira] [Updated] (FLINK-19209) Single bucket

[ https://issues.apache.org/jira/browse/FLINK-19209?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-19209: --- Labels: stale-minor (was: ) > Single bucket > - > > Key:

[jira] [Commented] (FLINK-18845) class not found exception when i use sql client to try mysql as datasource.

[ https://issues.apache.org/jira/browse/FLINK-18845?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321369#comment-17321369 ] Flink Jira Bot commented on FLINK-18845: This issue and all of its Sub-Tasks have not been

[jira] [Updated] (FLINK-18845) class not found exception when i use sql client to try mysql as datasource.

[ https://issues.apache.org/jira/browse/FLINK-18845?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-18845: --- Labels: stale-minor (was: ) > class not found exception when i use sql client to try mysql

[jira] [Commented] (FLINK-19443) runtime function 'splitIndex'

[ https://issues.apache.org/jira/browse/FLINK-19443?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321358#comment-17321358 ] Flink Jira Bot commented on FLINK-19443: This issue and all of its Sub-Tasks have not been

[jira] [Commented] (FLINK-19580) Creating PackagedProgram overwrites an actual job name with default JobName

[ https://issues.apache.org/jira/browse/FLINK-19580?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321357#comment-17321357 ] Flink Jira Bot commented on FLINK-19580: This issue and all of its Sub-Tasks have not been

[jira] [Commented] (FLINK-19164) Release scripts break other dependency versions unintentionally

[ https://issues.apache.org/jira/browse/FLINK-19164?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321364#comment-17321364 ] Flink Jira Bot commented on FLINK-19164: This issue and all of its Sub-Tasks have not been

[jira] [Updated] (FLINK-19139) flink-conf.yml read values from environment variables

[ https://issues.apache.org/jira/browse/FLINK-19139?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-19139: --- Labels: stale-minor (was: ) > flink-conf.yml read values from environment variables >

[jira] [Updated] (FLINK-19443) runtime function 'splitIndex'

[ https://issues.apache.org/jira/browse/FLINK-19443?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-19443: --- Labels: stale-minor (was: ) > runtime function 'splitIndex' >

[jira] [Updated] (FLINK-19359) Restore from Checkpoint fails if checkpoint folders is corrupt/partial

[ https://issues.apache.org/jira/browse/FLINK-19359?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-19359: --- Labels: stale-minor (was: ) > Restore from Checkpoint fails if checkpoint folders is

[jira] [Commented] (FLINK-19359) Restore from Checkpoint fails if checkpoint folders is corrupt/partial

[ https://issues.apache.org/jira/browse/FLINK-19359?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321360#comment-17321360 ] Flink Jira Bot commented on FLINK-19359: This issue and all of its Sub-Tasks have not been

[jira] [Commented] (FLINK-19198) Invalid default value for consume-start-offset in Hive streaming

[ https://issues.apache.org/jira/browse/FLINK-19198?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321363#comment-17321363 ] Flink Jira Bot commented on FLINK-19198: This issue and all of its Sub-Tasks have not been

[jira] [Commented] (FLINK-19373) Update documentation

[ https://issues.apache.org/jira/browse/FLINK-19373?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321359#comment-17321359 ] Flink Jira Bot commented on FLINK-19373: This issue and all of its Sub-Tasks have not been

[jira] [Commented] (FLINK-19209) Single bucket

[ https://issues.apache.org/jira/browse/FLINK-19209?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321362#comment-17321362 ] Flink Jira Bot commented on FLINK-19209: This issue and all of its Sub-Tasks have not been

[jira] [Updated] (FLINK-19373) Update documentation

[ https://issues.apache.org/jira/browse/FLINK-19373?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-19373: --- Labels: stale-minor (was: ) > Update documentation > > >

[jira] [Updated] (FLINK-19593) FlinkKafkaInternalProducer should be @Internal annotation ?

[ https://issues.apache.org/jira/browse/FLINK-19593?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-19593: --- Labels: stale-minor (was: ) > FlinkKafkaInternalProducer should be @Internal annotation ?

[jira] [Commented] (FLINK-19593) FlinkKafkaInternalProducer should be @Internal annotation ?

[ https://issues.apache.org/jira/browse/FLINK-19593?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321356#comment-17321356 ] Flink Jira Bot commented on FLINK-19593: This issue and all of its Sub-Tasks have not been

[jira] [Closed] (FLINK-21859) Outdated slot offer responses may release slot prematurely

[ https://issues.apache.org/jira/browse/FLINK-21859?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-21859. Resolution: Fixed master: c9fd6955630d320fce42cc36abe98a5eb65fd1b8 > Outdated slot offer

[GitHub] [flink] zentol merged pull request #15612: [FLINK-21859][coordination] Ignore outdated slot offer responses

zentol merged pull request #15612: URL: https://github.com/apache/flink/pull/15612 -- 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. For queries about this service, please

[GitHub] [flink] flinkbot edited a comment on pull request #15605: [FLINK-21996][coordination] - Part 3&4: Ensure OperatorEvent transport losses are handled

flinkbot edited a comment on pull request #15605: URL: https://github.com/apache/flink/pull/15605#issuecomment-819212302 ## CI report: * d2111f6d5a17e9263399aac7c188083c793b418d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15546: [FLINK-21346][build system] Adding timeout to all tasks

flinkbot edited a comment on pull request #15546: URL: https://github.com/apache/flink/pull/15546#issuecomment-816538766 ## CI report: * 9ba7b41fa1c3ed4f8b8d6ab54e339bfa6b35da05 Azure:

[jira] [Updated] (FLINK-21720) Rework Documentation Style Guide for the new build system

[ https://issues.apache.org/jira/browse/FLINK-21720?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-21720: --- Labels: pull-request-available (was: ) > Rework Documentation Style Guide for the new

[GitHub] [flink-web] scherrca opened a new pull request #434: [FLINK-21720] Updates documentation style guides for the new (Hugo) build system

scherrca opened a new pull request #434: URL: https://github.com/apache/flink-web/pull/434 [FLINK-21720 Jira Ticket](https://issues.apache.org/jira/browse/FLINK-21720) ### Description The docs build recently changed from Jekyll to Hugo (FLIP-157), so this updates the [style

[GitHub] [flink] flinkbot edited a comment on pull request #15605: [FLINK-21996][coordination] - Part 3&4: Ensure OperatorEvent transport losses are handled

flinkbot edited a comment on pull request #15605: URL: https://github.com/apache/flink/pull/15605#issuecomment-819212302 ## CI report: * d2111f6d5a17e9263399aac7c188083c793b418d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15546: [FLINK-21346][build system] Adding timeout to all tasks

flinkbot edited a comment on pull request #15546: URL: https://github.com/apache/flink/pull/15546#issuecomment-816538766 ## CI report: * 9ba7b41fa1c3ed4f8b8d6ab54e339bfa6b35da05 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15601: [FLINK-18071][FLINK-21996][coordination] - Part two: Ensure reliable OperatorEvent to running Task matching

flinkbot edited a comment on pull request #15601: URL: https://github.com/apache/flink/pull/15601#issuecomment-819126497 ## CI report: * 017e4c685eeb6cb145ded8d3a22baf3868559896 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15606: [FLINK-22260][table-planner-blink] Use unresolvedSchema during operation convertions

flinkbot edited a comment on pull request #15606: URL: https://github.com/apache/flink/pull/15606#issuecomment-819310662 ## CI report: * 788226f24586e46f6a37643e4938a995ce58f25c Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15121: The method $(String) is undefined for the type TableExample

flinkbot edited a comment on pull request #15121: URL: https://github.com/apache/flink/pull/15121#issuecomment-793480240 ## CI report: * cf26ce895a7956d258acc073817f578558e78227 UNKNOWN * 709c4110370b845f42d916a06e56c6026cf2fac8 UNKNOWN *

[jira] [Commented] (FLINK-22276) ExceptionHistoryEntryExtractor throws fatal error when task failure

[ https://issues.apache.org/jira/browse/FLINK-22276?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321312#comment-17321312 ] Matthias commented on FLINK-22276: -- [~Thesharing] thanks for your analysis. I guess, you're right. The

[jira] [Commented] (FLINK-20420) ES6 ElasticsearchSinkITCase failed due to no output for 900 seconds

[ https://issues.apache.org/jira/browse/FLINK-20420?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321306#comment-17321306 ] Dawid Wysakowicz commented on FLINK-20420: --

[jira] [Commented] (FLINK-22085) KafkaSourceLegacyITCase hangs/fails on azure

[ https://issues.apache.org/jira/browse/FLINK-22085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321305#comment-17321305 ] Dawid Wysakowicz commented on FLINK-22085: --

[GitHub] [flink] flinkbot edited a comment on pull request #15611: [FLINK-22180][coordination] Only reclaim slots if job is removed

flinkbot edited a comment on pull request #15611: URL: https://github.com/apache/flink/pull/15611#issuecomment-819470188 ## CI report: * 27067ec841693c4c63b7ea4f5ffaa2ef6d1b51ac Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15606: [FLINK-22260][table-planner-blink] Use unresolvedSchema during operation convertions

flinkbot edited a comment on pull request #15606: URL: https://github.com/apache/flink/pull/15606#issuecomment-819310662 ## CI report: * Unknown: [CANCELED](TBD) * 788226f24586e46f6a37643e4938a995ce58f25c Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15546: [FLINK-21346][build system] Adding timeout to all tasks

flinkbot edited a comment on pull request #15546: URL: https://github.com/apache/flink/pull/15546#issuecomment-816538766 ## CI report: * 9ba7b41fa1c3ed4f8b8d6ab54e339bfa6b35da05 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15121: The method $(String) is undefined for the type TableExample

flinkbot edited a comment on pull request #15121: URL: https://github.com/apache/flink/pull/15121#issuecomment-793480240 ## CI report: * cf26ce895a7956d258acc073817f578558e78227 UNKNOWN * 709c4110370b845f42d916a06e56c6026cf2fac8 UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on pull request #15611: [FLINK-22180][coordination] Only reclaim slots if job is removed

flinkbot edited a comment on pull request #15611: URL: https://github.com/apache/flink/pull/15611#issuecomment-819470188 ## CI report: * 27067ec841693c4c63b7ea4f5ffaa2ef6d1b51ac Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15612: [FLINK-21859][coordination] Ignore outdated slot offer responses

flinkbot edited a comment on pull request #15612: URL: https://github.com/apache/flink/pull/15612#issuecomment-819470321 ## CI report: * 08a1c4bc6e97f9f29d93958466c747a280d4cb10 UNKNOWN * 6abf3590f8ea6aa0244b82429dc7c57e2c5c5a7a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15606: [FLINK-22260][table-planner-blink] Use unresolvedSchema during operation convertions

flinkbot edited a comment on pull request #15606: URL: https://github.com/apache/flink/pull/15606#issuecomment-819310662 ## CI report: * Unknown: [CANCELED](TBD) * 788226f24586e46f6a37643e4938a995ce58f25c Azure:

[jira] [Commented] (FLINK-22259) UnalignedCheckpointITCase fails with "Value too large for header, this indicates that the test is running too long"

[ https://issues.apache.org/jira/browse/FLINK-22259?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321282#comment-17321282 ] Arvid Heise commented on FLINK-22259: - I guess the test assumes that the enumerator never fails (it

[jira] [Commented] (FLINK-22259) UnalignedCheckpointITCase fails with "Value too large for header, this indicates that the test is running too long"

[ https://issues.apache.org/jira/browse/FLINK-22259?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321280#comment-17321280 ] Arvid Heise commented on FLINK-22259: - It seems as if the {{SyncEvent}} is not sent from the

[jira] [Resolved] (FLINK-21992) Fix availability notification in UnionInputGate

[ https://issues.apache.org/jira/browse/FLINK-21992?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise resolved FLINK-21992. - Resolution: Fixed > Fix availability notification in UnionInputGate >

[jira] [Commented] (FLINK-21992) Fix availability notification in UnionInputGate

[ https://issues.apache.org/jira/browse/FLINK-21992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321279#comment-17321279 ] Arvid Heise commented on FLINK-21992: - Merged into 1.12 as e2cbfad6a3cdafe3d568bb43a1d048f9533b29ec.

[GitHub] [flink] AHeise merged pull request #15587: [FLINK-21992][network] Fix availability notification in UnionInputGate. [1.12]

AHeise merged pull request #15587: URL: https://github.com/apache/flink/pull/15587 -- 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. For queries about this service, please

[GitHub] [flink] flinkbot edited a comment on pull request #15611: [FLINK-22180][coordination] Only reclaim slots if job is removed

flinkbot edited a comment on pull request #15611: URL: https://github.com/apache/flink/pull/15611#issuecomment-819470188 ## CI report: * 27067ec841693c4c63b7ea4f5ffaa2ef6d1b51ac Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15589: [Flink-22248][Flink-22249] Harden JobMasterStopWithSavepointITCase

flinkbot edited a comment on pull request #15589: URL: https://github.com/apache/flink/pull/15589#issuecomment-818562022 ## CI report: * d3ddcf5ae33856edf855a55a43fdfe0782e9530e Azure:

[GitHub] [flink] Airblader commented on pull request #15606: [FLINK-22260][table-planner-blink] Use unresolvedSchema during operation convertions

Airblader commented on pull request #15606: URL: https://github.com/apache/flink/pull/15606#issuecomment-819763308 I had to revert one change to the tests in the setup stage where `TableSchema` / `CatalogTableImpl` are still used. The tables set up there (t1, t2) use a connector built

[jira] [Commented] (FLINK-22276) ExceptionHistoryEntryExtractor throws fatal error when task failure

[ https://issues.apache.org/jira/browse/FLINK-22276?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321235#comment-17321235 ] Matthias commented on FLINK-22276: -- I see, the {{RECOVERING}} was renamed into {{INITIALIZING}} in

[jira] [Commented] (FLINK-21986) taskmanager native memory not release timely after restart

[ https://issues.apache.org/jira/browse/FLINK-21986?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321239#comment-17321239 ] Feifan Wang commented on FLINK-21986: - Hi [~yunta], I confirm that I found the cause of this problem

[jira] [Commented] (FLINK-22276) ExceptionHistoryEntryExtractor throws fatal error when task failure

[ https://issues.apache.org/jira/browse/FLINK-22276?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321224#comment-17321224 ] Matthias commented on FLINK-22276: -- Thanks for bringing this up, [~jinxing6...@126.com]. On what

[GitHub] [flink] StephanEwen commented on a change in pull request #15601: [FLINK-18071][FLINK-21996][coordination] - Part two: Ensure reliable OperatorEvent to running Task matching

StephanEwen commented on a change in pull request #15601: URL: https://github.com/apache/flink/pull/15601#discussion_r613086839 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/operators/coordination/CoordinatorEventsExactlyOnceITCase.java ## @@ -285,41

[GitHub] [flink] StephanEwen commented on a change in pull request #15601: [FLINK-18071][FLINK-21996][coordination] - Part two: Ensure reliable OperatorEvent to running Task matching

StephanEwen commented on a change in pull request #15601: URL: https://github.com/apache/flink/pull/15601#discussion_r613468317 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/operators/coordination/OperatorCoordinator.java ## @@ -226,6 +219,26 @@ default

[GitHub] [flink] tillrohrmann commented on a change in pull request #15577: [FLINK-22001] Forward exceptions thrown during initialization to the user

tillrohrmann commented on a change in pull request #15577: URL: https://github.com/apache/flink/pull/15577#discussion_r613250217 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/DispatcherJob.java ## @@ -180,26 +173,36 @@ private void

<    5   6   7   8   9   10   11   12   13   14   >