首页
学习
活动
专区
工具
TVP
发布
精选内容/技术社群/优惠产品,尽在小程序
立即前往

Flink整合Oozie Shell Action提交任务带Kerberos认证

集群具体情况是 CDH6.3.0+Flink1.8.1,整个数据平台全部组件都上了kerberos和ldap因为要过认证,所以任务提交方法我们选择统一Oozie提交任务,并且因为kerberos认证,还需要...oozie提交job,由于oozie没有天生支持Flink提交,所以只能选择oozie shell action 的方式提交job。...在Flink搭建好以后开始提交任务,用oozie shell提交: #!/bin/bash flink run -m yarn-cluster flinktest.jar 马上 Duang !.../bin/bash env -i /flink run -m yarn-cluster flinktest.jar shell action成功提交flink任务。...有全部任务公用一个认证的,有用CICD在容器每次提交的镜像中在flink-conf.yaml中修改为指定的Kerberos的 但是 我们不一样~~ 因为我们是oozie提交任务,有点头大,还好最后还是解决了

1.2K20
  • 您找到你想要的搜索结果了吗?
    是的
    没有找到

    Github Action 入门

    这篇文章是开源章节系列的一篇,讲解 Github Action,以及一些应用样例。...Github Action,是 GitHub 提供了一套 CI/CD 方案,本质就是在 GitHub 产生交互事件时( Push,Tag,Issue……),触发一些预定的脚本,脚本中可以对代码进行单元测试...,代码检查,静态编译等;并将报告输出到合适的地方(可以在PR中评论,直接在Diff中输出,或发送到分析面板),也可以基于一定的授权进行代码改写并提交到仓库。...在提交代码后,自动的进行代码语法检查,风格检查,静态分析,以及单元测试和集成测试;以保证准备合入主干的代码是完成可用的;通常情况下,会在合并请求时进行集成检测,如果集成失败则禁止合并入主干,要求提交着进行修改...Action 的推荐,可直接添加到配置文件内。

    1.2K60

    尝鲜Github Action

    我是先试着用 Github Action 来发布我的blog,然后想给 xresloader 的自动发布也改成 Github Action ,但是找了一圈发现没有合适的已有的Action,就自己写了一个...Action Action 的使用 Github Action 的实际执行单元是里面的一个个的 action ,如果不use其他的action的话,就是普通的跑个脚本,像这样: name: "find...Action 开发 当 商店里已有的Action 满足不了需求的时候,还可以自己开发action用。... 的上下文里,方便后续其他action使用。 对基于nodejs 的action,官方提供了一些 工具npm包 用于方便action,感觉还是停方便实用的。...Release的名字 release_url: Release的URL地址 release_tag_name: Release绑定的tag名字 release_commitish: Release的提交

    1.2K20

    Action接收参数

    (当然原理他还是通过request) 02 方法一 属性封装 直接在Action类中定义与url传入的参数相对应的变量,并设置上set方法,当此url代参数请求后,Action类中对应的变量也就得到了参数的值...03 方法二 表达式封装 创建若干参数形成的对象,Action中直接获取到对象,参数名为“对象名.属性名”对象名对应Action中的,也是需要设置上set方法因为它内部是用反射来获取的。...Action得到对象 ?...像下面提交后集合会有3个元素第一个也就是角标为0的没有值为空 ? ? 封装成Map 在中括号的地方自定义key即可 ? ?...但当你在浏览器提交的参数值与模板类的类型转化不了就会出错,并返回input 下面由于student类中定义的age是Integer类型,传入a这样的字符无法转为整型所以出错,返回input。

    1.6K20

    扫码

    添加站长 进交流群

    领取专属 10元无门槛券

    手把手带您无忧上云

    扫码加入开发者社群

    相关资讯

    热门标签

    活动推荐

      运营活动

      活动名称
      广告关闭
      领券