[jira] [Closed] (FLINK-17965) Hive dialect doesn't properly handle special character escaping with SQL CLI

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

[jira] [Comment Edited] (FLINK-17965) Hive dialect doesn't properly handle special character escaping with SQL CLI

2020-06-11 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17965?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17132967#comment-17132967 ] Jingsong Lee edited comment on FLINK-17965 at 6/11/20, 6:51 AM: master:

[jira] [Commented] (FLINK-17182) RemoteInputChannelTest.testConcurrentOnSenderBacklogAndRecycle fail on azure

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

[jira] [Updated] (FLINK-17182) RemoteInputChannelTest.testConcurrentOnSenderBacklogAndRecycle fail on azure

2020-06-11 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17182?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-17182: --- Affects Version/s: 1.11.0 > RemoteInputChannelTest.testConcurrentOnSenderBacklogAndRecycle

[GitHub] [flink] wuchong commented on pull request #12574: [FLINK-18131][doc] Add documentation for the new JSON format

2020-06-11 Thread GitBox
wuchong commented on pull request #12574: URL: https://github.com/apache/flink/pull/12574#issuecomment-642451870 The failed tests are not related to this PR, merging... This is an automated message from the Apache Git

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

2020-06-11 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18122?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17132977#comment-17132977 ] Jark Wu commented on FLINK-18122: - Another instance:

[GitHub] [flink] wuchong merged pull request #12574: [FLINK-18131][doc] Add documentation for the new JSON format

2020-06-11 Thread GitBox
wuchong merged pull request #12574: URL: https://github.com/apache/flink/pull/12574 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] DashShen commented on a change in pull request #12369: [FLINK-17678][Connectors/HBase]Support fink-sql-connector-hbase

2020-06-11 Thread GitBox
DashShen commented on a change in pull request #12369: URL: https://github.com/apache/flink/pull/12369#discussion_r438561409 ## File path: flink-end-to-end-tests/flink-end-to-end-tests-hbase/src/test/java/org/apache/flink/tests/util/hbase/SQLClientHBaseITCase.java ## @@ -0,0

[jira] [Updated] (FLINK-18243) Flink SQL (1.10.0) to elasticsearch 5.6

2020-06-11 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-18243?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] 颖 updated FLINK-18243: -- Description: When Flink 1.10.0 Consumer Kafka writes ELASticSearch 5.6.3 through SQL data, the following problems

[jira] [Updated] (FLINK-18243) Flink SQL (1.10.0) From Kafkasource can not get data

2020-06-11 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-18243?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] 颖 updated FLINK-18243: -- Summary: Flink SQL (1.10.0) From Kafkasource can not get data (was: Flink SQL (1.10.0) to elasticsearch 5.6) >

[jira] [Created] (FLINK-18246) PyFlink e2e fails with java version mismatch on JDK11 nightly build

2020-06-11 Thread Robert Metzger (Jira)
Robert Metzger created FLINK-18246: -- Summary: PyFlink e2e fails with java version mismatch on JDK11 nightly build Key: FLINK-18246 URL: https://issues.apache.org/jira/browse/FLINK-18246 Project:

[jira] [Commented] (FLINK-18246) PyFlink e2e fails with java version mismatch on JDK11 nightly build

2020-06-11 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17132950#comment-17132950 ] Robert Metzger commented on FLINK-18246: This could also be a problem of the Azure setup, not

[GitHub] [flink] flinkbot edited a comment on pull request #12278: [FLINK-17019][runtime] Fulfill slot requests in request order

2020-06-11 Thread GitBox
flinkbot edited a comment on pull request #12278: URL: https://github.com/apache/flink/pull/12278#issuecomment-632060550 ## CI report: * 9a0102b7e3b412027bb84b16cf79f85e930ceb81 Azure:

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

2020-06-11 Thread GitBox
flinkbot edited a comment on pull request #12369: URL: https://github.com/apache/flink/pull/12369#issuecomment-635090403 ## CI report: * 586cad86df6ee5de33537f735fa5c65cabebe260 Azure:

[GitHub] [flink] JingsongLi merged pull request #12403: [FLINK-18030][hive] Hive UDF doesn't accept empty string literal para…

2020-06-11 Thread GitBox
JingsongLi merged pull request #12403: URL: https://github.com/apache/flink/pull/12403 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] nicusX commented on a change in pull request #12591: [FLINK-18223][avro] Fixed AvroSerializer to correctly initialize GenericRecords

2020-06-11 Thread GitBox
nicusX commented on a change in pull request #12591: URL: https://github.com/apache/flink/pull/12591#discussion_r438567233 ## File path: flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/typeutils/AvroSerializer.java ## @@ -170,7 +170,11 @@ public int

[jira] [Closed] (FLINK-18030) Hive UDF doesn't accept empty string literal parameter

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

[jira] [Comment Edited] (FLINK-17965) Hive dialect doesn't properly handle special character escaping with SQL CLI

2020-06-11 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17965?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17132967#comment-17132967 ] Jingsong Lee edited comment on FLINK-17965 at 6/11/20, 6:53 AM: master:

[GitHub] [flink] zhuzhurk commented on pull request #12540: [WIP][FLINK-17016][runtime] Change blink planner batch jobs to run with pipelined region scheduling

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

[GitHub] [flink] DashShen commented on a change in pull request #12369: [FLINK-17678][Connectors/HBase]Support fink-sql-connector-hbase

2020-06-11 Thread GitBox
DashShen commented on a change in pull request #12369: URL: https://github.com/apache/flink/pull/12369#discussion_r438561409 ## File path: flink-end-to-end-tests/flink-end-to-end-tests-hbase/src/test/java/org/apache/flink/tests/util/hbase/SQLClientHBaseITCase.java ## @@ -0,0

[jira] [Updated] (FLINK-18243) Flink SQL (1.10.0) From Kafkasource can not get data

2020-06-11 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-18243?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] 颖 updated FLINK-18243: -- Component/s: (was: Connectors / ElasticSearch) Connectors / Kafka > Flink SQL (1.10.0) From

[GitHub] [flink] flinkbot edited a comment on pull request #12591: [FLINK-18223][avro] Fixed AvroSerializer to correctly initialize GenericRecords

2020-06-11 Thread GitBox
flinkbot edited a comment on pull request #12591: URL: https://github.com/apache/flink/pull/12591#issuecomment-642119670 ## CI report: * 766a97492705b417323626f10573ffb8f58de106 Azure:

[jira] [Updated] (FLINK-18243) Flink SQL (1.10.0) From Kafkasource can not get data

2020-06-11 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-18243?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] 颖 updated FLINK-18243: -- Description: When Flink 1.10.0 Consumer Kafka cant read source from kafkatopicthrough SQL data, the following

[GitHub] [flink] flinkbot edited a comment on pull request #12571: [FLINK-18132][doc] Add documentation for the new CSV format

2020-06-11 Thread GitBox
flinkbot edited a comment on pull request #12571: URL: https://github.com/apache/flink/pull/12571#issuecomment-641787522 ## CI report: * aba77421459da92ba3f7587ffdb430e5f6a1b3ed Azure:

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

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

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

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

[GitHub] [flink] nicusX commented on a change in pull request #12591: [FLINK-18223][avro] Fixed AvroSerializer to correctly initialize GenericRecords

2020-06-11 Thread GitBox
nicusX commented on a change in pull request #12591: URL: https://github.com/apache/flink/pull/12591#discussion_r438559736 ## File path: flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/typeutils/AvroSerializer.java ## @@ -170,7 +170,11 @@ public int

[jira] [Commented] (FLINK-18020) SQLClientKafkaITCase.testKafka is flaky

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

[jira] [Closed] (FLINK-18131) Add documentation for the new JSON format

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

[GitHub] [flink] zhuzhurk removed a comment on pull request #12540: [WIP][FLINK-17016][runtime] Change blink planner batch jobs to run with pipelined region scheduling

2020-06-11 Thread GitBox
zhuzhurk removed a comment on pull request #12540: URL: https://github.com/apache/flink/pull/12540#issuecomment-641975359 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink] DashShen commented on a change in pull request #12369: [FLINK-17678][Connectors/HBase]Support fink-sql-connector-hbase

2020-06-11 Thread GitBox
DashShen commented on a change in pull request #12369: URL: https://github.com/apache/flink/pull/12369#discussion_r438563119 ## File path: flink-end-to-end-tests/flink-end-to-end-tests-hbase/src/test/resources/hbase_source_sink_schema.yaml ## @@ -0,0 +1,57 @@

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

2020-06-11 Thread GitBox
zhuzhurk removed a comment on pull request #12278: URL: https://github.com/apache/flink/pull/12278#issuecomment-633531282 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the

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

2020-06-11 Thread GitBox
zhuzhurk removed a comment on pull request #12278: URL: https://github.com/apache/flink/pull/12278#issuecomment-641975174 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink] zoudan commented on a change in pull request #12542: [FLINK-18168][table-runtime-blink] return a copy of reuseArray in ObjectArrayConverter.toBinaryArray()

2020-06-11 Thread GitBox
zoudan commented on a change in pull request #12542: URL: https://github.com/apache/flink/pull/12542#discussion_r438563071 ## File path: flink-table/flink-table-runtime-blink/src/test/java/org/apache/flink/table/data/DataStructureConvertersTest.java ## @@ -373,6 +375,20 @@

[GitHub] [flink] wuchong commented on a change in pull request #12579: [FLINK-17832][docs][es] Add documentation for the new Elasticsearch connector

2020-06-11 Thread GitBox
wuchong commented on a change in pull request #12579: URL: https://github.com/apache/flink/pull/12579#discussion_r438576207 ## File path: docs/dev/table/connectors/elasticsearch.md ## @@ -0,0 +1,266 @@ +--- +title: "Elasticsearch SQL Connector" +nav-title: Elasticsearch

[GitHub] [flink] flinkbot edited a comment on pull request #12571: [FLINK-18132][doc] Add documentation for the new CSV format

2020-06-11 Thread GitBox
flinkbot edited a comment on pull request #12571: URL: https://github.com/apache/flink/pull/12571#issuecomment-641787522 ## CI report: * aba77421459da92ba3f7587ffdb430e5f6a1b3ed Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12278: [FLINK-17019][runtime] Fulfill slot requests in request order

2020-06-11 Thread GitBox
flinkbot edited a comment on pull request #12278: URL: https://github.com/apache/flink/pull/12278#issuecomment-632060550 ## CI report: * 9a0102b7e3b412027bb84b16cf79f85e930ceb81 Azure:

[GitHub] [flink] nicusX commented on a change in pull request #12591: [FLINK-18223][avro] Fixed AvroSerializer to correctly initialize GenericRecords

2020-06-11 Thread GitBox
nicusX commented on a change in pull request #12591: URL: https://github.com/apache/flink/pull/12591#discussion_r438564688 ## File path: flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/typeutils/AvroSerializer.java ## @@ -170,7 +170,11 @@ public int

[jira] [Created] (FLINK-18247) Unstable test: TableITCase.testCollectWithClose:122 expected: but was:

2020-06-11 Thread Robert Metzger (Jira)
Robert Metzger created FLINK-18247: -- Summary: Unstable test: TableITCase.testCollectWithClose:122 expected: but was: Key: FLINK-18247 URL: https://issues.apache.org/jira/browse/FLINK-18247 Project:

[GitHub] [flink] JingsongLi merged pull request #12378: [FLINK-17965][sql-parser-hive] Hive dialect needs to unescape backslash in string literals

2020-06-11 Thread GitBox
JingsongLi merged pull request #12378: URL: https://github.com/apache/flink/pull/12378 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

[jira] [Updated] (FLINK-18137) JobMasterTriggerSavepointITCase.testStopJobAfterSavepoint fails with AskTimeoutException

2020-06-11 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18137?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-18137: --- Component/s: Tests Runtime / Checkpointing >

[jira] [Commented] (FLINK-18137) JobMasterTriggerSavepointITCase.testStopJobAfterSavepoint fails with AskTimeoutException

2020-06-11 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18137?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17132971#comment-17132971 ] Robert Metzger commented on FLINK-18137: The error is somewhat reproducible locally, BUT not

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

2020-06-11 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18200?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-18200: --- Assignee: Nicholas Jiang > Replace the deprecated interfaces with the new interfaces in the tests

[jira] [Commented] (FLINK-18020) SQLClientKafkaITCase.testKafka is flaky

2020-06-11 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18020?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17132983#comment-17132983 ] Jark Wu commented on FLINK-18020: -

[jira] [Commented] (FLINK-17824) "Resuming Savepoint" e2e stalls indefinitely

2020-06-11 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17824?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17132984#comment-17132984 ] Robert Metzger commented on FLINK-17824: [~roman_khachatryan] do you think this is the same

[GitHub] [flink] flinkbot commented on pull request #12593: [FLINK-13783][table] Implement type inference for string functions

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

2020-06-11 Thread GitBox
flinkbot commented on pull request #12594: URL: https://github.com/apache/flink/pull/12594#issuecomment-642468597 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] wuchong merged pull request #12571: [FLINK-18132][doc] Add documentation for the new CSV format

2020-06-11 Thread GitBox
wuchong merged pull request #12571: URL: https://github.com/apache/flink/pull/12571 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] JingsongLi commented on a change in pull request #12595: [FLINK-18247][table-planner-blink] Fix unstable test: TableITCase.testCollectWithClose

2020-06-11 Thread GitBox
JingsongLi commented on a change in pull request #12595: URL: https://github.com/apache/flink/pull/12595#discussion_r438615199 ## File path: flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/api/TableITCase.scala ## @@ -119,7 +119,13 @@ class

[jira] [Created] (FLINK-18252) Resuming Savepoint (file, async, no parallelism change) end-to-end test fails with unaligned checkpoint enabled

2020-06-11 Thread Arvid Heise (Jira)
Arvid Heise created FLINK-18252: --- Summary: Resuming Savepoint (file, async, no parallelism change) end-to-end test fails with unaligned checkpoint enabled Key: FLINK-18252 URL:

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

2020-06-11 Thread GitBox
azagrebin commented on a change in pull request #12375: URL: https://github.com/apache/flink/pull/12375#discussion_r438636756 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/BulkSlotProviderImpl.java ## @@ -0,0 +1,204 @@ +/* + * Licensed

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

2020-06-11 Thread GitBox
azagrebin commented on a change in pull request #12375: URL: https://github.com/apache/flink/pull/12375#discussion_r438643603 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/BulkSlotProviderImpl.java ## @@ -0,0 +1,204 @@ +/* + * Licensed

[jira] [Created] (FLINK-18253) Add filesystem documentation for Avro

2020-06-11 Thread Jingsong Lee (Jira)
Jingsong Lee created FLINK-18253: Summary: Add filesystem documentation for Avro Key: FLINK-18253 URL: https://issues.apache.org/jira/browse/FLINK-18253 Project: Flink Issue Type: Sub-task

[jira] [Commented] (FLINK-18246) PyFlink e2e fails with java version mismatch on JDK11 nightly build

2020-06-11 Thread Wei Zhong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17133076#comment-17133076 ] Wei Zhong commented on FLINK-18246: --- Hi [~rmetzger]. The cause of the test failure is that the docker

[GitHub] [flink] flinkbot commented on pull request #12597: [FLINK-18141][doc][parquet] Add documentation for Parquet format

2020-06-11 Thread GitBox
flinkbot commented on pull request #12597: URL: https://github.com/apache/flink/pull/12597#issuecomment-642526206 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] flinkbot commented on pull request #12598: [FLINK-18246][python][e2e] Disable PyFlink e2e tests when running on jdk11 to avoid the UnsupportedClassVersionError.

2020-06-11 Thread GitBox
flinkbot commented on pull request #12598: URL: https://github.com/apache/flink/pull/12598#issuecomment-642526187 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-17105) FLIP-71: E2E view support for Flink SQL

2020-06-11 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17105?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-17105: --- Component/s: (was: Table SQL / Legacy Planner) > FLIP-71: E2E view support for Flink SQL >

[jira] [Assigned] (FLINK-16375) Reintroduce registerTableSource/Sink methods for table env

2020-06-11 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16375?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-16375: -- Assignee: Kurt Young > Reintroduce registerTableSource/Sink methods for table env >

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

2020-06-11 Thread GitBox
zhuzhurk commented on a change in pull request #12375: URL: https://github.com/apache/flink/pull/12375#discussion_r438668891 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/jobmaster/slotpool/PhysicalSlotRequestBulkTrackerTest.java ## @@ -0,0 +1,224 @@ +/*

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

2020-06-11 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17978?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17133104#comment-17133104 ] Yang Wang edited comment on FLINK-17978 at 6/11/20, 9:46 AM: - cc [~rmetzger] 

[jira] [Updated] (FLINK-16375) Reintroduce registerTableSource/Sink methods for table env

2020-06-11 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16375?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-16375: --- Summary: Reintroduce registerTableSource/Sink methods for table env (was: Remove references to

[jira] [Commented] (FLINK-16375) Remove references to registerTableSource/Sink methods from documentation

2020-06-11 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16375?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17133108#comment-17133108 ] Kurt Young commented on FLINK-16375: I'm also ok for reintroduce them, dropping a method without

[jira] [Updated] (FLINK-15950) Remove registration of TableSource/TableSink in ConnectTableDescriptor

2020-06-11 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15950?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-15950: --- Summary: Remove registration of TableSource/TableSink in ConnectTableDescriptor (was: Remove

[GitHub] [flink] flinkbot edited a comment on pull request #12375: [FLINK-17017][runtime] Implements bulk allocation for physical slots

2020-06-11 Thread GitBox
flinkbot edited a comment on pull request #12375: URL: https://github.com/apache/flink/pull/12375#issuecomment-635184560 ## CI report: * cd3fc98c034fdc61235d9109c05b4f55d7423746 UNKNOWN * d3f81cb67e5924bfc9d3e7bbba25af281e6b3102 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12510: [FLINK-18039]

2020-06-11 Thread GitBox
flinkbot edited a comment on pull request #12510: URL: https://github.com/apache/flink/pull/12510#issuecomment-640199489 ## CI report: * f0b2f727fb5a23b466328167cfce898829dc3e13 Azure:

[jira] [Commented] (FLINK-18242) Custom OptionsFactory settings seem to have no effect on RocksDB

2020-06-11 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18242?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17133134#comment-17133134 ] Nico Kruber commented on FLINK-18242: - Thanks for the analysis - after changing to the new

[GitHub] [flink] flinkbot edited a comment on pull request #12442: [FLINK-12428][docs-zh] Translate the "Event Time" page into Chinese

2020-06-11 Thread GitBox
flinkbot edited a comment on pull request #12442: URL: https://github.com/apache/flink/pull/12442#issuecomment-637524638 ## CI report: * e7daada8999ed5e3abf16a329fea3c4b45d16b11 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12537: [FLINK-17733][FLINK-16448][hive][doc] Adjust Hive doc & Add documentation for real-time hive

2020-06-11 Thread GitBox
flinkbot edited a comment on pull request #12537: URL: https://github.com/apache/flink/pull/12537#issuecomment-641007085 ## CI report: * 7ff56f02d52ad06686ff3ef1cb3b1b00791c217e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12375: [FLINK-17017][runtime] Implements bulk allocation for physical slots

2020-06-11 Thread GitBox
flinkbot edited a comment on pull request #12375: URL: https://github.com/apache/flink/pull/12375#issuecomment-635184560 ## CI report: * cd3fc98c034fdc61235d9109c05b4f55d7423746 UNKNOWN * d3f81cb67e5924bfc9d3e7bbba25af281e6b3102 Azure:

[GitHub] [flink] leonardBang commented on a change in pull request #12577: [FLINK-17599][docs] Update documents due to FLIP-84

2020-06-11 Thread GitBox
leonardBang commented on a change in pull request #12577: URL: https://github.com/apache/flink/pull/12577#discussion_r438660767 ## File path: docs/dev/table/common.zh.md ## @@ -828,18 +830,16 @@ Table API 和 SQL 查询会被翻译成 [DataStream]({{ site.baseurl }}/zh/dev/d 1. 优化逻辑执行计划 2.

[GitHub] [flink] JingsongLi opened a new pull request #12602: [FLINK-18140][doc][orc] Add documentation for ORC format

2020-06-11 Thread GitBox
JingsongLi opened a new pull request #12602: URL: https://github.com/apache/flink/pull/12602 ## What is the purpose of the change Add documentation for ORC format for filesystem connector. ## Verifying this change

[GitHub] [flink] aljoscha commented on a change in pull request #12589: [FLINK-17327] Fix Kafka Producer Resource Leaks

2020-06-11 Thread GitBox
aljoscha commented on a change in pull request #12589: URL: https://github.com/apache/flink/pull/12589#discussion_r438691884 ## File path: flink-connectors/flink-connector-kafka-0.11/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer011.java ## @@

[jira] [Commented] (FLINK-16375) Reintroduce registerTableSource/Sink methods for table env

2020-06-11 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16375?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17133139#comment-17133139 ] Kurt Young commented on FLINK-16375: BTW, how about we only revert this in 1.11 branch? I don't see

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

2020-06-11 Thread GitBox
aljoscha commented on pull request #12589: URL: https://github.com/apache/flink/pull/12589#issuecomment-642559128 @becketqin I pushed changes, please take another look. This is an automated message from the Apache Git

[GitHub] [flink] flinkbot commented on pull request #12603: [1.11][FLINK-16375][table] Reintroduce registerTable[Source/Sink] methods for table env

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

[jira] [Updated] (FLINK-17788) scala shell in yarn mode is broken

2020-06-11 Thread Kostas Kloudas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17788?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-17788: --- Fix Version/s: 1.12.0 1.10.2 1.11.0 > scala shell in

[jira] [Assigned] (FLINK-17788) scala shell in yarn mode is broken

2020-06-11 Thread Kostas Kloudas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17788?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas reassigned FLINK-17788: -- Assignee: Kostas Kloudas > scala shell in yarn mode is broken >

[GitHub] [flink] JingsongLi commented on a change in pull request #12537: [FLINK-17733][FLINK-16448][hive][doc] Adjust Hive doc & Add documentation for real-time hive

2020-06-11 Thread GitBox
JingsongLi commented on a change in pull request #12537: URL: https://github.com/apache/flink/pull/12537#discussion_r438583581 ## File path: docs/dev/table/hive/hive_streaming.md ## @@ -0,0 +1,164 @@ +--- +title: "Hive Streaming" +nav-parent_id: hive_tableapi +nav-pos: 2 +---

[GitHub] [flink] JingsongLi commented on a change in pull request #12537: [FLINK-17733][FLINK-16448][hive][doc] Adjust Hive doc & Add documentation for real-time hive

2020-06-11 Thread GitBox
JingsongLi commented on a change in pull request #12537: URL: https://github.com/apache/flink/pull/12537#discussion_r438585128 ## File path: docs/dev/table/hive/hive_streaming.md ## @@ -0,0 +1,164 @@ +--- +title: "Hive Streaming" +nav-parent_id: hive_tableapi +nav-pos: 2 +---

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

2020-06-11 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18122?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17133001#comment-17133001 ] Yang Wang commented on FLINK-18122: --- [~jark] Could you rebase the latest master and try a again? Your

[GitHub] [flink] flinkbot edited a comment on pull request #12571: [FLINK-18132][doc] Add documentation for the new CSV format

2020-06-11 Thread GitBox
flinkbot edited a comment on pull request #12571: URL: https://github.com/apache/flink/pull/12571#issuecomment-641787522 ## CI report: * 6c8d167385bb5bb0a30f0c2ca2074ca959e552f3 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12579: [FLINK-17832][docs][es] Add documentation for the new Elasticsearch connector

2020-06-11 Thread GitBox
flinkbot edited a comment on pull request #12579: URL: https://github.com/apache/flink/pull/12579#issuecomment-641919167 ## CI report: * 1e4c7a68bd927367b1e0cf071157b57fbc6d50a9 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12591: [FLINK-18223][avro] Fixed AvroSerializer to correctly initialize GenericRecords

2020-06-11 Thread GitBox
flinkbot edited a comment on pull request #12591: URL: https://github.com/apache/flink/pull/12591#issuecomment-642119670 ## CI report: * 766a97492705b417323626f10573ffb8f58de106 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12589: [FLINK-17327] Fix Kafka Producer Resource Leaks

2020-06-11 Thread GitBox
flinkbot edited a comment on pull request #12589: URL: https://github.com/apache/flink/pull/12589#issuecomment-642078835 ## CI report: * f487b7e0ac685c9eeb239c169726a8abf235e421 Azure:

[GitHub] [flink] flinkbot commented on pull request #12593: [FLINK-13783][table] Implement type inference for string functions

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

[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-11 Thread GitBox
flinkbot edited a comment on pull request #12525: URL: https://github.com/apache/flink/pull/12525#issuecomment-640513261 ## CI report: * 9c986dc6290bc32cb56654f47f69276ff6d541bb Azure:

[GitHub] [flink] nicusX commented on a change in pull request #12591: [FLINK-18223][avro] Fixed AvroSerializer to correctly initialize GenericRecords

2020-06-11 Thread GitBox
nicusX commented on a change in pull request #12591: URL: https://github.com/apache/flink/pull/12591#discussion_r438567233 ## File path: flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/typeutils/AvroSerializer.java ## @@ -170,7 +170,11 @@ public int

[GitHub] [flink] flinkbot commented on pull request #12595: [FLINK-18247][table-planner-blink] Fix unstable test: TableITCase.testCollectWithClose

2020-06-11 Thread GitBox
flinkbot commented on pull request #12595: URL: https://github.com/apache/flink/pull/12595#issuecomment-642478408 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] [Closed] (FLINK-18092) E2E tests manually for HBase

2020-06-11 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18092?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu closed FLINK-18092. -- Resolution: Fixed > E2E tests manually for HBase > > >

[jira] [Comment Edited] (FLINK-18092) E2E tests manually for HBase

2020-06-11 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18092?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17128396#comment-17128396 ] Leonard Xu edited comment on FLINK-18092 at 6/11/20, 8:05 AM: -- -test Kafka

[jira] [Closed] (FLINK-18132) Add documentation for the new CSV format

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

[jira] [Updated] (FLINK-18137) JobMasterTriggerSavepointITCase.testStopJobAfterSavepoint fails with AskTimeoutException

2020-06-11 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18137?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-18137: --- Priority: Blocker (was: Critical) >

[jira] [Comment Edited] (FLINK-17824) "Resuming Savepoint" e2e stalls indefinitely

2020-06-11 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17824?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17132567#comment-17132567 ] Roman Khachatryan edited comment on FLINK-17824 at 6/11/20, 8:42 AM: -

[GitHub] [flink] morsapaes commented on a change in pull request #12556: [FLINK-17981][docs] rewrite docs home page

2020-06-11 Thread GitBox
morsapaes commented on a change in pull request #12556: URL: https://github.com/apache/flink/pull/12556#discussion_r438633593 ## File path: docs/index.md ## @@ -25,50 +25,60 @@ under the License. This documentation is for Apache Flink version {{ site.version_title }}. These

[GitHub] [flink-web] morsapaes commented on a change in pull request #349: [blog] Flink Community Update - June'20

2020-06-11 Thread GitBox
morsapaes commented on a change in pull request #349: URL: https://github.com/apache/flink-web/pull/349#discussion_r438648924 ## File path: _posts/2020-06-10-community-update.md ## @@ -0,0 +1,107 @@ +--- +layout: post +title: "Flink Community Update - June'20" +date:

[GitHub] [flink] WeiZhong94 opened a new pull request #12598: [FLINK-18246][python][e2e] Disable PyFlink e2e tests when running on jdk11 to avoid the UnsupportedClassVersionError.

2020-06-11 Thread GitBox
WeiZhong94 opened a new pull request #12598: URL: https://github.com/apache/flink/pull/12598 ## What is the purpose of the change *This pull request disables PyFlink e2e tests when running on jdk11 to avoid the UnsupportedClassVersionError.* ## Brief change log -

[jira] [Updated] (FLINK-18141) Add documentation for Parquet format

2020-06-11 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18141?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-18141: --- Labels: pull-request-available (was: ) > Add documentation for Parquet format >

[jira] [Updated] (FLINK-18246) PyFlink e2e fails with java version mismatch on JDK11 nightly build

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

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

2020-06-11 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17978?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17133097#comment-17133097 ] Jingsong Lee commented on FLINK-17978: -- In flink-orc, I think we should let flink-orc depends on 

[jira] [Commented] (FLINK-18254) Add documentation for primary key syntax

2020-06-11 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17133105#comment-17133105 ] Jark Wu commented on FLINK-18254: - cc [~danny0405] > Add documentation for primary key syntax >

  1   2   3   4   5   6   7   8   >