[GitHub] [flink] wuchong commented on a change in pull request #15006: [FLINK-21485][sql-client] Simplify the ExecutionContext

wuchong commented on a change in pull request #15006: URL: https://github.com/apache/flink/pull/15006#discussion_r589163832 ## File path: flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/context/DefaultContext.java ## @@ -0,0 +1,296 @@ +/* + *

[GitHub] [flink] wangyang0918 commented on a change in pull request #15095: [FLINK-13554][runtime] Add a timeout for worker registration.

wangyang0918 commented on a change in pull request #15095: URL: https://github.com/apache/flink/pull/15095#discussion_r589227565 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/ResourceManager.java ## @@ -1200,7 +1202,7 @@ public void

[GitHub] [flink] flinkbot edited a comment on pull request #15103: [FLINK-21612][table-planner-blink] Support StreamExecGroupAggregate json serialization/deserialization

flinkbot edited a comment on pull request #15103: URL: https://github.com/apache/flink/pull/15103#issuecomment-792244189 ## CI report: * e20294a097497a20e4a3db5317c7b81a30a971c6 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15101: [FLINK-21641][python] Support 'useModules' and 'listFullModules' in PyFlink

flinkbot edited a comment on pull request #15101: URL: https://github.com/apache/flink/pull/15101#issuecomment-791983297 ## CI report: * 642045406a87997c1e9e5e7ccff74017490e8b27 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15083: [FLINK-21242][python] Support state access API for the map/flat_map/filter/reduce operations of Python KeyedStream

flinkbot edited a comment on pull request #15083: URL: https://github.com/apache/flink/pull/15083#issuecomment-790411183 ## CI report: * edf533eccd54ccd16fca238397b1417fd98828c5 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15088: [FLINK-21328] Optimize the initialization of DefaultExecutionTopology

flinkbot edited a comment on pull request #15088: URL: https://github.com/apache/flink/pull/15088#issuecomment-791143147 ## CI report: * 75a6001c5dd93d98ac2d7f9330e74f5132b73512 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15075: [FLINK-21525] Move scheduler benchmarks to Flink and add unit tests

flinkbot edited a comment on pull request #15075: URL: https://github.com/apache/flink/pull/15075#issuecomment-789602188 ## CI report: * 065d7e810ae5548dafb6cc4782f6ec92cd20932e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13025: [FLINK-18762][network] Make network buffers per incoming/outgoing channel can be configured separately

flinkbot edited a comment on pull request #13025: URL: https://github.com/apache/flink/pull/13025#issuecomment-666200437 ## CI report: * d562983dad16117b1beeb8a5ba72f3f699be31d2 Azure:

[GitHub] [flink] LadyForest commented on pull request #15101: [FLINK-21641][python] Support 'useModules' and 'listFullModules' in PyFlink

LadyForest commented on pull request #15101: URL: https://github.com/apache/flink/pull/15101#issuecomment-792549067 Hi @dianfu, I've updated the PR, and you can take a look after CI passes. This is an automated message from

[GitHub] [flink] godfreyhe commented on pull request #15103: [FLINK-21612][table-planner-blink] Support StreamExecGroupAggregate json serialization/deserialization

godfreyhe commented on pull request #15103: URL: https://github.com/apache/flink/pull/15103#issuecomment-792547323 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [flink] shouweikun commented on a change in pull request #15060: [FLINK-19944][Connectors / Hive]Support sink parallelism configuratio…

shouweikun commented on a change in pull request #15060: URL: https://github.com/apache/flink/pull/15060#discussion_r58903 ## File path: flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/HiveDynamicTableFactory.java ## @@ -80,7 +80,6 @@

[GitHub] [flink] WeiZhong94 commented on pull request #15083: [FLINK-21242][python] Support state access API for the map/flat_map/filter/reduce operations of Python KeyedStream

WeiZhong94 commented on pull request #15083: URL: https://github.com/apache/flink/pull/15083#issuecomment-792544047 @HuangXingBo Thanks for your review! I have fixed the test failure and addressed your comments. This is an

[GitHub] [flink] HuangXingBo commented on a change in pull request #15083: [FLINK-21242][python] Support state access API for the map/flat_map/filter/reduce operations of Python KeyedStream

HuangXingBo commented on a change in pull request #15083: URL: https://github.com/apache/flink/pull/15083#discussion_r588212168 ## File path: flink-python/src/main/java/org/apache/flink/streaming/api/runners/python/beam/BeamPythonFunctionRunner.java ## @@ -657,6 +659,12 @@

[jira] [Updated] (FLINK-21659) Running HA per-job cluster (rocks, incremental) end-to-end test fails

[ https://issues.apache.org/jira/browse/FLINK-21659?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma updated FLINK-21659: -- Description:

[GitHub] [flink] godfreyhe commented on a change in pull request #15089: [FLINK-21614][sql-client] Introduce a new integration test framework for SQL Client

godfreyhe commented on a change in pull request #15089: URL: https://github.com/apache/flink/pull/15089#discussion_r589216628 ## File path: flink-table/flink-sql-client/src/test/resources/sql/catalog_database.q ## @@ -0,0 +1,323 @@ +# catalog_database.q - CREATE/DROP/SHOW/USE

[jira] [Created] (FLINK-21659) Running HA per-job cluster (rocks, incremental) end-to-end test fails

Guowei Ma created FLINK-21659: - Summary: Running HA per-job cluster (rocks, incremental) end-to-end test fails Key: FLINK-21659 URL: https://issues.apache.org/jira/browse/FLINK-21659 Project: Flink

[GitHub] [flink] flinkbot edited a comment on pull request #15101: [FLINK-21641][python] Support 'useModules' and 'listFullModules' in PyFlink

flinkbot edited a comment on pull request #15101: URL: https://github.com/apache/flink/pull/15101#issuecomment-791983297 ## CI report: * 642045406a87997c1e9e5e7ccff74017490e8b27 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15088: [FLINK-21328] Optimize the initialization of DefaultExecutionTopology

flinkbot edited a comment on pull request #15088: URL: https://github.com/apache/flink/pull/15088#issuecomment-791143147 ## CI report: * 75a6001c5dd93d98ac2d7f9330e74f5132b73512 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15075: [FLINK-21525] Move scheduler benchmarks to Flink and add unit tests

flinkbot edited a comment on pull request #15075: URL: https://github.com/apache/flink/pull/15075#issuecomment-789602188 ## CI report: * 065d7e810ae5548dafb6cc4782f6ec92cd20932e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #11877: [FLINK-16641][network] Announce sender's backlog to solve the deadlock issue without exclusive buffers

flinkbot edited a comment on pull request #11877: URL: https://github.com/apache/flink/pull/11877#issuecomment-618273998 ## CI report: * 379905b396355d37f565230cbcbee323dc626dce Azure:

[jira] [Updated] (FLINK-21658) Align flink-benchmarks with job graph builder

[ https://issues.apache.org/jira/browse/FLINK-21658?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-21658: --- Labels: pull-request-available (was: ) > Align flink-benchmarks with job graph builder >

[GitHub] [flink-benchmarks] Myasuka opened a new pull request #10: [FLINK-21658] Adopts JobGraphBuilder to create job graph

Myasuka opened a new pull request #10: URL: https://github.com/apache/flink-benchmarks/pull/10 This PR avoid current broken compilation. This is an automated message from the Apache Git Service. To respond to the message,

[jira] [Commented] (FLINK-21657) flink doc fails to display a picture

[ https://issues.apache.org/jira/browse/FLINK-21657?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17297127#comment-17297127 ] Zhilong Hong commented on FLINK-21657: -- cc [~sjwiesman]. By the way, there are several broken

[GitHub] [flink] flinkbot edited a comment on pull request #15110: [FLINK-21579][table] Support "SHOW USER FUNCTIONS" statement

flinkbot edited a comment on pull request #15110: URL: https://github.com/apache/flink/pull/15110#issuecomment-792438797 ## CI report: * e3cc98e078ac438d617b69a78d3ee5663df657c2 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15095: [FLINK-13554][runtime] Add a timeout for worker registration.

flinkbot edited a comment on pull request #15095: URL: https://github.com/apache/flink/pull/15095#issuecomment-791301808 ## CI report: * 55487801a298fe8c0aba7b246e4f1db7fd7eadc7 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15087: [FLINK-21299][table] Support 'SHOW [FULL] MODULES' syntax in SqlParser, TableEnvironment and SqlCli

flinkbot edited a comment on pull request #15087: URL: https://github.com/apache/flink/pull/15087#issuecomment-790639412 ## CI report: * 6f993020ae69c6d001399abdaf99683f55281146 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15060: [FLINK-19944][Connectors / Hive]Support sink parallelism configuratio…

flinkbot edited a comment on pull request #15060: URL: https://github.com/apache/flink/pull/15060#issuecomment-788795982 ## CI report: * f5e5565cd42d6600a421961e5a2cec3b560ea250 Azure:

[jira] [Created] (FLINK-21658) Align flink-benchmarks with job graph builder

Yun Tang created FLINK-21658: Summary: Align flink-benchmarks with job graph builder Key: FLINK-21658 URL: https://issues.apache.org/jira/browse/FLINK-21658 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-21657) flink doc fails to display a picture

zl created FLINK-21657: -- Summary: flink doc fails to display a picture Key: FLINK-21657 URL: https://issues.apache.org/jira/browse/FLINK-21657 Project: Flink Issue Type: Bug Components:

[GitHub] [flink] zhuzhurk removed a comment on pull request #15075: [FLINK-21525] Move scheduler benchmarks to Flink and add unit tests

zhuzhurk removed a comment on pull request #15075: URL: https://github.com/apache/flink/pull/15075#issuecomment-792476644 @Thesharing I prefer to narrow down the scope of this ticket to just do *Benchmark moving without adding new unit tests. Unit tests can be added later with more

[jira] [Updated] (FLINK-20740) Use managed memory (network memory) to avoid direct memory OOM error for sort-merge shuffle (introduce a separated buffer pool)

[ https://issues.apache.org/jira/browse/FLINK-20740?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yingjie Cao updated FLINK-20740: Summary: Use managed memory (network memory) to avoid direct memory OOM error for sort-merge

[jira] [Updated] (FLINK-20740) Use managed memory (network memory) to avoid direct memory OOM error for sort-merge shuffle

[ https://issues.apache.org/jira/browse/FLINK-20740?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yingjie Cao updated FLINK-20740: Description: Currently, sort-merge blocking shuffle uses some unmanaged memory for data writing

[jira] [Comment Edited] (FLINK-19142) Investigate slot hijacking from preceding pipelined regions after failover

[ https://issues.apache.org/jira/browse/FLINK-19142?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17297082#comment-17297082 ] Zhu Zhu edited comment on FLINK-19142 at 3/8/21, 6:59 AM: -- [~trohrmann] do you

[jira] [Comment Edited] (FLINK-19142) Investigate slot hijacking from preceding pipelined regions after failover

[ https://issues.apache.org/jira/browse/FLINK-19142?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17297082#comment-17297082 ] Zhu Zhu edited comment on FLINK-19142 at 3/8/21, 6:58 AM: -- [~trohrmann] do you

[GitHub] [flink] yulei0824 commented on pull request #15110: [FLINK-21579][table] Support "SHOW USER FUNCTIONS" statement

yulei0824 commented on pull request #15110: URL: https://github.com/apache/flink/pull/15110#issuecomment-792519062 Hello @wuchong, Do we implement "SHOW [function_kind] FUNCTIONS" sytanx ? The valid function kinds are USER, SYSTEM and ALL.

[GitHub] [flink] godfreyhe commented on a change in pull request #15006: [FLINK-21485][sql-client] Simplify the ExecutionContext

godfreyhe commented on a change in pull request #15006: URL: https://github.com/apache/flink/pull/15006#discussion_r589133210 ## File path: flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/context/SessionContext.java ## @@ -0,0 +1,269 @@ +/* +

[GitHub] [flink] flinkbot edited a comment on pull request #15095: [FLINK-13554][runtime] Add a timeout for worker registration.

flinkbot edited a comment on pull request #15095: URL: https://github.com/apache/flink/pull/15095#issuecomment-791301808 ## CI report: * 55487801a298fe8c0aba7b246e4f1db7fd7eadc7 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13025: [FLINK-18762][network] Make network buffers per incoming/outgoing channel can be configured separately

flinkbot edited a comment on pull request #13025: URL: https://github.com/apache/flink/pull/13025#issuecomment-666200437 ## CI report: * d562983dad16117b1beeb8a5ba72f3f699be31d2 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #11877: [FLINK-16641][network] Announce sender's backlog to solve the deadlock issue without exclusive buffers

flinkbot edited a comment on pull request #11877: URL: https://github.com/apache/flink/pull/11877#issuecomment-618273998 ## CI report: * 57cd88378e64e7c534d592d4538b2aa8222a2b00 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15111: [hotfix][javadoc] fix typos: paralelism->parallelism

flinkbot edited a comment on pull request #15111: URL: https://github.com/apache/flink/pull/15111#issuecomment-792485807 ## CI report: * 1d572b56765bf763a17f3fffa229a03c0320aa8d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15095: [FLINK-13554][runtime] Add a timeout for worker registration.

flinkbot edited a comment on pull request #15095: URL: https://github.com/apache/flink/pull/15095#issuecomment-791301808 ## CI report: * 55487801a298fe8c0aba7b246e4f1db7fd7eadc7 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15018: [FLINK-21460][table api] Use Configuration to create TableEnvironment

flinkbot edited a comment on pull request #15018: URL: https://github.com/apache/flink/pull/15018#issuecomment-785717193 ## CI report: * 61a067312ad95ce5f2a26e909ef688773a2c31d3 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13025: [FLINK-18762][network] Make network buffers per incoming/outgoing channel can be configured separately

flinkbot edited a comment on pull request #13025: URL: https://github.com/apache/flink/pull/13025#issuecomment-666200437 ## CI report: * d562983dad16117b1beeb8a5ba72f3f699be31d2 Azure:

[jira] [Commented] (FLINK-21038) jobmanager.sh may misinterpret webui-port argument

[ https://issues.apache.org/jira/browse/FLINK-21038?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17297094#comment-17297094 ] Yang Wang commented on FLINK-21038: --- Since this ticket will introduce incompatible changes for the

[GitHub] [flink] flinkbot edited a comment on pull request #11877: [FLINK-16641][network] Announce sender's backlog to solve the deadlock issue without exclusive buffers

flinkbot edited a comment on pull request #11877: URL: https://github.com/apache/flink/pull/11877#issuecomment-618273998 ## CI report: * 57cd88378e64e7c534d592d4538b2aa8222a2b00 Azure:

[jira] [Created] (FLINK-21656) Add antlr parser for hive dialect

Rui Li created FLINK-21656: -- Summary: Add antlr parser for hive dialect Key: FLINK-21656 URL: https://issues.apache.org/jira/browse/FLINK-21656 Project: Flink Issue Type: Sub-task

[jira] [Commented] (FLINK-21432) Web UI -- Error - {"errors":["Service temporarily unavailable due to an ongoing leader election. Please refresh."]}

[ https://issues.apache.org/jira/browse/FLINK-21432?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17297090#comment-17297090 ] Yang Wang commented on FLINK-21432: --- I do not think the environment variable "MY_POD_IP" will 

[GitHub] [flink] xintongsong commented on pull request #15095: [FLINK-13554][runtime] Add a timeout for worker registration.

xintongsong commented on pull request #15095: URL: https://github.com/apache/flink/pull/15095#issuecomment-792495223 Thanks for the review, @wangyang0918. Comments addressed. This is an automated message from the Apache Git

[jira] [Created] (FLINK-21655) Incorrect simplification for coalesce call on a groupingsets' result

lincoln lee created FLINK-21655: --- Summary: Incorrect simplification for coalesce call on a groupingsets' result Key: FLINK-21655 URL: https://issues.apache.org/jira/browse/FLINK-21655 Project: Flink

[GitHub] [flink] flinkbot commented on pull request #15111: [hotfix][javadoc] fix typos: paralelism->parallelism

flinkbot commented on pull request #15111: URL: https://github.com/apache/flink/pull/15111#issuecomment-792485807 ## CI report: * 1d572b56765bf763a17f3fffa229a03c0320aa8d UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Comment Edited] (FLINK-19142) Investigate slot hijacking from preceding pipelined regions after failover

[ https://issues.apache.org/jira/browse/FLINK-19142?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17297082#comment-17297082 ] Zhu Zhu edited comment on FLINK-19142 at 3/8/21, 5:44 AM: -- [~trohrmann] do you

[jira] [Commented] (FLINK-19142) Investigate slot hijacking from preceding pipelined regions after failover

[ https://issues.apache.org/jira/browse/FLINK-19142?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17297082#comment-17297082 ] Zhu Zhu commented on FLINK-19142: - [~trohrmann] do you mean a case like this? - Previously bulk_1 uses

[GitHub] [flink] xintongsong commented on a change in pull request #15095: [FLINK-13554][runtime] Add a timeout for worker registration.

xintongsong commented on a change in pull request #15095: URL: https://github.com/apache/flink/pull/15095#discussion_r589181652 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/active/ActiveResourceManager.java ## @@ -235,6 +241,8 @@ public

[GitHub] [flink] flinkbot commented on pull request #15111: [hotfix][javadoc] fix typos: paralelism->parallelism

flinkbot commented on pull request #15111: URL: https://github.com/apache/flink/pull/15111#issuecomment-792480647 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

[GitHub] [flink] Sunt-ing opened a new pull request #15111: [hotfix][javadoc] fix typos: paralelism->parallelism

Sunt-ing opened a new pull request #15111: URL: https://github.com/apache/flink/pull/15111 ## What is the purpose of the change Fix a typo in code: paralelism/parallism->parallelism ## Brief change log I noticed the typo "paralelism", so I replaced them with

[jira] [Updated] (FLINK-21525) Move scheduler benchmarks to Flink

[ https://issues.apache.org/jira/browse/FLINK-21525?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhilong Hong updated FLINK-21525: - Summary: Move scheduler benchmarks to Flink (was: Move scheduler benchmarks to Flink and add

[jira] [Commented] (FLINK-20654) Unaligned checkpoint recovery may lead to corrupted data stream

[ https://issues.apache.org/jira/browse/FLINK-20654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17297080#comment-17297080 ] Liwei Lin commented on FLINK-20654: --- Hi [~pnowojski], very appreciated for your detailed explanation!

[GitHub] [flink] zhuzhurk commented on pull request #15075: [FLINK-21525] Move scheduler benchmarks to Flink and add unit tests

zhuzhurk commented on pull request #15075: URL: https://github.com/apache/flink/pull/15075#issuecomment-792476644 @Thesharing I prefer to narrow down the scope of this ticket to just do *Benchmark moving without adding new unit tests. Unit tests can be added later with more discussion

[GitHub] [flink] wuchong commented on pull request #15110: [FLINK-21579][table] Support "SHOW USER FUNCTIONS" statement

wuchong commented on pull request #15110: URL: https://github.com/apache/flink/pull/15110#issuecomment-792476221 Yes. That's what I mean. This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [flink] flinkbot edited a comment on pull request #13025: [FLINK-18762][network] Make network buffers per incoming/outgoing channel can be configured separately

flinkbot edited a comment on pull request #13025: URL: https://github.com/apache/flink/pull/13025#issuecomment-666200437 ## CI report: * d562983dad16117b1beeb8a5ba72f3f699be31d2 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #11877: [FLINK-16641][network] Announce sender's backlog to solve the deadlock issue without exclusive buffers

flinkbot edited a comment on pull request #11877: URL: https://github.com/apache/flink/pull/11877#issuecomment-618273998 ## CI report: * 57cd88378e64e7c534d592d4538b2aa8222a2b00 Azure:

[jira] [Updated] (FLINK-21654) YARNSessionCapacitySchedulerITCase.testStartYarnSessionClusterInQaTeamQueue fail because of NullPointerException

[ https://issues.apache.org/jira/browse/FLINK-21654?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma updated FLINK-21654: -- Labels: test-stability (was: ) >

[GitHub] [flink] flinkbot edited a comment on pull request #15104: [FLINK-21635][connectors/jdbc] Support optional driverName in jdbc connection establishment

flinkbot edited a comment on pull request #15104: URL: https://github.com/apache/flink/pull/15104#issuecomment-792303376 ## CI report: * b58ceb640451e6ad7277a4b032b323f43583554a Azure:

[GitHub] [flink] yulei0824 commented on pull request #15110: [FLINK-21579][table] Support "SHOW USER FUNCTIONS" statement

yulei0824 commented on pull request #15110: URL: https://github.com/apache/flink/pull/15110#issuecomment-792469508 > Thanks for the contribution @yulei0824 . However, I think `SHOW USER FUNCTIONS` is a subset of `SHOW FUNCTIONS`. We don't need to implement an independent sytnax. `USER` is

[GitHub] [flink] wangyang0918 commented on a change in pull request #15095: [FLINK-13554][runtime] Add a timeout for worker registration.

wangyang0918 commented on a change in pull request #15095: URL: https://github.com/apache/flink/pull/15095#discussion_r589146194 ## File path: flink-kubernetes/src/main/java/org/apache/flink/kubernetes/kubeclient/resources/KubernetesPod.java ## @@ -42,6 +43,17 @@ public

[GitHub] [flink] flinkbot edited a comment on pull request #15104: [FLINK-21635][connectors/jdbc] Support optional driverName in jdbc connection establishment

flinkbot edited a comment on pull request #15104: URL: https://github.com/apache/flink/pull/15104#issuecomment-792303376 ## CI report: * b58ceb640451e6ad7277a4b032b323f43583554a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15075: [FLINK-21525] Move scheduler benchmarks to Flink and add unit tests

flinkbot edited a comment on pull request #15075: URL: https://github.com/apache/flink/pull/15075#issuecomment-789602188 ## CI report: * 065d7e810ae5548dafb6cc4782f6ec92cd20932e Azure:

[GitHub] [flink] kezhuw commented on a change in pull request #15104: [FLINK-21635][connectors/jdbc] Support optional driverName in jdbc connection establishment

kezhuw commented on a change in pull request #15104: URL: https://github.com/apache/flink/pull/15104#discussion_r589166185 ## File path: flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/internal/connection/SimpleJdbcConnectionProvider.java

[jira] [Created] (FLINK-21654) YARNSessionCapacitySchedulerITCase.testStartYarnSessionClusterInQaTeamQueue fail because of NullPointerException

Guowei Ma created FLINK-21654: - Summary: YARNSessionCapacitySchedulerITCase.testStartYarnSessionClusterInQaTeamQueue fail because of NullPointerException Key: FLINK-21654 URL:

[GitHub] [flink] flinkbot edited a comment on pull request #15103: [FLINK-21612][table-planner-blink] Support StreamExecGroupAggregate json serialization/deserialization

flinkbot edited a comment on pull request #15103: URL: https://github.com/apache/flink/pull/15103#issuecomment-792244189 ## CI report: * e20294a097497a20e4a3db5317c7b81a30a971c6 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15075: [FLINK-21525] Move scheduler benchmarks to Flink and add unit tests

flinkbot edited a comment on pull request #15075: URL: https://github.com/apache/flink/pull/15075#issuecomment-789602188 ## CI report: * 065d7e810ae5548dafb6cc4782f6ec92cd20932e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13025: [FLINK-18762][network] Make network buffers per incoming/outgoing channel can be configured separately

flinkbot edited a comment on pull request #13025: URL: https://github.com/apache/flink/pull/13025#issuecomment-666200437 ## CI report: * 1a246ceb679a7982ae563363058d23367d605877 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #11877: [FLINK-16641][network] Announce sender's backlog to solve the deadlock issue without exclusive buffers

flinkbot edited a comment on pull request #11877: URL: https://github.com/apache/flink/pull/11877#issuecomment-618273998 ## CI report: * 1440a6f1d30fc6cb7f4107facb3f9a5d08f34e87 Azure:

[GitHub] [flink] wuchong commented on pull request #15110: [FLINK-21579][table] Support "SHOW USER FUNCTIONS" statement

wuchong commented on pull request #15110: URL: https://github.com/apache/flink/pull/15110#issuecomment-792449408 Thanks for the contribution @yulei0824 . However, I think `SHOW USER FUNCTIONS` is a subset of `SHOW FUNCTIONS`. We don't need to implement an independent sytnax. `USER` is

[GitHub] [flink] flinkbot edited a comment on pull request #15110: [FLINK-21579][table] Support "SHOW USER FUNCTIONS" statement

flinkbot edited a comment on pull request #15110: URL: https://github.com/apache/flink/pull/15110#issuecomment-792438797 ## CI report: * e3cc98e078ac438d617b69a78d3ee5663df657c2 Azure:

[jira] [Commented] (FLINK-21503) Tests time out on azure

[ https://issues.apache.org/jira/browse/FLINK-21503?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17297056#comment-17297056 ] Guowei Ma commented on FLINK-21503: --- I found the 1.12 branch test is hanged by a

[GitHub] [flink] flinkbot edited a comment on pull request #15087: [FLINK-21299][table] Support 'SHOW [FULL] MODULES' syntax in SqlParser, TableEnvironment and SqlCli

flinkbot edited a comment on pull request #15087: URL: https://github.com/apache/flink/pull/15087#issuecomment-790639412 ## CI report: * 9ffda823695c3895a480ac8f68f68358b2ee17c3 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15075: [FLINK-21525] Move scheduler benchmarks to Flink and add unit tests

flinkbot edited a comment on pull request #15075: URL: https://github.com/apache/flink/pull/15075#issuecomment-789602188 ## CI report: * 065d7e810ae5548dafb6cc4782f6ec92cd20932e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15060: [FLINK-19944][Connectors / Hive]Support sink parallelism configuratio…

flinkbot edited a comment on pull request #15060: URL: https://github.com/apache/flink/pull/15060#issuecomment-788795982 ## CI report: * Unknown: [CANCELED](TBD) * f5e5565cd42d6600a421961e5a2cec3b560ea250 Azure:

[GitHub] [flink] wuchong commented on a change in pull request #15104: [FLINK-21635][connectors/jdbc] Support optional driverName in jdbc connection establishment

wuchong commented on a change in pull request #15104: URL: https://github.com/apache/flink/pull/15104#discussion_r589155192 ## File path: flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/internal/connection/SimpleJdbcConnectionProvider.java

[GitHub] [flink] Thesharing commented on pull request #15075: [FLINK-21525] Move scheduler benchmarks to Flink and add unit tests

Thesharing commented on pull request #15075: URL: https://github.com/apache/flink/pull/15075#issuecomment-792443632 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [flink] flinkbot edited a comment on pull request #13025: [FLINK-18762][network] Make network buffers per incoming/outgoing channel can be configured separately

flinkbot edited a comment on pull request #13025: URL: https://github.com/apache/flink/pull/13025#issuecomment-666200437 ## CI report: * 1a246ceb679a7982ae563363058d23367d605877 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #11877: [FLINK-16641][network] Announce sender's backlog to solve the deadlock issue without exclusive buffers

flinkbot edited a comment on pull request #11877: URL: https://github.com/apache/flink/pull/11877#issuecomment-618273998 ## CI report: * 1440a6f1d30fc6cb7f4107facb3f9a5d08f34e87 Azure:

[jira] [Commented] (FLINK-19449) LEAD/LAG cannot work correctly in streaming mode

[ https://issues.apache.org/jira/browse/FLINK-19449?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17297055#comment-17297055 ] laiyijie commented on FLINK-19449: -- LI, Implementation  without the index may not be so good, but is a

[GitHub] [flink] flinkbot commented on pull request #15110: [FLINK-21579][table] Support "SHOW USER FUNCTIONS" statement

flinkbot commented on pull request #15110: URL: https://github.com/apache/flink/pull/15110#issuecomment-792438797 ## CI report: * e3cc98e078ac438d617b69a78d3ee5663df657c2 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #15087: [FLINK-21299][table] Support 'SHOW [FULL] MODULES' syntax in SqlParser, TableEnvironment and SqlCli

flinkbot edited a comment on pull request #15087: URL: https://github.com/apache/flink/pull/15087#issuecomment-790639412 ## CI report: * 9ffda823695c3895a480ac8f68f68358b2ee17c3 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15060: [FLINK-19944][Connectors / Hive]Support sink parallelism configuratio…

flinkbot edited a comment on pull request #15060: URL: https://github.com/apache/flink/pull/15060#issuecomment-788795982 ## CI report: * Unknown: [CANCELED](TBD) * f5e5565cd42d6600a421961e5a2cec3b560ea250 UNKNOWN Bot commands The @flinkbot bot supports the

[GitHub] [flink] shouweikun commented on pull request #15060: [FLINK-19944][Connectors / Hive]Support sink parallelism configuratio…

shouweikun commented on pull request #15060: URL: https://github.com/apache/flink/pull/15060#issuecomment-792436223 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message,

[jira] [Commented] (FLINK-21428) AdaptiveSchedulerSlotSharingITCase.testSchedulingOfJobRequiringSlotSharing fail

[ https://issues.apache.org/jira/browse/FLINK-21428?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17297051#comment-17297051 ] Guowei Ma commented on FLINK-21428: ---

[jira] [Closed] (FLINK-21653) org.apache.flink.streaming.scala.api.TextOutputFormatITCase.testPath failed because of "Not enough resources available for scheduling."

[ https://issues.apache.org/jira/browse/FLINK-21653?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma closed FLINK-21653. - Resolution: Duplicate > org.apache.flink.streaming.scala.api.TextOutputFormatITCase.testPath failed >

[jira] [Created] (FLINK-21653) org.apache.flink.streaming.scala.api.TextOutputFormatITCase.testPath failed because of "Not enough resources available for scheduling."

Guowei Ma created FLINK-21653: - Summary: org.apache.flink.streaming.scala.api.TextOutputFormatITCase.testPath failed because of "Not enough resources available for scheduling." Key: FLINK-21653 URL:

[GitHub] [flink] flinkbot edited a comment on pull request #15095: [FLINK-13554][runtime] Add a timeout for worker registration.

flinkbot edited a comment on pull request #15095: URL: https://github.com/apache/flink/pull/15095#issuecomment-791301808 ## CI report: * 6695d2b5d4fe378852161df5caddb98a4a94efec Azure:

[GitHub] [flink] wuchong commented on pull request #15087: [FLINK-21299][table] Support 'SHOW [FULL] MODULES' syntax in SqlParser, TableEnvironment and SqlCli

wuchong commented on pull request #15087: URL: https://github.com/apache/flink/pull/15087#issuecomment-792432314 I have rebased the PR and will merge it once build is passed. This is an automated message from the Apache Git

[GitHub] [flink] flinkbot edited a comment on pull request #15020: [FLINK-21445][kubernetes] Application mode does not set the configuration when building PackagedProgram

flinkbot edited a comment on pull request #15020: URL: https://github.com/apache/flink/pull/15020#issuecomment-785804760 ## CI report: * 58698d9f356ec39088d65a51c0907784eb482c72 Azure:

[jira] [Updated] (FLINK-21652) Elasticsearch6DynamicSinkITCase.testWritingDocumentsFromTableApi failed because of throwing SocketTimeoutException during the closing stage.

[ https://issues.apache.org/jira/browse/FLINK-21652?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma updated FLINK-21652: -- Summary: Elasticsearch6DynamicSinkITCase.testWritingDocumentsFromTableApi failed because of throwing

[jira] [Assigned] (FLINK-21651) Migrate module-related tests in LocalExecutorITCase to new integration test framework

[ https://issues.apache.org/jira/browse/FLINK-21651?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-21651: --- Assignee: Jane Chan > Migrate module-related tests in LocalExecutorITCase to new integration test

[GitHub] [flink] flinkbot commented on pull request #15110: [FLINK-21579][table] Support "SHOW USER FUNCTIONS" statement

flinkbot commented on pull request #15110: URL: https://github.com/apache/flink/pull/15110#issuecomment-792431331 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

[jira] [Created] (FLINK-21652) Elasticsearch6DynamicSinkITCase.testWritingDocumentsFromTableApi failed because of throwing SocketTimeOut Exception during closing stage.

Guowei Ma created FLINK-21652: - Summary: Elasticsearch6DynamicSinkITCase.testWritingDocumentsFromTableApi failed because of throwing SocketTimeOut Exception during closing stage. Key: FLINK-21652 URL:

[GitHub] [flink] wuchong commented on a change in pull request #15087: [FLINK-21299][table] Support 'SHOW [FULL] MODULES' syntax in SqlParser, TableEnvironment and SqlCli

wuchong commented on a change in pull request #15087: URL: https://github.com/apache/flink/pull/15087#discussion_r589146077 ## File path: flink-table/flink-sql-parser-hive/src/main/codegen/includes/parserImpls.ftl ## @@ -1581,3 +1581,23 @@ SqlUseModules SqlUseModules() :

[jira] [Updated] (FLINK-21579) Support "SHOW USER FUNCTIONS" statement

[ https://issues.apache.org/jira/browse/FLINK-21579?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-21579: --- Labels: pull-request-available (was: ) > Support "SHOW USER FUNCTIONS" statement >

  1   2   3   >