[GitHub] [flink] JingsongLi commented on issue #10039: [FLINK-14262][table] Support referencing function with fully/partially qualified names in SQL

JingsongLi commented on issue #10039: [FLINK-14262][table] Support referencing function with fully/partially qualified names in SQL URL: https://github.com/apache/flink/pull/10039#issuecomment-548645119 > @JingsongLi Thanks a lot for the PR! > > I wonder if exposing catalog manager

[GitHub] [flink] sunjincheng121 commented on issue #9874: [FLINK-14240][table] Merge table config parameters(TableConfig#getConfiguration) into global job parameters(ExecutionConfig#getGlobalJobParame

sunjincheng121 commented on issue #9874: [FLINK-14240][table] Merge table config parameters(TableConfig#getConfiguration) into global job parameters(ExecutionConfig#getGlobalJobParameters) when running with the legacy planner. URL:

[GitHub] [flink] danny0405 commented on a change in pull request #9994: [FLINK-14322][table-api] Add watermark information in TableSchema

danny0405 commented on a change in pull request #9994: [FLINK-14322][table-api] Add watermark information in TableSchema URL: https://github.com/apache/flink/pull/9994#discussion_r341427986 ## File path:

[jira] [Commented] (FLINK-14585) flink connector for sink to apache/incubator-druid

[ https://issues.apache.org/jira/browse/FLINK-14585?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16964544#comment-16964544 ] hailong wang commented on FLINK-14585: -- +1 from my side. Around me, there are many flink to druid

[jira] [Created] (FLINK-14590) Unify the working directory of Java process and Python process when submitting python jobs via "flink run -py"

Wei Zhong created FLINK-14590: - Summary: Unify the working directory of Java process and Python process when submitting python jobs via "flink run -py" Key: FLINK-14590 URL:

[GitHub] [flink] lirui-apache commented on a change in pull request #10062: [FLINK-14588][hive] Support Hive version 1.0.0 and 1.0.1

lirui-apache commented on a change in pull request #10062: [FLINK-14588][hive] Support Hive version 1.0.0 and 1.0.1 URL: https://github.com/apache/flink/pull/10062#discussion_r341432718 ## File path:

[GitHub] [flink] xuefuz commented on a change in pull request #10054: [FLINK-14221][table] support drop temp system functions and temp catalog functions

xuefuz commented on a change in pull request #10054: [FLINK-14221][table] support drop temp system functions and temp catalog functions URL: https://github.com/apache/flink/pull/10054#discussion_r341399463 ## File path:

[GitHub] [flink] KurtYoung commented on a change in pull request #9994: [FLINK-14322][table-api] Add watermark information in TableSchema

KurtYoung commented on a change in pull request #9994: [FLINK-14322][table-api] Add watermark information in TableSchema URL: https://github.com/apache/flink/pull/9994#discussion_r341434266 ## File path:

[GitHub] [flink] lirui-apache commented on a change in pull request #10062: [FLINK-14588][hive] Support Hive version 1.0.0 and 1.0.1

lirui-apache commented on a change in pull request #10062: [FLINK-14588][hive] Support Hive version 1.0.0 and 1.0.1 URL: https://github.com/apache/flink/pull/10062#discussion_r341433876 ## File path:

[GitHub] [flink] TisonKun commented on issue #9972: [FLINK-14496][client] Exclude detach flag from ClusterClient

TisonKun commented on issue #9972: [FLINK-14496][client] Exclude detach flag from ClusterClient URL: https://github.com/apache/flink/pull/9972#issuecomment-548636537 Thanks for your review @kl0u ! Integrate comments, squash commits and rebase on master. Merging once travis gives green.

[GitHub] [flink] docete commented on a change in pull request #10035: [FLINK-14080][table-planner-blink] Introduce DateTime as internal representation of TIMESTAMP_WITHOUT_TIME_ZONE

docete commented on a change in pull request #10035: [FLINK-14080][table-planner-blink] Introduce DateTime as internal representation of TIMESTAMP_WITHOUT_TIME_ZONE URL: https://github.com/apache/flink/pull/10035#discussion_r341428358 ## File path:

[jira] [Commented] (FLINK-13111) FlinkKinesisConsumer fails with endpoint and region used together

[ https://issues.apache.org/jira/browse/FLINK-13111?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16964439#comment-16964439 ] Akshay Kanfade commented on FLINK-13111: Thank you [~rmetzger] ! I have provided minor feedback

[GitHub] [flink] flinkbot edited a comment on issue #9972: [FLINK-14496][client] Exclude detach flag from ClusterClient

flinkbot edited a comment on issue #9972: [FLINK-14496][client] Exclude detach flag from ClusterClient URL: https://github.com/apache/flink/pull/9972#issuecomment-545092005 ## CI report: * 355939385e2951dd0da0e3fe1da8feb7dbc27f61 : FAILURE

[GitHub] [flink] TisonKun opened a new pull request #10056: [FLINK-14565][metric] Shut down SystemResourcesCounter on Metric closed to prevent thread leak

TisonKun opened a new pull request #10056: [FLINK-14565][metric] Shut down SystemResourcesCounter on Metric closed to prevent thread leak URL: https://github.com/apache/flink/pull/10056 ## What is the purpose of the change Solve potentially thread leak described in

[jira] [Updated] (FLINK-14565) Shutdown SystemResourcesCounter on (JM|TM)MetricGroup closed

[ https://issues.apache.org/jira/browse/FLINK-14565?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14565: --- Labels: pull-request-available (was: ) > Shutdown SystemResourcesCounter on

[GitHub] [flink] wsry commented on issue #9993: [FLINK-14498][runtime]Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool.

wsry commented on issue #9993: [FLINK-14498][runtime]Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool. URL: https://github.com/apache/flink/pull/9993#issuecomment-548232682 Many thanks to @zhijiangW and @pnowojski for the review. I have updated the PR.

[GitHub] [flink] flinkbot edited a comment on issue #9993: [FLINK-14498][runtime]Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool.

flinkbot edited a comment on issue #9993: [FLINK-14498][runtime]Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool. URL: https://github.com/apache/flink/pull/9993#issuecomment-546219804 ## CI report: * f47a9f60dff6710ce5a7d5fe341a94d0fffb2d6d :

[GitHub] [flink] wsry commented on a change in pull request #9993: [FLINK-14498][runtime]Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool.

wsry commented on a change in pull request #9993: [FLINK-14498][runtime]Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool. URL: https://github.com/apache/flink/pull/9993#discussion_r340973400 ## File path:

[GitHub] [flink] KurtYoung commented on a change in pull request #10035: [FLINK-14080][table-planner-blink] Introduce Timestamp as internal representation of TIMESTAMP_WITHOUT_TIME_ZONE

KurtYoung commented on a change in pull request #10035: [FLINK-14080][table-planner-blink] Introduce Timestamp as internal representation of TIMESTAMP_WITHOUT_TIME_ZONE URL: https://github.com/apache/flink/pull/10035#discussion_r340976335 ## File path:

[GitHub] [flink] zhijiangW commented on a change in pull request #10029: [FLINK-14553][runtime] Respect non-blocking output in StreamTask#processInput

zhijiangW commented on a change in pull request #10029: [FLINK-14553][runtime] Respect non-blocking output in StreamTask#processInput URL: https://github.com/apache/flink/pull/10029#discussion_r340978662 ## File path:

[GitHub] [flink] wsry commented on a change in pull request #9993: [FLINK-14498][runtime]Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool.

wsry commented on a change in pull request #9993: [FLINK-14498][runtime]Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool. URL: https://github.com/apache/flink/pull/9993#discussion_r340971659 ## File path:

[GitHub] [flink] flinkbot commented on issue #10056: [FLINK-14565][metric] Shut down SystemResourcesCounter on Metric closed to prevent thread leak

flinkbot commented on issue #10056: [FLINK-14565][metric] Shut down SystemResourcesCounter on Metric closed to prevent thread leak URL: https://github.com/apache/flink/pull/10056#issuecomment-548229030 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I

[GitHub] [flink] docete commented on a change in pull request #10035: [FLINK-14080][table-planner-blink] Introduce Timestamp as internal representation of TIMESTAMP_WITHOUT_TIME_ZONE

docete commented on a change in pull request #10035: [FLINK-14080][table-planner-blink] Introduce Timestamp as internal representation of TIMESTAMP_WITHOUT_TIME_ZONE URL: https://github.com/apache/flink/pull/10035#discussion_r340973836 ## File path:

[GitHub] [flink] docete commented on a change in pull request #10035: [FLINK-14080][table-planner-blink] Introduce Timestamp as internal representation of TIMESTAMP_WITHOUT_TIME_ZONE

docete commented on a change in pull request #10035: [FLINK-14080][table-planner-blink] Introduce Timestamp as internal representation of TIMESTAMP_WITHOUT_TIME_ZONE URL: https://github.com/apache/flink/pull/10035#discussion_r340973836 ## File path:

[GitHub] [flink] flinkbot commented on issue #10056: [FLINK-14565][metric] Shut down SystemResourcesCounter on Metric closed to prevent thread leak

flinkbot commented on issue #10056: [FLINK-14565][metric] Shut down SystemResourcesCounter on Metric closed to prevent thread leak URL: https://github.com/apache/flink/pull/10056#issuecomment-548232338 ## CI report: * caa585061e20672b3ca16298101dbd49230854e8 : UNKNOWN

[GitHub] [flink] KurtYoung commented on a change in pull request #10035: [FLINK-14080][table-planner-blink] Introduce Timestamp as internal representation of TIMESTAMP_WITHOUT_TIME_ZONE

KurtYoung commented on a change in pull request #10035: [FLINK-14080][table-planner-blink] Introduce Timestamp as internal representation of TIMESTAMP_WITHOUT_TIME_ZONE URL: https://github.com/apache/flink/pull/10035#discussion_r340977059 ## File path:

[GitHub] [flink] JingsongLi edited a comment on issue #10035: [FLINK-14080][table-planner-blink] Introduce Timestamp as internal representation of TIMESTAMP_WITHOUT_TIME_ZONE

JingsongLi edited a comment on issue #10035: [FLINK-14080][table-planner-blink] Introduce Timestamp as internal representation of TIMESTAMP_WITHOUT_TIME_ZONE URL: https://github.com/apache/flink/pull/10035#issuecomment-548235482 > adding these methods long getEpochMilliSecond(int idx), int

[GitHub] [flink] JingsongLi commented on issue #10035: [FLINK-14080][table-planner-blink] Introduce Timestamp as internal representation of TIMESTAMP_WITHOUT_TIME_ZONE

JingsongLi commented on issue #10035: [FLINK-14080][table-planner-blink] Introduce Timestamp as internal representation of TIMESTAMP_WITHOUT_TIME_ZONE URL: https://github.com/apache/flink/pull/10035#issuecomment-548235482 > adding these methods long getEpochMilliSecond(int idx), int

[jira] [Commented] (FLINK-14556) Correct the package of cloud pickle

[ https://issues.apache.org/jira/browse/FLINK-14556?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16963701#comment-16963701 ] Hequn Cheng commented on FLINK-14556: - Fix in 1.10.0 via 6c6ada5b36577490fde74fc8d34b784a6e0dc25a >

[jira] [Closed] (FLINK-14556) Correct the package of cloud pickle

[ https://issues.apache.org/jira/browse/FLINK-14556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-14556. --- Resolution: Fixed > Correct the package of cloud pickle > --- > >

[GitHub] [flink] flinkbot edited a comment on issue #10056: [FLINK-14565][metric] Shut down SystemResourcesCounter on Metric closed to prevent thread leak

flinkbot edited a comment on issue #10056: [FLINK-14565][metric] Shut down SystemResourcesCounter on Metric closed to prevent thread leak URL: https://github.com/apache/flink/pull/10056#issuecomment-548232338 ## CI report: * caa585061e20672b3ca16298101dbd49230854e8 : PENDING

[GitHub] [flink] JingsongLi commented on a change in pull request #10035: [FLINK-14080][table-planner-blink] Introduce Timestamp as internal representation of TIMESTAMP_WITHOUT_TIME_ZONE

JingsongLi commented on a change in pull request #10035: [FLINK-14080][table-planner-blink] Introduce Timestamp as internal representation of TIMESTAMP_WITHOUT_TIME_ZONE URL: https://github.com/apache/flink/pull/10035#discussion_r340974658 ## File path:

[GitHub] [flink] zhijiangW commented on a change in pull request #10029: [FLINK-14553][runtime] Respect non-blocking output in StreamTask#processInput

zhijiangW commented on a change in pull request #10029: [FLINK-14553][runtime] Respect non-blocking output in StreamTask#processInput URL: https://github.com/apache/flink/pull/10029#discussion_r340980280 ## File path:

[GitHub] [flink] zhijiangW commented on a change in pull request #10029: [FLINK-14553][runtime] Respect non-blocking output in StreamTask#processInput

zhijiangW commented on a change in pull request #10029: [FLINK-14553][runtime] Respect non-blocking output in StreamTask#processInput URL: https://github.com/apache/flink/pull/10029#discussion_r340980280 ## File path:

[GitHub] [flink] hequn8128 closed pull request #10046: [FLINK-14556][python] Correct the package of cloudpickle

hequn8128 closed pull request #10046: [FLINK-14556][python] Correct the package of cloudpickle URL: https://github.com/apache/flink/pull/10046 This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink] flinkbot edited a comment on issue #9974: [FLINK-14501][FLINK-14502] Decouple ClusterDescriptor/ClusterSpecification from CommandLine

flinkbot edited a comment on issue #9974: [FLINK-14501][FLINK-14502] Decouple ClusterDescriptor/ClusterSpecification from CommandLine URL: https://github.com/apache/flink/pull/9974#issuecomment-545348099 ## CI report: * 07d3f11426dbdcc4fd961641da0a573914926aca : SUCCESS

[GitHub] [flink] wangyang0918 commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes.

wangyang0918 commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes. URL: https://github.com/apache/flink/pull/9984#discussion_r341077087 ## File path:

[GitHub] [flink] wangyang0918 commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes.

wangyang0918 commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes. URL: https://github.com/apache/flink/pull/9984#discussion_r341077763 ## File path:

[GitHub] [flink] AHeise commented on a change in pull request #10029: [FLINK-14553][runtime] Respect non-blocking output in StreamTask#processInput

AHeise commented on a change in pull request #10029: [FLINK-14553][runtime] Respect non-blocking output in StreamTask#processInput URL: https://github.com/apache/flink/pull/10029#discussion_r341077614 ## File path:

[jira] [Commented] (FLINK-14565) Shutdown SystemResourcesCounter on (JM|TM)MetricGroup closed

[ https://issues.apache.org/jira/browse/FLINK-14565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16963884#comment-16963884 ] Zili Chen commented on FLINK-14565: --- Thanks for your insights. I agree that we don't manage this

[jira] [Comment Edited] (FLINK-14565) Shutdown SystemResourcesCounter on (JM|TM)MetricGroup closed

[ https://issues.apache.org/jira/browse/FLINK-14565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16963884#comment-16963884 ] Zili Chen edited comment on FLINK-14565 at 10/31/19 11:14 AM: -- Thanks for

[GitHub] [flink] flinkbot edited a comment on issue #9993: [FLINK-14498][runtime]Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool.

flinkbot edited a comment on issue #9993: [FLINK-14498][runtime]Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool. URL: https://github.com/apache/flink/pull/9993#issuecomment-546219804 ## CI report: * f47a9f60dff6710ce5a7d5fe341a94d0fffb2d6d :

[GitHub] [flink] flinkbot edited a comment on issue #10003: [BP-1.9][FLINK-14074][mesos] Forward configuration to Mesos TaskExecutor

flinkbot edited a comment on issue #10003: [BP-1.9][FLINK-14074][mesos] Forward configuration to Mesos TaskExecutor URL: https://github.com/apache/flink/pull/10003#issuecomment-546599805 ## CI report: * f51cd353402817c2a22946c857fe80cf6954fda3 : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #10002: [FLINK-14074][mesos] Forward configuration to Mesos TaskExecutor

flinkbot edited a comment on issue #10002: [FLINK-14074][mesos] Forward configuration to Mesos TaskExecutor URL: https://github.com/apache/flink/pull/10002#issuecomment-546597933 ## CI report: * 4c13fd02d0f6f98e18ddb04bd11581e0c378a7ca : UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on issue #10037: [FLINK-14561] Don't write FLINK_PLUGINS_DIR env variable to Configuration

flinkbot edited a comment on issue #10037: [FLINK-14561] Don't write FLINK_PLUGINS_DIR env variable to Configuration URL: https://github.com/apache/flink/pull/10037#issuecomment-547497114 ## CI report: * d162b69fa12ca127b422d68e79e222415347c24d : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #10060: [FLINK-14546] [flink-json] Support map type in flink-json

flinkbot edited a comment on issue #10060: [FLINK-14546] [flink-json] Support map type in flink-json URL: https://github.com/apache/flink/pull/10060#issuecomment-548313242 ## CI report: * c68dc12d24be4ef19efc1ef42246e6018c4f6e8d : PENDING

[GitHub] [flink] yanghua commented on issue #10058: [FLINK-12527] Remove GLOBAL_VERSION_UPDATER in ExecutionGraph

yanghua commented on issue #10058: [FLINK-12527] Remove GLOBAL_VERSION_UPDATER in ExecutionGraph URL: https://github.com/apache/flink/pull/10058#issuecomment-548326015 cc @GJL This is an automated message from the Apache

[GitHub] [flink] zhijiangW commented on a change in pull request #10029: [FLINK-14553][runtime] Respect non-blocking output in StreamTask#processInput

zhijiangW commented on a change in pull request #10029: [FLINK-14553][runtime] Respect non-blocking output in StreamTask#processInput URL: https://github.com/apache/flink/pull/10029#discussion_r341085791 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #9928: [FLINK-12122] Add support for spreading slots out across all TaskExecutors

flinkbot edited a comment on issue #9928: [FLINK-12122] Add support for spreading slots out across all TaskExecutors URL: https://github.com/apache/flink/pull/9928#issuecomment-543204040 ## CI report: * 1f0eed38301790afdbbd981d2a9853fa240e10df : FAILURE

[jira] [Comment Edited] (FLINK-13702) BaseMapSerializerTest.testDuplicate fails on Travis

[ https://issues.apache.org/jira/browse/FLINK-13702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16963894#comment-16963894 ] Jark Wu edited comment on FLINK-13702 at 10/31/19 11:30 AM: I thought about

[jira] [Commented] (FLINK-13702) BaseMapSerializerTest.testDuplicate fails on Travis

[ https://issues.apache.org/jira/browse/FLINK-13702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16963894#comment-16963894 ] Jark Wu commented on FLINK-13702: - I thought about call {{duplicate}} too, but calling {{duplicate}} for

[jira] [Updated] (FLINK-14581) Support to run Python UDF jobs in a YARN cluster

[ https://issues.apache.org/jira/browse/FLINK-14581?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14581: --- Labels: pull-request-available (was: ) > Support to run Python UDF jobs in a YARN cluster

[GitHub] [flink] pnowojski commented on a change in pull request #9993: [FLINK-14498][runtime]Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool.

pnowojski commented on a change in pull request #9993: [FLINK-14498][runtime]Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool. URL: https://github.com/apache/flink/pull/9993#discussion_r341081009 ## File path:

[GitHub] [flink] WeiZhong94 opened a new pull request #10061: [FLINK-14581][python] Let python UDF execution no longer rely on the flink directory structure to support running python UDFs on yarn.

WeiZhong94 opened a new pull request #10061: [FLINK-14581][python] Let python UDF execution no longer rely on the flink directory structure to support running python UDFs on yarn. URL: https://github.com/apache/flink/pull/10061 ## What is the purpose of the change *This pull

[GitHub] [flink] flinkbot commented on issue #10061: [FLINK-14581][python] Let python UDF execution no longer rely on the flink directory structure to support running python UDFs on yarn.

flinkbot commented on issue #10061: [FLINK-14581][python] Let python UDF execution no longer rely on the flink directory structure to support running python UDFs on yarn. URL: https://github.com/apache/flink/pull/10061#issuecomment-548329682 Thanks a lot for your contribution to the

[jira] [Commented] (FLINK-14583) Remove progressLock from ExecutionGraph

[ https://issues.apache.org/jira/browse/FLINK-14583?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16963896#comment-16963896 ] Gary Yao commented on FLINK-14583: -- I think it can be removed. > Remove progressLock from

[jira] [Comment Edited] (FLINK-14583) Remove progressLock from ExecutionGraph

[ https://issues.apache.org/jira/browse/FLINK-14583?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16963896#comment-16963896 ] Gary Yao edited comment on FLINK-14583 at 10/31/19 11:37 AM: - I think the

[jira] [Commented] (FLINK-14582) Do not upload {uuid}-taskmanager-conf.yaml for each task manager container

[ https://issues.apache.org/jira/browse/FLINK-14582?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16963898#comment-16963898 ] Gary Yao commented on FLINK-14582: -- How much time can we save with this feature? Afaik [~trohrmann] was

[jira] [Commented] (FLINK-13702) BaseMapSerializerTest.testDuplicate fails on Travis

[ https://issues.apache.org/jira/browse/FLINK-13702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16963897#comment-16963897 ] Jingsong Lee commented on FLINK-13702: -- Hi [~dwysakowicz] , I think maybe we don't need to make it

[jira] [Commented] (FLINK-14557) Clean up the package of py4j

[ https://issues.apache.org/jira/browse/FLINK-14557?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16963900#comment-16963900 ] Hequn Cheng commented on FLINK-14557: - Resolved in 1.10.0 via

[GitHub] [flink] hequn8128 closed pull request #10047: [FLINK-14557][python] Cleanup the py4j package

hequn8128 closed pull request #10047: [FLINK-14557][python] Cleanup the py4j package URL: https://github.com/apache/flink/pull/10047 This is an automated message from the Apache Git Service. To respond to the message,

[jira] [Closed] (FLINK-14557) Clean up the package of py4j

[ https://issues.apache.org/jira/browse/FLINK-14557?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-14557. --- Resolution: Resolved > Clean up the package of py4j > > >

[GitHub] [flink] flinkbot edited a comment on issue #8194: [FLINK-12216][Runtime]Respect the number of bytes from input parameters in HybridMemorySegment

flinkbot edited a comment on issue #8194: [FLINK-12216][Runtime]Respect the number of bytes from input parameters in HybridMemorySegment URL: https://github.com/apache/flink/pull/8194#issuecomment-545319242 ## CI report: * 29a887134fd9564f67c3698d187f36ea9148cf32 : SUCCESS

[jira] [Commented] (FLINK-14583) Remove progressLock from ExecutionGraph

[ https://issues.apache.org/jira/browse/FLINK-14583?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16963905#comment-16963905 ] vinoyang commented on FLINK-14583: -- OK, will open a PR. > Remove progressLock from ExecutionGraph >

[GitHub] [flink] flinkbot edited a comment on issue #10002: [FLINK-14074][mesos] Forward configuration to Mesos TaskExecutor

flinkbot edited a comment on issue #10002: [FLINK-14074][mesos] Forward configuration to Mesos TaskExecutor URL: https://github.com/apache/flink/pull/10002#issuecomment-546597933 ## CI report: * 4c13fd02d0f6f98e18ddb04bd11581e0c378a7ca : UNKNOWN *

[jira] [Commented] (FLINK-13702) BaseMapSerializerTest.testDuplicate fails on Travis

[ https://issues.apache.org/jira/browse/FLINK-13702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16963903#comment-16963903 ] Jingsong Lee commented on FLINK-13702: -- About BinaryGeneric: I have considered pass type

[GitHub] [flink] flinkbot edited a comment on issue #10003: [BP-1.9][FLINK-14074][mesos] Forward configuration to Mesos TaskExecutor

flinkbot edited a comment on issue #10003: [BP-1.9][FLINK-14074][mesos] Forward configuration to Mesos TaskExecutor URL: https://github.com/apache/flink/pull/10003#issuecomment-546599805 ## CI report: * f51cd353402817c2a22946c857fe80cf6954fda3 : FAILURE

[jira] [Created] (FLINK-14587) HiveTableSourceTest timeouts on Travis

Gary Yao created FLINK-14587: Summary: HiveTableSourceTest timeouts on Travis Key: FLINK-14587 URL: https://issues.apache.org/jira/browse/FLINK-14587 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-14587) HiveTableSourceTest timeouts on Travis

[ https://issues.apache.org/jira/browse/FLINK-14587?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-14587: - Description: {{HiveTableSourceTest}} failed in nightly tests running on Travis (stage: misc - scala

[jira] [Commented] (FLINK-14505) SQL Client end-to-end test for Kafka 0.10 nightly end-to-end test failed on travis

[ https://issues.apache.org/jira/browse/FLINK-14505?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16963911#comment-16963911 ] Gary Yao commented on FLINK-14505: -- Another instance https://api.travis-ci.org/v3/job/604945337/log.txt

[GitHub] [flink] flinkbot edited a comment on issue #10037: [FLINK-14561] Don't write FLINK_PLUGINS_DIR env variable to Configuration

flinkbot edited a comment on issue #10037: [FLINK-14561] Don't write FLINK_PLUGINS_DIR env variable to Configuration URL: https://github.com/apache/flink/pull/10037#issuecomment-547497114 ## CI report: * d162b69fa12ca127b422d68e79e222415347c24d : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #10049: [FLINK-14544][runtime] Fixing race condition during task cancellation

flinkbot edited a comment on issue #10049: [FLINK-14544][runtime] Fixing race condition during task cancellation URL: https://github.com/apache/flink/pull/10049#issuecomment-547930818 ## CI report: * 7e94dd883cdbfa5f32bdf727166366819f956a17 : SUCCESS

[GitHub] [flink] JingsongLi commented on issue #9864: [FLINK-14254][table] Introduce FileSystemOutputFormat for batch

JingsongLi commented on issue #9864: [FLINK-14254][table] Introduce FileSystemOutputFormat for batch URL: https://github.com/apache/flink/pull/9864#issuecomment-548334839 > We can try to find more appropriate modules for these but `flink-table-common` is definitely not one of them.

[GitHub] [flink] flinkbot commented on issue #10061: [FLINK-14581][python] Let python UDF execution no longer rely on the flink directory structure to support running python UDFs on yarn.

flinkbot commented on issue #10061: [FLINK-14581][python] Let python UDF execution no longer rely on the flink directory structure to support running python UDFs on yarn. URL: https://github.com/apache/flink/pull/10061#issuecomment-548335375 ## CI report: *

[GitHub] [flink] JingsongLi commented on issue #10059: [FLINK-14543][table] Support partition for temporary table

JingsongLi commented on issue #10059: [FLINK-14543][table] Support partition for temporary table URL: https://github.com/apache/flink/pull/10059#issuecomment-548336267 CC: @dawidwys This is an automated message from the

[jira] [Commented] (FLINK-9953) Active Kubernetes integration

[ https://issues.apache.org/jira/browse/FLINK-9953?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16963915#comment-16963915 ] Yang Wang commented on FLINK-9953: -- Hi [~felixzheng], Do you have some time to help with the code

[GitHub] [flink] flinkbot edited a comment on issue #9974: [FLINK-14501][FLINK-14502] Decouple ClusterDescriptor/ClusterSpecification from CommandLine

flinkbot edited a comment on issue #9974: [FLINK-14501][FLINK-14502] Decouple ClusterDescriptor/ClusterSpecification from CommandLine URL: https://github.com/apache/flink/pull/9974#issuecomment-545348099 ## CI report: * 07d3f11426dbdcc4fd961641da0a573914926aca : SUCCESS

[jira] [Commented] (FLINK-14577) Hortonworks schema registry support for avro deserialization

[ https://issues.apache.org/jira/browse/FLINK-14577?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16963706#comment-16963706 ] Gyula Fora commented on FLINK-14577: Thanks for bringing up the discussion. We have built the

[GitHub] [flink] docete commented on issue #10035: [FLINK-14080][table-planner-blink] Introduce Timestamp as internal representation of TIMESTAMP_WITHOUT_TIME_ZONE

docete commented on issue #10035: [FLINK-14080][table-planner-blink] Introduce Timestamp as internal representation of TIMESTAMP_WITHOUT_TIME_ZONE URL: https://github.com/apache/flink/pull/10035#issuecomment-548245095 @wuchong 1. Adding new interface for BaseRow is another problem 2.

[GitHub] [flink] KurtYoung commented on issue #9864: [FLINK-14254][table] Introduce FileSystemOutputFormat for batch

KurtYoung commented on issue #9864: [FLINK-14254][table] Introduce FileSystemOutputFormat for batch URL: https://github.com/apache/flink/pull/9864#issuecomment-548244894 It also doesn't feel right when you introducing 10+ new classes but only test one of them

[GitHub] [flink] flinkbot edited a comment on issue #10056: [FLINK-14565][metric] Shut down SystemResourcesCounter on Metric closed to prevent thread leak

flinkbot edited a comment on issue #10056: [FLINK-14565][metric] Shut down SystemResourcesCounter on Metric closed to prevent thread leak URL: https://github.com/apache/flink/pull/10056#issuecomment-548232338 ## CI report: * caa585061e20672b3ca16298101dbd49230854e8 : SUCCESS

[GitHub] [flink] zhijiangW commented on a change in pull request #9993: [FLINK-14498][runtime]Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool.

zhijiangW commented on a change in pull request #9993: [FLINK-14498][runtime]Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool. URL: https://github.com/apache/flink/pull/9993#discussion_r340988167 ## File path:

[GitHub] [flink] zhijiangW commented on a change in pull request #9993: [FLINK-14498][runtime]Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool.

zhijiangW commented on a change in pull request #9993: [FLINK-14498][runtime]Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool. URL: https://github.com/apache/flink/pull/9993#discussion_r340988167 ## File path:

[GitHub] [flink] zhijiangW commented on a change in pull request #9993: [FLINK-14498][runtime]Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool.

zhijiangW commented on a change in pull request #9993: [FLINK-14498][runtime]Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool. URL: https://github.com/apache/flink/pull/9993#discussion_r340990425 ## File path:

[GitHub] [flink] JingsongLi commented on issue #9864: [FLINK-14254][table] Introduce FileSystemOutputFormat for batch

JingsongLi commented on issue #9864: [FLINK-14254][table] Introduce FileSystemOutputFormat for batch URL: https://github.com/apache/flink/pull/9864#issuecomment-548247936 > It also doesn't feel right when you introducing 10+ new classes but only test one of them I have added some

[GitHub] [flink] dianfu commented on issue #10057: [FLINK-14488][python] Update python table API with temporary tables & views methods

dianfu commented on issue #10057: [FLINK-14488][python] Update python table API with temporary tables & views methods URL: https://github.com/apache/flink/pull/10057#issuecomment-548249635 @flinkbot attention @sunjincheng121 @hequn8128 @dawidwys

[GitHub] [flink] flinkbot commented on issue #10058: [FLINK-12527] Remove GLOBAL_VERSION_UPDATER in ExecutionGraph

flinkbot commented on issue #10058: [FLINK-12527] Remove GLOBAL_VERSION_UPDATER in ExecutionGraph URL: https://github.com/apache/flink/pull/10058#issuecomment-548252848 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review

[jira] [Updated] (FLINK-12527) Remove GLOBAL_VERSION_UPDATER in ExecutionGraph

[ https://issues.apache.org/jira/browse/FLINK-12527?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-12527: --- Labels: pull-request-available (was: ) > Remove GLOBAL_VERSION_UPDATER in ExecutionGraph >

[GitHub] [flink] GJL commented on a change in pull request #10037: [FLINK-14561] Don't write FLINK_PLUGINS_DIR env variable to Configuration

GJL commented on a change in pull request #10037: [FLINK-14561] Don't write FLINK_PLUGINS_DIR env variable to Configuration URL: https://github.com/apache/flink/pull/10037#discussion_r340996665 ## File path: flink-core/src/main/java/org/apache/flink/core/plugin/PluginConfig.java

[jira] [Commented] (FLINK-14536) Make clear the way to aggregate specified cpuCores resources

[ https://issues.apache.org/jira/browse/FLINK-14536?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16963744#comment-16963744 ] Zhu Zhu commented on FLINK-14536: - Thanks [~zjwang] for the explanation. Agreed that using {{sum()}} is

[jira] [Updated] (FLINK-14582) Do not upload {uuid}-taskmanager-conf.yaml for each task manager container

[ https://issues.apache.org/jira/browse/FLINK-14582?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang updated FLINK-14582: -- Description: Currently when we {{createTaskExecutorLaunchContext}}, a new task manager conf will be

[jira] [Created] (FLINK-14582) Do not upload {uuid}-taskmanager-conf.yaml for each task manager container

Yang Wang created FLINK-14582: - Summary: Do not upload {uuid}-taskmanager-conf.yaml for each task manager container Key: FLINK-14582 URL: https://issues.apache.org/jira/browse/FLINK-14582 Project: Flink

[GitHub] [flink] flinkbot edited a comment on issue #10057: [FLINK-14488][python] Update python table API with temporary tables & views methods

flinkbot edited a comment on issue #10057: [FLINK-14488][python] Update python table API with temporary tables & views methods URL: https://github.com/apache/flink/pull/10057#issuecomment-548252146 ## CI report: * 53d0b7dd23f39f6b8308958475c23ca8dd32aa1c : PENDING

[jira] [Commented] (FLINK-14583) Remove progressLock from ExecutionGraph

[ https://issues.apache.org/jira/browse/FLINK-14583?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16963749#comment-16963749 ] vinoyang commented on FLINK-14583: -- [~gjy] WDYT? > Remove progressLock from ExecutionGraph >

[jira] [Created] (FLINK-14583) Remove progressLock from ExecutionGraph

vinoyang created FLINK-14583: Summary: Remove progressLock from ExecutionGraph Key: FLINK-14583 URL: https://issues.apache.org/jira/browse/FLINK-14583 Project: Flink Issue Type: Sub-task

[GitHub] [flink] azagrebin commented on a change in pull request #8194: [FLINK-12216][Runtime]Respect the number of bytes from input parameters in HybridMemorySegment

azagrebin commented on a change in pull request #8194: [FLINK-12216][Runtime]Respect the number of bytes from input parameters in HybridMemorySegment URL: https://github.com/apache/flink/pull/8194#discussion_r341009633 ## File path:

[GitHub] [flink] azagrebin commented on a change in pull request #8194: [FLINK-12216][Runtime]Respect the number of bytes from input parameters in HybridMemorySegment

azagrebin commented on a change in pull request #8194: [FLINK-12216][Runtime]Respect the number of bytes from input parameters in HybridMemorySegment URL: https://github.com/apache/flink/pull/8194#discussion_r341011729 ## File path:

[jira] [Assigned] (FLINK-10257) Incorrect CHAR type support in Flink SQL and Table API

[ https://issues.apache.org/jira/browse/FLINK-10257?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reassigned FLINK-10257: --- Assignee: Zhenghua Gao (was: huang zheng) > Incorrect CHAR type support in Flink SQL and

[jira] [Assigned] (FLINK-9559) The type of a union of CHAR columns of different lengths should be VARCHAR

[ https://issues.apache.org/jira/browse/FLINK-9559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reassigned FLINK-9559: -- Assignee: Zhenghua Gao (was: Hequn Cheng) > The type of a union of CHAR columns of different

[jira] [Updated] (FLINK-14582) Do not upload {uuid}-taskmanager-conf.yaml for each task manager container

[ https://issues.apache.org/jira/browse/FLINK-14582?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-14582: -- Component/s: Deployment / YARN > Do not upload {uuid}-taskmanager-conf.yaml for each task

<    1   2   3   4   5   >