 PyFlink 1.15 Documentationorg.apache.flink.table.planner.plan.nodes.exec.common.CommonExecSink. ˓→createSinkFunctionTransformation(CommonExecSink.java:331) at org.apache.flink.table.planner.plan.nodes.exec.common.CommonExecSink at org.apache.flink.table.planner.plan.nodes.exec.common.CommonExecSink. ˓→createSinkTransformation(CommonExecSink.java:146) at org.apache.flink.table.planner.plan.nodes.exec.stream.StreamExecSink. ˓→translateToPlanInternal(StreamExecSink.java:140) at org.apache.flink.table.planner.plan.nodes.exec.ExecNodeBase. ˓→translateToPlan(ExecNodeBase.java:134) This is an issue around Java 17. It still0 码力 | 36 页 | 266.77 KB | 1 年前3 PyFlink 1.15 Documentationorg.apache.flink.table.planner.plan.nodes.exec.common.CommonExecSink. ˓→createSinkFunctionTransformation(CommonExecSink.java:331) at org.apache.flink.table.planner.plan.nodes.exec.common.CommonExecSink at org.apache.flink.table.planner.plan.nodes.exec.common.CommonExecSink. ˓→createSinkTransformation(CommonExecSink.java:146) at org.apache.flink.table.planner.plan.nodes.exec.stream.StreamExecSink. ˓→translateToPlanInternal(StreamExecSink.java:140) at org.apache.flink.table.planner.plan.nodes.exec.ExecNodeBase. ˓→translateToPlan(ExecNodeBase.java:134) This is an issue around Java 17. It still0 码力 | 36 页 | 266.77 KB | 1 年前3
 PyFlink 1.16 Documentationorg.apache.flink.table.planner.plan.nodes.exec.common.CommonExecSink. ˓→createSinkFunctionTransformation(CommonExecSink.java:331) at org.apache.flink.table.planner.plan.nodes.exec.common.CommonExecSink at org.apache.flink.table.planner.plan.nodes.exec.common.CommonExecSink. ˓→createSinkTransformation(CommonExecSink.java:146) at org.apache.flink.table.planner.plan.nodes.exec.stream.StreamExecSink. ˓→translateToPlanInternal(StreamExecSink.java:140) at org.apache.flink.table.planner.plan.nodes.exec.ExecNodeBase. ˓→translateToPlan(ExecNodeBase.java:134) This is an issue around Java 17. It still0 码力 | 36 页 | 266.80 KB | 1 年前3 PyFlink 1.16 Documentationorg.apache.flink.table.planner.plan.nodes.exec.common.CommonExecSink. ˓→createSinkFunctionTransformation(CommonExecSink.java:331) at org.apache.flink.table.planner.plan.nodes.exec.common.CommonExecSink at org.apache.flink.table.planner.plan.nodes.exec.common.CommonExecSink. ˓→createSinkTransformation(CommonExecSink.java:146) at org.apache.flink.table.planner.plan.nodes.exec.stream.StreamExecSink. ˓→translateToPlanInternal(StreamExecSink.java:140) at org.apache.flink.table.planner.plan.nodes.exec.ExecNodeBase. ˓→translateToPlan(ExecNodeBase.java:134) This is an issue around Java 17. It still0 码力 | 36 页 | 266.80 KB | 1 年前3
 Flow control and load shedding - CS 591 K1: Data Stream Processing and Analytics Spring 2020monitors input rates or other system metrics and can access information about the running query plan • It detects overload and decides what actions to take in order to maintain acceptable latency • detect overload quickly to avoid latency increase • monitor input rates • Where in the query plan? • dropping at the sources vs. dropping at bottleneck operators • How much load to shed? • enough Where in the query plan to drop tuples, which tuples, and how many • The question of where is equivalent to placing special drop operators in the best positions in the query plan • Drop operators0 码力 | 43 页 | 2.42 MB | 1 年前3 Flow control and load shedding - CS 591 K1: Data Stream Processing and Analytics Spring 2020monitors input rates or other system metrics and can access information about the running query plan • It detects overload and decides what actions to take in order to maintain acceptable latency • detect overload quickly to avoid latency increase • monitor input rates • Where in the query plan? • dropping at the sources vs. dropping at bottleneck operators • How much load to shed? • enough Where in the query plan to drop tuples, which tuples, and how many • The question of where is equivalent to placing special drop operators in the best positions in the query plan • Drop operators0 码力 | 43 页 | 2.42 MB | 1 年前3
 Apache Kyuubi 1.8.0-rc0 Documentationace,UseStat ement,SetN amespaceC ommand,Set Command, ResetComm and Comma-separated list of query plan names, in the form of simple class names, i.e, for SET abc=xyz, the value will be SetCommand. For Meaning Type Since use this config to exclude them and let them take effect. See also kyuubi.operation.plan.only.mode. kyuubi.operation.pl an.only.mode none Configures the statement performed mode, The value filter condition as city='${{USER.born_city}}' will be transformed to city='Guangzhou' in execution plan. More supported macros and usage refer to RANGER-3605 [https://issues.apache.org/jira/browse/RANGER-3605]0 码力 | 428 页 | 5.28 MB | 1 年前3 Apache Kyuubi 1.8.0-rc0 Documentationace,UseStat ement,SetN amespaceC ommand,Set Command, ResetComm and Comma-separated list of query plan names, in the form of simple class names, i.e, for SET abc=xyz, the value will be SetCommand. For Meaning Type Since use this config to exclude them and let them take effect. See also kyuubi.operation.plan.only.mode. kyuubi.operation.pl an.only.mode none Configures the statement performed mode, The value filter condition as city='${{USER.born_city}}' will be transformed to city='Guangzhou' in execution plan. More supported macros and usage refer to RANGER-3605 [https://issues.apache.org/jira/browse/RANGER-3605]0 码力 | 428 页 | 5.28 MB | 1 年前3
 Apache Kyuubi 1.8.0-rc1 Documentationace,UseStat ement,SetN amespaceC ommand,Set Command, ResetComm and Comma-separated list of query plan names, in the form of simple class names, i.e, for SET abc=xyz, the value will be SetCommand. For Meaning Type Since use this config to exclude them and let them take effect. See also kyuubi.operation.plan.only.mode. kyuubi.operation.pl an.only.mode none Configures the statement performed mode, The value filter condition as city='${{USER.born_city}}' will be transformed to city='Guangzhou' in execution plan. More supported macros and usage refer to RANGER-3605 [https://issues.apache.org/jira/browse/RANGER-3605]0 码力 | 429 页 | 5.28 MB | 1 年前3 Apache Kyuubi 1.8.0-rc1 Documentationace,UseStat ement,SetN amespaceC ommand,Set Command, ResetComm and Comma-separated list of query plan names, in the form of simple class names, i.e, for SET abc=xyz, the value will be SetCommand. For Meaning Type Since use this config to exclude them and let them take effect. See also kyuubi.operation.plan.only.mode. kyuubi.operation.pl an.only.mode none Configures the statement performed mode, The value filter condition as city='${{USER.born_city}}' will be transformed to city='Guangzhou' in execution plan. More supported macros and usage refer to RANGER-3605 [https://issues.apache.org/jira/browse/RANGER-3605]0 码力 | 429 页 | 5.28 MB | 1 年前3
 Apache Kyuubi 1.8.0 Documentationace,UseStat ement,SetN amespaceC ommand,Set Command, ResetComm and Comma-separated list of query plan names, in the form of simple class names, i.e, for SET abc=xyz, the value will be SetCommand. For Meaning Type Since use this config to exclude them and let them take effect. See also kyuubi.operation.plan.only.mode. kyuubi.operation.pl an.only.mode none Configures the statement performed mode, The value filter condition as city='${{USER.born_city}}' will be transformed to city='Guangzhou' in execution plan. More supported macros and usage refer to RANGER-3605 [https://issues.apache.org/jira/browse/RANGER-3605]0 码力 | 429 页 | 5.28 MB | 1 年前3 Apache Kyuubi 1.8.0 Documentationace,UseStat ement,SetN amespaceC ommand,Set Command, ResetComm and Comma-separated list of query plan names, in the form of simple class names, i.e, for SET abc=xyz, the value will be SetCommand. For Meaning Type Since use this config to exclude them and let them take effect. See also kyuubi.operation.plan.only.mode. kyuubi.operation.pl an.only.mode none Configures the statement performed mode, The value filter condition as city='${{USER.born_city}}' will be transformed to city='Guangzhou' in execution plan. More supported macros and usage refer to RANGER-3605 [https://issues.apache.org/jira/browse/RANGER-3605]0 码力 | 429 页 | 5.28 MB | 1 年前3
 Apache Kyuubi 1.7.1-rc0 Documentationmand,SetNa mespaceCo mmand,Use Statement,S etCatalogA ndNamespa ce Comma-separated list of query plan names, in the form of simple class names, i.e, for SET abc=xyz, the value will be SetCommand. For queries, we can use this config to exclude them and let them take effect. See also kyuubi.operation.plan.only.mode. seq 1.5.0 kyuubi.operation.pl an.only.mode none Configures the statement performed mode filter condition as city='${{USER.born_city}}' will be transformed to city='Guangzhou' in execution plan. More supported macros and usage refer to RANGER-3605 [https://issues.apache.org/jira/browse/RANGER-3605]0 码力 | 401 页 | 5.25 MB | 1 年前3 Apache Kyuubi 1.7.1-rc0 Documentationmand,SetNa mespaceCo mmand,Use Statement,S etCatalogA ndNamespa ce Comma-separated list of query plan names, in the form of simple class names, i.e, for SET abc=xyz, the value will be SetCommand. For queries, we can use this config to exclude them and let them take effect. See also kyuubi.operation.plan.only.mode. seq 1.5.0 kyuubi.operation.pl an.only.mode none Configures the statement performed mode filter condition as city='${{USER.born_city}}' will be transformed to city='Guangzhou' in execution plan. More supported macros and usage refer to RANGER-3605 [https://issues.apache.org/jira/browse/RANGER-3605]0 码力 | 401 页 | 5.25 MB | 1 年前3
 Apache Kyuubi 1.7.0-rc0 Documentationmand,SetNa mespaceCo mmand,Use Statement,S etCatalogA ndNamespa ce Comma-separated list of query plan names, in the form of simple class names, i.e, for SET abc=xyz, the value will be SetCommand. For queries, we can use this config to exclude them and let them take effect. See also kyuubi.operation.plan.only.mode. seq 1.5.0 kyuubi.operation.pl an.only.mode none Configures the statement performed mode filter condition as city='${{USER.born_city}}' will be transformed to city='Guangzhou' in execution plan. More supported macros and usage refer to RANGER-3605 [https://issues.apache.org/jira/browse/RANGER-3605]0 码力 | 404 页 | 5.25 MB | 1 年前3 Apache Kyuubi 1.7.0-rc0 Documentationmand,SetNa mespaceCo mmand,Use Statement,S etCatalogA ndNamespa ce Comma-separated list of query plan names, in the form of simple class names, i.e, for SET abc=xyz, the value will be SetCommand. For queries, we can use this config to exclude them and let them take effect. See also kyuubi.operation.plan.only.mode. seq 1.5.0 kyuubi.operation.pl an.only.mode none Configures the statement performed mode filter condition as city='${{USER.born_city}}' will be transformed to city='Guangzhou' in execution plan. More supported macros and usage refer to RANGER-3605 [https://issues.apache.org/jira/browse/RANGER-3605]0 码力 | 404 页 | 5.25 MB | 1 年前3
 Apache Kyuubi 1.7.0 Documentationmand,SetNa mespaceCo mmand,Use Statement,S etCatalogA ndNamespa ce Comma-separated list of query plan names, in the form of simple class names, i.e, for SET abc=xyz, the value will be SetCommand. For queries, we can use this config to exclude them and let them take effect. See also kyuubi.operation.plan.only.mode. seq 1.5.0 kyuubi.operation.pl an.only.mode none Configures the statement performed mode filter condition as city='${{USER.born_city}}' will be transformed to city='Guangzhou' in execution plan. More supported macros and usage refer to RANGER-3605 [https://issues.apache.org/jira/browse/RANGER-3605]0 码力 | 400 页 | 5.25 MB | 1 年前3 Apache Kyuubi 1.7.0 Documentationmand,SetNa mespaceCo mmand,Use Statement,S etCatalogA ndNamespa ce Comma-separated list of query plan names, in the form of simple class names, i.e, for SET abc=xyz, the value will be SetCommand. For queries, we can use this config to exclude them and let them take effect. See also kyuubi.operation.plan.only.mode. seq 1.5.0 kyuubi.operation.pl an.only.mode none Configures the statement performed mode filter condition as city='${{USER.born_city}}' will be transformed to city='Guangzhou' in execution plan. More supported macros and usage refer to RANGER-3605 [https://issues.apache.org/jira/browse/RANGER-3605]0 码力 | 400 页 | 5.25 MB | 1 年前3
 Apache Kyuubi 1.7.0-rc1 Documentationmand,SetNa mespaceCo mmand,Use Statement,S etCatalogA ndNamespa ce Comma-separated list of query plan names, in the form of simple class names, i.e, for SET abc=xyz, the value will be SetCommand. For queries, we can use this config to exclude them and let them take effect. See also kyuubi.operation.plan.only.mode. seq 1.5.0 kyuubi.operation.pl an.only.mode none Configures the statement performed mode filter condition as city='${{USER.born_city}}' will be transformed to city='Guangzhou' in execution plan. More supported macros and usage refer to RANGER-3605 [https://issues.apache.org/jira/browse/RANGER-3605]0 码力 | 400 页 | 5.25 MB | 1 年前3 Apache Kyuubi 1.7.0-rc1 Documentationmand,SetNa mespaceCo mmand,Use Statement,S etCatalogA ndNamespa ce Comma-separated list of query plan names, in the form of simple class names, i.e, for SET abc=xyz, the value will be SetCommand. For queries, we can use this config to exclude them and let them take effect. See also kyuubi.operation.plan.only.mode. seq 1.5.0 kyuubi.operation.pl an.only.mode none Configures the statement performed mode filter condition as city='${{USER.born_city}}' will be transformed to city='Guangzhou' in execution plan. More supported macros and usage refer to RANGER-3605 [https://issues.apache.org/jira/browse/RANGER-3605]0 码力 | 400 页 | 5.25 MB | 1 年前3
共 177 条
- 1
- 2
- 3
- 4
- 5
- 6
- 18














