API tools faq
paste
Advertisement
Guest User

Flink Log

a guest
Feb 4th, 2015
279
0
Never
Add comment
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 166.71 KB | None | 0 0
raw download clone embed print report
  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)
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement
Public Pastes
Advertisement
We use cookies for various purposes including analytics. By continuing to use Pastebin, you agree to our use of cookies as described in the Cookies Policy.  OK, I Understand
Not a member of Pastebin yet?
Sign Up, it unlocks many cool features!