[jira] [Commented] (FLINK-17544) NPE JDBCUpsertOutputFormat

[ https://issues.apache.org/jira/browse/FLINK-17544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17107760#comment-17107760 ] John Lonergan commented on FLINK-17544: --- Off which branch. BTW Theres a load of ot

[GitHub] [flink] flinkbot edited a comment on pull request #12069: [FLINK-14807][streaming] Add specialized collecting sink function

flinkbot edited a comment on pull request #12069: URL: https://github.com/apache/flink/pull/12069#issuecomment-626515528 ## CI report: * 731dff0812f1abb16193f7a2fe6f54b3ef65ae2d UNKNOWN * b90556c18fabe5fcfc3e93ba8c6b6a44b0d21f88 Azure: [FAILURE](https://dev.azure.com/apache-fl

[jira] [Commented] (FLINK-17706) Clarify licensing situation

[ https://issues.apache.org/jira/browse/FLINK-17706?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17107734#comment-17107734 ] Nico Kruber commented on FLINK-17706: - I'm ok with relicensing my contributions to t

[jira] [Updated] (FLINK-17706) Clarify licensing situation

[ https://issues.apache.org/jira/browse/FLINK-17706?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-17706: Description: After enabling the rat plugin, it finds the following files with missing or invalid

[jira] [Created] (FLINK-17706) Clarify licensing situation

Nico Kruber created FLINK-17706: --- Summary: Clarify licensing situation Key: FLINK-17706 URL: https://issues.apache.org/jira/browse/FLINK-17706 Project: Flink Issue Type: Sub-task Comp

[jira] [Created] (FLINK-17705) Add rat license checks

Nico Kruber created FLINK-17705: --- Summary: Add rat license checks Key: FLINK-17705 URL: https://issues.apache.org/jira/browse/FLINK-17705 Project: Flink Issue Type: Sub-task Component

[GitHub] [flink] flinkbot edited a comment on pull request #12137: [FLINK-16177][FLINK-16357][checkpointing] Complete / improve checkpointing for OperatorCoordinators

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

[GitHub] [flink] flinkbot edited a comment on pull request #12154: [FLINK-17693][table] Add createTypeInformation to DynamicTableSink#Contxt

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

[jira] [Created] (FLINK-17704) Allow running specific benchmarks from maven directly

Nico Kruber created FLINK-17704: --- Summary: Allow running specific benchmarks from maven directly Key: FLINK-17704 URL: https://issues.apache.org/jira/browse/FLINK-17704 Project: Flink Issue Typ

[GitHub] [flink] flinkbot edited a comment on pull request #12137: [FLINK-16177][FLINK-16357][checkpointing] Complete / improve checkpointing for OperatorCoordinators

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

[GitHub] [flink] flinkbot edited a comment on pull request #12120: [FLINK-17547] Support unaligned checkpoints for records spilled to files

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

[GitHub] [flink] flinkbot edited a comment on pull request #11814: [FLINK-17218][tests] Adding recoverable failures and correctness chec…

flinkbot edited a comment on pull request #11814: URL: https://github.com/apache/flink/pull/11814#issuecomment-616347961 ## CI report: * 1e0c61b438830bd4d377ae16f7f8d2b1bc0ce047 UNKNOWN * 6abf4ce6e94c0b9d16370bc58381c4e4c3951267 UNKNOWN * 0ea51bf82cd4ac18d8003632cd4b817ca322

[jira] [Updated] (FLINK-17703) Default execution command fails due 'benchmark' profile being inactive

[ https://issues.apache.org/jira/browse/FLINK-17703?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-17703: Issue Type: Bug (was: Improvement) > Default execution command fails due 'benchmark' profile bein

[jira] [Created] (FLINK-17703) Default execution command fails due 'benchmark' profile being inactive

Nico Kruber created FLINK-17703: --- Summary: Default execution command fails due 'benchmark' profile being inactive Key: FLINK-17703 URL: https://issues.apache.org/jira/browse/FLINK-17703 Project: Flink

[GitHub] [flink] StephanEwen commented on pull request #11722: [FLINK-5763][state backends] Make savepoints self-contained and relocatable

StephanEwen commented on pull request #11722: URL: https://github.com/apache/flink/pull/11722#issuecomment-628885180 Thank you for the patience, these days before feature freeze dates are very busy. At a high level glance, this looks quite good to me, good job and thanks for the har

[jira] [Created] (FLINK-17702) OperatorCoordinators must be notified of tasks cancelled as part of failover

Stephan Ewen created FLINK-17702: Summary: OperatorCoordinators must be notified of tasks cancelled as part of failover Key: FLINK-17702 URL: https://issues.apache.org/jira/browse/FLINK-17702 Project:

[GitHub] [flink] flinkbot edited a comment on pull request #12159: [hotfix][docs] Fix Kinesis consumer example

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

[GitHub] [flink] flinkbot edited a comment on pull request #12120: [FLINK-17547] Support unaligned checkpoints for records spilled to files

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

[GitHub] [flink] StephanEwen edited a comment on pull request #12156: [FLINK-17701][build] Exclude transitive jdk:tools dependency from all Hadoop dependencies.

StephanEwen edited a comment on pull request #12156: URL: https://github.com/apache/flink/pull/12156#issuecomment-628881205 Should I merge this anyways, or wait for @zentol's investigation? This is an automated message from t

[GitHub] [flink] StephanEwen commented on pull request #12156: [FLINK-17701][build] Exclude transitive jdk:tools dependency from all Hadoop dependencies.

StephanEwen commented on pull request #12156: URL: https://github.com/apache/flink/pull/12156#issuecomment-628881205 Should I merge this anyways, or wait for @zentol' investigation? This is an automated message from the Apach

[GitHub] [flink] StephanEwen commented on pull request #12155: [various] Cleanups and improvements to the SourceOperators

StephanEwen commented on pull request #12155: URL: https://github.com/apache/flink/pull/12155#issuecomment-628880625 The test failure looks unrelated to these changes (Kafka 0.11 ExactlyOnceProducer Test) This is an automate

[GitHub] [flink] flinkbot edited a comment on pull request #11814: [FLINK-17218][tests] Adding recoverable failures and correctness chec…

flinkbot edited a comment on pull request #11814: URL: https://github.com/apache/flink/pull/11814#issuecomment-616347961 ## CI report: * 1e0c61b438830bd4d377ae16f7f8d2b1bc0ce047 UNKNOWN * 6abf4ce6e94c0b9d16370bc58381c4e4c3951267 UNKNOWN * 0ea51bf82cd4ac18d8003632cd4b817ca322

[GitHub] [flink] flinkbot edited a comment on pull request #12159: [hotfix][docs] Fix Kinesis consumer example

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

[GitHub] [flink] flinkbot edited a comment on pull request #11814: [FLINK-17218][tests] Adding recoverable failures and correctness chec…

flinkbot edited a comment on pull request #11814: URL: https://github.com/apache/flink/pull/11814#issuecomment-616347961 ## CI report: * 1e0c61b438830bd4d377ae16f7f8d2b1bc0ce047 UNKNOWN * 6abf4ce6e94c0b9d16370bc58381c4e4c3951267 UNKNOWN * 0ea51bf82cd4ac18d8003632cd4b817ca322

[GitHub] [flink] pnowojski commented on a change in pull request #12120: [FLINK-17547] Support unaligned checkpoints for records spilled to files

pnowojski commented on a change in pull request #12120: URL: https://github.com/apache/flink/pull/12120#discussion_r425390633 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/channel/ChannelStateWriteRequest.java ## @@ -46,8 +47,23 @@ static Checkp

[GitHub] [flink] flinkbot commented on pull request #12159: [hotfix][docs] Fix Kinesis consumer example

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

[GitHub] [flink] flinkbot edited a comment on pull request #12025: [FLINK-17435] [hive] Hive non-partitioned source supports streaming read

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

[jira] [Closed] (FLINK-17668) Fix shortcomings in new data structures

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

[GitHub] [flink] twalthr closed pull request #12130: [FLINK-17668][table] Fix shortcomings in new data structures

twalthr closed pull request #12130: URL: https://github.com/apache/flink/pull/12130 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] [Commented] (FLINK-17545) Resource leak JDBCUpsertOutputFormat

[ https://issues.apache.org/jira/browse/FLINK-17545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17107578#comment-17107578 ] John Lonergan commented on FLINK-17545: --- Been hit by further failures due to this

[GitHub] [flink] AHeise commented on a change in pull request #11725: [FLINK-15670][API] Provide a Kafka Source/Sink pair as KafkaShuffle

AHeise commented on a change in pull request #11725: URL: https://github.com/apache/flink/pull/11725#discussion_r425298217 ## File path: flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer.java ## @@ -210,7 +210,7

[GitHub] [flink] flinkbot commented on pull request #12159: [hotfix][docs] Fix Kinesis consumer example

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

[GitHub] [flink] Myasuka commented on pull request #8693: [FLINK-8871] Support to cancel checkpoing via notification

Myasuka commented on pull request #8693: URL: https://github.com/apache/flink/pull/8693#issuecomment-628828516 @rkhachatryan thanks for your review. It's quite late for me at my time now and plan to update at my day time. Before go to sleep, I could answer the 1st question: barrier align

[GitHub] [flink] rmetzger opened a new pull request #12159: [hotfix][docs] Fix Kinesis consumer example

rmetzger opened a new pull request #12159: URL: https://github.com/apache/flink/pull/12159 The docs refer to a non-existing method This is an automated message from the Apache Git Service. To respond to the message, please lo

[GitHub] [flink] flinkbot edited a comment on pull request #12140: [FLINK-17629] Implement format factory for JSON serialization and des…

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

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

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

[GitHub] [flink] flinkbot edited a comment on pull request #12157: [FLINK-17691][Connectors/Kafka] fix the bug FlinkKafkaProducer011 transactional.id too long when use Semantic.EXACTLY_ONCE mode

flinkbot edited a comment on pull request #12157: URL: https://github.com/apache/flink/pull/12157#issuecomment-628732224 ## CI report: * c72006072a887727d7ac814ef85576ae3c9a6bd7 UNKNOWN * 4d9d19dd8a1bcaa317dc8f0550186bba13f7c103 Travis: [FAILURE](https://travis-ci.com/github/f

[GitHub] [flink] flinkbot edited a comment on pull request #11814: [FLINK-17218][tests] Adding recoverable failures and correctness chec…

flinkbot edited a comment on pull request #11814: URL: https://github.com/apache/flink/pull/11814#issuecomment-616347961 ## CI report: * 1e0c61b438830bd4d377ae16f7f8d2b1bc0ce047 UNKNOWN * 6abf4ce6e94c0b9d16370bc58381c4e4c3951267 UNKNOWN * 0ea51bf82cd4ac18d8003632cd4b817ca322

[GitHub] [flink] flinkbot edited a comment on pull request #12120: [FLINK-17547] Support unaligned checkpoints for records spilled to files

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

[GitHub] [flink] zentol commented on a change in pull request #12153: [FLINK-16966][metrics][infuxdb] Convert InfluxDB reporter to plugin

zentol commented on a change in pull request #12153: URL: https://github.com/apache/flink/pull/12153#discussion_r425360834 ## File path: flink-metrics/flink-metrics-influxdb/src/main/java/org/apache/flink/metrics/influxdb/InfluxdbReporterFactory.java ## @@ -0,0 +1,14 @@ +packa

[GitHub] [flink] Myasuka commented on a change in pull request #8693: [FLINK-8871] Support to cancel checkpoing via notification

Myasuka commented on a change in pull request #8693: URL: https://github.com/apache/flink/pull/8693#discussion_r425361635 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/HeapKeyedStateBackend.java ## @@ -311,6 +311,11 @@ public void notifyCheckpoi

[GitHub] [flink] zentol commented on pull request #12156: [FLINK-17701][build] Exclude transitive jdk:tools dependency from all Hadoop dependencies.

zentol commented on pull request #12156: URL: https://github.com/apache/flink/pull/12156#issuecomment-628824630 @rmetzger I tried that in the past but it wasn't working for some reason; the enforcer still picked them up. You can give it another go though. -

[GitHub] [flink] rkhachatryan commented on pull request #8693: [FLINK-8871] Support to cancel checkpoing via notification

rkhachatryan commented on pull request #8693: URL: https://github.com/apache/flink/pull/8693#issuecomment-628824673 Thanks for the updates @Myasuka There are still some questions open, please see the comments above. Besides that, can you please list some IT cases covering chec

[GitHub] [flink] Myasuka commented on a change in pull request #8693: [FLINK-8871] Support to cancel checkpoing via notification

Myasuka commented on a change in pull request #8693: URL: https://github.com/apache/flink/pull/8693#discussion_r425359640 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/SubtaskCheckpointCoordinatorImpl.java ## @@ -60,17 +63,22 @@ cla

[GitHub] [flink] pnowojski commented on a change in pull request #11814: [FLINK-17218][tests] Adding recoverable failures and correctness chec…

pnowojski commented on a change in pull request #11814: URL: https://github.com/apache/flink/pull/11814#discussion_r425307799 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/SubtaskCheckpointCoordinatorImpl.java ## @@ -240,7 +240,8 @@

[GitHub] [flink] flinkbot edited a comment on pull request #12158: [FLINK-17697][jdbc]Fix exception message comparison for tests.

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

[GitHub] [flink] flinkbot edited a comment on pull request #11814: [FLINK-17218][tests] Adding recoverable failures and correctness chec…

flinkbot edited a comment on pull request #11814: URL: https://github.com/apache/flink/pull/11814#issuecomment-616347961 ## CI report: * 1e0c61b438830bd4d377ae16f7f8d2b1bc0ce047 UNKNOWN * 6abf4ce6e94c0b9d16370bc58381c4e4c3951267 UNKNOWN * 0ea51bf82cd4ac18d8003632cd4b817ca322

[jira] [Resolved] (FLINK-14881) Upgrade AWS SDK to support "IAM Roles for Service Accounts" in AWS EKS

[ https://issues.apache.org/jira/browse/FLINK-14881?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-14881. Fix Version/s: 1.11.0 Resolution: Fixed Thanks a lot [~aroch] for improving Flink!

[GitHub] [flink] rmetzger closed pull request #12008: [FLINK-14881] [s3|kinesis] Add support for IAM Roles for Service Accounts on AWS EKS

rmetzger closed pull request #12008: URL: https://github.com/apache/flink/pull/12008 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] rkhachatryan commented on a change in pull request #8693: [FLINK-8871] Support to cancel checkpoing via notification

rkhachatryan commented on a change in pull request #8693: URL: https://github.com/apache/flink/pull/8693#discussion_r425319227 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/SubtaskCheckpointCoordinatorImpl.java ## @@ -183,6 +235,42 @

[jira] [Closed] (FLINK-17222) Improve FieldsDataType

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

[GitHub] [flink] twalthr closed pull request #12121: [FLINK-17222][table-common] Ensure deterministic field order in FieldsDataType

twalthr closed pull request #12121: URL: https://github.com/apache/flink/pull/12121 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-17467) Implement aligned savepoint in UC mode

[ https://issues.apache.org/jira/browse/FLINK-17467?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-17467: --- Parent: FLINK-14551 Issue Type: Sub-task (was: Improvement) > Implement aligned sav

[jira] [Closed] (FLINK-17467) Implement aligned savepoint in UC mode

[ https://issues.apache.org/jira/browse/FLINK-17467?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-17467. -- Resolution: Fixed I've supplemented the PR with an e2e test (I've repurposed `StatefulStreamJ

[GitHub] [flink] pnowojski closed pull request #11948: [FLINK-17467] Align channels on savepoint in UC mode

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

[GitHub] [flink] flinkbot edited a comment on pull request #12120: [FLINK-17547] Support unaligned checkpoints for records spilled to files

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

[GitHub] [flink] flinkbot edited a comment on pull request #12155: [various] Cleanups and improvements to the SourceOperators

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

[GitHub] [flink] flinkbot edited a comment on pull request #11948: [FLINK-17467] Align channels on savepoint in UC mode

flinkbot edited a comment on pull request #11948: URL: https://github.com/apache/flink/pull/11948#issuecomment-621327009 ## CI report: * e4ce0de30cb5d324dc4a2a030e416de1f7f1a79d UNKNOWN * d54111c2ca84686374c6e1c787fa8999ad26971c UNKNOWN * 6e67644b8eaad167f6397a07320946beb369

[GitHub] [flink] rkhachatryan commented on a change in pull request #8693: [FLINK-8871] Support to cancel checkpoing via notification

rkhachatryan commented on a change in pull request #8693: URL: https://github.com/apache/flink/pull/8693#discussion_r425330030 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/state/CheckpointListener.java ## @@ -38,4 +38,12 @@ * @throws Exception

[GitHub] [flink] rkhachatryan commented on a change in pull request #8693: [FLINK-8871] Support to cancel checkpoing via notification

rkhachatryan commented on a change in pull request #8693: URL: https://github.com/apache/flink/pull/8693#discussion_r425324821 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/HeapKeyedStateBackend.java ## @@ -311,6 +311,11 @@ public void notifyChe

[GitHub] [flink] rkhachatryan commented on a change in pull request #8693: [FLINK-8871] Support to cancel checkpoing via notification

rkhachatryan commented on a change in pull request #8693: URL: https://github.com/apache/flink/pull/8693#discussion_r425319227 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/SubtaskCheckpointCoordinatorImpl.java ## @@ -183,6 +235,42 @

[GitHub] [flink] flinkbot edited a comment on pull request #12120: [FLINK-17547] Support unaligned checkpoints for records spilled to files

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

[GitHub] [flink] flinkbot edited a comment on pull request #12143: [FLINK-17632][yarn] Support to specify a remote path for job jar

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

[GitHub] [flink] flinkbot edited a comment on pull request #12092: [FLINK-17596][python] Move the Python UDF runner script out of the jar of flink-python

flinkbot edited a comment on pull request #12092: URL: https://github.com/apache/flink/pull/12092#issuecomment-627157672 ## CI report: * a9c696fd00358fc2e142f0546524ce5d30d8f7e8 UNKNOWN * 8d309a011dbda867a22a92215bf0de5001c90eb5 Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #12069: [FLINK-14807][streaming] Add specialized collecting sink function

flinkbot edited a comment on pull request #12069: URL: https://github.com/apache/flink/pull/12069#issuecomment-626515528 ## CI report: * 731dff0812f1abb16193f7a2fe6f54b3ef65ae2d UNKNOWN * 1fe027d6ce199faabe008c240b62a42616e931a3 Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] rkhachatryan commented on a change in pull request #8693: [FLINK-8871] Support to cancel checkpoing via notification

rkhachatryan commented on a change in pull request #8693: URL: https://github.com/apache/flink/pull/8693#discussion_r425315334 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java ## @@ -182,7 +181,7 @@ protected fin

[GitHub] [flink] pnowojski commented on a change in pull request #8693: [FLINK-8871] Support to cancel checkpoing via notification

pnowojski commented on a change in pull request #8693: URL: https://github.com/apache/flink/pull/8693#discussion_r425288321 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/HeapKeyedStateBackend.java ## @@ -311,6 +311,11 @@ public void notifyCheckp

[jira] [Commented] (FLINK-16572) CheckPubSubEmulatorTest is flaky on Azure

[ https://issues.apache.org/jira/browse/FLINK-16572?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17107484#comment-17107484 ] Stephan Ewen commented on FLINK-16572: -- One more instance: https://dev.azure.com/se

[GitHub] [flink] flinkbot edited a comment on pull request #12157: [FLINK-17691][Connectors/Kafka] fix the bug FlinkKafkaProducer011 transactional.id too long when use Semantic.EXACTLY_ONCE mode

flinkbot edited a comment on pull request #12157: URL: https://github.com/apache/flink/pull/12157#issuecomment-628732224 ## CI report: * c72006072a887727d7ac814ef85576ae3c9a6bd7 UNKNOWN * 4d9d19dd8a1bcaa317dc8f0550186bba13f7c103 Travis: [FAILURE](https://travis-ci.com/github/f

[GitHub] [flink] flinkbot edited a comment on pull request #12158: [FLINK-17697][jdbc]Fix exception message comparison for tests.

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

[GitHub] [flink] tillrohrmann commented on a change in pull request #11010: [FLINK-15836][k8s] Throw fatal error in KubernetesResourceManager when the pods watcher is closed with exception

tillrohrmann commented on a change in pull request #11010: URL: https://github.com/apache/flink/pull/11010#discussion_r425292724 ## File path: flink-kubernetes/src/main/java/org/apache/flink/kubernetes/KubernetesResourceManager.java ## @@ -91,6 +93,8 @@ /** The number

[GitHub] [flink] flinkbot edited a comment on pull request #12069: [FLINK-14807][streaming] Add specialized collecting sink function

flinkbot edited a comment on pull request #12069: URL: https://github.com/apache/flink/pull/12069#issuecomment-626515528 ## CI report: * 731dff0812f1abb16193f7a2fe6f54b3ef65ae2d UNKNOWN * 1fe027d6ce199faabe008c240b62a42616e931a3 Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #11814: [FLINK-17218][tests] Adding recoverable failures and correctness chec…

flinkbot edited a comment on pull request #11814: URL: https://github.com/apache/flink/pull/11814#issuecomment-616347961 ## CI report: * 1e0c61b438830bd4d377ae16f7f8d2b1bc0ce047 UNKNOWN * 6abf4ce6e94c0b9d16370bc58381c4e4c3951267 UNKNOWN * 0ea51bf82cd4ac18d8003632cd4b817ca322

[GitHub] [flink] flinkbot edited a comment on pull request #12008: [FLINK-14881] [s3|kinesis] Add support for IAM Roles for Service Accounts on AWS EKS

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

[GitHub] [flink] flinkbot edited a comment on pull request #11725: [FLINK-15670][API] Provide a Kafka Source/Sink pair as KafkaShuffle

flinkbot edited a comment on pull request #11725: URL: https://github.com/apache/flink/pull/11725#issuecomment-613252882 ## CI report: * 066795205734add3b142a92c687c98b25253985e UNKNOWN * ba529bb050fb3fa07c15fc620b5c29e3fa73ae7f Azure: [CANCELED](https://dev.azure.com/apache-f

[jira] [Commented] (FLINK-17441) FlinkKinesisConsumerTest.testPeriodicWatermark: watermark count expected:<2> but was:<1>

[ https://issues.apache.org/jira/browse/FLINK-17441?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17107477#comment-17107477 ] Robert Metzger commented on FLINK-17441: Another case: https://dev.azure.com/ap

[jira] [Comment Edited] (FLINK-16383) KafkaProducerExactlyOnceITCase. testExactlyOnceRegularSink fails with "The producer has already been closed"

[ https://issues.apache.org/jira/browse/FLINK-16383?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17107475#comment-17107475 ] Robert Metzger edited comment on FLINK-16383 at 5/14/20, 5:04 PM:

[jira] [Reopened] (FLINK-16383) KafkaProducerExactlyOnceITCase. testExactlyOnceRegularSink fails with "The producer has already been closed"

[ https://issues.apache.org/jira/browse/FLINK-16383?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reopened FLINK-16383: Reopening ... {The producer 1502537416 has already been closed} https://dev.azure.com/apache-

[GitHub] [flink] flinkbot commented on pull request #12158: [FLINK-17697][jdbc]Fix exception message comparison for tests.

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

[GitHub] [flink] flinkbot edited a comment on pull request #12156: [FLINK-17701][build] Exclude transitive jdk:tools dependency from all Hadoop dependencies.

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

[GitHub] [flink] flinkbot edited a comment on pull request #12157: [FLINK-17691][Connectors/Kafka] fix the bug FlinkKafkaProducer011 transactional.id too long when use Semantic.EXACTLY_ONCE mode

flinkbot edited a comment on pull request #12157: URL: https://github.com/apache/flink/pull/12157#issuecomment-628732224 ## CI report: * c72006072a887727d7ac814ef85576ae3c9a6bd7 UNKNOWN * 4d9d19dd8a1bcaa317dc8f0550186bba13f7c103 UNKNOWN Bot commands The @flinkbo

[GitHub] [flink] flinkbot edited a comment on pull request #12143: [FLINK-17632][yarn] Support to specify a remote path for job jar

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

[GitHub] [flink] flinkbot edited a comment on pull request #12110: [FLINK-17652][config] Legacy JM heap options should fallback to new JVM_HEAP_MEMORY in standalone

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

[GitHub] [flink] flinkbot edited a comment on pull request #12130: [FLINK-17668][table] Fix shortcomings in new data structures

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

[GitHub] [flink] flinkbot edited a comment on pull request #12008: [FLINK-14881] [s3|kinesis] Add support for IAM Roles for Service Accounts on AWS EKS

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

[GitHub] [flink] tillrohrmann commented on a change in pull request #11957: [FLINK-17248] Introduce configuration for pool size of io-executor for ClusterEntrypoint and MiniCluster

tillrohrmann commented on a change in pull request #11957: URL: https://github.com/apache/flink/pull/11957#discussion_r425287489 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/minicluster/MiniCluster.java ## @@ -304,8 +305,12 @@ public void start() throws E

[GitHub] [flink] Myasuka commented on pull request #8693: [FLINK-8871] Support to cancel checkpoing via notification

Myasuka commented on pull request #8693: URL: https://github.com/apache/flink/pull/8693#issuecomment-628754467 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message, please lo

[GitHub] [flink] tillrohrmann commented on a change in pull request #11854: [FLINK-17407] Introduce external resource framework

tillrohrmann commented on a change in pull request #11854: URL: https://github.com/apache/flink/pull/11854#discussion_r425173912 ## File path: flink-kubernetes/src/test/java/org/apache/flink/kubernetes/KubernetesResourceManagerTest.java ## @@ -113,12 +113,17 @@ priva

[GitHub] [flink] TsReaper commented on a change in pull request #12069: [FLINK-14807][streaming] Add specialized collecting sink function

TsReaper commented on a change in pull request #12069: URL: https://github.com/apache/flink/pull/12069#discussion_r425268065 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/collect/CollectSinkFunction.java ## @@ -0,0 +1,381 @@ +/* + *

[jira] [Updated] (FLINK-17691) FlinkKafkaProducer011 transactional.id too long when use Semantic.EXACTLY_ONCE mode

[ https://issues.apache.org/jira/browse/FLINK-17691?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] freezhan updated FLINK-17691: - Summary: FlinkKafkaProducer011 transactional.id too long when use Semantic.EXACTLY_ONCE mode (was: Fail

[GitHub] [flink] rmetzger commented on pull request #12156: [FLINK-17701][build] Exclude transitive jdk:tools dependency from all Hadoop dependencies.

rmetzger commented on pull request #12156: URL: https://github.com/apache/flink/pull/12156#issuecomment-628739060 Thanks a lot for addressing this issue. Does it make sense to ban this dependency in the java11 profile? https://github.com/apache/flink/blob/master/pom.xml#L1619

[GitHub] [flink] TsReaper commented on a change in pull request #12069: [FLINK-14807][streaming] Add specialized collecting sink function

TsReaper commented on a change in pull request #12069: URL: https://github.com/apache/flink/pull/12069#discussion_r425261853 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/collect/CollectCoordinationResponse.java ## @@ -0,0 +1,104 @@

[GitHub] [flink] flinkbot commented on pull request #12158: [FLINK-17697][jdbc]Fix exception message comparison for tests.

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

[GitHub] [flink] tillrohrmann commented on pull request #12037: [FLINK-14807][runtime][client] Introduce communication through REST API between the clients and the operator coordinators

tillrohrmann commented on pull request #12037: URL: https://github.com/apache/flink/pull/12037#issuecomment-628733250 Thanks @TsReaper. Merging this PR once AZP gives green light. This is an automated message from the Apache

[jira] [Updated] (FLINK-17691) Failed to sinkKafka with exactly once mode when transactional.id too long

[ https://issues.apache.org/jira/browse/FLINK-17691?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-17691: --- Labels: pull-request-available (was: ) > Failed to sinkKafka with exactly once mode when tr

[GitHub] [flink] flinkbot edited a comment on pull request #12143: [FLINK-17632][yarn] Support to specify a remote path for job jar

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

[GitHub] [flink] flinkbot commented on pull request #12156: [FLINK-17701][build] Exclude transitive jdk:tools dependency from all Hadoop dependencies.

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

[GitHub] [flink] flinkbot edited a comment on pull request #12148: [FLINK-13811][python] Support converting flink Table to pandas DataFrame

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

[GitHub] [flink] flinkbot edited a comment on pull request #12155: [various] Cleanups and improvements to the SourceOperators

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

[GitHub] [flink] flinkbot commented on pull request #12157: [FLINK-17691][Connectors/Kafka] fix the bug FlinkKafkaProducer011 transactional.id too long when use Semantic.EXACTLY_ONCE mode

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

<    1   2   3   4   5   6   7   8   9   10   >