[GitHub] [flink] aljoscha commented on pull request #12674: [FLINK-18311] Fix StreamingKafkaITCase on Kafka 2.4.1

2020-06-16 Thread GitBox
aljoscha commented on pull request #12674: URL: https://github.com/apache/flink/pull/12674#issuecomment-644649736 @zentol I pushed more changes to fix an instability that I only saw locally. This is an automated message from

[GitHub] [flink] aljoscha commented on pull request #12674: [FLINK-18311] Fix StreamingKafkaITCase on Kafka 2.4.1

2020-06-16 Thread GitBox
aljoscha commented on pull request #12674: URL: https://github.com/apache/flink/pull/12674#issuecomment-644658041 @zentol I pushed a change to refactor `sendMessage()` into two separate method This is an automated message

[GitHub] [flink] flinkbot commented on pull request #8652: [FLINK-12489][Deployment/Mesos] Parametrisation of the network resource

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

[GitHub] [flink] flinkbot commented on pull request #8466: [FLINK-12336][monitoring] Add HTTPS support to InfluxDB reporter

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

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

2020-06-16 Thread GitBox
twalthr commented on a change in pull request #12577: URL: https://github.com/apache/flink/pull/12577#discussion_r440737603 ## File path: docs/try-flink/table_api.md ## @@ -462,14 +469,17 @@ public class SpendReport { tEnv.registerTableSource("transactions", new

[jira] [Commented] (FLINK-18238) RemoteChannelThroughputBenchmark deadlocks

2020-06-16 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18238?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17136511#comment-17136511 ] Piotr Nowojski commented on FLINK-18238: Copying the result of an online discussion: we decided

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

2020-06-16 Thread GitBox
flinkbot commented on pull request #12679: URL: https://github.com/apache/flink/pull/12679#issuecomment-644692386 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 edited a comment on pull request #12666: [FLINK-18313][doc] Hive dialect doc should mention that views created…

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

[GitHub] [flink] flinkbot commented on pull request #12678: [FLINK-18301][e2e] Backup kafka logs on failure

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

[GitHub] [flink] flinkbot edited a comment on pull request #12674: [FLINK-18311] Fix StreamingKafkaITCase on Kafka 2.4.1

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

[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_r440767961 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/DualKeyLinkedMap.java ## @@ -22,12 +22,16 @@ import

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

2020-06-16 Thread GitBox
aljoscha closed pull request #12667: URL: https://github.com/apache/flink/pull/12667 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] Myasuka opened a new 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 opened a new pull request #12681: URL: https://github.com/apache/flink/pull/12681 ## What is the purpose of the change This PR targets for release-1.11 branch. Emit `CancelCheckpointMarker` downstream on `checkpointState` in sync phase of checkpoint on task side to

[GitHub] [flink] dawidwys commented on a change in pull request #12649: [FLINK-18286] Implement type inference for GET/FLATTEN

2020-06-16 Thread GitBox
dawidwys commented on a change in pull request #12649: URL: https://github.com/apache/flink/pull/12649#discussion_r440794777 ## File path: flink-table/flink-table-planner-blink/src/test/java/org/apache/flink/table/planner/expressions/CompositeTypeAccessExpressionITCase.java

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

2020-06-16 Thread Rui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18320?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17136602#comment-17136602 ] Rui Li commented on FLINK-18320: {{minlog}}, {{reflectasm}} and {{objenesis}} are introduced by {{kryo}}

[jira] [Commented] (FLINK-18318) Flink ML

2020-06-16 Thread Dimitris Vogiatzidakis (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18318?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17136613#comment-17136613 ] Dimitris Vogiatzidakis commented on FLINK-18318: Oh, my bad then. thank you very much.

[jira] [Updated] (FLINK-18314) Fix wrong documentation in Kafka SQL Connector page

2020-06-16 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18314?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-18314: Summary: Fix wrong documentation in Kafka SQL Connector page (was: There are some problems in docs) >

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

2020-06-16 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17824?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17136624#comment-17136624 ] Roman Khachatryan commented on FLINK-17824: --- "200 records" is measured closer to sink. Source

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

2020-06-16 Thread GitBox
twalthr commented on a change in pull request #12577: URL: https://github.com/apache/flink/pull/12577#discussion_r440699062 ## File path: docs/try-flink/table_api.md ## @@ -462,14 +469,17 @@ public class SpendReport { tEnv.registerTableSource("transactions", new

[GitHub] [flink] wuchong merged pull request #12627: [FLINK-18083][hbase] Improve exception message of TIMESTAMP/TIME out of the HBase connector supported precision

2020-06-16 Thread GitBox
wuchong merged pull request #12627: URL: https://github.com/apache/flink/pull/12627 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] tillrohrmann closed pull request #9265: [FLINK-13477][core] Add `memory-overhead-ratio` conf for containers

2020-06-16 Thread GitBox
tillrohrmann closed pull request #9265: URL: https://github.com/apache/flink/pull/9265 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] tillrohrmann commented on pull request #9265: [FLINK-13477][core] Add `memory-overhead-ratio` conf for containers

2020-06-16 Thread GitBox
tillrohrmann commented on pull request #9265: URL: https://github.com/apache/flink/pull/9265#issuecomment-644645434 Thanks for creating this PR @BenoitHanotte. Sorry for the late response. In the meantime, the community has completed FLIP-49 and, hence, this change is no longer required.

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

2020-06-16 Thread GitBox
godfreyhe commented on a change in pull request #12577: URL: https://github.com/apache/flink/pull/12577#discussion_r440716919 ## File path: docs/try-flink/table_api.md ## @@ -462,14 +469,17 @@ public class SpendReport { tEnv.registerTableSource("transactions", new

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

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

[jira] [Assigned] (FLINK-12336) Add HTTPS support to InfluxDB reporter

2020-06-16 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12336?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-12336: - Assignee: Etienne Carriere > Add HTTPS support to InfluxDB reporter >

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

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

[GitHub] [flink] flinkbot edited a comment on pull request #11245: [FLINK-15794][Kubernetes] Generate the Kubernetes default image version

2020-06-16 Thread GitBox
flinkbot edited a comment on pull request #11245: URL: https://github.com/apache/flink/pull/11245#issuecomment-592002512 ## CI report: * f1d4f9163a2cd60daa02fe6b7af5a459cee9660c UNKNOWN * 3d51e2f87a199ae260c47832f68d3a36876904c4 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #11868: [FLINK-17258][tests] Enabling unaligned checkpoint in all tests by default

2020-06-16 Thread GitBox
flinkbot edited a comment on pull request #11868: URL: https://github.com/apache/flink/pull/11868#issuecomment-617994961 ## CI report: * c9a8597b0f40ac2600440a65c2c2488dd385ff4e UNKNOWN * 1ed80167a0655c9fb579e93cd94a49517eaa9b42 UNKNOWN *

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

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

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

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

[GitHub] [flink] flinkbot edited a comment on pull request #12668: [FLINK-18291][e2e] Introduce timeout into Streaming File Sink s3 test

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

[GitHub] [flink] flinkbot edited a comment on pull request #12655: [FLINK-18300][sql-client] SQL Client doesn't support ALTER VIEW

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

[GitHub] [flink] flinkbot edited a comment on pull request #12632: [FLINK-18134][FLINK-18135][docs] Add documentation for Debezium and Canal formats

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

[GitHub] [flink] flinkbot edited a comment on pull request #12674: [FLINK-18311] Fix StreamingKafkaITCase on Kafka 2.4.1

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

[jira] [Closed] (FLINK-18305) Add interval configuration too all reporter examples that support it

2020-06-16 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18305?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-18305. Resolution: Fixed master: 6220ceea1561e4ce62d2c66dcab42d271b610597 1.11:

[GitHub] [flink] zentol merged pull request #12659: [FLINK-18304][metrics] Document default reporter interval

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

[jira] [Closed] (FLINK-18304) Document default reporter interval

2020-06-16 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18304?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-18304. Resolution: Fixed master: 8c565dbef454e1c31cad674a1de2081f2d8a 1.11:

[GitHub] [flink] AHeise commented on a change in pull request #12575: [FLINK-18094][checkpointing] Unifies the creation of BarrierHandlers and CheckpointedInputGate.

2020-06-16 Thread GitBox
AHeise commented on a change in pull request #12575: URL: https://github.com/apache/flink/pull/12575#discussion_r440772079 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/CheckpointBarrierAligner.java ## @@ -46,14 +49,8 @@

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

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

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

2020-06-16 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18119?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-18119: --- Labels: pull-request-available (was: ) > Fix unlimitedly growing state for time range

[GitHub] [flink] ifndef-SleePy 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
ifndef-SleePy commented on a change in pull request #12670: URL: https://github.com/apache/flink/pull/12670#discussion_r440786956 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinator.java ## @@ -538,51 +542,61 @@ private void

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

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

[GitHub] [flink] flinkbot edited a comment 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
flinkbot edited a comment on pull request #12664: URL: https://github.com/apache/flink/pull/12664#issuecomment-644339378 ## CI report: * 800fe871cc016061a9550631ba0c8c851c0ce5fd Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12672: [hotfix][typo] fix typos in ProcTimeRangeBoundedPrecedingFunction & ProcTimeBoundedRangeOver

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

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

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

[GitHub] [flink] aljoscha commented on pull request #12674: [FLINK-18311] Fix StreamingKafkaITCase on Kafka 2.4.1

2020-06-16 Thread GitBox
aljoscha commented on pull request #12674: URL: https://github.com/apache/flink/pull/12674#issuecomment-644712001 I pushed another commit but I agree that we should merge this at some point.  This is an automated message

[GitHub] [flink] flinkbot edited a comment on pull request #12674: [FLINK-18311] Fix StreamingKafkaITCase on Kafka 2.4.1

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

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

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

[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_r440777286 ## File path: flink-formats/flink-json/src/test/java/org/apache/flink/formats/json/JsonRowDataSerDeSchemaTest.java ## @@ -383,73 +407,117 @@ private

[jira] [Updated] (FLINK-18314) There are some problems in docs

2020-06-16 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18314?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-18314: Fix Version/s: 1.11.0 > There are some problems in docs > --- > >

[GitHub] [flink] zhuzhurk merged pull request #12256: [FLINK-17018][runtime] Allocates slots in bulks for pipelined region scheduling

2020-06-16 Thread GitBox
zhuzhurk merged pull request #12256: URL: https://github.com/apache/flink/pull/12256 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] zhuzhurk commented on pull request #12256: [FLINK-17018][runtime] Allocates slots in bulks for pipelined region scheduling

2020-06-16 Thread GitBox
zhuzhurk commented on pull request #12256: URL: https://github.com/apache/flink/pull/12256#issuecomment-644640968 The failed case `StreamingKafkaITCase` is unrelated. The problem is FLINK-18311. Merging. This is an

[jira] [Closed] (FLINK-18083) Improve exception message of TIMESTAMP/TIME out of the HBase connector supported precision

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

[jira] [Closed] (FLINK-13477) Containerized TaskManager killed because of lack of memory overhead

2020-06-16 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13477?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-13477. - Resolution: Duplicate This ticket has been solved as part of FLIP-49. > Containerized

[GitHub] [flink] Myasuka commented on pull request #12650: [FLINK-18289][Checkpoint] Ensure notifyCheckpointAborted interface work in UDF operator

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

[GitHub] [flink] tillrohrmann closed pull request #7844: [FLINK-10932][ResourceManager] Initial flink-kubernetes module with e…

2020-06-16 Thread GitBox
tillrohrmann closed pull request #7844: URL: https://github.com/apache/flink/pull/7844 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] tillrohrmann commented on pull request #7844: [FLINK-10932][ResourceManager] Initial flink-kubernetes module with e…

2020-06-16 Thread GitBox
tillrohrmann commented on pull request #7844: URL: https://github.com/apache/flink/pull/7844#issuecomment-644646528 Closing this PR as it has been subsumed. This is an automated message from the Apache Git Service. To

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

2020-06-16 Thread GitBox
Myasuka removed a comment on pull request #12650: URL: https://github.com/apache/flink/pull/12650#issuecomment-644043335 @flinkbot run travis This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink] kl0u commented on pull request #11322: [FLINK-16376][yarn] Use consistent method to get Yarn application dir…

2020-06-16 Thread GitBox
kl0u commented on pull request #11322: URL: https://github.com/apache/flink/pull/11322#issuecomment-644665486 Really sorry for that @jiasheng55 . It was my bad, I just got carried away while working on the other issue and did not inform you about my work. Sorry and I hope this will not

[GitHub] [flink] flinkbot edited a comment on pull request #9978: [FLINK-14511][Deployment / YARN] Checking YARN queues with "root." prefix

2020-06-16 Thread GitBox
flinkbot edited a comment on pull request #9978: URL: https://github.com/apache/flink/pull/9978#issuecomment-545539829 ## CI report: * ee06b2a60f36f93effe035373fb681b297bfc7ad Travis: [SUCCESS](https://travis-ci.com/flink-ci/flink/builds/133235445) *

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

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

[GitHub] [flink] zentol opened a new pull request #12678: [FLINK-18301][e2e] Backup kafka logs on failure

2020-06-16 Thread GitBox
zentol opened a new pull request #12678: URL: https://github.com/apache/flink/pull/12678 Java e2e tests backup kafka logs on failure, similarly to what we do with the Flink logs. There is a fair amount of duplication with the Flink resource, and we may want to look into ways to

[jira] [Updated] (FLINK-18301) Backup Kafka logs on e2e failure

2020-06-16 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18301?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-18301: --- Labels: pull-request-available (was: ) > Backup Kafka logs on e2e failure >

[jira] [Updated] (FLINK-18325) SqlMapTypeNameSpec#unparse may throw NPE

2020-06-16 Thread Jiatao Tao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18325?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiatao Tao updated FLINK-18325: --- Description: SqlMapTypeNameSpec#unparse calls SqlDataTypeSpec#getNullable, and "getNullable" may

[jira] [Created] (FLINK-18325) SqlMapTypeNameSpec#unparse may throw NPE

2020-06-16 Thread Jiatao Tao (Jira)
Jiatao Tao created FLINK-18325: -- Summary: SqlMapTypeNameSpec#unparse may throw NPE Key: FLINK-18325 URL: https://issues.apache.org/jira/browse/FLINK-18325 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-18310) Failure while parsing reporter interval does not reliably revert back to default

2020-06-16 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18310?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-18310: --- Labels: pull-request-available (was: ) > Failure while parsing reporter interval does not

[jira] [Commented] (FLINK-18325) SqlMapTypeNameSpec#unparse may throw NPE

2020-06-16 Thread Jiatao Tao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18325?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17136544#comment-17136544 ] Jiatao Tao commented on FLINK-18325: Not only 

[GitHub] [flink] zentol opened a new pull request #12679: [FLINK-18310][metrics] Properly handle interval parsing errors

2020-06-16 Thread GitBox
zentol opened a new pull request #12679: URL: https://github.com/apache/flink/pull/12679 Changes the reporter interval parsing to use the `TimeUtils` instead, which should make it more consistent with other time-based options . This also makes the parsing of both components an atomic

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

2020-06-16 Thread GitBox
flinkbot commented on pull request #12680: URL: https://github.com/apache/flink/pull/12680#issuecomment-644702392 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] [Resolved] (FLINK-17800) RocksDB optimizeForPointLookup results in missing time windows

2020-06-16 Thread Yu Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17800?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Li resolved FLINK-17800. --- Fix Version/s: 1.12.0 Release Note: After FLINK-17800 by default we will set `setTotalOrderSeek` to

[GitHub] [flink] flinkbot 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
flinkbot commented on pull request #12681: URL: https://github.com/apache/flink/pull/12681#issuecomment-644716581 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-18318) Flink ML

2020-06-16 Thread Aljoscha Krettek (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18318?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-18318. Resolution: Not A Problem Hi [~dvogiatz], for questions about Flink the mailing lists are

[GitHub] [flink] rmetzger commented on pull request #12570: [FLINK-17976][doc] Synchronize Chinese native Kubernetes document

2020-06-16 Thread GitBox
rmetzger commented on pull request #12570: URL: https://github.com/apache/flink/pull/12570#issuecomment-644722983 @wangyang0918 Awesome, thanks a lot for opening this PR! I forgot to open a JIRA ticket for this :( Thanks for the review @klion26. Will merge it soon!

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

2020-06-16 Thread GitBox
carp84 opened a new pull request #12683: URL: https://github.com/apache/flink/pull/12683 ### What is the purpose of the change `OptionsFactory` and related classes have been marked as deprecated since release 1.10.0, and in this change we will remove them completely. ##

[GitHub] [flink] tillrohrmann commented on a change in pull request #11488: [FLINK-16717][k8s] Use headless service for rpc and blob port

2020-06-16 Thread GitBox
tillrohrmann commented on a change in pull request #11488: URL: https://github.com/apache/flink/pull/11488#discussion_r440827078 ## File path: flink-container/kubernetes/jobmanager-rest-service.yaml ## @@ -0,0 +1,34 @@

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

2020-06-16 Thread GitBox
flinkbot commented on pull request #12683: URL: https://github.com/apache/flink/pull/12683#issuecomment-644744910 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] [Created] (FLINK-18329) Runtime NOTICE issues

2020-06-16 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-18329: Summary: Runtime NOTICE issues Key: FLINK-18329 URL: https://issues.apache.org/jira/browse/FLINK-18329 Project: Flink Issue Type: Bug

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

2020-06-16 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18324?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-18324: Component/s: chinese-translation > Translate updated data type and function page into Chinese >

[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: * 9994520727018f9f9583ce9b91d221c69346f0d2 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12673: [FLINK-18242][state-backend-rocksdb] Separate RocksDBOptionsFactory from OptionsFactory

2020-06-16 Thread GitBox
flinkbot edited a comment on pull request #12673: URL: https://github.com/apache/flink/pull/12673#issuecomment-644604112 ## CI report: * 5b41145108afc366b94e820320cbbf19be9031e8 Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/171540258) *

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

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

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

2020-06-16 Thread GitBox
flinkbot commented on pull request #12685: URL: https://github.com/apache/flink/pull/12685#issuecomment-644770372 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 edited a comment on pull request #12313: [FLINK-17005][docs] Translate the CREATE TABLE ... LIKE syntax documentation to Chinese

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

[GitHub] [flink] flinkbot edited a comment on pull request #11245: [FLINK-15794][Kubernetes] Generate the Kubernetes default image version

2020-06-16 Thread GitBox
flinkbot edited a comment on pull request #11245: URL: https://github.com/apache/flink/pull/11245#issuecomment-592002512 ## CI report: * f1d4f9163a2cd60daa02fe6b7af5a459cee9660c UNKNOWN * 3477dcbc0268bbe2bce68f6d9661bbf350471169 Azure:

[jira] [Updated] (FLINK-18328) Blink planner NOTICE issues

2020-06-16 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18328?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-18328: - Priority: Blocker (was: Major) > Blink planner NOTICE issues >

[jira] [Updated] (FLINK-18331) Hive NOTICE issues

2020-06-16 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18331?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-18331: - Priority: Minor (was: Major) > Hive NOTICE issues > -- > >

[jira] [Updated] (FLINK-18329) Dist NOTICE issues

2020-06-16 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18329?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-18329: - Priority: Blocker (was: Major) > Dist NOTICE issues > -- > >

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

2020-06-16 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18330?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-18330: - Priority: Critical (was: Major) > Python NOTICE issues > > >

[jira] [Created] (FLINK-18333) UnsignedTypeConversionITCase failed caused by MariaDB4j "Asked to waitFor Program"

2020-06-16 Thread Jark Wu (Jira)
Jark Wu created FLINK-18333: --- Summary: UnsignedTypeConversionITCase failed caused by MariaDB4j "Asked to waitFor Program" Key: FLINK-18333 URL: https://issues.apache.org/jira/browse/FLINK-18333 Project:

[jira] [Updated] (FLINK-18333) UnsignedTypeConversionITCase failed caused by MariaDB4j "Asked to waitFor Program"

2020-06-16 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18333?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-18333: Affects Version/s: 1.12.0 > UnsignedTypeConversionITCase failed caused by MariaDB4j "Asked to waitFor >

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

2020-06-16 Thread GitBox
StephanEwen commented on a change in pull request #12683: URL: https://github.com/apache/flink/pull/12683#discussion_r440885165 ## File path: flink-python/pyflink/datastream/state_backend.py ## @@ -637,11 +637,11 @@ def set_options(self, options_factory_class_name):

[jira] [Commented] (FLINK-17192) java.lang.RuntimeException: Error obtaining the sorted input: Thread 'SortMerger Reading Thread' terminated due to an exception: The record exceeds the maximum size of

2020-06-16 Thread Nikola (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17192?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17136706#comment-17136706 ] Nikola commented on FLINK-17192: Hello, I have tested the option, but it didn't change much for us. It

[GitHub] [flink] flinkbot edited a comment on pull request #12313: [FLINK-17005][docs] Translate the CREATE TABLE ... LIKE syntax documentation to Chinese

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

[GitHub] [flink] sjwiesman closed pull request #12663: [hotfix][docs] Using a savepoint prevents data loss

2020-06-16 Thread GitBox
sjwiesman closed pull request #12663: URL: https://github.com/apache/flink/pull/12663 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] zentol commented on pull request #12678: [FLINK-18301][e2e] Backup kafka logs on failure

2020-06-16 Thread GitBox
zentol commented on pull request #12678: URL: https://github.com/apache/flink/pull/12678#issuecomment-644821996 @rmetzger You can see it in action [here](https://dev.azure.com/chesnay/flink/_build/results?buildId=344=results); i caused the test to fail on purpose.

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

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

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

2020-06-16 Thread appleyuchi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18288?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] appleyuchi updated FLINK-18288: --- Comment: was deleted (was:   some unproper part by [~vthinkxie]

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

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

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

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

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

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

<    1   2   3   4   5   6   7   8   >