API tools faq
paste
Advertisement
Guest User

Untitled

a guest
Jun 22nd, 2016
107
0
Never
Add comment
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 9.31 KB | None | 0 0
raw download clone embed print report
  1. 2016-06-22 11:03:51,954 INFO org.apache.flink.client.CliFrontend - --------------------------------------------------------------------------------
  2. 2016-06-22 11:03:51,956 INFO org.apache.flink.client.CliFrontend - Starting Command Line Client (Version: 1.0.3, Rev:f3a6b5f, Date:06.05.2016 @ 12:58:02 UTC)
  3. 2016-06-22 11:03:51,956 INFO org.apache.flink.client.CliFrontend - Current user: root
  4. 2016-06-22 11:03:51,956 INFO org.apache.flink.client.CliFrontend - JVM: Java HotSpot(TM) 64-Bit Server VM - Oracle Corporation - 1.8/25.74-b02
  5. 2016-06-22 11:03:51,956 INFO org.apache.flink.client.CliFrontend - Maximum heap size: 3540 MiBytes
  6. 2016-06-22 11:03:51,956 INFO org.apache.flink.client.CliFrontend - JAVA_HOME: /usr/lib/jvm/java-8-oracle
  7. 2016-06-22 11:03:51,959 INFO org.apache.flink.client.CliFrontend - Hadoop version: 2.7.2
  8. 2016-06-22 11:03:51,959 INFO org.apache.flink.client.CliFrontend - JVM Options:
  9. 2016-06-22 11:03:51,959 INFO org.apache.flink.client.CliFrontend - -Dlog.file=/root/flink-1.0.3/log/flink-root-client-analytics1.log
  10. 2016-06-22 11:03:51,959 INFO org.apache.flink.client.CliFrontend - -Dlog4j.configuration=file:/root/flink-1.0.3/conf/log4j-cli.properties
  11. 2016-06-22 11:03:51,959 INFO org.apache.flink.client.CliFrontend - -Dlogback.configurationFile=file:/root/flink-1.0.3/conf/logback.xml
  12. 2016-06-22 11:03:51,960 INFO org.apache.flink.client.CliFrontend - Program Arguments:
  13. 2016-06-22 11:03:51,960 INFO org.apache.flink.client.CliFrontend - run
  14. 2016-06-22 11:03:51,960 INFO org.apache.flink.client.CliFrontend - -m
  15. 2016-06-22 11:03:51,960 INFO org.apache.flink.client.CliFrontend - analytics1:6123
  16. 2016-06-22 11:03:51,960 INFO org.apache.flink.client.CliFrontend - -c
  17. 2016-06-22 11:03:51,960 INFO org.apache.flink.client.CliFrontend - KafkaWordCountFlink
  18. 2016-06-22 11:03:51,960 INFO org.apache.flink.client.CliFrontend - ../benchmark_Spark-Flink-assembly-1.0.jar
  19. 2016-06-22 11:03:51,960 INFO org.apache.flink.client.CliFrontend - wordCount3
  20. 2016-06-22 11:03:51,960 INFO org.apache.flink.client.CliFrontend - Classpath: /root/flink-1.0.3/lib/flink-dist_2.10-1.0.3.jar:/root/flink-1.0.3/lib/flink-python_2.10-1.0.3.jar:/root/flink-1.0.3/lib/log4j-1.2.17.jar:/root/flink-1.0.3/lib/slf4j-log4j12-1.7.7.jar:::
  21. 2016-06-22 11:03:51,960 INFO org.apache.flink.client.CliFrontend - --------------------------------------------------------------------------------
  22. 2016-06-22 11:03:51,961 INFO org.apache.flink.client.CliFrontend - Using configuration directory /root/flink-1.0.3/conf
  23. 2016-06-22 11:03:51,961 INFO org.apache.flink.client.CliFrontend - Trying to load configuration file
  24. 2016-06-22 11:03:52,217 INFO org.apache.flink.client.CliFrontend - Running 'run' command.
  25. 2016-06-22 11:03:52,226 INFO org.apache.flink.client.CliFrontend - Building program from JAR file
  26. 2016-06-22 11:03:52,408 INFO org.apache.flink.client.program.Client - Starting client actor system
  27. 2016-06-22 11:03:52,410 INFO org.apache.flink.runtime.client.JobClient - Starting JobClient actor system
  28. 2016-06-22 11:03:52,776 INFO akka.event.slf4j.Slf4jLogger - Slf4jLogger started
  29. 2016-06-22 11:03:52,827 INFO Remoting - Starting remoting
  30. 2016-06-22 11:03:52,987 INFO Remoting - Remoting started; listening on addresses :[akka.tcp://flink@127.0.0.1:34740]
  31. 2016-06-22 11:03:52,994 INFO org.apache.flink.runtime.client.JobClient - Started JobClient actor system at 127.0.0.1:34740
  32. 2016-06-22 11:03:52,994 INFO org.apache.flink.client.CliFrontend - Starting execution of program
  33. 2016-06-22 11:03:52,994 INFO org.apache.flink.client.program.Client - Starting program in interactive mode
  34. 2016-06-22 11:03:53,187 INFO org.elasticsearch.plugins - [Razorback] modules [], plugins [], sites []
  35. 2016-06-22 11:03:53,967 INFO org.apache.kafka.clients.consumer.ConsumerConfig - ConsumerConfig values:
  36. metric.reporters = []
  37. metadata.max.age.ms = 300000
  38. value.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer
  39. group.id = myGroup
  40. partition.assignment.strategy = [org.apache.kafka.clients.consumer.RangeAssignor]
  41. reconnect.backoff.ms = 50
  42. sasl.kerberos.ticket.renew.window.factor = 0.8
  43. max.partition.fetch.bytes = 1048576
  44. bootstrap.servers = [localhost:9092]
  45. retry.backoff.ms = 100
  46. sasl.kerberos.kinit.cmd = /usr/bin/kinit
  47. sasl.kerberos.service.name = null
  48. sasl.kerberos.ticket.renew.jitter = 0.05
  49. ssl.keystore.type = JKS
  50. ssl.trustmanager.algorithm = PKIX
  51. enable.auto.commit = true
  52. ssl.key.password = null
  53. fetch.max.wait.ms = 500
  54. sasl.kerberos.min.time.before.relogin = 60000
  55. connections.max.idle.ms = 540000
  56. ssl.truststore.password = null
  57. session.timeout.ms = 30000
  58. metrics.num.samples = 2
  59. client.id =
  60. ssl.endpoint.identification.algorithm = null
  61. key.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer
  62. ssl.protocol = TLS
  63. check.crcs = true
  64. request.timeout.ms = 40000
  65. ssl.provider = null
  66. ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1]
  67. ssl.keystore.location = null
  68. heartbeat.interval.ms = 3000
  69. auto.commit.interval.ms = 5000
  70. receive.buffer.bytes = 32768
  71. ssl.cipher.suites = null
  72. ssl.truststore.type = JKS
  73. security.protocol = PLAINTEXT
  74. ssl.truststore.location = null
  75. ssl.keystore.password = null
  76. ssl.keymanager.algorithm = SunX509
  77. metrics.sample.window.ms = 30000
  78. fetch.min.bytes = 1
  79. send.buffer.bytes = 131072
  80. auto.offset.reset = latest
  81.  
  82. 2016-06-22 11:03:54,077 INFO org.apache.kafka.common.utils.AppInfoParser - Kafka version : 0.9.0.1
  83. 2016-06-22 11:03:54,077 INFO org.apache.kafka.common.utils.AppInfoParser - Kafka commitId : 23c69d62a0cabf06
  84. 2016-06-22 11:03:54,078 INFO org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer09 - Trying to get partitions for topic wordCount3
  85. 2016-06-22 11:03:54,232 INFO org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer09 - Got 1 partitions from these topics: [wordCount3]
  86. 2016-06-22 11:03:54,232 INFO org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumerBase - Consumer is going to read the following topics (with number of partitions): wordCount3 (1),
  87. 2016-06-22 11:03:54,420 INFO org.apache.flink.runtime.client.JobClientActor - Received job kafka stream (249e739e846fbc15900cc35648747a40).
  88. 2016-06-22 11:03:54,421 INFO org.apache.flink.runtime.client.JobClientActor - Could not submit job kafka stream (249e739e846fbc15900cc35648747a40), because there is no connection to a JobManager.
  89. 2016-06-22 11:03:54,423 INFO org.apache.flink.runtime.client.JobClientActor - Disconnect from JobManager null.
  90. 2016-06-22 11:03:54,655 INFO org.apache.flink.runtime.client.JobClientActor - Connect to JobManager Actor[akka.tcp://flink@10.10.40.1:6123/user/jobmanager#-470128903].
  91. 2016-06-22 11:03:54,655 INFO org.apache.flink.runtime.client.JobClientActor - Connected to new JobManager akka.tcp://flink@10.10.40.1:6123/user/jobmanager.
  92. 2016-06-22 11:03:54,660 INFO org.apache.flink.runtime.client.JobClientActor - Sending message to JobManager akka.tcp://flink@10.10.40.1:6123/user/jobmanager to submit job kafka stream (249e739e846fbc15900cc35648747a40) and wait for progress
  93. 2016-06-22 11:03:54,663 INFO org.apache.flink.runtime.client.JobClientActor - Upload jar files to job manager akka.tcp://flink@10.10.40.1:6123/user/jobmanager.
  94. 2016-06-22 11:03:55,845 INFO org.apache.flink.runtime.client.JobClientActor - Submit job to the job manager akka.tcp://flink@10.10.40.1:6123/user/jobmanager.
  95. 2016-06-22 11:03:55,866 INFO org.apache.flink.runtime.client.JobClientActor - Job was successfully submitted to the JobManager akka.tcp://flink@10.10.40.1:6123/user/jobmanager.
  96. 2016-06-22 11:03:55,869 INFO org.apache.flink.runtime.client.JobClientActor - 06/22/2016 11:03:55 Job execution switched to status RUNNING.
  97. 2016-06-22 11:03:55,875 INFO org.apache.flink.runtime.client.JobClientActor - 06/22/2016 11:03:55 Source: Custom Source -> Sink: Unnamed(1/1) switched to SCHEDULED
  98. 2016-06-22 11:03:55,876 INFO org.apache.flink.runtime.client.JobClientActor - 06/22/2016 11:03:55 Source: Custom Source -> Sink: Unnamed(1/1) switched to DEPLOYING
  99. 2016-06-22 11:03:55,878 INFO org.apache.flink.runtime.client.JobClientActor - 06/22/2016 11:03:55 Source: Custom Source -> Sink: Unnamed(1/1) switched to RUNNING
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!