Skip to content
Permalink
Branch: master
Commits on Jun 19, 2019
  1. [hotfix] Fix error message in BatchTableSourceScan & StreamTableSourc…

    sjwiesman authored and dawidwys committed Jun 19, 2019
    …eScan
  2. [FLINK-12268][runtime] Port SharedSlotsTest to new code base

    leesf authored and zentol committed Jun 19, 2019
  3. [FLINK-12264][runtime] Remove unused methods in ExecutionGraphTestUtils

    leesf authored and zentol committed Jun 19, 2019
  4. [FLINK-12843][network] Refactor the pin logic in ReleaseOnConsumption…

    zhijiangW authored and zentol committed Jun 17, 2019
    …ResultPartition
    
    The pin logic is for adding the reference counter based on number of subpartitions for ReleaseOnConsumptionResultPartition. It seems
    not necessary to do it in while loop as now, because the atomic counter would not be accessed by other threads during pin. If the
    ReleaseOnConsumptionResultPartition was not created yet, the createSubpartitionView would not be called actually resulting in
    PartitionNotFoundException. So we could simple increase the reference counter in ReleaseOnConsumptionResultPartition constructor directly.
  5. [hotfix][network][tests] Add new unit tests for ReleaseOnConsumptionR…

    zhijiangW authored and zentol committed Jun 17, 2019
    …esultPartition
    
    The process of ReleaseOnConsumptionResultPartition#onConsumedSubpartition was not covered by unit tests before, so adding a new test for it.
  6. [hotfix][streaming] Report correct value of currentProcessingTime in …

    pnowojski committed Jun 17, 2019
    …the exception
    
    Previously the actual and reported values were always of by small margin.
  7. [FLINK-12257][table-api][table-planner] Instantiate TableSource from …

    dawidwys committed Jun 5, 2019
    …CatalogTable
    
    This closes #8634
  8. [FLINK-10984][build] Remove flink-shaded-hadoop(-uber) modules

    sunjincheng121 authored and zentol committed Jun 19, 2019
  9. Revert "Revert "[FLINK-12143][e2e] Change end-to-end tests with file …

    1u0 authored and pnowojski committed Jun 17, 2019
    …system to use plugins mechanism""
    
    This reverts commit 24246b8.
  10. [FLINK-12143][runtime] Workaround for dynamic class loading in FS cre…

    1u0 authored and pnowojski committed Jun 17, 2019
    …ation: set thread context class loader to plugin's class loader
  11. [FLINK-12861][coordination] Remove legacy ListeningBehaviour

    TisonKun authored and zentol committed Jun 19, 2019
  12. [FLINK-12862][coordination] Remove legacy QuarantineHandler/-Monitor

    TisonKun authored and zentol committed Jun 19, 2019
  13. [hotfix][table] Add a summary method to expressions

    twalthr committed Jun 19, 2019
  14. [FLINK-12720][python][docs] Add the Python Table API Sphinx docs

    HuangXingBo authored and sunjincheng121 committed Jun 13, 2019
    This closes #8774
  15. [FLINK-12364] Introduce CheckpointFailureManager for centralized chec…

    yanghua authored and StefanRRichter committed Jun 19, 2019
    …kpoint failure handling
  16. [FLINK-12878][travis] Move flink-table-planner-blink & flink-table-ru…

    godfreyhe authored and KurtYoung committed Jun 19, 2019
    …ntime-blink to separate profile
    
    This closes #8772
  17. [FLINK-12874][table-common] Improve the semantics of zero length strings

    twalthr committed Jun 18, 2019
    This closes #8781.
Commits on Jun 18, 2019
  1. [FLINK-12892][table][hive] serialize catalog table to properties for …

    bowenli86 committed Jun 18, 2019
    …table discovery service
    
    This PR enables serialization of catalog table to properties for table discovery service and table factory to initiate source/sink from those properties.
    
    This closes #8784.
  2. [FLINK-12875][hive] support converting input args of char, varchar, b…

    bowenli86 committed Jun 17, 2019
    …ytes, timestamp, date for Hive functions
    
    This PR adds support for converting input args of char, varchar, bytes, timestamp, date for Hive functions.
    
    This closes #8769.
  3. [FLINK-12711][table] Separate function implementation and definition

    twalthr committed Jun 7, 2019
    This closes #8661.
  4. [FLINK-12832][datastream] Use new StreamGraphGenerator configurabilit…

    ifndef-SleePy authored and aljoscha committed Jun 14, 2019
    …y in Blink Table Runner
  5. [FLINK-12686][datastream] Configure co-location group of iteration no…

    ifndef-SleePy authored and aljoscha committed Jun 14, 2019
    …des in StreamGraph instread of in StreamingJobGraphGenerator
  6. [FLINK-12867][sql-parser] Add insert overwrite grammar as HIVE dialect

    danny0405 authored and KurtYoung committed Jun 5, 2019
    This closes #8758
  7. [hotfix][python][test] fix IDE test problems and unified assertion usage

    sunjincheng121 committed Jun 18, 2019
    This closes #8777
  8. [FLINK-12864][python][tests] Improves the Python Table API test cases…

    dianfu authored and sunjincheng121 committed Jun 16, 2019
    … performance
    
    This closes #8755
Older
You can’t perform that action at this time.