[GitHub] [flink-docker] zentol opened a new pull request #14: [FLINK-17287][github] Disable merge commit button

zentol opened a new pull request #14: URL: https://github.com/apache/flink-docker/pull/14 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

[GitHub] [flink] wangyang0918 opened a new pull request #11839: [FLINK-17166][dist] Modify the log4j-console.properties to also output logs into the files for WebUI

wangyang0918 opened a new pull request #11839: URL: https://github.com/apache/flink/pull/11839 ## What is the purpose of the change Currently, we when use `flink-console.sh` to start jobmanager/taskmanager start-foreground, the logs could not be accessed via webui. Just because

[jira] [Commented] (FLINK-14295) Nightly flink-runtime failed with java 11

[ https://issues.apache.org/jira/browse/FLINK-14295?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17088407#comment-17088407 ] Till Rohrmann commented on FLINK-14295: --- [~chesnay] do you think that we should close this issue

[jira] [Commented] (FLINK-15170) WebFrontendITCase.testCancelYarn fails on travis

[ https://issues.apache.org/jira/browse/FLINK-15170?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17088405#comment-17088405 ] Till Rohrmann commented on FLINK-15170: --- Gentle reminder for [~lining]. >

[GitHub] [flink] wuchong commented on a change in pull request #11512: [FLINK-16589][table-planner-blink] Split code for AggsHandlerCodeGene…

wuchong commented on a change in pull request #11512: URL: https://github.com/apache/flink/pull/11512#discussion_r411966790 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/codegen/GenerateUtils.scala ## @@ -204,39 +204,47 @@

[GitHub] [flink] JingsongLi commented on a change in pull request #11651: [FLINK-16995][table-common] Add new data structure interfaces in table-common

JingsongLi commented on a change in pull request #11651: URL: https://github.com/apache/flink/pull/11651#discussion_r411966000 ## File path: flink-table/flink-table-common/src/main/java/org/apache/flink/table/data/DecimalData.java ## @@ -0,0 +1,260 @@ +/* + * Licensed to the

[GitHub] [flink] azagrebin commented on a change in pull request #11545: [FLINK-16742][runtime][dist] Extend and use BashJavaUtils to start JM JVM process and pass JVM memory args

azagrebin commented on a change in pull request #11545: URL: https://github.com/apache/flink/pull/11545#discussion_r411965414 ## File path: flink-dist/src/main/flink-bin/bin/config.sh ## @@ -633,16 +633,29 @@ runBashJavaUtilsCmd() { echo "$output" }

[GitHub] [flink] curcur commented on issue #11725: [FLINK-15670][API] Provide a Kafka Source/Sink pair as KafkaShuffle

curcur commented on issue #11725: URL: https://github.com/apache/flink/pull/11725#issuecomment-617021982 List some of the points here, just in case I forgot :-). We can chat details offline. 1. If I am understanding correctly (please ignore if I am not), the original idea is to

[jira] [Commented] (FLINK-17214) Docker entrypoint scripts may print credentials

[ https://issues.apache.org/jira/browse/FLINK-17214?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17088399#comment-17088399 ] Chesnay Schepler commented on FLINK-17214: -- Fix versions are a temporary crutch; can't find any

[jira] [Updated] (FLINK-17214) Docker entrypoint scripts may print credentials

[ https://issues.apache.org/jira/browse/FLINK-17214?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-17214: - Fix Version/s: docker-1.11.0 docker-1.10.X

[GitHub] [flink] flinkbot edited a comment on issue #11829: [FLINK-17021][table-planner-blink] Blink batch planner set GlobalDataExchangeMode

flinkbot edited a comment on issue #11829: URL: https://github.com/apache/flink/pull/11829#issuecomment-616561190 ## CI report: * c01e235c3048c97accdd33f7cfe2b03f6f60c8b3 Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/161169854) Azure:

[GitHub] [flink] flinkbot edited a comment on issue #11794: [FLINK-17126] [table-planner] Correct the execution behavior of BatchTableEnvironment

flinkbot edited a comment on issue #11794: URL: https://github.com/apache/flink/pull/11794#issuecomment-615243118 ## CI report: * 7c2cf88b04594bb73875fa8bb6ea5aa60d7a1bd9 Travis: [CANCELED](https://travis-ci.com/github/flink-ci/flink/builds/161169815) Azure:

[GitHub] [flink] flinkbot edited a comment on issue #11687: [FLINK-16536][network][checkpointing] Implement InputChannel state recovery for unaligned checkpoint

flinkbot edited a comment on issue #11687: URL: https://github.com/apache/flink/pull/11687#issuecomment-611445542 ## CI report: * 5bad018f00f85a7359345187a12d7938aa510d25 UNKNOWN * d51ce7f47381d99b843278cd701dcff223761a0b UNKNOWN * cba096ae3d8eba4a0d39c64659f76ad10a62be27

[GitHub] [flink] flinkbot edited a comment on issue #11351: [FLINK-16404][runtime] Avoid caching buffers for blocked input channels before barrier alignment

flinkbot edited a comment on issue #11351: URL: https://github.com/apache/flink/pull/11351#issuecomment-596351676 ## CI report: * 715889a35cfcc3aaf1b17f39dadaa86f755cc75d UNKNOWN * 548b22258f5e87fd53b45c7f4bb6de40bfd4e6d2 UNKNOWN * 9179aab74eeaf80ea30c0894f3e5a0171338baed

[GitHub] [flink] docete commented on a change in pull request #11727: [FLINK-17106][table] Support create and drop view in Flink SQL

docete commented on a change in pull request #11727: URL: https://github.com/apache/flink/pull/11727#discussion_r411959260 ## File path: flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/planner/catalog/CatalogTableITCase.scala ## @@ -946,6 +946,485

[GitHub] [flink] aljoscha commented on issue #11835: [hotfix][table sql planner/table sql legacy planner]fix icu license in NOTICE file.

aljoscha commented on issue #11835: URL: https://github.com/apache/flink/pull/11835#issuecomment-617017246 Looks good, could you fix the commit title to say `[hotfix][table sql planner/table sql legacy planner]fix icu license in NOTICE file`, then I can quickly merge it here on github

[jira] [Closed] (FLINK-16750) Kerberized YARN on Docker test fails due to stalling Hadoop cluster

[ https://issues.apache.org/jira/browse/FLINK-16750?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-16750. - Fix Version/s: (was: 1.11.0) Resolution: Later Closed after having merged some debug

[GitHub] [flink] aljoscha commented on issue #11820: [FLINK-17264][scripts] Fix broken taskmanager.sh by using -eq to compare num_lines

aljoscha commented on issue #11820: URL: https://github.com/apache/flink/pull/11820#issuecomment-617016247 @wangyang0918 I regularly run e2e tests on my mac when debugging issues, so it would be good to also fix those usages. Do you want to open an issue and cut a PR for that? Please ping

[GitHub] [flink] aljoscha commented on a change in pull request #10904: [FLINK-15669] [sql client] fix SQL client can't cancel flink job

aljoscha commented on a change in pull request #10904: URL: https://github.com/apache/flink/pull/10904#discussion_r411951194 ## File path: flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/local/result/CollectStreamResult.java ## @@ -86,18

[GitHub] [flink] godfreyhe commented on issue #11794: [FLINK-17126] [table-planner] Correct the execution behavior of BatchTableEnvironment

godfreyhe commented on issue #11794: URL: https://github.com/apache/flink/pull/11794#issuecomment-617012775 > Could you also add a release note in the JIRA issue? thanks for the suggestion @wuchong , I updated the PR and the release note.

[jira] [Updated] (FLINK-17126) Correct the execution behavior of BatchTableEnvironment

[ https://issues.apache.org/jira/browse/FLINK-17126?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-17126: --- Release Note: In previous versions, BatchTableEnvironment.execute() and

[jira] [Commented] (FLINK-17288) Speedup loading from savepoints into RocksDB by bulk load

[ https://issues.apache.org/jira/browse/FLINK-17288?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17088390#comment-17088390 ] Yun Tang commented on FLINK-17288: -- [~qinjunjerry] Thanks Jun for reporting this and offer one possible

[GitHub] [flink] flinkbot edited a comment on issue #11774: [FLINK-17020][runtime] Introduce GlobalDataExchangeMode for JobGraph generation

flinkbot edited a comment on issue #11774: URL: https://github.com/apache/flink/pull/11774#issuecomment-614576955 ## CI report: * 1f72fb850f69449f4ef886ec0cad8a0644bab93d Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/161169787) Azure:

[GitHub] [flink] zhijiangW commented on issue #11687: [FLINK-16536][network][checkpointing] Implement InputChannel state recovery for unaligned checkpoint

zhijiangW commented on issue #11687: URL: https://github.com/apache/flink/pull/11687#issuecomment-617007900 @pnowojski I have added all the necessary unit tests for covering the changes inside `StreamTask`, `SingleInputGate` and `RemoteInputChannel`. I guess this

[GitHub] [flink] flinkbot edited a comment on issue #11727: [FLINK-17106][table] Support create and drop view in Flink SQL

flinkbot edited a comment on issue #11727: URL: https://github.com/apache/flink/pull/11727#issuecomment-613273432 ## CI report: * fa5592cec0a6a5dcecc4f45c4bf72caf6e166eb4 UNKNOWN * a3901b149f603721be62fbb3d8bf46143d08c3d1 UNKNOWN * 25bb852676993fd14ebccf710b35a5f49bd56fd6

[GitHub] [flink] flinkbot edited a comment on issue #11768: [FLINK-16943][python] Support set the configuration option "pipeline.jars" in PyFlink.

flinkbot edited a comment on issue #11768: URL: https://github.com/apache/flink/pull/11768#issuecomment-614482552 ## CI report: * 375c382d79b0eb32388aa1b6b9c2f365a91344ee Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/160993435) Azure:

[GitHub] [flink] flinkbot edited a comment on issue #11687: [FLINK-16536][network][checkpointing] Implement InputChannel state recovery for unaligned checkpoint

flinkbot edited a comment on issue #11687: URL: https://github.com/apache/flink/pull/11687#issuecomment-611445542 ## CI report: * 5bad018f00f85a7359345187a12d7938aa510d25 UNKNOWN * d51ce7f47381d99b843278cd701dcff223761a0b UNKNOWN * cba096ae3d8eba4a0d39c64659f76ad10a62be27

[GitHub] [flink] flinkbot edited a comment on issue #11351: [FLINK-16404][runtime] Avoid caching buffers for blocked input channels before barrier alignment

flinkbot edited a comment on issue #11351: URL: https://github.com/apache/flink/pull/11351#issuecomment-596351676 ## CI report: * 715889a35cfcc3aaf1b17f39dadaa86f755cc75d UNKNOWN * 548b22258f5e87fd53b45c7f4bb6de40bfd4e6d2 UNKNOWN * 9179aab74eeaf80ea30c0894f3e5a0171338baed

[jira] [Updated] (FLINK-17288) Speedup loading from savepoints into RocksDB by bulk load

[ https://issues.apache.org/jira/browse/FLINK-17288?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Qin updated FLINK-17288: Description: When resource is a constraint,  loading a big savepoint into RocksDB may take some time.

[jira] [Created] (FLINK-17288) Speedup loading from savepoints into RocksDB by bulk load

Jun Qin created FLINK-17288: --- Summary: Speedup loading from savepoints into RocksDB by bulk load Key: FLINK-17288 URL: https://issues.apache.org/jira/browse/FLINK-17288 Project: Flink Issue Type:

[GitHub] [flink] wuchong commented on issue #11794: [FLINK-17126] [table-planner] Correct the execution behavior of BatchTableEnvironment

wuchong commented on issue #11794: URL: https://github.com/apache/flink/pull/11794#issuecomment-617005453 Could you also add a release note in the JIRA issue? This is an automated message from the Apache Git Service. To

[GitHub] [flink] wuchong commented on a change in pull request #11794: [FLINK-17126] [table-planner] Correct the execution behavior of BatchTableEnvironment

wuchong commented on a change in pull request #11794: URL: https://github.com/apache/flink/pull/11794#discussion_r411906063 ## File path: flink-java/src/main/java/org/apache/flink/api/java/utils/CollectionPipelineExecutor.java ## @@ -0,0 +1,92 @@ +/* + * Licensed to the

[jira] [Commented] (FLINK-16995) Add new data structure interfaces in table-common

[ https://issues.apache.org/jira/browse/FLINK-16995?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17088379#comment-17088379 ] Jark Wu commented on FLINK-16995: - Self-answering: I find a long time ago discussion about the

[jira] [Closed] (FLINK-16887) Refactor retraction rules to support inferring ChangelogMode

[ https://issues.apache.org/jira/browse/FLINK-16887?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-16887. --- > Refactor retraction rules to support inferring ChangelogMode >

[jira] [Closed] (FLINK-16995) Add new data structure interfaces in table-common

[ https://issues.apache.org/jira/browse/FLINK-16995?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-16995. --- > Add new data structure interfaces in table-common > - > >

[jira] [Assigned] (FLINK-11086) Add support for Hadoop 3

[ https://issues.apache.org/jira/browse/FLINK-11086?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-11086: -- Assignee: Robert Metzger > Add support for Hadoop 3 > > >

[jira] [Commented] (FLINK-16423) test_ha_per_job_cluster_datastream.sh gets stuck

[ https://issues.apache.org/jira/browse/FLINK-16423?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17088375#comment-17088375 ] Piotr Nowojski commented on FLINK-16423: Ops, I've missed that. I'm not sure if this should be a

[jira] [Closed] (FLINK-17197) ContinuousFileReaderOperator might shade the real exception when processing records

[ https://issues.apache.org/jira/browse/FLINK-17197?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-17197. -- Fix Version/s: 1.11.0 Resolution: Fixed Merged as 89cc0b9760..7269e6c41d >

[jira] [Created] (FLINK-17287) Disable merge commit button

Chesnay Schepler created FLINK-17287: Summary: Disable merge commit button Key: FLINK-17287 URL: https://issues.apache.org/jira/browse/FLINK-17287 Project: Flink Issue Type: Improvement

[GitHub] [flink] pnowojski commented on issue #11802: [FLINK-17197][runtime] switch ContinuousFileReaderOperator state to FAILED on error

pnowojski commented on issue #11802: URL: https://github.com/apache/flink/pull/11802#issuecomment-617000127 Travis is green, azure failure is unrelated and previous azure run was successful. This is an automated message

[jira] [Resolved] (FLINK-17266) WorkerResourceSpec is not serializable

[ https://issues.apache.org/jira/browse/FLINK-17266?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-17266. --- Resolution: Fixed Fixed via 036197e21f16769f937cde610bda0ddc502783e2 > WorkerResourceSpec

[GitHub] [flink] tillrohrmann commented on issue #11821: [FLINK-17266] Make WorkerResourceSpec serializable

tillrohrmann commented on issue #11821: URL: https://github.com/apache/flink/pull/11821#issuecomment-616999604 Thanks for the review @GJL. Merging this PR now. This is an automated message from the Apache Git Service. To

[GitHub] [flink] flinkbot edited a comment on issue #11838: [FLINK-16965] Convert Graphite reporter to plugin

flinkbot edited a comment on issue #11838: URL: https://github.com/apache/flink/pull/11838#issuecomment-616983944 ## CI report: * 9dd1c071e271de645564791bc9267551eb7021a2 Travis: [PENDING](https://travis-ci.com/github/flink-ci/flink/builds/161183108) Azure:

[GitHub] [flink] flinkbot edited a comment on issue #11823: [FLINK-16412][hive] Disallow embedded metastore in HiveCatalog produc…

flinkbot edited a comment on issue #11823: URL: https://github.com/apache/flink/pull/11823#issuecomment-616533916 ## CI report: * 9c2f9e65d3046ee911f0494ccf20dbcdc92f9ddf Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/161164708) Azure:

[GitHub] [flink] flinkbot edited a comment on issue #11785: [FLINK-17206][table] refactor function catalog to support delayed UDF initialization.

flinkbot edited a comment on issue #11785: URL: https://github.com/apache/flink/pull/11785#issuecomment-615087743 ## CI report: * bda5c47abf20ea3682c2b1d21188d1e08edd1d87 UNKNOWN * 7fee2a180eea4d0e37ff86f04d728b5b501a3679 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11794: [FLINK-17126] [table-planner] Correct the execution behavior of BatchTableEnvironment

flinkbot edited a comment on issue #11794: URL: https://github.com/apache/flink/pull/11794#issuecomment-615243118 ## CI report: * 7c2cf88b04594bb73875fa8bb6ea5aa60d7a1bd9 Travis: [CANCELED](https://travis-ci.com/github/flink-ci/flink/builds/161169815) Azure:

[GitHub] [flink] flinkbot edited a comment on issue #11768: [FLINK-16943][python] Support set the configuration option "pipeline.jars" in PyFlink.

flinkbot edited a comment on issue #11768: URL: https://github.com/apache/flink/pull/11768#issuecomment-614482552 ## CI report: * 375c382d79b0eb32388aa1b6b9c2f365a91344ee Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/160993435) Azure:

[GitHub] [flink] flinkbot edited a comment on issue #11727: [FLINK-17106][table] Support create and drop view in Flink SQL

flinkbot edited a comment on issue #11727: URL: https://github.com/apache/flink/pull/11727#issuecomment-613273432 ## CI report: * fa5592cec0a6a5dcecc4f45c4bf72caf6e166eb4 UNKNOWN * a3901b149f603721be62fbb3d8bf46143d08c3d1 UNKNOWN * 25bb852676993fd14ebccf710b35a5f49bd56fd6

[GitHub] [flink] flinkbot edited a comment on issue #11351: [FLINK-16404][runtime] Avoid caching buffers for blocked input channels before barrier alignment

flinkbot edited a comment on issue #11351: URL: https://github.com/apache/flink/pull/11351#issuecomment-596351676 ## CI report: * 715889a35cfcc3aaf1b17f39dadaa86f755cc75d UNKNOWN * 548b22258f5e87fd53b45c7f4bb6de40bfd4e6d2 UNKNOWN * 9179aab74eeaf80ea30c0894f3e5a0171338baed

[jira] [Commented] (FLINK-16638) Flink checkStateMappingCompleteness doesn't include UserDefinedOperatorIDs

[ https://issues.apache.org/jira/browse/FLINK-16638?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17088364#comment-17088364 ] Piotr Nowojski commented on FLINK-16638: Thanks for the update [~basharaj]. No problem. I have

[jira] [Resolved] (FLINK-17264) taskmanager.sh could not work on Mac

[ https://issues.apache.org/jira/browse/FLINK-17264?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-17264. --- Resolution: Fixed Fixed via 3ae1da0bed0f365057af8deed3055eba2853484a > taskmanager.sh

[jira] [Assigned] (FLINK-16638) Flink checkStateMappingCompleteness doesn't include UserDefinedOperatorIDs

[ https://issues.apache.org/jira/browse/FLINK-16638?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reassigned FLINK-16638: -- Assignee: (was: Bashar Abdul Jawad) > Flink checkStateMappingCompleteness

[GitHub] [flink] tillrohrmann commented on issue #11820: [FLINK-17264][scripts] Fix broken taskmanager.sh by using -eq to compare num_lines

tillrohrmann commented on issue #11820: URL: https://github.com/apache/flink/pull/11820#issuecomment-616996906 Merging this PR now. This is an automated message from the Apache Git Service. To respond to the message, please

[jira] [Reopened] (FLINK-13698) Rework threading model of CheckpointCoordinator

[ https://issues.apache.org/jira/browse/FLINK-13698?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reopened FLINK-13698: > Rework threading model of CheckpointCoordinator >

[GitHub] [flink] KurtYoung commented on a change in pull request #11727: [FLINK-17106][table] Support create and drop view in Flink SQL

KurtYoung commented on a change in pull request #11727: URL: https://github.com/apache/flink/pull/11727#discussion_r411923611 ## File path: flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/planner/catalog/CatalogTableITCase.scala ## @@ -946,6

[jira] [Commented] (FLINK-16636) TableEnvironmentITCase is crashing on Travis

[ https://issues.apache.org/jira/browse/FLINK-16636?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17088353#comment-17088353 ] Kurt Young commented on FLINK-16636: If there is indeed some memory leak, we should be able to

[jira] [Commented] (FLINK-16636) TableEnvironmentITCase is crashing on Travis

[ https://issues.apache.org/jira/browse/FLINK-16636?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17088349#comment-17088349 ] Kurt Young commented on FLINK-16636: That's the weird thing. We've configured the JVM with 2GM heap

[jira] [Closed] (FLINK-15078) Report Python version exceptions in time

[ https://issues.apache.org/jira/browse/FLINK-15078?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-15078. --- Resolution: Invalid Close this issue as it should doesn't exist any more after bump Beam to 2.19.0

[GitHub] [flink] WeiZhong94 commented on issue #11768: [FLINK-16943][python] Support set the configuration option "pipeline.jars" in PyFlink.

WeiZhong94 commented on issue #11768: URL: https://github.com/apache/flink/pull/11768#issuecomment-616985701 @dianfu Thanks for your review. I have addressed your comments in the latest commit. This is an automated message

[GitHub] [flink] flinkbot edited a comment on issue #11687: [FLINK-16536][network][checkpointing] Implement InputChannel state recovery for unaligned checkpoint

flinkbot edited a comment on issue #11687: URL: https://github.com/apache/flink/pull/11687#issuecomment-611445542 ## CI report: * 5bad018f00f85a7359345187a12d7938aa510d25 UNKNOWN * d51ce7f47381d99b843278cd701dcff223761a0b UNKNOWN * cba096ae3d8eba4a0d39c64659f76ad10a62be27

[GitHub] [flink] flinkbot edited a comment on issue #11794: [FLINK-17126] [table-planner] Correct the execution behavior of BatchTableEnvironment

flinkbot edited a comment on issue #11794: URL: https://github.com/apache/flink/pull/11794#issuecomment-615243118 ## CI report: * 7c2cf88b04594bb73875fa8bb6ea5aa60d7a1bd9 Travis: [CANCELED](https://travis-ci.com/github/flink-ci/flink/builds/161169815) Azure:

[GitHub] [flink] flinkbot commented on issue #11838: [FLINK-16965] Convert Graphite reporter to plugin

flinkbot commented on issue #11838: URL: https://github.com/apache/flink/pull/11838#issuecomment-616983944 ## CI report: * 9dd1c071e271de645564791bc9267551eb7021a2 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run

[jira] [Closed] (FLINK-14269) The close method does not work for Python UserDefinedFunction

[ https://issues.apache.org/jira/browse/FLINK-14269?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-14269. --- Resolution: Invalid Closed as it should have been resolved in FLINK-15875 after bump Beam to 2.19.0 > The

[jira] [Comment Edited] (FLINK-17274) Maven: Premature end of Content-Length delimited message body

[ https://issues.apache.org/jira/browse/FLINK-17274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17088340#comment-17088340 ] Robert Metzger edited comment on FLINK-17274 at 4/21/20, 6:30 AM: --

[jira] [Commented] (FLINK-17274) Maven: Premature end of Content-Length delimited message body

[ https://issues.apache.org/jira/browse/FLINK-17274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17088340#comment-17088340 ] Robert Metzger commented on FLINK-17274:

[GitHub] [flink] flinkbot commented on issue #11838: [FLINK-16965] Convert Graphite reporter to plugin

flinkbot commented on issue #11838: URL: https://github.com/apache/flink/pull/11838#issuecomment-616980218 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 progress

[jira] [Updated] (FLINK-16965) Convert Graphite reporter to plugin

[ https://issues.apache.org/jira/browse/FLINK-16965?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-16965: --- Labels: pull-request-available (was: ) > Convert Graphite reporter to plugin >

[GitHub] [flink] KarmaGYZ opened a new pull request #11838: [FLINK-16965] Convert Graphite reporter to plugin

KarmaGYZ opened a new pull request #11838: URL: https://github.com/apache/flink/pull/11838 ## What is the purpose of the change Convert Graphite reporter to plugin. ## Brief change log Convert Graphite reporter to plugin. ## Verifying this change

[GitHub] [flink] docete commented on a change in pull request #11727: [FLINK-17106][table] Support create and drop view in Flink SQL

docete commented on a change in pull request #11727: URL: https://github.com/apache/flink/pull/11727#discussion_r411902392 ## File path: flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/planner/catalog/CatalogTableITCase.scala ## @@ -946,6 +946,485

[GitHub] [flink] docete commented on a change in pull request #11727: [FLINK-17106][table] Support create and drop view in Flink SQL

docete commented on a change in pull request #11727: URL: https://github.com/apache/flink/pull/11727#discussion_r411902392 ## File path: flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/planner/catalog/CatalogTableITCase.scala ## @@ -946,6 +946,485

[jira] [Commented] (FLINK-17279) Use gradle build scans for training exercises

[ https://issues.apache.org/jira/browse/FLINK-17279?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17088333#comment-17088333 ] Robert Metzger commented on FLINK-17279: I renamed it to "Documentation / Training / Exercises"

[GitHub] [flink] flinkbot edited a comment on issue #11837: [FLINK-16160][table-planner-blink] Fix proctime()/rowtime() doesn't w…

flinkbot edited a comment on issue #11837: URL: https://github.com/apache/flink/pull/11837#issuecomment-616956896 ## CI report: * afa79d577eecd36ad2843f50380c07a33bedaa6c Travis: [PENDING](https://travis-ci.com/github/flink-ci/flink/builds/161174787) Azure:

[GitHub] [flink] flinkbot edited a comment on issue #11794: [FLINK-17126] [table-planner] Correct the execution behavior of BatchTableEnvironment

flinkbot edited a comment on issue #11794: URL: https://github.com/apache/flink/pull/11794#issuecomment-615243118 ## CI report: * 5bcc43b771b5c05d027268b52cf81121db562a7a Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/160968796) Azure:

[GitHub] [flink] flinkbot edited a comment on issue #11823: [FLINK-16412][hive] Disallow embedded metastore in HiveCatalog produc…

flinkbot edited a comment on issue #11823: URL: https://github.com/apache/flink/pull/11823#issuecomment-616533916 ## CI report: * 9c2f9e65d3046ee911f0494ccf20dbcdc92f9ddf Travis: [PENDING](https://travis-ci.com/github/flink-ci/flink/builds/161164708) Azure:

[GitHub] [flink] flinkbot edited a comment on issue #11687: [FLINK-16536][network][checkpointing] Implement InputChannel state recovery for unaligned checkpoint

flinkbot edited a comment on issue #11687: URL: https://github.com/apache/flink/pull/11687#issuecomment-611445542 ## CI report: * 5bad018f00f85a7359345187a12d7938aa510d25 UNKNOWN * d51ce7f47381d99b843278cd701dcff223761a0b UNKNOWN * cba096ae3d8eba4a0d39c64659f76ad10a62be27

[jira] [Commented] (FLINK-16636) TableEnvironmentITCase is crashing on Travis

[ https://issues.apache.org/jira/browse/FLINK-16636?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17088330#comment-17088330 ] Robert Metzger commented on FLINK-16636: About the memory usage, what's the total memory size

[jira] [Comment Edited] (FLINK-16636) TableEnvironmentITCase is crashing on Travis

[ https://issues.apache.org/jira/browse/FLINK-16636?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17088330#comment-17088330 ] Robert Metzger edited comment on FLINK-16636 at 4/21/20, 6:17 AM: -- bq.

[GitHub] [flink] tillrohrmann commented on issue #11820: [FLINK-17264][scripts] Fix broken taskmanager.sh by using -eq to compare num_lines

tillrohrmann commented on issue #11820: URL: https://github.com/apache/flink/pull/11820#issuecomment-616975630 Thanks for creating this PR @wangyang0918. LGTM. +1 for merging this PR. This is an automated message from the

[GitHub] [flink] flinkbot edited a comment on issue #10228: [FLINK-14816] Add thread dump feature for taskmanager

flinkbot edited a comment on issue #10228: URL: https://github.com/apache/flink/pull/10228#issuecomment-554599522 ## CI report: * 45a8d72869eee0e3eafdc007280725e8043f2521 UNKNOWN * c0a3c6e519d1793383794c797064039fa66b90d2 UNKNOWN * 737ce43f7dea5d3e6429a4d75c597630506deb1f

[jira] [Assigned] (FLINK-17264) taskmanager.sh could not work on Mac

[ https://issues.apache.org/jira/browse/FLINK-17264?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-17264: - Assignee: Yang Wang > taskmanager.sh could not work on Mac >

[jira] [Commented] (FLINK-17273) Fix not calling ResourceManager#closeTaskManagerConnection in KubernetesResourceManager in case of registered TaskExecutor failure

[ https://issues.apache.org/jira/browse/FLINK-17273?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17088324#comment-17088324 ] Yang Wang commented on FLINK-17273: --- [~felixzheng] Do you mean when a TaskManager pod crashed

[jira] [Commented] (FLINK-16947) ArtifactResolutionException: Could not transfer artifact. Entry [...] has not been leased from this pool

[ https://issues.apache.org/jira/browse/FLINK-16947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17088325#comment-17088325 ] Robert Metzger commented on FLINK-16947: Mh, this is a case (against the google mirror) from a

[jira] [Comment Edited] (FLINK-16636) TableEnvironmentITCase is crashing on Travis

[ https://issues.apache.org/jira/browse/FLINK-16636?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17088308#comment-17088308 ] Caizhi Weng edited comment on FLINK-16636 at 4/21/20, 6:06 AM: --- Hi

[jira] [Commented] (FLINK-16636) TableEnvironmentITCase is crashing on Travis

[ https://issues.apache.org/jira/browse/FLINK-16636?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17088322#comment-17088322 ] Robert Metzger commented on FLINK-16636: Sadly, there was no heapdump created. Afaik, by

[jira] [Comment Edited] (FLINK-16160) Schema#proctime and Schema#rowtime don't work in TableEnvironment#connect code path

[ https://issues.apache.org/jira/browse/FLINK-16160?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17088275#comment-17088275 ] Zhenghua Gao edited comment on FLINK-16160 at 4/21/20, 6:04 AM: The root

[GitHub] [flink] flinkbot edited a comment on issue #11836: [FLINK-17188][python] Use pip instead of conda to install flake8 and sphinx

flinkbot edited a comment on issue #11836: URL: https://github.com/apache/flink/pull/11836#issuecomment-616922166 ## CI report: * 6df508f9c18e15b1a4c15a691c5e71500d32262d Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/161162947) Azure:

[GitHub] [flink] flinkbot edited a comment on issue #11797: [FLINK-17169][table-blink] Refactor BaseRow to use RowKind instead of byte header

flinkbot edited a comment on issue #11797: URL: https://github.com/apache/flink/pull/11797#issuecomment-615294694 ## CI report: * 85f40e3041783b1dbda1eb3b812f23e77936f7b3 UNKNOWN * 5b8d39bef382e260dbec301105c32dde88153245 Travis:

<    1   2   3   4   5   6