[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=17126409#comment-17126409 ] Hequn Cheng commented on FLINK-18143: - Fixed in 1.12.0 via dcd764a8a0df788846886f2c3aa2b38828ae0e21

[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

[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

[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=17126406#comment-17126406 ] Hequn Cheng commented on FLINK-18100: - Check different kinds of metrics. Found one bug for meter.

[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=17126405#comment-17126405 ] Hequn Cheng commented on FLINK-18101: - Done. Test Python Transformer and Estimator. Test Wrapper

[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

[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

[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:

[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:

[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:

[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

[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=17126396#comment-17126396 ] Jiangjie Qin commented on FLINK-17949: -- The LEADER_NOT_AVAILABLE case basically means the partition

[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=17126395#comment-17126395 ] Benchao Li commented on FLINK-16497: +1 to Danny's proposal. > Improve default flush strategy for

[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

[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 >

[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

[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

[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

[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

[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

[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:

[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:

[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:

[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=17126385#comment-17126385 ] Zhe Yu commented on FLINK-16198: PR: [https://github.com/apache/flink/pull/12413] > FileUtilsTest fails

[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

[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

[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=17126379#comment-17126379 ] Piotr Nowojski edited comment on FLINK-17824 at 6/5/20, 4:39 AM: - As it

[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=17126379#comment-17126379 ] Piotr Nowojski commented on FLINK-17824: As it was first reported around feature when we were

[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

[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=17126378#comment-17126378 ] Jingsong Lee commented on FLINK-16497: -- +1 to default flush size (100) and flush interval(1s).  I

[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

[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

[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

[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

[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

[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

[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:

[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

[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:

[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:

[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:

[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

[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=17126373#comment-17126373 ] Danny Chen commented on FLINK-16497: I think as a popular streaming engine, ensure good throughput

[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=17126353#comment-17126353 ] Yuan Mei edited comment on FLINK-17949 at 6/5/20, 4:09 AM: --- These comments are

[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

[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

[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

[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:

[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=17126362#comment-17126362 ] Yang Wang commented on FLINK-17033: --- >From release-1.11(done via FLINK-17160), the base image has been

[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:

[jira] [Closed] (FLINK-16508) Name the ports exposed by the main Container in Pod

[ https://issues.apache.org/jira/browse/FLINK-16508?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang closed FLINK-16508. - Fix Version/s: 1.12.0 Resolution: Fixed Master and release-1.11 via

[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-639243709 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

[jira] [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=17126348#comment-17126348 ] Yuan Mei edited comment on FLINK-17949 at 6/5/20, 3:55 AM: --- Thanks,

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

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

[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=17126353#comment-17126353 ] Yuan Mei commented on FLINK-17949: -- This comment is quoted from [~becket_qin] "Theoretically speaking,

[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=17126353#comment-17126353 ] Yuan Mei edited comment on FLINK-17949 at 6/5/20, 3:54 AM: --- This comment is

[jira] [Updated] (FLINK-18110) Bucket Listener in StreamingFileSink should notify for buckets detected to be inactive at recovery

[ https://issues.apache.org/jira/browse/FLINK-18110?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-18110: --- Labels: pull-request-available (was: ) > Bucket Listener in StreamingFileSink should

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

gaoyunhaii opened a new pull request #12496: URL: https://github.com/apache/flink/pull/12496 ## What is the purpose of the change This PR fixed the issue that the `BucketLifeCycleListener` in `StreamingFileSink` misses the notification for buckets detected inactive on restoring. On

[jira] [Updated] (FLINK-17102) Add -Dkubernetes.container.image= for the start-flink-session section

[ https://issues.apache.org/jira/browse/FLINK-17102?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang updated FLINK-17102: -- Affects Version/s: 1.11.0 1.10.1 > Add -Dkubernetes.container.image= for the

[jira] [Closed] (FLINK-17102) Add -Dkubernetes.container.image= for the start-flink-session section

[ https://issues.apache.org/jira/browse/FLINK-17102?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang closed FLINK-17102. - Resolution: Fixed > Add -Dkubernetes.container.image= for the start-flink-session > section >

[jira] [Commented] (FLINK-17102) Add -Dkubernetes.container.image= for the start-flink-session section

[ https://issues.apache.org/jira/browse/FLINK-17102?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17126351#comment-17126351 ] Yang Wang commented on FLINK-17102: --- The image option has been added in custom-flink-docker-image

[jira] [Updated] (FLINK-17102) Add -Dkubernetes.container.image= for the start-flink-session section

[ https://issues.apache.org/jira/browse/FLINK-17102?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang updated FLINK-17102: -- Fix Version/s: 1.12.0 1.11.0 > Add -Dkubernetes.container.image= for the

[GitHub] [flink] zhuzhurk commented on a change in pull request #12375: [FLINK-17017][runtime] Implements bulk allocation for physical slots

zhuzhurk commented on a change in pull request #12375: URL: https://github.com/apache/flink/pull/12375#discussion_r435674952 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/BulkSlotProviderImpl.java ## @@ -0,0 +1,271 @@ +/* + * Licensed

[jira] [Updated] (FLINK-16496) Improve default flush strategy for HBase sink to make it work out-of-box

[ https://issues.apache.org/jira/browse/FLINK-16496?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-16496: Priority: Critical (was: Major) > Improve default flush strategy for HBase sink to make it work

[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=17126348#comment-17126348 ] Yuan Mei edited comment on FLINK-17949 at 6/5/20, 3:46 AM: --- Thanks,

[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=17126348#comment-17126348 ] Yuan Mei edited comment on FLINK-17949 at 6/5/20, 3:46 AM: --- Thanks,

[jira] [Updated] (FLINK-16495) Improve default flush strategy for Elasticsearch sink to make it work out-of-box

[ https://issues.apache.org/jira/browse/FLINK-16495?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-16495: Fix Version/s: (was: 1.12.0) 1.11.0 > Improve default flush strategy for

[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_r435674425 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/CheckpointBarrierUnaligner.java ## @@ -331,6 +331,7 @@ public

[jira] [Updated] (FLINK-16495) Improve default flush strategy for Elasticsearch sink to make it work out-of-box

[ https://issues.apache.org/jira/browse/FLINK-16495?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-16495: Priority: Critical (was: Major) > Improve default flush strategy for Elasticsearch sink to make it work

[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_r435674253 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/CheckpointBarrierUnaligner.java ## @@ -310,16 +310,16 @@

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

JingsongLi commented on pull request #12485: URL: https://github.com/apache/flink/pull/12485#issuecomment-639241037 CC: @gaoyunhaii @lirui-apache This is an automated message from the Apache Git Service. To respond to the

[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=17126348#comment-17126348 ] Yuan Mei commented on FLINK-17949: -- Thanks, Robert, I got a bit more msg this time:   {code:java}

[jira] [Commented] (FLINK-17416) Flink-kubernetes doesn't work on java 8 8u252

[ https://issues.apache.org/jira/browse/FLINK-17416?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17126347#comment-17126347 ] Yang Wang commented on FLINK-17416: --- Fixed in FLINK-17565. > Flink-kubernetes doesn't work on java 8

[jira] [Updated] (FLINK-17416) Flink-kubernetes doesn't work on java 8 8u252

[ https://issues.apache.org/jira/browse/FLINK-17416?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang updated FLINK-17416: -- Release Note: (was: Fixed in FLINK-17565.) > Flink-kubernetes doesn't work on java 8 8u252 >

[jira] [Closed] (FLINK-17416) Flink-kubernetes doesn't work on java 8 8u252

[ https://issues.apache.org/jira/browse/FLINK-17416?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang closed FLINK-17416. - Release Note: Fixed in FLINK-17565. Resolution: Fixed > Flink-kubernetes doesn't work on java 8

[jira] [Closed] (FLINK-17566) Fix potential K8s resources leak after JobManager finishes in Applicaion mode

[ https://issues.apache.org/jira/browse/FLINK-17566?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang closed FLINK-17566. - Resolution: Fixed > Fix potential K8s resources leak after JobManager finishes in Applicaion mode >

[jira] [Commented] (FLINK-17566) Fix potential K8s resources leak after JobManager finishes in Applicaion mode

[ https://issues.apache.org/jira/browse/FLINK-17566?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17126345#comment-17126345 ] Yang Wang commented on FLINK-17566: --- Fixed in FLINK-17565. > Fix potential K8s resources leak after

[jira] [Updated] (FLINK-17416) Flink-kubernetes doesn't work on java 8 8u252

[ https://issues.apache.org/jira/browse/FLINK-17416?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang updated FLINK-17416: -- Fix Version/s: 1.12.0 > Flink-kubernetes doesn't work on java 8 8u252 >

[jira] [Closed] (FLINK-17883) Unable to configure write mode for FileSystem() connector in PyFlink

[ https://issues.apache.org/jira/browse/FLINK-17883?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-17883. --- Resolution: Won't Fix [~rmetzger] Thanks for creating this ticket. I'm closing it as it should already be

[jira] [Commented] (FLINK-18122) Kubernetes test fails with "error: timed out waiting for the condition on jobs/flink-job-cluster"

[ https://issues.apache.org/jira/browse/FLINK-18122?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17126337#comment-17126337 ] Yang Wang commented on FLINK-18122: --- I agree that we should {{exit}} when build the image failed. >

[jira] [Comment Edited] (FLINK-18122) Kubernetes test fails with "error: timed out waiting for the condition on jobs/flink-job-cluster"

[ https://issues.apache.org/jira/browse/FLINK-18122?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17126337#comment-17126337 ] Yang Wang edited comment on FLINK-18122 at 6/5/20, 3:17 AM: I agree that we

[GitHub] [flink] wuchong commented on a change in pull request #12303: [FLINK-17625] [table] Fix ArrayIndexOutOfBoundsException in AppendOnlyTopNFunction

wuchong commented on a change in pull request #12303: URL: https://github.com/apache/flink/pull/12303#discussion_r435667861 ## File path: flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/rank/AppendOnlyTopNFunction.java ## @@

[jira] [Commented] (FLINK-17883) Unable to configure write mode for FileSystem() connector in PyFlink

[ https://issues.apache.org/jira/browse/FLINK-17883?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17126336#comment-17126336 ] Dian Fu commented on FLINK-17883: - I have verified the following interface defined in StatementSet:

[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-639233022 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

[GitHub] [flink] wangyang0918 opened a new pull request #12495: [FLINK-18048] Fix --host option for standalone job cluster

wangyang0918 opened a new pull request #12495: URL: https://github.com/apache/flink/pull/12495 Backport #12426 to release-1.10 branch. This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [flink] flinkbot edited a comment on pull request #12488: [FLINK-18126][python] Correct the exception handling of the Python CompletableFuture

flinkbot edited a comment on pull request #12488: URL: https://github.com/apache/flink/pull/12488#issuecomment-638911342 ## CI report: * b0ec0676015c04ee58c9aa38b9733f42a99e1997 Azure:

[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: * 84524977ee6597667093943fce7c1730ab934c35 Azure:

[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: * e733198f517f74de94d68622a3a039d3f888acaa Azure:

[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:

[jira] [Closed] (FLINK-15126) migrate "show functions" from sql cli to sql parser

[ https://issues.apache.org/jira/browse/FLINK-15126?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Chen closed FLINK-15126. -- Resolution: Fixed > migrate "show functions" from sql cli to sql parser >

  1   2   3   4   5   6   7   >