1. 22 1月, 2020 1 次提交
    • D
      [FLINK-15519][configuration]Preserve logs from BashJavaUtils and make them part of TM logs · fcd00551
      Dawid Wysakowicz 提交于
      We build a separate jar for BashJavaUtils with bundled log4j classes and
      a configuration that logs to the stdout. Using this jar we run the
      utility to capture the output. Out of the last line we extract jvm
      parameters. The rest we pass as an environment variable (INHERITED_LOGS)
      to the TaskManager process.
      
      As part of the EnvironmentInformation printing we log whatever was
      passed through the INHERITED_LOGS in the TM/JM process.
      
      This closes #10850
      fcd00551
  2. 16 1月, 2020 2 次提交
  3. 15 1月, 2020 1 次提交
  4. 13 1月, 2020 2 次提交
  5. 10 1月, 2020 2 次提交
  6. 26 12月, 2019 1 次提交
  7. 14 12月, 2019 1 次提交
  8. 11 12月, 2019 2 次提交
  9. 08 12月, 2019 1 次提交
  10. 06 12月, 2019 1 次提交
  11. 05 12月, 2019 1 次提交
  12. 03 12月, 2019 6 次提交
  13. 29 11月, 2019 1 次提交
  14. 19 11月, 2019 1 次提交
    • W
      [FLINK-14581][python] Let python UDF execution no longer rely on the flink... · df9b757b
      Wei Zhong 提交于
      [FLINK-14581][python] Let python UDF execution no longer rely on the flink directory structure to support running python UDFs on yarn.
      
      This commit adds pyflink-udf-runner.sh, pyflink.zip, py4j-0.10.8.1-src.zip and
      cloudpickle-1.2.2-src.zip as resources into flink-python-{VERSION}.jar and extract
      during runtime. In this way, we don't need to care about the file path.
      
      This closes #10061.
      df9b757b
  15. 22 10月, 2019 1 次提交
  16. 21 10月, 2019 1 次提交
  17. 17 10月, 2019 1 次提交
  18. 15 10月, 2019 1 次提交
  19. 24 9月, 2019 1 次提交
  20. 18 9月, 2019 1 次提交
  21. 06 9月, 2019 1 次提交
  22. 08 8月, 2019 1 次提交
  23. 07 8月, 2019 1 次提交
  24. 31 7月, 2019 1 次提交
  25. 30 7月, 2019 3 次提交
  26. 26 7月, 2019 1 次提交
  27. 22 7月, 2019 1 次提交
  28. 19 7月, 2019 1 次提交
  29. 16 7月, 2019 1 次提交