1. 29 11月, 2017 2 次提交
  2. 27 11月, 2017 1 次提交
  3. 24 11月, 2017 1 次提交
  4. 22 11月, 2017 1 次提交
  5. 21 11月, 2017 1 次提交
  6. 20 11月, 2017 1 次提交
  7. 15 11月, 2017 2 次提交
  8. 13 11月, 2017 3 次提交
    • A
      [hotfix] Make end-to-end test scripts more robust · 8fa6cf94
      Aljoscha Krettek 提交于
      This uses traps to ensure that we properly do cleanups, remove config
      values and shutdown things.
      8fa6cf94
    • A
      e9e7c337
    • N
      [FLINK-7973] Fix shading and relocating Hadoop for the S3 filesystems · 0e5fb0b7
      Nico Kruber 提交于
      - do not shade everything, especially not JDK classes!
      -> instead define include patterns explicitly
      - do not shade core Flink classes (only those imported from flink-hadoop-fs)
      - hack around Hadoop loading (unshaded/non-relocated) classes based on names in
        the core-default.xml by overwriting the Configuration class (we may need to
        extend this for the mapred-default.xml and hdfs-defaults.xml):
      -> provide a core-default-shaded.xml file with shaded class names and copy and
        adapt the Configuration class of the respective Hadoop version to load this
        file instead of core-default.xml.
      
      Add checkstyle suppression pattern for the Hadoop Configuration classes
      
      Also fix the (integration) tests not working because they tried to load the
      relocated classes which are apparently not available there
      
      Remove minimizeJar from shading of flink-s3-fs-presto because this was
      causing "java.lang.ClassNotFoundException:
      org.apache.flink.fs.s3presto.shaded.org.apache.commons.logging.impl.LogFactoryImpl"
      since these classes are not statically imported and thus removed when
      minimizing.
      
      Fix s3-fs-presto not shading org.HdrHistogram
      
      Fix log4j being relocated in the S3 fs implementations
      
      Add shading checks to travis
      0e5fb0b7
  9. 10 11月, 2017 1 次提交
  10. 07 11月, 2017 1 次提交
  11. 03 11月, 2017 1 次提交
  12. 02 11月, 2017 1 次提交
  13. 01 11月, 2017 1 次提交
  14. 27 10月, 2017 1 次提交
    • K
      [FLINK-7908][QS] Restructure the queryable state module. · 0c771505
      kkloudas 提交于
      The QS module is split into core and client. The core should
      be put in the lib folder to enable queryable state, while the
      client is the one that the user will program against. The
      reason for the restructuring in mainly to remove the dependency
      on the flink-runtime from the user's program.
      0c771505
  15. 26 10月, 2017 1 次提交
  16. 25 10月, 2017 1 次提交
    • T
      [FLINK-7637] [kinesis] Fix at-least-once guarantee in FlinkKinesisProducer · 073b82c8
      Tzu-Li (Gordon) Tai 提交于
      Prior to this commit, there is no flushing of KPL outstanding records on
      checkpoints in the FlinkKinesisProducer. Likewise to the at-least-once
      issue on the Flink Kafka producer before, this may lead to data loss if
      there are asynchronous failing records after a checkpoint which the
      records was part of was completed.
      
      This closes #4871.
      073b82c8
  17. 24 10月, 2017 1 次提交
  18. 23 10月, 2017 1 次提交
  19. 19 10月, 2017 1 次提交
  20. 14 10月, 2017 2 次提交
    • A
      [FLINK-7809] Remove support for Scala 2.10 · a6039cab
      Aljoscha Krettek 提交于
      a6039cab
    • S
      [FLINK-5706] [file systems] Add S3 file systems without Hadoop dependencies · 991af365
      Stephan Ewen 提交于
      This adds two implementations of a file system that write to S3.
      Both are not actual re-implementations but wrap other implementations and shade dependencies.
      
      (1) A wrapper around Hadoop's s3a file system. By pulling a smaller dependency tree and
          shading all dependencies away, this keeps the appearance of Flink being Hadoop-free,
          from a dependency perspective.
      
      (2) The second S3 file system is from the Presto Project.
          Initial simple tests seem to indicate that it responds slightly faster
          and in a bit more lightweight manner to write/read/list requests, compared
          to the Hadoop s3a FS, but it has some semantical differences.
      
      This closes #4818
      991af365
  21. 10 10月, 2017 1 次提交
  22. 07 10月, 2017 2 次提交
  23. 06 10月, 2017 1 次提交
    • S
      [FLINK-7768] [core] Load File Systems via Java Service abstraction · 77e3701c
      Stephan Ewen 提交于
      This changes the discovery mechanism of file from static class name configurations
      to a service mechanism (META-INF/services).
      
      As part of that, it factors HDFS and MapR FS implementations into separate modules.
      
      With this change, users can add new filesystem implementations and make them available
      by simply adding them to the class path.
      77e3701c
  24. 28 9月, 2017 1 次提交
  25. 21 9月, 2017 1 次提交
  26. 19 9月, 2017 1 次提交
  27. 18 8月, 2017 1 次提交
  28. 15 8月, 2017 2 次提交
  29. 10 8月, 2017 2 次提交
  30. 08 8月, 2017 2 次提交
  31. 07 8月, 2017 1 次提交