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

2020-06-08 Thread hehuiyuan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18145?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hehuiyuan updated FLINK-18145: -- Attachment: image-2020-06-09-14-58-44-221.png > Segment optimization does not work in blink ? > --

[jira] [Closed] (FLINK-18127) Streamline manual execution of Java E2E tests

2020-06-08 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18127?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-18127. Resolution: Fixed master: e0c6f76cba87223a1712d6d0fa2b929167ccc1b4 64f8f657f7c1b5fff052394

[jira] [Commented] (FLINK-18191) Rename new Master memory options to start with "master" prefix

2020-06-08 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18191?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17128936#comment-17128936 ] Nicholas Jiang commented on FLINK-18191: [~chesnay]Therefore, I would like to wo

[jira] [Commented] (FLINK-18013) Refactor Hadoop Utility classes/functions into a common Maven module

2020-06-08 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17128933#comment-17128933 ] Robert Metzger commented on FLINK-18013: Hey [~zenfenan], please let me know if

[jira] [Commented] (FLINK-18191) Rename new Master memory options to start with "master" prefix

2020-06-08 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18191?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17128932#comment-17128932 ] Chesnay Schepler commented on FLINK-18191: -- [~nicholasjiang] yes > Rename new

[jira] [Comment Edited] (FLINK-17976) Test native K8s integration

2020-06-08 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17976?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17128926#comment-17128926 ] Yang Wang edited comment on FLINK-17976 at 6/9/20, 6:50 AM:

[jira] [Commented] (FLINK-17498) MapCancelingITCase.testMapCancelling fails with timeout

2020-06-08 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17498?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17128929#comment-17128929 ] Robert Metzger commented on FLINK-17498: Sounds good to me. > MapCancelingITCas

[jira] [Commented] (FLINK-17976) Test native K8s integration

2020-06-08 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17976?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17128927#comment-17128927 ] Robert Metzger commented on FLINK-17976: okay, I see. Thanks for clarifying. >

[jira] [Commented] (FLINK-17976) Test native K8s integration

2020-06-08 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17976?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17128926#comment-17128926 ] Yang Wang commented on FLINK-17976: --- [~rmetzger] Thanks for testing the native K8s. {

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

2020-06-08 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16768?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17128923#comment-17128923 ] Robert Metzger commented on FLINK-16768: at org.apache.flink.fs.s3hadoo

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

2020-06-08 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17260?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17128922#comment-17128922 ] Robert Metzger commented on FLINK-17260: https://dev.azure.com/apache-flink/apac

[jira] [Commented] (FLINK-18148) "Resuming Savepoint" e2e fails with TimeoutException in CliFrontend.stop()

2020-06-08 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18148?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17128920#comment-17128920 ] Robert Metzger commented on FLINK-18148: https://dev.azure.com/apache-flink/apac

[jira] [Commented] (FLINK-15318) RocksDBWriteBatchPerformanceTest.benchMark fails on ppc64le

2020-06-08 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15318?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17128915#comment-17128915 ] Robert Metzger commented on FLINK-15318: I don't really have an opinion here, be

[jira] [Commented] (FLINK-18148) "Resuming Savepoint" e2e fails with TimeoutException in CliFrontend.stop()

2020-06-08 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18148?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17128911#comment-17128911 ] Robert Metzger commented on FLINK-18148: https://dev.azure.com/apache-flink/apac

[jira] [Commented] (FLINK-18148) "Resuming Savepoint" e2e fails with TimeoutException in CliFrontend.stop()

2020-06-08 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18148?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17128910#comment-17128910 ] Robert Metzger commented on FLINK-18148: https://dev.azure.com/apache-flink/apac

[jira] [Commented] (FLINK-18148) "Resuming Savepoint" e2e fails with TimeoutException in CliFrontend.stop()

2020-06-08 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18148?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17128909#comment-17128909 ] Robert Metzger commented on FLINK-18148: https://dev.azure.com/apache-flink/apac

[jira] [Updated] (FLINK-18057) SingleInputGateTest.testConcurrentReadStateAndProcessAndClose: expected:<3> but was:<2>

2020-06-08 Thread Zhijiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18057?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang updated FLINK-18057: - Affects Version/s: (was: 1.12.0) 1.11.0 > SingleInputGateTest.testConcurrentR

[jira] [Updated] (FLINK-18057) SingleInputGateTest.testConcurrentReadStateAndProcessAndClose: expected:<3> but was:<2>

2020-06-08 Thread Zhijiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18057?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang updated FLINK-18057: - Fix Version/s: 1.12.0 > SingleInputGateTest.testConcurrentReadStateAndProcessAndClose: expected:<3> > b

[jira] [Updated] (FLINK-18022) Add e2e test for new streaming file sink

2020-06-08 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18022?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-18022: - Parent: (was: FLINK-18021) Issue Type: Improvement (was: Sub-task) > Add e2e test f

[jira] [Updated] (FLINK-18022) Add e2e test for new streaming file sink

2020-06-08 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18022?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-18022: - Fix Version/s: (was: 1.11.0) 1.12.0 > Add e2e test for new streaming file

[jira] [Updated] (FLINK-18022) Add e2e test for new streaming file sink

2020-06-08 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18022?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-18022: - Priority: Major (was: Blocker) > Add e2e test for new streaming file sink > ---

[jira] [Commented] (FLINK-17978) Test Hadoop dependency change

2020-06-08 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17978?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17128891#comment-17128891 ] Yang Wang commented on FLINK-17978: --- [~trohrmann] I am willing to test the hadoop depe

[jira] [Closed] (FLINK-18130) File name conflict for different jobs in filesystem/hive sink

2020-06-08 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18130?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-18130. Resolution: Fixed master: 603cd830073f95d1b48cf8fa6817100ac17e1eb3 release-1.11: ab6cf4083c84bf8c

[jira] [Updated] (FLINK-18201) Support create_function in Python Table API

2020-06-08 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18201?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-18201: Description: There is an interface *createFunction* in the Java *TableEnvironment*. It's used to register

[jira] [Closed] (FLINK-18056) Hive file sink throws exception when the target in-progress file exists.

2020-06-08 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18056?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-18056. Resolution: Fixed master: 45f42f8e6bf2c2d360a6d4fff4f23d53b4dd4f8a release-1.11: 0d9ed9012286ef24

[jira] [Updated] (FLINK-18201) Support create_function in Python Table API

2020-06-08 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18201?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-18201: Description: There is an interface *createFunction* in the Java *TableEnvironment*. It's used to register

[jira] [Updated] (FLINK-18200) Replace the deprecated interfaces with the new interfaces in the tests and examples

2020-06-08 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18200?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-18200: Description: Currently, there are a few deprecated interfaces which are still heavily used in the tests an

[jira] [Created] (FLINK-18201) Support create_function in Python Table API

2020-06-08 Thread Dian Fu (Jira)
Dian Fu created FLINK-18201: --- Summary: Support create_function in Python Table API Key: FLINK-18201 URL: https://issues.apache.org/jira/browse/FLINK-18201 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-18200) Replace the deprecated interfaces with the new interfaces in the tests and examples

2020-06-08 Thread Dian Fu (Jira)
Dian Fu created FLINK-18200: --- Summary: Replace the deprecated interfaces with the new interfaces in the tests and examples Key: FLINK-18200 URL: https://issues.apache.org/jira/browse/FLINK-18200 Project: Fl

[jira] [Closed] (FLINK-17902) Support the new interfaces about temporary functions in PyFlink

2020-06-08 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17902?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-17902. --- Resolution: Resolved Merged to master via 74231f736cdb7abb06887ab93940519bda87c169 > Support the new interf

[jira] [Updated] (FLINK-17422) Create user document for the external resource framework and the GPU plugin..

2020-06-08 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17422?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo updated FLINK-17422: --- Labels: pull-request-available (was: ) > Create user document for the external resource framework a

[jira] [Created] (FLINK-18199) Translate "Filesystem SQL Connector" page into Chinese

2020-06-08 Thread Jark Wu (Jira)
Jark Wu created FLINK-18199: --- Summary: Translate "Filesystem SQL Connector" page into Chinese Key: FLINK-18199 URL: https://issues.apache.org/jira/browse/FLINK-18199 Project: Flink Issue Type: Sub-

[jira] [Created] (FLINK-18198) Translate "HBase SQL Connector"page into Chinese

2020-06-08 Thread Jark Wu (Jira)
Jark Wu created FLINK-18198: --- Summary: Translate "HBase SQL Connector"page into Chinese Key: FLINK-18198 URL: https://issues.apache.org/jira/browse/FLINK-18198 Project: Flink Issue Type: Sub-task

[jira] [Updated] (FLINK-18198) Translate "HBase SQL Connector" page into Chinese

2020-06-08 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18198?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-18198: Summary: Translate "HBase SQL Connector" page into Chinese (was: Translate "HBase SQL Connector"page into

[jira] [Updated] (FLINK-18196) flink throws `NullPointerException` when executeCheckpointing

2020-06-08 Thread Kai Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kai Chen updated FLINK-18196: - Description: I meet checkpoint NPE when executing wordcount example: java.lang.Exception: Could not per

[jira] [Updated] (FLINK-18196) flink throws `NullPointerException` when executeCheckpointing

2020-06-08 Thread Kai Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kai Chen updated FLINK-18196: - Description: I meet checkpoint NPE when executing wordcount example: java.lang.Exception: Could not per

[jira] [Closed] (FLINK-16559) Cannot create Hive avro table in test

2020-06-08 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-16559. Assignee: Rui Li Resolution: Fixed master: fd9214e7754455ab4733fe52daeb4e0b292e583f release

[jira] [Closed] (FLINK-16291) Count(*) doesn't work with Hive module

2020-06-08 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16291?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-16291. Resolution: Fixed master: 2be8239fc0f61524d9456c1e38d76f0c16b9ee7b release-1.11: 513ac5ae8d4fc1e6

[jira] [Commented] (FLINK-16090) Translate "Table API" page of "Table API & SQL" into Chinese

2020-06-08 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16090?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17128834#comment-17128834 ] Jark Wu commented on FLINK-16090: - Hi [~CrazyTomatoOo], are you still working on this?

[jira] [Closed] (FLINK-16091) Translate "Connect to External Systems" page of "Table API & SQL" into Chinese

2020-06-08 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16091?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-16091. --- Resolution: Won't Do connect.zh.md is a legeacy page, we won't translate it, the new page is in https://ci.

[jira] [Closed] (FLINK-17893) SQL-CLI no exception stack

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

[jira] [Created] (FLINK-18197) Add more logs for hive streaming integration

2020-06-08 Thread Rui Li (Jira)
Rui Li created FLINK-18197: -- Summary: Add more logs for hive streaming integration Key: FLINK-18197 URL: https://issues.apache.org/jira/browse/FLINK-18197 Project: Flink Issue Type: Task C

[jira] [Comment Edited] (FLINK-17978) Test Hadoop dependency change

2020-06-08 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17978?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17128815#comment-17128815 ] Yang Wang edited comment on FLINK-17978 at 6/9/20, 3:45 AM:

[jira] [Commented] (FLINK-17978) Test Hadoop dependency change

2020-06-08 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17978?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17128815#comment-17128815 ] Yang Wang commented on FLINK-17978: --- If hadoop dependency is missing in client side, t

[jira] [Closed] (FLINK-16101) Translate "Hive Functions" page of "Hive Integration" into Chinese

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

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

2020-06-08 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18186?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang updated FLINK-18186: -- Summary: Various updates on Kubernetes standalone document (was: Various updates of Kubernetes standa

[jira] [Commented] (FLINK-16448) add documentation for Hive table source and sink parallelism setting strategy

2020-06-08 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16448?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17128807#comment-17128807 ] Jingsong Lee commented on FLINK-16448: -- [https://github.com/apache/flink/pull/12537

[jira] [Commented] (FLINK-17579) Set the resource id of taskexecutor according to environment variable if exist in standalone mode

2020-06-08 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17579?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17128805#comment-17128805 ] Yang Wang commented on FLINK-17579: --- [~azagrebin] [~karmagyz] Thanks for the fruitful

[jira] [Closed] (FLINK-17835) Add document for Hive streaming sink

2020-06-08 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17835?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-17835. Resolution: Duplicate > Add document for Hive streaming sink > ---

[jira] [Updated] (FLINK-17733) Add documentation for real-time hive

2020-06-08 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17733?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-17733: - Fix Version/s: (was: 1.12.0) > Add documentation for real-time hive > --

[jira] [Commented] (FLINK-18186) Various updates of Kubernetes standalone document

2020-06-08 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18186?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17128806#comment-17128806 ] Yang Wang commented on FLINK-18186: --- cc [~azagrebin], since many parts of this documen

[jira] [Closed] (FLINK-17834) Add document for Hive streaming source

2020-06-08 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17834?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-17834. Resolution: Duplicate > Add document for Hive streaming source > -

[jira] [Assigned] (FLINK-17834) Add document for Hive streaming source

2020-06-08 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17834?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-17834: Assignee: Jingsong Lee (was: Rui Li) > Add document for Hive streaming source >

[jira] [Updated] (FLINK-18196) flink throws `NullPointerException` when executeCheckpointing

2020-06-08 Thread Kai Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kai Chen updated FLINK-18196: - Description: I meet checkpoint NPE when executing wordcount example: java.lang.Exception: Could not per

[jira] [Closed] (FLINK-17625) Fix ArrayIndexOutOfBoundsException in AppendOnlyTopNFunction

2020-06-08 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17625?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-17625. --- Fix Version/s: (was: 1.10.2) Resolution: Fixed - master (1.12.0): 926523e14e8dda8d648d56eb0992aae

[jira] [Commented] (FLINK-18196) flink throws `NullPointerException` when executeCheckpointing

2020-06-08 Thread Jiayi Liao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18196?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17128801#comment-17128801 ] Jiayi Liao commented on FLINK-18196: Thanks for reporting this. Could you tell us wh

[jira] [Commented] (FLINK-18071) CoordinatorEventsExactlyOnceITCase.checkListContainsSequence fails on CI

2020-06-08 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18071?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17128798#comment-17128798 ] Yun Tang commented on FLINK-18071: -- Another instance: https://myasuka.visualstudio.com

[jira] [Updated] (FLINK-18196) flink throws `NullPointerException` when executeCheckpointing

2020-06-08 Thread Kai Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kai Chen updated FLINK-18196: - Description: I meet checkpoint NPE when executing wordcount example: java.lang.Exception: Could not per

[jira] [Updated] (FLINK-18196) flink throws `NullPointerException` when executeCheckpointing

2020-06-08 Thread Kai Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kai Chen updated FLINK-18196: - Description: I meet checkpoint NPE when executing wordcount example: java.lang.Exception: Could not per

[jira] [Updated] (FLINK-18196) flink throws `NullPointerException` when executeCheckpointing

2020-06-08 Thread Kai Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kai Chen updated FLINK-18196: - Description: I meet checkpoint NPE when executing wordcount example: java.lang.Exception: Could not per

[jira] [Updated] (FLINK-18196) flink throws `NullPointerException` when executeCheckpointing

2020-06-08 Thread Kai Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kai Chen updated FLINK-18196: - Description: I meet checkpoint NPE when executing wordcount example: java.lang.Exception: Could not per

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

2020-06-08 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16495?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-16495: Description: Currently, Elasticsearch sink provides 3 flush options: {code:java} 'connector.bulk-flush.m

[jira] [Created] (FLINK-18196) flink throws `NullPointerException` when executeCheckpointing

2020-06-08 Thread Kai Chen (Jira)
Kai Chen created FLINK-18196: Summary: flink throws `NullPointerException` when executeCheckpointing Key: FLINK-18196 URL: https://issues.apache.org/jira/browse/FLINK-18196 Project: Flink Issue

[jira] [Commented] (FLINK-18185) Confusing ValidationExcetion in DataGenTableSourceFactory

2020-06-08 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18185?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17128789#comment-17128789 ] Jingsong Lee commented on FLINK-18185: -- Thanks [~knaufk] for reporting, I should ad

[jira] [Commented] (FLINK-18188) Document asymmetric allocation of Flink memory

2020-06-08 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18188?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17128785#comment-17128785 ] Xintong Song commented on FLINK-18188: -- I think this behavior is by design. However

[jira] [Closed] (FLINK-18108) Wheel package consistency checks

2020-06-08 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18108?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-18108. --- Resolution: Done > Wheel package consistency checks > > > K

[jira] [Closed] (FLINK-18107) Performance tests for PyFlink UDFs

2020-06-08 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18107?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-18107. --- Resolution: Done > Performance tests for PyFlink UDFs > -- > >

[jira] [Closed] (FLINK-18106) Tests Python UDTF support

2020-06-08 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18106?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-18106. --- Resolution: Done > Tests Python UDTF support > - > > Key: FLINK-1810

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

2020-06-08 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17128779#comment-17128779 ] Yang Wang commented on FLINK-18085: --- Test application mode for standalone K8s: * Use

[jira] [Reopened] (FLINK-15798) Running ./bin/kubernetes-session.sh -Dkubernetes.cluster-id= -Dexecution.attached=true fails with exception

2020-06-08 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15798?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang reopened FLINK-15798: --- > Running ./bin/kubernetes-session.sh -Dkubernetes.cluster-id= > -Dexecution.attached=true fails with e

[jira] [Commented] (FLINK-15798) Running ./bin/kubernetes-session.sh -Dkubernetes.cluster-id= -Dexecution.attached=true fails with exception

2020-06-08 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15798?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17128777#comment-17128777 ] Yang Wang commented on FLINK-15798: --- Reopen this ticket for further investigation. It

[jira] [Comment Edited] (FLINK-17722) "Failed to find the file" in "build_wheels" stage

2020-06-08 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17722?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17117706#comment-17117706 ] Dian Fu edited comment on FLINK-17722 at 6/9/20, 2:25 AM: -- Merg

[jira] [Commented] (FLINK-18191) Rename new Master memory options to start with "master" prefix

2020-06-08 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18191?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17128776#comment-17128776 ] Nicholas Jiang commented on FLINK-18191: [~chesnay]Do you mean that replace "job

[jira] [Comment Edited] (FLINK-18184) Could not find a suitable table factory for 'org.apache.flink.table.factories.TableSourceFactory'

2020-06-08 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17128775#comment-17128775 ] Jark Wu edited comment on FLINK-18184 at 6/9/20, 2:13 AM: -- [~dw

[jira] [Comment Edited] (FLINK-18184) Could not find a suitable table factory for 'org.apache.flink.table.factories.TableSourceFactory'

2020-06-08 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17128775#comment-17128775 ] Jark Wu edited comment on FLINK-18184 at 6/9/20, 2:13 AM: -- [~dw

[jira] [Closed] (FLINK-18184) Could not find a suitable table factory for 'org.apache.flink.table.factories.TableSourceFactory'

2020-06-08 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18184?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-18184. --- Resolution: Not A Bug [~dwysakowicz] is right. Besides, I guess [~mzz_q] encountered this problem in 1.9.1.

[jira] [Assigned] (FLINK-17978) Test Hadoop dependency change

2020-06-08 Thread Zhijiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17978?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang reassigned FLINK-17978: Assignee: Yang Wang > Test Hadoop dependency change > - > >

[jira] [Assigned] (FLINK-18185) Confusing ValidationExcetion in DataGenTableSourceFactory

2020-06-08 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18185?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-18185: --- Assignee: Jingsong Lee > Confusing ValidationExcetion in DataGenTableSourceFactory > --

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

2020-06-08 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17260?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17128762#comment-17128762 ] godfrey he commented on FLINK-17260: another one: https://dev.azure.com/apache-flink

[jira] [Commented] (FLINK-18189) Incorrect size check for sum of heap/non-heap memory

2020-06-08 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18189?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17128754#comment-17128754 ] Nicholas Jiang commented on FLINK-18189: [~azagrebin][~chesnay] Could you please

[jira] [Updated] (FLINK-18195) Remove references to Expressions.interval(Duration) from (java)docs

2020-06-08 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18195?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-18195: - Summary: Remove references to Expressions.interval(Duration) from (java)docs (was: Remo

[jira] [Created] (FLINK-18195) Remove references to Expressions.interval(Duration)

2020-06-08 Thread Dawid Wysakowicz (Jira)
Dawid Wysakowicz created FLINK-18195: Summary: Remove references to Expressions.interval(Duration) Key: FLINK-18195 URL: https://issues.apache.org/jira/browse/FLINK-18195 Project: Flink I

[jira] [Created] (FLINK-18194) Update Table API Walkthrough

2020-06-08 Thread Seth Wiesman (Jira)
Seth Wiesman created FLINK-18194: Summary: Update Table API Walkthrough Key: FLINK-18194 URL: https://issues.apache.org/jira/browse/FLINK-18194 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-18193) Replace all documentation self links with {% link %} tag

2020-06-08 Thread Seth Wiesman (Jira)
Seth Wiesman created FLINK-18193: Summary: Replace all documentation self links with {% link %} tag Key: FLINK-18193 URL: https://issues.apache.org/jira/browse/FLINK-18193 Project: Flink Issu

[jira] [Comment Edited] (FLINK-15798) Running ./bin/kubernetes-session.sh -Dkubernetes.cluster-id= -Dexecution.attached=true fails with exception

2020-06-08 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15798?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17128546#comment-17128546 ] Robert Metzger edited comment on FLINK-15798 at 6/8/20, 7:02 PM: -

[jira] [Created] (FLINK-18192) Upgrade to Avro version 1.9.1 from 1.8.2

2020-06-08 Thread Lucas Heimberg (Jira)
Lucas Heimberg created FLINK-18192: -- Summary: Upgrade to Avro version 1.9.1 from 1.8.2 Key: FLINK-18192 URL: https://issues.apache.org/jira/browse/FLINK-18192 Project: Flink Issue Type: Impr

[jira] [Commented] (FLINK-15798) Running ./bin/kubernetes-session.sh -Dkubernetes.cluster-id= -Dexecution.attached=true fails with exception

2020-06-08 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15798?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17128546#comment-17128546 ] Robert Metzger commented on FLINK-15798: I got this error also on job submission

[jira] [Comment Edited] (FLINK-17976) Test native K8s integration

2020-06-08 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17976?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17128313#comment-17128313 ] Robert Metzger edited comment on FLINK-17976 at 6/8/20, 6:31 PM: -

[jira] [Comment Edited] (FLINK-17976) Test native K8s integration

2020-06-08 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17976?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17128313#comment-17128313 ] Robert Metzger edited comment on FLINK-17976 at 6/8/20, 6:03 PM: -

[jira] [Closed] (FLINK-17194) TPC-DS end-to-end test fails due to missing execution attempt

2020-06-08 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17194?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger closed FLINK-17194. -- Resolution: Cannot Reproduce I agree. I've closed the ticket. > TPC-DS end-to-end test fails

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

2020-06-08 Thread Aljoscha Krettek (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17260?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17128461#comment-17128461 ] Aljoscha Krettek commented on FLINK-17260: -- I pushed 50b6d9d5ffbcfbcc20c843e875

[jira] [Created] (FLINK-18191) Rename new Master memory options to start with "master" prefix

2020-06-08 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-18191: Summary: Rename new Master memory options to start with "master" prefix Key: FLINK-18191 URL: https://issues.apache.org/jira/browse/FLINK-18191 Project: Flink

[jira] [Commented] (FLINK-13777) Introduce sql function wrappers and conversion to ExpressionConverter

2020-06-08 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13777?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17128408#comment-17128408 ] Dawid Wysakowicz commented on FLINK-13777: -- [~twalthr] Wasn't this implemented

[jira] [Closed] (FLINK-13782) Implement type inference for logic functions

2020-06-08 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13782?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-13782. Resolution: Implemented Implemented *master: ** 618b7795ba9567650df05e0c4808acc34711d396

[jira] [Comment Edited] (FLINK-13782) Implement type inference for logic functions

2020-06-08 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13782?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17128407#comment-17128407 ] Dawid Wysakowicz edited comment on FLINK-13782 at 6/8/20, 4:01 PM: ---

[jira] [Comment Edited] (FLINK-13782) Implement type inference for logic functions

2020-06-08 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13782?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17128407#comment-17128407 ] Dawid Wysakowicz edited comment on FLINK-13782 at 6/8/20, 4:01 PM: ---

[jira] [Comment Edited] (FLINK-18184) Could not find a suitable table factory for 'org.apache.flink.table.factories.TableSourceFactory'

2020-06-08 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17128403#comment-17128403 ] Dawid Wysakowicz edited comment on FLINK-18184 at 6/8/20, 3:56 PM: ---

[jira] [Commented] (FLINK-18184) Could not find a suitable table factory for 'org.apache.flink.table.factories.TableSourceFactory'

2020-06-08 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17128403#comment-17128403 ] Dawid Wysakowicz commented on FLINK-18184: -- Yes, that's what we are trying to d

[jira] [Commented] (FLINK-18189) Incorrect size check for sum of heap/non-heap memory

2020-06-08 Thread Andrey Zagrebin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18189?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17128401#comment-17128401 ] Andrey Zagrebin commented on FLINK-18189: - Indeed, the error message is incorrec

[jira] [Updated] (FLINK-17980) Simplify Flink Getting Started Material

2020-06-08 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17980?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman updated FLINK-17980: - Fix Version/s: 1.12.0 > Simplify Flink Getting Started Material > --

  1   2   3   4   >