[jira] [Updated] (FLINK-18145) Segment optimization does not work in blink ?

[ https://issues.apache.org/jira/browse/FLINK-18145?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hehuiyuan updated FLINK-18145: -- Summary: Segment optimization does not work in blink ? (was: Segment optimization does not work ?) >

[jira] [Updated] (FLINK-18145) Segment optimization does not work ?

[ https://issues.apache.org/jira/browse/FLINK-18145?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hehuiyuan updated FLINK-18145: -- Component/s: Table SQL / Planner > Segment optimization does not work ? >

[jira] [Updated] (FLINK-18145) Segment optimization does not work ?

[ https://issues.apache.org/jira/browse/FLINK-18145?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hehuiyuan updated FLINK-18145: -- Attachment: image-2020-06-05-14-57-11-287.png > Segment optimization does not work ? > ---

[jira] [Updated] (FLINK-18145) Segment optimization does not work ?

[ https://issues.apache.org/jira/browse/FLINK-18145?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hehuiyuan updated FLINK-18145: -- Description: DAG Segement Optimization:    !image-2020-06-05-14-56-01-710.png|width=762,height=264!

[GitHub] [flink] danny0405 commented on a change in pull request #12439: [FLINK-17776][hive][doc] Add documentation for DDL&DML in hive dialect

danny0405 commented on a change in pull request #12439: URL: https://github.com/apache/flink/pull/12439#discussion_r435723057 ## File path: docs/dev/table/hive/hive_dialect.md ## @@ -0,0 +1,347 @@ +--- +title: "Hive Dialect" +nav-parent_id: hive_tableapi +nav-pos: 1 +--- + + +S

[jira] [Updated] (FLINK-18145) Segment optimization does not work ?

[ https://issues.apache.org/jira/browse/FLINK-18145?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hehuiyuan updated FLINK-18145: -- Attachment: image-2020-06-05-14-56-48-625.png > Segment optimization does not work ? > ---

[jira] [Updated] (FLINK-18145) Segment optimization does not work ?

[ https://issues.apache.org/jira/browse/FLINK-18145?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hehuiyuan updated FLINK-18145: -- Attachment: image-2020-06-05-14-56-01-710.png > Segment optimization does not work ? > ---

[GitHub] [flink] azagrebin edited a comment on pull request #12446: [FLINK-16225] Implement user class loading exception handler

azagrebin edited a comment on pull request #12446: URL: https://github.com/apache/flink/pull/12446#issuecomment-639295316 Thanks for the review @tillrohrmann, I will address the comments. The drawback of inheritance is, as usual, having this error handling concern and new inheritance

[jira] [Created] (FLINK-18145) Segment optimization does not work ?

hehuiyuan created FLINK-18145: - Summary: Segment optimization does not work ? Key: FLINK-18145 URL: https://issues.apache.org/jira/browse/FLINK-18145 Project: Flink Issue Type: Wish R

[jira] [Commented] (FLINK-16795) End to end tests timeout on Azure

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

[GitHub] [flink] azagrebin commented on pull request #12446: [FLINK-16225] Implement user class loading exception handler

azagrebin commented on pull request #12446: URL: https://github.com/apache/flink/pull/12446#issuecomment-639295316 Thanks for the review @tillrohrmann, I will address the comments. The drawback of inheritance is, as usual, having this error handling concern and new inheritance contra

[GitHub] [flink] flinkbot edited a comment on pull request #12435: [FLINK-18059] [sql-client] Fix create/drop catalog statement can not be executed in sql client

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

[GitHub] [flink] flinkbot edited a comment on pull request #12319: [FLINK-17406][doc] Add documentation about dynamic table options

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

[GitHub] [flink] flinkbot edited a comment on pull request #12355: [FLINK-17893] [sql-client] SQL CLI should print the root cause if the statement is invalid

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

[GitHub] [flink] Jiayi-Liao commented on a change in pull request #11445: [FLINK-16615] Introduce data structures and utilities to calculate Job Manager memory components

Jiayi-Liao commented on a change in pull request #11445: URL: https://github.com/apache/flink/pull/11445#discussion_r435721169 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/util/config/memory/ProcessMemoryUtils.java ## @@ -0,0 +1,281 @@ +/* + * Licensed to

[jira] [Commented] (FLINK-16497) Improve default flush strategy for JDBC sink to make it work out-of-box

[ https://issues.apache.org/jira/browse/FLINK-16497?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17126446#comment-17126446 ] lincoln lee commented on FLINK-16497: - +1 to default flush size (100) and flush inte

[jira] [Commented] (FLINK-18085) Manually test application mode for standalone, Yarn, K8s

[ https://issues.apache.org/jira/browse/FLINK-18085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17126450#comment-17126450 ] Yang Wang commented on FLINK-18085: --- Testing application mode in a Yarn cluster with n

[GitHub] [flink] wuchong commented on a change in pull request #12483: [FLINK-15339][table][docs] Correct the terminology of "Time-windowed Join" to "Interval Join" in Table API & SQL

wuchong commented on a change in pull request #12483: URL: https://github.com/apache/flink/pull/12483#discussion_r435718608 ## File path: flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/join/ProcTimeIntervalStreamJoin.java ## @@ -24

[GitHub] [flink] danny0405 commented on a change in pull request #12483: [FLINK-15339][table][docs] Correct the terminology of "Time-windowed Join" to "Interval Join" in Table API & SQL

danny0405 commented on a change in pull request #12483: URL: https://github.com/apache/flink/pull/12483#discussion_r435717318 ## File path: flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/join/ProcTimeIntervalStreamJoin.java ## @@ -

[jira] [Issue Comment Deleted] (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 ] Yuan Mei updated FLINK-17769: - Comment: was deleted (was: *This is what I think is happening:* The error msg of "Error during disposal

[jira] [Comment Edited] (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:comment-tabpanel&focusedCommentId=17125674#comment-17125674 ] Yuan Mei edited comment on FLINK-17769 at 6/5/20, 6:31 AM: --- *T

[jira] [Commented] (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:comment-tabpanel&focusedCommentId=17126444#comment-17126444 ] Yuan Mei commented on FLINK-17769: -- [~roman_khachatryan] [~pnowojski] Please let me kn

[GitHub] [flink] wuchong commented on a change in pull request #12483: [FLINK-15339][table][docs] Correct the terminology of "Time-windowed Join" to "Interval Join" in Table API & SQL

wuchong commented on a change in pull request #12483: URL: https://github.com/apache/flink/pull/12483#discussion_r435714461 ## File path: flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/join/ProcTimeIntervalStreamJoin.java ## @@ -24

[jira] [Comment Edited] (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:comment-tabpanel&focusedCommentId=17126427#comment-17126427 ] Yuan Mei edited comment on FLINK-17769 at 6/5/20, 6:27 AM: --- Or

[GitHub] [flink] danny0405 commented on a change in pull request #12483: [FLINK-15339][table][docs] Correct the terminology of "Time-windowed Join" to "Interval Join" in Table API & SQL

danny0405 commented on a change in pull request #12483: URL: https://github.com/apache/flink/pull/12483#discussion_r435711748 ## File path: docs/dev/table/sql/queries.zh.md ## @@ -566,15 +566,15 @@ FROM Orders FULL OUTER JOIN Product ON Orders.productId = Product.id

[jira] [Comment Edited] (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:comment-tabpanel&focusedCommentId=17126427#comment-17126427 ] Yuan Mei edited comment on FLINK-17769 at 6/5/20, 6:25 AM: --- Or

[jira] [Comment Edited] (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:comment-tabpanel&focusedCommentId=17126427#comment-17126427 ] Yuan Mei edited comment on FLINK-17769 at 6/5/20, 6:23 AM: --- Or

[jira] [Comment Edited] (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:comment-tabpanel&focusedCommentId=17126427#comment-17126427 ] Yuan Mei edited comment on FLINK-17769 at 6/5/20, 6:22 AM: --- Or

[jira] [Commented] (FLINK-17571) A better way to show the files used in currently checkpoints

[ https://issues.apache.org/jira/browse/FLINK-17571?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17126434#comment-17126434 ] Jiayi Liao commented on FLINK-17571: [~klion26] Thanks for your advice! That's exact

[GitHub] [flink] wuchong commented on a change in pull request #12427: [FLINK-16681][jdbc] Fix the bug that jdbc lost connection after a lon…

wuchong commented on a change in pull request #12427: URL: https://github.com/apache/flink/pull/12427#discussion_r435711642 ## File path: flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/internal/executor/InsertOrUpdateJdbcExecutor.java ## @@

[jira] [Commented] (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:comment-tabpanel&focusedCommentId=17126427#comment-17126427 ] Yuan Mei commented on FLINK-17769: -- Originally, I was thinking this problem is introduc

[jira] [Commented] (FLINK-17571) A better way to show the files used in currently checkpoints

[ https://issues.apache.org/jira/browse/FLINK-17571?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17126428#comment-17126428 ] Congxian Qiu(klion26) commented on FLINK-17571: --- [~wind_ljy] The reason do

[jira] [Closed] (FLINK-15687) Potential test instabilities due to concurrent access to TaskSlotTable.

[ https://issues.apache.org/jira/browse/FLINK-15687?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-15687. Resolution: Fixed Fixed via master: e2cffe19a044d6decfae83e14ce59eca1e4c449f 1.11.0: 10b2842013377

[GitHub] [flink] xintongsong closed pull request #12399: [FLINK-15687][runtime][test] Fix test instabilities due to concurrent access to TaskSlotTable

xintongsong closed pull request #12399: URL: https://github.com/apache/flink/pull/12399 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] xintongsong commented on pull request #12399: [FLINK-15687][runtime][test] Fix test instabilities due to concurrent access to TaskSlotTable

xintongsong commented on pull request #12399: URL: https://github.com/apache/flink/pull/12399#issuecomment-639278497 Thanks for the review, @wangyang0918. Merging this. This is an automated message from the Apache Git Service

[jira] [Commented] (FLINK-15745) KafkaITCase.testKeyValueSupport failure due to assertion error.

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

[jira] [Created] (FLINK-18144) State TTL configuration can't be set in SQL CLI

Jark Wu created FLINK-18144: --- Summary: State TTL configuration can't be set in SQL CLI Key: FLINK-18144 URL: https://issues.apache.org/jira/browse/FLINK-18144 Project: Flink Issue Type: Bug

[GitHub] [flink] flinkbot edited a comment on pull request #12497: [FLINK-18142][hive] Wrong state names in HiveContinuousMonitoringFunction

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

[GitHub] [flink] flinkbot edited a comment on pull request #12399: [FLINK-15687][runtime][test] Fix test instabilities due to concurrent access to TaskSlotTable

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

[GitHub] [flink] flinkbot edited a comment on pull request #12495: [FLINK-18048][Backport 1.10] Fix --host option for standalone job cluster

flinkbot edited a comment on pull request #12495: URL: https://github.com/apache/flink/pull/12495#issuecomment-639245767 ## CI report: * 6589b314827707fe2b20b00c4f14936b4adb4474 Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/169752033) Bot comman

[jira] [Commented] (FLINK-18143) Fix Python meter metric not correct problem

[ https://issues.apache.org/jira/browse/FLINK-18143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17126409#comment-17126409 ] Hequn Cheng commented on FLINK-18143: - Fixed in 1.12.0 via dcd764a8a0df788846886f2c

[jira] [Closed] (FLINK-18143) Fix Python meter metric not correct problem

[ https://issues.apache.org/jira/browse/FLINK-18143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-18143. --- Resolution: Fixed > Fix Python meter metric not correct problem > --

[GitHub] [flink] hequn8128 merged pull request #12498: [FLINK-18143][python] Fix Python meter metric incorrect value problem

hequn8128 merged pull request #12498: URL: https://github.com/apache/flink/pull/12498 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] hequn8128 commented on pull request #12498: [FLINK-18143][python] Fix Python meter metric incorrect value problem

hequn8128 commented on pull request #12498: URL: https://github.com/apache/flink/pull/12498#issuecomment-639269071 @dianfu Thanks. Merging... This is an automated message from the Apache Git Service. To respond to the message

[jira] [Commented] (FLINK-18100) Test different user-defined metrics for Python UDF

[ https://issues.apache.org/jira/browse/FLINK-18100?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17126406#comment-17126406 ] Hequn Cheng commented on FLINK-18100: - Check different kinds of metrics. Found one b

[jira] [Commented] (FLINK-18101) Test Python Pipeline API including Transformer and Estimator

[ https://issues.apache.org/jira/browse/FLINK-18101?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17126405#comment-17126405 ] Hequn Cheng commented on FLINK-18101: - Done. Test Python Transformer and Estimator.

[jira] [Closed] (FLINK-18101) Test Python Pipeline API including Transformer and Estimator

[ https://issues.apache.org/jira/browse/FLINK-18101?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-18101. --- Resolution: Resolved > Test Python Pipeline API including Transformer and Estimator > --

[GitHub] [flink] dianfu commented on pull request #12498: [FLINK-18143][python] Fix Python meter metric incorrect value problem

dianfu commented on pull request #12498: URL: https://github.com/apache/flink/pull/12498#issuecomment-639266564 @hequn8128 Thanks for the PR. LGTM. This is an automated message from the Apache Git Service. To respond to the m

[GitHub] [flink] flinkbot commented on pull request #12498: [FLINK-18143][python] Fix Python meter metric incorrect value problem

flinkbot commented on pull request #12498: URL: https://github.com/apache/flink/pull/12498#issuecomment-639266322 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] hequn8128 opened a new pull request #12498: [FLINK-18143][python] Fix Python meter metric incorrect value problem

hequn8128 opened a new pull request #12498: URL: https://github.com/apache/flink/pull/12498 ## What is the purpose of the change This pull request fixes Python meter metric incorrect value problem. ## Brief change log - Report the diff value instead of the

[jira] [Updated] (FLINK-18143) Fix Python meter metric not correct problem

[ https://issues.apache.org/jira/browse/FLINK-18143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-18143: --- Labels: pull-request-available (was: ) > Fix Python meter metric not correct problem >

[GitHub] [flink] flinkbot edited a comment on pull request #12456: [FLINK-17113][sql-cli] Refactor view support in SQL Client

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

[GitHub] [flink] flinkbot edited a comment on pull request #12497: [FLINK-18142][hive] Wrong state names in HiveContinuousMonitoringFunction

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

[GitHub] [flink] flinkbot edited a comment on pull request #12494: [FLINK-18038] [statebackend] Logging user-provided state backends after they are configured

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

[jira] [Updated] (FLINK-18143) Fix Python meter metric not correct problem

[ https://issues.apache.org/jira/browse/FLINK-18143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-18143: Description: We should report the diff value instead of the total ones. Code `meter.markEvent(upda

[jira] [Assigned] (FLINK-18143) Fix Python meter metric not correct problem

[ https://issues.apache.org/jira/browse/FLINK-18143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reassigned FLINK-18143: --- Assignee: Hequn Cheng > Fix Python meter metric not correct problem > -

[jira] [Created] (FLINK-18143) Fix Python meter metric not correct problem

Hequn Cheng created FLINK-18143: --- Summary: Fix Python meter metric not correct problem Key: FLINK-18143 URL: https://issues.apache.org/jira/browse/FLINK-18143 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-17949) KafkaShuffleITCase.testSerDeIngestionTime:156->testRecordSerDe:388 expected:<310> but was:<0>

[ https://issues.apache.org/jira/browse/FLINK-17949?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17126396#comment-17126396 ] Jiangjie Qin commented on FLINK-17949: -- The LEADER_NOT_AVAILABLE case basically mea

[jira] [Commented] (FLINK-16497) Improve default flush strategy for JDBC sink to make it work out-of-box

[ https://issues.apache.org/jira/browse/FLINK-16497?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17126395#comment-17126395 ] Benchao Li commented on FLINK-16497: +1 to Danny's proposal. > Improve default flus

[GitHub] [flink] Myasuka commented on a change in pull request #12470: [FLINK-18074][checkpoint] Ensure task could fail when exception thrown out on notified of checkpoint completed/aborted

Myasuka commented on a change in pull request #12470: URL: https://github.com/apache/flink/pull/12470#discussion_r435692788 ## File path: flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/StreamTaskTest.java ## @@ -969,6 +970,34 @@ public void testNot

[jira] [Closed] (FLINK-18074) Confirm checkpoint completed on task side would not fail the task if exception thrown out

[ https://issues.apache.org/jira/browse/FLINK-18074?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-18074. -- Resolution: Fixed merged commit e27c517 into apache:master and 29f9918046 to release-1.11 > C

[GitHub] [flink] pnowojski commented on a change in pull request #12470: [FLINK-18074][checkpoint] Ensure task could fail when exception thrown out on notified of checkpoint completed/aborted

pnowojski commented on a change in pull request #12470: URL: https://github.com/apache/flink/pull/12470#discussion_r435691849 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java ## @@ -919,9 +920,33 @@ public final Executor

[GitHub] [flink] pnowojski merged pull request #12470: [FLINK-18074][checkpoint] Ensure task could fail when exception thrown out on notified of checkpoint completed/aborted

pnowojski merged pull request #12470: URL: https://github.com/apache/flink/pull/12470 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] pnowojski commented on pull request #12470: [FLINK-18074][checkpoint] Ensure task could fail when exception thrown out on notified of checkpoint completed/aborted

pnowojski commented on pull request #12470: URL: https://github.com/apache/flink/pull/12470#issuecomment-639260996 Merged, thanks for fixing the issue :) This is an automated message from the Apache Git Service. To respond to

[GitHub] [flink] Myasuka commented on a change in pull request #12470: [FLINK-18074][checkpoint] Ensure task could fail when exception thrown out on notified of checkpoint completed/aborted

Myasuka commented on a change in pull request #12470: URL: https://github.com/apache/flink/pull/12470#discussion_r435691165 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java ## @@ -919,9 +920,33 @@ public final ExecutorSe

[GitHub] [flink] flinkbot commented on pull request #12497: [FLINK-18142][hive] Wrong state names in HiveContinuousMonitoringFunction

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

[GitHub] [flink] flinkbot edited a comment on pull request #12496: [FLINK-18110][fs-connector] StreamingFileSink notifies for buckets detected to be inactive on restoring

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

[GitHub] [flink] flinkbot edited a comment on pull request #12335: [FLINK-17753] [table-planner-blink] Fix watermark defined in ddl does not work in Table api

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

[GitHub] [flink] flinkbot edited a comment on pull request #12456: [FLINK-17113][sql-cli] Refactor view support in SQL Client

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

[jira] [Commented] (FLINK-16198) FileUtilsTest fails on Mac OS

[ https://issues.apache.org/jira/browse/FLINK-16198?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17126385#comment-17126385 ] Zhe Yu commented on FLINK-16198: PR: [https://github.com/apache/flink/pull/12413] > Fil

[GitHub] [flink] godfreyhe commented on a change in pull request #12471: [FLINK-18073][FLINK-18029][avro] Fix AvroRowDataSerializationSchema is not serializable and add IT cases

godfreyhe commented on a change in pull request #12471: URL: https://github.com/apache/flink/pull/12471#discussion_r435687446 ## File path: flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/typeutils/AvroSchemaConverter.java ## @@ -254,14 +254,6 @@ public st

[GitHub] [flink] pnowojski commented on a change in pull request #12457: [FLINK-18050][task][checkpointing] Fix double buffer recycling

pnowojski commented on a change in pull request #12457: URL: https://github.com/apache/flink/pull/12457#discussion_r435687298 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/channel/ChannelStateWriteRequest.java ## @@ -52,6 +53,10 @@ static Channe

[jira] [Comment Edited] (FLINK-17824) "Resuming Savepoint" e2e stalls indefinitely

[ https://issues.apache.org/jira/browse/FLINK-17824?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17126379#comment-17126379 ] Piotr Nowojski edited comment on FLINK-17824 at 6/5/20, 4:39 AM: -

[jira] [Commented] (FLINK-17824) "Resuming Savepoint" e2e stalls indefinitely

[ https://issues.apache.org/jira/browse/FLINK-17824?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17126379#comment-17126379 ] Piotr Nowojski commented on FLINK-17824: As it was first reported around feature

[GitHub] [flink] JingsongLi commented on pull request #12408: [FLINK-15547][hive] Add test for avro table

JingsongLi commented on pull request #12408: URL: https://github.com/apache/flink/pull/12408#issuecomment-639253780 @lirui-apache Please rebase and update JIRA. This is an automated message from the Apache Git Service. To res

[jira] [Commented] (FLINK-16497) Improve default flush strategy for JDBC sink to make it work out-of-box

[ https://issues.apache.org/jira/browse/FLINK-16497?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17126378#comment-17126378 ] Jingsong Lee commented on FLINK-16497: -- +1 to default flush size (100) and flush in

[GitHub] [flink] pnowojski commented on pull request #12457: [FLINK-18050][task][checkpointing] Fix double buffer recycling

pnowojski commented on pull request #12457: URL: https://github.com/apache/flink/pull/12457#issuecomment-639252997 This issue FLINK-17824 could be caused by some of our changes, we should take a look at it. This is an automa

[GitHub] [flink] TsReaper commented on a change in pull request #12453: [FLINK-18061] [table] TableResult#collect method should return a closeable iterator to avoid resource leak

TsReaper commented on a change in pull request #12453: URL: https://github.com/apache/flink/pull/12453#discussion_r435684399 ## File path: flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/TableResult.java ## @@ -49,9 +49,33 @@ ResultKind getRes

[GitHub] [flink] flinkbot commented on pull request #12497: [FLINK-18142][hive] Wrong state names in HiveContinuousMonitoringFunction

flinkbot commented on pull request #12497: URL: https://github.com/apache/flink/pull/12497#issuecomment-639252070 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] danny0405 commented on pull request #12456: [FLINK-17113][sql-cli] Refactor view support in SQL Client

danny0405 commented on pull request #12456: URL: https://github.com/apache/flink/pull/12456#issuecomment-639252001 > Thanks for the fix @danny0405 , I find there are many unrelated change ? such as `Sink`, `TableSourceTable`, `FlinkTypeFactory`. I found that the legacy planner does n

[GitHub] [flink] TsReaper commented on a change in pull request #12473: [FLINK-18061] [table] TableResult#collect method should return a closeable iterator to avoid resource leak

TsReaper commented on a change in pull request #12473: URL: https://github.com/apache/flink/pull/12473#discussion_r435684144 ## File path: flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/TableResult.java ## @@ -49,9 +49,33 @@ ResultKind getRes

[GitHub] [flink] JingsongLi opened a new pull request #12497: [FLINK-18142][hive] Wrong state names in HiveContinuousMonitoringFunction

JingsongLi opened a new pull request #12497: URL: https://github.com/apache/flink/pull/12497 ## What is the purpose of the change Should have different name between currReadTimeState and distinctPartsState. Otherwise will checkpoint failure. ## Verifying this change

[jira] [Updated] (FLINK-18142) Wrong state names in HiveContinuousMonitoringFunction

[ https://issues.apache.org/jira/browse/FLINK-18142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-18142: --- Labels: pull-request-available (was: ) > Wrong state names in HiveContinuousMonitoringFunct

[GitHub] [flink] flinkbot edited a comment on pull request #12496: [FLINK-18110][fs-connector] StreamingFileSink notifies for buckets detected to be inactive on restoring

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

[GitHub] [flink] flinkbot edited a comment on pull request #12495: [FLINK-18048][Backport 1.10] Fix --host option for standalone job cluster

flinkbot edited a comment on pull request #12495: URL: https://github.com/apache/flink/pull/12495#issuecomment-639245767 ## CI report: * 6589b314827707fe2b20b00c4f14936b4adb4474 Travis: [PENDING](https://travis-ci.com/github/flink-ci/flink/builds/169752033) Bot comman

[GitHub] [flink] flinkbot edited a comment on pull request #12335: [FLINK-17753] [table-planner-blink] Fix watermark defined in ddl does not work in Table api

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

[GitHub] [flink] flinkbot edited a comment on pull request #12485: [FLINK-18130][hive][fs-connector] File name conflict for different jobs in filesystem/hive sink

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

[GitHub] [flink] flinkbot edited a comment on pull request #12028: [FLINK-17553][table]fix plan error when constant exists in group window key

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

[jira] [Updated] (FLINK-18142) Wrong state names in HiveContinuousMonitoringFunction

[ https://issues.apache.org/jira/browse/FLINK-18142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-18142: - Priority: Critical (was: Major) > Wrong state names in HiveContinuousMonitoringFunction > -

[jira] [Created] (FLINK-18142) Wrong state names in HiveContinuousMonitoringFunction

Jingsong Lee created FLINK-18142: Summary: Wrong state names in HiveContinuousMonitoringFunction Key: FLINK-18142 URL: https://issues.apache.org/jira/browse/FLINK-18142 Project: Flink Issue T

[jira] [Commented] (FLINK-16497) Improve default flush strategy for JDBC sink to make it work out-of-box

[ https://issues.apache.org/jira/browse/FLINK-16497?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17126373#comment-17126373 ] Danny Chen commented on FLINK-16497: I think as a popular streaming engine, ensure g

[jira] [Comment Edited] (FLINK-17949) KafkaShuffleITCase.testSerDeIngestionTime:156->testRecordSerDe:388 expected:<310> but was:<0>

[ https://issues.apache.org/jira/browse/FLINK-17949?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17126353#comment-17126353 ] Yuan Mei edited comment on FLINK-17949 at 6/5/20, 4:09 AM: --- Th

[GitHub] [flink] flinkbot commented on pull request #12496: [FLINK-18110][fs-connector] StreamingFileSink notifies for buckets detected to be inactive on restoring

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

[GitHub] [flink] zhijiangW commented on a change in pull request #12493: [FLINK-18139][checkpointing] Fixing unaligned checkpoints checks wrong channels for inflight data.

zhijiangW commented on a change in pull request #12493: URL: https://github.com/apache/flink/pull/12493#discussion_r435678966 ## File path: flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/io/StreamTaskNetworkInputTest.java ## @@ -110,6 +118,69 @@ public v

[GitHub] [flink] flinkbot commented on pull request #12495: [FLINK-18048][Backport 1.10] Fix --host option for standalone job cluster

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

[GitHub] [flink] flinkbot edited a comment on pull request #12485: [FLINK-18130][hive][fs-connector] File name conflict for different jobs in filesystem/hive sink

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

[jira] [Closed] (FLINK-17033) Upgrade OpenJDK docker image for Kubernetes

[ https://issues.apache.org/jira/browse/FLINK-17033?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang closed FLINK-17033. - Resolution: Fixed > Upgrade OpenJDK docker image for Kubernetes > --

[jira] [Updated] (FLINK-17033) Upgrade OpenJDK docker image for Kubernetes

[ https://issues.apache.org/jira/browse/FLINK-17033?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang updated FLINK-17033: -- Fix Version/s: 1.12.0 > Upgrade OpenJDK docker image for Kubernetes >

[jira] [Commented] (FLINK-17033) Upgrade OpenJDK docker image for Kubernetes

[ https://issues.apache.org/jira/browse/FLINK-17033?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17126362#comment-17126362 ] Yang Wang commented on FLINK-17033: --- >From release-1.11(done via FLINK-17160), the bas

[GitHub] [flink] flinkbot edited a comment on pull request #12028: [FLINK-17553][table]fix plan error when constant exists in group window key

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

  1   2   3   4   5   6   7   >