[GitHub] [flink] dianfu commented on issue #9851: [FLINK-14341]Fix flink-python builds failure: no such option: --prefix

dianfu commented on issue #9851: [FLINK-14341]Fix flink-python builds failure: no such option: --prefix URL: https://github.com/apache/flink/pull/9851#issuecomment-540462706 @liupc Thanks a lot for the update. +1 from my side. ---

[GitHub] [flink] flinkbot commented on issue #9876: [FLINK-14134][table] Introduce LimitableTableSource for optimizing limit

flinkbot commented on issue #9876: [FLINK-14134][table] Introduce LimitableTableSource for optimizing limit URL: https://github.com/apache/flink/pull/9876#issuecomment-540462303 ## CI report: * 3eca02d54759452fdc285687c7aedbf2199a7b46 : UNKNOWN Bot commands The @f

[GitHub] [flink] flinkbot edited a comment on issue #9865: [FLINK-14212][python] Support no-argument Python UDFs.

flinkbot edited a comment on issue #9865: [FLINK-14212][python] Support no-argument Python UDFs. URL: https://github.com/apache/flink/pull/9865#issuecomment-539919841 ## CI report: * bf1d566ea2f91d61c2f436bb92b5337088b7 : SUCCESS [Build](https://travis-ci.com/flink-ci/flink/

[GitHub] [flink] flinkbot edited a comment on issue #9866: [FLINK-14349][hbase] Create a Connector Descriptor for HBase so that user can connect HBase by TableEnvironment#connect

flinkbot edited a comment on issue #9866: [FLINK-14349][hbase] Create a Connector Descriptor for HBase so that user can connect HBase by TableEnvironment#connect URL: https://github.com/apache/flink/pull/9866#issuecomment-539968272 ## CI report: * 372923b25d5fa8376fc40b18e2bf024

[GitHub] [flink] flinkbot edited a comment on issue #9858: [FLINK-14208][python] Optimize Python UDFs with parameters of constant values

flinkbot edited a comment on issue #9858: [FLINK-14208][python] Optimize Python UDFs with parameters of constant values URL: https://github.com/apache/flink/pull/9858#issuecomment-539830457 ## CI report: * 5b6f4eb6008d7f2656fce8c2fbd7b43d7b8a0cf0 : FAILURE [Build](https://travis

[GitHub] [flink] docete commented on a change in pull request #9803: [FLINK-14265][table-planner-blink] Don't use ContinuousFileReaderOperator to support multiple paths

docete commented on a change in pull request #9803: [FLINK-14265][table-planner-blink] Don't use ContinuousFileReaderOperator to support multiple paths URL: https://github.com/apache/flink/pull/9803#discussion_r89832 ## File path: flink-table/flink-table-planner-blink/src/test

[GitHub] [flink] dianfu commented on a change in pull request #9874: [FLINK-14240][table] Merge table config parameters(TableConfig#getConfiguration) into global job parameters(ExecutionConfig#getGlob

dianfu commented on a change in pull request #9874: [FLINK-14240][table] Merge table config parameters(TableConfig#getConfiguration) into global job parameters(ExecutionConfig#getGlobalJobParameters) when running with the legacy planner. URL: https://github.com/apache/flink/pull/9874#discussion_

[GitHub] [flink] dianfu commented on a change in pull request #9865: [FLINK-14212][python] Support no-argument Python UDFs.

dianfu commented on a change in pull request #9865: [FLINK-14212][python] Support no-argument Python UDFs. URL: https://github.com/apache/flink/pull/9865#discussion_r87770 ## File path: flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/plan/ExpressionReducti

[GitHub] [flink] 1u0 commented on a change in pull request #9772: [FLINK-14199] Only use dedicated/named classes for mailbox letters.

1u0 commented on a change in pull request #9772: [FLINK-14199] Only use dedicated/named classes for mailbox letters. URL: https://github.com/apache/flink/pull/9772#discussion_r84274 ## File path: flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/mailb

[GitHub] [flink] 1u0 commented on a change in pull request #9772: [FLINK-14199] Only use dedicated/named classes for mailbox letters.

1u0 commented on a change in pull request #9772: [FLINK-14199] Only use dedicated/named classes for mailbox letters. URL: https://github.com/apache/flink/pull/9772#discussion_r84274 ## File path: flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/mailb

[GitHub] [flink] wsry commented on issue #9706: [FLINK-14118][runtime]Reduce the unnecessary flushing when there is no data available for flush.

wsry commented on issue #9706: [FLINK-14118][runtime]Reduce the unnecessary flushing when there is no data available for flush. URL: https://github.com/apache/flink/pull/9706#issuecomment-540456266 Thanks @pnowojski I will pay more attention to the commit descriptions in the future. -

[GitHub] [flink] 1u0 commented on a change in pull request #9772: [FLINK-14199] Only use dedicated/named classes for mailbox letters.

1u0 commented on a change in pull request #9772: [FLINK-14199] Only use dedicated/named classes for mailbox letters. URL: https://github.com/apache/flink/pull/9772#discussion_r72570 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/Strea

[GitHub] [flink] 1u0 commented on a change in pull request #9772: [FLINK-14199] Only use dedicated/named classes for mailbox letters.

1u0 commented on a change in pull request #9772: [FLINK-14199] Only use dedicated/named classes for mailbox letters. URL: https://github.com/apache/flink/pull/9772#discussion_r84274 ## File path: flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/mailb

[GitHub] [flink] 1u0 commented on a change in pull request #9772: [FLINK-14199] Only use dedicated/named classes for mailbox letters.

1u0 commented on a change in pull request #9772: [FLINK-14199] Only use dedicated/named classes for mailbox letters. URL: https://github.com/apache/flink/pull/9772#discussion_r81245 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/mailb

[GitHub] [flink] 1u0 commented on a change in pull request #9772: [FLINK-14199] Only use dedicated/named classes for mailbox letters.

1u0 commented on a change in pull request #9772: [FLINK-14199] Only use dedicated/named classes for mailbox letters. URL: https://github.com/apache/flink/pull/9772#discussion_r71175 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/Strea

[jira] [Closed] (FLINK-14118) Reduce the unnecessary flushing when there is no data available for flush

[ https://issues.apache.org/jira/browse/FLINK-14118?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-14118. -- Resolution: Fixed merged commit d231032 into apache:master > Reduce the unnecessary flushing

[GitHub] [flink] pnowojski edited a comment on issue #9706: [FLINK-14118][runtime]Reduce the unnecessary flushing when there is no data available for flush.

pnowojski edited a comment on issue #9706: [FLINK-14118][runtime]Reduce the unnecessary flushing when there is no data available for flush. URL: https://github.com/apache/flink/pull/9706#issuecomment-540452572 Benchmark [looks stable](http://codespeed.dak8s.net:8000/timeline/#/?exe=1,3&ben

[GitHub] [flink] pnowojski merged pull request #9706: [FLINK-14118][runtime]Reduce the unnecessary flushing when there is no data available for flush.

pnowojski merged pull request #9706: [FLINK-14118][runtime]Reduce the unnecessary flushing when there is no data available for flush. URL: https://github.com/apache/flink/pull/9706 This is an automated message from the Apach

[GitHub] [flink] WeiZhong94 commented on issue #9865: [FLINK-14212][python] Support no-argument Python UDFs.

WeiZhong94 commented on issue #9865: [FLINK-14212][python] Support no-argument Python UDFs. URL: https://github.com/apache/flink/pull/9865#issuecomment-540452708 @dianfu Thanks for your review again! I have addressed your comments in the latest commit.

[GitHub] [flink] pnowojski commented on issue #9706: [FLINK-14118][runtime]Reduce the unnecessary flushing when there is no data available for flush.

pnowojski commented on issue #9706: [FLINK-14118][runtime]Reduce the unnecessary flushing when there is no data available for flush. URL: https://github.com/apache/flink/pull/9706#issuecomment-540452572 Benchmark [looks stable](http://codespeed.dak8s.net:8000/timeline/#/?exe=1,3&ben=networ

[GitHub] [flink] pnowojski edited a comment on issue #9706: [FLINK-14118][runtime]Reduce the unnecessary flushing when there is no data available for flush.

pnowojski edited a comment on issue #9706: [FLINK-14118][runtime]Reduce the unnecessary flushing when there is no data available for flush. URL: https://github.com/apache/flink/pull/9706#issuecomment-540452572 Benchmark [looks stable](http://codespeed.dak8s.net:8000/timeline/#/?exe=1,3&ben

[GitHub] [flink] WeiZhong94 commented on a change in pull request #9865: [FLINK-14212][python] Support no-argument Python UDFs.

WeiZhong94 commented on a change in pull request #9865: [FLINK-14212][python] Support no-argument Python UDFs. URL: https://github.com/apache/flink/pull/9865#discussion_r81690 ## File path: flink-python/pyflink/table/tests/test_udf.py ## @@ -204,6 +204,28 @@ def eval(s

[GitHub] [flink] flinkbot edited a comment on issue #9866: [FLINK-14349][hbase] Create a Connector Descriptor for HBase so that user can connect HBase by TableEnvironment#connect

flinkbot edited a comment on issue #9866: [FLINK-14349][hbase] Create a Connector Descriptor for HBase so that user can connect HBase by TableEnvironment#connect URL: https://github.com/apache/flink/pull/9866#issuecomment-539968272 ## CI report: * 372923b25d5fa8376fc40b18e2bf024

[GitHub] [flink] flinkbot edited a comment on issue #9858: [FLINK-14208][python] Optimize Python UDFs with parameters of constant values

flinkbot edited a comment on issue #9858: [FLINK-14208][python] Optimize Python UDFs with parameters of constant values URL: https://github.com/apache/flink/pull/9858#issuecomment-539830457 ## CI report: * 5b6f4eb6008d7f2656fce8c2fbd7b43d7b8a0cf0 : FAILURE [Build](https://travis

[GitHub] [flink] flinkbot edited a comment on issue #9848: [FLINK-14332] [flink-metrics-signalfx] add flink-metrics-signalfx

flinkbot edited a comment on issue #9848: [FLINK-14332] [flink-metrics-signalfx] add flink-metrics-signalfx URL: https://github.com/apache/flink/pull/9848#issuecomment-538885706 ## CI report: * dd22d245973b8caf25f8f26a392a1ca95f863736 : SUCCESS [Build](https://travis-ci.com/flin

[GitHub] [flink] flinkbot edited a comment on issue #9851: [FLINK-14341]Fix flink-python builds failure: no such option: --prefix

flinkbot edited a comment on issue #9851: [FLINK-14341]Fix flink-python builds failure: no such option: --prefix URL: https://github.com/apache/flink/pull/9851#issuecomment-539365871 ## CI report: * 1007e8b66d42b613ceafb86457913381a4e27b0f : FAILURE [Build](https://travis-ci.com

[GitHub] [flink] flinkbot commented on issue #9876: [FLINK-14134][table] Introduce LimitableTableSource for optimizing limit

flinkbot commented on issue #9876: [FLINK-14134][table] Introduce LimitableTableSource for optimizing limit URL: https://github.com/apache/flink/pull/9876#issuecomment-540450322 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to re

[jira] [Updated] (FLINK-14134) Introduce LimitableTableSource to optimize limit

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

[GitHub] [flink] dianfu commented on a change in pull request #9858: [FLINK-14208][python] Optimize Python UDFs with parameters of constant values

dianfu commented on a change in pull request #9858: [FLINK-14208][python] Optimize Python UDFs with parameters of constant values URL: https://github.com/apache/flink/pull/9858#discussion_r75220 ## File path: flink-python/pyflink/table/tests/test_udf.py ## @@ -96,6 +96

[GitHub] [flink] dianfu commented on a change in pull request #9858: [FLINK-14208][python] Optimize Python UDFs with parameters of constant values

dianfu commented on a change in pull request #9858: [FLINK-14208][python] Optimize Python UDFs with parameters of constant values URL: https://github.com/apache/flink/pull/9858#discussion_r70109 ## File path: flink-python/pyflink/table/tests/test_udf.py ## @@ -96,6 +96

[GitHub] [flink] dianfu commented on a change in pull request #9858: [FLINK-14208][python] Optimize Python UDFs with parameters of constant values

dianfu commented on a change in pull request #9858: [FLINK-14208][python] Optimize Python UDFs with parameters of constant values URL: https://github.com/apache/flink/pull/9858#discussion_r69200 ## File path: flink-python/pyflink/table/tests/test_udf.py ## @@ -96,6 +96

[GitHub] [flink] dianfu commented on a change in pull request #9858: [FLINK-14208][python] Optimize Python UDFs with parameters of constant values

dianfu commented on a change in pull request #9858: [FLINK-14208][python] Optimize Python UDFs with parameters of constant values URL: https://github.com/apache/flink/pull/9858#discussion_r76429 ## File path: flink-python/pyflink/fn_execution/operations.py ## @@ -79,6

[GitHub] [flink] dianfu commented on a change in pull request #9858: [FLINK-14208][python] Optimize Python UDFs with parameters of constant values

dianfu commented on a change in pull request #9858: [FLINK-14208][python] Optimize Python UDFs with parameters of constant values URL: https://github.com/apache/flink/pull/9858#discussion_r65971 ## File path: flink-python/pyflink/proto/flink-fn-execution.proto ## @@ -2

[GitHub] [flink] dianfu commented on a change in pull request #9858: [FLINK-14208][python] Optimize Python UDFs with parameters of constant values

dianfu commented on a change in pull request #9858: [FLINK-14208][python] Optimize Python UDFs with parameters of constant values URL: https://github.com/apache/flink/pull/9858#discussion_r73867 ## File path: flink-python/src/main/java/org/apache/flink/api/common/python/PythonB

[GitHub] [flink] dianfu commented on a change in pull request #9858: [FLINK-14208][python] Optimize Python UDFs with parameters of constant values

dianfu commented on a change in pull request #9858: [FLINK-14208][python] Optimize Python UDFs with parameters of constant values URL: https://github.com/apache/flink/pull/9858#discussion_r67301 ## File path: flink-python/pyflink/table/tests/test_udf.py ## @@ -96,6 +96

[GitHub] [flink] dianfu commented on a change in pull request #9858: [FLINK-14208][python] Optimize Python UDFs with parameters of constant values

dianfu commented on a change in pull request #9858: [FLINK-14208][python] Optimize Python UDFs with parameters of constant values URL: https://github.com/apache/flink/pull/9858#discussion_r67175 ## File path: flink-python/pyflink/table/tests/test_udf.py ## @@ -96,6 +96

[GitHub] [flink] JingsongLi opened a new pull request #9876: [FLINK-14134][table] Introduce LimitableTableSource for optimizing limit

JingsongLi opened a new pull request #9876: [FLINK-14134][table] Introduce LimitableTableSource for optimizing limit URL: https://github.com/apache/flink/pull/9876 ## What is the purpose of the change SQL: select *from t1 limit 1 Now source will scan full table, if we can introduc

[GitHub] [flink] dianfu commented on a change in pull request #9858: [FLINK-14208][python] Optimize Python UDFs with parameters of constant values

dianfu commented on a change in pull request #9858: [FLINK-14208][python] Optimize Python UDFs with parameters of constant values URL: https://github.com/apache/flink/pull/9858#discussion_r74856 ## File path: flink-table/flink-table-planner/src/main/scala/org/apache/flink/table

[jira] [Assigned] (FLINK-14134) Introduce LimitableTableSource to optimize limit

[ https://issues.apache.org/jira/browse/FLINK-14134?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-14134: --- Assignee: Jingsong Lee > Introduce LimitableTableSource to optimize limit > ---

[GitHub] [flink] JingsongLi commented on a change in pull request #9796: [FLINK-14253][table-planner-blink] Add hash distribution and sort grouping only when dynamic partition insert

JingsongLi commented on a change in pull request #9796: [FLINK-14253][table-planner-blink] Add hash distribution and sort grouping only when dynamic partition insert URL: https://github.com/apache/flink/pull/9796#discussion_r73524 ## File path: flink-table/flink-table-planner-

[jira] [Closed] (FLINK-14353) Enable fork-reuse for table-planner

[ https://issues.apache.org/jira/browse/FLINK-14353?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-14353. Resolution: Fixed master: 17fae0e0273c031118bdedbcdb8a03c401257690 > Enable fork-reuse fo

[GitHub] [flink] zentol merged pull request #9871: [FLINK-14353][table] Enable fork reuse for tests

zentol merged pull request #9871: [FLINK-14353][table] Enable fork reuse for tests URL: https://github.com/apache/flink/pull/9871 This is an automated message from the Apache Git Service. To respond to the message, please lo

[GitHub] [flink] flinkbot edited a comment on issue #9858: [FLINK-14208][python] Optimize Python UDFs with parameters of constant values

flinkbot edited a comment on issue #9858: [FLINK-14208][python] Optimize Python UDFs with parameters of constant values URL: https://github.com/apache/flink/pull/9858#issuecomment-539830457 ## CI report: * 5b6f4eb6008d7f2656fce8c2fbd7b43d7b8a0cf0 : FAILURE [Build](https://travis

[GitHub] [flink] flinkbot edited a comment on issue #9866: [FLINK-14349][hbase] Create a Connector Descriptor for HBase so that user can connect HBase by TableEnvironment#connect

flinkbot edited a comment on issue #9866: [FLINK-14349][hbase] Create a Connector Descriptor for HBase so that user can connect HBase by TableEnvironment#connect URL: https://github.com/apache/flink/pull/9866#issuecomment-539968272 ## CI report: * 372923b25d5fa8376fc40b18e2bf024

[GitHub] [flink] flinkbot edited a comment on issue #9865: [FLINK-14212][python] Support no-argument Python UDFs.

flinkbot edited a comment on issue #9865: [FLINK-14212][python] Support no-argument Python UDFs. URL: https://github.com/apache/flink/pull/9865#issuecomment-539919841 ## CI report: * bf1d566ea2f91d61c2f436bb92b5337088b7 : SUCCESS [Build](https://travis-ci.com/flink-ci/flink/

[GitHub] [flink] flinkbot edited a comment on issue #9848: [FLINK-14332] [flink-metrics-signalfx] add flink-metrics-signalfx

flinkbot edited a comment on issue #9848: [FLINK-14332] [flink-metrics-signalfx] add flink-metrics-signalfx URL: https://github.com/apache/flink/pull/9848#issuecomment-538885706 ## CI report: * dd22d245973b8caf25f8f26a392a1ca95f863736 : SUCCESS [Build](https://travis-ci.com/flin

[GitHub] [flink] docete commented on a change in pull request #9796: [FLINK-14253][table-planner-blink] Add hash distribution and sort grouping only when dynamic partition insert

docete commented on a change in pull request #9796: [FLINK-14253][table-planner-blink] Add hash distribution and sort grouping only when dynamic partition insert URL: https://github.com/apache/flink/pull/9796#discussion_r69466 ## File path: flink-table/flink-table-planner-blin

[GitHub] [flink] docete commented on a change in pull request #9796: [FLINK-14253][table-planner-blink] Add hash distribution and sort grouping only when dynamic partition insert

docete commented on a change in pull request #9796: [FLINK-14253][table-planner-blink] Add hash distribution and sort grouping only when dynamic partition insert URL: https://github.com/apache/flink/pull/9796#discussion_r65571 ## File path: flink-table/flink-table-planner-blin

[GitHub] [flink] docete commented on a change in pull request #9796: [FLINK-14253][table-planner-blink] Add hash distribution and sort grouping only when dynamic partition insert

docete commented on a change in pull request #9796: [FLINK-14253][table-planner-blink] Add hash distribution and sort grouping only when dynamic partition insert URL: https://github.com/apache/flink/pull/9796#discussion_r65477 ## File path: flink-table/flink-table-planner-blin

[GitHub] [flink] docete commented on a change in pull request #9796: [FLINK-14253][table-planner-blink] Add hash distribution and sort grouping only when dynamic partition insert

docete commented on a change in pull request #9796: [FLINK-14253][table-planner-blink] Add hash distribution and sort grouping only when dynamic partition insert URL: https://github.com/apache/flink/pull/9796#discussion_r65272 ## File path: flink-table/flink-table-planner-blin

[GitHub] [flink] docete commented on a change in pull request #9796: [FLINK-14253][table-planner-blink] Add hash distribution and sort grouping only when dynamic partition insert

docete commented on a change in pull request #9796: [FLINK-14253][table-planner-blink] Add hash distribution and sort grouping only when dynamic partition insert URL: https://github.com/apache/flink/pull/9796#discussion_r65017 ## File path: flink-table/flink-table-planner-blin

[GitHub] [flink] dianfu commented on a change in pull request #9865: [FLINK-14212][python] Support no-argument Python UDFs.

dianfu commented on a change in pull request #9865: [FLINK-14212][python] Support no-argument Python UDFs. URL: https://github.com/apache/flink/pull/9865#discussion_r61887 ## File path: flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/planner/plan/rul

[GitHub] [flink] dianfu commented on a change in pull request #9865: [FLINK-14212][python] Support no-argument Python UDFs.

dianfu commented on a change in pull request #9865: [FLINK-14212][python] Support no-argument Python UDFs. URL: https://github.com/apache/flink/pull/9865#discussion_r58371 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/codegen/

[GitHub] [flink] dianfu commented on a change in pull request #9865: [FLINK-14212][python] Support no-argument Python UDFs.

dianfu commented on a change in pull request #9865: [FLINK-14212][python] Support no-argument Python UDFs. URL: https://github.com/apache/flink/pull/9865#discussion_r58011 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/codegen/

[GitHub] [flink] dianfu commented on a change in pull request #9865: [FLINK-14212][python] Support no-argument Python UDFs.

dianfu commented on a change in pull request #9865: [FLINK-14212][python] Support no-argument Python UDFs. URL: https://github.com/apache/flink/pull/9865#discussion_r61311 ## File path: flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/planner/plan/rul

[GitHub] [flink] dianfu commented on a change in pull request #9865: [FLINK-14212][python] Support no-argument Python UDFs.

dianfu commented on a change in pull request #9865: [FLINK-14212][python] Support no-argument Python UDFs. URL: https://github.com/apache/flink/pull/9865#discussion_r57976 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/codegen/

[GitHub] [flink] dianfu commented on a change in pull request #9865: [FLINK-14212][python] Support no-argument Python UDFs.

dianfu commented on a change in pull request #9865: [FLINK-14212][python] Support no-argument Python UDFs. URL: https://github.com/apache/flink/pull/9865#discussion_r59811 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/uti

[GitHub] [flink] dianfu commented on a change in pull request #9865: [FLINK-14212][python] Support no-argument Python UDFs.

dianfu commented on a change in pull request #9865: [FLINK-14212][python] Support no-argument Python UDFs. URL: https://github.com/apache/flink/pull/9865#discussion_r57377 ## File path: flink-python/pyflink/table/tests/test_udf.py ## @@ -204,6 +204,28 @@ def eval(self,

[GitHub] [flink] flinkbot edited a comment on issue #9866: [FLINK-14349][hbase] Create a Connector Descriptor for HBase so that user can connect HBase by TableEnvironment#connect

flinkbot edited a comment on issue #9866: [FLINK-14349][hbase] Create a Connector Descriptor for HBase so that user can connect HBase by TableEnvironment#connect URL: https://github.com/apache/flink/pull/9866#issuecomment-539968272 ## CI report: * 372923b25d5fa8376fc40b18e2bf024

[GitHub] [flink] flinkbot edited a comment on issue #9865: [FLINK-14212][python] Support no-argument Python UDFs.

flinkbot edited a comment on issue #9865: [FLINK-14212][python] Support no-argument Python UDFs. URL: https://github.com/apache/flink/pull/9865#issuecomment-539919841 ## CI report: * bf1d566ea2f91d61c2f436bb92b5337088b7 : SUCCESS [Build](https://travis-ci.com/flink-ci/flink/

[GitHub] [flink] flinkbot edited a comment on issue #9848: [FLINK-14332] [flink-metrics-signalfx] add flink-metrics-signalfx

flinkbot edited a comment on issue #9848: [FLINK-14332] [flink-metrics-signalfx] add flink-metrics-signalfx URL: https://github.com/apache/flink/pull/9848#issuecomment-538885706 ## CI report: * dd22d245973b8caf25f8f26a392a1ca95f863736 : SUCCESS [Build](https://travis-ci.com/flin

[GitHub] [flink] flinkbot edited a comment on issue #9851: [FLINK-14341]Fix flink-python builds failure: no such option: --prefix

flinkbot edited a comment on issue #9851: [FLINK-14341]Fix flink-python builds failure: no such option: --prefix URL: https://github.com/apache/flink/pull/9851#issuecomment-539365871 ## CI report: * 1007e8b66d42b613ceafb86457913381a4e27b0f : FAILURE [Build](https://travis-ci.com

[GitHub] [flink] flinkbot edited a comment on issue #9818: [FLINK-14289][runtime] Remove Optional fields from RecordWriter relevant classes

flinkbot edited a comment on issue #9818: [FLINK-14289][runtime] Remove Optional fields from RecordWriter relevant classes URL: https://github.com/apache/flink/pull/9818#issuecomment-536416616 ## CI report: * 519051016f02b8257eb1e3d5834f36c315816266 : FAILURE [Build](https://tr

[GitHub] [flink] flinkbot edited a comment on issue #9542: [FLINK-13873][metrics] Change the column family as tags for influxdb …

flinkbot edited a comment on issue #9542: [FLINK-13873][metrics] Change the column family as tags for influxdb … URL: https://github.com/apache/flink/pull/9542#issuecomment-525276537 ## CI report: * e8636926351f3d406962dcadba275e20e49aff39 : SUCCESS [Build](https://travis-ci.com

[GitHub] [flink] WeiZhong94 commented on issue #9865: [FLINK-14212][python] Support no-argument Python UDFs.

WeiZhong94 commented on issue #9865: [FLINK-14212][python] Support no-argument Python UDFs. URL: https://github.com/apache/flink/pull/9865#issuecomment-540423623 @JingsongLi I noticed that the "getScalarFunction" method in "ScalarSqlFunction" of blink planner was replaced by "makeFunction"

[jira] [Assigned] (FLINK-14361) Decorrelate subQuery fail when multi correlate in project

[ https://issues.apache.org/jira/browse/FLINK-14361?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-14361: --- Assignee: godfrey he > Decorrelate subQuery fail when multi correlate in project >

<    1   2   3   4