[flink] branch master updated (c83bc65 -> 0477368)
This is an automated email from the ASF dual-hosted git repository. gary pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git. from c83bc65 [FLINK-11088] Add unit test for Kerberos parsing in YarnEntrypointUtilsTest add 0477368 [FLINK-14121] Update commons-compress because of CVE-2019-12402 No new revisions were added by this update. Summary of changes: flink-dist/src/main/resources/META-INF/NOTICE | 2 +- .../flink-oss-fs-hadoop/src/main/resources/META-INF/NOTICE | 2 +- .../flink-swift-fs-hadoop/src/main/resources/META-INF/NOTICE| 2 +- pom.xml | 2 +- 4 files changed, 4 insertions(+), 4 deletions(-)
[flink] branch master updated (3b99f7e -> c83bc65)
This is an automated email from the ASF dual-hosted git repository. aljoscha pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git. from 3b99f7e [FLINK-16554][task][refactoring] split StreamTask add 0920e64 [FLINK-11088] Allow YARN to discover pre-installed keytab files add ea8f0e3 [FLINK-11088] Refactor keytab resolution to Utils add 7f86f74 [FLINK-11088] Regenerate YARN/kerberos config docs add c83bc65 [FLINK-11088] Add unit test for Kerberos parsing in YarnEntrypointUtilsTest No new revisions were added by this update. Summary of changes: .../generated/yarn_config_configuration.html | 12 +++ .../runtime/security/SecurityConfiguration.java| 8 +- .../apache/flink/yarn/YARNSessionFIFOITCase.java | 17 ++-- .../flink/yarn/YARNSessionFIFOSecuredITCase.java | 92 +++--- .../src/main/java/org/apache/flink/yarn/Utils.java | 54 ++--- .../apache/flink/yarn/YarnClusterDescriptor.java | 24 -- .../java/org/apache/flink/yarn/YarnConfigKeys.java | 3 +- .../apache/flink/yarn/YarnTaskExecutorRunner.java | 20 ++--- .../yarn/configuration/YarnConfigOptions.java | 22 ++ .../flink/yarn/entrypoint/YarnEntrypointUtils.java | 16 +--- .../flink/yarn/YarnTaskExecutorRunnerTest.java | 40 +- .../yarn/entrypoint/YarnEntrypointUtilsTest.java | 40 +- 12 files changed, 259 insertions(+), 89 deletions(-)
[flink-web] branch asf-site updated: Rebuild website
This is an automated email from the ASF dual-hosted git repository. lzljs3620320 pushed a commit to branch asf-site in repository https://gitbox.apache.org/repos/asf/flink-web.git The following commit(s) were added to refs/heads/asf-site by this push: new ad290f6 Rebuild website ad290f6 is described below commit ad290f696a0c5d597211641e62c13af14d45a9da Author: 之信 AuthorDate: Fri Mar 13 21:09:45 2020 +0800 Rebuild website --- content/community.html| 6 ++ content/zh/community.html | 6 ++ 2 files changed, 12 insertions(+) diff --git a/content/community.html b/content/community.html index 7f7bb6a..8cb9eeb 100644 --- a/content/community.html +++ b/content/community.html @@ -539,6 +539,12 @@ nkruber +https://avatars1.githubusercontent.com/u/9601882?s=50; class="committer-avatar" /> +Jingsong Lee +Committer +lzljs3620320 + + https://avatars1.githubusercontent.com/u/1892692?s=50; class="committer-avatar" /> Bowen Li Committer diff --git a/content/zh/community.html b/content/zh/community.html index f855da0..74d763d 100644 --- a/content/zh/community.html +++ b/content/zh/community.html @@ -530,6 +530,12 @@ nkruber +https://avatars1.githubusercontent.com/u/9601882?s=50; class="committer-avatar" /> +Jingsong Lee +Committer +lzljs3620320 + + https://avatars1.githubusercontent.com/u/1892692?s=50; class="committer-avatar" /> Bowen Li Committer
[flink-web] branch asf-site updated: Add committer Jingsong Lee to community page
This is an automated email from the ASF dual-hosted git repository. lzljs3620320 pushed a commit to branch asf-site in repository https://gitbox.apache.org/repos/asf/flink-web.git The following commit(s) were added to refs/heads/asf-site by this push: new 06453b8 Add committer Jingsong Lee to community page 06453b8 is described below commit 06453b8b18dcb32383d79337be1d314ce7a4100c Author: Jingsong Lee AuthorDate: Fri Mar 13 21:07:28 2020 +0800 Add committer Jingsong Lee to community page This closes #313 --- community.md| 6 ++ community.zh.md | 6 ++ 2 files changed, 12 insertions(+) diff --git a/community.md b/community.md index f0e7bf6..46b5767 100644 --- a/community.md +++ b/community.md @@ -322,6 +322,12 @@ Flink Forward is a conference happening yearly in different locations around the nkruber +https://avatars1.githubusercontent.com/u/9601882?s=50; class="committer-avatar"> +Jingsong Lee +Committer +lzljs3620320 + + https://avatars1.githubusercontent.com/u/1892692?s=50; class="committer-avatar"> Bowen Li Committer diff --git a/community.zh.md b/community.zh.md index cb0fe24..7940206 100644 --- a/community.zh.md +++ b/community.zh.md @@ -311,6 +311,12 @@ Flink Forward 大会每年都会在世界的不同地方举办。关于大会最 nkruber +https://avatars1.githubusercontent.com/u/9601882?s=50; class="committer-avatar"> +Jingsong Lee +Committer +lzljs3620320 + + https://avatars1.githubusercontent.com/u/1892692?s=50; class="committer-avatar"> Bowen Li Committer
[flink] branch master updated (6126600 -> 3b99f7e)
This is an automated email from the ASF dual-hosted git repository. zhijiang pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git. from 6126600 [FLINK-16261][table] Use type compatibility consistently to avoid casting add 3b99f7e [FLINK-16554][task][refactoring] split StreamTask No new revisions were added by this update. Summary of changes: .../runtime/tasks/AsyncCheckpointRunnable.java | 256 +++ .../runtime/tasks/CheckpointingOperation.java | 136 .../flink/streaming/runtime/tasks/StreamTask.java | 355 + .../runtime/tasks/LocalStateForwardingTest.java| 16 +- 4 files changed, 409 insertions(+), 354 deletions(-) create mode 100644 flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/AsyncCheckpointRunnable.java create mode 100644 flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/CheckpointingOperation.java
svn commit: r38502 - /release/flink/KEYS
Author: jincheng Date: Fri Mar 13 12:55:26 2020 New Revision: 38502 Log: Add KEY for Yu Li Modified: release/flink/KEYS Modified: release/flink/KEYS == --- release/flink/KEYS (original) +++ release/flink/KEYS Fri Mar 13 12:55:26 2020 @@ -1764,3 +1764,62 @@ bdBQn5N9SpDTqE4moVe2Pc9aWPPj4en+EEjgWoSC DTA= =o0P4 -END PGP PUBLIC KEY BLOCK- +pub rsa4096 2019-08-29 [SC] + D8D3D42E84C753CA5F170BDF93C07902771AB743 +uid [ultimate] Yu Li (CODE SIGNING KEY) +sig 393C07902771AB743 2019-08-29 Yu Li (CODE SIGNING KEY) +sub rsa4096 2019-08-29 [E] +sig 93C07902771AB743 2019-08-29 Yu Li (CODE SIGNING KEY) + +-BEGIN PGP PUBLIC KEY BLOCK- + +mQINBF1nH5kBEACvfpza6VlMFn/mwLOD2mnxJWBxEatau3KKTuTpj4ygByvt2/AP +5mwXkFzBBBiVvz0y+CYnj8jDcXhgV3Xe+e8Dpc5svV25ezsoAQq6BPXhJayzTFnG +AtypvRCv9IwaePBRxmaP68M/RtgYlgIxwFMzF07ntMMsz9MXiBQJfpL4Am685Ywi +iX2aAGnS+ikMFTI19ENMv32d+0Arg0Klfrmb2KMUkjFVEidc2noamIcZ8QlFwzAh +/RT/7juGNSJ68rG6+9Ya5KmCJYY1BqOq2LQC1H7Ba3oHCyMYHfFl1PUi+S+CtiIJ +aO59Zht8+kQ7X9W4UydGy/XegtT4ivktjXmhysQTYfaj9RVmQvXXG/OGIdyW+jQb ++3/ZWr4cQsye/jW9LHBWtEq0t/+xb+3WkjBAPWSAPYNEWhJN7yqJayGAhyPTNink +tBp6UfOKnPDVu08R0SYHqBP+ks50lyWHBJDqhRwoeYRY+fs5dn9DmMuqWkS21w+L +NkHKhCW+UNhxhzL96ASqAYJoc5Vn8wVwp7oPNi/3aWUdvup/Lq/g2utUq+zipRG/ +RB9/Dcg8m26hEnLidIOJ6Y8uFCjtwtcsXR0597UxvKYrsMItfaLZy9BNsLdejs+N +S2AiaxFDm/Dm93xgPVyZhxH1O5eg7ev3X6Nf4ckXoubWsbaEJpNadmvoqwARAQAB +tCpZdSBMaSAoQ09ERSBTSUdOSU5HIEtFWSkgPGxpeXVAYXBhY2hlLm9yZz6JAk4E +EwEKADgWIQTY09QuhMdTyl8XC9+TwHkCdxq3QwUCXWcfmQIbAwULCQgHAwUVCgkI +CwUWAgMBAAIeAQIXgAAKCRCTwHkCdxq3Q6ekD/9N88rU2lsZyABLDNGWWJf+qzPH +kneujxY8HYIsxF5paHdHJbKKcLxMch26grhijLQtqlE2CcHANgiui+ispFoSTF0t +jiDvofai+PFjF+o9SEMypKq/GstwpTQ1t3i0G8gpBROu+5g7regFmlGqhbYQG+Sf +0pHtTYkm5AxM83AMGQLpavZWXjPegj7ANPLf/8SnfxeDCsTJlpnqsWqnigKoWQDh +TH8WH9Nv881GqknKlt1Yb5aqjOwFn5MlKxjX7LszbGdyUqRpYCmtc/mxYPWgWDc6 +1CTF5eVTNQfuBSA/xMR/8EekMmOcCBeMTaeEGPU+cmo2TKnKhDsudOR/PDg2kXoM +sj+b7GF07lvragv7psN7MScPnN4DJrWa7M8Uo41CB6Zz3eml+ngOC80pHSP+lGWv +NGlaHHYS1vA/hW306aDA5dgAMcs84M3z0jJ1KmmU1sn3QwF+ukaf1G6pukQi0rQt +pSftD9IIySeM7naT16WwVC1fFOtB4iwWUauvMNCjpf0kSN+gJTyFBysLCtltmpxI +krllW/EJkKQzsIwZJ3AkFdVPgDe6eJD7NJ/pteNV2MmiPFEl9q1qJ/2gtdNcmKCQ +v8THjtyAWRNnSsXiP18lOqzz4ftnAcsSpebb6z1JkWrkTwDDokuzlqkR3i85Yvg8 +s/Xng1VwGTJSZkUDdrkCDQRdZx+ZARAAwUuZMEz6cg9PSLfaYW3rqkm5U5jAvChO +91KwIHbIsrN5wsR5BfZVsCTCR3fZJVxlE0H5Vk9IrhMYPQcC9hPdZthDIGJ1bsJu +oT42RR9mmuETYd/HRvULu083m7YDkaNRhHcjoQShYy4NVC/ijTn22LdRval6drmz +NAqtiFKsAvv7W0UfkBLOn3mTeGRd5J1llvb8Rve468iAecj4WxN11/J8eNtLYodn +fLugjKKDonGCrAeSdNeINuM3TKDsaQtHTT7uIl288P83Z7Ldm5oq2wZbwh3FY7Q8 +YZRYpaDQWRxOul8SM4DMKcg/CHk5mH7p0N4P+LWkCbW3HbblDnzPkTW8MA3JVzOt ++YhP3AP6ugvPZvDxjt0gYdqAFpqKTnOG8hk4SzOkQZ3wKbn1CAy0WDBKqN+a6ZHc +IPDCOgb2vsywT3Vww+dgKr3SctZKkD7fFzqo8ISXyuhqgDrSoTjH7EXpiVFkgXkS +b2ZkW+twDZIz67FdIh+Mdsn0U7frjSocYQEUOM8CRxBC+N7oU2qjgu23fC96jcUf +XPzd6gzvlkkL43506YlJcIh9/CpMNxJwZOzO1yPHF3ovz8XAmkQ28yIdMFt9YP/m +G0s+cc+N8Em/nLyJessdAhuAzm8SQRddtsAXKxWiaH+ZvXtp32kzQkdWUeFMY0AG +KDNUIqVweg0AEQEAAYkCNgQYAQoAIBYhBNjT1C6Ex1PKXxcL35PAeQJ3GrdDBQJd +Zx+ZAhsMAAoJEJPAeQJ3GrdDSB0QAJGdwyTkqsyypKrs6lJ7TQMMVzUEGmfYZbIQ +D3oVLfs19+hWtX3b1Gu+TKCb/v3EJ46VAG/1vjUb3l4GQzlJkRSWoYkhAe8RRLXR +YHRo0renr3MS0xRvtqhYloRwtnL0rQRREnrdlVQMR0kJeDDcIUC54AuPXyFTmi+C +oTbyYjoPTnqK0QM89WeMdr0WAkXlBNr5Er5USiyJn7wi0qwvjn+a8gOZ35pMUmMH +o3AenLTgPkKu12P+mHfYfPKqfn3adurZ4uesdWm2b7gDdsTz3XmM49QITXEVnk61 +wTDYHLAOiK0px3dlcXfnR6uO9qGeTfr9qHj92uKaDGjidUL50dkV53WnYIrkFpMK +P9KzSTMyOTAs2Hk9iz9QefGIH8HpBgQVRPE06i5uk3lWuSoP9YhJulwp3mJG4o/H +Vlr/Y7ypALd8bZ+kMtWFzQRNrQfp0MDn6QbPNvJ4y2Q90MCB6Q34KkbBY5O4Gxj1 +PFVcnH+6DTs/i8TVho4VUd72CMSzZ3sfc8XssMU9G2iyhKotWMDi6+4k69joUiPQ +BizgLBrKDr+0OQDcdcuXme2s16fhx7Ly+WEVtzi502nEsb1vYcyj4HJnWupYkDlJ +XsJeobCqzKNL8uowvoOcsfalfEn6PSCSO7tyUlUbA0s//IPt9/BhmLS/pXVgToSs +0CWBS+8V +=fg3B +-END PGP PUBLIC KEY BLOCK-
[flink] branch master updated (d6038cc -> 6126600)
This is an automated email from the ASF dual-hosted git repository.
twalthr pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from d6038cc [FLINK-16524][python] Optimize the Python UDF execution to
use generator to eliminate unnecessary function calls (#11374)
add 6126600 [FLINK-16261][table] Use type compatibility consistently to
avoid casting
No new revisions were added by this update.
Summary of changes:
.../resolver/rules/ResolveCallByArgumentsRule.java | 4 +-
.../strategies/AndArgumentTypeStrategy.java| 4 +-
.../strategies/ExplicitArgumentTypeStrategy.java | 8 +-
.../inference/strategies/MappingTypeStrategy.java | 6 +-
.../strategies/OrArgumentTypeStrategy.java | 6 +-
.../inference/strategies/OrInputTypeStrategy.java | 10 +-
.../types/logical/utils/LogicalTypeCasts.java | 115 +
.../types/logical/utils/LogicalTypeChecks.java | 60 ---
.../apache/flink/table/utils/TypeMappingUtils.java | 3 +-
...Test.java => LogicalTypeCastAvoidanceTest.java} | 80 ++
.../types/inference/InputTypeStrategiesTest.java | 7 ++
.../table/types/inference/TypeStrategiesTest.java | 7 ++
.../inference/TypeInferenceOperandChecker.java | 13 ++-
.../codegen/calls/BridgingSqlFunctionCallGen.scala | 8 +-
.../flink/table/planner/sinks/TableSinkUtils.scala | 23 ++---
.../planner/runtime/stream/sql/FunctionITCase.java | 37 ++-
16 files changed, 268 insertions(+), 123 deletions(-)
rename
flink-table/flink-table-common/src/test/java/org/apache/flink/table/types/{LogicalTypeCompatibleCheckTest.java
=> LogicalTypeCastAvoidanceTest.java} (76%)
[flink] branch master updated (22915d0 -> d6038cc)
This is an automated email from the ASF dual-hosted git repository.
dianfu pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 22915d0 [FLINK-16464][sql-client] Result-mode tableau may shift when
content contains Chinese string in SQL CLI (#11334)
add d6038cc [FLINK-16524][python] Optimize the Python UDF execution to
use generator to eliminate unnecessary function calls (#11374)
No new revisions were added by this update.
Summary of changes:
flink-python/pyflink/fn_execution/coder_impl.py| 119 +++--
flink-python/pyflink/fn_execution/coders.py| 21 +++-
flink-python/pyflink/fn_execution/operations.py| 30 ++
...coders_test_common.py => test_coders_common.py} | 17 ++-
4 files changed, 132 insertions(+), 55 deletions(-)
rename flink-python/pyflink/fn_execution/tests/{coders_test_common.py =>
test_coders_common.py} (88%)
[flink] branch master updated (2424301 -> 22915d0)
This is an automated email from the ASF dual-hosted git repository. kurt pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git. from 2424301 [FLINK-16538][python][docs] Restructure Python Table API documentation (#11375) add 22915d0 [FLINK-16464][sql-client] Result-mode tableau may shift when content contains Chinese string in SQL CLI (#11334) No new revisions were added by this update. Summary of changes: flink-table/flink-sql-client/pom.xml | 8 + .../table/client/cli/CliTableauResultView.java | 34 +- .../apache/flink/table/client/cli/CliUtils.java| 31 ++ .../src/main/resources/META-INF/NOTICE | 1 + .../main/resources/META-INF/licenses/LICENSE.icu4j | 414 + .../table/client/cli/CliTableauResultViewTest.java | 61 ++- .../flink/table/client/cli/CliUtilsTest.java | 25 ++ 7 files changed, 553 insertions(+), 21 deletions(-) create mode 100644 flink-table/flink-sql-client/src/main/resources/META-INF/licenses/LICENSE.icu4j
[flink] branch master updated (ae1d1b2 -> 2424301)
This is an automated email from the ASF dual-hosted git repository.
hequn pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from ae1d1b2 [FLINK-16008][python][table-planner][table-planner-blink] Add
rules to transpose the join condition as a Calc on top of the Python Correlate
node (#11299)
add 2424301 [FLINK-16538][python][docs] Restructure Python Table API
documentation (#11375)
No new revisions were added by this update.
Summary of changes:
docs/dev/table/config.md | 4 -
docs/dev/table/config.zh.md| 4 -
docs/dev/table/functions/udfs.md | 149 ++---
docs/dev/table/functions/udfs.zh.md| 149 ++---
docs/dev/table/python/dependency_management.md | 94 +
docs/dev/table/python/dependency_management.zh.md | 94 +
docs/dev/table/python/index.md | 35 +
docs/dev/table/python/index.zh.md | 35 +
.../index.md => dev/table/python/installation.md} | 27 +++-
.../table/python/installation.zh.md} | 27 +++-
.../{tuning/index.md => python/python_config.md} | 15 ++-
.../index.md => python/python_config.zh.md}| 15 ++-
docs/dev/table/python/python_udfs.md | 125 +
docs/dev/table/python/python_udfs.zh.md| 125 +
.../walkthroughs/python_table_api.md | 16 +--
.../walkthroughs/python_table_api.zh.md| 12 +-
docs/ops/python_shell.md | 7 +-
docs/ops/python_shell.zh.md| 7 +-
18 files changed, 598 insertions(+), 342 deletions(-)
create mode 100644 docs/dev/table/python/dependency_management.md
create mode 100644 docs/dev/table/python/dependency_management.zh.md
create mode 100644 docs/dev/table/python/index.md
create mode 100644 docs/dev/table/python/index.zh.md
copy docs/{getting-started/docker-playgrounds/index.md =>
dev/table/python/installation.md} (52%)
copy docs/{getting-started/docker-playgrounds/index.md =>
dev/table/python/installation.zh.md} (52%)
copy docs/dev/table/{tuning/index.md => python/python_config.md} (55%)
copy docs/dev/table/{tuning/index.md => python/python_config.zh.md} (55%)
create mode 100644 docs/dev/table/python/python_udfs.md
create mode 100644 docs/dev/table/python/python_udfs.zh.md
