You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ga...@apache.org on 2019/11/28 21:03:00 UTC
[flink] branch FLINK-14651 updated (0d1c438 -> faf9849)
This is an automated email from the ASF dual-hosted git repository.
gary pushed a change to branch FLINK-14651
in repository https://gitbox.apache.org/repos/asf/flink.git.
discard 0d1c438 Remove wrong checkState
omit 3a8e1ed fixup Disable SQL client E2E kafka tests
omit 4091ee1 [FLINK-14651][travis, tests] Run tests against legacy scheduler in separate Travis stages
omit 0acb9af [FLINK-14651][runtime] Enable DefaultScheduler by default
omit dc78784 Enable E2E tests
omit 6070e39 Disable SQL client E2E kafka tests
omit 5a3d89e Disable known failing E2E tests
omit 0be8e44 Temporarily disable notifications from TravisCI
add d3dbc96 [FLINK-14788][configuration] Add configure method to CheckpointConfig
add 65a472f [FLINK-14788][documentation] Generated documentation for ExecutionCheckpointingOptions
add 23c9b5a [FLINK-13708][table-planner-blink] Transformations should be cleared after execution in blink planner
add f01cdd1 [FLINK-13708][table-planner-blink] Revert changes in fb7beb88 which is a temporary fix
add 6dbb308 [FLINK-14481]Modify the Flink valid socket port check to 0 to 65535. (#10184)
add 03dc734 [FLINK-14481] Unify port range check in couple of missing places
add 2c5dd63 [hotfix][configuration] Match enums case insensitively in configuration
add ccf322c [hotfix] Fix scaladocs links
add 3ec3079 [FLINK-14787][configuration] Add configure method to StreamExecutionEnvironment
add 444e26d [FLINK-14787][documentation] Generate documentation for ExecutionOptions, PipelineOptions and StreamPipelineOptions
add c7ae2b8 [FLINK-14722][hadoop] Optimize mapred.HadoopInputSplit to serialize conf only when necessary
add 793f3b0 [FLINK-14915][runtime] Remove unnecessary parameter JobGraph from SchedulingStrategyFactory#createInstance
add fb17587 [FLINK-14876]Putting xercesImpl related classes into alwaysParentFirstLoaderPatterns to avoid conflicts
add ec85f82 [FLINK-14878][table] Add useCatalogOperation and support it both in flink/blink planner
add c2f3af5 [FLINK-14924][connectorsi] Add treat empty field as null option to CsvTableSource
add ea721c8 [FLINK-14931][docs] Regenerated documentation
add 33c4abf [hotfix][runtime] Adding back the missing blacklisting information when refining SotProfile in allocateCoLocatedMultiTaskSlot
add 2bbcdab [hotfix][runtime] Fix code style violations in SlotProfile, SchedulerTestBase, PreviousAllocationSlotSelectionStrategyTest and ScheduleWithCoLocationHintTest
add 50712da [hotfix][runtime] Cleanup the SlotProfile constructors
add bc24186 [FLINK-14314][runtime] Introduce physical slot ResourceProfile in SlotProfile
add 39a2777 [FLINK-14314][runtime] Remove SharedSlotOversubscribedException handling
add 3442189 [FLINK-14928][docs] Fix the broken links in documentation (#10292)
add 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#<init> final
add 38750f0 [hotfix] Extract loadJarFile from PackageProgram#<init>
add 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 6111170 [hotfix] Add debug logging in MiniDispatcher
add 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
add 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
add 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
add 5984d52 [FLINK-14892][docs] Add documentation for checkpoint directory layout (#10305)
add 6691894 [hotfix] Correct wrong log level in TaskLocalStateStoreImpl#storeLocalState
add 20f6976 [FLINK-14846][doc] Correct the default writerbuffer size documentation of RocksDB
add ffde750 [hotfix][table] Move UnresolvedIdentifier to table-common and update UDT
add 81b5d17 [FLINK-14903][table] Relax structured types constraints
add 08f1f42 [FLINK-13995][legal] Properly exclude netty license directory
add d95e2c1 [FLINK-14904][table] Rename ANY type to RAW type
add 9505b0e [hotfix][examples-table] Update registerDataSet to createTemporaryView
add e6dae01 [hotfix] Add more logging in YARN/docker test scripts
add e383414 [hotfix][core] Make CoreMatchers.containsCause more flexible
add edf440a [FLINK-12996][table-common] Require equals/hashCode for type inference classes
add dac2cb8 [FLINK-12996][table-common] Offer unified exception for type inference classes
add 0a9e2bd [FLINK-12996][table-common] Add required input type validators for FLIP-65
add 86038cd [FLINK-12996][table-common] Add required type strategies for FLIP-65
add 0af4801 [FLINK-12996][table-common] Simplify type validators structure
add e24681b [FLINK-14817][doc] Fix misleading documentation using method chaining of Configuration (#10323)
add 9ffc2a2 [FLINK-14913][table] refactor CatalogFunction to remove properties
add 672cdb3 [FLINK-14948][client] Implement shutDownCluster for MiniClusterClient
add 3d94ba0 [FLINK-10932][kubernetes] Initialize flink-kubernetes module
add 20c983c [FLINK-11491][e2e] Add TPC-DS queries to end to end tests
add 4b21753 [minor] Fix error logging in common yarn/docker test scripts
add 5374cfe [FLINK-14968] Disable flaky yarn_kerberos_docker (custom fs plugin) test
add 488c742 [hotfix][runtime] Fix checkstyle violations in runtime classes which use ResourceProfile
add 3466c22 [FLINK-14733][runtime] Introduce a builder for flexible ResourceProfile building
add 17e7fe9 [FLINK-14930][fs][oss] Fix shading prefix
add d79dbec [FLINK-14930][fs][oss] Document credential providers
add 77bb81b [hotfix][coordination] Fix error message
add 4c85821 [FLINK-11835][tests] Wait until job was recovered before unblocking task
add 4b1a9e4 [FLINK-14940][travis] Fix error code handling for maven calls
add 3d657b4 [FLINK-14939][e2e] Set distDir property
add 9f6b204 [FLINK-14901] Throw Error in MemoryUtils if there is problem with using system classes over reflection
add 8930f62 [hotfix] Annotate interfaces in JavaGcCleanerWrapper with @FunctionalInterface
add f381065 [FLINK-14505][tests] Temporarily disable SQL Client end-to-end tests for Kafka
add 981b054 [FLINK-14969][tests] Refactor CliFrontendRunWithYarnTest reflect to new execution codepath (#10331)
add e583a1c [FLINK-14709] Allow outputting elements in user defined close method, executed by chained driver.
add 09f2847 [FLINK-14709] Remove unused GroupCombineChainedDriver.
add 2ac0dd0 [FLINK-14709] Dispose resources in ChainedDriver close method instead of closeTask.
add 2772cd0 [FLINK-14813][metrics] Provide `isBackPressured` Task metric
add 959cf62 [FLINK-13634] Add compression format for use with StreamingFileSink
add 2ba4a67 [FLINK-13634] Add CompressWriterFactory to documentation
add 76d794b [hotfix][tests] Avoid to add vertices to TestingSchedulingTopology when building edges using ProducerConsumerConnectionBuilder
add 24b77db [FLINK-14909][runtime] Respect the scheduled vertex order from scheduling strategies
add 33d81cc [FLINK-14909][runtime] Change default scheduling strategies to schedule vertices in topological order
add 7902947 [FLINK-14909][runtime] Cleanup default scheduling strategies
add 33f5e33 [FLINK-10377] Support checkpoint overtaking a savepoint in TwoPhaseCommitSink
add 9c9ac52 Revert "[FLINK-14813][metrics] Provide `isBackPressured` Task metric"
add af688dd Temporarily disable notifications from TravisCI
add db8fbd2 Disable known failing E2E tests
add 35c834e Enable E2E tests
add 4b225e5 [FLINK-14651][runtime] Enable DefaultScheduler by default
add faf9849 [FLINK-14651][travis, tests] Run tests against legacy scheduler in separate Travis stages
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (0d1c438)
\
N -- N -- N refs/heads/FLINK-14651 (faf9849)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
No new revisions were added by this update.
Summary of changes:
.travis.yml | 24 +-
docs/_includes/generated/core_configuration.html | 2 +-
.../execution_checkpointing_configuration.html | 60 +
.../generated/execution_configuration.html | 6 +
.../generated/pipeline_configuration.html | 12 +
.../rocks_db_configurable_configuration.html | 2 +-
.../generated/stream_pipeline_configuration.html | 18 +
.../generated/task_manager_configuration.html | 6 -
docs/dev/connectors/streamfile_sink.md | 3 +-
docs/dev/connectors/streamfile_sink.zh.md | 1 +
docs/dev/table/config.md | 33 +-
docs/dev/table/config.zh.md | 33 +-
docs/dev/table/functions/systemFunctions.md | 16 +-
docs/dev/table/functions/systemFunctions.zh.md | 16 +-
docs/dev/table/sql.md | 4 +-
.../tuning/streaming_aggregation_optimization.md | 72 +-
.../streaming_aggregation_optimization.zh.md | 72 +-
docs/dev/table/types.md | 18 +-
docs/getting-started/index.zh.md | 2 +-
docs/ops/config.md | 2 +
docs/ops/config.zh.md | 2 +
docs/ops/filesystems/oss.md | 9 +
docs/ops/python_shell.md | 4 +-
docs/ops/scala_shell.md | 4 +-
docs/ops/scala_shell.zh.md | 4 +-
docs/ops/state/checkpoints.md | 18 +
docs/ops/state/checkpoints.zh.md | 18 +
.../org/apache/flink/client/cli/CliFrontend.java | 7 +-
.../apache/flink/client/program/ClusterClient.java | 4 +-
.../flink/client/program/MiniClusterClient.java | 11 +
.../flink/client/program/PackagedProgram.java | 72 +-
.../client/cli/CliFrontendPackageProgramTest.java | 5 +-
.../flink-connector-elasticsearch2/pom.xml | 2 +-
.../flink-connector-elasticsearch5/pom.xml | 2 +-
.../flink/table/catalog/hive/HiveCatalog.java | 21 +-
.../factories/HiveFunctionDefinitionFactory.java | 3 +-
.../table/catalog/hive/HiveCatalogTestBase.java | 14 +
.../catalog/hive/HiveCatalogUseBlinkITCase.java | 9 +-
.../hadoop/mapred/wrapper/HadoopInputSplit.java | 58 +-
.../mapred/wrapper/HadoopInputSplitTest.java | 211 ++
flink-connectors/pom.xml | 1 -
.../flink/api/common/cache/DistributedCache.java | 23 +
.../apache/flink/configuration/Configuration.java | 7 +-
.../apache/flink/configuration/CoreOptions.java | 2 +-
.../flink/configuration/ExecutionOptions.java | 20 +
.../flink/configuration/PipelineOptions.java | 18 +
.../ReadableConfigToConfigurationAdapter.java | 328 +++
.../flink/configuration/TaskManagerOptions.java | 1 +
.../org/apache/flink/core/memory/MemoryUtils.java | 33 +-
.../apache/flink/util/JavaGcCleanerWrapper.java | 13 +-
.../main/java/org/apache/flink/util/NetUtils.java | 28 +-
.../java/org/apache/flink/util/CoreMatchers.java | 8 +-
flink-dist/pom.xml | 6 +
flink-docs/pom.xml | 5 +
.../configuration/ConfigOptionsDocGenerator.java | 2 +
.../flink-tpcds-test}/pom.xml | 77 +-
.../apache/flink/table/tpcds/TpcdsTestProgram.java | 184 ++
.../apache/flink/table/tpcds/schema/Column.java | 31 +-
.../flink/table/tpcds/schema/TpcdsSchema.java | 32 +-
.../table/tpcds/schema/TpcdsSchemaProvider.java | 529 ++++
.../flink/table/tpcds/stats/CatalogTableStats.java | 57 +
.../table/tpcds/stats/TpcdsStatsProvider.java | 648 +++++
.../flink/table/tpcds/utils/AnswerFormatter.java | 187 ++
.../table/tpcds/utils/TpcdsResultComparator.java | 226 ++
.../flink-tpcds-test/tpcds-tool/README.md | 0
.../flink-tpcds-test/tpcds-tool/answer_set/1.ans | 105 +
.../flink-tpcds-test/tpcds-tool/answer_set/10.ans | 10 +
.../flink-tpcds-test/tpcds-tool/answer_set/11.ans | 90 +
.../flink-tpcds-test/tpcds-tool/answer_set/12.ans | 103 +
.../flink-tpcds-test/tpcds-tool/answer_set/13.ans | 6 +
.../tpcds-tool/answer_set/14a_NULLS_FIRST.ans | 104 +
.../tpcds-tool/answer_set/14a_SQL_SERVER.ans | 101 +
.../tpcds-tool/answer_set/14b_NULLS_FIRST.ans | 102 +
.../tpcds-tool/answer_set/15_NULLS_FIRST.ans | 102 +
.../tpcds-tool/answer_set/15_NULLS_LAST.ans | 107 +
.../flink-tpcds-test/tpcds-tool/answer_set/16.ans | 6 +
.../flink-tpcds-test/tpcds-tool/answer_set/17.ans | 5 +
.../tpcds-tool/answer_set/18_NULLS_FIRST.ans | 101 +
.../tpcds-tool/answer_set/18_NULLS_LAST.ans | 107 +
.../tpcds-tool/answer_set/18_SQL_SERVER.ans | 101 +
.../flink-tpcds-test/tpcds-tool/answer_set/19.ans | 107 +
.../flink-tpcds-test/tpcds-tool/answer_set/2.ans | 2520 ++++++++++++++++++++
.../tpcds-tool/answer_set/20_NULLS_FIRST.ans | 103 +
.../tpcds-tool/answer_set/20_NULLS_LAST.ans | 103 +
.../tpcds-tool/answer_set/21_NULLS_FIRST.ans | 101 +
.../tpcds-tool/answer_set/21_NULLS_LAST.ans | 107 +
.../tpcds-tool/answer_set/22_NULLS_FIRST.ans | 102 +
.../tpcds-tool/answer_set/22_NULLS_LAST.ans | 107 +
.../tpcds-tool/answer_set/23_NULLS_LAST.ans | 12 +
.../tpcds-tool/answer_set/23a_NULLS_FIRST.ans | 3 +
.../tpcds-tool/answer_set/23b_NULLS_FIRST.ans | 6 +
.../flink-tpcds-test/tpcds-tool/answer_set/24a.ans | 6 +
.../flink-tpcds-test/tpcds-tool/answer_set/24b.ans | 6 +
.../flink-tpcds-test/tpcds-tool/answer_set/25.ans | 6 +
.../flink-tpcds-test/tpcds-tool/answer_set/26.ans | 107 +
.../tpcds-tool/answer_set/27_NULLS_FIRST.ans | 102 +
.../tpcds-tool/answer_set/27_NULLS_LAST.ans | 107 +
.../flink-tpcds-test/tpcds-tool/answer_set/28.ans | 6 +
.../flink-tpcds-test/tpcds-tool/answer_set/29.ans | 6 +
.../flink-tpcds-test/tpcds-tool/answer_set/3.ans | 96 +
.../flink-tpcds-test/tpcds-tool/answer_set/30.ans | 107 +
.../flink-tpcds-test/tpcds-tool/answer_set/31.ans | 58 +
.../flink-tpcds-test/tpcds-tool/answer_set/32.ans | 6 +
.../flink-tpcds-test/tpcds-tool/answer_set/33.ans | 107 +
.../tpcds-tool/answer_set/34_NULLS_FIRST.ans | 455 ++++
.../tpcds-tool/answer_set/34_NULLS_LAST.ans | 455 ++++
.../tpcds-tool/answer_set/35_NULLS_FIRST.ans | 103 +
.../tpcds-tool/answer_set/35_NULLS_LAST.ans | 102 +
.../tpcds-tool/answer_set/36_NULLS_FIRST.ans | 101 +
.../tpcds-tool/answer_set/36_NULLS_LAST.ans | 107 +
.../flink-tpcds-test/tpcds-tool/answer_set/37.ans | 6 +
.../flink-tpcds-test/tpcds-tool/answer_set/38.ans | 4 +
.../flink-tpcds-test/tpcds-tool/answer_set/39a.ans | 244 ++
.../flink-tpcds-test/tpcds-tool/answer_set/39b.ans | 15 +
.../flink-tpcds-test/tpcds-tool/answer_set/4.ans | 10 +
.../flink-tpcds-test/tpcds-tool/answer_set/40.ans | 107 +
.../flink-tpcds-test/tpcds-tool/answer_set/41.ans | 9 +
.../flink-tpcds-test/tpcds-tool/answer_set/42.ans | 17 +
.../flink-tpcds-test/tpcds-tool/answer_set/43.ans | 7 +
.../flink-tpcds-test/tpcds-tool/answer_set/44.ans | 17 +
.../flink-tpcds-test/tpcds-tool/answer_set/45.ans | 25 +
.../tpcds-tool/answer_set/46_NULLS_FIRST.ans | 103 +
.../tpcds-tool/answer_set/46_NULLS_LAST.ans | 107 +
.../flink-tpcds-test/tpcds-tool/answer_set/47.ans | 107 +
.../flink-tpcds-test/tpcds-tool/answer_set/48.ans | 6 +
.../flink-tpcds-test/tpcds-tool/answer_set/49.ans | 39 +
.../flink-tpcds-test/tpcds-tool/answer_set/50.ans | 13 +
.../flink-tpcds-test/tpcds-tool/answer_set/51.ans | 107 +
.../flink-tpcds-test/tpcds-tool/answer_set/52.ans | 107 +
.../flink-tpcds-test/tpcds-tool/answer_set/53.ans | 102 +
.../flink-tpcds-test/tpcds-tool/answer_set/54.ans | 6 +
.../flink-tpcds-test/tpcds-tool/answer_set/55.ans | 107 +
.../tpcds-tool/answer_set/56_NULLS_FIRST.ans | 102 +
.../tpcds-tool/answer_set/56_NULLS_LAST.ans | 102 +
.../flink-tpcds-test/tpcds-tool/answer_set/57.ans | 107 +
.../flink-tpcds-test/tpcds-tool/answer_set/58.ans | 5 +
.../flink-tpcds-test/tpcds-tool/answer_set/59.ans | 103 +
.../tpcds-tool/answer_set/5_NULLS_FIRST.ans | 101 +
.../tpcds-tool/answer_set/5_NULLS_LAST.ans | 107 +
.../flink-tpcds-test/tpcds-tool/answer_set/60.ans | 107 +
.../flink-tpcds-test/tpcds-tool/answer_set/61.ans | 3 +
.../tpcds-tool/answer_set/62_NULLS_FIRST.ans | 104 +
.../tpcds-tool/answer_set/62_NULLS_LAST.ans | 107 +
.../flink-tpcds-test/tpcds-tool/answer_set/63.ans | 101 +
.../flink-tpcds-test/tpcds-tool/answer_set/64.ans | 12 +
.../tpcds-tool/answer_set/65_NULLS_FIRST.ans | 102 +
.../tpcds-tool/answer_set/65_NULLS_LAST.ans | 102 +
.../tpcds-tool/answer_set/66_NULLS_FIRST.ans | 6 +
.../tpcds-tool/answer_set/66_NULLS_LAST.ans | 10 +
.../tpcds-tool/answer_set/67_NULLS_FIRST.ans | 102 +
.../tpcds-tool/answer_set/67_NULLS_LAST.ans | 107 +
.../tpcds-tool/answer_set/68_NULLS_FIRST.ans | 101 +
.../tpcds-tool/answer_set/68_NULLS_LAST.ans | 107 +
.../flink-tpcds-test/tpcds-tool/answer_set/69.ans | 107 +
.../tpcds-tool/answer_set/6_NULLS_FIRST.ans | 47 +
.../tpcds-tool/answer_set/6_NULLS_LAST.ans | 47 +
.../flink-tpcds-test/tpcds-tool/answer_set/7.ans | 102 +
.../flink-tpcds-test/tpcds-tool/answer_set/70.ans | 8 +
.../tpcds-tool/answer_set/70_SQL_SERVER.ans | 4 +
.../tpcds-tool/answer_set/71_NULLS_FIRST.ans | 1022 ++++++++
.../tpcds-tool/answer_set/71_NULLS_LAST.ans | 1019 ++++++++
.../tpcds-tool/answer_set/72_NULLS_FIRST.ans | 103 +
.../tpcds-tool/answer_set/72_NULLS_LAST.ans | 102 +
.../flink-tpcds-test/tpcds-tool/answer_set/73.ans | 7 +
.../flink-tpcds-test/tpcds-tool/answer_set/74.ans | 99 +
.../flink-tpcds-test/tpcds-tool/answer_set/75.ans | 102 +
.../tpcds-tool/answer_set/76_NULLS_FIRST.ans | 101 +
.../tpcds-tool/answer_set/76_NULLS_LAST.ans | 107 +
.../tpcds-tool/answer_set/77_NULLS_FIRST.ans | 47 +
.../tpcds-tool/answer_set/77_NULLS_LAST.ans | 46 +
.../tpcds-tool/answer_set/77_SQL_SERVER.ans | 45 +
.../flink-tpcds-test/tpcds-tool/answer_set/78.ans | 103 +
.../tpcds-tool/answer_set/79_NULLS_FIRST.ans | 101 +
.../tpcds-tool/answer_set/79_NULLS_LAST.ans | 107 +
.../flink-tpcds-test/tpcds-tool/answer_set/8.ans | 10 +
.../tpcds-tool/answer_set/80_NULLS_FIRST.ans | 102 +
.../tpcds-tool/answer_set/80_NULLS_LAST.ans | 107 +
.../flink-tpcds-test/tpcds-tool/answer_set/81.ans | 107 +
.../flink-tpcds-test/tpcds-tool/answer_set/82.ans | 7 +
.../flink-tpcds-test/tpcds-tool/answer_set/83.ans | 28 +
.../flink-tpcds-test/tpcds-tool/answer_set/84.ans | 32 +
.../flink-tpcds-test/tpcds-tool/answer_set/85.ans | 13 +
.../tpcds-tool/answer_set/86_NULLS_FIRST.ans | 101 +
.../tpcds-tool/answer_set/86_NULLS_LAST.ans | 107 +
.../flink-tpcds-test/tpcds-tool/answer_set/87.ans | 6 +
.../flink-tpcds-test/tpcds-tool/answer_set/88.ans | 6 +
.../flink-tpcds-test/tpcds-tool/answer_set/89.ans | 107 +
.../tpcds-tool/answer_set/8_SQL_SERVER.ans | 6 +
.../flink-tpcds-test/tpcds-tool/answer_set/9.ans | 6 +
.../flink-tpcds-test/tpcds-tool/answer_set/90.ans | 6 +
.../flink-tpcds-test/tpcds-tool/answer_set/91.ans | 6 +
.../flink-tpcds-test/tpcds-tool/answer_set/92.ans | 3 +
.../tpcds-tool/answer_set/93_NULLS_FIRST.ans | 101 +
.../tpcds-tool/answer_set/93_NULLS_LAST.ans | 107 +
.../flink-tpcds-test/tpcds-tool/answer_set/94.ans | 6 +
.../flink-tpcds-test/tpcds-tool/answer_set/95.ans | 6 +
.../flink-tpcds-test/tpcds-tool/answer_set/96.ans | 6 +
.../flink-tpcds-test/tpcds-tool/answer_set/97.ans | 2 +
.../tpcds-tool/answer_set/98_NULLS_FIRST.ans | 2518 +++++++++++++++++++
.../tpcds-tool/answer_set/98_NULLS_LAST.ans | 2518 +++++++++++++++++++
.../tpcds-tool/answer_set/99_NULLS_FIRST.ans | 91 +
.../tpcds-tool/answer_set/99_NULLS_LAST.ans | 97 +
.../flink-tpcds-test/tpcds-tool/data_generator.sh | 87 +
.../flink-tpcds-test/tpcds-tool/query/query1.sql | 25 +
.../flink-tpcds-test/tpcds-tool/query/query10.sql | 59 +
.../flink-tpcds-test/tpcds-tool/query/query11.sql | 81 +
.../flink-tpcds-test/tpcds-tool/query/query12.sql | 34 +
.../flink-tpcds-test/tpcds-tool/query/query13.sql | 52 +
.../flink-tpcds-test/tpcds-tool/query/query14a.sql | 104 +
.../flink-tpcds-test/tpcds-tool/query/query14b.sql | 109 +
.../flink-tpcds-test/tpcds-tool/query/query15.sql | 20 +
.../flink-tpcds-test/tpcds-tool/query/query16.sql | 31 +
.../flink-tpcds-test/tpcds-tool/query/query17.sql | 45 +
.../flink-tpcds-test/tpcds-tool/query/query18.sql | 33 +
.../flink-tpcds-test/tpcds-tool/query/query19.sql | 25 +
.../flink-tpcds-test/tpcds-tool/query/query2.sql | 60 +
.../flink-tpcds-test/tpcds-tool/query/query20.sql | 30 +
.../flink-tpcds-test/tpcds-tool/query/query21.sql | 30 +
.../flink-tpcds-test/tpcds-tool/query/query22.sql | 20 +
.../flink-tpcds-test/tpcds-tool/query/query23a.sql | 52 +
.../flink-tpcds-test/tpcds-tool/query/query23b.sql | 58 +
.../flink-tpcds-test/tpcds-tool/query/query24a.sql | 55 +
.../flink-tpcds-test/tpcds-tool/query/query24b.sql | 55 +
.../flink-tpcds-test/tpcds-tool/query/query25.sql | 48 +
.../flink-tpcds-test/tpcds-tool/query/query26.sql | 21 +
.../flink-tpcds-test/tpcds-tool/query/query27.sql | 23 +
.../flink-tpcds-test/tpcds-tool/query/query28.sql | 53 +
.../flink-tpcds-test/tpcds-tool/query/query29.sql | 47 +
.../flink-tpcds-test/tpcds-tool/query/query3.sql | 21 +
.../flink-tpcds-test/tpcds-tool/query/query30.sql | 31 +
.../flink-tpcds-test/tpcds-tool/query/query31.sql | 52 +
.../flink-tpcds-test/tpcds-tool/query/query32.sql | 28 +
.../flink-tpcds-test/tpcds-tool/query/query33.sql | 75 +
.../flink-tpcds-test/tpcds-tool/query/query34.sql | 31 +
.../flink-tpcds-test/tpcds-tool/query/query35.sql | 58 +
.../flink-tpcds-test/tpcds-tool/query/query36.sql | 29 +
.../flink-tpcds-test/tpcds-tool/query/query37.sql | 17 +
.../flink-tpcds-test/tpcds-tool/query/query38.sql | 23 +
.../flink-tpcds-test/tpcds-tool/query/query39a.sql | 28 +
.../flink-tpcds-test/tpcds-tool/query/query39b.sql | 29 +
.../flink-tpcds-test/tpcds-tool/query/query4.sql | 116 +
.../flink-tpcds-test/tpcds-tool/query/query40.sql | 28 +
.../flink-tpcds-test/tpcds-tool/query/query41.sql | 52 +
.../flink-tpcds-test/tpcds-tool/query/query42.sql | 22 +
.../flink-tpcds-test/tpcds-tool/query/query43.sql | 19 +
.../flink-tpcds-test/tpcds-tool/query/query44.sql | 35 +
.../flink-tpcds-test/tpcds-tool/query/query45.sql | 20 +
.../flink-tpcds-test/tpcds-tool/query/query46.sql | 35 +
.../flink-tpcds-test/tpcds-tool/query/query47.sql | 51 +
.../flink-tpcds-test/tpcds-tool/query/query48.sql | 67 +
.../flink-tpcds-test/tpcds-tool/query/query49.sql | 129 +
.../flink-tpcds-test/tpcds-tool/query/query5.sql | 128 +
.../flink-tpcds-test/tpcds-tool/query/query50.sql | 59 +
.../flink-tpcds-test/tpcds-tool/query/query51.sql | 45 +
.../flink-tpcds-test/tpcds-tool/query/query52.sql | 22 +
.../flink-tpcds-test/tpcds-tool/query/query53.sql | 28 +
.../flink-tpcds-test/tpcds-tool/query/query54.sql | 56 +
.../flink-tpcds-test/tpcds-tool/query/query55.sql | 14 +
.../flink-tpcds-test/tpcds-tool/query/query56.sql | 69 +
.../flink-tpcds-test/tpcds-tool/query/query57.sql | 48 +
.../flink-tpcds-test/tpcds-tool/query/query58.sql | 65 +
.../flink-tpcds-test/tpcds-tool/query/query59.sql | 44 +
.../flink-tpcds-test/tpcds-tool/query/query6.sql | 26 +
.../flink-tpcds-test/tpcds-tool/query/query60.sql | 78 +
.../flink-tpcds-test/tpcds-tool/query/query61.sql | 44 +
.../flink-tpcds-test/tpcds-tool/query/query62.sql | 35 +
.../flink-tpcds-test/tpcds-tool/query/query63.sql | 29 +
.../flink-tpcds-test/tpcds-tool/query/query64.sql | 121 +
.../flink-tpcds-test/tpcds-tool/query/query65.sql | 29 +
.../flink-tpcds-test/tpcds-tool/query/query66.sql | 220 ++
.../flink-tpcds-test/tpcds-tool/query/query67.sql | 44 +
.../flink-tpcds-test/tpcds-tool/query/query68.sql | 43 +
.../flink-tpcds-test/tpcds-tool/query/query69.sql | 47 +
.../flink-tpcds-test/tpcds-tool/query/query7.sql | 21 +
.../flink-tpcds-test/tpcds-tool/query/query70.sql | 38 +
.../flink-tpcds-test/tpcds-tool/query/query71.sql | 40 +
.../flink-tpcds-test/tpcds-tool/query/query72.sql | 29 +
.../flink-tpcds-test/tpcds-tool/query/query73.sql | 28 +
.../flink-tpcds-test/tpcds-tool/query/query74.sql | 61 +
.../flink-tpcds-test/tpcds-tool/query/query75.sql | 70 +
.../flink-tpcds-test/tpcds-tool/query/query76.sql | 24 +
.../flink-tpcds-test/tpcds-tool/query/query77.sql | 108 +
.../flink-tpcds-test/tpcds-tool/query/query78.sql | 58 +
.../flink-tpcds-test/tpcds-tool/query/query79.sql | 23 +
.../flink-tpcds-test/tpcds-tool/query/query8.sql | 108 +
.../flink-tpcds-test/tpcds-tool/query/query80.sql | 96 +
.../flink-tpcds-test/tpcds-tool/query/query81.sql | 31 +
.../flink-tpcds-test/tpcds-tool/query/query82.sql | 17 +
.../flink-tpcds-test/tpcds-tool/query/query83.sql | 67 +
.../flink-tpcds-test/tpcds-tool/query/query84.sql | 21 +
.../flink-tpcds-test/tpcds-tool/query/query85.sql | 84 +
.../flink-tpcds-test/tpcds-tool/query/query86.sql | 26 +
.../flink-tpcds-test/tpcds-tool/query/query87.sql | 23 +
.../flink-tpcds-test/tpcds-tool/query/query88.sql | 94 +
.../flink-tpcds-test/tpcds-tool/query/query89.sql | 28 +
.../flink-tpcds-test/tpcds-tool/query/query9.sql | 51 +
.../flink-tpcds-test/tpcds-tool/query/query90.sql | 22 +
.../flink-tpcds-test/tpcds-tool/query/query91.sql | 31 +
.../flink-tpcds-test/tpcds-tool/query/query92.sql | 30 +
.../flink-tpcds-test/tpcds-tool/query/query93.sql | 18 +
.../flink-tpcds-test/tpcds-tool/query/query94.sql | 29 +
.../flink-tpcds-test/tpcds-tool/query/query95.sql | 32 +
.../flink-tpcds-test/tpcds-tool/query/query96.sql | 16 +
.../flink-tpcds-test/tpcds-tool/query/query97.sql | 25 +
.../flink-tpcds-test/tpcds-tool/query/query98.sql | 33 +
.../flink-tpcds-test/tpcds-tool/query/query99.sql | 35 +
flink-end-to-end-tests/pom.xml | 1 +
flink-end-to-end-tests/run-nightly-tests.sh | 5 +-
.../test-scripts/common_yarn_docker.sh | 5 +-
flink-end-to-end-tests/test-scripts/test_tpcds.sh | 88 +
.../flink/table/examples/java/WordCountSQL.java | 4 +-
.../flink/table/examples/scala/WordCountSQL.scala | 4 +-
.../flink/fs/osshadoop/OSSFileSystemFactory.java | 2 +-
.../fs/osshadoop/HadoopOSSFileSystemITCase.java | 2 +-
.../flink-compress}/pom.xml | 78 +-
.../formats/compress/CompressWriterFactory.java | 80 +
.../flink/formats/compress/CompressWriters.java | 17 +-
.../compress/extractor/DefaultExtractor.java | 20 +-
.../formats/compress/extractor/Extractor.java | 16 +-
.../writers/HadoopCompressionBulkWriter.java | 66 +
.../compress/writers/NoCompressionBulkWriter.java | 58 +
.../compress/CompressWriterFactoryTest.java | 183 ++
.../src/test/resources/log4j-test.properties | 0
.../flink-orc/pom.xml | 23 +-
.../java/org/apache/flink/orc/OrcBatchReader.java | 0
.../org/apache/flink/orc/OrcRowInputFormat.java | 0
.../java/org/apache/flink/orc/OrcTableSource.java | 0
.../org/apache/flink/orc/OrcBatchReaderTest.java | 0
.../apache/flink/orc/OrcRowInputFormatTest.java | 0
.../org/apache/flink/orc/OrcTableSourceITCase.java | 0
.../org/apache/flink/orc/OrcTableSourceTest.java | 0
.../flink/orc/util/OrcTestFileGenerator.java | 0
.../src/test/resources/log4j-test.properties | 0
.../resources/test-data-composites-with-nulls.orc | Bin
.../src/test/resources/test-data-decimal.orc | Bin
.../src/test/resources/test-data-flat.orc | Bin
.../src/test/resources/test-data-nested.orc | Bin
.../src/test/resources/test-data-nestedlist.orc | Bin
.../src/test/resources/test-data-repeating.orc | Bin
.../src/test/resources/test-data-timetypes.orc | Bin
flink-formats/pom.xml | 2 +
flink-kubernetes/pom.xml | 217 ++
.../flink/metrics/influxdb/InfluxdbReporter.java | 6 +-
flink-python/dev/lint-python.sh | 149 +-
...st_stream_execution_environment_completeness.py | 2 +-
flink-python/pyflink/table/catalog.py | 16 +-
flink-python/pyflink/table/tests/test_catalog.py | 8 +-
.../table/tests/test_table_environment_api.py | 29 +-
.../flink/client/python/PythonDriverEnvUtils.java | 4 +-
.../client/python/PythonResourceExtractor.java | 3 +-
.../flink/client/python/PythonShellParser.java | 10 -
.../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 +-
.../functions/python/PythonTypeUtilsTest.java | 5 +-
.../client/QueryableStateClient.java | 5 +-
flink-runtime/pom.xml | 2 +-
.../clusterframework/types/ResourceProfile.java | 174 +-
.../clusterframework/types/SlotProfile.java | 110 +-
.../flink/runtime/dispatcher/MiniDispatcher.java | 7 +
.../flink/runtime/executiongraph/Execution.java | 4 +-
.../runtime/io/network/netty/NettyConfig.java | 3 +-
.../runtime/jobmaster/JobNotFinishedException.java | 2 +-
.../LocationPreferenceSlotSelectionStrategy.java | 2 +-
.../runtime/jobmaster/slotpool/SchedulerImpl.java | 41 +-
.../jobmaster/slotpool/SlotSharingManager.java | 49 +-
.../apache/flink/runtime/operators/BatchTask.java | 5 +-
.../flink/runtime/operators/DataSourceTask.java | 5 +-
.../operators/chaining/ChainedAllReduceDriver.java | 2 +-
.../operators/chaining/ChainedMapDriver.java | 2 +-
.../chaining/ChainedReduceCombineDriver.java | 22 +-
.../chaining/GroupCombineChainedDriver.java | 241 --
.../chaining/SynchronousChainedCombineDriver.java | 27 +-
.../org/apache/flink/runtime/rest/RestClient.java | 3 +-
.../runtime/rpc/akka/AkkaRpcServiceUtils.java | 3 +-
.../scheduler/DefaultExecutionSlotAllocator.java | 9 +-
.../flink/runtime/scheduler/DefaultScheduler.java | 33 +-
.../runtime/scheduler/ExecutionSlotAllocator.java | 6 +-
.../ExecutionVertexSchedulingRequirements.java | 49 +-
...xecutionVertexSchedulingRequirementsMapper.java | 25 +-
.../flink/runtime/scheduler/SchedulerBase.java | 3 +-
.../runtime/scheduler/SchedulerOperations.java | 7 +-
.../strategy/EagerSchedulingStrategy.java | 33 +-
.../LazyFromSourcesSchedulingStrategy.java | 46 +-
.../strategy/SchedulingStrategyFactory.java | 4 +-
.../strategy/SchedulingStrategyUtils.java | 63 +
.../runtime/state/TaskLocalStateStoreImpl.java | 2 +-
.../runtime/taskexecutor/TaskManagerServices.java | 17 +-
...ocationPreferenceSlotSelectionStrategyTest.java | 37 +-
...reviousAllocationSlotSelectionStrategyTest.java | 38 +-
.../types/ResourceProfileTest.java | 230 +-
.../types/SlotSelectionStrategyTestBase.java | 7 +-
.../scheduler/ScheduleWithCoLocationHintTest.java | 7 +-
.../scheduler/SchedulerIsolatedTasksTest.java | 23 +-
.../jobmanager/scheduler/SchedulerTestBase.java | 9 +-
.../jobmaster/slotpool/AvailableSlotsTest.java | 5 +-
.../slotpool/SlotPoolBatchSlotRequestTest.java | 4 +-
.../jobmaster/slotpool/SlotPoolCoLocationTest.java | 161 --
.../slotpool/SlotPoolSlotSharingTest.java | 98 +-
.../jobmaster/slotpool/SlotSharingManagerTest.java | 109 +-
.../jobmaster/slotpool/TestingSlotPoolImpl.java | 21 +
.../runtime/operators/DataSourceTaskTest.java | 2 +-
.../runtime/operators/chaining/ChainTaskTest.java | 112 +-
.../AnyMatchingSlotMatchingStrategyTest.java | 6 +-
.../LeastUtilizationSlotMatchingStrategyTest.java | 4 +-
.../SlotManagerFailUnfulfillableTest.java | 22 +-
.../slotmanager/SlotManagerImplTest.java | 52 +-
.../slotmanager/SlotProtocolTest.java | 18 +-
.../TaskManagerReleaseInSlotManagerTest.java | 3 +-
.../DefaultExecutionSlotAllocatorTest.java | 23 +-
.../runtime/scheduler/DefaultSchedulerTest.java | 31 +-
.../scheduler/TestExecutionSlotAllocator.java | 2 +-
.../strategy/EagerSchedulingStrategyTest.java | 78 +-
.../LazyFromSourcesSchedulingStrategyTest.java | 76 +-
.../scheduler/strategy/StrategyTestUtil.java | 6 +-
.../scheduler/strategy/TestSchedulingStrategy.java | 11 +-
.../strategy/TestingSchedulerOperations.java | 11 +-
.../strategy/TestingSchedulingTopology.java | 21 +-
.../runtime/taskexecutor/TaskExecutorTest.java | 2 +-
.../runtime/taskexecutor/slot/TaskSlotUtils.java | 19 +-
.../state/RocksDBConfigurableOptions.java | 2 +-
.../api/environment/CheckpointConfig.java | 30 +
.../environment/ExecutionCheckpointingOptions.java | 126 +
.../environment/StreamExecutionEnvironment.java | 69 +
.../api/environment/StreamPipelineOptions.java | 48 +
.../api/functions/sink/SocketClientSink.java | 3 +-
.../functions/sink/TwoPhaseCommitSinkFunction.java | 1 -
.../functions/source/SocketTextStreamFunction.java | 3 +-
.../CheckpointConfigFromConfigurationTest.java | 182 ++
...ecutionEnvironmentComplexConfigurationTest.java | 100 +
...treamExecutionEnvironmentConfigurationTest.java | 174 ++
.../sink/TwoPhaseCommitSinkFunctionTest.java | 20 +
.../api/scala/StreamExecutionEnvironment.scala | 37 +-
.../client/gateway/local/ExecutionContext.java | 7 +-
.../src/main/codegen/data/Parser.tdd | 1 +
.../apache/flink/sql/parser/ddl/SqlUseCatalog.java | 2 +-
.../java/internal/StreamTableEnvironmentImpl.java | 6 +
.../apache/flink/table/sources/CsvTableSource.java | 121 +-
.../table/api/internal/TableEnvironmentImpl.java | 8 +-
.../flink/table/catalog/CatalogFunctionImpl.java | 34 +-
.../table/operations/UseCatalogOperation.java | 25 +-
.../flink/table/operations/UseOperation.java} | 21 +-
.../utils/factories/AggregateOperationFactory.java | 4 +-
.../flink/table/catalog/CatalogTestBase.java | 16 -
.../flink/table/catalog/FunctionCatalogTest.java | 4 +-
.../table/catalog/GenericInMemoryCatalogTest.java | 12 +
.../functions/FunctionDefinitionUtilTest.java | 10 +-
.../flink/table/functions/TestGenericUDF.java | 27 +-
.../flink/table/functions/TestSimpleUDF.java | 27 +-
.../internal/StreamTableEnvironmentImpl.scala | 6 +
.../java/org/apache/flink/table/api/DataTypes.java | 36 +-
.../flink/table/catalog/CatalogFunction.java | 14 +-
.../flink/table/catalog/UnresolvedIdentifier.java | 32 +-
.../flink/table/types/inference/ArgumentCount.java | 2 +
...peValidator.java => ArgumentTypeValidator.java} | 27 +-
.../table/types/inference/CallContextBase.java | 8 +
.../types/inference/ConstantArgumentCount.java | 100 +
.../table/types/inference/InputTypeValidator.java | 5 +-
.../table/types/inference/InputTypeValidators.java | 124 +-
.../flink/table/types/inference/TypeInference.java | 7 +
.../table/types/inference/TypeInferenceUtil.java | 18 +-
.../table/types/inference/TypeStrategies.java | 20 +
.../flink/table/types/inference/TypeStrategy.java | 2 +
...TypeStrategy.java => ExplicitTypeStrategy.java} | 30 +-
...TypeStrategy.java => MatchingTypeStrategy.java} | 39 +-
.../inference/strategies/MissingTypeStrategy.java | 12 +-
.../validators/AndTypeArgumentValidator.java | 80 +
.../inference/validators/AnyTypeValidator.java | 72 +
.../validators/ExplicitTypeValidator.java | 85 +
...ypeValidator.java => LiteralTypeValidator.java} | 66 +-
.../validators/OrTypeArgumentValidator.java | 86 +
.../inference/validators/OrTypeInputValidator.java | 179 ++
.../inference/validators/PassingTypeValidator.java | 35 +-
.../validators/SequenceInputValidator.java | 112 +
.../validators/VaryingSequenceTypeValidator.java | 134 ++
.../flink/table/types/logical/DistinctType.java | 15 +-
.../types/logical/LegacyTypeInformationType.java | 4 +-
.../flink/table/types/logical/LogicalTypeRoot.java | 4 +-
.../table/types/logical/LogicalTypeVisitor.java | 4 +-
.../types/logical/{AnyType.java => RawType.java} | 22 +-
.../flink/table/types/logical/StructuredType.java | 101 +-
...ionAnyType.java => TypeInformationRawType.java} | 30 +-
.../types/logical/UnresolvedUserDefinedType.java | 60 +-
.../flink/table/types/logical/UserDefinedType.java | 24 +-
.../types/logical/utils/LogicalTypeCasts.java | 6 +-
.../logical/utils/LogicalTypeDefaultVisitor.java | 6 +-
.../types/logical/utils/LogicalTypeDuplicator.java | 63 +-
.../logical/utils/LogicalTypeGeneralization.java | 16 +-
.../types/logical/utils/LogicalTypeParser.java | 28 +-
.../utils/LegacyTypeInfoDataTypeConverter.java | 20 +-
.../types/utils/LogicalTypeDataTypeConverter.java | 6 +-
.../apache/flink/table/catalog/CatalogTest.java | 2 +-
.../apache/flink/table/types/DataTypesTest.java | 14 +-
.../types/LegacyTypeInfoDataTypeConverterTest.java | 2 +-
.../flink/table/types/LogicalTypeCastsTest.java | 10 +-
.../types/LogicalTypeCompatibleCheckTest.java | 27 +-
.../table/types/LogicalTypeDuplicatorTest.java | 18 +-
.../flink/table/types/LogicalTypeParserTest.java | 27 +-
.../apache/flink/table/types/LogicalTypesTest.java | 95 +-
.../types/inference/InputTypeValidatorsTest.java | 349 +++
.../table/types/inference/TypeStrategiesTest.java | 175 ++
.../types/inference/utils/CallContextMock.java | 75 +
.../inference/utils/FunctionDefinitionMock.java | 20 +-
.../table/planner/delegation/BatchExecutor.java | 68 +-
.../table/planner/delegation/ExecutorBase.java | 19 +-
.../table/planner/delegation/StreamExecutor.java | 14 +-
.../FirstValueWithRetractAggFunction.java | 6 +-
.../LastValueWithRetractAggFunction.java | 6 +-
.../operations/SqlToOperationConverter.java | 9 +
.../utils/DummyStreamExecutionEnvironment.java | 295 +++
.../ExecutorUtils.java} | 63 +-
.../table/planner/calcite/FlinkTypeFactory.scala | 12 +-
.../flink/table/planner/codegen/CodeGenUtils.scala | 12 +-
.../table/planner/codegen/ExprCodeGenerator.scala | 4 +-
.../table/planner/codegen/GenerateUtils.scala | 12 +-
.../planner/codegen/calls/FunctionGenerator.scala | 38 +-
.../planner/codegen/calls/ScalarOperatorGens.scala | 2 +-
.../table/planner/delegation/BatchPlanner.scala | 23 +-
.../table/planner/delegation/PlannerBase.scala | 5 +-
.../table/planner/delegation/StreamPlanner.scala | 18 +-
.../functions/utils/UserDefinedFunctionUtils.scala | 6 +-
.../plan/nodes/common/CommonLookupJoin.scala | 6 +-
.../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 +
.../planner/plan/schema/GenericRelDataType.scala | 13 +-
.../planner/plan/utils/AggFunctionFactory.scala | 2 +-
.../planner/codegen/SortCodeGeneratorTest.java | 16 +-
.../planner/delegation/BatchExecutorTest.java | 4 +-
.../operations/SqlToOperationConverterTest.java | 15 +-
.../runtime/utils/BatchAbstractTestBase.java | 2 +-
.../batch/sql/agg/AggregateReduceGroupingTest.xml | 16 +-
.../plan/batch/sql/agg/GroupingSetsTest.xml | 18 +-
.../physical/batch/EnforceLocalHashAggRuleTest.xml | 160 ++
.../physical/batch/EnforceLocalSortAggRuleTest.xml | 242 ++
.../flink/table/api/TableEnvironmentITCase.scala | 179 ++
.../flink/table/api/TableEnvironmentTest.scala | 25 +-
.../table/planner/catalog/CatalogTableITCase.scala | 17 +-
.../batch/EnforceLocalAggRuleTestBase.scala | 66 +
.../batch/EnforceLocalHashAggRuleTest.scala | 77 +
.../batch/EnforceLocalSortAggRuleTest.scala | 95 +
.../batch/sql/agg/AggregateITCaseBase.scala | 4 -
.../table/sqlexec/SqlToOperationConverter.java | 9 +
.../flink/table/api/internal/TableEnvImpl.scala | 6 +-
.../flink/table/calcite/FlinkTypeFactory.scala | 4 +-
.../table/sqlexec/SqlToOperationConverterTest.java | 11 +
.../flink/table/catalog/CatalogTableITCase.scala | 10 +
.../runtime/batch/sql/TableSourceITCase.scala | 19 +
.../flink/table/runtime/utils/CommonTestData.scala | 24 +
.../flink/table/dataformat/BinaryWriter.java | 2 +-
.../table/dataformat/DataFormatConverters.java | 6 +-
.../flink/table/dataformat/TypeGetterSetters.java | 2 +-
.../runtime/types/ClassLogicalTypeConverter.java | 2 +-
.../table/runtime/types/InternalSerializers.java | 6 +-
.../types/LogicalTypeDataTypeConverter.java | 4 +-
.../table/runtime/typeutils/TypeCheckUtils.java | 10 +-
.../flink/table/dataformat/NestedRowTest.java | 2 +-
.../runtime/types/LogicalTypeAssignableTest.java | 27 +-
.../runtime/typeutils/BaseArraySerializerTest.java | 2 +-
.../runtime/typeutils/BaseMapSerializerTest.java | 4 +-
flink-test-utils-parent/flink-test-utils/pom.xml | 2 +-
.../ZooKeeperLeaderElectionITCase.java | 2 +-
.../flink/yarn/CliFrontendRunWithYarnTest.java | 48 +-
.../util/NonDeployingYarnClusterDescriptor.java | 79 -
.../apache/flink/yarn/YarnClusterDescriptor.java | 51 +-
.../java/org/apache/flink/yarn/YarnConfigKeys.java | 1 -
.../apache/flink/yarn/cli/FlinkYarnSessionCli.java | 2 +-
.../apache/flink/yarn/FlinkYarnSessionCliTest.java | 12 +-
.../apache/flink/yarn/YarnResourceManagerTest.java | 12 +-
pom.xml | 3 +
tools/releasing/create_binary_release.sh | 4 +
tools/travis/splits/split_container.sh | 3 +-
tools/travis/splits/split_misc.sh | 6 +-
.../splits/{split_container.sh => split_tpcds.sh} | 10 +-
tools/travis/stage.sh | 14 +-
tools/travis_watchdog.sh | 4 +-
582 files changed, 34329 insertions(+), 2628 deletions(-)
create mode 100644 docs/_includes/generated/execution_checkpointing_configuration.html
create mode 100644 docs/_includes/generated/stream_pipeline_configuration.html
create mode 100644 flink-connectors/flink-hadoop-compatibility/src/test/java/org/apache/flink/api/java/hadoop/mapred/wrapper/HadoopInputSplitTest.java
create mode 100644 flink-core/src/main/java/org/apache/flink/configuration/ReadableConfigToConfigurationAdapter.java
copy {flink-formats => flink-end-to-end-tests/flink-tpcds-test}/pom.xml (50%)
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/src/main/java/org/apache/flink/table/tpcds/TpcdsTestProgram.java
copy flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/MissingTypeStrategy.java => flink-end-to-end-tests/flink-tpcds-test/src/main/java/org/apache/flink/table/tpcds/schema/Column.java (64%)
rename flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/SharedSlotOversubscribedException.java => flink-end-to-end-tests/flink-tpcds-test/src/main/java/org/apache/flink/table/tpcds/schema/TpcdsSchema.java (55%)
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/src/main/java/org/apache/flink/table/tpcds/schema/TpcdsSchemaProvider.java
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/src/main/java/org/apache/flink/table/tpcds/stats/CatalogTableStats.java
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/src/main/java/org/apache/flink/table/tpcds/stats/TpcdsStatsProvider.java
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/src/main/java/org/apache/flink/table/tpcds/utils/AnswerFormatter.java
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/src/main/java/org/apache/flink/table/tpcds/utils/TpcdsResultComparator.java
copy flink-yarn/src/test/resources/krb5.keytab => flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/README.md (100%)
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/answer_set/1.ans
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/answer_set/10.ans
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/answer_set/11.ans
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/answer_set/12.ans
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/answer_set/13.ans
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/answer_set/14a_NULLS_FIRST.ans
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/answer_set/14a_SQL_SERVER.ans
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/answer_set/14b_NULLS_FIRST.ans
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/answer_set/15_NULLS_FIRST.ans
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/answer_set/15_NULLS_LAST.ans
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/answer_set/16.ans
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/answer_set/17.ans
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/answer_set/18_NULLS_FIRST.ans
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/answer_set/18_NULLS_LAST.ans
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/answer_set/18_SQL_SERVER.ans
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/answer_set/19.ans
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/answer_set/2.ans
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/answer_set/20_NULLS_FIRST.ans
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/answer_set/20_NULLS_LAST.ans
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/answer_set/21_NULLS_FIRST.ans
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/answer_set/21_NULLS_LAST.ans
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/answer_set/22_NULLS_FIRST.ans
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/answer_set/22_NULLS_LAST.ans
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/answer_set/23_NULLS_LAST.ans
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/answer_set/23a_NULLS_FIRST.ans
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/answer_set/23b_NULLS_FIRST.ans
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/answer_set/24a.ans
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/answer_set/24b.ans
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/answer_set/25.ans
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/answer_set/26.ans
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/answer_set/27_NULLS_FIRST.ans
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/answer_set/27_NULLS_LAST.ans
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/answer_set/28.ans
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/answer_set/29.ans
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/answer_set/3.ans
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/answer_set/30.ans
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/answer_set/31.ans
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/answer_set/32.ans
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/answer_set/33.ans
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/answer_set/34_NULLS_FIRST.ans
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/answer_set/34_NULLS_LAST.ans
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/answer_set/35_NULLS_FIRST.ans
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/answer_set/35_NULLS_LAST.ans
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/answer_set/36_NULLS_FIRST.ans
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/answer_set/36_NULLS_LAST.ans
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/answer_set/37.ans
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/answer_set/38.ans
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/answer_set/39a.ans
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/answer_set/39b.ans
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/answer_set/4.ans
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/answer_set/40.ans
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/answer_set/41.ans
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/answer_set/42.ans
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/answer_set/43.ans
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/answer_set/44.ans
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/answer_set/45.ans
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/answer_set/46_NULLS_FIRST.ans
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/answer_set/46_NULLS_LAST.ans
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/answer_set/47.ans
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/answer_set/48.ans
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/answer_set/49.ans
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/answer_set/50.ans
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/answer_set/51.ans
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/answer_set/52.ans
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/answer_set/53.ans
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/answer_set/54.ans
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/answer_set/55.ans
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/answer_set/56_NULLS_FIRST.ans
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/answer_set/56_NULLS_LAST.ans
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/answer_set/57.ans
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/answer_set/58.ans
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/answer_set/59.ans
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/answer_set/5_NULLS_FIRST.ans
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/answer_set/5_NULLS_LAST.ans
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/answer_set/60.ans
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/answer_set/61.ans
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/answer_set/62_NULLS_FIRST.ans
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/answer_set/62_NULLS_LAST.ans
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/answer_set/63.ans
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/answer_set/64.ans
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/answer_set/65_NULLS_FIRST.ans
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/answer_set/65_NULLS_LAST.ans
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/answer_set/66_NULLS_FIRST.ans
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/answer_set/66_NULLS_LAST.ans
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/answer_set/67_NULLS_FIRST.ans
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/answer_set/67_NULLS_LAST.ans
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/answer_set/68_NULLS_FIRST.ans
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/answer_set/68_NULLS_LAST.ans
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/answer_set/69.ans
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/answer_set/6_NULLS_FIRST.ans
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/answer_set/6_NULLS_LAST.ans
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/answer_set/7.ans
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/answer_set/70.ans
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/answer_set/70_SQL_SERVER.ans
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/answer_set/71_NULLS_FIRST.ans
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/answer_set/71_NULLS_LAST.ans
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/answer_set/72_NULLS_FIRST.ans
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/answer_set/72_NULLS_LAST.ans
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/answer_set/73.ans
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/answer_set/74.ans
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/answer_set/75.ans
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/answer_set/76_NULLS_FIRST.ans
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/answer_set/76_NULLS_LAST.ans
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/answer_set/77_NULLS_FIRST.ans
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/answer_set/77_NULLS_LAST.ans
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/answer_set/77_SQL_SERVER.ans
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/answer_set/78.ans
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/answer_set/79_NULLS_FIRST.ans
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/answer_set/79_NULLS_LAST.ans
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/answer_set/8.ans
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/answer_set/80_NULLS_FIRST.ans
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/answer_set/80_NULLS_LAST.ans
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/answer_set/81.ans
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/answer_set/82.ans
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/answer_set/83.ans
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/answer_set/84.ans
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/answer_set/85.ans
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/answer_set/86_NULLS_FIRST.ans
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/answer_set/86_NULLS_LAST.ans
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/answer_set/87.ans
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/answer_set/88.ans
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/answer_set/89.ans
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/answer_set/8_SQL_SERVER.ans
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/answer_set/9.ans
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/answer_set/90.ans
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/answer_set/91.ans
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/answer_set/92.ans
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/answer_set/93_NULLS_FIRST.ans
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/answer_set/93_NULLS_LAST.ans
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/answer_set/94.ans
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/answer_set/95.ans
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/answer_set/96.ans
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/answer_set/97.ans
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/answer_set/98_NULLS_FIRST.ans
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/answer_set/98_NULLS_LAST.ans
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/answer_set/99_NULLS_FIRST.ans
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/answer_set/99_NULLS_LAST.ans
create mode 100755 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/data_generator.sh
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/query/query1.sql
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/query/query10.sql
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/query/query11.sql
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/query/query12.sql
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/query/query13.sql
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/query/query14a.sql
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/query/query14b.sql
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/query/query15.sql
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/query/query16.sql
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/query/query17.sql
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/query/query18.sql
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/query/query19.sql
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/query/query2.sql
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/query/query20.sql
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/query/query21.sql
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/query/query22.sql
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/query/query23a.sql
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/query/query23b.sql
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/query/query24a.sql
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/query/query24b.sql
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/query/query25.sql
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/query/query26.sql
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/query/query27.sql
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/query/query28.sql
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/query/query29.sql
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/query/query3.sql
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/query/query30.sql
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/query/query31.sql
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/query/query32.sql
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/query/query33.sql
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/query/query34.sql
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/query/query35.sql
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/query/query36.sql
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/query/query37.sql
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/query/query38.sql
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/query/query39a.sql
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/query/query39b.sql
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/query/query4.sql
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/query/query40.sql
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/query/query41.sql
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/query/query42.sql
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/query/query43.sql
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/query/query44.sql
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/query/query45.sql
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/query/query46.sql
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/query/query47.sql
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/query/query48.sql
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/query/query49.sql
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/query/query5.sql
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/query/query50.sql
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/query/query51.sql
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/query/query52.sql
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/query/query53.sql
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/query/query54.sql
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/query/query55.sql
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/query/query56.sql
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/query/query57.sql
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/query/query58.sql
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/query/query59.sql
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/query/query6.sql
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/query/query60.sql
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/query/query61.sql
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/query/query62.sql
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/query/query63.sql
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/query/query64.sql
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/query/query65.sql
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/query/query66.sql
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/query/query67.sql
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/query/query68.sql
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/query/query69.sql
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/query/query7.sql
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/query/query70.sql
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/query/query71.sql
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/query/query72.sql
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/query/query73.sql
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/query/query74.sql
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/query/query75.sql
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/query/query76.sql
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/query/query77.sql
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/query/query78.sql
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/query/query79.sql
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/query/query8.sql
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/query/query80.sql
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/query/query81.sql
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/query/query82.sql
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/query/query83.sql
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/query/query84.sql
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/query/query85.sql
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/query/query86.sql
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/query/query87.sql
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/query/query88.sql
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/query/query89.sql
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/query/query9.sql
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/query/query90.sql
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/query/query91.sql
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/query/query92.sql
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/query/query93.sql
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/query/query94.sql
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/query/query95.sql
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/query/query96.sql
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/query/query97.sql
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/query/query98.sql
create mode 100644 flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/query/query99.sql
create mode 100755 flink-end-to-end-tests/test-scripts/test_tpcds.sh
copy {flink-connectors/flink-orc => flink-formats/flink-compress}/pom.xml (55%)
create mode 100644 flink-formats/flink-compress/src/main/java/org/apache/flink/formats/compress/CompressWriterFactory.java
copy flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/strategy/SchedulingStrategyFactory.java => flink-formats/flink-compress/src/main/java/org/apache/flink/formats/compress/CompressWriters.java (66%)
copy flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/strategy/SchedulingStrategyFactory.java => flink-formats/flink-compress/src/main/java/org/apache/flink/formats/compress/extractor/DefaultExtractor.java (66%)
copy flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/strategy/SchedulingStrategyFactory.java => flink-formats/flink-compress/src/main/java/org/apache/flink/formats/compress/extractor/Extractor.java (66%)
create mode 100644 flink-formats/flink-compress/src/main/java/org/apache/flink/formats/compress/writers/HadoopCompressionBulkWriter.java
create mode 100644 flink-formats/flink-compress/src/main/java/org/apache/flink/formats/compress/writers/NoCompressionBulkWriter.java
create mode 100644 flink-formats/flink-compress/src/test/java/org/apache/flink/formats/compress/CompressWriterFactoryTest.java
copy flink-formats/{flink-sequence-file => flink-compress}/src/test/resources/log4j-test.properties (100%)
rename {flink-connectors => flink-formats}/flink-orc/pom.xml (87%)
rename {flink-connectors => flink-formats}/flink-orc/src/main/java/org/apache/flink/orc/OrcBatchReader.java (100%)
rename {flink-connectors => flink-formats}/flink-orc/src/main/java/org/apache/flink/orc/OrcRowInputFormat.java (100%)
rename {flink-connectors => flink-formats}/flink-orc/src/main/java/org/apache/flink/orc/OrcTableSource.java (100%)
rename {flink-connectors => flink-formats}/flink-orc/src/test/java/org/apache/flink/orc/OrcBatchReaderTest.java (100%)
rename {flink-connectors => flink-formats}/flink-orc/src/test/java/org/apache/flink/orc/OrcRowInputFormatTest.java (100%)
rename {flink-connectors => flink-formats}/flink-orc/src/test/java/org/apache/flink/orc/OrcTableSourceITCase.java (100%)
rename {flink-connectors => flink-formats}/flink-orc/src/test/java/org/apache/flink/orc/OrcTableSourceTest.java (100%)
rename {flink-connectors => flink-formats}/flink-orc/src/test/java/org/apache/flink/orc/util/OrcTestFileGenerator.java (100%)
rename {flink-connectors => flink-formats}/flink-orc/src/test/resources/log4j-test.properties (100%)
rename {flink-connectors => flink-formats}/flink-orc/src/test/resources/test-data-composites-with-nulls.orc (100%)
rename {flink-connectors => flink-formats}/flink-orc/src/test/resources/test-data-decimal.orc (100%)
rename {flink-connectors => flink-formats}/flink-orc/src/test/resources/test-data-flat.orc (100%)
rename {flink-connectors => flink-formats}/flink-orc/src/test/resources/test-data-nested.orc (100%)
rename {flink-connectors => flink-formats}/flink-orc/src/test/resources/test-data-nestedlist.orc (100%)
rename {flink-connectors => flink-formats}/flink-orc/src/test/resources/test-data-repeating.orc (100%)
rename {flink-connectors => flink-formats}/flink-orc/src/test/resources/test-data-timetypes.orc (100%)
create mode 100644 flink-kubernetes/pom.xml
delete mode 100644 flink-runtime/src/main/java/org/apache/flink/runtime/operators/chaining/GroupCombineChainedDriver.java
create mode 100644 flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/strategy/SchedulingStrategyUtils.java
create mode 100644 flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment/ExecutionCheckpointingOptions.java
create mode 100644 flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment/StreamPipelineOptions.java
create mode 100644 flink-streaming-java/src/test/java/org/apache/flink/streaming/api/environment/CheckpointConfigFromConfigurationTest.java
create mode 100644 flink-streaming-java/src/test/java/org/apache/flink/streaming/api/environment/StreamExecutionEnvironmentComplexConfigurationTest.java
create mode 100644 flink-streaming-java/src/test/java/org/apache/flink/streaming/api/environment/StreamExecutionEnvironmentConfigurationTest.java
copy flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobNotFinishedException.java => flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/operations/UseCatalogOperation.java (65%)
copy flink-table/{flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/MissingTypeStrategy.java => flink-table-api-java/src/main/java/org/apache/flink/table/operations/UseOperation.java} (65%)
copy flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/strategy/SchedulingStrategyFactory.java => flink-table/flink-table-api-java/src/test/java/org/apache/flink/table/functions/TestGenericUDF.java (66%)
copy flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/strategy/SchedulingStrategyFactory.java => flink-table/flink-table-api-java/src/test/java/org/apache/flink/table/functions/TestSimpleUDF.java (66%)
rename flink-table/{flink-table-api-java => flink-table-common}/src/main/java/org/apache/flink/table/catalog/UnresolvedIdentifier.java (85%)
copy flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/{InputTypeValidator.java => ArgumentTypeValidator.java} (62%)
create mode 100644 flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/ConstantArgumentCount.java
copy flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/{MissingTypeStrategy.java => ExplicitTypeStrategy.java} (63%)
copy flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/{MissingTypeStrategy.java => MatchingTypeStrategy.java} (50%)
create mode 100644 flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/validators/AndTypeArgumentValidator.java
create mode 100644 flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/validators/AnyTypeValidator.java
create mode 100644 flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/validators/ExplicitTypeValidator.java
copy flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/validators/{PassingTypeValidator.java => LiteralTypeValidator.java} (50%)
create mode 100644 flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/validators/OrTypeArgumentValidator.java
create mode 100644 flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/validators/OrTypeInputValidator.java
create mode 100644 flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/validators/SequenceInputValidator.java
create mode 100644 flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/validators/VaryingSequenceTypeValidator.java
rename flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/{AnyType.java => RawType.java} (87%)
rename flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/{TypeInformationAnyType.java => TypeInformationRawType.java} (81%)
create mode 100644 flink-table/flink-table-common/src/test/java/org/apache/flink/table/types/inference/InputTypeValidatorsTest.java
create mode 100644 flink-table/flink-table-common/src/test/java/org/apache/flink/table/types/inference/TypeStrategiesTest.java
create mode 100644 flink-table/flink-table-common/src/test/java/org/apache/flink/table/types/inference/utils/CallContextMock.java
copy flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/strategy/SchedulingStrategyFactory.java => flink-table/flink-table-common/src/test/java/org/apache/flink/table/types/inference/utils/FunctionDefinitionMock.java (66%)
create mode 100644 flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/utils/DummyStreamExecutionEnvironment.java
copy flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/{delegation/BatchExecutor.java => utils/ExecutorUtils.java} (66%)
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
create mode 100644 flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/api/TableEnvironmentITCase.scala
create mode 100644 flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/planner/plan/rules/physical/batch/EnforceLocalAggRuleTestBase.scala
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
delete mode 100644 flink-yarn-tests/src/test/java/org/apache/flink/yarn/util/NonDeployingYarnClusterDescriptor.java
copy tools/travis/splits/{split_container.sh => split_tpcds.sh} (72%)