[jira] [Updated] (FLINK-17769) Wrong order of log events on a task failure

[ https://issues.apache.org/jira/browse/FLINK-17769?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-17769: --- Priority: Critical (was: Blocker) > Wrong order of log events on a task failure > -

[GitHub] [flink] SteNicholas opened a new pull request #12197: [FLINK-15349][table-planner-blink] add 'DROP catalog' DDL to blink pl…

SteNicholas opened a new pull request #12197: URL: https://github.com/apache/flink/pull/12197 ## What is the purpose of the change *DDL statement of table blink planner has no statement that drop catalog, this should add 'DROP catalog' DDL to blink planner.* ## Brief change lo

[jira] [Commented] (FLINK-17768) UnalignedCheckpointITCase.shouldPerformUnalignedCheckpointOnLocalAndRemoteChannel is instable

[ https://issues.apache.org/jira/browse/FLINK-17768?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17109396#comment-17109396 ] Robert Metzger commented on FLINK-17768: upgrading to blocker https://dev.azure.

[jira] [Updated] (FLINK-17768) UnalignedCheckpointITCase.shouldPerformUnalignedCheckpointOnLocalAndRemoteChannel is instable

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

[GitHub] [flink] pnowojski commented on a change in pull request #12186: [FLINK-16383][task] Do not relay notifyCheckpointComplete to closed operators

pnowojski commented on a change in pull request #12186: URL: https://github.com/apache/flink/pull/12186#discussion_r426235142 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointFailureReason.java ## @@ -44,6 +44,8 @@ CHECKPOINT_DE

[GitHub] [flink] JingsongLi commented on pull request #12132: [FLINK-17593][Connectors/FileSystem] Support arbitrary recovery mechanism for PartFileWriter

JingsongLi commented on pull request #12132: URL: https://github.com/apache/flink/pull/12132#issuecomment-629763746 @guoweiM Thanks for updating, can you rebase master? This is an automated message from the Apache Git Service

[GitHub] [flink] flinkbot edited a comment on pull request #12172: [FLINK-17656][tests] Migrate docker e2e tests to flink-docker

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

[GitHub] [flink] flinkbot edited a comment on pull request #12153: [FLINK-16966][metrics][infuxdb] Convert InfluxDB reporter to plugin

flinkbot edited a comment on pull request #12153: URL: https://github.com/apache/flink/pull/12153#issuecomment-628618072 ## CI report: * 670bf0c510cee2e656e3ca9633f9da66506746b0 Travis: [FAILURE](https://travis-ci.com/github/flink-ci/flink/builds/166440422) Azure: [FAILURE](http

[GitHub] [flink] JingsongLi commented on a change in pull request #12168: [WIP][FLINK-14255][hive] Integrate hive to streaming file sink

JingsongLi commented on a change in pull request #12168: URL: https://github.com/apache/flink/pull/12168#discussion_r426233687 ## File path: flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/write/HiveRecordWriterFactory.java ## @@ -167,56 +1

[GitHub] [flink] JingsongLi commented on a change in pull request #12168: [WIP][FLINK-14255][hive] Integrate hive to streaming file sink

JingsongLi commented on a change in pull request #12168: URL: https://github.com/apache/flink/pull/12168#discussion_r42626 ## File path: flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/streaming/api/functions/sink/filesystem/HadoopPathBasedBulkFormatBuilder.ja

[GitHub] [flink] JingsongLi commented on a change in pull request #12168: [WIP][FLINK-14255][hive] Integrate hive to streaming file sink

JingsongLi commented on a change in pull request #12168: URL: https://github.com/apache/flink/pull/12168#discussion_r426233264 ## File path: flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/connectors/hive/write/HadoopPathBasedPartFileWriterTest.java ## @@

[GitHub] [flink] JingsongLi commented on a change in pull request #12168: [WIP][FLINK-14255][hive] Integrate hive to streaming file sink

JingsongLi commented on a change in pull request #12168: URL: https://github.com/apache/flink/pull/12168#discussion_r426233235 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/filesystem/PartFileWriter.java ## @@ -20,122 +20,172 @@

[GitHub] [flink] JingsongLi commented on a change in pull request #12168: [WIP][FLINK-14255][hive] Integrate hive to streaming file sink

JingsongLi commented on a change in pull request #12168: URL: https://github.com/apache/flink/pull/12168#discussion_r426233102 ## File path: flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/connectors/hive/write/HadoopPathBasedPartFileWriterTest.java ## @@

[GitHub] [flink] JingsongLi commented on a change in pull request #12168: [WIP][FLINK-14255][hive] Integrate hive to streaming file sink

JingsongLi commented on a change in pull request #12168: URL: https://github.com/apache/flink/pull/12168#discussion_r426233061 ## File path: flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/connectors/hive/HiveTableSinkTest.java ## @@ -213,6 +228,95 @@ publ

[jira] [Commented] (FLINK-17487) Do not delete old checkpoints when stop the job.

[ https://issues.apache.org/jira/browse/FLINK-17487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17109386#comment-17109386 ] Congxian Qiu(klion26) commented on FLINK-17487: --- [~nobleyd] Do you mean th

[GitHub] [flink] TsReaper commented on a change in pull request #12073: [FLINK-17735][streaming] Add specialized collecting iterator

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

[GitHub] [flink] flinkbot edited a comment on pull request #12196: [FLINK-17353][docs] Fix Broken links in Flink docs master

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

[GitHub] [flink] TsReaper commented on a change in pull request #12073: [FLINK-17735][streaming] Add specialized collecting iterator

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

[GitHub] [flink] lirui-apache commented on a change in pull request #12168: [WIP][FLINK-14255][hive] Integrate hive to streaming file sink

lirui-apache commented on a change in pull request #12168: URL: https://github.com/apache/flink/pull/12168#discussion_r426141927 ## File path: flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/HiveRowDataPartitionComputer.java ## @@ -0,0 +1,7

[jira] [Commented] (FLINK-9528) Incorrect results: Filter does not treat Upsert messages correctly.

[ https://issues.apache.org/jira/browse/FLINK-9528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17109381#comment-17109381 ] Hequn Cheng commented on FLINK-9528: [~jark] (y) > Incorrect results: Filter does no

[GitHub] [flink] TsReaper commented on a change in pull request #12073: [FLINK-17735][streaming] Add specialized collecting iterator

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

[GitHub] [flink] flinkbot edited a comment on pull request #12184: [FLINK-17027] Introduce a new Elasticsearch 7 connector with new property keys

flinkbot edited a comment on pull request #12184: URL: https://github.com/apache/flink/pull/12184#issuecomment-629425634 ## CI report: * 80bbdd72c2aeb3c802deef71436882603590d147 UNKNOWN * 513b2b6030c6dc4cbe4e56ab433dd57e838ed0a9 Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot commented on pull request #12196: [FLINK-17353][docs] Fix Broken links in Flink docs master

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

[GitHub] [flink] flinkbot edited a comment on pull request #11920: [FLINK-17408] Introduce GPUDriver and discovery script

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

[jira] [Closed] (FLINK-17428) Support SupportsProjectionPushDown in planner

[ https://issues.apache.org/jira/browse/FLINK-17428?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-17428. -- Fix Version/s: 1.11.0 Resolution: Fixed master: 7c7137173a2b14f49c4f87b191ff26026af2a4d0 > Sup

[GitHub] [flink] KurtYoung merged pull request #12145: [FLINK-17428] [table-planner-blink] supports projection push down on new table source interface in blink planner

KurtYoung merged pull request #12145: URL: https://github.com/apache/flink/pull/12145 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

[jira] [Closed] (FLINK-17451) Implement view DDLs for Hive dialect

[ https://issues.apache.org/jira/browse/FLINK-17451?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-17451. -- Assignee: Rui Li Resolution: Fixed master: 81c37384e5c607cc8abd65b7db79fce78c925a62 > Implement

[GitHub] [flink] KurtYoung closed pull request #12029: [FLINK-17451][sql-parser][table-planner-blink][hive] Implement view D…

KurtYoung closed pull request #12029: URL: https://github.com/apache/flink/pull/12029 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] yangyichao-mango commented on a change in pull request #12196: [FLINK-17353][docs] Fix Broken links in Flink docs master

yangyichao-mango commented on a change in pull request #12196: URL: https://github.com/apache/flink/pull/12196#discussion_r426228350 ## File path: docs/concepts/flink-architecture.zh.md ## @@ -0,0 +1,132 @@ +--- Review comment: This md is added for matching English flin

[jira] [Commented] (FLINK-17767) Tumble and Hop window support offset

[ https://issues.apache.org/jira/browse/FLINK-17767?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17109371#comment-17109371 ] hailong wang commented on FLINK-17767: -- Hi [~jark] , This feature is explicitly not

[GitHub] [flink] yangyichao-mango commented on pull request #12196: [FLINK-17353][docs] Fix Broken links in Flink docs master

yangyichao-mango commented on pull request #12196: URL: https://github.com/apache/flink/pull/12196#issuecomment-629755819 cc @wuchong This is an automated message from the Apache Git Service. To respond to the message, pleas

[GitHub] [flink] TsReaper commented on a change in pull request #12073: [FLINK-17735][streaming] Add specialized collecting iterator

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

[GitHub] [flink] flinkbot commented on pull request #12196: [FLINK-17353][docs] Fix Broken links in Flink docs master

flinkbot commented on pull request #12196: URL: https://github.com/apache/flink/pull/12196#issuecomment-629755223 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

[jira] [Updated] (FLINK-17353) Broken links in Flink docs master

[ https://issues.apache.org/jira/browse/FLINK-17353?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-17353: --- Labels: pull-request-available (was: ) > Broken links in Flink docs master > --

[GitHub] [flink] yangyichao-mango opened a new pull request #12196: [FLINK-17353][docs] Fix Broken links in Flink docs master

yangyichao-mango opened a new pull request #12196: URL: https://github.com/apache/flink/pull/12196 ## What is the purpose of the change *Fix all of the broken links in Flink docs master mentioned in [[FLINK-17353](https://issues.apache.org/jira/browse/FLINK-17353)]*

[GitHub] [flink] flinkbot edited a comment on pull request #12195: [FLINK-17449][sql-parser][table-api-java][table-planner-blink][hive] …

flinkbot edited a comment on pull request #12195: URL: https://github.com/apache/flink/pull/12195#issuecomment-629749977 ## CI report: * eef0ff2deffeb35b7aa34da7e35c07a054bd1643 UNKNOWN * 64b2df57074876d050964bfd47143aba6a7f4011 Azure: [PENDING](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #12122: [FLINK-15102] Add continuousSource() method to StreamExecutionEnvironment.

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

[jira] [Commented] (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=17109368#comment-17109368 ] Robert Metzger commented on FLINK-16383: https://dev.azure.com/apache-flink/apac

[jira] [Commented] (FLINK-13553) KvStateServerHandlerTest.readInboundBlocking unstable on Travis

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

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

[ https://issues.apache.org/jira/browse/FLINK-17274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17109366#comment-17109366 ] Robert Metzger commented on FLINK-17274: https://dev.azure.com/apache-flink/apac

[GitHub] [flink] KurtYoung commented on a change in pull request #12073: [FLINK-17735][streaming] Add specialized collecting iterator

KurtYoung commented on a change in pull request #12073: URL: https://github.com/apache/flink/pull/12073#discussion_r426226686 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/collect/CollectResultFetcher.java ## @@ -0,0 +1,359 @@ +/* +

[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_r426226419 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/disk/FileBasedBufferIterator.java ## @@ -85,6 +90,6 @@ private int read(byte[] bu

[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_r426226419 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/disk/FileBasedBufferIterator.java ## @@ -85,6 +90,6 @@ private int read(byte[] bu

[GitHub] [flink] KurtYoung commented on a change in pull request #12073: [FLINK-17735][streaming] Add specialized collecting iterator

KurtYoung commented on a change in pull request #12073: URL: https://github.com/apache/flink/pull/12073#discussion_r426223511 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/collect/CollectResultFetcher.java ## @@ -0,0 +1,359 @@ +/* +

[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_r426226419 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/disk/FileBasedBufferIterator.java ## @@ -85,6 +90,6 @@ private int read(byte[] bu

[jira] [Commented] (FLINK-17768) UnalignedCheckpointITCase.shouldPerformUnalignedCheckpointOnLocalAndRemoteChannel is instable

[ https://issues.apache.org/jira/browse/FLINK-17768?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17109365#comment-17109365 ] Robert Metzger commented on FLINK-17768: https://dev.azure.com/apache-flink/apac

[jira] [Commented] (FLINK-17768) UnalignedCheckpointITCase.shouldPerformUnalignedCheckpointOnLocalAndRemoteChannel is instable

[ https://issues.apache.org/jira/browse/FLINK-17768?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17109364#comment-17109364 ] Robert Metzger commented on FLINK-17768: https://dev.azure.com/apache-flink/apac

[jira] [Updated] (FLINK-17768) UnalignedCheckpointITCase.shouldPerformUnalignedCheckpointOnLocalAndRemoteChannel is instable

[ https://issues.apache.org/jira/browse/FLINK-17768?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-17768: --- Priority: Critical (was: Major) > UnalignedCheckpointITCase.shouldPerformUnalignedCheckpoin

[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_r426226419 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/disk/FileBasedBufferIterator.java ## @@ -85,6 +90,6 @@ private int read(byte[] bu

[jira] [Commented] (FLINK-17730) HadoopS3RecoverableWriterITCase.testRecoverAfterMultiplePersistsStateWithMultiPart times out

[ https://issues.apache.org/jira/browse/FLINK-17730?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17109363#comment-17109363 ] Robert Metzger commented on FLINK-17730: https://dev.azure.com/apache-flink/apac

[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_r426226419 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/disk/FileBasedBufferIterator.java ## @@ -85,6 +90,6 @@ private int read(byte[] bu

[jira] [Commented] (FLINK-17768) UnalignedCheckpointITCase.shouldPerformUnalignedCheckpointOnLocalAndRemoteChannel is instable

[ https://issues.apache.org/jira/browse/FLINK-17768?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17109362#comment-17109362 ] Robert Metzger commented on FLINK-17768: https://dev.azure.com/apache-flink/apac

[jira] [Created] (FLINK-17769) Wrong order of log events on a task failure

Robert Metzger created FLINK-17769: -- Summary: Wrong order of log events on a task failure Key: FLINK-17769 URL: https://issues.apache.org/jira/browse/FLINK-17769 Project: Flink Issue Type: B

[GitHub] [flink] flinkbot edited a comment on pull request #12188: [FLINK-17728] [sql-client] sql client supports parser statements via sql parser

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

[GitHub] [flink] flinkbot edited a comment on pull request #12195: [FLINK-17449][sql-parser][table-api-java][table-planner-blink][hive] …

flinkbot edited a comment on pull request #12195: URL: https://github.com/apache/flink/pull/12195#issuecomment-629749977 ## CI report: * eef0ff2deffeb35b7aa34da7e35c07a054bd1643 UNKNOWN * 64b2df57074876d050964bfd47143aba6a7f4011 UNKNOWN Bot commands The @flinkbo

[GitHub] [flink] flinkbot edited a comment on pull request #12184: [FLINK-17027] Introduce a new Elasticsearch 7 connector with new property keys

flinkbot edited a comment on pull request #12184: URL: https://github.com/apache/flink/pull/12184#issuecomment-629425634 ## CI report: * 80bbdd72c2aeb3c802deef71436882603590d147 UNKNOWN * cd36d3abe76854bdabb47fd498e51786fee69239 Azure: [FAILURE](https://dev.azure.com/apache-fl

<    1   2   3   4   5   6