[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&focusedCommentId=17138157#comment-17138157 ] Robert Metzger commented on FLINK-16795: This is a real e2e timeout now: https:

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

2020-06-16 Thread GitBox
rmetzger commented on pull request #12594: URL: https://github.com/apache/flink/pull/12594#issuecomment-645190034 This is the CI build: https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=3668&view=results

[jira] [Reopened] (FLINK-18072) HBaseLookupFunction can not work with new internal data structure RowData

2020-06-16 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18072?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reopened FLINK-18072: Reverted change in https://github.com/apache/flink/commit/8192e1bcc2f4fb5917c041a454bf9e20eda

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

2020-06-16 Thread GitBox
rmetzger commented on pull request #12594: URL: https://github.com/apache/flink/pull/12594#issuecomment-645189673 But only in `release-1.11`: https://github.com/apache/flink/commit/8192e1bcc2f4fb5917c041a454bf9e20eda5b83e ---

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

2020-06-16 Thread GitBox
rmetzger commented on pull request #12594: URL: https://github.com/apache/flink/pull/12594#issuecomment-645189323 Note, this change broke the release-1.11. I reverted the commit This is an automated message from the Apache Gi

[jira] [Closed] (FLINK-16654) Implement Application Mode according to FLIP-85

2020-06-16 Thread Kostas Kloudas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16654?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-16654. -- Resolution: Implemented > Implement Application Mode according to FLIP-85 > --

[jira] [Updated] (FLINK-16654) Implement Application Mode according to FLIP-85

2020-06-16 Thread Kostas Kloudas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16654?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-16654: --- Fix Version/s: 1.11.0 > Implement Application Mode according to FLIP-85 > --

[GitHub] [flink] zhuzhurk commented on a change in pull request #12278: [FLINK-17019][runtime] Fulfill slot requests in request order

2020-06-16 Thread GitBox
zhuzhurk commented on a change in pull request #12278: URL: https://github.com/apache/flink/pull/12278#discussion_r441316261 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/jobmaster/slotpool/DualKeyLinkedMapTest.java ## @@ -85,4 +85,28 @@ public void ensur

[GitHub] [flink] fsk119 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
fsk119 commented on a change in pull request #12661: URL: https://github.com/apache/flink/pull/12661#discussion_r441315908 ## File path: flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/JsonOptions.java ## @@ -38,4 +44,40 @@ .default

[GitHub] [flink] flinkbot commented on pull request #12690: [FLINK-18186][doc] Various updates on standalone kubernetes document

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

[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 * 546c2965dadb8b9fa36cdc4ae6de0370076e

[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: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[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 * af50f547204f12002cc8ab146058b8c00aa454ab UNKNOWN * 24897cd0337aeb7292ad7754a5633ab0b096

[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: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

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

2020-06-16 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18339?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17138141#comment-17138141 ] Jark Wu commented on FLINK-18339: - Could you try to use {{ObjectArrayTypeInfo.getInfoFor

[GitHub] [flink] flinkbot commented on pull request #12690: [FLINK-18186][doc] Various updates on standalone kubernetes document

2020-06-16 Thread GitBox
flinkbot commented on pull request #12690: URL: https://github.com/apache/flink/pull/12690#issuecomment-645178442 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the pro

[jira] [Updated] (FLINK-18186) Various updates on Kubernetes standalone document

2020-06-16 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18186?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-18186: --- Labels: pull-request-available (was: ) > Various updates on Kubernetes standalone document

[GitHub] [flink] wangyang0918 opened a new pull request #12690: [FLINK-18186][doc] Various updates on standalone kubernetes document

2020-06-16 Thread GitBox
wangyang0918 opened a new pull request #12690: URL: https://github.com/apache/flink/pull/12690 ## What is the purpose of the change Various updates on standalone kubernetes document to improve the user experience. ## Brief change log This commit introduces t

[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: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[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: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Closed] (FLINK-18072) HBaseLookupFunction can not work with new internal data structure RowData

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

[jira] [Updated] (FLINK-18072) HBaseLookupFunction can not work with new internal data structure RowData

2020-06-16 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18072?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-18072: Fix Version/s: (was: 1.12.0) > HBaseLookupFunction can not work with new internal data structure RowDa

[GitHub] [flink] wuchong merged pull request #12594: [FLINK-18072][hbase] HBaseLookupFunction can not work with new internal data structure RowData

2020-06-16 Thread GitBox
wuchong merged pull request #12594: URL: https://github.com/apache/flink/pull/12594 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 #12594: [FLINK-18072][hbase] HBaseLookupFunction can not work with new internal data structure RowData

2020-06-16 Thread GitBox
wuchong commented on pull request #12594: URL: https://github.com/apache/flink/pull/12594#issuecomment-645169835 The failed case is not related to this PR. This is an automated message from the Apache Git Service. To respond

[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: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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&focusedCommentId=17138115#comment-17138115 ] godfrey he commented on FLINK-18070: we need to materialize time attribute only in s

[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&focusedCommentId=17138114#comment-17138114 ] godfrey he commented on FLINK-18070: [~liuyufei] Thanks for reporting this. the simp

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

[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: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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&focusedCommentId=17138107#comment-17138107 ] Piotr Nowojski commented on FLINK-17260: https://dev.azure.com/apache-flink/apac

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

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

[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&focusedCommentId=17138102#comment-17138102 ] Julius Michaelis commented on FLINK-18150: -- I tried reproducing the problem out

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

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

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

[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: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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: https://issues.apa

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

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

[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: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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 `parquet-hadoop

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

[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&focusedCommentId=17138087#comment-17138087 ] Jark Wu commented on FLINK-18070: - cc [~godfreyhe] > Time attribute been materialized a

[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&focusedCommentId=17138085#comment-17138085 ] Yingjie Cao commented on FLINK-17572: - [~chesnay] Thanks for your comments and point

[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: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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 `parquet-hado

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

[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: [FAILURE](https://dev.azure.com/apache-fl

[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: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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: [CANCELED](https://dev.azure.com/apache-f

[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: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

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

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

[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&focusedCommentId=17138071#comment-17138071 ] shengsheng lin commented on FLINK-18204: Thanks [~yunta] , we solved this proble

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

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

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

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

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

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

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

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

[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: https://issues.apache.org/jira/browse/FL

[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: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

[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: [FAILURE](https://dev.azure.com/apache-fl

[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: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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&view=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&view=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&focusedCommentId=17138042#comment-17138042 ] Benchao Li commented on FLINK-18324: [~liyubin117] Thanks for taking this, assigned

[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&view=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: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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: [FAILURE](https://dev.azure.com/apache-fl

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

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

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

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

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

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

  1   2   3   4   5   6   7   >