[GitHub] [flink] flinkbot edited a comment on pull request #14086: [hotifx][docs]fix_docs_typo

flinkbot edited a comment on pull request #14086: URL: https://github.com/apache/flink/pull/14086#issuecomment-728628875 ## CI report: * 6ce369532814fef97b8d30df3bca0d12a4ad5bee UNKNOWN * 8dbf3477b8c11d7d98530e69ce20ba356e9c98fa UNKNOWN Bot commands The

[jira] [Comment Edited] (FLINK-19951) PyFlink end-to-end test stuck in "Reading kafka messages"

[ https://issues.apache.org/jira/browse/FLINK-19951?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17233190#comment-17233190 ] Shuiqiang Chen edited comment on FLINK-19951 at 11/17/20, 1:58 AM: --- Hi

[GitHub] [flink] flinkbot edited a comment on pull request #13790: [FLINK-19806][runtime] Harden DefaultScheduler for concurrent suspending and failing

flinkbot edited a comment on pull request #13790: URL: https://github.com/apache/flink/pull/13790#issuecomment-716351574 ## CI report: * ceec2a33502f264be73720b5c502a3071b0de94a Azure:

[jira] [Commented] (FLINK-19951) PyFlink end-to-end test stuck in "Reading kafka messages"

[ https://issues.apache.org/jira/browse/FLINK-19951?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17233190#comment-17233190 ] Shuiqiang Chen commented on FLINK-19951: Hi [~dian.fu] it's because that the Kafka consumer

[jira] [Commented] (FLINK-19863) SQLClientHBaseITCase.testHBase failed with "java.io.IOException: Process failed due to timeout"

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

[jira] [Commented] (FLINK-17424) SQL Client end-to-end test (Old planner) Elasticsearch (v7.5.1) failed due to download error

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

[GitHub] [flink] flinkbot commented on pull request #14087: [FLINK-20177][doc] Fix the wrong link of kinesis in index.zh.md

flinkbot commented on pull request #14087: URL: https://github.com/apache/flink/pull/14087#issuecomment-728631978 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-20177) Liquid Exception: Could not find document 'dev/table/connectors/kinesis.md' in tag 'link'. Make sure the document exists and the path is correct. in dev/table/connector

[ https://issues.apache.org/jira/browse/FLINK-20177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-20177: --- Labels: pull-request-available (was: ) > Liquid Exception: Could not find document

[GitHub] [flink] HuangXingBo opened a new pull request #14087: [FLINK-20177][doc] Fix the wrong link of kinesis in index.zh.md

HuangXingBo opened a new pull request #14087: URL: https://github.com/apache/flink/pull/14087 ## What is the purpose of the change *This pull request will Fix the wrong link of kinesis in index.zh.md* ## Brief change log - *Correct the link of kinesis in

[jira] [Comment Edited] (FLINK-20038) Rectify the usage of ResultPartitionType#isPipelined() in partition tracker.

[ https://issues.apache.org/jira/browse/FLINK-20038?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17232495#comment-17232495 ] Jin Xing edited comment on FLINK-20038 at 11/17/20, 1:38 AM: - Hi

[jira] [Commented] (FLINK-20177) Liquid Exception: Could not find document 'dev/table/connectors/kinesis.md' in tag 'link'. Make sure the document exists and the path is correct. in dev/table/connect

[ https://issues.apache.org/jira/browse/FLINK-20177?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17233182#comment-17233182 ] Huang Xingbo commented on FLINK-20177: -- The problem is that index.zh.md points to the wrong link

[jira] [Commented] (FLINK-18570) SQLClientHBaseITCase.testHBase fails on azure

[ https://issues.apache.org/jira/browse/FLINK-18570?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17233180#comment-17233180 ] Leonard Xu commented on FLINK-18570: [~rmetzger] Yes, the added log is helpful, I hope we can fix

[GitHub] [flink-web] ClownfishYang commented on pull request #269: [FLINK-13680] Translate "Common Rules" page into Chinese

ClownfishYang commented on pull request #269: URL: https://github.com/apache/flink-web/pull/269#issuecomment-728629174 @klion26 I think it would be easier for me to submit a new request.https://github.com/apache/flink-web/pull/394

[GitHub] [flink] flinkbot commented on pull request #14086: [hotifx][docs]fix_docs_typo

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

[jira] [Updated] (FLINK-20177) Liquid Exception: Could not find document 'dev/table/connectors/kinesis.md' in tag 'link'. Make sure the document exists and the path is correct. in dev/table/connector

[ https://issues.apache.org/jira/browse/FLINK-20177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-20177: Fix Version/s: 1.12.0 > Liquid Exception: Could not find document 'dev/table/connectors/kinesis.md' >

[GitHub] [flink-web] ClownfishYang opened a new pull request #394: [FLINK-13680] Translate "Common Rules" page into Chinese

ClownfishYang opened a new pull request #394: URL: https://github.com/apache/flink-web/pull/394 [FLINK-13680] Translate "Common Rules" page into Chinese This is an automated message from the Apache Git Service. To respond to

[jira] [Updated] (FLINK-19806) Job may try to leave SUSPENDED state in ExecutionGraph#failJob()

[ https://issues.apache.org/jira/browse/FLINK-19806?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-19806: Affects Version/s: 1.10.0 > Job may try to leave SUSPENDED state in ExecutionGraph#failJob() >

[jira] [Updated] (FLINK-19806) Job may try to leave SUSPENDED state in ExecutionGraph#failJob()

[ https://issues.apache.org/jira/browse/FLINK-19806?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-19806: Fix Version/s: 1.12.0 > Job may try to leave SUSPENDED state in ExecutionGraph#failJob() >

[jira] [Commented] (FLINK-2320) Enable DataSet DataStream Joins

[ https://issues.apache.org/jira/browse/FLINK-2320?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17233179#comment-17233179 ] Sugar commented on FLINK-2320: -- Hello community, Do we have any updates on this feature? > Enable DataSet

[jira] [Created] (FLINK-20177) Liquid Exception: Could not find document 'dev/table/connectors/kinesis.md' in tag 'link'. Make sure the document exists and the path is correct. in dev/table/connector

Huang Xingbo created FLINK-20177: Summary: Liquid Exception: Could not find document 'dev/table/connectors/kinesis.md' in tag 'link'. Make sure the document exists and the path is correct. in dev/table/connectors/index.zh.md

[GitHub] [flink] flinkbot commented on pull request #14086: [hotifx][docs]fix_docs_typo

flinkbot commented on pull request #14086: URL: https://github.com/apache/flink/pull/14086#issuecomment-728617127 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] dufeng1010 opened a new pull request #14086: [hotifx][docs]fix_docs_typo

dufeng1010 opened a new pull request #14086: URL: https://github.com/apache/flink/pull/14086 Fix some typos in udfs.zh.md This is an automated message from the Apache Git Service. To respond to the message, please log on to

[jira] [Commented] (FLINK-19864) TwoInputStreamTaskTest.testWatermarkMetrics failed with "expected:<1> but was:<-9223372036854775808>"

[ https://issues.apache.org/jira/browse/FLINK-19864?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17233174#comment-17233174 ] Kezhu Wang commented on FLINK-19864: How about using a combination of {{Thread.isAlive}} and

[GitHub] [flink] flinkbot edited a comment on pull request #14084: [FLINK-15867][table-planner-blink] Support time-related types for FIRST_VALUE and LAST_VALUE aggregate functions

flinkbot edited a comment on pull request #14084: URL: https://github.com/apache/flink/pull/14084#issuecomment-728296283 ## CI report: * 54c17b2c00b65af7eec5fcb13592e0893b2d Azure:

[jira] [Created] (FLINK-20176) CompactionITCaseBase.testNonPartition failed with Timeout

Matthias created FLINK-20176: Summary: CompactionITCaseBase.testNonPartition failed with Timeout Key: FLINK-20176 URL: https://issues.apache.org/jira/browse/FLINK-20176 Project: Flink Issue

[GitHub] [flink] flinkbot edited a comment on pull request #14085: [FLINK-19997] Implement an e2e test for sql-client with Confluent Registry Avro format

flinkbot edited a comment on pull request #14085: URL: https://github.com/apache/flink/pull/14085#issuecomment-728305152 ## CI report: * 6bc29df5f1107d4fd49ed23aa48f156eda02ec2e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14085: [FLINK-19997] Implement an e2e test for sql-client with Confluent Registry Avro format

flinkbot edited a comment on pull request #14085: URL: https://github.com/apache/flink/pull/14085#issuecomment-728305152 ## CI report: * 6bc29df5f1107d4fd49ed23aa48f156eda02ec2e Azure:

[GitHub] [flink] flinkbot commented on pull request #14085: [FLINK-19997] Implement an e2e test for sql-client with Confluent Registry Avro format

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

[GitHub] [flink] flinkbot edited a comment on pull request #14084: [FLINK-15867][table-planner-blink] Support time-related types for FIRST_VALUE and LAST_VALUE aggregate functions

flinkbot edited a comment on pull request #14084: URL: https://github.com/apache/flink/pull/14084#issuecomment-728296283 ## CI report: * 54c17b2c00b65af7eec5fcb13592e0893b2d Azure:

[GitHub] [flink] flinkbot commented on pull request #14085: [FLINK-19997] Implement an e2e test for sql-client with Confluent Registry Avro format

flinkbot commented on pull request #14085: URL: https://github.com/apache/flink/pull/14085#issuecomment-728300552 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-19997) Implement an e2e test for sql-client with Confluent Registry Avro format

[ https://issues.apache.org/jira/browse/FLINK-19997?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-19997: --- Labels: pull-request-available (was: ) > Implement an e2e test for sql-client with

[GitHub] [flink] dawidwys opened a new pull request #14085: [FLINK-19997] Implement an e2e test for sql-client with Confluent Registry Avro format

dawidwys opened a new pull request #14085: URL: https://github.com/apache/flink/pull/14085 ## What is the purpose of the change * Implement an e2e test for Avro Confluent Registry SQL format ## Brief change log See commit log **NOTE to reviewers** If requested I

[jira] [Closed] (FLINK-19979) Sanity check after bash e2e tests for no leftover processes

[ https://issues.apache.org/jira/browse/FLINK-19979?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger closed FLINK-19979. -- Resolution: Fixed Merged to master in

[GitHub] [flink] flinkbot commented on pull request #14084: [FLINK-15867][table-planner-blink] Support time-related types for FIRST_VALUE and LAST_VALUE aggregate functions

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

[GitHub] [flink] rmetzger merged pull request #14033: [FLINK-19979][e2e] Add sanity check after bash e2e tests for no leftovers

rmetzger merged pull request #14033: URL: https://github.com/apache/flink/pull/14033 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] rmetzger commented on pull request #14033: [FLINK-19979][e2e] Add sanity check after bash e2e tests for no leftovers

rmetzger commented on pull request #14033: URL: https://github.com/apache/flink/pull/14033#issuecomment-728295854 Thanks a lot. Merging ... This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [flink] Acesine commented on a change in pull request #14042: [FLINK-19300][flink-core] Fix input stream read to prevent heap based timer loss

Acesine commented on a change in pull request #14042: URL: https://github.com/apache/flink/pull/14042#discussion_r524536409 ## File path: flink-core/src/main/java/org/apache/flink/util/IOUtils.java ## @@ -143,6 +143,30 @@ public static void readFully(final InputStream in,

[GitHub] [flink] flinkbot commented on pull request #14084: [FLINK-15867][table-planner-blink] Support time-related types for FIRST_VALUE and LAST_VALUE aggregate functions

flinkbot commented on pull request #14084: URL: https://github.com/apache/flink/pull/14084#issuecomment-728287751 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-15867) LAST_VALUE and FIRST_VALUE aggregate function does not support time-related types

[ https://issues.apache.org/jira/browse/FLINK-15867?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-15867: --- Labels: pull-request-available (was: ) > LAST_VALUE and FIRST_VALUE aggregate function

[GitHub] [flink] shmyer opened a new pull request #14084: [FLINK-15867][table-planner-blink] Support time-related types for FIRST_VALUE and LAST_VALUE aggregate functions

shmyer opened a new pull request #14084: URL: https://github.com/apache/flink/pull/14084 …ST_VALUE and LAST_VALUE aggregate functions ## What is the purpose of the change This pull request enables support for time-related types in FIRST_VALUE and LAST_VALUE aggregate

[jira] [Commented] (FLINK-20005) "Kerberized YARN application" test unstable

[ https://issues.apache.org/jira/browse/FLINK-20005?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17233026#comment-17233026 ] Robert Metzger commented on FLINK-20005: I don't know if that's a good solution. I initially

[jira] [Comment Edited] (FLINK-10615) Cancel with savepoint can fail the job

[ https://issues.apache.org/jira/browse/FLINK-10615?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17233019#comment-17233019 ] Roman Khachatryan edited comment on FLINK-10615 at 11/16/20, 7:28 PM:

[jira] [Commented] (FLINK-19653) HiveCatalogITCase fails on azure

[ https://issues.apache.org/jira/browse/FLINK-19653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17233020#comment-17233020 ] Robert Metzger commented on FLINK-19653: [~lirui] are you going to open a pull request for the

[jira] [Commented] (FLINK-10615) Cancel with savepoint can fail the job

[ https://issues.apache.org/jira/browse/FLINK-10615?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17233019#comment-17233019 ] Roman Khachatryan commented on FLINK-10615: --- I see the error log in the description, so it

[jira] [Commented] (FLINK-19630) Sink data in [ORC] format into Hive By using Legacy Table API caused unexpected Exception

[ https://issues.apache.org/jira/browse/FLINK-19630?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17233018#comment-17233018 ] Robert Metzger commented on FLINK-19630: Do we want to add the documentation for the 1.12

[jira] [Created] (FLINK-20175) Avro Confluent Registry SQL format does not support adding nullable columns

Dawid Wysakowicz created FLINK-20175: Summary: Avro Confluent Registry SQL format does not support adding nullable columns Key: FLINK-20175 URL: https://issues.apache.org/jira/browse/FLINK-20175

[jira] [Updated] (FLINK-20175) Avro Confluent Registry SQL format does not support adding nullable columns

[ https://issues.apache.org/jira/browse/FLINK-20175?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-20175: - Description: The {{AvroSchemaConverter#convertToSchema}} generates a union with "null"

[jira] [Issue Comment Deleted] (FLINK-19585) UnalignedCheckpointCompatibilityITCase.test:97->runAndTakeSavepoint: "Not all required tasks are currently running."

[ https://issues.apache.org/jira/browse/FLINK-19585?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-19585: --- Comment: was deleted (was: Closing. This could be fixed now by the revert.) >

[jira] [Reopened] (FLINK-19585) UnalignedCheckpointCompatibilityITCase.test:97->runAndTakeSavepoint: "Not all required tasks are currently running."

[ https://issues.apache.org/jira/browse/FLINK-19585?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reopened FLINK-19585: > UnalignedCheckpointCompatibilityITCase.test:97->runAndTakeSavepoint: "Not all > required

[jira] [Closed] (FLINK-19585) UnalignedCheckpointCompatibilityITCase.test:97->runAndTakeSavepoint: "Not all required tasks are currently running."

[ https://issues.apache.org/jira/browse/FLINK-19585?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger closed FLINK-19585. -- Resolution: Cannot Reproduce Closing. This could be fixed now by the revert. >

[jira] [Commented] (FLINK-18570) SQLClientHBaseITCase.testHBase fails on azure

[ https://issues.apache.org/jira/browse/FLINK-18570?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17233016#comment-17233016 ] Robert Metzger commented on FLINK-18570: [~Leonard Xu] is the failure I reported after the

[jira] [Updated] (FLINK-20043) Add flink-sql-connector-kinesis package

[ https://issues.apache.org/jira/browse/FLINK-20043?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-20043: - Component/s: Connectors / Kinesis > Add flink-sql-connector-kinesis package >

[jira] [Assigned] (FLINK-20043) Add flink-sql-connector-kinesis package

[ https://issues.apache.org/jira/browse/FLINK-20043?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther reassigned FLINK-20043: Assignee: Danny Cranmer (was: Alexander Alexandrov) > Add flink-sql-connector-kinesis

[jira] [Closed] (FLINK-20043) Add flink-sql-connector-kinesis package

[ https://issues.apache.org/jira/browse/FLINK-20043?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-20043. Resolution: Fixed > Add flink-sql-connector-kinesis package >

[jira] [Reopened] (FLINK-20043) Add flink-sql-connector-kinesis package

[ https://issues.apache.org/jira/browse/FLINK-20043?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther reopened FLINK-20043: -- > Add flink-sql-connector-kinesis package > --- > >

[jira] [Closed] (FLINK-20043) Add flink-sql-connector-kinesis package

[ https://issues.apache.org/jira/browse/FLINK-20043?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-20043. Fix Version/s: 1.12.0 Resolution: Fixed Fixed in 1.12.0:

[GitHub] [flink] twalthr closed pull request #14049: [FLINK-20043][kinesis] Add flink-sql-connector-kinesis package

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

[jira] [Updated] (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:all-tabpanel ] Robert Metzger updated FLINK-17274: --- Fix Version/s: (was: 1.12.0) > Maven: Premature end of Content-Length delimited message

[jira] [Assigned] (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:all-tabpanel ] Robert Metzger reassigned FLINK-17274: -- Assignee: (was: Robert Metzger) > Maven: Premature end of Content-Length

[jira] [Commented] (FLINK-16947) ArtifactResolutionException: Could not transfer artifact. Entry [...] has not been leased from this pool

[ https://issues.apache.org/jira/browse/FLINK-16947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17233011#comment-17233011 ] Robert Metzger commented on FLINK-16947: I removed the fix for 1.12 marker. This is an

[jira] [Updated] (FLINK-16947) ArtifactResolutionException: Could not transfer artifact. Entry [...] has not been leased from this pool

[ https://issues.apache.org/jira/browse/FLINK-16947?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-16947: --- Fix Version/s: (was: 1.12.0) > ArtifactResolutionException: Could not transfer

[jira] [Updated] (FLINK-15557) Cannot connect to Azure Event Hub/Kafka since Jan 5th 2020. Kafka version issue

[ https://issues.apache.org/jira/browse/FLINK-15557?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-15557: --- Fix Version/s: (was: 1.12.0) 1.13.0 > Cannot connect to Azure Event

[jira] [Commented] (FLINK-15557) Cannot connect to Azure Event Hub/Kafka since Jan 5th 2020. Kafka version issue

[ https://issues.apache.org/jira/browse/FLINK-15557?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17233009#comment-17233009 ] Robert Metzger commented on FLINK-15557: I don't think we should bump the Kafka dependency

[jira] [Closed] (FLINK-15330) HadoopS3RecoverableWriterITCase.testCallingDeleteObjectTwiceDoesNotThroughException() fails with AssertionError

[ https://issues.apache.org/jira/browse/FLINK-15330?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger closed FLINK-15330. -- Resolution: Cannot Reproduce Closing as cannot reproduce >

[jira] [Commented] (FLINK-10615) Cancel with savepoint can fail the job

[ https://issues.apache.org/jira/browse/FLINK-10615?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17233006#comment-17233006 ] Robert Metzger commented on FLINK-10615: This ticket has been filed in 2018 by a Flink committer

[jira] [Updated] (FLINK-10615) Cancel with savepoint can fail the job

[ https://issues.apache.org/jira/browse/FLINK-10615?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-10615: --- Component/s: Runtime / Checkpointing > Cancel with savepoint can fail the job >

[GitHub] [flink] flinkbot edited a comment on pull request #14083: [FLINK-20171][coordination] Improve error message for Flink process memory configuration

flinkbot edited a comment on pull request #14083: URL: https://github.com/apache/flink/pull/14083#issuecomment-728115665 ## CI report: * e1e4bfb8d05344b4b3a09921af44d0b93c6388f2 Azure:

[jira] [Commented] (FLINK-9667) Scala docs are only generated for flink-scala

[ https://issues.apache.org/jira/browse/FLINK-9667?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17233002#comment-17233002 ] Robert Metzger commented on FLINK-9667: --- Since there was no response, I'll remove it from the 1.12

[jira] [Updated] (FLINK-9667) Scala docs are only generated for flink-scala

[ https://issues.apache.org/jira/browse/FLINK-9667?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-9667: -- Fix Version/s: (was: 1.12.0) > Scala docs are only generated for flink-scala >

[jira] [Updated] (FLINK-20028) FileCompactionITCase is unstable

[ https://issues.apache.org/jira/browse/FLINK-20028?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-20028: --- Priority: Critical (was: Blocker) > FileCompactionITCase is unstable >

[jira] [Updated] (FLINK-20174) Make BulkFormat more extensible

[ https://issues.apache.org/jira/browse/FLINK-20174?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Steven Zhen Wu updated FLINK-20174: --- Description: Right now, BulkFormat has the generic `SpitT` type extending from

[jira] [Commented] (FLINK-19791) PartitionRequestClientFactoryTest.testInterruptsNotCached fails with NullPointerException

[ https://issues.apache.org/jira/browse/FLINK-19791?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17232974#comment-17232974 ] Roman Khachatryan commented on FLINK-19791: --- The original issue was caused by an incorrect

[jira] [Commented] (FLINK-20159) [FLIP-27 source] FutureNotifier does not return a new future when Future::future() is invoked within the returned future's callback

[ https://issues.apache.org/jira/browse/FLINK-20159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17232969#comment-17232969 ] Sundaram Ananthanarayanan commented on FLINK-20159: --- [~becket_qin]Sure I'll submit a

[jira] [Created] (FLINK-20174) Make BulkFormat more extensible

Steven Zhen Wu created FLINK-20174: -- Summary: Make BulkFormat more extensible Key: FLINK-20174 URL: https://issues.apache.org/jira/browse/FLINK-20174 Project: Flink Issue Type: Improvement

[GitHub] [flink] flinkbot edited a comment on pull request #13900: [FLINK-19949][csv] Unescape CSV format line delimiter character

flinkbot edited a comment on pull request #13900: URL: https://github.com/apache/flink/pull/13900#issuecomment-720989833 ## CI report: * d9e47451664a976692e4e6110bbffa2842f2ae7a UNKNOWN * d65ba6f5d492114726ca7e6a1f73afe5ab36bcdd Azure:

[jira] [Closed] (FLINK-18673) Calling ROW() in a UDF results in UnsupportedOperationException

[ https://issues.apache.org/jira/browse/FLINK-18673?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-18673. Fix Version/s: 1.11.3 1.12.0 Resolution: Fixed Fixed in 1.12.0:

[GitHub] [flink] kl0u commented on pull request #14028: [FLINK-20020][client] Make UnsuccessfulExecutionException part of the JobClient.getJobExecutionResult() contract

kl0u commented on pull request #14028: URL: https://github.com/apache/flink/pull/14028#issuecomment-728205825 @SteNicholas I had a look at this solution and I would like to think on how to make the `status` `final`. This means that I am trying to see if we can have all the

[GitHub] [flink] flinkbot edited a comment on pull request #14080: [FLINK-19996][e2e] Add end-to-end IT case for Debezium + Kafka + temporal join

flinkbot edited a comment on pull request #14080: URL: https://github.com/apache/flink/pull/14080#issuecomment-727900302 ## CI report: * 1de159250bb479bf142967e35d51e4ae5df3363f Azure:

[GitHub] [flink] kl0u commented on pull request #14077: [FLINK-20141][fs-connector] Translate FileSink document into Chinese

kl0u commented on pull request #14077: URL: https://github.com/apache/flink/pull/14077#issuecomment-728204347 @gaoyunhaii I merged the english version. This is an automated message from the Apache Git Service. To respond to

[jira] [Commented] (FLINK-19970) State leak in CEP Operators (expired events/keys not removed from state)

[ https://issues.apache.org/jira/browse/FLINK-19970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17232913#comment-17232913 ] Thomas Wozniakowski commented on FLINK-19970: - Hey [~dwysakowicz] - thanks for the update.

[GitHub] [flink] rkhachatryan commented on pull request #14051: [FLINK-20107][network] Make InputChannel.statePersister immutable

rkhachatryan commented on pull request #14051: URL: https://github.com/apache/flink/pull/14051#issuecomment-728195493 I mentioned it in JIRA (and now pulled to PR description): > This change leaves `statePersister` mutable in channels that will be converted after requesting partitions.

[jira] [Commented] (FLINK-20144) Change link format to "{% link ... %}" in docs/ops dir

[ https://issues.apache.org/jira/browse/FLINK-20144?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17232899#comment-17232899 ] Seth Wiesman commented on FLINK-20144: -- fixed in master caa5104f93e1f320ec5199f16fca996430d8d4d1 >

[jira] [Assigned] (FLINK-20144) Change link format to "{% link ... %}" in docs/ops dir

[ https://issues.apache.org/jira/browse/FLINK-20144?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman reassigned FLINK-20144: Assignee: Xiao Huang > Change link format to "{% link ... %}" in docs/ops dir >

[jira] [Closed] (FLINK-20144) Change link format to "{% link ... %}" in docs/ops dir

[ https://issues.apache.org/jira/browse/FLINK-20144?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman closed FLINK-20144. Resolution: Fixed > Change link format to "{% link ... %}" in docs/ops dir >

[jira] [Updated] (FLINK-20144) Change link format to "{% link ... %}" in docs/ops dir

[ https://issues.apache.org/jira/browse/FLINK-20144?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman updated FLINK-20144: - Fix Version/s: 1.12.0 > Change link format to "{% link ... %}" in docs/ops dir >

[GitHub] [flink] sjwiesman closed pull request #14066: [FLINK-20144][docs] Change link format in docs/ops dir

sjwiesman closed pull request #14066: URL: https://github.com/apache/flink/pull/14066 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] rkhachatryan commented on a change in pull request #14052: [FLINK-20030][network] Rewrite RemoteInputChannel#getInflightBuffersUnsafe to use sequence numbers

rkhachatryan commented on a change in pull request #14052: URL: https://github.com/apache/flink/pull/14052#discussion_r524417953 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/consumer/RemoteInputChannelTest.java ## @@ -1125,70

[GitHub] [flink] rkhachatryan commented on a change in pull request #14052: [FLINK-20030][network] Rewrite RemoteInputChannel#getInflightBuffersUnsafe to use sequence numbers

rkhachatryan commented on a change in pull request #14052: URL: https://github.com/apache/flink/pull/14052#discussion_r524417953 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/consumer/RemoteInputChannelTest.java ## @@ -1125,70

[GitHub] [flink] sjwiesman commented on pull request #14066: [FLINK-20144][docs] Change link format in docs/ops dir

sjwiesman commented on pull request #14066: URL: https://github.com/apache/flink/pull/14066#issuecomment-728183693 Grazi, merging . . . This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [flink] flinkbot edited a comment on pull request #14082: [FLINK-20143][yarn] Support non-qualified path for Yarn shared lib

flinkbot edited a comment on pull request #14082: URL: https://github.com/apache/flink/pull/14082#issuecomment-727936406 ## CI report: * a7eb3c1b421bca0fedfa0aecee377c2789deed84 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14066: [FLINK-20144][docs] Change link format in docs/ops dir

flinkbot edited a comment on pull request #14066: URL: https://github.com/apache/flink/pull/14066#issuecomment-726763095 ## CI report: * 6d180cae9b82981c786f865ef7d077aff41187fb Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14049: [FLINK-20043][kinesis] Add flink-sql-connector-kinesis package

flinkbot edited a comment on pull request #14049: URL: https://github.com/apache/flink/pull/14049#issuecomment-726094991 ## CI report: * 0a068c0f16865a2c91819d21f52d759151acb97e UNKNOWN * d15f6e11ca8d46da440ed6c2235f73937d70ab3a UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on pull request #14028: [FLINK-20020][client] Make UnsuccessfulExecutionException part of the JobClient.getJobExecutionResult() contract

flinkbot edited a comment on pull request #14028: URL: https://github.com/apache/flink/pull/14028#issuecomment-725222918 ## CI report: * 257753275bc370049438a58d129801888c1c6ddb Azure:

[GitHub] [flink] twalthr closed pull request #14067: [FLINK-18673][table] Improve support for ROW constructor

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

[GitHub] [flink] flinkbot edited a comment on pull request #13924: [FLINK-19938][network] Implement shuffle data read scheduling for sort-merge blocking shuffle

flinkbot edited a comment on pull request #13924: URL: https://github.com/apache/flink/pull/13924#issuecomment-721619690 ## CI report: * d2d755ef20178373148235501a2b67d8ab82fd6b Azure:

[jira] [Closed] (FLINK-20169) Move emitting MAX_WATERMARK out of SourceOperator processing loop

[ https://issues.apache.org/jira/browse/FLINK-20169?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-20169. Resolution: Implemented Implemented in b878f54d54bbf1b8f966924e3d1dab8c23f7c628 > Move

[GitHub] [flink] dawidwys merged pull request #14078: [FLINK-20169] Move emitting MAX_WATERMARK out of the SourceOperator processing loop

dawidwys merged pull request #14078: URL: https://github.com/apache/flink/pull/14078 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] rkhachatryan commented on a change in pull request #14052: [FLINK-20030][network] Rewrite RemoteInputChannel#getInflightBuffersUnsafe to use sequence numbers

rkhachatryan commented on a change in pull request #14052: URL: https://github.com/apache/flink/pull/14052#discussion_r524391892 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/RemoteInputChannel.java ## @@ -98,14 +100,11 @@

[jira] [Commented] (FLINK-20173) CoordinatedSourceITCase.testEnumeratorReaderCommunication fails with IllegalStateException

[ https://issues.apache.org/jira/browse/FLINK-20173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17232863#comment-17232863 ] Robert Metzger commented on FLINK-20173: [~becket_qin] told me offline that this has been fixed

[GitHub] [flink] flinkbot edited a comment on pull request #14066: [FLINK-20144][docs] Change link format in docs/ops dir

flinkbot edited a comment on pull request #14066: URL: https://github.com/apache/flink/pull/14066#issuecomment-726763095 ## CI report: * 6d180cae9b82981c786f865ef7d077aff41187fb Azure:

<    1   2   3   4   5   6   7   >