[GitHub] [flink] rmetzger commented on a change in pull request #11741: [FLINK-17121][build system][python] Adds Pipeline of Building Wheel Packages in Azure CI

2020-04-21 Thread GitBox
rmetzger commented on a change in pull request #11741: URL: https://github.com/apache/flink/pull/11741#discussion_r412031423 ## File path: tools/azure-pipelines/build-python-wheels.yml ## @@ -0,0 +1,82 @@ +# Licensed to the Apache Software Foundation (ASF) under one or more +#

[jira] [Assigned] (FLINK-17249) Bump universal Kafka connector to Kafka 2.2.2

2020-04-21 Thread Aljoscha Krettek (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17249?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-17249: Assignee: Ismael Juma > Bump universal Kafka connector to Kafka 2.2.2 >

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

2020-04-21 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17287?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17088485#comment-17088485 ] Nico Kruber commented on FLINK-17287: - - merged to flink-training {{master}} via

[jira] [Updated] (FLINK-15448) Log host informations for TaskManager failures.

2020-04-21 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15448?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo updated FLINK-15448: --- Parent: FLINK-15679 Issue Type: Sub-task (was: Improvement) > Log host informations for

[jira] [Closed] (FLINK-17229) Add a flink-sql-client-sdk module

2020-04-21 Thread Aljoscha Krettek (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17229?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-17229. Resolution: Not A Problem Closing this for now, I think the Table API is the SQL client

[GitHub] [flink-training] alpinegizmo commented on issue #2: [FLINK-17276][checkstyle] add definitions from Flink and enforce them

2020-04-21 Thread GitBox
alpinegizmo commented on issue #2: URL: https://github.com/apache/flink-training/pull/2#issuecomment-617067583 What a nuisance. Sorry there was so much to clean up. :( +1 This is an automated message from the Apache Git

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

2020-04-21 Thread GitBox
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 #11837: [FLINK-16160][table-planner-blink] Fix proctime()/rowtime() doesn't w…

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

[jira] [Created] (FLINK-17301) TaskManagerRunnerStartupTest.testStartupWhenNetworkStackFailsToInitialize fails on OSX

2020-04-21 Thread Robert Metzger (Jira)
Robert Metzger created FLINK-17301: -- Summary: TaskManagerRunnerStartupTest.testStartupWhenNetworkStackFailsToInitialize fails on OSX Key: FLINK-17301 URL: https://issues.apache.org/jira/browse/FLINK-17301

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

2020-04-21 Thread GitBox
flinkbot edited a comment on issue #11794: URL: https://github.com/apache/flink/pull/11794#issuecomment-615243118 ## CI report: * 3b3a405dfd58840c1410adff725f98153d883116 Travis: [CANCELED](https://travis-ci.com/github/flink-ci/flink/builds/161194625) Azure:

[GitHub] [flink] flinkbot edited a comment on issue #11741: [FLINK-17121][build system][python] Adds Pipeline of Building Wheel Packages in Azure CI

2020-04-21 Thread GitBox
flinkbot edited a comment on issue #11741: URL: https://github.com/apache/flink/pull/11741#issuecomment-613485875 ## CI report: * 80994a1940edb055fbb58b05f5d4394fb54a3042 Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/160226692) Azure:

[jira] [Resolved] (FLINK-16874) Respect the dynamic options when calculating memory options in taskmanager.sh

2020-04-21 Thread Andrey Zagrebin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16874?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin resolved FLINK-16874. - Resolution: Fixed merged into 1.10 by db8b0dd25371413169a5b53d7d4eec2748d2cef9 >

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

2020-04-21 Thread GitBox
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-training] alpinegizmo commented on issue #1: [FLINK-17275] port core training exercises, descriptions, solutions and tests

2020-04-21 Thread GitBox
alpinegizmo commented on issue #1: URL: https://github.com/apache/flink-training/pull/1#issuecomment-617066188 +1 Looks good to me. Thanks, @NicoK, for taking this on! This is an automated message from the Apache Git

[jira] [Issue Comment Deleted] (FLINK-17289) Translate tutorials/etl.md to chinese

2020-04-21 Thread Li Ying (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17289?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Li Ying updated FLINK-17289: Comment: was deleted (was: Hi David, is there a link to the original English Page? I would like to

[jira] [Updated] (FLINK-17299) Add checkpoint with remote channel benchmark

2020-04-21 Thread Zhijiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17299?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang updated FLINK-17299: - Summary: Add checkpoint with remote channel benchmark (was: Add remote channel throughput benchmark)

[GitHub] [flink] azagrebin commented on issue #11578: [RELEASE-1.10][FLINK-16874] Respect the dynamic options when calculating memory opt…

2020-04-21 Thread GitBox
azagrebin commented on issue #11578: URL: https://github.com/apache/flink/pull/11578#issuecomment-617065834 merged into 1.10 by db8b0dd25371413169a5b53d7d4eec2748d2cef9 This is an automated message from the Apache Git

[jira] [Assigned] (FLINK-17299) Add remote channel throughput benchmark

2020-04-21 Thread Zhijiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17299?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang reassigned FLINK-17299: Assignee: Yingjie Cao > Add remote channel throughput benchmark >

[jira] [Commented] (FLINK-17289) Translate tutorials/etl.md to chinese

2020-04-21 Thread Li Ying (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17088477#comment-17088477 ] Li Ying commented on FLINK-17289: - Hi David, is there a link to the original English Page? I would like

[jira] [Comment Edited] (FLINK-17289) Translate tutorials/etl.md to chinese

2020-04-21 Thread Li Ying (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17088477#comment-17088477 ] Li Ying edited comment on FLINK-17289 at 4/21/20, 9:28 AM: --- Hi David, is there

[jira] [Created] (FLINK-17299) Add remote channel throughput benchmark

2020-04-21 Thread Yingjie Cao (Jira)
Yingjie Cao created FLINK-17299: --- Summary: Add remote channel throughput benchmark Key: FLINK-17299 URL: https://issues.apache.org/jira/browse/FLINK-17299 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-17300) Log the lineage information between ExecutionAttemptID and AllocationID

2020-04-21 Thread Yangze Guo (Jira)
Yangze Guo created FLINK-17300: -- Summary: Log the lineage information between ExecutionAttemptID and AllocationID Key: FLINK-17300 URL: https://issues.apache.org/jira/browse/FLINK-17300 Project: Flink

[jira] [Updated] (FLINK-17298) Log the lineage information between SlotRequestID and AllocationID

2020-04-21 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17298?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo updated FLINK-17298: --- Summary: Log the lineage information between SlotRequestID and AllocationID (was: Log the lineage

[jira] [Created] (FLINK-17298) Log the lineage information between ExecutionAttemptID and SlotRequestID

2020-04-21 Thread Yangze Guo (Jira)
Yangze Guo created FLINK-17298: -- Summary: Log the lineage information between ExecutionAttemptID and SlotRequestID Key: FLINK-17298 URL: https://issues.apache.org/jira/browse/FLINK-17298 Project: Flink

[jira] [Created] (FLINK-17297) Log the lineage information between ExecutionAttemptID and SlotRequestID

2020-04-21 Thread Yangze Guo (Jira)
Yangze Guo created FLINK-17297: -- Summary: Log the lineage information between ExecutionAttemptID and SlotRequestID Key: FLINK-17297 URL: https://issues.apache.org/jira/browse/FLINK-17297 Project: Flink

[jira] [Created] (FLINK-17296) Support "create table if not exists" in JDBC table sink.

2020-04-21 Thread Lijie Wang (Jira)
Lijie Wang created FLINK-17296: -- Summary: Support "create table if not exists" in JDBC table sink. Key: FLINK-17296 URL: https://issues.apache.org/jira/browse/FLINK-17296 Project: Flink Issue

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

2020-04-21 Thread GitBox
leonardBang commented on issue #11835: URL: https://github.com/apache/flink/pull/11835#issuecomment-617063039 update the commit title. This is an automated message from the Apache Git Service. To respond to the message,

[jira] [Created] (FLINK-17295) Refactor the ExecutionAttemptID to consist of ExecutionVertexID and attemptNumber

2020-04-21 Thread Yangze Guo (Jira)
Yangze Guo created FLINK-17295: -- Summary: Refactor the ExecutionAttemptID to consist of ExecutionVertexID and attemptNumber Key: FLINK-17295 URL: https://issues.apache.org/jira/browse/FLINK-17295

[GitHub] [flink] kl0u commented on issue #11811: [FLINK-16658][FLINK-16660] Introduce the ApplicationDispatcherBootstrap and wire it to StandaloneJobEntrypoint

2020-04-21 Thread GitBox
kl0u commented on issue #11811: URL: https://github.com/apache/flink/pull/11811#issuecomment-617061635 Merged. Thanks @aljoscha ! This is an automated message from the Apache Git Service. To respond to the message, please

[jira] [Closed] (FLINK-16660) Introduce the ApplicationDispatcherBootstrap

2020-04-21 Thread Kostas Kloudas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16660?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-16660. -- Resolution: Implemented Merged on master with 3ff4cee8e69e8f1772458b63138021593d6acf36 >

[jira] [Closed] (FLINK-16658) Wire the EmbeddedExecutor to the StandaloneJobClusterEntryPoint.

2020-04-21 Thread Kostas Kloudas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16658?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-16658. -- Resolution: Implemented Merged on master with 74fc5a7cc8132eec2a247f6894a81a63a1e6128a >

[GitHub] [flink] zentol commented on a change in pull request #11836: [FLINK-17188][python] Use pip instead of conda to install flake8 and sphinx

2020-04-21 Thread GitBox
zentol commented on a change in pull request #11836: URL: https://github.com/apache/flink/pull/11836#discussion_r412019520 ## File path: flink-python/dev/lint-python.sh ## @@ -244,6 +244,7 @@ function install_py_env() { # Install tox. # In some situations,you need to run the

[jira] [Closed] (FLINK-16656) Introduce DispatcherBootstrap to initialise Dispatcher

2020-04-21 Thread Kostas Kloudas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16656?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-16656. -- Resolution: Implemented Merged on master with c89df66d1506a20588d704699f88a10571b66f43 >

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

2020-04-21 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16636?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17088467#comment-17088467 ] Caizhi Weng edited comment on FLINK-16636 at 4/21/20, 9:19 AM: --- I've tried

[jira] [Updated] (FLINK-13639) Consider refactoring of IntermediateResultPartitionID to consist of IntermediateDataSetID and partitionIndex

2020-04-21 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13639?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo updated FLINK-13639: --- Parent: FLINK-15679 Issue Type: Sub-task (was: Improvement) > Consider refactoring of

[GitHub] [flink-training] NicoK commented on a change in pull request #1: [FLINK-17275] port core training exercises, descriptions, solutions and tests

2020-04-21 Thread GitBox
NicoK commented on a change in pull request #1: URL: https://github.com/apache/flink-training/pull/1#discussion_r412019275 ## File path: hourly-tips/src/main/scala/org/apache/flink/training/exercises/hourlytips/scala/HourlyTipsExercise.scala ## @@ -0,0 +1,67 @@ +/* + *

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

2020-04-21 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16636?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17088467#comment-17088467 ] Caizhi Weng edited comment on FLINK-16636 at 4/21/20, 9:18 AM: --- I've tried

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

2020-04-21 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16636?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17088467#comment-17088467 ] Caizhi Weng commented on FLINK-16636: - I've tried to run the IT cases on my local machine and read

[GitHub] [flink-training] NicoK commented on a change in pull request #1: [FLINK-17275] port core training exercises, descriptions, solutions and tests

2020-04-21 Thread GitBox
NicoK commented on a change in pull request #1: URL: https://github.com/apache/flink-training/pull/1#discussion_r412015506 ## File path: README.md ## @@ -1,3 +1,257 @@ + + # Flink Training Exercises Exercises that go along with the training content in the documentation. +

[GitHub] [flink] HuangXingBo commented on issue #11741: [FLINK-17121][build system][python] Adds Pipeline of Building Wheel Packages in Azure CI

2020-04-21 Thread GitBox
HuangXingBo commented on issue #11741: URL: https://github.com/apache/flink/pull/11741#issuecomment-617056936 Thanks a lot for @rmetzger review, I have addressed the comments at the latest commit. This is an automated

[jira] [Updated] (FLINK-17294) Using "DataSource" instead of "DriverManager" to get connection in JDBC connector

2020-04-21 Thread Lijie Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17294?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lijie Wang updated FLINK-17294: --- Description: I noticed that JDBC connector using DriverManager to get connection, but DataSource

[jira] [Created] (FLINK-17294) Using "DataSource" instead of "DriverManager" to get connection in JDBC connector

2020-04-21 Thread Lijie Wang (Jira)
Lijie Wang created FLINK-17294: -- Summary: Using "DataSource" instead of "DriverManager" to get connection in JDBC connector Key: FLINK-17294 URL: https://issues.apache.org/jira/browse/FLINK-17294

[jira] [Created] (FLINK-17293) Port training exercises data sets to a generator

2020-04-21 Thread Nico Kruber (Jira)
Nico Kruber created FLINK-17293: --- Summary: Port training exercises data sets to a generator Key: FLINK-17293 URL: https://issues.apache.org/jira/browse/FLINK-17293 Project: Flink Issue Type:

[GitHub] [flink] HuangXingBo commented on a change in pull request #11741: [FLINK-17121][build system][python] Adds Pipeline of Building Wheel Packages in Azure CI

2020-04-21 Thread GitBox
HuangXingBo commented on a change in pull request #11741: URL: https://github.com/apache/flink/pull/11741#discussion_r412012804 ## File path: tools/azure-pipelines/build-python-wheels.yml ## @@ -0,0 +1,82 @@ +# Licensed to the Apache Software Foundation (ASF) under one or more

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

2020-04-21 Thread GitBox
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 #11836: [FLINK-17188][python] Use pip instead of conda to install flake8 and sphinx

2020-04-21 Thread GitBox
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 #11839: [FLINK-17166][dist] Modify the log4j-console.properties to also output logs into the files for WebUI

2020-04-21 Thread GitBox
flinkbot edited a comment on issue #11839: URL: https://github.com/apache/flink/pull/11839#issuecomment-617042256 ## CI report: * c369785530aac75cb69c6445340f0684590921c1 Travis: [PENDING](https://travis-ci.com/github/flink-ci/flink/builds/161201647) Azure:

[GitHub] [flink] flinkbot edited a comment on issue #11840: [FLINK-17287][github] Disable merge commit button

2020-04-21 Thread GitBox
flinkbot edited a comment on issue #11840: URL: https://github.com/apache/flink/pull/11840#issuecomment-617042387 ## CI report: * 6018de54ddb2967466a4ce9bfcf3867ef7180ef1 Travis: [PENDING](https://travis-ci.com/github/flink-ci/flink/builds/161201677) Azure:

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

2020-04-21 Thread GitBox
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

2020-04-21 Thread GitBox
flinkbot edited a comment on issue #11794: URL: https://github.com/apache/flink/pull/11794#issuecomment-615243118 ## CI report: * 3cf24e9c3c30eb5bbfe5cd927202c5f0d54efc65 Travis: [CANCELED](https://travis-ci.com/github/flink-ci/flink/builds/161180735) Azure:

[GitHub] [flink] flinkbot edited a comment on issue #11578: [RELEASE-1.10][FLINK-16874] Respect the dynamic options when calculating memory opt…

2020-04-21 Thread GitBox
flinkbot edited a comment on issue #11578: URL: https://github.com/apache/flink/pull/11578#issuecomment-606518441 ## CI report: * ae19b37903d8116e3457103ea4dac98fb8a85a23 Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/161174685) Bot commands

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

2020-04-21 Thread GitBox
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] flinkbot edited a comment on issue #10904: [FLINK-15669] [sql client] fix SQL client can't cancel flink job

2020-04-21 Thread GitBox
flinkbot edited a comment on issue #10904: URL: https://github.com/apache/flink/pull/10904#issuecomment-576004529 ## CI report: * 6d89ef84c8f0673d93a1048350b302e7d24d7484 Travis: [SUCCESS](https://travis-ci.com/flink-ci/flink/builds/149745708) Azure:

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

2020-04-21 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16423?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17088453#comment-17088453 ] Till Rohrmann commented on FLINK-16423: --- Duplicates should not have a fix version since the

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

2020-04-21 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16423?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-16423: -- Fix Version/s: (was: 1.11.0) > test_ha_per_job_cluster_datastream.sh gets stuck >

[jira] [Commented] (FLINK-16198) FileUtilsTest fails on Mac OS

2020-04-21 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16198?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17088449#comment-17088449 ] Robert Metzger commented on FLINK-16198: I ran into this issue as well today. It's a bit

[jira] [Updated] (FLINK-16198) FileUtilsTest fails on Mac OS

2020-04-21 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16198?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-16198: --- Fix Version/s: 1.11.0 > FileUtilsTest fails on Mac OS > - > >

[GitHub] [flink] KarmaGYZ commented on issue #11578: [RELEASE-1.10][FLINK-16874] Respect the dynamic options when calculating memory opt…

2020-04-21 Thread GitBox
KarmaGYZ commented on issue #11578: URL: https://github.com/apache/flink/pull/11578#issuecomment-617046982 Hi, @azagrebin . I've fixed that issue. `BashJavaUtilsITCase#testConfigOverwrittenByDynamicOpts` passes now. This is

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

2020-04-21 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14295?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-14295. - Resolution: Cannot Reproduce Please re-open this issue in case another incident occurs. >

[jira] [Created] (FLINK-17292) Translate Fault Tolerance tutorial to Chinese

2020-04-21 Thread David Anderson (Jira)
David Anderson created FLINK-17292: -- Summary: Translate Fault Tolerance tutorial to Chinese Key: FLINK-17292 URL: https://issues.apache.org/jira/browse/FLINK-17292 Project: Flink Issue

[jira] [Commented] (FLINK-15641) Support to start init container

2020-04-21 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15641?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17088439#comment-17088439 ] Yang Wang commented on FLINK-15641: --- [~ouyangwuli] Thanks a lot for making this ticket moving forward.

[jira] [Created] (FLINK-17291) Translate tutorial on event-driven applications to chinese

2020-04-21 Thread David Anderson (Jira)
David Anderson created FLINK-17291: -- Summary: Translate tutorial on event-driven applications to chinese Key: FLINK-17291 URL: https://issues.apache.org/jira/browse/FLINK-17291 Project: Flink

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

2020-04-21 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17273?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17088438#comment-17088438 ] Till Rohrmann commented on FLINK-17273: --- {{ResourceManager#closeTaskManagerConnection}} cleans up

[jira] [Created] (FLINK-17290) Translate Streaming Analytics tutorial to chinese

2020-04-21 Thread David Anderson (Jira)
David Anderson created FLINK-17290: -- Summary: Translate Streaming Analytics tutorial to chinese Key: FLINK-17290 URL: https://issues.apache.org/jira/browse/FLINK-17290 Project: Flink Issue

[jira] [Created] (FLINK-17289) Translate tutorials/etl.md to chinese

2020-04-21 Thread David Anderson (Jira)
David Anderson created FLINK-17289: -- Summary: Translate tutorials/etl.md to chinese Key: FLINK-17289 URL: https://issues.apache.org/jira/browse/FLINK-17289 Project: Flink Issue Type:

[jira] [Commented] (FLINK-17248) Make the thread nums of io executor of ClusterEntrypoint and MiniCluster configurable

2020-04-21 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17248?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17088436#comment-17088436 ] Till Rohrmann commented on FLINK-17248: --- Hi [~yunta]. This sounds good. Instead of {{-1}} you

[GitHub] [flink] flinkbot commented on issue #11839: [FLINK-17166][dist] Modify the log4j-console.properties to also output logs into the files for WebUI

2020-04-21 Thread GitBox
flinkbot commented on issue #11839: URL: https://github.com/apache/flink/pull/11839#issuecomment-617042256 ## CI report: * c369785530aac75cb69c6445340f0684590921c1 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run

[jira] [Commented] (FLINK-17075) Add task status reconciliation between TM and JM

2020-04-21 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17088435#comment-17088435 ] Till Rohrmann commented on FLINK-17075: --- Hi [~vdhar], yes I think this fix can be backported. The

[GitHub] [flink] flinkbot commented on issue #11840: [FLINK-17287][github] Disable merge commit button

2020-04-21 Thread GitBox
flinkbot commented on issue #11840: URL: https://github.com/apache/flink/pull/11840#issuecomment-617042387 ## CI report: * 6018de54ddb2967466a4ce9bfcf3867ef7180ef1 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run

[jira] [Updated] (FLINK-17075) Add task status reconciliation between TM and JM

2020-04-21 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17075?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-17075: -- Fix Version/s: 1.10.1 > Add task status reconciliation between TM and JM >

[GitHub] [flink] flinkbot edited a comment on issue #11787: [FLINK-16746] Deprecate legacy heap memory option for JM and expose the new ones in docs

2020-04-21 Thread GitBox
flinkbot edited a comment on issue #11787: URL: https://github.com/apache/flink/pull/11787#issuecomment-615109268 ## CI report: * b4b0faccea4cb2569f1d75cde3c11095d0aab5d4 Travis: [FAILURE](https://travis-ci.com/github/flink-ci/flink/builds/161068765) Azure:

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

2020-04-21 Thread GitBox
flinkbot edited a comment on issue #11727: URL: https://github.com/apache/flink/pull/11727#issuecomment-613273432 ## CI report: * fa5592cec0a6a5dcecc4f45c4bf72caf6e166eb4 UNKNOWN * a3901b149f603721be62fbb3d8bf46143d08c3d1 UNKNOWN * 95c227eee727485d3785b7366c3f9efd80242fa2

[GitHub] [flink] flinkbot edited a comment on issue #10904: [FLINK-15669] [sql client] fix SQL client can't cancel flink job

2020-04-21 Thread GitBox
flinkbot edited a comment on issue #10904: URL: https://github.com/apache/flink/pull/10904#issuecomment-576004529 ## CI report: * 6d89ef84c8f0673d93a1048350b302e7d24d7484 Travis: [SUCCESS](https://travis-ci.com/flink-ci/flink/builds/149745708) Azure:

[GitHub] [flink] godfreyhe commented on issue #10904: [FLINK-15669] [sql client] fix SQL client can't cancel flink job

2020-04-21 Thread GitBox
godfreyhe commented on issue #10904: URL: https://github.com/apache/flink/pull/10904#issuecomment-617038452 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use

[GitHub] [flink] aljoscha commented on issue #10904: [FLINK-15669] [sql client] fix SQL client can't cancel flink job

2020-04-21 Thread GitBox
aljoscha commented on issue #10904: URL: https://github.com/apache/flink/pull/10904#issuecomment-617038848  I'll wait until Azure/Travis is green and then merge. This is an automated message from the Apache Git Service. To

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

2020-04-21 Thread GitBox
docete commented on issue #11727: URL: https://github.com/apache/flink/pull/11727#issuecomment-617038609 @KurtYoung pls take another look if you have time. This is an automated message from the Apache Git Service. To

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

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

[jira] [Assigned] (FLINK-16922) Decimal.toUnscaledBytes should be consistent with BigDecimla.unscaledValue.toByteArray

2020-04-21 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16922?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-16922: --- Assignee: Jark Wu > Decimal.toUnscaledBytes should be consistent with >

[GitHub] [flink] wangyang0918 commented on issue #11839: [FLINK-17166][dist] Modify the log4j-console.properties to also output logs into the files for WebUI

2020-04-21 Thread GitBox
wangyang0918 commented on issue #11839: URL: https://github.com/apache/flink/pull/11839#issuecomment-617034550 cc @tillrohrmann @azagrebin Could you please have a look at your convenience? This is an automated message from

[GitHub] [flink] zentol commented on a change in pull request #11838: [FLINK-16965] Convert Graphite reporter to plugin

2020-04-21 Thread GitBox
zentol commented on a change in pull request #11838: URL: https://github.com/apache/flink/pull/11838#discussion_r411982069 ## File path: flink-metrics/flink-metrics-graphite/src/main/java/org/apache/flink/metrics/graphite/GraphiteReporter.java ## @@ -32,7 +32,7 @@ * This

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

2020-04-21 Thread GitBox
curcur edited a comment 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

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

2020-04-21 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14295?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17088425#comment-17088425 ] Chesnay Schepler commented on FLINK-14295: -- [~trohrmann] fine with me > Nightly flink-runtime

[GitHub] [flink] godfreyhe commented on issue #10904: [FLINK-15669] [sql client] fix SQL client can't cancel flink job

2020-04-21 Thread GitBox
godfreyhe commented on issue #10904: URL: https://github.com/apache/flink/pull/10904#issuecomment-617033658 @aljoscha Thanks for your suggestion, I have updated the pr based on comments. This is an automated message from

[jira] [Resolved] (FLINK-16572) CheckPubSubEmulatorTest is flaky on Azure

2020-04-21 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16572?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-16572. Resolution: Fixed [~Xeli] Thanks a lot for providing a fix for the test instability. I

[jira] [Commented] (FLINK-17271) Translate new DataStream API tutorial

2020-04-21 Thread Bai Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17271?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17088422#comment-17088422 ] Bai Xu commented on FLINK-17271: Hi, [~alpinegizmo].l'm willing to handle this.:) > Translate new

[GitHub] [flink] flinkbot commented on issue #11840: [FLINK-17287][github] Disable merge commit button

2020-04-21 Thread GitBox
flinkbot commented on issue #11840: URL: https://github.com/apache/flink/pull/11840#issuecomment-617032176 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-17130) Web UI: Enable listing JM Logs and displaying Logs by Filename

2020-04-21 Thread Gary Yao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17130?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-17130: - Fix Version/s: 1.11.0 > Web UI: Enable listing JM Logs and displaying Logs by Filename >

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

2020-04-21 Thread GitBox
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 #11774: [FLINK-17020][runtime] Introduce GlobalDataExchangeMode for JobGraph generation

2020-04-21 Thread GitBox
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] flinkbot edited a comment on issue #11794: [FLINK-17126] [table-planner] Correct the execution behavior of BatchTableEnvironment

2020-04-21 Thread GitBox
flinkbot edited a comment on issue #11794: URL: https://github.com/apache/flink/pull/11794#issuecomment-615243118 ## CI report: * 3cf24e9c3c30eb5bbfe5cd927202c5f0d54efc65 Travis: [CANCELED](https://travis-ci.com/github/flink-ci/flink/builds/161180735) Azure:

[GitHub] [flink] flinkbot edited a comment on issue #11787: [FLINK-16746] Deprecate legacy heap memory option for JM and expose the new ones in docs

2020-04-21 Thread GitBox
flinkbot edited a comment on issue #11787: URL: https://github.com/apache/flink/pull/11787#issuecomment-615109268 ## CI report: * b4b0faccea4cb2569f1d75cde3c11095d0aab5d4 Travis: [FAILURE](https://travis-ci.com/github/flink-ci/flink/builds/161068765) Azure:

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

2020-04-21 Thread GitBox
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] zentol opened a new pull request #11840: [FLINK-17287][github] Disable merge commit button

2020-04-21 Thread GitBox
zentol opened a new pull request #11840: URL: https://github.com/apache/flink/pull/11840 (I know it is already disabled, this is just for consistency and to introduce the asf.yaml concept to all repos) This is an automated

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

2020-04-21 Thread GitBox
zentol opened a new pull request #3: URL: https://github.com/apache/flink-statefun-docker/pull/3 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

[GitHub] [flink] flinkbot commented on issue #11839: [FLINK-17166][dist] Modify the log4j-console.properties to also output logs into the files for WebUI

2020-04-21 Thread GitBox
flinkbot commented on issue #11839: URL: https://github.com/apache/flink/pull/11839#issuecomment-617028171 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

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

2020-04-21 Thread GitBox
curcur edited a comment 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

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

2020-04-21 Thread GitBox
zentol opened a new pull request #6: URL: https://github.com/apache/flink-training/pull/6 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-statefun] zentol opened a new pull request #101: [FLINK-17287][github] Disable merge commit button

2020-04-21 Thread GitBox
zentol opened a new pull request #101: URL: https://github.com/apache/flink-statefun/pull/101 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

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

2020-04-21 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17287?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-17287: --- Labels: pull-request-available (was: ) > Disable merge commit button >

[jira] [Updated] (FLINK-17166) Modify the log4j-console.properties to also output logs into the files for WebUI

2020-04-21 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17166?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-17166: --- Labels: pull-request-available (was: ) > Modify the log4j-console.properties to also

<    1   2   3   4   5   6   >