[GitHub] [flink] flinkbot edited a comment on pull request #12689: [FLINK-18320][notice][hive] Merge hive-exec dependencies for hive uber 2.3.6 and 3.1.2

2020-06-16 Thread GitBox
flinkbot edited a comment on pull request #12689: URL: https://github.com/apache/flink/pull/12689#issuecomment-645159155 ## CI report: * fcb7907dc31fc27756076404f60ab8fd50503f03 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12525: [FLINK-17769] [runtime] Fix the order of log events on a task failure

2020-06-16 Thread GitBox
flinkbot edited a comment on pull request #12525: URL: https://github.com/apache/flink/pull/12525#issuecomment-640513261 ## CI report: * 2276d043aa2232437e36b047d4fcd284f698d011 Azure:

[GitHub] [flink] lirui-apache commented on pull request #12682: [FLINK-18320][hive] Fix NOTICE and license files for flink-sql-connec…

2020-06-16 Thread GitBox
lirui-apache commented on pull request #12682: URL: https://github.com/apache/flink/pull/12682#issuecomment-645164498 Thank you all for the review. I have updated to address (some of) the comments. The JSON classes are excluded from the jar (Flink does't need them to integrate with Hive).

[jira] [Commented] (FLINK-18070) Time attribute been materialized after sub graph optimize

2020-06-16 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18070?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17138115#comment-17138115 ] godfrey he commented on FLINK-18070: we need to materialize time attribute only in sink-block. >

[jira] [Commented] (FLINK-18070) Time attribute been materialized after sub graph optimize

2020-06-16 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18070?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17138114#comment-17138114 ] godfrey he commented on FLINK-18070: [~liuyufei] Thanks for reporting this. the simple approach to

[GitHub] [flink] flinkbot commented on pull request #12689: [FLINK-18320][notice][hive] Merge hive-exec dependencies for hive uber 2.3.6 and 3.1.2

2020-06-16 Thread GitBox
flinkbot commented on pull request #12689: URL: https://github.com/apache/flink/pull/12689#issuecomment-645159155 ## CI report: * fcb7907dc31fc27756076404f60ab8fd50503f03 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #12688: [FLINK-18337][table] Introduce TableResult#await method to wait for data ready

2020-06-16 Thread GitBox
flinkbot edited a comment on pull request #12688: URL: https://github.com/apache/flink/pull/12688#issuecomment-644921647 ## CI report: * 51d8c4c4c144431d425dace01ee07e5fb49d83cc Azure:

[jira] [Updated] (FLINK-17260) StreamingKafkaITCase failure on Azure

2020-06-16 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17260?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-17260: --- Priority: Critical (was: Major) > StreamingKafkaITCase failure on Azure >

[jira] [Commented] (FLINK-17260) StreamingKafkaITCase failure on Azure

2020-06-16 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17260?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17138107#comment-17138107 ] Piotr Nowojski commented on FLINK-17260:

[jira] [Assigned] (FLINK-18330) Python NOTICE issues

2020-06-16 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18330?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-18330: --- Assignee: Dian Fu > Python NOTICE issues > > > Key:

[GitHub] [flink] curcur commented on pull request #12525: [FLINK-17769] [runtime] Fix the order of log events on a task failure

2020-06-16 Thread GitBox
curcur commented on pull request #12525: URL: https://github.com/apache/flink/pull/12525#issuecomment-645153956 I've updated the existing unit test case `StreamTaskTest.testCleanUpExceptionSuppressing` to test the suppressed exception here, which I think it should be enough.

[jira] [Updated] (FLINK-18341) Building Flink Walkthrough Table Java 0.1 COMPILATION ERROR

2020-06-16 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18341?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-18341: --- Labels: test-stability (was: ) > Building Flink Walkthrough Table Java 0.1 COMPILATION

[GitHub] [flink] lirui-apache commented on a change in pull request #12682: [FLINK-18320][hive] Fix NOTICE and license files for flink-sql-connec…

2020-06-16 Thread GitBox
lirui-apache commented on a change in pull request #12682: URL: https://github.com/apache/flink/pull/12682#discussion_r441282801 ## File path: flink-connectors/flink-sql-connector-hive-1.2.2/src/main/resources/META-INF/licenses/LICENSE.jodd-core ## @@ -0,0 +1,31 @@ +Copyright

[jira] [Created] (FLINK-18341) Building Flink Walkthrough Table Java 0.1 COMPILATION ERROR

2020-06-16 Thread Piotr Nowojski (Jira)
Piotr Nowojski created FLINK-18341: -- Summary: Building Flink Walkthrough Table Java 0.1 COMPILATION ERROR Key: FLINK-18341 URL: https://issues.apache.org/jira/browse/FLINK-18341 Project: Flink

[GitHub] [flink] lirui-apache commented on a change in pull request #12682: [FLINK-18320][hive] Fix NOTICE and license files for flink-sql-connec…

2020-06-16 Thread GitBox
lirui-apache commented on a change in pull request #12682: URL: https://github.com/apache/flink/pull/12682#discussion_r441282026 ## File path: flink-connectors/flink-sql-connector-hive-1.2.2/src/main/resources/META-INF/licenses/LICENSE.jodd-core ## @@ -0,0 +1,31 @@ +Copyright

[jira] [Commented] (FLINK-18150) A single failing Kafka broker may cause jobs to fail indefinitely with TimeoutException: Timeout expired while fetching topic metadata

2020-06-16 Thread Julius Michaelis (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18150?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17138102#comment-17138102 ] Julius Michaelis commented on FLINK-18150: -- I tried reproducing the problem outside of this

[GitHub] [flink] pnowojski commented on a change in pull request #12670: [FLINK-18290][checkpointing] Fail job on checkpoint future failure instead of System.exit

2020-06-16 Thread GitBox
pnowojski commented on a change in pull request #12670: URL: https://github.com/apache/flink/pull/12670#discussion_r441280357 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinator.java ## @@ -538,51 +542,61 @@ private void

[GitHub] [flink] flinkbot commented on pull request #12689: [FLINK-18320][notice][hive] Merge hive-exec dependencies for hive uber 2.3.6 and 3.1.2

2020-06-16 Thread GitBox
flinkbot commented on pull request #12689: URL: https://github.com/apache/flink/pull/12689#issuecomment-645148684 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] JingsongLi opened a new pull request #12689: [FLINK-18320][notice][hive] Merge hive-exec dependencies for hive uber 2.3.6 and 3.1.2

2020-06-16 Thread GitBox
JingsongLi opened a new pull request #12689: URL: https://github.com/apache/flink/pull/12689 ## What is the purpose of the change flink-sql-connector-hive depends on hive-exec which is a uber jar and doesn't come with a proper NOTICE file. So we need to find out the artifacts

[GitHub] [flink] flinkbot edited a comment on pull request #12688: [FLINK-18337][table] Introduce TableResult#await method to wait for data ready

2020-06-16 Thread GitBox
flinkbot edited a comment on pull request #12688: URL: https://github.com/apache/flink/pull/12688#issuecomment-644921647 ## CI report: * a66d075fe969ae716d3700ad4661482b6c79dc05 Azure:

[jira] [Created] (FLINK-18340) Support directly providing bytes instead of a Protobuf messages when writing to Kafka / Kinesis with the Python SDK

2020-06-16 Thread Tzu-Li (Gordon) Tai (Jira)
Tzu-Li (Gordon) Tai created FLINK-18340: --- Summary: Support directly providing bytes instead of a Protobuf messages when writing to Kafka / Kinesis with the Python SDK Key: FLINK-18340 URL:

[jira] [Assigned] (FLINK-18335) NotifyCheckpointAbortedITCase.testNotifyCheckpointAborted time outs

2020-06-16 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18335?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reassigned FLINK-18335: -- Assignee: Yun Tang > NotifyCheckpointAbortedITCase.testNotifyCheckpointAborted time

[GitHub] [flink] JingsongLi commented on a change in pull request #12682: [FLINK-18320][hive] Fix NOTICE and license files for flink-sql-connec…

2020-06-16 Thread GitBox
JingsongLi commented on a change in pull request #12682: URL: https://github.com/apache/flink/pull/12682#discussion_r441275184 ## File path: flink-connectors/flink-sql-connector-hive-1.2.2/src/main/resources/META-INF/licenses/LICENSE.jodd-core ## @@ -0,0 +1,31 @@ +Copyright

[GitHub] [flink] JingsongLi commented on a change in pull request #12682: [FLINK-18320][hive] Fix NOTICE and license files for flink-sql-connec…

2020-06-16 Thread GitBox
JingsongLi commented on a change in pull request #12682: URL: https://github.com/apache/flink/pull/12682#discussion_r441274051 ## File path: flink-connectors/flink-sql-connector-hive-1.2.2/src/main/resources/META-INF/licenses/LICENSE.jodd-core ## @@ -0,0 +1,31 @@ +Copyright

[GitHub] [flink] flinkbot edited a comment on pull request #12594: [FLINK-18072][hbase] HBaseLookupFunction can not work with new internal data structure RowData

2020-06-16 Thread GitBox
flinkbot edited a comment on pull request #12594: URL: https://github.com/apache/flink/pull/12594#issuecomment-642474618 ## CI report: * 79249151cc48e2711a224e5ca943c41ae434ce19 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12688: [FLINK-18337][table] Introduce TableResult#await method to wait for data ready

2020-06-16 Thread GitBox
flinkbot edited a comment on pull request #12688: URL: https://github.com/apache/flink/pull/12688#issuecomment-644921647 ## CI report: * a66d075fe969ae716d3700ad4661482b6c79dc05 Azure:

[GitHub] [flink] JingsongLi commented on pull request #12682: [FLINK-18320][hive] Fix NOTICE and license files for flink-sql-connec…

2020-06-16 Thread GitBox
JingsongLi commented on pull request #12682: URL: https://github.com/apache/flink/pull/12682#issuecomment-645140465 > It seems that there are a lot of `org/apache/hadoop{fs,hive,mapred,security}` files, but it is not clear through with dependency they come in. It is not the

[GitHub] [flink] lirui-apache commented on pull request #12682: [FLINK-18320][hive] Fix NOTICE and license files for flink-sql-connec…

2020-06-16 Thread GitBox
lirui-apache commented on pull request #12682: URL: https://github.com/apache/flink/pull/12682#issuecomment-645136144 > Looking through these checks, I am wondering if we have a set of unnecessary dependencies here. For example Kryo, minlog, objenises are all dependencies of flink-core

[jira] [Updated] (FLINK-14902) JDBCTableSource support AsyncLookupFunction

2020-06-16 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14902?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-14902: Fix Version/s: (was: 1.11.0) > JDBCTableSource support AsyncLookupFunction >

[jira] [Commented] (FLINK-18070) Time attribute been materialized after sub graph optimize

2020-06-16 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18070?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17138087#comment-17138087 ] Jark Wu commented on FLINK-18070: - cc [~godfreyhe] > Time attribute been materialized after sub graph

[jira] [Commented] (FLINK-17572) Remove checkpoint alignment buffered metric from webui

2020-06-16 Thread Yingjie Cao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17572?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17138085#comment-17138085 ] Yingjie Cao commented on FLINK-17572: - [~chesnay] Thanks for your comments and pointing out the REST

[GitHub] [flink] flinkbot edited a comment on pull request #12683: [FLINK-18242][state-backend-rocksdb] Remove the deprecated OptionsFactory and related classes

2020-06-16 Thread GitBox
flinkbot edited a comment on pull request #12683: URL: https://github.com/apache/flink/pull/12683#issuecomment-644766134 ## CI report: * 8d9f3f74b05b797407268dc75882c1940a0b521f Azure:

[jira] [Updated] (FLINK-17752) Align the timestamp format with Flink SQL types in JSON format

2020-06-16 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17752?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-17752: Fix Version/s: (was: 1.11.0) > Align the timestamp format with Flink SQL types in JSON format >

[jira] [Updated] (FLINK-18299) Add option in json format to parse timestamp in different standard

2020-06-16 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18299?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-18299: Fix Version/s: 1.11.0 > Add option in json format to parse timestamp in different standard >

[GitHub] [flink] lirui-apache commented on pull request #12682: [FLINK-18320][hive] Fix NOTICE and license files for flink-sql-connec…

2020-06-16 Thread GitBox
lirui-apache commented on pull request #12682: URL: https://github.com/apache/flink/pull/12682#issuecomment-645131846 > It seems that there are a lot of `org/apache/hadoop{fs,hive,mapred,security}` files, but it is not clear through with dependency they come in. It is not the

[GitHub] [flink] lirui-apache commented on pull request #12682: [FLINK-18320][hive] Fix NOTICE and license files for flink-sql-connec…

2020-06-16 Thread GitBox
lirui-apache commented on pull request #12682: URL: https://github.com/apache/flink/pull/12682#issuecomment-645130436 > There are some `javaewah/` files in the archive, which are not documented in the license files yet. Those are from `com.googlecode.javaewah:JavaEWAH:0.3.2` which I

[GitHub] [flink] curcur commented on a change in pull request #12525: [FLINK-17769] [runtime] Fix the order of log events on a task failure

2020-06-16 Thread GitBox
curcur commented on a change in pull request #12525: URL: https://github.com/apache/flink/pull/12525#discussion_r441263365 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java ## @@ -686,27 +680,38 @@ private void

[GitHub] [flink] flinkbot edited a comment on pull request #12661: [FLINK-18299][json] Add option in json format to parse timestamp in different format standard

2020-06-16 Thread GitBox
flinkbot edited a comment on pull request #12661: URL: https://github.com/apache/flink/pull/12661#issuecomment-644211738 ## CI report: * 834418105a612f01b27c41ccd8a21d64cbbebdd5 UNKNOWN * a27644dead7045e5a44289a4b886d940a27ea1a3 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12683: [FLINK-18242][state-backend-rocksdb] Remove the deprecated OptionsFactory and related classes

2020-06-16 Thread GitBox
flinkbot edited a comment on pull request #12683: URL: https://github.com/apache/flink/pull/12683#issuecomment-644766134 ## CI report: * 8d9f3f74b05b797407268dc75882c1940a0b521f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12670: [FLINK-18290][checkpointing] Fail job on checkpoint future failure instead of System.exit

2020-06-16 Thread GitBox
flinkbot edited a comment on pull request #12670: URL: https://github.com/apache/flink/pull/12670#issuecomment-644591855 ## CI report: * edce7433fbf7d8f64feb9e0a5c541fb50ddb3cd0 UNKNOWN * 8c0119088686cbbe7253404ea13be77ef0b48716 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12677: [FLINK-18315][table-planner-blink] Insert into partitioned table can …

2020-06-16 Thread GitBox
flinkbot edited a comment on pull request #12677: URL: https://github.com/apache/flink/pull/12677#issuecomment-644656915 ## CI report: * 668d7a7f961a4fab0ede3c8db8e9c1b3eab491b8 Azure:

[GitHub] [flink] curcur commented on a change in pull request #12525: [FLINK-17769] [runtime] Fix the order of log events on a task failure

2020-06-16 Thread GitBox
curcur commented on a change in pull request #12525: URL: https://github.com/apache/flink/pull/12525#discussion_r441263365 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java ## @@ -686,27 +680,38 @@ private void

[GitHub] [flink] flinkbot edited a comment on pull request #12594: [FLINK-18072][hbase] HBaseLookupFunction can not work with new internal data structure RowData

2020-06-16 Thread GitBox
flinkbot edited a comment on pull request #12594: URL: https://github.com/apache/flink/pull/12594#issuecomment-642474618 ## CI report: * a6358e3178bb96500b37a7f0e209845cd4822622 Azure:

[GitHub] [flink] lirui-apache commented on a change in pull request #12682: [FLINK-18320][hive] Fix NOTICE and license files for flink-sql-connec…

2020-06-16 Thread GitBox
lirui-apache commented on a change in pull request #12682: URL: https://github.com/apache/flink/pull/12682#discussion_r441263211 ## File path: flink-connectors/flink-sql-connector-hive-1.2.2/src/main/resources/META-INF/NOTICE ## @@ -8,6 +8,41 @@ This project bundles the

[GitHub] [flink] curcur commented on a change in pull request #12525: [FLINK-17769] [runtime] Fix the order of log events on a task failure

2020-06-16 Thread GitBox
curcur commented on a change in pull request #12525: URL: https://github.com/apache/flink/pull/12525#discussion_r441263156 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java ## @@ -611,27 +611,21 @@ protected void

[jira] [Commented] (FLINK-18204) NullPointerException when materialize checkpoint

2020-06-16 Thread shengsheng lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18204?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17138071#comment-17138071 ] shengsheng lin commented on FLINK-18204: Thanks [~yunta] , we solved this problem by adding lock

[jira] [Closed] (FLINK-18204) NullPointerException when materialize checkpoint

2020-06-16 Thread shengsheng lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18204?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] shengsheng lin closed FLINK-18204. -- Resolution: Implemented > NullPointerException when materialize checkpoint >

[GitHub] [flink] curcur commented on a change in pull request #12525: [FLINK-17769] [runtime] Fix the order of log events on a task failure

2020-06-16 Thread GitBox
curcur commented on a change in pull request #12525: URL: https://github.com/apache/flink/pull/12525#discussion_r441261520 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java ## @@ -611,27 +611,21 @@ protected void

[GitHub] [flink] curcur commented on a change in pull request #12525: [FLINK-17769] [runtime] Fix the order of log events on a task failure

2020-06-16 Thread GitBox
curcur commented on a change in pull request #12525: URL: https://github.com/apache/flink/pull/12525#discussion_r441261520 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java ## @@ -611,27 +611,21 @@ protected void

[jira] [Resolved] (FLINK-18332) Add error message to precondition in KeyGroupPartitionedPriorityQueue

2020-06-16 Thread Yu Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18332?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Li resolved FLINK-18332. --- Resolution: Fixed Merged into master via 204aa6d977c16bef7eafd3809b68e2260e31c88b > Add error message to

[GitHub] [flink] carp84 closed pull request #12508: [FLINK-18332][state] Add error message to precondition in KeyGroupPartitio…

2020-06-16 Thread GitBox
carp84 closed pull request #12508: URL: https://github.com/apache/flink/pull/12508 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to

[GitHub] [flink] wuchong commented on pull request #12311: [FLINK-17269][docs] Translate new Training Overview to Chinese

2020-06-16 Thread GitBox
wuchong commented on pull request #12311: URL: https://github.com/apache/flink/pull/12311#issuecomment-645123531 Thanks @yangyichao-mango and @klion26 , will merge this. This is an automated message from the Apache Git

[jira] [Updated] (FLINK-18339) ValidationException exception that field typeinformation in TableSchema and in TableSource return type for blink

2020-06-16 Thread hehuiyuan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18339?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hehuiyuan updated FLINK-18339: -- Description: The  type of `datatime` field   is OBJECT_ARRAY.   Exception:   {code:java} Exception

[GitHub] [flink] zhijiangW merged pull request #12664: [FLINK-18238][checkpoint] Emit CancelCheckpointMarker downstream on checkpointState in sync phase of checkpoint on task side

2020-06-16 Thread GitBox
zhijiangW merged pull request #12664: URL: https://github.com/apache/flink/pull/12664 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] wuchong commented on a change in pull request #12661: [FLINK-18299][json] Add option in json format to parse timestamp in different format standard

2020-06-16 Thread GitBox
wuchong commented on a change in pull request #12661: URL: https://github.com/apache/flink/pull/12661#discussion_r441250789 ## File path: flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/JsonOptions.java ## @@ -38,4 +44,40 @@

[jira] [Updated] (FLINK-18339) ValidationException exception that field typeinformation in TableSchema and in TableSource return type for blink

2020-06-16 Thread hehuiyuan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18339?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hehuiyuan updated FLINK-18339: -- Component/s: (was: Formats (JSON, Avro, Parquet, ORC, SequenceFile)) > ValidationException

[jira] [Created] (FLINK-18339) ValidationException exception that field typeinformation in TableSchema and in TableSource return type for blink

2020-06-16 Thread hehuiyuan (Jira)
hehuiyuan created FLINK-18339: - Summary: ValidationException exception that field typeinformation in TableSchema and in TableSource return type for blink Key: FLINK-18339 URL:

[GitHub] [flink] flinkbot edited a comment on pull request #12677: [FLINK-18315][table-planner-blink] Insert into partitioned table can …

2020-06-16 Thread GitBox
flinkbot edited a comment on pull request #12677: URL: https://github.com/apache/flink/pull/12677#issuecomment-644656915 ## CI report: * e7234f4e40dc338dc480b0e3b808a805ae98621c Azure:

[jira] [Assigned] (FLINK-18332) Add error message to precondition in KeyGroupPartitionedPriorityQueue

2020-06-16 Thread Yu Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18332?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Li reassigned FLINK-18332: - Fix Version/s: 1.12.0 Assignee: tartarus Thanks for creating the JIRA [~tartarus]. As

[GitHub] [flink] flinkbot edited a comment on pull request #12661: [FLINK-18299][json] Add option in json format to parse timestamp in different format standard

2020-06-16 Thread GitBox
flinkbot edited a comment on pull request #12661: URL: https://github.com/apache/flink/pull/12661#issuecomment-644211738 ## CI report: * 834418105a612f01b27c41ccd8a21d64cbbebdd5 UNKNOWN * a27644dead7045e5a44289a4b886d940a27ea1a3 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12594: [FLINK-18072][hbase] HBaseLookupFunction can not work with new internal data structure RowData

2020-06-16 Thread GitBox
flinkbot edited a comment on pull request #12594: URL: https://github.com/apache/flink/pull/12594#issuecomment-642474618 ## CI report: * a6358e3178bb96500b37a7f0e209845cd4822622 Azure:

[GitHub] [flink] Myasuka commented on pull request #12664: [FLINK-18238][checkpoint] Emit CancelCheckpointMarker downstream on checkpointState in sync phase of checkpoint on task side

2020-06-16 Thread GitBox
Myasuka commented on pull request #12664: URL: https://github.com/apache/flink/pull/12664#issuecomment-645115770 My local azure CI built with success: https://myasuka.visualstudio.com/flink/_build/results?buildId=105=results

[GitHub] [flink] Myasuka removed a comment on pull request #12681: [FLINK-18238][checkpoint] Emit CancelCheckpointMarker downstream on checkpointState in sync phase of checkpoint on task side

2020-06-16 Thread GitBox
Myasuka removed a comment on pull request #12681: URL: https://github.com/apache/flink/pull/12681#issuecomment-645115253 My local azure CI built with success : https://myasuka.visualstudio.com/flink/_build/results?buildId=105=results

[jira] [Commented] (FLINK-18324) Translate updated data type and function page into Chinese

2020-06-16 Thread Benchao Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18324?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17138042#comment-17138042 ] Benchao Li commented on FLINK-18324: [~liyubin117] Thanks for taking this, assigned to you. >

[jira] [Assigned] (FLINK-18324) Translate updated data type and function page into Chinese

2020-06-16 Thread Benchao Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18324?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Benchao Li reassigned FLINK-18324: -- Assignee: Yubin Li > Translate updated data type and function page into Chinese >

[GitHub] [flink] Myasuka commented on pull request #12681: [FLINK-18238][checkpoint] Emit CancelCheckpointMarker downstream on checkpointState in sync phase of checkpoint on task side

2020-06-16 Thread GitBox
Myasuka commented on pull request #12681: URL: https://github.com/apache/flink/pull/12681#issuecomment-645115253 My local azure CI built with success : https://myasuka.visualstudio.com/flink/_build/results?buildId=105=results

[GitHub] [flink] flinkbot edited a comment on pull request #12677: [FLINK-18315][table-planner-blink] Insert into partitioned table can …

2020-06-16 Thread GitBox
flinkbot edited a comment on pull request #12677: URL: https://github.com/apache/flink/pull/12677#issuecomment-644656915 ## CI report: * e7234f4e40dc338dc480b0e3b808a805ae98621c Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12661: [FLINK-18299][json] Add option in json format to parse timestamp in different format standard

2020-06-16 Thread GitBox
flinkbot edited a comment on pull request #12661: URL: https://github.com/apache/flink/pull/12661#issuecomment-644211738 ## CI report: * 834418105a612f01b27c41ccd8a21d64cbbebdd5 UNKNOWN * a27644dead7045e5a44289a4b886d940a27ea1a3 Azure:

[GitHub] [flink] lirui-apache commented on a change in pull request #12682: [FLINK-18320][hive] Fix NOTICE and license files for flink-sql-connec…

2020-06-16 Thread GitBox
lirui-apache commented on a change in pull request #12682: URL: https://github.com/apache/flink/pull/12682#discussion_r441248922 ## File path: flink-connectors/flink-sql-connector-hive-1.2.2/src/main/resources/META-INF/NOTICE ## @@ -8,6 +8,41 @@ This project bundles the

[GitHub] [flink] lirui-apache commented on a change in pull request #12682: [FLINK-18320][hive] Fix NOTICE and license files for flink-sql-connec…

2020-06-16 Thread GitBox
lirui-apache commented on a change in pull request #12682: URL: https://github.com/apache/flink/pull/12682#discussion_r441247643 ## File path: flink-connectors/flink-sql-connector-hive-1.2.2/src/main/resources/META-INF/NOTICE ## @@ -8,6 +8,41 @@ This project bundles the

[GitHub] [flink] lirui-apache commented on a change in pull request #12682: [FLINK-18320][hive] Fix NOTICE and license files for flink-sql-connec…

2020-06-16 Thread GitBox
lirui-apache commented on a change in pull request #12682: URL: https://github.com/apache/flink/pull/12682#discussion_r441248366 ## File path: flink-connectors/flink-sql-connector-hive-1.2.2/src/main/resources/META-INF/licenses/LICENSE.json ## @@ -0,0 +1,9 @@ +Copyright (c)

[GitHub] [flink] zhijiangW commented on pull request #12681: [FLINK-18238][checkpoint] Emit CancelCheckpointMarker downstream on checkpointState in sync phase of checkpoint on task side

2020-06-16 Thread GitBox
zhijiangW commented on pull request #12681: URL: https://github.com/apache/flink/pull/12681#issuecomment-645112337 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [flink] wuchong commented on pull request #12644: [FLINK-18198][docs-zh]Translate "HBase SQL Connector" page into Chinese

2020-06-16 Thread GitBox
wuchong commented on pull request #12644: URL: https://github.com/apache/flink/pull/12644#issuecomment-645110183 Hi @bigdata-ny , there is some updates in `hbase.zh.md`. Could you update the corresponding translation ? I will review it then.

[GitHub] [flink] curcur commented on a change in pull request #12525: [FLINK-17769] [runtime] Fix the order of log events on a task failure

2020-06-16 Thread GitBox
curcur commented on a change in pull request #12525: URL: https://github.com/apache/flink/pull/12525#discussion_r441245446 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java ## @@ -592,7 +592,7 @@ protected void

[jira] [Closed] (FLINK-18086) Migrate SQLClientKafkaITCase to use DDL and new options to create tables

2020-06-16 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18086?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-18086. --- Resolution: Fixed [e2e] Migrate SQLClientKafkaITCase to use DDL and new options to create tables - master

[jira] [Closed] (FLINK-18303) Filesystem connector doesn't flush part files after rolling interval

2020-06-16 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18303?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-18303. --- Resolution: Fixed - master (1.12.0): e2db1dcc6a5a60210a4452849048b915cf794aaf - 1.11.0:

[jira] [Closed] (FLINK-18302) Sql client uses wrong class loader when execute INSERT statements

2020-06-16 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18302?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-18302. --- Resolution: Fixed - master (1.12.0): ca1f7642c7120800f1ac93575dcdfa0223c097a4 - 1.11.0:

[GitHub] [flink] wuchong closed pull request #12657: [FLINK-18086][tests][e2e][kafka] Migrate SQLClientKafkaITCase to use DDL and new options to create tables

2020-06-16 Thread GitBox
wuchong closed pull request #12657: URL: https://github.com/apache/flink/pull/12657 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to

[GitHub] [flink] wuchong commented on pull request #12657: [FLINK-18086][tests][e2e][kafka] Migrate SQLClientKafkaITCase to use DDL and new options to create tables

2020-06-16 Thread GitBox
wuchong commented on pull request #12657: URL: https://github.com/apache/flink/pull/12657#issuecomment-645103026 Build is passed. Merging... This is an automated message from the Apache Git Service. To respond to the

[jira] [Commented] (FLINK-18324) Translate updated data type and function page into Chinese

2020-06-16 Thread Yubin Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18324?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17138025#comment-17138025 ] Yubin Li commented on FLINK-18324: -- Hi, [~twalthr], I am willing to do it > Translate updated data

[GitHub] [flink] carp84 commented on pull request #12683: [FLINK-18242][state-backend-rocksdb] Remove the deprecated OptionsFactory and related classes

2020-06-16 Thread GitBox
carp84 commented on pull request #12683: URL: https://github.com/apache/flink/pull/12683#issuecomment-645089484 Thanks for the review @StephanEwen ! The `ConfigOptionsDocsCompletenessITCase` failure in pre-commit check is related to changes here, so I will push another addendum fix

[GitHub] [flink] flinkbot edited a comment on pull request #12687: [FLINK-17678][hbase] Support fink-sql-connector-hbase

2020-06-16 Thread GitBox
flinkbot edited a comment on pull request #12687: URL: https://github.com/apache/flink/pull/12687#issuecomment-644892023 ## CI report: * b0a58a724af992da53061c770b18813c3bab69b5 Azure:

[GitHub] [flink] zhengcanbin commented on pull request #11707: [FLINK-15648][k8s] Introduce CPU limit support for JM/TM Container

2020-06-16 Thread GitBox
zhengcanbin commented on pull request #11707: URL: https://github.com/apache/flink/pull/11707#issuecomment-645086294 > Shall we close this PR until we have reached agreement on the JIRA ticket @zhengcanbin? Sure!

[GitHub] [flink] zhengcanbin closed pull request #11707: [FLINK-15648][k8s] Introduce CPU limit support for JM/TM Container

2020-06-16 Thread GitBox
zhengcanbin closed pull request #11707: URL: https://github.com/apache/flink/pull/11707 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

[GitHub] [flink] flinkbot edited a comment on pull request #12657: [FLINK-18086][tests][e2e][kafka] Migrate SQLClientKafkaITCase to use DDL and new options to create tables

2020-06-16 Thread GitBox
flinkbot edited a comment on pull request #12657: URL: https://github.com/apache/flink/pull/12657#issuecomment-644140243 ## CI report: * e2db1dcc6a5a60210a4452849048b915cf794aaf Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12670: [FLINK-18290][checkpointing] Fail job on checkpoint future failure instead of System.exit

2020-06-16 Thread GitBox
flinkbot edited a comment on pull request #12670: URL: https://github.com/apache/flink/pull/12670#issuecomment-644591855 ## CI report: * edce7433fbf7d8f64feb9e0a5c541fb50ddb3cd0 UNKNOWN * ad5d1ffa1d4a457d2f90f109b6eb9b87aa15c2b1 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12670: [FLINK-18290][checkpointing] Fail job on checkpoint future failure instead of System.exit

2020-06-16 Thread GitBox
flinkbot edited a comment on pull request #12670: URL: https://github.com/apache/flink/pull/12670#issuecomment-644591855 ## CI report: * edce7433fbf7d8f64feb9e0a5c541fb50ddb3cd0 UNKNOWN * ad5d1ffa1d4a457d2f90f109b6eb9b87aa15c2b1 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12685: testing UC ITCase in close loop

2020-06-16 Thread GitBox
flinkbot edited a comment on pull request #12685: URL: https://github.com/apache/flink/pull/12685#issuecomment-644778759 ## CI report: * b2a4cbe7b0093074062d0ed42fa11deabfbc82f4 UNKNOWN * 7f6b12329d6bef48e2132675528e2d325db1208e UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on pull request #12594: [FLINK-18072][hbase] HBaseLookupFunction can not work with new internal data structure RowData

2020-06-16 Thread GitBox
flinkbot edited a comment on pull request #12594: URL: https://github.com/apache/flink/pull/12594#issuecomment-642474618 ## CI report: * a6358e3178bb96500b37a7f0e209845cd4822622 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12688: [FLINK-18337][table] Introduce TableResult#await method to wait for data ready

2020-06-16 Thread GitBox
flinkbot edited a comment on pull request #12688: URL: https://github.com/apache/flink/pull/12688#issuecomment-644921647 ## CI report: * a66d075fe969ae716d3700ad4661482b6c79dc05 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12685: testing UC ITCase in close loop

2020-06-16 Thread GitBox
flinkbot edited a comment on pull request #12685: URL: https://github.com/apache/flink/pull/12685#issuecomment-644778759 ## CI report: * b2a4cbe7b0093074062d0ed42fa11deabfbc82f4 UNKNOWN * 7f6b12329d6bef48e2132675528e2d325db1208e UNKNOWN Bot commands The

[GitHub] [flink] flinkbot edited a comment on pull request #12681: [FLINK-18238][checkpoint] Emit CancelCheckpointMarker downstream on checkpointState in sync phase of checkpoint on task side

2020-06-16 Thread GitBox
flinkbot edited a comment on pull request #12681: URL: https://github.com/apache/flink/pull/12681#issuecomment-644721789 ## CI report: * 4729205024662a115004435a2b3598d2a1e1148e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12682: [FLINK-18320][hive] Fix NOTICE and license files for flink-sql-connec…

2020-06-16 Thread GitBox
flinkbot edited a comment on pull request #12682: URL: https://github.com/apache/flink/pull/12682#issuecomment-644736459 ## CI report: * 61808c49ff0ad562cbaf0b0bbc5c99e542f5563d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12525: [FLINK-17769] [runtime] Fix the order of log events on a task failure

2020-06-16 Thread GitBox
flinkbot edited a comment on pull request #12525: URL: https://github.com/apache/flink/pull/12525#issuecomment-640513261 ## CI report: * 2276d043aa2232437e36b047d4fcd284f698d011 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12680: [FLINK-18119][table-runtime-blink] Retract old records in time range …

2020-06-16 Thread GitBox
flinkbot edited a comment on pull request #12680: URL: https://github.com/apache/flink/pull/12680#issuecomment-644712277 ## CI report: * a71ca38af1450b30f5c2d1fd05903f6cf6588ddb Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12679: [FLINK-18310][metrics] Properly handle interval parsing errors

2020-06-16 Thread GitBox
flinkbot edited a comment on pull request #12679: URL: https://github.com/apache/flink/pull/12679#issuecomment-644703645 ## CI report: * 0170d15e5356c3c566d18fd2e530c951a4a1e5cb Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12577: [FLINK-17599][docs] Update documents due to FLIP-84

2020-06-16 Thread GitBox
flinkbot edited a comment on pull request #12577: URL: https://github.com/apache/flink/pull/12577#issuecomment-641885509 ## CI report: * 46653035ed50d09254b07b24f0fb8cfff308623b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12649: [FLINK-18286] Implement type inference for GET/FLATTEN

2020-06-16 Thread GitBox
flinkbot edited a comment on pull request #12649: URL: https://github.com/apache/flink/pull/12649#issuecomment-643957887 ## CI report: * 326222e8eb85270297876eba22ffda57ebe592c3 Azure:

[jira] [Commented] (FLINK-16768) HadoopS3RecoverableWriterITCase.testRecoverWithStateWithMultiPart hangs

2020-06-16 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16768?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17137886#comment-17137886 ] Robert Metzger commented on FLINK-16768:

[GitHub] [flink] flinkbot edited a comment on pull request #12650: [FLINK-18289][Checkpoint] Ensure notifyCheckpointAborted interface work in UDF operator

2020-06-16 Thread GitBox
flinkbot edited a comment on pull request #12650: URL: https://github.com/apache/flink/pull/12650#issuecomment-643987851 ## CI report: * 02ef4bd57924bdf2bc7ae5b609b8e78931192f8f Azure:

  1   2   3   4   5   6   7   8   >