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

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

[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

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

[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

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

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

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

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

[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

[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

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

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

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

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

[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

[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

[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] 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] 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 #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] 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 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] 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.

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

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

[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

[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

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

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

[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 #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] 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,

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

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

[jira] [Commented] (FLINK-18290) Tests are crashing with exit code 239

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

[GitHub] [flink] sdlcwangsong commented on a change in pull request #12642: [FLINK-18282][docs-zh] retranslate the documentation home page

2020-06-16 Thread GitBox
sdlcwangsong commented on a change in pull request #12642: URL: https://github.com/apache/flink/pull/12642#discussion_r440610076 ## File path: docs/index.zh.md ## @@ -23,53 +23,71 @@ specific language governing permissions and limitations under the License. --> + +Apache

[GitHub] [flink] rmetzger commented on a change in pull request #12653: [FLINK-18294][e2e] Log java processes and disk usage

2020-06-16 Thread GitBox
rmetzger commented on a change in pull request #12653: URL: https://github.com/apache/flink/pull/12653#discussion_r440610507 ## File path: flink-end-to-end-tests/test-scripts/test-runner-common.sh ## @@ -105,6 +107,13 @@ function post_test_validation { fi } +function

[GitHub] [flink] flinkbot commented on pull request #12666: [FLINK-18313][doc] Hive dialect doc should mention that views created…

2020-06-16 Thread GitBox
flinkbot commented on pull request #12666: URL: https://github.com/apache/flink/pull/12666#issuecomment-644558781 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] [Updated] (FLINK-18311) StreamingKafkaITCase stalls indefinitely

2020-06-16 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18311?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-18311: --- Priority: Blocker (was: Critical) > StreamingKafkaITCase stalls indefinitely >

[GitHub] [flink] rmetzger commented on pull request #12589: [FLINK-17327] Fix Kafka Producer Resource Leaks

2020-06-16 Thread GitBox
rmetzger commented on pull request #12589: URL: https://github.com/apache/flink/pull/12589#issuecomment-644564287 Note: The CI build for this PR was not passing. In the Azure UI, you can "Toggle Timestamps" next to the "View Raw Log" button. You'll then see that the test stalls for over

[jira] [Comment Edited] (FLINK-18288) WEB UI failure in Flink1.12

2020-06-16 Thread appleyuchi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18288?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17136356#comment-17136356 ] appleyuchi edited comment on FLINK-18288 at 6/16/20, 6:40 AM: -- Thanks for

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

2020-06-16 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17136364#comment-17136364 ] Robert Metzger commented on FLINK-16795: I guess all these new failures are caused by

[jira] [Updated] (FLINK-18119) Fix unlimitedly growing state for time range bounded over aggregate

2020-06-16 Thread Hyeonseop Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18119?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hyeonseop Lee updated FLINK-18119: -- Description: For time range bounded over aggregation in streaming query, like below,

[jira] [Comment Edited] (FLINK-18288) WEB UI failure in Flink1.12

2020-06-16 Thread appleyuchi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18288?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17136356#comment-17136356 ] appleyuchi edited comment on FLINK-18288 at 6/16/20, 6:50 AM: -- Thanks for

[GitHub] [flink] carp84 opened a new pull request #12669: [FLINK-17800][roksdb] Ensure total order seek to avoid user misuse

2020-06-16 Thread GitBox
carp84 opened a new pull request #12669: URL: https://github.com/apache/flink/pull/12669 ## What is the purpose of the change The changes here are based on #12514 and mainly for pre-merge review. ## Brief change log The same changes as #12514 with final comments

[GitHub] [flink] flinkbot commented on pull request #12667: [FLINK-18209] Replace slave with worker in docker cluster test scripts

2020-06-16 Thread GitBox
flinkbot commented on pull request #12667: URL: https://github.com/apache/flink/pull/12667#issuecomment-644574617 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] [Updated] (FLINK-18291) Streaming File Sink s3 end-to-end test stalls

2020-06-16 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18291?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-18291: --- Labels: pull-request-available test-stability (was: test-stability) > Streaming File Sink

[jira] [Assigned] (FLINK-18291) Streaming File Sink s3 end-to-end test stalls

2020-06-16 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18291?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-18291: -- Assignee: Robert Metzger > Streaming File Sink s3 end-to-end test stalls >

[GitHub] [flink] rmetzger opened a new pull request #12668: [FLINK-18291][e2e] Introduce timeout into Streaming File Sink s3 test

2020-06-16 Thread GitBox
rmetzger opened a new pull request #12668: URL: https://github.com/apache/flink/pull/12668 ## What is the purpose of the change We observed a case where this test stalled, but no logs were available due to the stalling. ## Brief change log - Use

[GitHub] [flink] flinkbot commented on pull request #12671: [FLINK-17824][tests] Fix resume_savepoint e2e test by slowing down th…

2020-06-16 Thread GitBox
flinkbot commented on pull request #12671: URL: https://github.com/apache/flink/pull/12671#issuecomment-644583065 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] carp84 commented on pull request #12508: [hotfix][state] Add error message to precondition in KeyGroupPartitio…

2020-06-16 Thread GitBox
carp84 commented on pull request #12508: URL: https://github.com/apache/flink/pull/12508#issuecomment-644583184 And could you create a JIRA to describe the issue fixed here @Tartarus0zm ? I think that would be easier for later tracking than hotfix. Thanks.

[GitHub] [flink] carp84 edited a comment on pull request #12508: [hotfix][state] Add error message to precondition in KeyGroupPartitio…

2020-06-16 Thread GitBox
carp84 edited a comment on pull request #12508: URL: https://github.com/apache/flink/pull/12508#issuecomment-644582168 > @carp84 @wuchong I reproduced this case. > SimpleDateFormat is not thread safe,but a static SimpleDateFormat is used in KeySelector. timestamp changed before and

[GitHub] [flink] zentol commented on a change in pull request #12674: [FLINK-18311] Fix StreamingKafkaITCase on Kafka 2.4.1

2020-06-16 Thread GitBox
zentol commented on a change in pull request #12674: URL: https://github.com/apache/flink/pull/12674#discussion_r440657166 ## File path: flink-end-to-end-tests/flink-end-to-end-tests-common-kafka/src/main/java/org/apache/flink/tests/util/kafka/LocalStandaloneKafkaResource.java

[GitHub] [flink] wuchong commented on a change in 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 a change in pull request #12657: URL: https://github.com/apache/flink/pull/12657#discussion_r440655924 ## File path: flink-end-to-end-tests/flink-end-to-end-tests-common/src/main/java/org/apache/flink/tests/util/AutoClosableProcess.java ## @@ -167,6

[jira] [Resolved] (FLINK-18307) Replace "slave" file name with "workers"

2020-06-16 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18307?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-18307. -- Release Note: For Standalone Setups, the file with the worker nodes is no longer called

[jira] [Closed] (FLINK-18307) Replace "slave" file name with "workers"

2020-06-16 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18307?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-18307. > Replace "slave" file name with "workers" > > >

[jira] [Created] (FLINK-18320) flink-sql-connector-hive modules should merge hive-exec dependencies

2020-06-16 Thread Jingsong Lee (Jira)
Jingsong Lee created FLINK-18320: Summary: flink-sql-connector-hive modules should merge hive-exec dependencies Key: FLINK-18320 URL: https://issues.apache.org/jira/browse/FLINK-18320 Project: Flink

  1   2   3   4   5   6   7   8   >