Guest User

Flink Log

a guest
Feb 4th, 2015
211
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
  1. Found a yarn properties file (.yarn-properties) file, using "ovhbhshad4.had.1aconomy.com:6170" to connect to the JobManager
  2. 02/04/2015 13:28:54: Job execution switched to status RUNNING
  3. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1426) (org.apache.flink.api.java.io.CsvInputFormat)) (1/24) switched to SCHEDULED
  4. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1426) (org.apache.flink.api.java.io.CsvInputFormat)) (1/24) switched to DEPLOYING
  5. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1426) (org.apache.flink.api.java.io.CsvInputFormat)) (2/24) switched to SCHEDULED
  6. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1426) (org.apache.flink.api.java.io.CsvInputFormat)) (2/24) switched to DEPLOYING
  7. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1426) (org.apache.flink.api.java.io.CsvInputFormat)) (3/24) switched to SCHEDULED
  8. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1426) (org.apache.flink.api.java.io.CsvInputFormat)) (3/24) switched to DEPLOYING
  9. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1426) (org.apache.flink.api.java.io.CsvInputFormat)) (4/24) switched to SCHEDULED
  10. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1426) (org.apache.flink.api.java.io.CsvInputFormat)) (4/24) switched to DEPLOYING
  11. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1426) (org.apache.flink.api.java.io.CsvInputFormat)) (5/24) switched to SCHEDULED
  12. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1426) (org.apache.flink.api.java.io.CsvInputFormat)) (5/24) switched to DEPLOYING
  13. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1426) (org.apache.flink.api.java.io.CsvInputFormat)) (6/24) switched to SCHEDULED
  14. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1426) (org.apache.flink.api.java.io.CsvInputFormat)) (6/24) switched to DEPLOYING
  15. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1426) (org.apache.flink.api.java.io.CsvInputFormat)) (7/24) switched to SCHEDULED
  16. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1426) (org.apache.flink.api.java.io.CsvInputFormat)) (7/24) switched to DEPLOYING
  17. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1426) (org.apache.flink.api.java.io.CsvInputFormat)) (8/24) switched to SCHEDULED
  18. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1426) (org.apache.flink.api.java.io.CsvInputFormat)) (8/24) switched to DEPLOYING
  19. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1426) (org.apache.flink.api.java.io.CsvInputFormat)) (9/24) switched to SCHEDULED
  20. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1426) (org.apache.flink.api.java.io.CsvInputFormat)) (9/24) switched to DEPLOYING
  21. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1426) (org.apache.flink.api.java.io.CsvInputFormat)) (10/24) switched to SCHEDULED
  22. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1426) (org.apache.flink.api.java.io.CsvInputFormat)) (10/24) switched to DEPLOYING
  23. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1426) (org.apache.flink.api.java.io.CsvInputFormat)) (11/24) switched to SCHEDULED
  24. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1426) (org.apache.flink.api.java.io.CsvInputFormat)) (11/24) switched to DEPLOYING
  25. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1426) (org.apache.flink.api.java.io.CsvInputFormat)) (12/24) switched to SCHEDULED
  26. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1426) (org.apache.flink.api.java.io.CsvInputFormat)) (12/24) switched to DEPLOYING
  27. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1426) (org.apache.flink.api.java.io.CsvInputFormat)) (13/24) switched to SCHEDULED
  28. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1426) (org.apache.flink.api.java.io.CsvInputFormat)) (13/24) switched to DEPLOYING
  29. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1426) (org.apache.flink.api.java.io.CsvInputFormat)) (14/24) switched to SCHEDULED
  30. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1426) (org.apache.flink.api.java.io.CsvInputFormat)) (14/24) switched to DEPLOYING
  31. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1426) (org.apache.flink.api.java.io.CsvInputFormat)) (15/24) switched to SCHEDULED
  32. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1426) (org.apache.flink.api.java.io.CsvInputFormat)) (15/24) switched to DEPLOYING
  33. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1426) (org.apache.flink.api.java.io.CsvInputFormat)) (16/24) switched to SCHEDULED
  34. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1426) (org.apache.flink.api.java.io.CsvInputFormat)) (16/24) switched to DEPLOYING
  35. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1426) (org.apache.flink.api.java.io.CsvInputFormat)) (17/24) switched to SCHEDULED
  36. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1426) (org.apache.flink.api.java.io.CsvInputFormat)) (17/24) switched to DEPLOYING
  37. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1426) (org.apache.flink.api.java.io.CsvInputFormat)) (18/24) switched to SCHEDULED
  38. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1426) (org.apache.flink.api.java.io.CsvInputFormat)) (18/24) switched to DEPLOYING
  39. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1426) (org.apache.flink.api.java.io.CsvInputFormat)) (19/24) switched to SCHEDULED
  40. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1426) (org.apache.flink.api.java.io.CsvInputFormat)) (19/24) switched to DEPLOYING
  41. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1426) (org.apache.flink.api.java.io.CsvInputFormat)) (20/24) switched to SCHEDULED
  42. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1426) (org.apache.flink.api.java.io.CsvInputFormat)) (20/24) switched to DEPLOYING
  43. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1426) (org.apache.flink.api.java.io.CsvInputFormat)) (21/24) switched to SCHEDULED
  44. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1426) (org.apache.flink.api.java.io.CsvInputFormat)) (21/24) switched to DEPLOYING
  45. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1426) (org.apache.flink.api.java.io.CsvInputFormat)) (22/24) switched to SCHEDULED
  46. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1426) (org.apache.flink.api.java.io.CsvInputFormat)) (22/24) switched to DEPLOYING
  47. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1426) (org.apache.flink.api.java.io.CsvInputFormat)) (23/24) switched to SCHEDULED
  48. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1426) (org.apache.flink.api.java.io.CsvInputFormat)) (23/24) switched to DEPLOYING
  49. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1426) (org.apache.flink.api.java.io.CsvInputFormat)) (24/24) switched to SCHEDULED
  50. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1426) (org.apache.flink.api.java.io.CsvInputFormat)) (24/24) switched to DEPLOYING
  51. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1398) (org.apache.flink.api.java.io.TextInputFormat)) -> Map (Map at main(FlightConnectionJoiner.java:1399)) (1/24) switched to SCHEDULED
  52. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1398) (org.apache.flink.api.java.io.TextInputFormat)) -> Map (Map at main(FlightConnectionJoiner.java:1399)) (1/24) switched to DEPLOYING
  53. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1398) (org.apache.flink.api.java.io.TextInputFormat)) -> Map (Map at main(FlightConnectionJoiner.java:1399)) (2/24) switched to SCHEDULED
  54. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1398) (org.apache.flink.api.java.io.TextInputFormat)) -> Map (Map at main(FlightConnectionJoiner.java:1399)) (2/24) switched to DEPLOYING
  55. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1398) (org.apache.flink.api.java.io.TextInputFormat)) -> Map (Map at main(FlightConnectionJoiner.java:1399)) (3/24) switched to SCHEDULED
  56. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1398) (org.apache.flink.api.java.io.TextInputFormat)) -> Map (Map at main(FlightConnectionJoiner.java:1399)) (3/24) switched to DEPLOYING
  57. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1398) (org.apache.flink.api.java.io.TextInputFormat)) -> Map (Map at main(FlightConnectionJoiner.java:1399)) (4/24) switched to SCHEDULED
  58. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1398) (org.apache.flink.api.java.io.TextInputFormat)) -> Map (Map at main(FlightConnectionJoiner.java:1399)) (4/24) switched to DEPLOYING
  59. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1398) (org.apache.flink.api.java.io.TextInputFormat)) -> Map (Map at main(FlightConnectionJoiner.java:1399)) (5/24) switched to SCHEDULED
  60. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1398) (org.apache.flink.api.java.io.TextInputFormat)) -> Map (Map at main(FlightConnectionJoiner.java:1399)) (5/24) switched to DEPLOYING
  61. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1398) (org.apache.flink.api.java.io.TextInputFormat)) -> Map (Map at main(FlightConnectionJoiner.java:1399)) (6/24) switched to SCHEDULED
  62. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1398) (org.apache.flink.api.java.io.TextInputFormat)) -> Map (Map at main(FlightConnectionJoiner.java:1399)) (6/24) switched to DEPLOYING
  63. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1398) (org.apache.flink.api.java.io.TextInputFormat)) -> Map (Map at main(FlightConnectionJoiner.java:1399)) (7/24) switched to SCHEDULED
  64. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1398) (org.apache.flink.api.java.io.TextInputFormat)) -> Map (Map at main(FlightConnectionJoiner.java:1399)) (7/24) switched to DEPLOYING
  65. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1398) (org.apache.flink.api.java.io.TextInputFormat)) -> Map (Map at main(FlightConnectionJoiner.java:1399)) (8/24) switched to SCHEDULED
  66. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1398) (org.apache.flink.api.java.io.TextInputFormat)) -> Map (Map at main(FlightConnectionJoiner.java:1399)) (8/24) switched to DEPLOYING
  67. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1398) (org.apache.flink.api.java.io.TextInputFormat)) -> Map (Map at main(FlightConnectionJoiner.java:1399)) (9/24) switched to SCHEDULED
  68. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1398) (org.apache.flink.api.java.io.TextInputFormat)) -> Map (Map at main(FlightConnectionJoiner.java:1399)) (9/24) switched to DEPLOYING
  69. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1398) (org.apache.flink.api.java.io.TextInputFormat)) -> Map (Map at main(FlightConnectionJoiner.java:1399)) (10/24) switched to SCHEDULED
  70. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1398) (org.apache.flink.api.java.io.TextInputFormat)) -> Map (Map at main(FlightConnectionJoiner.java:1399)) (10/24) switched to DEPLOYING
  71. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1398) (org.apache.flink.api.java.io.TextInputFormat)) -> Map (Map at main(FlightConnectionJoiner.java:1399)) (11/24) switched to SCHEDULED
  72. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1398) (org.apache.flink.api.java.io.TextInputFormat)) -> Map (Map at main(FlightConnectionJoiner.java:1399)) (11/24) switched to DEPLOYING
  73. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1398) (org.apache.flink.api.java.io.TextInputFormat)) -> Map (Map at main(FlightConnectionJoiner.java:1399)) (12/24) switched to SCHEDULED
  74. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1398) (org.apache.flink.api.java.io.TextInputFormat)) -> Map (Map at main(FlightConnectionJoiner.java:1399)) (12/24) switched to DEPLOYING
  75. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1398) (org.apache.flink.api.java.io.TextInputFormat)) -> Map (Map at main(FlightConnectionJoiner.java:1399)) (13/24) switched to SCHEDULED
  76. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1398) (org.apache.flink.api.java.io.TextInputFormat)) -> Map (Map at main(FlightConnectionJoiner.java:1399)) (13/24) switched to DEPLOYING
  77. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1398) (org.apache.flink.api.java.io.TextInputFormat)) -> Map (Map at main(FlightConnectionJoiner.java:1399)) (14/24) switched to SCHEDULED
  78. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1398) (org.apache.flink.api.java.io.TextInputFormat)) -> Map (Map at main(FlightConnectionJoiner.java:1399)) (14/24) switched to DEPLOYING
  79. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1398) (org.apache.flink.api.java.io.TextInputFormat)) -> Map (Map at main(FlightConnectionJoiner.java:1399)) (15/24) switched to SCHEDULED
  80. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1398) (org.apache.flink.api.java.io.TextInputFormat)) -> Map (Map at main(FlightConnectionJoiner.java:1399)) (15/24) switched to DEPLOYING
  81. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1398) (org.apache.flink.api.java.io.TextInputFormat)) -> Map (Map at main(FlightConnectionJoiner.java:1399)) (16/24) switched to SCHEDULED
  82. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1398) (org.apache.flink.api.java.io.TextInputFormat)) -> Map (Map at main(FlightConnectionJoiner.java:1399)) (16/24) switched to DEPLOYING
  83. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1398) (org.apache.flink.api.java.io.TextInputFormat)) -> Map (Map at main(FlightConnectionJoiner.java:1399)) (17/24) switched to SCHEDULED
  84. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1398) (org.apache.flink.api.java.io.TextInputFormat)) -> Map (Map at main(FlightConnectionJoiner.java:1399)) (17/24) switched to DEPLOYING
  85. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1398) (org.apache.flink.api.java.io.TextInputFormat)) -> Map (Map at main(FlightConnectionJoiner.java:1399)) (18/24) switched to SCHEDULED
  86. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1398) (org.apache.flink.api.java.io.TextInputFormat)) -> Map (Map at main(FlightConnectionJoiner.java:1399)) (18/24) switched to DEPLOYING
  87. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1398) (org.apache.flink.api.java.io.TextInputFormat)) -> Map (Map at main(FlightConnectionJoiner.java:1399)) (19/24) switched to SCHEDULED
  88. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1398) (org.apache.flink.api.java.io.TextInputFormat)) -> Map (Map at main(FlightConnectionJoiner.java:1399)) (19/24) switched to DEPLOYING
  89. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1398) (org.apache.flink.api.java.io.TextInputFormat)) -> Map (Map at main(FlightConnectionJoiner.java:1399)) (20/24) switched to SCHEDULED
  90. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1398) (org.apache.flink.api.java.io.TextInputFormat)) -> Map (Map at main(FlightConnectionJoiner.java:1399)) (20/24) switched to DEPLOYING
  91. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1398) (org.apache.flink.api.java.io.TextInputFormat)) -> Map (Map at main(FlightConnectionJoiner.java:1399)) (21/24) switched to SCHEDULED
  92. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1398) (org.apache.flink.api.java.io.TextInputFormat)) -> Map (Map at main(FlightConnectionJoiner.java:1399)) (21/24) switched to DEPLOYING
  93. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1398) (org.apache.flink.api.java.io.TextInputFormat)) -> Map (Map at main(FlightConnectionJoiner.java:1399)) (22/24) switched to SCHEDULED
  94. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1398) (org.apache.flink.api.java.io.TextInputFormat)) -> Map (Map at main(FlightConnectionJoiner.java:1399)) (22/24) switched to DEPLOYING
  95. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1398) (org.apache.flink.api.java.io.TextInputFormat)) -> Map (Map at main(FlightConnectionJoiner.java:1399)) (23/24) switched to SCHEDULED
  96. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1398) (org.apache.flink.api.java.io.TextInputFormat)) -> Map (Map at main(FlightConnectionJoiner.java:1399)) (23/24) switched to DEPLOYING
  97. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1398) (org.apache.flink.api.java.io.TextInputFormat)) -> Map (Map at main(FlightConnectionJoiner.java:1399)) (24/24) switched to SCHEDULED
  98. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1398) (org.apache.flink.api.java.io.TextInputFormat)) -> Map (Map at main(FlightConnectionJoiner.java:1399)) (24/24) switched to DEPLOYING
  99. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1423) (org.apache.flink.api.java.io.CsvInputFormat)) (1/24) switched to SCHEDULED
  100. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1423) (org.apache.flink.api.java.io.CsvInputFormat)) (1/24) switched to DEPLOYING
  101. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1423) (org.apache.flink.api.java.io.CsvInputFormat)) (2/24) switched to SCHEDULED
  102. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1423) (org.apache.flink.api.java.io.CsvInputFormat)) (2/24) switched to DEPLOYING
  103. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1423) (org.apache.flink.api.java.io.CsvInputFormat)) (3/24) switched to SCHEDULED
  104. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1423) (org.apache.flink.api.java.io.CsvInputFormat)) (3/24) switched to DEPLOYING
  105. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1423) (org.apache.flink.api.java.io.CsvInputFormat)) (4/24) switched to SCHEDULED
  106. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1423) (org.apache.flink.api.java.io.CsvInputFormat)) (4/24) switched to DEPLOYING
  107. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1423) (org.apache.flink.api.java.io.CsvInputFormat)) (5/24) switched to SCHEDULED
  108. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1423) (org.apache.flink.api.java.io.CsvInputFormat)) (5/24) switched to DEPLOYING
  109. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1423) (org.apache.flink.api.java.io.CsvInputFormat)) (6/24) switched to SCHEDULED
  110. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1423) (org.apache.flink.api.java.io.CsvInputFormat)) (6/24) switched to DEPLOYING
  111. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1423) (org.apache.flink.api.java.io.CsvInputFormat)) (7/24) switched to SCHEDULED
  112. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1423) (org.apache.flink.api.java.io.CsvInputFormat)) (7/24) switched to DEPLOYING
  113. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1423) (org.apache.flink.api.java.io.CsvInputFormat)) (8/24) switched to SCHEDULED
  114. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1423) (org.apache.flink.api.java.io.CsvInputFormat)) (8/24) switched to DEPLOYING
  115. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1423) (org.apache.flink.api.java.io.CsvInputFormat)) (9/24) switched to SCHEDULED
  116. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1423) (org.apache.flink.api.java.io.CsvInputFormat)) (9/24) switched to DEPLOYING
  117. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1423) (org.apache.flink.api.java.io.CsvInputFormat)) (10/24) switched to SCHEDULED
  118. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1423) (org.apache.flink.api.java.io.CsvInputFormat)) (10/24) switched to DEPLOYING
  119. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1426) (org.apache.flink.api.java.io.CsvInputFormat)) (1/24) switched to RUNNING
  120. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1423) (org.apache.flink.api.java.io.CsvInputFormat)) (11/24) switched to SCHEDULED
  121. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1423) (org.apache.flink.api.java.io.CsvInputFormat)) (11/24) switched to DEPLOYING
  122. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1423) (org.apache.flink.api.java.io.CsvInputFormat)) (12/24) switched to SCHEDULED
  123. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1423) (org.apache.flink.api.java.io.CsvInputFormat)) (12/24) switched to DEPLOYING
  124. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1423) (org.apache.flink.api.java.io.CsvInputFormat)) (13/24) switched to SCHEDULED
  125. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1423) (org.apache.flink.api.java.io.CsvInputFormat)) (13/24) switched to DEPLOYING
  126. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1423) (org.apache.flink.api.java.io.CsvInputFormat)) (14/24) switched to SCHEDULED
  127. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1423) (org.apache.flink.api.java.io.CsvInputFormat)) (14/24) switched to DEPLOYING
  128. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1423) (org.apache.flink.api.java.io.CsvInputFormat)) (15/24) switched to SCHEDULED
  129. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1423) (org.apache.flink.api.java.io.CsvInputFormat)) (15/24) switched to DEPLOYING
  130. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1423) (org.apache.flink.api.java.io.CsvInputFormat)) (16/24) switched to SCHEDULED
  131. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1423) (org.apache.flink.api.java.io.CsvInputFormat)) (16/24) switched to DEPLOYING
  132. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1423) (org.apache.flink.api.java.io.CsvInputFormat)) (17/24) switched to SCHEDULED
  133. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1423) (org.apache.flink.api.java.io.CsvInputFormat)) (17/24) switched to DEPLOYING
  134. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1423) (org.apache.flink.api.java.io.CsvInputFormat)) (18/24) switched to SCHEDULED
  135. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1423) (org.apache.flink.api.java.io.CsvInputFormat)) (18/24) switched to DEPLOYING
  136. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1423) (org.apache.flink.api.java.io.CsvInputFormat)) (19/24) switched to SCHEDULED
  137. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1423) (org.apache.flink.api.java.io.CsvInputFormat)) (19/24) switched to DEPLOYING
  138. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1423) (org.apache.flink.api.java.io.CsvInputFormat)) (20/24) switched to SCHEDULED
  139. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1423) (org.apache.flink.api.java.io.CsvInputFormat)) (20/24) switched to DEPLOYING
  140. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1423) (org.apache.flink.api.java.io.CsvInputFormat)) (21/24) switched to SCHEDULED
  141. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1423) (org.apache.flink.api.java.io.CsvInputFormat)) (21/24) switched to DEPLOYING
  142. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1423) (org.apache.flink.api.java.io.CsvInputFormat)) (22/24) switched to SCHEDULED
  143. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1423) (org.apache.flink.api.java.io.CsvInputFormat)) (22/24) switched to DEPLOYING
  144. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1423) (org.apache.flink.api.java.io.CsvInputFormat)) (23/24) switched to SCHEDULED
  145. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1423) (org.apache.flink.api.java.io.CsvInputFormat)) (23/24) switched to DEPLOYING
  146. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1423) (org.apache.flink.api.java.io.CsvInputFormat)) (24/24) switched to SCHEDULED
  147. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1423) (org.apache.flink.api.java.io.CsvInputFormat)) (24/24) switched to DEPLOYING
  148. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1394) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1395)) (1/24) switched to SCHEDULED
  149. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1394) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1395)) (1/24) switched to DEPLOYING
  150. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1394) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1395)) (2/24) switched to SCHEDULED
  151. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1394) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1395)) (2/24) switched to DEPLOYING
  152. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1394) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1395)) (3/24) switched to SCHEDULED
  153. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1394) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1395)) (3/24) switched to DEPLOYING
  154. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1394) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1395)) (4/24) switched to SCHEDULED
  155. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1394) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1395)) (4/24) switched to DEPLOYING
  156. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1394) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1395)) (5/24) switched to SCHEDULED
  157. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1394) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1395)) (5/24) switched to DEPLOYING
  158. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1394) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1395)) (6/24) switched to SCHEDULED
  159. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1394) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1395)) (6/24) switched to DEPLOYING
  160. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1394) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1395)) (7/24) switched to SCHEDULED
  161. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1394) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1395)) (7/24) switched to DEPLOYING
  162. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1394) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1395)) (8/24) switched to SCHEDULED
  163. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1394) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1395)) (8/24) switched to DEPLOYING
  164. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1394) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1395)) (9/24) switched to SCHEDULED
  165. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1394) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1395)) (9/24) switched to DEPLOYING
  166. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1394) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1395)) (10/24) switched to SCHEDULED
  167. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1394) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1395)) (10/24) switched to DEPLOYING
  168. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1394) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1395)) (11/24) switched to SCHEDULED
  169. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1394) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1395)) (11/24) switched to DEPLOYING
  170. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1394) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1395)) (12/24) switched to SCHEDULED
  171. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1394) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1395)) (12/24) switched to DEPLOYING
  172. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1394) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1395)) (13/24) switched to SCHEDULED
  173. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1394) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1395)) (13/24) switched to DEPLOYING
  174. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1394) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1395)) (14/24) switched to SCHEDULED
  175. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1394) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1395)) (14/24) switched to DEPLOYING
  176. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1394) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1395)) (15/24) switched to SCHEDULED
  177. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1394) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1395)) (15/24) switched to DEPLOYING
  178. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1394) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1395)) (16/24) switched to SCHEDULED
  179. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1394) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1395)) (16/24) switched to DEPLOYING
  180. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1394) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1395)) (17/24) switched to SCHEDULED
  181. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1394) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1395)) (17/24) switched to DEPLOYING
  182. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1394) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1395)) (18/24) switched to SCHEDULED
  183. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1394) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1395)) (18/24) switched to DEPLOYING
  184. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1394) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1395)) (19/24) switched to SCHEDULED
  185. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1394) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1395)) (19/24) switched to DEPLOYING
  186. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1394) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1395)) (20/24) switched to SCHEDULED
  187. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1394) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1395)) (20/24) switched to DEPLOYING
  188. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1394) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1395)) (21/24) switched to SCHEDULED
  189. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1394) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1395)) (21/24) switched to DEPLOYING
  190. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1394) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1395)) (22/24) switched to SCHEDULED
  191. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1394) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1395)) (22/24) switched to DEPLOYING
  192. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1394) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1395)) (23/24) switched to SCHEDULED
  193. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1394) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1395)) (23/24) switched to DEPLOYING
  194. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1394) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1395)) (24/24) switched to SCHEDULED
  195. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1394) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1395)) (24/24) switched to DEPLOYING
  196. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1390) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1391)) (1/24) switched to SCHEDULED
  197. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1390) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1391)) (1/24) switched to DEPLOYING
  198. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1390) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1391)) (2/24) switched to SCHEDULED
  199. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1390) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1391)) (2/24) switched to DEPLOYING
  200. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1390) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1391)) (3/24) switched to SCHEDULED
  201. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1390) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1391)) (3/24) switched to DEPLOYING
  202. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1390) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1391)) (4/24) switched to SCHEDULED
  203. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1390) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1391)) (4/24) switched to DEPLOYING
  204. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1390) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1391)) (5/24) switched to SCHEDULED
  205. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1390) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1391)) (5/24) switched to DEPLOYING
  206. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1390) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1391)) (6/24) switched to SCHEDULED
  207. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1390) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1391)) (6/24) switched to DEPLOYING
  208. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1390) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1391)) (7/24) switched to SCHEDULED
  209. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1390) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1391)) (7/24) switched to DEPLOYING
  210. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1390) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1391)) (8/24) switched to SCHEDULED
  211. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1390) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1391)) (8/24) switched to DEPLOYING
  212. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1390) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1391)) (9/24) switched to SCHEDULED
  213. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1390) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1391)) (9/24) switched to DEPLOYING
  214. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1390) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1391)) (10/24) switched to SCHEDULED
  215. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1390) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1391)) (10/24) switched to DEPLOYING
  216. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1390) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1391)) (11/24) switched to SCHEDULED
  217. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1390) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1391)) (11/24) switched to DEPLOYING
  218. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1390) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1391)) (12/24) switched to SCHEDULED
  219. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1390) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1391)) (12/24) switched to DEPLOYING
  220. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1390) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1391)) (13/24) switched to SCHEDULED
  221. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1390) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1391)) (13/24) switched to DEPLOYING
  222. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1390) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1391)) (14/24) switched to SCHEDULED
  223. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1390) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1391)) (14/24) switched to DEPLOYING
  224. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1390) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1391)) (15/24) switched to SCHEDULED
  225. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1390) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1391)) (15/24) switched to DEPLOYING
  226. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1390) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1391)) (16/24) switched to SCHEDULED
  227. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1390) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1391)) (16/24) switched to DEPLOYING
  228. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1390) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1391)) (17/24) switched to SCHEDULED
  229. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1390) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1391)) (17/24) switched to DEPLOYING
  230. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1390) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1391)) (18/24) switched to SCHEDULED
  231. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1390) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1391)) (18/24) switched to DEPLOYING
  232. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1390) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1391)) (19/24) switched to SCHEDULED
  233. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1390) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1391)) (19/24) switched to DEPLOYING
  234. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1390) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1391)) (20/24) switched to SCHEDULED
  235. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1390) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1391)) (20/24) switched to DEPLOYING
  236. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1390) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1391)) (21/24) switched to SCHEDULED
  237. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1390) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1391)) (21/24) switched to DEPLOYING
  238. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1390) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1391)) (22/24) switched to SCHEDULED
  239. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1390) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1391)) (22/24) switched to DEPLOYING
  240. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1390) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1391)) (23/24) switched to SCHEDULED
  241. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1390) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1391)) (23/24) switched to DEPLOYING
  242. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1390) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1391)) (24/24) switched to SCHEDULED
  243. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1390) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1391)) (24/24) switched to DEPLOYING
  244. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1426) (org.apache.flink.api.java.io.CsvInputFormat)) (24/24) switched to RUNNING
  245. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1426) (org.apache.flink.api.java.io.CsvInputFormat)) (3/24) switched to FAILED
  246. java.lang.Exception: Failed to deploy the task DataSource (at main(FlightConnectionJoiner.java:1426) (org.apache.flink.api.java.io.CsvInputFormat)) (3/24) - execution #0 to slot SubSlot 0 (41ea5741bcb1ec3073069e8c6f901acb (1) - ALLOCATED/ALIVE): java.io.FileNotFoundException: /tmp/blobStore-7d93e071-4515-4d27-8d4e-c2983a800077/cache/blob_0bfb661afec4ff2bff2dbb3993a1f6ab69106a2e (No such file or directory)
  247. at java.io.FileOutputStream.open(Native Method)
  248. at java.io.FileOutputStream.<init>(FileOutputStream.java:221)
  249. at java.io.FileOutputStream.<init>(FileOutputStream.java:171)
  250. at org.apache.flink.runtime.blob.BlobCache.getURL(BlobCache.java:103)
  251. at org.apache.flink.runtime.execution.librarycache.BlobLibraryCacheManager.registerReferenceToBlobKeyAndGetURL(BlobLibraryCacheManager.java:225)
  252. at org.apache.flink.runtime.execution.librarycache.BlobLibraryCacheManager.registerTask(BlobLibraryCacheManager.java:111)
  253. at org.apache.flink.runtime.taskmanager.TaskManager.submitTask(TaskManager.java:597)
  254. at sun.reflect.GeneratedMethodAccessor2.invoke(Unknown Source)
  255. at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
  256. at java.lang.reflect.Method.invoke(Method.java:606)
  257. at org.apache.flink.runtime.ipc.RPC$Server.call(RPC.java:420)
  258. at org.apache.flink.runtime.ipc.Server$Handler.run(Server.java:949)
  259.  
  260. at org.apache.flink.runtime.executiongraph.Execution$2.run(Execution.java:289)
  261. at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
  262. at java.util.concurrent.FutureTask.run(FutureTask.java:262)
  263. at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
  264. at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
  265. at java.lang.Thread.run(Thread.java:744)
  266.  
  267. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1426) (org.apache.flink.api.java.io.CsvInputFormat)) (23/24) switched to RUNNING
  268. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1426) (org.apache.flink.api.java.io.CsvInputFormat)) (2/24) switched to RUNNING
  269. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1398) (org.apache.flink.api.java.io.TextInputFormat)) -> Map (Map at main(FlightConnectionJoiner.java:1399)) (1/24) switched to RUNNING
  270. 02/04/2015 13:28:54: Job execution switched to status FAILING
  271. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1423) (org.apache.flink.api.java.io.CsvInputFormat)) (1/24) switched to CANCELING
  272. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1423) (org.apache.flink.api.java.io.CsvInputFormat)) (2/24) switched to CANCELING
  273. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1423) (org.apache.flink.api.java.io.CsvInputFormat)) (3/24) switched to CANCELING
  274. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1423) (org.apache.flink.api.java.io.CsvInputFormat)) (4/24) switched to CANCELING
  275. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1423) (org.apache.flink.api.java.io.CsvInputFormat)) (5/24) switched to CANCELING
  276. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1423) (org.apache.flink.api.java.io.CsvInputFormat)) (6/24) switched to CANCELING
  277. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1423) (org.apache.flink.api.java.io.CsvInputFormat)) (7/24) switched to CANCELING
  278. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1423) (org.apache.flink.api.java.io.CsvInputFormat)) (8/24) switched to CANCELING
  279. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1423) (org.apache.flink.api.java.io.CsvInputFormat)) (9/24) switched to CANCELING
  280. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1423) (org.apache.flink.api.java.io.CsvInputFormat)) (10/24) switched to CANCELING
  281. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1423) (org.apache.flink.api.java.io.CsvInputFormat)) (11/24) switched to CANCELING
  282. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1423) (org.apache.flink.api.java.io.CsvInputFormat)) (12/24) switched to CANCELING
  283. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1423) (org.apache.flink.api.java.io.CsvInputFormat)) (13/24) switched to CANCELING
  284. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1423) (org.apache.flink.api.java.io.CsvInputFormat)) (14/24) switched to CANCELING
  285. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1423) (org.apache.flink.api.java.io.CsvInputFormat)) (15/24) switched to CANCELING
  286. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1423) (org.apache.flink.api.java.io.CsvInputFormat)) (16/24) switched to CANCELING
  287. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1426) (org.apache.flink.api.java.io.CsvInputFormat)) (21/24) switched to RUNNING
  288. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1423) (org.apache.flink.api.java.io.CsvInputFormat)) (17/24) switched to CANCELING
  289. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1423) (org.apache.flink.api.java.io.CsvInputFormat)) (18/24) switched to CANCELING
  290. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1423) (org.apache.flink.api.java.io.CsvInputFormat)) (19/24) switched to CANCELING
  291. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1423) (org.apache.flink.api.java.io.CsvInputFormat)) (20/24) switched to CANCELING
  292. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1423) (org.apache.flink.api.java.io.CsvInputFormat)) (21/24) switched to CANCELING
  293. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1423) (org.apache.flink.api.java.io.CsvInputFormat)) (22/24) switched to CANCELING
  294. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1423) (org.apache.flink.api.java.io.CsvInputFormat)) (23/24) switched to CANCELING
  295. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1423) (org.apache.flink.api.java.io.CsvInputFormat)) (24/24) switched to CANCELING
  296. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1394) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1395)) (1/24) switched to CANCELING
  297. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1394) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1395)) (2/24) switched to CANCELING
  298. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1394) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1395)) (3/24) switched to CANCELING
  299. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1394) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1395)) (4/24) switched to CANCELING
  300. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1394) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1395)) (5/24) switched to CANCELING
  301. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1394) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1395)) (6/24) switched to CANCELING
  302. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1394) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1395)) (7/24) switched to CANCELING
  303. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1394) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1395)) (8/24) switched to CANCELING
  304. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1394) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1395)) (9/24) switched to CANCELING
  305. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1394) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1395)) (10/24) switched to CANCELING
  306. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1394) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1395)) (11/24) switched to CANCELING
  307. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1394) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1395)) (12/24) switched to CANCELING
  308. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1394) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1395)) (13/24) switched to CANCELING
  309. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1394) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1395)) (14/24) switched to CANCELING
  310. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1394) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1395)) (15/24) switched to CANCELING
  311. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1394) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1395)) (16/24) switched to CANCELING
  312. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1394) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1395)) (17/24) switched to CANCELING
  313. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1394) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1395)) (18/24) switched to CANCELING
  314. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1394) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1395)) (19/24) switched to CANCELING
  315. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1394) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1395)) (20/24) switched to CANCELING
  316. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1394) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1395)) (21/24) switched to CANCELING
  317. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1394) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1395)) (22/24) switched to CANCELING
  318. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1394) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1395)) (23/24) switched to CANCELING
  319. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1394) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1395)) (24/24) switched to CANCELING
  320. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1426) (org.apache.flink.api.java.io.CsvInputFormat)) (13/24) switched to RUNNING
  321. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1390) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1391)) (1/24) switched to CANCELING
  322. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1426) (org.apache.flink.api.java.io.CsvInputFormat)) (14/24) switched to RUNNING
  323. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1390) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1391)) (2/24) switched to CANCELING
  324. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1390) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1391)) (3/24) switched to CANCELING
  325. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1390) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1391)) (4/24) switched to CANCELING
  326. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1390) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1391)) (5/24) switched to CANCELING
  327. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1426) (org.apache.flink.api.java.io.CsvInputFormat)) (11/24) switched to RUNNING
  328. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1390) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1391)) (6/24) switched to CANCELING
  329. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1426) (org.apache.flink.api.java.io.CsvInputFormat)) (12/24) switched to RUNNING
  330. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1390) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1391)) (7/24) switched to CANCELING
  331. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1390) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1391)) (8/24) switched to CANCELING
  332. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1390) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1391)) (9/24) switched to CANCELING
  333. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1390) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1391)) (10/24) switched to CANCELING
  334. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1390) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1391)) (11/24) switched to CANCELING
  335. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1426) (org.apache.flink.api.java.io.CsvInputFormat)) (9/24) switched to RUNNING
  336. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1390) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1391)) (12/24) switched to CANCELING
  337. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1390) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1391)) (13/24) switched to CANCELING
  338. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1390) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1391)) (14/24) switched to CANCELING
  339. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1390) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1391)) (15/24) switched to CANCELING
  340. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1390) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1391)) (16/24) switched to CANCELING
  341. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1390) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1391)) (17/24) switched to CANCELING
  342. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1390) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1391)) (18/24) switched to CANCELING
  343. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1390) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1391)) (19/24) switched to CANCELING
  344. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1390) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1391)) (20/24) switched to CANCELING
  345. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1390) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1391)) (21/24) switched to CANCELING
  346. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1390) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1391)) (22/24) switched to CANCELING
  347. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1390) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1391)) (23/24) switched to CANCELING
  348. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1390) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1391)) (24/24) switched to CANCELING
  349. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1398) (org.apache.flink.api.java.io.TextInputFormat)) -> Map (Map at main(FlightConnectionJoiner.java:1399)) (1/24) switched to CANCELING
  350. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1398) (org.apache.flink.api.java.io.TextInputFormat)) -> Map (Map at main(FlightConnectionJoiner.java:1399)) (2/24) switched to CANCELING
  351. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1398) (org.apache.flink.api.java.io.TextInputFormat)) -> Map (Map at main(FlightConnectionJoiner.java:1399)) (3/24) switched to CANCELING
  352. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1398) (org.apache.flink.api.java.io.TextInputFormat)) -> Map (Map at main(FlightConnectionJoiner.java:1399)) (4/24) switched to CANCELING
  353. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1398) (org.apache.flink.api.java.io.TextInputFormat)) -> Map (Map at main(FlightConnectionJoiner.java:1399)) (5/24) switched to CANCELING
  354. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1398) (org.apache.flink.api.java.io.TextInputFormat)) -> Map (Map at main(FlightConnectionJoiner.java:1399)) (6/24) switched to CANCELING
  355. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1398) (org.apache.flink.api.java.io.TextInputFormat)) -> Map (Map at main(FlightConnectionJoiner.java:1399)) (7/24) switched to CANCELING
  356. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1398) (org.apache.flink.api.java.io.TextInputFormat)) -> Map (Map at main(FlightConnectionJoiner.java:1399)) (8/24) switched to CANCELING
  357. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1398) (org.apache.flink.api.java.io.TextInputFormat)) -> Map (Map at main(FlightConnectionJoiner.java:1399)) (9/24) switched to CANCELING
  358. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1398) (org.apache.flink.api.java.io.TextInputFormat)) -> Map (Map at main(FlightConnectionJoiner.java:1399)) (10/24) switched to CANCELING
  359. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1398) (org.apache.flink.api.java.io.TextInputFormat)) -> Map (Map at main(FlightConnectionJoiner.java:1399)) (11/24) switched to CANCELING
  360. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1398) (org.apache.flink.api.java.io.TextInputFormat)) -> Map (Map at main(FlightConnectionJoiner.java:1399)) (12/24) switched to CANCELING
  361. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1398) (org.apache.flink.api.java.io.TextInputFormat)) -> Map (Map at main(FlightConnectionJoiner.java:1399)) (13/24) switched to CANCELING
  362. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1398) (org.apache.flink.api.java.io.TextInputFormat)) -> Map (Map at main(FlightConnectionJoiner.java:1399)) (14/24) switched to CANCELING
  363. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1398) (org.apache.flink.api.java.io.TextInputFormat)) -> Map (Map at main(FlightConnectionJoiner.java:1399)) (15/24) switched to CANCELING
  364. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1398) (org.apache.flink.api.java.io.TextInputFormat)) -> Map (Map at main(FlightConnectionJoiner.java:1399)) (16/24) switched to CANCELING
  365. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1398) (org.apache.flink.api.java.io.TextInputFormat)) -> Map (Map at main(FlightConnectionJoiner.java:1399)) (17/24) switched to CANCELING
  366. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1398) (org.apache.flink.api.java.io.TextInputFormat)) -> Map (Map at main(FlightConnectionJoiner.java:1399)) (18/24) switched to CANCELING
  367. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1398) (org.apache.flink.api.java.io.TextInputFormat)) -> Map (Map at main(FlightConnectionJoiner.java:1399)) (19/24) switched to CANCELING
  368. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1398) (org.apache.flink.api.java.io.TextInputFormat)) -> Map (Map at main(FlightConnectionJoiner.java:1399)) (20/24) switched to CANCELING
  369. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1398) (org.apache.flink.api.java.io.TextInputFormat)) -> Map (Map at main(FlightConnectionJoiner.java:1399)) (21/24) switched to CANCELING
  370. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1398) (org.apache.flink.api.java.io.TextInputFormat)) -> Map (Map at main(FlightConnectionJoiner.java:1399)) (22/24) switched to CANCELING
  371. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1398) (org.apache.flink.api.java.io.TextInputFormat)) -> Map (Map at main(FlightConnectionJoiner.java:1399)) (23/24) switched to CANCELING
  372. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1398) (org.apache.flink.api.java.io.TextInputFormat)) -> Map (Map at main(FlightConnectionJoiner.java:1399)) (24/24) switched to CANCELING
  373. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1426) (org.apache.flink.api.java.io.CsvInputFormat)) (1/24) switched to CANCELING
  374. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1426) (org.apache.flink.api.java.io.CsvInputFormat)) (2/24) switched to CANCELING
  375. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1426) (org.apache.flink.api.java.io.CsvInputFormat)) (4/24) switched to CANCELING
  376. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1426) (org.apache.flink.api.java.io.CsvInputFormat)) (5/24) switched to CANCELING
  377. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1426) (org.apache.flink.api.java.io.CsvInputFormat)) (6/24) switched to CANCELING
  378. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1426) (org.apache.flink.api.java.io.CsvInputFormat)) (7/24) switched to CANCELING
  379. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1426) (org.apache.flink.api.java.io.CsvInputFormat)) (8/24) switched to CANCELING
  380. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1426) (org.apache.flink.api.java.io.CsvInputFormat)) (9/24) switched to CANCELING
  381. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1426) (org.apache.flink.api.java.io.CsvInputFormat)) (10/24) switched to CANCELING
  382. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1426) (org.apache.flink.api.java.io.CsvInputFormat)) (11/24) switched to CANCELING
  383. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1426) (org.apache.flink.api.java.io.CsvInputFormat)) (12/24) switched to CANCELING
  384. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1426) (org.apache.flink.api.java.io.CsvInputFormat)) (13/24) switched to CANCELING
  385. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1426) (org.apache.flink.api.java.io.CsvInputFormat)) (17/24) switched to RUNNING
  386. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1426) (org.apache.flink.api.java.io.CsvInputFormat)) (14/24) switched to CANCELING
  387. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1426) (org.apache.flink.api.java.io.CsvInputFormat)) (15/24) switched to CANCELING
  388. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1426) (org.apache.flink.api.java.io.CsvInputFormat)) (16/24) switched to CANCELING
  389. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1426) (org.apache.flink.api.java.io.CsvInputFormat)) (17/24) switched to CANCELING
  390. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1426) (org.apache.flink.api.java.io.CsvInputFormat)) (18/24) switched to CANCELING
  391. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1426) (org.apache.flink.api.java.io.CsvInputFormat)) (19/24) switched to CANCELING
  392. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1426) (org.apache.flink.api.java.io.CsvInputFormat)) (20/24) switched to CANCELING
  393. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1426) (org.apache.flink.api.java.io.CsvInputFormat)) (21/24) switched to CANCELING
  394. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1426) (org.apache.flink.api.java.io.CsvInputFormat)) (22/24) switched to CANCELING
  395. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1426) (org.apache.flink.api.java.io.CsvInputFormat)) (23/24) switched to CANCELING
  396. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1426) (org.apache.flink.api.java.io.CsvInputFormat)) (24/24) switched to CANCELING
  397. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1401)) (1/24) switched to CANCELED
  398. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1401)) (2/24) switched to CANCELED
  399. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1401)) (3/24) switched to CANCELED
  400. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1401)) (4/24) switched to CANCELED
  401. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1401)) (5/24) switched to CANCELED
  402. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1401)) (6/24) switched to CANCELED
  403. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1401)) (7/24) switched to CANCELED
  404. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1401)) (8/24) switched to CANCELED
  405. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1401)) (9/24) switched to CANCELED
  406. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1401)) (10/24) switched to CANCELED
  407. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1401)) (11/24) switched to CANCELED
  408. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1401)) (12/24) switched to CANCELED
  409. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1401)) (13/24) switched to CANCELED
  410. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1401)) (14/24) switched to CANCELED
  411. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1401)) (15/24) switched to CANCELED
  412. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1401)) (16/24) switched to CANCELED
  413. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1401)) (17/24) switched to CANCELED
  414. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1401)) (18/24) switched to CANCELED
  415. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1401)) (19/24) switched to CANCELED
  416. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1401)) (20/24) switched to CANCELED
  417. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1401)) (21/24) switched to CANCELED
  418. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1401)) (22/24) switched to CANCELED
  419. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1401)) (23/24) switched to CANCELED
  420. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1401)) (24/24) switched to CANCELED
  421. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1417)) (1/24) switched to CANCELED
  422. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1417)) (2/24) switched to CANCELED
  423. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1417)) (3/24) switched to CANCELED
  424. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1417)) (4/24) switched to CANCELED
  425. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1417)) (5/24) switched to CANCELED
  426. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1417)) (6/24) switched to CANCELED
  427. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1417)) (7/24) switched to CANCELED
  428. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1417)) (8/24) switched to CANCELED
  429. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1417)) (9/24) switched to CANCELED
  430. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1417)) (10/24) switched to CANCELED
  431. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1417)) (11/24) switched to CANCELED
  432. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1417)) (12/24) switched to CANCELED
  433. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1417)) (13/24) switched to CANCELED
  434. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1417)) (14/24) switched to CANCELED
  435. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1417)) (15/24) switched to CANCELED
  436. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1426) (org.apache.flink.api.java.io.CsvInputFormat)) (15/24) switched to FAILED
  437. java.lang.Exception: Failed to deploy the task DataSource (at main(FlightConnectionJoiner.java:1426) (org.apache.flink.api.java.io.CsvInputFormat)) (15/24) - execution #0 to slot SubSlot 0 (41ea5741bcb1ec3073069e8c6f901acb (0) - ALLOCATED/ALIVE): java.io.FileNotFoundException: /tmp/blobStore-7d93e071-4515-4d27-8d4e-c2983a800077/cache/blob_0bfb661afec4ff2bff2dbb3993a1f6ab69106a2e (No such file or directory)
  438. at java.io.FileOutputStream.open(Native Method)
  439. at java.io.FileOutputStream.<init>(FileOutputStream.java:221)
  440. at java.io.FileOutputStream.<init>(FileOutputStream.java:171)
  441. at org.apache.flink.runtime.blob.BlobCache.getURL(BlobCache.java:103)
  442. at org.apache.flink.runtime.execution.librarycache.BlobLibraryCacheManager.registerReferenceToBlobKeyAndGetURL(BlobLibraryCacheManager.java:225)
  443. at org.apache.flink.runtime.execution.librarycache.BlobLibraryCacheManager.registerTask(BlobLibraryCacheManager.java:111)
  444. at org.apache.flink.runtime.taskmanager.TaskManager.submitTask(TaskManager.java:597)
  445. at sun.reflect.GeneratedMethodAccessor2.invoke(Unknown Source)
  446. at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
  447. at java.lang.reflect.Method.invoke(Method.java:606)
  448. at org.apache.flink.runtime.ipc.RPC$Server.call(RPC.java:420)
  449. at org.apache.flink.runtime.ipc.Server$Handler.run(Server.java:949)
  450.  
  451. at org.apache.flink.runtime.executiongraph.Execution$2.run(Execution.java:289)
  452. at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
  453. at java.util.concurrent.FutureTask.run(FutureTask.java:262)
  454. at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
  455. at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
  456. at java.lang.Thread.run(Thread.java:744)
  457.  
  458. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1398) (org.apache.flink.api.java.io.TextInputFormat)) -> Map (Map at main(FlightConnectionJoiner.java:1399)) (5/24) switched to FAILED
  459. java.lang.Exception: Failed to deploy the task CHAIN DataSource (at main(FlightConnectionJoiner.java:1398) (org.apache.flink.api.java.io.TextInputFormat)) -> Map (Map at main(FlightConnectionJoiner.java:1399)) (5/24) - execution #0 to slot SubSlot 1 (41ea5741bcb1ec3073069e8c6f901acb (0) - ALLOCATED/ALIVE): java.io.FileNotFoundException: /tmp/blobStore-7d93e071-4515-4d27-8d4e-c2983a800077/cache/blob_0bfb661afec4ff2bff2dbb3993a1f6ab69106a2e (No such file or directory)
  460. at java.io.FileOutputStream.open(Native Method)
  461. at java.io.FileOutputStream.<init>(FileOutputStream.java:221)
  462. at java.io.FileOutputStream.<init>(FileOutputStream.java:171)
  463. at org.apache.flink.runtime.blob.BlobCache.getURL(BlobCache.java:103)
  464. at org.apache.flink.runtime.execution.librarycache.BlobLibraryCacheManager.registerReferenceToBlobKeyAndGetURL(BlobLibraryCacheManager.java:225)
  465. at org.apache.flink.runtime.execution.librarycache.BlobLibraryCacheManager.registerTask(BlobLibraryCacheManager.java:111)
  466. at org.apache.flink.runtime.taskmanager.TaskManager.submitTask(TaskManager.java:597)
  467. at sun.reflect.GeneratedMethodAccessor2.invoke(Unknown Source)
  468. at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
  469. at java.lang.reflect.Method.invoke(Method.java:606)
  470. at org.apache.flink.runtime.ipc.RPC$Server.call(RPC.java:420)
  471. at org.apache.flink.runtime.ipc.Server$Handler.run(Server.java:949)
  472.  
  473. at org.apache.flink.runtime.executiongraph.Execution$2.run(Execution.java:289)
  474. at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
  475. at java.util.concurrent.FutureTask.run(FutureTask.java:262)
  476. at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
  477. at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
  478. at java.lang.Thread.run(Thread.java:744)
  479.  
  480. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1417)) (16/24) switched to CANCELED
  481. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1417)) (17/24) switched to CANCELED
  482. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1417)) (18/24) switched to CANCELED
  483. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1417)) (19/24) switched to CANCELED
  484. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1417)) (20/24) switched to CANCELED
  485. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1417)) (21/24) switched to CANCELED
  486. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1398) (org.apache.flink.api.java.io.TextInputFormat)) -> Map (Map at main(FlightConnectionJoiner.java:1399)) (6/24) switched to FAILED
  487. java.lang.Exception: Failed to deploy the task CHAIN DataSource (at main(FlightConnectionJoiner.java:1398) (org.apache.flink.api.java.io.TextInputFormat)) -> Map (Map at main(FlightConnectionJoiner.java:1399)) (6/24) - execution #0 to slot SubSlot 1 (41ea5741bcb1ec3073069e8c6f901acb (1) - ALLOCATED/ALIVE): java.io.FileNotFoundException: /tmp/blobStore-7d93e071-4515-4d27-8d4e-c2983a800077/cache/blob_0bfb661afec4ff2bff2dbb3993a1f6ab69106a2e (No such file or directory)
  488. at java.io.FileOutputStream.open(Native Method)
  489. at java.io.FileOutputStream.<init>(FileOutputStream.java:221)
  490. at java.io.FileOutputStream.<init>(FileOutputStream.java:171)
  491. at org.apache.flink.runtime.blob.BlobCache.getURL(BlobCache.java:103)
  492. at org.apache.flink.runtime.execution.librarycache.BlobLibraryCacheManager.registerReferenceToBlobKeyAndGetURL(BlobLibraryCacheManager.java:225)
  493. at org.apache.flink.runtime.execution.librarycache.BlobLibraryCacheManager.registerTask(BlobLibraryCacheManager.java:111)
  494. at org.apache.flink.runtime.taskmanager.TaskManager.submitTask(TaskManager.java:597)
  495. at sun.reflect.GeneratedMethodAccessor2.invoke(Unknown Source)
  496. at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
  497. at java.lang.reflect.Method.invoke(Method.java:606)
  498. at org.apache.flink.runtime.ipc.RPC$Server.call(RPC.java:420)
  499. at org.apache.flink.runtime.ipc.Server$Handler.run(Server.java:949)
  500.  
  501. at org.apache.flink.runtime.executiongraph.Execution$2.run(Execution.java:289)
  502. at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
  503. at java.util.concurrent.FutureTask.run(FutureTask.java:262)
  504. at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
  505. at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
  506. at java.lang.Thread.run(Thread.java:744)
  507.  
  508. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1417)) (22/24) switched to CANCELED
  509. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1417)) (23/24) switched to CANCELED
  510. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1417)) (24/24) switched to CANCELED
  511. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1419)) (1/24) switched to CANCELED
  512. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1419)) (2/24) switched to CANCELED
  513. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1419)) (3/24) switched to CANCELED
  514. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1419)) (4/24) switched to CANCELED
  515. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1419)) (5/24) switched to CANCELED
  516. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1419)) (6/24) switched to CANCELED
  517. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1419)) (7/24) switched to CANCELED
  518. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1419)) (8/24) switched to CANCELED
  519. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1419)) (9/24) switched to CANCELED
  520. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1419)) (10/24) switched to CANCELED
  521. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1419)) (11/24) switched to CANCELED
  522. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1419)) (12/24) switched to CANCELED
  523. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1419)) (13/24) switched to CANCELED
  524. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1419)) (14/24) switched to CANCELED
  525. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1419)) (15/24) switched to CANCELED
  526. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1419)) (16/24) switched to CANCELED
  527. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1419)) (17/24) switched to CANCELED
  528. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1419)) (18/24) switched to CANCELED
  529. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1419)) (19/24) switched to CANCELED
  530. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1419)) (20/24) switched to CANCELED
  531. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1419)) (21/24) switched to CANCELED
  532. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1419)) (22/24) switched to CANCELED
  533. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1419)) (23/24) switched to CANCELED
  534. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1419)) (24/24) switched to CANCELED
  535. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1424)) (1/24) switched to CANCELED
  536. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1424)) (2/24) switched to CANCELED
  537. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1424)) (3/24) switched to CANCELED
  538. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1424)) (4/24) switched to CANCELED
  539. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1424)) (5/24) switched to CANCELED
  540. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1424)) (6/24) switched to CANCELED
  541. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1424)) (7/24) switched to CANCELED
  542. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1424)) (8/24) switched to CANCELED
  543. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1424)) (9/24) switched to CANCELED
  544. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1424)) (10/24) switched to CANCELED
  545. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1424)) (11/24) switched to CANCELED
  546. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1424)) (12/24) switched to CANCELED
  547. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1424)) (13/24) switched to CANCELED
  548. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1424)) (14/24) switched to CANCELED
  549. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1424)) (15/24) switched to CANCELED
  550. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1424)) (16/24) switched to CANCELED
  551. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1424)) (17/24) switched to CANCELED
  552. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1424)) (18/24) switched to CANCELED
  553. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1424)) (19/24) switched to CANCELED
  554. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1424)) (20/24) switched to CANCELED
  555. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1424)) (21/24) switched to CANCELED
  556. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1424)) (22/24) switched to CANCELED
  557. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1424)) (23/24) switched to CANCELED
  558. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1424)) (24/24) switched to CANCELED
  559. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1429)) (1/24) switched to CANCELED
  560. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1429)) (2/24) switched to CANCELED
  561. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1429)) (3/24) switched to CANCELED
  562. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1429)) (4/24) switched to CANCELED
  563. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1429)) (5/24) switched to CANCELED
  564. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1429)) (6/24) switched to CANCELED
  565. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1429)) (7/24) switched to CANCELED
  566. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1429)) (8/24) switched to CANCELED
  567. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1429)) (9/24) switched to CANCELED
  568. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1429)) (10/24) switched to CANCELED
  569. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1429)) (11/24) switched to CANCELED
  570. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1429)) (12/24) switched to CANCELED
  571. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1429)) (13/24) switched to CANCELED
  572. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1429)) (14/24) switched to CANCELED
  573. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1429)) (15/24) switched to CANCELED
  574. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1429)) (16/24) switched to CANCELED
  575. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1429)) (17/24) switched to CANCELED
  576. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1429)) (18/24) switched to CANCELED
  577. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1429)) (19/24) switched to CANCELED
  578. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1429)) (20/24) switched to CANCELED
  579. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1429)) (21/24) switched to CANCELED
  580. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1429)) (22/24) switched to CANCELED
  581. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1429)) (23/24) switched to CANCELED
  582. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1429)) (24/24) switched to CANCELED
  583. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1445)) (1/24) switched to CANCELED
  584. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1445)) (2/24) switched to CANCELED
  585. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1445)) (3/24) switched to CANCELED
  586. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1445)) (4/24) switched to CANCELED
  587. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1445)) (5/24) switched to CANCELED
  588. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1445)) (6/24) switched to CANCELED
  589. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1423) (org.apache.flink.api.java.io.CsvInputFormat)) (5/24) switched to FAILED
  590. java.lang.Exception: Failed to deploy the task DataSource (at main(FlightConnectionJoiner.java:1423) (org.apache.flink.api.java.io.CsvInputFormat)) (5/24) - execution #0 to slot SubSlot 2 (41ea5741bcb1ec3073069e8c6f901acb (0) - ALLOCATED/ALIVE): java.io.FileNotFoundException: /tmp/blobStore-7d93e071-4515-4d27-8d4e-c2983a800077/cache/blob_0bfb661afec4ff2bff2dbb3993a1f6ab69106a2e (No such file or directory)
  591. at java.io.FileOutputStream.open(Native Method)
  592. at java.io.FileOutputStream.<init>(FileOutputStream.java:221)
  593. at java.io.FileOutputStream.<init>(FileOutputStream.java:171)
  594. at org.apache.flink.runtime.blob.BlobCache.getURL(BlobCache.java:103)
  595. at org.apache.flink.runtime.execution.librarycache.BlobLibraryCacheManager.registerReferenceToBlobKeyAndGetURL(BlobLibraryCacheManager.java:225)
  596. at org.apache.flink.runtime.execution.librarycache.BlobLibraryCacheManager.registerTask(BlobLibraryCacheManager.java:111)
  597. at org.apache.flink.runtime.taskmanager.TaskManager.submitTask(TaskManager.java:597)
  598. at sun.reflect.GeneratedMethodAccessor2.invoke(Unknown Source)
  599. at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
  600. at java.lang.reflect.Method.invoke(Method.java:606)
  601. at org.apache.flink.runtime.ipc.RPC$Server.call(RPC.java:420)
  602. at org.apache.flink.runtime.ipc.Server$Handler.run(Server.java:949)
  603.  
  604. at org.apache.flink.runtime.executiongraph.Execution$2.run(Execution.java:289)
  605. at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
  606. at java.util.concurrent.FutureTask.run(FutureTask.java:262)
  607. at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
  608. at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
  609. at java.lang.Thread.run(Thread.java:744)
  610.  
  611. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1445)) (7/24) switched to CANCELED
  612. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1445)) (8/24) switched to CANCELED
  613. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1423) (org.apache.flink.api.java.io.CsvInputFormat)) (6/24) switched to FAILED
  614. java.lang.Exception: Failed to deploy the task DataSource (at main(FlightConnectionJoiner.java:1423) (org.apache.flink.api.java.io.CsvInputFormat)) (6/24) - execution #0 to slot SubSlot 2 (41ea5741bcb1ec3073069e8c6f901acb (1) - ALLOCATED/ALIVE): java.io.FileNotFoundException: /tmp/blobStore-7d93e071-4515-4d27-8d4e-c2983a800077/cache/blob_0bfb661afec4ff2bff2dbb3993a1f6ab69106a2e (No such file or directory)
  615. at java.io.FileOutputStream.open(Native Method)
  616. at java.io.FileOutputStream.<init>(FileOutputStream.java:221)
  617. at java.io.FileOutputStream.<init>(FileOutputStream.java:171)
  618. at org.apache.flink.runtime.blob.BlobCache.getURL(BlobCache.java:103)
  619. at org.apache.flink.runtime.execution.librarycache.BlobLibraryCacheManager.registerReferenceToBlobKeyAndGetURL(BlobLibraryCacheManager.java:225)
  620. at org.apache.flink.runtime.execution.librarycache.BlobLibraryCacheManager.registerTask(BlobLibraryCacheManager.java:111)
  621. at org.apache.flink.runtime.taskmanager.TaskManager.submitTask(TaskManager.java:597)
  622. at sun.reflect.GeneratedMethodAccessor2.invoke(Unknown Source)
  623. at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
  624. at java.lang.reflect.Method.invoke(Method.java:606)
  625. at org.apache.flink.runtime.ipc.RPC$Server.call(RPC.java:420)
  626. at org.apache.flink.runtime.ipc.Server$Handler.run(Server.java:949)
  627.  
  628. at org.apache.flink.runtime.executiongraph.Execution$2.run(Execution.java:289)
  629. at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
  630. at java.util.concurrent.FutureTask.run(FutureTask.java:262)
  631. at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
  632. at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
  633. at java.lang.Thread.run(Thread.java:744)
  634.  
  635. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1445)) (9/24) switched to CANCELED
  636. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1445)) (10/24) switched to CANCELED
  637. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1445)) (11/24) switched to CANCELED
  638. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1445)) (12/24) switched to CANCELED
  639. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1445)) (13/24) switched to CANCELED
  640. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1445)) (14/24) switched to CANCELED
  641. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1445)) (15/24) switched to CANCELED
  642. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1445)) (16/24) switched to CANCELED
  643. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1445)) (17/24) switched to CANCELED
  644. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1445)) (18/24) switched to CANCELED
  645. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1445)) (19/24) switched to CANCELED
  646. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1445)) (20/24) switched to CANCELED
  647. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1445)) (21/24) switched to CANCELED
  648. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1445)) (22/24) switched to CANCELED
  649. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1445)) (23/24) switched to CANCELED
  650. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1445)) (24/24) switched to CANCELED
  651. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1447)) (1/24) switched to CANCELED
  652. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1447)) (2/24) switched to CANCELED
  653. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1447)) (3/24) switched to CANCELED
  654. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1447)) (4/24) switched to CANCELED
  655. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1447)) (5/24) switched to CANCELED
  656. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1447)) (6/24) switched to CANCELED
  657. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1447)) (7/24) switched to CANCELED
  658. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1447)) (8/24) switched to CANCELED
  659. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1447)) (9/24) switched to CANCELED
  660. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1447)) (10/24) switched to CANCELED
  661. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1447)) (11/24) switched to CANCELED
  662. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1447)) (12/24) switched to CANCELED
  663. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1447)) (13/24) switched to CANCELED
  664. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1447)) (14/24) switched to CANCELED
  665. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1447)) (15/24) switched to CANCELED
  666. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1447)) (16/24) switched to CANCELED
  667. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1447)) (17/24) switched to CANCELED
  668. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1447)) (18/24) switched to CANCELED
  669. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1447)) (19/24) switched to CANCELED
  670. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1447)) (20/24) switched to CANCELED
  671. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1447)) (21/24) switched to CANCELED
  672. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1447)) (22/24) switched to CANCELED
  673. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1447)) (23/24) switched to CANCELED
  674. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1447)) (24/24) switched to CANCELED
  675. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1451)) (1/24) switched to CANCELED
  676. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1451)) (2/24) switched to CANCELED
  677. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1451)) (3/24) switched to CANCELED
  678. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1451)) (4/24) switched to CANCELED
  679. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1451)) (5/24) switched to CANCELED
  680. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1451)) (6/24) switched to CANCELED
  681. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1451)) (7/24) switched to CANCELED
  682. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1451)) (8/24) switched to CANCELED
  683. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1451)) (9/24) switched to CANCELED
  684. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1451)) (10/24) switched to CANCELED
  685. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1451)) (11/24) switched to CANCELED
  686. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1451)) (12/24) switched to CANCELED
  687. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1451)) (13/24) switched to CANCELED
  688. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1451)) (14/24) switched to CANCELED
  689. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1451)) (15/24) switched to CANCELED
  690. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1451)) (16/24) switched to CANCELED
  691. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1451)) (17/24) switched to CANCELED
  692. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1451)) (18/24) switched to CANCELED
  693. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1451)) (19/24) switched to CANCELED
  694. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1451)) (20/24) switched to CANCELED
  695. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1451)) (21/24) switched to CANCELED
  696. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1451)) (22/24) switched to CANCELED
  697. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1451)) (23/24) switched to CANCELED
  698. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1451)) (24/24) switched to CANCELED
  699. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1453)) (1/24) switched to CANCELED
  700. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1453)) (2/24) switched to CANCELED
  701. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1394) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1395)) (5/24) switched to FAILED
  702. java.lang.Exception: Failed to deploy the task CHAIN DataSource (at main(FlightConnectionJoiner.java:1394) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1395)) (5/24) - execution #0 to slot SubSlot 3 (41ea5741bcb1ec3073069e8c6f901acb (0) - ALLOCATED/ALIVE): java.io.FileNotFoundException: /tmp/blobStore-7d93e071-4515-4d27-8d4e-c2983a800077/cache/blob_0bfb661afec4ff2bff2dbb3993a1f6ab69106a2e (No such file or directory)
  703. at java.io.FileOutputStream.open(Native Method)
  704. at java.io.FileOutputStream.<init>(FileOutputStream.java:221)
  705. at java.io.FileOutputStream.<init>(FileOutputStream.java:171)
  706. at org.apache.flink.runtime.blob.BlobCache.getURL(BlobCache.java:103)
  707. at org.apache.flink.runtime.execution.librarycache.BlobLibraryCacheManager.registerReferenceToBlobKeyAndGetURL(BlobLibraryCacheManager.java:225)
  708. at org.apache.flink.runtime.execution.librarycache.BlobLibraryCacheManager.registerTask(BlobLibraryCacheManager.java:111)
  709. at org.apache.flink.runtime.taskmanager.TaskManager.submitTask(TaskManager.java:597)
  710. at sun.reflect.GeneratedMethodAccessor2.invoke(Unknown Source)
  711. at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
  712. at java.lang.reflect.Method.invoke(Method.java:606)
  713. at org.apache.flink.runtime.ipc.RPC$Server.call(RPC.java:420)
  714. at org.apache.flink.runtime.ipc.Server$Handler.run(Server.java:949)
  715.  
  716. at org.apache.flink.runtime.executiongraph.Execution$2.run(Execution.java:289)
  717. at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
  718. at java.util.concurrent.FutureTask.run(FutureTask.java:262)
  719. at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
  720. at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
  721. at java.lang.Thread.run(Thread.java:744)
  722.  
  723. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1453)) (3/24) switched to CANCELED
  724. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1453)) (4/24) switched to CANCELED
  725. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1453)) (5/24) switched to CANCELED
  726. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1453)) (6/24) switched to CANCELED
  727. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1453)) (7/24) switched to CANCELED
  728. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1453)) (8/24) switched to CANCELED
  729. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1453)) (9/24) switched to CANCELED
  730. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1453)) (10/24) switched to CANCELED
  731. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1453)) (11/24) switched to CANCELED
  732. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1453)) (12/24) switched to CANCELED
  733. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1453)) (13/24) switched to CANCELED
  734. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1453)) (14/24) switched to CANCELED
  735. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1453)) (15/24) switched to CANCELED
  736. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1453)) (16/24) switched to CANCELED
  737. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1453)) (17/24) switched to CANCELED
  738. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1453)) (18/24) switched to CANCELED
  739. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1453)) (19/24) switched to CANCELED
  740. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1453)) (20/24) switched to CANCELED
  741. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1453)) (21/24) switched to CANCELED
  742. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1453)) (22/24) switched to CANCELED
  743. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1453)) (23/24) switched to CANCELED
  744. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1453)) (24/24) switched to CANCELED
  745. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1463)) (1/24) switched to CANCELED
  746. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1463)) (2/24) switched to CANCELED
  747. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1463)) (3/24) switched to CANCELED
  748. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1463)) (4/24) switched to CANCELED
  749. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1463)) (5/24) switched to CANCELED
  750. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1463)) (6/24) switched to CANCELED
  751. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1463)) (7/24) switched to CANCELED
  752. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1463)) (8/24) switched to CANCELED
  753. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1463)) (9/24) switched to CANCELED
  754. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1463)) (10/24) switched to CANCELED
  755. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1463)) (11/24) switched to CANCELED
  756. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1463)) (12/24) switched to CANCELED
  757. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1463)) (13/24) switched to CANCELED
  758. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1463)) (14/24) switched to CANCELED
  759. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1463)) (15/24) switched to CANCELED
  760. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1463)) (16/24) switched to CANCELED
  761. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1463)) (17/24) switched to CANCELED
  762. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1463)) (18/24) switched to CANCELED
  763. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1463)) (19/24) switched to CANCELED
  764. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1463)) (20/24) switched to CANCELED
  765. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1463)) (21/24) switched to CANCELED
  766. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1463)) (22/24) switched to CANCELED
  767. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1463)) (23/24) switched to CANCELED
  768. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1463)) (24/24) switched to CANCELED
  769. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1465)) (1/24) switched to CANCELED
  770. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1465)) (2/24) switched to CANCELED
  771. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1465)) (3/24) switched to CANCELED
  772. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1465)) (4/24) switched to CANCELED
  773. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1465)) (5/24) switched to CANCELED
  774. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1465)) (6/24) switched to CANCELED
  775. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1465)) (7/24) switched to CANCELED
  776. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1465)) (8/24) switched to CANCELED
  777. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1465)) (9/24) switched to CANCELED
  778. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1465)) (10/24) switched to CANCELED
  779. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1465)) (11/24) switched to CANCELED
  780. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1465)) (12/24) switched to CANCELED
  781. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1465)) (13/24) switched to CANCELED
  782. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1465)) (14/24) switched to CANCELED
  783. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1465)) (15/24) switched to CANCELED
  784. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1465)) (16/24) switched to CANCELED
  785. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1465)) (17/24) switched to CANCELED
  786. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1465)) (18/24) switched to CANCELED
  787. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1465)) (19/24) switched to CANCELED
  788. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1465)) (20/24) switched to CANCELED
  789. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1465)) (21/24) switched to CANCELED
  790. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1465)) (22/24) switched to CANCELED
  791. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1465)) (23/24) switched to CANCELED
  792. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1465)) (24/24) switched to CANCELED
  793. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1469)) (1/24) switched to CANCELED
  794. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1469)) (2/24) switched to CANCELED
  795. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1469)) (3/24) switched to CANCELED
  796. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1469)) (4/24) switched to CANCELED
  797. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1469)) (5/24) switched to CANCELED
  798. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1469)) (6/24) switched to CANCELED
  799. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1469)) (7/24) switched to CANCELED
  800. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1469)) (8/24) switched to CANCELED
  801. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1469)) (9/24) switched to CANCELED
  802. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1469)) (10/24) switched to CANCELED
  803. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1469)) (11/24) switched to CANCELED
  804. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1469)) (12/24) switched to CANCELED
  805. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1469)) (13/24) switched to CANCELED
  806. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1469)) (14/24) switched to CANCELED
  807. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1469)) (15/24) switched to CANCELED
  808. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1469)) (16/24) switched to CANCELED
  809. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1469)) (17/24) switched to CANCELED
  810. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1469)) (18/24) switched to CANCELED
  811. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1469)) (19/24) switched to CANCELED
  812. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1469)) (20/24) switched to CANCELED
  813. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1469)) (21/24) switched to CANCELED
  814. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1469)) (22/24) switched to CANCELED
  815. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1469)) (23/24) switched to CANCELED
  816. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1469)) (24/24) switched to CANCELED
  817. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1471)) (1/24) switched to CANCELED
  818. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1471)) (2/24) switched to CANCELED
  819. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1471)) (3/24) switched to CANCELED
  820. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1471)) (4/24) switched to CANCELED
  821. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1471)) (5/24) switched to CANCELED
  822. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1471)) (6/24) switched to CANCELED
  823. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1471)) (7/24) switched to CANCELED
  824. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1471)) (8/24) switched to CANCELED
  825. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1471)) (9/24) switched to CANCELED
  826. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1471)) (10/24) switched to CANCELED
  827. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1471)) (11/24) switched to CANCELED
  828. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1471)) (12/24) switched to CANCELED
  829. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1471)) (13/24) switched to CANCELED
  830. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1471)) (14/24) switched to CANCELED
  831. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1471)) (15/24) switched to CANCELED
  832. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1471)) (16/24) switched to CANCELED
  833. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1471)) (17/24) switched to CANCELED
  834. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1471)) (18/24) switched to CANCELED
  835. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1471)) (19/24) switched to CANCELED
  836. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1471)) (20/24) switched to CANCELED
  837. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1471)) (21/24) switched to CANCELED
  838. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1471)) (22/24) switched to CANCELED
  839. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1471)) (23/24) switched to CANCELED
  840. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1471)) (24/24) switched to CANCELED
  841. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1457)) (1/24) switched to CANCELED
  842. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1457)) (2/24) switched to CANCELED
  843. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1457)) (3/24) switched to CANCELED
  844. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1457)) (4/24) switched to CANCELED
  845. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1457)) (5/24) switched to CANCELED
  846. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1457)) (6/24) switched to CANCELED
  847. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1457)) (7/24) switched to CANCELED
  848. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1457)) (8/24) switched to CANCELED
  849. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1457)) (9/24) switched to CANCELED
  850. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1457)) (10/24) switched to CANCELED
  851. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1457)) (11/24) switched to CANCELED
  852. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1457)) (12/24) switched to CANCELED
  853. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1457)) (13/24) switched to CANCELED
  854. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1457)) (14/24) switched to CANCELED
  855. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1457)) (15/24) switched to CANCELED
  856. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1457)) (16/24) switched to CANCELED
  857. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1457)) (17/24) switched to CANCELED
  858. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1457)) (18/24) switched to CANCELED
  859. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1457)) (19/24) switched to CANCELED
  860. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1457)) (20/24) switched to CANCELED
  861. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1457)) (21/24) switched to CANCELED
  862. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1457)) (22/24) switched to CANCELED
  863. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1457)) (23/24) switched to CANCELED
  864. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1457)) (24/24) switched to CANCELED
  865. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1459)) (1/24) switched to CANCELED
  866. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1459)) (2/24) switched to CANCELED
  867. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1459)) (3/24) switched to CANCELED
  868. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1423) (org.apache.flink.api.java.io.CsvInputFormat)) (4/24) switched to CANCELED
  869. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1423) (org.apache.flink.api.java.io.CsvInputFormat)) (17/24) switched to CANCELED
  870. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1459)) (4/24) switched to CANCELED
  871. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1459)) (5/24) switched to CANCELED
  872. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1459)) (6/24) switched to CANCELED
  873. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1459)) (7/24) switched to CANCELED
  874. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1459)) (8/24) switched to CANCELED
  875. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1459)) (9/24) switched to CANCELED
  876. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1459)) (10/24) switched to CANCELED
  877. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1459)) (11/24) switched to CANCELED
  878. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1459)) (12/24) switched to CANCELED
  879. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1459)) (13/24) switched to CANCELED
  880. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1423) (org.apache.flink.api.java.io.CsvInputFormat)) (19/24) switched to CANCELED
  881. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1459)) (14/24) switched to CANCELED
  882. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1423) (org.apache.flink.api.java.io.CsvInputFormat)) (23/24) switched to CANCELED
  883. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1394) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1395)) (3/24) switched to CANCELED
  884. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1423) (org.apache.flink.api.java.io.CsvInputFormat)) (15/24) switched to CANCELED
  885. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1394) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1395)) (2/24) switched to CANCELED
  886. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1423) (org.apache.flink.api.java.io.CsvInputFormat)) (18/24) switched to CANCELED
  887. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1423) (org.apache.flink.api.java.io.CsvInputFormat)) (21/24) switched to CANCELED
  888. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1423) (org.apache.flink.api.java.io.CsvInputFormat)) (20/24) switched to CANCELED
  889. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1394) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1395)) (6/24) switched to FAILED
  890. java.lang.Exception: Failed to deploy the task CHAIN DataSource (at main(FlightConnectionJoiner.java:1394) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1395)) (6/24) - execution #0 to slot SubSlot 3 (41ea5741bcb1ec3073069e8c6f901acb (1) - ALLOCATED/ALIVE): java.io.FileNotFoundException: /tmp/blobStore-7d93e071-4515-4d27-8d4e-c2983a800077/cache/blob_0bfb661afec4ff2bff2dbb3993a1f6ab69106a2e (No such file or directory)
  891. at java.io.FileOutputStream.open(Native Method)
  892. at java.io.FileOutputStream.<init>(FileOutputStream.java:221)
  893. at java.io.FileOutputStream.<init>(FileOutputStream.java:171)
  894. at org.apache.flink.runtime.blob.BlobCache.getURL(BlobCache.java:103)
  895. at org.apache.flink.runtime.execution.librarycache.BlobLibraryCacheManager.registerReferenceToBlobKeyAndGetURL(BlobLibraryCacheManager.java:225)
  896. at org.apache.flink.runtime.execution.librarycache.BlobLibraryCacheManager.registerTask(BlobLibraryCacheManager.java:111)
  897. at org.apache.flink.runtime.taskmanager.TaskManager.submitTask(TaskManager.java:597)
  898. at sun.reflect.GeneratedMethodAccessor2.invoke(Unknown Source)
  899. at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
  900. at java.lang.reflect.Method.invoke(Method.java:606)
  901. at org.apache.flink.runtime.ipc.RPC$Server.call(RPC.java:420)
  902. at org.apache.flink.runtime.ipc.Server$Handler.run(Server.java:949)
  903.  
  904. at org.apache.flink.runtime.executiongraph.Execution$2.run(Execution.java:289)
  905. at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
  906. at java.util.concurrent.FutureTask.run(FutureTask.java:262)
  907. at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
  908. at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
  909. at java.lang.Thread.run(Thread.java:744)
  910.  
  911. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1459)) (15/24) switched to CANCELED
  912. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1394) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1395)) (9/24) switched to CANCELED
  913. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1459)) (16/24) switched to CANCELED
  914. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1423) (org.apache.flink.api.java.io.CsvInputFormat)) (24/24) switched to CANCELED
  915. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1394) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1395)) (13/24) switched to CANCELED
  916. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1398) (org.apache.flink.api.java.io.TextInputFormat)) -> Map (Map at main(FlightConnectionJoiner.java:1399)) (3/24) switched to CANCELED
  917. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1423) (org.apache.flink.api.java.io.CsvInputFormat)) (16/24) switched to CANCELED
  918. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1394) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1395)) (1/24) switched to CANCELED
  919. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1390) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1391)) (5/24) switched to FAILED
  920. java.lang.Exception: Failed to deploy the task CHAIN DataSource (at main(FlightConnectionJoiner.java:1390) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1391)) (5/24) - execution #0 to slot SubSlot 4 (41ea5741bcb1ec3073069e8c6f901acb (0) - ALLOCATED/ALIVE): java.io.FileNotFoundException: /tmp/blobStore-7d93e071-4515-4d27-8d4e-c2983a800077/cache/blob_0bfb661afec4ff2bff2dbb3993a1f6ab69106a2e (No such file or directory)
  921. at java.io.FileOutputStream.open(Native Method)
  922. at java.io.FileOutputStream.<init>(FileOutputStream.java:221)
  923. at java.io.FileOutputStream.<init>(FileOutputStream.java:171)
  924. at org.apache.flink.runtime.blob.BlobCache.getURL(BlobCache.java:103)
  925. at org.apache.flink.runtime.execution.librarycache.BlobLibraryCacheManager.registerReferenceToBlobKeyAndGetURL(BlobLibraryCacheManager.java:225)
  926. at org.apache.flink.runtime.execution.librarycache.BlobLibraryCacheManager.registerTask(BlobLibraryCacheManager.java:111)
  927. at org.apache.flink.runtime.taskmanager.TaskManager.submitTask(TaskManager.java:597)
  928. at sun.reflect.GeneratedMethodAccessor2.invoke(Unknown Source)
  929. at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
  930. at java.lang.reflect.Method.invoke(Method.java:606)
  931. at org.apache.flink.runtime.ipc.RPC$Server.call(RPC.java:420)
  932. at org.apache.flink.runtime.ipc.Server$Handler.run(Server.java:949)
  933.  
  934. at org.apache.flink.runtime.executiongraph.Execution$2.run(Execution.java:289)
  935. at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
  936. at java.util.concurrent.FutureTask.run(FutureTask.java:262)
  937. at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
  938. at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
  939. at java.lang.Thread.run(Thread.java:744)
  940.  
  941. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1423) (org.apache.flink.api.java.io.CsvInputFormat)) (22/24) switched to CANCELED
  942. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1394) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1395)) (19/24) switched to CANCELED
  943. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1394) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1395)) (10/24) switched to CANCELED
  944. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1394) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1395)) (14/24) switched to CANCELED
  945. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1394) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1395)) (15/24) switched to CANCELED
  946. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1394) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1395)) (21/24) switched to CANCELED
  947. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1398) (org.apache.flink.api.java.io.TextInputFormat)) -> Map (Map at main(FlightConnectionJoiner.java:1399)) (14/24) switched to CANCELED
  948. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1394) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1395)) (16/24) switched to CANCELED
  949. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1398) (org.apache.flink.api.java.io.TextInputFormat)) -> Map (Map at main(FlightConnectionJoiner.java:1399)) (2/24) switched to CANCELED
  950. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1394) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1395)) (22/24) switched to CANCELED
  951. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1390) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1391)) (13/24) switched to CANCELED
  952. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1423) (org.apache.flink.api.java.io.CsvInputFormat)) (7/24) switched to CANCELED
  953. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1390) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1391)) (15/24) switched to CANCELED
  954. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1394) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1395)) (17/24) switched to CANCELED
  955. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1426) (org.apache.flink.api.java.io.CsvInputFormat)) (23/24) switched to CANCELED
  956. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1423) (org.apache.flink.api.java.io.CsvInputFormat)) (14/24) switched to CANCELED
  957. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1423) (org.apache.flink.api.java.io.CsvInputFormat)) (8/24) switched to CANCELED
  958. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1423) (org.apache.flink.api.java.io.CsvInputFormat)) (13/24) switched to CANCELED
  959. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1394) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1395)) (8/24) switched to CANCELED
  960. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1423) (org.apache.flink.api.java.io.CsvInputFormat)) (12/24) switched to CANCELED
  961. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1390) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1391)) (16/24) switched to CANCELED
  962. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1426) (org.apache.flink.api.java.io.CsvInputFormat)) (7/24) switched to CANCELED
  963. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1394) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1395)) (7/24) switched to CANCELED
  964. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1398) (org.apache.flink.api.java.io.TextInputFormat)) -> Map (Map at main(FlightConnectionJoiner.java:1399)) (16/24) switched to CANCELED
  965. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1390) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1391)) (6/24) switched to FAILED
  966. java.lang.Exception: Failed to deploy the task CHAIN DataSource (at main(FlightConnectionJoiner.java:1390) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1391)) (6/24) - execution #0 to slot SubSlot 4 (41ea5741bcb1ec3073069e8c6f901acb (1) - ALLOCATED/ALIVE): java.io.FileNotFoundException: /tmp/blobStore-7d93e071-4515-4d27-8d4e-c2983a800077/cache/blob_0bfb661afec4ff2bff2dbb3993a1f6ab69106a2e (No such file or directory)
  967. at java.io.FileOutputStream.open(Native Method)
  968. at java.io.FileOutputStream.<init>(FileOutputStream.java:221)
  969. at java.io.FileOutputStream.<init>(FileOutputStream.java:171)
  970. at org.apache.flink.runtime.blob.BlobCache.getURL(BlobCache.java:103)
  971. at org.apache.flink.runtime.execution.librarycache.BlobLibraryCacheManager.registerReferenceToBlobKeyAndGetURL(BlobLibraryCacheManager.java:225)
  972. at org.apache.flink.runtime.execution.librarycache.BlobLibraryCacheManager.registerTask(BlobLibraryCacheManager.java:111)
  973. at org.apache.flink.runtime.taskmanager.TaskManager.submitTask(TaskManager.java:597)
  974. at sun.reflect.GeneratedMethodAccessor2.invoke(Unknown Source)
  975. at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
  976. at java.lang.reflect.Method.invoke(Method.java:606)
  977. at org.apache.flink.runtime.ipc.RPC$Server.call(RPC.java:420)
  978. at org.apache.flink.runtime.ipc.Server$Handler.run(Server.java:949)
  979.  
  980. at org.apache.flink.runtime.executiongraph.Execution$2.run(Execution.java:289)
  981. at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
  982. at java.util.concurrent.FutureTask.run(FutureTask.java:262)
  983. at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
  984. at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
  985. at java.lang.Thread.run(Thread.java:744)
  986.  
  987. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1390) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1391)) (8/24) switched to CANCELED
  988. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1398) (org.apache.flink.api.java.io.TextInputFormat)) -> Map (Map at main(FlightConnectionJoiner.java:1399)) (4/24) switched to CANCELED
  989. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1459)) (17/24) switched to CANCELED
  990. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1459)) (18/24) switched to CANCELED
  991. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1459)) (19/24) switched to CANCELED
  992. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1459)) (20/24) switched to CANCELED
  993. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1459)) (21/24) switched to CANCELED
  994. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1459)) (22/24) switched to CANCELED
  995. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1459)) (23/24) switched to CANCELED
  996. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1459)) (24/24) switched to CANCELED
  997. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1475)) (1/24) switched to CANCELED
  998. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1475)) (2/24) switched to CANCELED
  999. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1426) (org.apache.flink.api.java.io.CsvInputFormat)) (21/24) switched to CANCELED
  1000. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1475)) (3/24) switched to CANCELED
  1001. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1475)) (4/24) switched to CANCELED
  1002. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1475)) (5/24) switched to CANCELED
  1003. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1426) (org.apache.flink.api.java.io.CsvInputFormat)) (22/24) switched to CANCELED
  1004. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1475)) (6/24) switched to CANCELED
  1005. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1475)) (7/24) switched to CANCELED
  1006. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1475)) (8/24) switched to CANCELED
  1007. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1475)) (9/24) switched to CANCELED
  1008. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1475)) (10/24) switched to CANCELED
  1009. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1475)) (11/24) switched to CANCELED
  1010. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1475)) (12/24) switched to CANCELED
  1011. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1475)) (13/24) switched to CANCELED
  1012. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1475)) (14/24) switched to CANCELED
  1013. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1475)) (15/24) switched to CANCELED
  1014. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1475)) (16/24) switched to CANCELED
  1015. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1475)) (17/24) switched to CANCELED
  1016. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1475)) (18/24) switched to CANCELED
  1017. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1475)) (19/24) switched to CANCELED
  1018. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1475)) (20/24) switched to CANCELED
  1019. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1475)) (21/24) switched to CANCELED
  1020. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1475)) (22/24) switched to CANCELED
  1021. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1475)) (23/24) switched to CANCELED
  1022. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1475)) (24/24) switched to CANCELED
  1023. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1477)) (1/24) switched to CANCELED
  1024. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1477)) (2/24) switched to CANCELED
  1025. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1477)) (3/24) switched to CANCELED
  1026. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1477)) (4/24) switched to CANCELED
  1027. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1477)) (5/24) switched to CANCELED
  1028. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1477)) (6/24) switched to CANCELED
  1029. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1477)) (7/24) switched to CANCELED
  1030. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1477)) (8/24) switched to CANCELED
  1031. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1477)) (9/24) switched to CANCELED
  1032. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1477)) (10/24) switched to CANCELED
  1033. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1477)) (11/24) switched to CANCELED
  1034. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1477)) (12/24) switched to CANCELED
  1035. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1477)) (13/24) switched to CANCELED
  1036. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1477)) (14/24) switched to CANCELED
  1037. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1477)) (15/24) switched to CANCELED
  1038. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1477)) (16/24) switched to CANCELED
  1039. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1477)) (17/24) switched to CANCELED
  1040. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1477)) (18/24) switched to CANCELED
  1041. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1477)) (19/24) switched to CANCELED
  1042. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1477)) (20/24) switched to CANCELED
  1043. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1477)) (21/24) switched to CANCELED
  1044. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1477)) (22/24) switched to CANCELED
  1045. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1477)) (23/24) switched to CANCELED
  1046. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1477)) (24/24) switched to CANCELED
  1047. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1481)) (1/24) switched to CANCELED
  1048. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1426) (org.apache.flink.api.java.io.CsvInputFormat)) (6/24) switched to CANCELED
  1049. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1481)) (2/24) switched to CANCELED
  1050. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1481)) (3/24) switched to CANCELED
  1051. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1394) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1395)) (23/24) switched to CANCELED
  1052. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1426) (org.apache.flink.api.java.io.CsvInputFormat)) (4/24) switched to CANCELED
  1053. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1426) (org.apache.flink.api.java.io.CsvInputFormat)) (18/24) switched to CANCELED
  1054. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1481)) (4/24) switched to CANCELED
  1055. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1394) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1395)) (20/24) switched to CANCELED
  1056. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1481)) (5/24) switched to CANCELED
  1057. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1481)) (6/24) switched to CANCELED
  1058. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1423) (org.apache.flink.api.java.io.CsvInputFormat)) (10/24) switched to CANCELED
  1059. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1481)) (7/24) switched to CANCELED
  1060. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1426) (org.apache.flink.api.java.io.CsvInputFormat)) (24/24) switched to CANCELED
  1061. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1481)) (8/24) switched to CANCELED
  1062. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1481)) (9/24) switched to CANCELED
  1063. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1481)) (10/24) switched to CANCELED
  1064. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1481)) (11/24) switched to CANCELED
  1065. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1481)) (12/24) switched to CANCELED
  1066. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1481)) (13/24) switched to CANCELED
  1067. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1481)) (14/24) switched to CANCELED
  1068. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1481)) (15/24) switched to CANCELED
  1069. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1481)) (16/24) switched to CANCELED
  1070. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1481)) (17/24) switched to CANCELED
  1071. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1481)) (18/24) switched to CANCELED
  1072. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1481)) (19/24) switched to CANCELED
  1073. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1481)) (20/24) switched to CANCELED
  1074. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1481)) (21/24) switched to CANCELED
  1075. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1481)) (22/24) switched to CANCELED
  1076. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1481)) (23/24) switched to CANCELED
  1077. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1481)) (24/24) switched to CANCELED
  1078. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1483)) (1/24) switched to CANCELED
  1079. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1483)) (2/24) switched to CANCELED
  1080. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1483)) (3/24) switched to CANCELED
  1081. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1483)) (4/24) switched to CANCELED
  1082. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1483)) (5/24) switched to CANCELED
  1083. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1483)) (6/24) switched to CANCELED
  1084. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1483)) (7/24) switched to CANCELED
  1085. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1483)) (8/24) switched to CANCELED
  1086. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1483)) (9/24) switched to CANCELED
  1087. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1483)) (10/24) switched to CANCELED
  1088. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1483)) (11/24) switched to CANCELED
  1089. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1483)) (12/24) switched to CANCELED
  1090. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1483)) (13/24) switched to CANCELED
  1091. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1483)) (14/24) switched to CANCELED
  1092. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1483)) (15/24) switched to CANCELED
  1093. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1483)) (16/24) switched to CANCELED
  1094. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1483)) (17/24) switched to CANCELED
  1095. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1483)) (18/24) switched to CANCELED
  1096. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1483)) (19/24) switched to CANCELED
  1097. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1483)) (20/24) switched to CANCELED
  1098. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1483)) (21/24) switched to CANCELED
  1099. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1483)) (22/24) switched to CANCELED
  1100. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1483)) (23/24) switched to CANCELED
  1101. 02/04/2015 13:28:54: Join(Join at main(FlightConnectionJoiner.java:1483)) (24/24) switched to CANCELED
  1102. 02/04/2015 13:28:54: Filter (Filter at main(FlightConnectionJoiner.java:1507)) (1/24) switched to CANCELED
  1103. 02/04/2015 13:28:54: Filter (Filter at main(FlightConnectionJoiner.java:1507)) (2/24) switched to CANCELED
  1104. 02/04/2015 13:28:54: Filter (Filter at main(FlightConnectionJoiner.java:1507)) (3/24) switched to CANCELED
  1105. 02/04/2015 13:28:54: Filter (Filter at main(FlightConnectionJoiner.java:1507)) (4/24) switched to CANCELED
  1106. 02/04/2015 13:28:54: Filter (Filter at main(FlightConnectionJoiner.java:1507)) (5/24) switched to CANCELED
  1107. 02/04/2015 13:28:54: Filter (Filter at main(FlightConnectionJoiner.java:1507)) (6/24) switched to CANCELED
  1108. 02/04/2015 13:28:54: Filter (Filter at main(FlightConnectionJoiner.java:1507)) (7/24) switched to CANCELED
  1109. 02/04/2015 13:28:54: Filter (Filter at main(FlightConnectionJoiner.java:1507)) (8/24) switched to CANCELED
  1110. 02/04/2015 13:28:54: Filter (Filter at main(FlightConnectionJoiner.java:1507)) (9/24) switched to CANCELED
  1111. 02/04/2015 13:28:54: Filter (Filter at main(FlightConnectionJoiner.java:1507)) (10/24) switched to CANCELED
  1112. 02/04/2015 13:28:54: Filter (Filter at main(FlightConnectionJoiner.java:1507)) (11/24) switched to CANCELED
  1113. 02/04/2015 13:28:54: Filter (Filter at main(FlightConnectionJoiner.java:1507)) (12/24) switched to CANCELED
  1114. 02/04/2015 13:28:54: Filter (Filter at main(FlightConnectionJoiner.java:1507)) (13/24) switched to CANCELED
  1115. 02/04/2015 13:28:54: Filter (Filter at main(FlightConnectionJoiner.java:1507)) (14/24) switched to CANCELED
  1116. 02/04/2015 13:28:54: Filter (Filter at main(FlightConnectionJoiner.java:1507)) (15/24) switched to CANCELED
  1117. 02/04/2015 13:28:54: Filter (Filter at main(FlightConnectionJoiner.java:1507)) (16/24) switched to CANCELED
  1118. 02/04/2015 13:28:54: Filter (Filter at main(FlightConnectionJoiner.java:1507)) (17/24) switched to CANCELED
  1119. 02/04/2015 13:28:54: Filter (Filter at main(FlightConnectionJoiner.java:1507)) (18/24) switched to CANCELED
  1120. 02/04/2015 13:28:54: Filter (Filter at main(FlightConnectionJoiner.java:1507)) (19/24) switched to CANCELED
  1121. 02/04/2015 13:28:54: Filter (Filter at main(FlightConnectionJoiner.java:1507)) (20/24) switched to CANCELED
  1122. 02/04/2015 13:28:54: Filter (Filter at main(FlightConnectionJoiner.java:1507)) (21/24) switched to CANCELED
  1123. 02/04/2015 13:28:54: Filter (Filter at main(FlightConnectionJoiner.java:1507)) (22/24) switched to CANCELED
  1124. 02/04/2015 13:28:54: Filter (Filter at main(FlightConnectionJoiner.java:1507)) (23/24) switched to CANCELED
  1125. 02/04/2015 13:28:54: Filter (Filter at main(FlightConnectionJoiner.java:1507)) (24/24) switched to CANCELED
  1126. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1398) (org.apache.flink.api.java.io.TextInputFormat)) -> Map (Map at main(FlightConnectionJoiner.java:1399)) (1/24) switched to CANCELED
  1127. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1426) (org.apache.flink.api.java.io.CsvInputFormat)) (9/24) switched to CANCELED
  1128. 02/04/2015 13:28:54: DataSink(TextOutputFormat (hdfs:/user/rwaury/output2/flights/one) - UTF-8) (1/24) switched to CANCELED
  1129. 02/04/2015 13:28:54: DataSink(TextOutputFormat (hdfs:/user/rwaury/output2/flights/one) - UTF-8) (2/24) switched to CANCELED
  1130. 02/04/2015 13:28:54: DataSink(TextOutputFormat (hdfs:/user/rwaury/output2/flights/one) - UTF-8) (3/24) switched to CANCELED
  1131. 02/04/2015 13:28:54: DataSink(TextOutputFormat (hdfs:/user/rwaury/output2/flights/one) - UTF-8) (4/24) switched to CANCELED
  1132. 02/04/2015 13:28:54: DataSink(TextOutputFormat (hdfs:/user/rwaury/output2/flights/one) - UTF-8) (5/24) switched to CANCELED
  1133. 02/04/2015 13:28:54: DataSink(TextOutputFormat (hdfs:/user/rwaury/output2/flights/one) - UTF-8) (6/24) switched to CANCELED
  1134. 02/04/2015 13:28:54: DataSink(TextOutputFormat (hdfs:/user/rwaury/output2/flights/one) - UTF-8) (7/24) switched to CANCELED
  1135. 02/04/2015 13:28:54: DataSink(TextOutputFormat (hdfs:/user/rwaury/output2/flights/one) - UTF-8) (8/24) switched to CANCELED
  1136. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1426) (org.apache.flink.api.java.io.CsvInputFormat)) (10/24) switched to CANCELED
  1137. 02/04/2015 13:28:54: DataSink(TextOutputFormat (hdfs:/user/rwaury/output2/flights/one) - UTF-8) (9/24) switched to CANCELED
  1138. 02/04/2015 13:28:54: DataSink(TextOutputFormat (hdfs:/user/rwaury/output2/flights/one) - UTF-8) (10/24) switched to CANCELED
  1139. 02/04/2015 13:28:54: DataSink(TextOutputFormat (hdfs:/user/rwaury/output2/flights/one) - UTF-8) (11/24) switched to CANCELED
  1140. 02/04/2015 13:28:54: DataSink(TextOutputFormat (hdfs:/user/rwaury/output2/flights/one) - UTF-8) (12/24) switched to CANCELED
  1141. 02/04/2015 13:28:54: DataSink(TextOutputFormat (hdfs:/user/rwaury/output2/flights/one) - UTF-8) (13/24) switched to CANCELED
  1142. 02/04/2015 13:28:54: DataSink(TextOutputFormat (hdfs:/user/rwaury/output2/flights/one) - UTF-8) (14/24) switched to CANCELED
  1143. 02/04/2015 13:28:54: DataSink(TextOutputFormat (hdfs:/user/rwaury/output2/flights/one) - UTF-8) (15/24) switched to CANCELED
  1144. 02/04/2015 13:28:54: DataSink(TextOutputFormat (hdfs:/user/rwaury/output2/flights/one) - UTF-8) (16/24) switched to CANCELED
  1145. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1426) (org.apache.flink.api.java.io.CsvInputFormat)) (17/24) switched to CANCELED
  1146. 02/04/2015 13:28:54: DataSink(TextOutputFormat (hdfs:/user/rwaury/output2/flights/one) - UTF-8) (17/24) switched to CANCELED
  1147. 02/04/2015 13:28:54: DataSink(TextOutputFormat (hdfs:/user/rwaury/output2/flights/one) - UTF-8) (18/24) switched to CANCELED
  1148. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1398) (org.apache.flink.api.java.io.TextInputFormat)) -> Map (Map at main(FlightConnectionJoiner.java:1399)) (23/24) switched to CANCELED
  1149. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1426) (org.apache.flink.api.java.io.CsvInputFormat)) (16/24) switched to CANCELED
  1150. 02/04/2015 13:28:54: DataSink(TextOutputFormat (hdfs:/user/rwaury/output2/flights/one) - UTF-8) (19/24) switched to CANCELED
  1151. 02/04/2015 13:28:54: DataSink(TextOutputFormat (hdfs:/user/rwaury/output2/flights/one) - UTF-8) (20/24) switched to CANCELED
  1152. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1426) (org.apache.flink.api.java.io.CsvInputFormat)) (14/24) switched to CANCELED
  1153. 02/04/2015 13:28:54: DataSink(TextOutputFormat (hdfs:/user/rwaury/output2/flights/one) - UTF-8) (21/24) switched to CANCELED
  1154. 02/04/2015 13:28:54: DataSink(TextOutputFormat (hdfs:/user/rwaury/output2/flights/one) - UTF-8) (22/24) switched to CANCELED
  1155. 02/04/2015 13:28:54: DataSink(TextOutputFormat (hdfs:/user/rwaury/output2/flights/one) - UTF-8) (23/24) switched to CANCELED
  1156. 02/04/2015 13:28:54: DataSink(TextOutputFormat (hdfs:/user/rwaury/output2/flights/one) - UTF-8) (24/24) switched to CANCELED
  1157. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1398) (org.apache.flink.api.java.io.TextInputFormat)) -> Map (Map at main(FlightConnectionJoiner.java:1399)) (11/24) switched to CANCELED
  1158. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1426) (org.apache.flink.api.java.io.CsvInputFormat)) (8/24) switched to CANCELED
  1159. 02/04/2015 13:28:54: DataSink(com.amadeus.pcb.join.FlightOutput$NonStopFullOutputFormat@1377c533) (1/24) switched to CANCELED
  1160. 02/04/2015 13:28:54: DataSink(com.amadeus.pcb.join.FlightOutput$NonStopFullOutputFormat@1377c533) (2/24) switched to CANCELED
  1161. 02/04/2015 13:28:54: DataSink(com.amadeus.pcb.join.FlightOutput$NonStopFullOutputFormat@1377c533) (3/24) switched to CANCELED
  1162. 02/04/2015 13:28:54: DataSink(com.amadeus.pcb.join.FlightOutput$NonStopFullOutputFormat@1377c533) (4/24) switched to CANCELED
  1163. 02/04/2015 13:28:54: DataSink(com.amadeus.pcb.join.FlightOutput$NonStopFullOutputFormat@1377c533) (5/24) switched to CANCELED
  1164. 02/04/2015 13:28:54: DataSink(com.amadeus.pcb.join.FlightOutput$NonStopFullOutputFormat@1377c533) (6/24) switched to CANCELED
  1165. 02/04/2015 13:28:54: DataSink(com.amadeus.pcb.join.FlightOutput$NonStopFullOutputFormat@1377c533) (7/24) switched to CANCELED
  1166. 02/04/2015 13:28:54: DataSink(com.amadeus.pcb.join.FlightOutput$NonStopFullOutputFormat@1377c533) (8/24) switched to CANCELED
  1167. 02/04/2015 13:28:54: DataSink(com.amadeus.pcb.join.FlightOutput$NonStopFullOutputFormat@1377c533) (9/24) switched to CANCELED
  1168. 02/04/2015 13:28:54: DataSink(com.amadeus.pcb.join.FlightOutput$NonStopFullOutputFormat@1377c533) (10/24) switched to CANCELED
  1169. 02/04/2015 13:28:54: DataSink(com.amadeus.pcb.join.FlightOutput$NonStopFullOutputFormat@1377c533) (11/24) switched to CANCELED
  1170. 02/04/2015 13:28:54: DataSink(com.amadeus.pcb.join.FlightOutput$NonStopFullOutputFormat@1377c533) (12/24) switched to CANCELED
  1171. 02/04/2015 13:28:54: DataSink(com.amadeus.pcb.join.FlightOutput$NonStopFullOutputFormat@1377c533) (13/24) switched to CANCELED
  1172. 02/04/2015 13:28:54: DataSink(com.amadeus.pcb.join.FlightOutput$NonStopFullOutputFormat@1377c533) (14/24) switched to CANCELED
  1173. 02/04/2015 13:28:54: DataSink(com.amadeus.pcb.join.FlightOutput$NonStopFullOutputFormat@1377c533) (15/24) switched to CANCELED
  1174. 02/04/2015 13:28:54: DataSink(com.amadeus.pcb.join.FlightOutput$NonStopFullOutputFormat@1377c533) (16/24) switched to CANCELED
  1175. 02/04/2015 13:28:54: DataSink(com.amadeus.pcb.join.FlightOutput$NonStopFullOutputFormat@1377c533) (17/24) switched to CANCELED
  1176. 02/04/2015 13:28:54: DataSink(com.amadeus.pcb.join.FlightOutput$NonStopFullOutputFormat@1377c533) (18/24) switched to CANCELED
  1177. 02/04/2015 13:28:54: DataSink(com.amadeus.pcb.join.FlightOutput$NonStopFullOutputFormat@1377c533) (19/24) switched to CANCELED
  1178. 02/04/2015 13:28:54: DataSink(com.amadeus.pcb.join.FlightOutput$NonStopFullOutputFormat@1377c533) (20/24) switched to CANCELED
  1179. 02/04/2015 13:28:54: DataSink(com.amadeus.pcb.join.FlightOutput$NonStopFullOutputFormat@1377c533) (21/24) switched to CANCELED
  1180. 02/04/2015 13:28:54: DataSink(com.amadeus.pcb.join.FlightOutput$NonStopFullOutputFormat@1377c533) (22/24) switched to CANCELED
  1181. 02/04/2015 13:28:54: DataSink(com.amadeus.pcb.join.FlightOutput$NonStopFullOutputFormat@1377c533) (23/24) switched to CANCELED
  1182. 02/04/2015 13:28:54: DataSink(com.amadeus.pcb.join.FlightOutput$NonStopFullOutputFormat@1377c533) (24/24) switched to CANCELED
  1183. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1423) (org.apache.flink.api.java.io.CsvInputFormat)) (2/24) switched to CANCELED
  1184. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1426) (org.apache.flink.api.java.io.CsvInputFormat)) (11/24) switched to CANCELED
  1185. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1398) (org.apache.flink.api.java.io.TextInputFormat)) -> Map (Map at main(FlightConnectionJoiner.java:1399)) (10/24) switched to CANCELED
  1186. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1398) (org.apache.flink.api.java.io.TextInputFormat)) -> Map (Map at main(FlightConnectionJoiner.java:1399)) (13/24) switched to CANCELED
  1187. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1394) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1395)) (4/24) switched to CANCELED
  1188. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1426) (org.apache.flink.api.java.io.CsvInputFormat)) (20/24) switched to CANCELED
  1189. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1423) (org.apache.flink.api.java.io.CsvInputFormat)) (3/24) switched to CANCELED
  1190. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1390) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1391)) (14/24) switched to CANCELED
  1191. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1426) (org.apache.flink.api.java.io.CsvInputFormat)) (1/24) switched to CANCELED
  1192. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1398) (org.apache.flink.api.java.io.TextInputFormat)) -> Map (Map at main(FlightConnectionJoiner.java:1399)) (21/24) switched to CANCELED
  1193. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1398) (org.apache.flink.api.java.io.TextInputFormat)) -> Map (Map at main(FlightConnectionJoiner.java:1399)) (9/24) switched to CANCELED
  1194. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1426) (org.apache.flink.api.java.io.CsvInputFormat)) (19/24) switched to CANCELED
  1195. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1390) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1391)) (3/24) switched to CANCELED
  1196. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1390) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1391)) (2/24) switched to CANCELED
  1197. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1398) (org.apache.flink.api.java.io.TextInputFormat)) -> Map (Map at main(FlightConnectionJoiner.java:1399)) (17/24) switched to CANCELED
  1198. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1390) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1391)) (21/24) switched to CANCELED
  1199. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1390) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1391)) (9/24) switched to CANCELED
  1200. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1394) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1395)) (24/24) switched to CANCELED
  1201. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1426) (org.apache.flink.api.java.io.CsvInputFormat)) (2/24) switched to CANCELED
  1202. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1426) (org.apache.flink.api.java.io.CsvInputFormat)) (13/24) switched to CANCELED
  1203. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1398) (org.apache.flink.api.java.io.TextInputFormat)) -> Map (Map at main(FlightConnectionJoiner.java:1399)) (20/24) switched to CANCELED
  1204. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1390) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1391)) (10/24) switched to CANCELED
  1205. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1398) (org.apache.flink.api.java.io.TextInputFormat)) -> Map (Map at main(FlightConnectionJoiner.java:1399)) (19/24) switched to CANCELED
  1206. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1426) (org.apache.flink.api.java.io.CsvInputFormat)) (5/24) switched to CANCELED
  1207. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1423) (org.apache.flink.api.java.io.CsvInputFormat)) (9/24) switched to CANCELED
  1208. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1423) (org.apache.flink.api.java.io.CsvInputFormat)) (1/24) switched to CANCELED
  1209. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1423) (org.apache.flink.api.java.io.CsvInputFormat)) (11/24) switched to CANCELED
  1210. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1394) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1395)) (11/24) switched to CANCELED
  1211. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1398) (org.apache.flink.api.java.io.TextInputFormat)) -> Map (Map at main(FlightConnectionJoiner.java:1399)) (12/24) switched to CANCELED
  1212. 02/04/2015 13:28:54: DataSource (at main(FlightConnectionJoiner.java:1426) (org.apache.flink.api.java.io.CsvInputFormat)) (12/24) switched to CANCELED
  1213. 02/04/2015 13:28:54: CHAIN DataSource (at main(FlightConnectionJoiner.java:1398) (org.apache.flink.api.java.io.TextInputFormat)) -> Map (Map at main(FlightConnectionJoiner.java:1399)) (24/24) switched to CANCELED
  1214. 02/04/2015 13:28:55: CHAIN DataSource (at main(FlightConnectionJoiner.java:1390) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1391)) (17/24) switched to CANCELED
  1215. 02/04/2015 13:28:55: CHAIN DataSource (at main(FlightConnectionJoiner.java:1390) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1391)) (19/24) switched to CANCELED
  1216. 02/04/2015 13:28:55: CHAIN DataSource (at main(FlightConnectionJoiner.java:1390) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1391)) (23/24) switched to CANCELED
  1217. 02/04/2015 13:28:55: CHAIN DataSource (at main(FlightConnectionJoiner.java:1390) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1391)) (11/24) switched to CANCELED
  1218. 02/04/2015 13:28:55: CHAIN DataSource (at main(FlightConnectionJoiner.java:1390) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1391)) (24/24) switched to CANCELED
  1219. 02/04/2015 13:28:55: CHAIN DataSource (at main(FlightConnectionJoiner.java:1390) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1391)) (7/24) switched to CANCELED
  1220. 02/04/2015 13:28:55: CHAIN DataSource (at main(FlightConnectionJoiner.java:1390) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1391)) (4/24) switched to CANCELED
  1221. 02/04/2015 13:28:55: CHAIN DataSource (at main(FlightConnectionJoiner.java:1390) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1391)) (1/24) switched to CANCELED
  1222. 02/04/2015 13:28:55: CHAIN DataSource (at main(FlightConnectionJoiner.java:1390) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1391)) (22/24) switched to CANCELED
  1223. 02/04/2015 13:28:55: CHAIN DataSource (at main(FlightConnectionJoiner.java:1394) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1395)) (18/24) switched to CANCELED
  1224. 02/04/2015 13:28:55: CHAIN DataSource (at main(FlightConnectionJoiner.java:1390) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1391)) (20/24) switched to CANCELED
  1225. 02/04/2015 13:28:55: CHAIN DataSource (at main(FlightConnectionJoiner.java:1398) (org.apache.flink.api.java.io.TextInputFormat)) -> Map (Map at main(FlightConnectionJoiner.java:1399)) (15/24) switched to CANCELED
  1226. 02/04/2015 13:28:55: CHAIN DataSource (at main(FlightConnectionJoiner.java:1390) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1391)) (18/24) switched to CANCELED
  1227. 02/04/2015 13:28:55: CHAIN DataSource (at main(FlightConnectionJoiner.java:1398) (org.apache.flink.api.java.io.TextInputFormat)) -> Map (Map at main(FlightConnectionJoiner.java:1399)) (8/24) switched to CANCELED
  1228. 02/04/2015 13:28:55: CHAIN DataSource (at main(FlightConnectionJoiner.java:1390) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1391)) (12/24) switched to CANCELED
  1229. 02/04/2015 13:28:55: CHAIN DataSource (at main(FlightConnectionJoiner.java:1398) (org.apache.flink.api.java.io.TextInputFormat)) -> Map (Map at main(FlightConnectionJoiner.java:1399)) (22/24) switched to CANCELED
  1230. 02/04/2015 13:28:55: CHAIN DataSource (at main(FlightConnectionJoiner.java:1398) (org.apache.flink.api.java.io.TextInputFormat)) -> Map (Map at main(FlightConnectionJoiner.java:1399)) (7/24) switched to CANCELED
  1231. 02/04/2015 13:28:55: CHAIN DataSource (at main(FlightConnectionJoiner.java:1398) (org.apache.flink.api.java.io.TextInputFormat)) -> Map (Map at main(FlightConnectionJoiner.java:1399)) (18/24) switched to CANCELED
  1232. 02/04/2015 13:28:55: CHAIN DataSource (at main(FlightConnectionJoiner.java:1394) (org.apache.flink.api.java.io.TextInputFormat)) -> FlatMap (FlatMap at main(FlightConnectionJoiner.java:1395)) (12/24) switched to CANCELED
  1233. 02/04/2015 13:28:55: Job execution switched to status FAILED
  1234. Error: The program execution failed: java.lang.Exception: Failed to deploy the task DataSource (at main(FlightConnectionJoiner.java:1426) (org.apache.flink.api.java.io.CsvInputFormat)) (3/24) - execution #0 to slot SubSlot 0 (41ea5741bcb1ec3073069e8c6f901acb (1) - ALLOCATED/ALIVE): java.io.FileNotFoundException: /tmp/blobStore-7d93e071-4515-4d27-8d4e-c2983a800077/cache/blob_0bfb661afec4ff2bff2dbb3993a1f6ab69106a2e (No such file or directory)
  1235. at java.io.FileOutputStream.open(Native Method)
  1236. at java.io.FileOutputStream.<init>(FileOutputStream.java:221)
  1237. at java.io.FileOutputStream.<init>(FileOutputStream.java:171)
  1238. at org.apache.flink.runtime.blob.BlobCache.getURL(BlobCache.java:103)
  1239. at org.apache.flink.runtime.execution.librarycache.BlobLibraryCacheManager.registerReferenceToBlobKeyAndGetURL(BlobLibraryCacheManager.java:225)
  1240. at org.apache.flink.runtime.execution.librarycache.BlobLibraryCacheManager.registerTask(BlobLibraryCacheManager.java:111)
  1241. at org.apache.flink.runtime.taskmanager.TaskManager.submitTask(TaskManager.java:597)
  1242. at sun.reflect.GeneratedMethodAccessor2.invoke(Unknown Source)
  1243. at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
  1244. at java.lang.reflect.Method.invoke(Method.java:606)
  1245. at org.apache.flink.runtime.ipc.RPC$Server.call(RPC.java:420)
  1246. at org.apache.flink.runtime.ipc.Server$Handler.run(Server.java:949)
  1247.  
  1248. at org.apache.flink.runtime.executiongraph.Execution$2.run(Execution.java:289)
  1249. at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
  1250. at java.util.concurrent.FutureTask.run(FutureTask.java:262)
  1251. at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
  1252. at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
  1253. at java.lang.Thread.run(Thread.java:744)
RAW Paste Data