• zhh
    2020-10-21
    git上没有这些例子的文件，比如flink on k8s的yaml文件

    作者回复: 有的，可以结合代码看，所有课上的例子都可以在实验代码中找到，https://gitee.com/geektime-geekbang/geektime-Flink

    共 2 条评论
    
  • Geek_ecd17b
    2023-08-23 来自上海
    老师请教下，k8s application模式和session模式如何选型呢
    
    
  • 花棉裤男孩
    2021-11-23
    我按照例子操作好像报错 session 模式 ERROR StatusLogger Unable to access file:/opt/flink/conf/log4j-cli.properties java.io.FileNotFoundException: /opt/flink/conf/log4j-cli.properties (No such file or directory) at java.io.FileInputStream.open0(Native Method) at java.io.FileInputStream.open(FileInputStream.java:195) at java.io.FileInputStream.<init>(FileInputStream.java:138) at java.io.FileInputStream.<init>(FileInputStream.java:93) at sun.net.www.protocol.file.FileURLConnection.connect(FileURLConnection.java:90) at sun.net.www.protocol.file.FileURLConnection.getInputStream(FileURLConnection.java:188) at org.apache.logging.log4j.core.config.ConfigurationSource.fromUri(ConfigurationSource.java:321) at org.apache.logging.log4j.core.config.ConfigurationFactory$Factory.getConfiguration(ConfigurationFactory.java:443) at org.apache.logging.log4j.core.config.ConfigurationFactory$Factory.getConfiguration(ConfigurationFactory.java:385) at org.apache.logging.log4j.core.config.ConfigurationFactory.getConfiguration(ConfigurationFactory.java:293) at org.apache.logging.log4j.core.LoggerContext.reconfigure(LoggerContext.java:647) at org.apache.logging.log4j.core.LoggerContext.reconfigure(LoggerContext.java:668) at org.apache.logging.log4j.core.LoggerContext.start(LoggerContext.java:253) at org.apache.logging.log4j.core.impl.Log4jContextFactory.getContext(Log4jContextFactory.java:153) at org.apache.logging.log4j.core.impl.Log4jContextFactory.getContext(Log4jContextFactory.java:45) at org.apache.logging.log4j.LogManager.getContext(LogManager.java:194) at org.apache.logging.log4j.spi.AbstractLoggerAdapter.getContext(AbstractLoggerAdapter.java:138) at org.apache.logging.slf4j.Log4jLoggerFactory.getContext(Log4jLoggerFactory.java:45) at org.apache.flink.client.cli.CliFrontend.<clinit>(CliFrontend.java:91) ERROR StatusLogger Reconfiguration failed: No configuration found for '677327b6' at 'null' in 'null'
    展开
    
    
  • 老胡
    2021-07-23
    kubectl create -f jobmanager-job-deployment.yaml kubectl logs -f 发现异常 org.apache.flink.util.FlinkException: Could not find the provided job class (org.apache.flink.streaming.examples.windowing.TopSpeedWindowing) in the user lib directory (/opt/flink/usrlib).
    
    