[flink] branch master updated (8f665be -> 5984d52)
This is an automated email from the ASF dual-hosted git repository. jark pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git. from 8f665be [FLINK-14865][python] fix unstable tests PyFlinkBlinkStreamUserDefinedFunctionTests#test_udf_in_join_condition_2 add 5984d52 [FLINK-14892][docs] Add documentation for checkpoint directory layout (#10305) No new revisions were added by this update. Summary of changes: docs/ops/state/checkpoints.md| 18 ++ docs/ops/state/checkpoints.zh.md | 18 ++ 2 files changed, 36 insertions(+)
[flink] branch master updated (e08e29e -> 8f665be)
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 e08e29e [FLINK-14885][client] YarnClusterDescriptor should not know about detached option add 8f665be [FLINK-14865][python] fix unstable tests PyFlinkBlinkStreamUserDefinedFunctionTests#test_udf_in_join_condition_2 No new revisions were added by this update. Summary of changes: .../flink/client/python/PythonDriverEnvUtils.java | 4 +- .../client/python/PythonResourceExtractor.java | 3 +- .../flink/python/AbstractPythonFunctionRunner.java | 3 +- .../org/apache/flink/python/util/ResourceUtil.java | 71 ++ .../client/python/PythonDriverEnvUtilsTest.java| 2 +- .../apache/flink/python/util/ResourceUtilTest.java | 5 +- 6 files changed, 51 insertions(+), 37 deletions(-)
[flink] branch master updated (9abe977 -> e08e29e)
This is an automated email from the ASF dual-hosted git repository. tison pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git. from 9abe977 [FLINK-14506][python][build] Improve the release script for Python API release package add e08e29e [FLINK-14885][client] YarnClusterDescriptor should not know about detached option No new revisions were added by this update. Summary of changes: .../apache/flink/yarn/YarnClusterDescriptor.java | 29 +++--- .../java/org/apache/flink/yarn/YarnConfigKeys.java | 1 - .../apache/flink/yarn/cli/FlinkYarnSessionCli.java | 2 +- .../apache/flink/yarn/FlinkYarnSessionCliTest.java | 12 +++-- 4 files changed, 14 insertions(+), 30 deletions(-)
[flink] branch master updated (75427bf -> 9abe977)
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 75427bf [FLINK-14874][table-planner-blink] add local aggregation to solve data skew for ROLLUP/CUBE add 9abe977 [FLINK-14506][python][build] Improve the release script for Python API release package No new revisions were added by this update. Summary of changes: flink-python/dev/lint-python.sh | 149 ++- tools/releasing/create_binary_release.sh | 4 + 2 files changed, 132 insertions(+), 21 deletions(-)
[flink] branch master updated (89634d7 -> 75427bf)
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 89634d7 [FLINK-14838] Cleanup the description about container number
config option in Scala and python shell doc
add 75427bf [FLINK-14874][table-planner-blink] add local aggregation to
solve data skew for ROLLUP/CUBE
No new revisions were added by this update.
Summary of changes:
.../plan/optimize/program/FlinkBatchProgram.scala | 10 +
.../planner/plan/rules/FlinkBatchRuleSets.scala| 8 +
.../physical/batch/BatchExecAggRuleBase.scala | 69 +-
.../physical/batch/BatchExecHashAggRule.scala | 28 +--
.../physical/batch/BatchExecSortAggRule.scala | 23 +-
.../physical/batch/EnforceLocalAggRuleBase.scala | 165 ++
.../physical/batch/EnforceLocalHashAggRule.scala | 83 +++
.../physical/batch/EnforceLocalSortAggRule.scala | 112 ++
.../batch/sql/agg/AggregateReduceGroupingTest.xml | 16 +-
.../plan/batch/sql/agg/GroupingSetsTest.xml| 18 +-
.../physical/batch/EnforceLocalHashAggRuleTest.xml | 160 ++
.../physical/batch/EnforceLocalSortAggRuleTest.xml | 242 +
.../batch/EnforceLocalAggRuleTestBase.scala} | 43 +++-
.../batch/EnforceLocalHashAggRuleTest.scala| 77 +++
.../batch/EnforceLocalSortAggRuleTest.scala| 95
15 files changed, 1090 insertions(+), 59 deletions(-)
create mode 100644
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/rules/physical/batch/EnforceLocalAggRuleBase.scala
create mode 100644
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/rules/physical/batch/EnforceLocalHashAggRule.scala
create mode 100644
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/rules/physical/batch/EnforceLocalSortAggRule.scala
create mode 100644
flink-table/flink-table-planner-blink/src/test/resources/org/apache/flink/table/planner/plan/rules/physical/batch/EnforceLocalHashAggRuleTest.xml
create mode 100644
flink-table/flink-table-planner-blink/src/test/resources/org/apache/flink/table/planner/plan/rules/physical/batch/EnforceLocalSortAggRuleTest.xml
copy
flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/planner/plan/{stream/table/PythonCalcTest.scala
=> rules/physical/batch/EnforceLocalAggRuleTestBase.scala} (51%)
create mode 100644
flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/planner/plan/rules/physical/batch/EnforceLocalHashAggRuleTest.scala
create mode 100644
flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/planner/plan/rules/physical/batch/EnforceLocalSortAggRuleTest.scala
[flink] branch master updated (0a62bc0 -> 89634d7)
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 0a62bc0 [hotfix] Fix checkstyle error in ExecutionContext.java add 89634d7 [FLINK-14838] Cleanup the description about container number config option in Scala and python shell doc No new revisions were added by this update. Summary of changes: docs/ops/python_shell.md | 4 +--- docs/ops/scala_shell.md| 4 +--- docs/ops/scala_shell.zh.md | 4 +--- .../java/org/apache/flink/client/python/PythonShellParser.java | 10 -- 4 files changed, 3 insertions(+), 19 deletions(-)
[flink] branch master updated (6111170 -> 0a62bc0)
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 670 [hotfix] Add debug logging in MiniDispatcher add 0a62bc0 [hotfix] Fix checkstyle error in ExecutionContext.java No new revisions were added by this update. Summary of changes: .../org/apache/flink/table/client/gateway/local/ExecutionContext.java| 1 - 1 file changed, 1 deletion(-)
[flink] branch master updated (461d5af -> 6111170)
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 461d5af [FLINK-14767] Mark TaskManagerOptions#EXIT_ON_FATAL_AKKA_ERROR with @Deprecated annotation add a7987d4 [hotfix] Don't set plan name after creation in SQL cli ExecutionContext add 670 [hotfix] Add debug logging in MiniDispatcher No new revisions were added by this update. Summary of changes: .../java/org/apache/flink/runtime/dispatcher/MiniDispatcher.java | 7 +++ .../apache/flink/table/client/gateway/local/ExecutionContext.java | 4 +--- 2 files changed, 8 insertions(+), 3 deletions(-)
[flink] branch release-1.8 updated: [FLINK-14104][build] Use flink-shaded-jackson 9.0
This is an automated email from the ASF dual-hosted git repository.
chesnay pushed a commit to branch release-1.8
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/release-1.8 by this push:
new b4c387b [FLINK-14104][build] Use flink-shaded-jackson 9.0
b4c387b is described below
commit b4c387b8bde32c2649b35ec7a6ee5df3fefa3286
Author: Chesnay Schepler
AuthorDate: Sun Nov 24 18:21:12 2019 +0100
[FLINK-14104][build] Use flink-shaded-jackson 9.0
---
.../java/org/apache/flink/runtime/rest/handler/AbstractHandler.java | 3 ++-
pom.xml | 6 +++---
2 files changed, 5 insertions(+), 4 deletions(-)
diff --git
a/flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/AbstractHandler.java
b/flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/AbstractHandler.java
index 1325d01..1d2aa0f 100644
---
a/flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/AbstractHandler.java
+++
b/flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/AbstractHandler.java
@@ -51,6 +51,7 @@ import javax.annotation.Nonnull;
import javax.annotation.Nullable;
import java.io.IOException;
+import java.io.InputStream;
import java.util.Arrays;
import java.util.Map;
import java.util.concurrent.CompletableFuture;
@@ -122,7 +123,7 @@ public abstract class AbstractHandler0.7.6
3.4.10
2.12.0
- 2.7.9
+ 2.10.1
3.1.5
0.3.0
1.8.2
@@ -260,13 +260,13 @@ under the License.
org.apache.flink
flink-shaded-jackson
-
${jackson.version}-${flink.shaded.version}
+ ${jackson.version}-9.0
org.apache.flink
flink-shaded-jackson-module-jsonSchema
-
${jackson.version}-${flink.shaded.version}
+ ${jackson.version}-9.0
[flink] branch master updated (38750f0 -> 461d5af)
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 38750f0 [hotfix] Extract loadJarFile from PackageProgram# add 461d5af [FLINK-14767] Mark TaskManagerOptions#EXIT_ON_FATAL_AKKA_ERROR with @Deprecated annotation No new revisions were added by this update. Summary of changes: docs/_includes/generated/task_manager_configuration.html| 6 -- .../java/org/apache/flink/configuration/TaskManagerOptions.java | 1 + 2 files changed, 1 insertion(+), 6 deletions(-)
[flink] branch master updated (320240e -> 38750f0)
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 320240e [FLINK-14595][orc] Move flink-orc to flink-formats from flink-connectors (#10277) add a6d6778 [FLINK-14873][client] Make PackagedProgram#savepointSettings final add 5be1e78 [hotfix] Make parameter of PackagedProgram# final add 38750f0 [hotfix] Extract loadJarFile from PackageProgram# No new revisions were added by this update. Summary of changes: .../org/apache/flink/client/cli/CliFrontend.java | 7 +-- .../flink/client/program/PackagedProgram.java | 72 +- .../client/cli/CliFrontendPackageProgramTest.java | 5 +- 3 files changed, 48 insertions(+), 36 deletions(-)
