flink-extended/dl-on-flink

Issues

• 运行Linear.java python报dl_on_flink_framework依赖不存在

  #764 opened a year ago by I-am-DJ
  0

• group id is too big - Error when building Java files from source.

  #760 opened 2 years ago by maurodlt
  2

• [Tensorflow On Flink] Batch train heartbeat failed

  #540 opened 2 years ago by wuchaochen
  0

• looks like property key REMOTE_CODE_ZIP_FILE("remote_code_zip_file") has no effect when training without input

  #744 opened 2 years ago by 1202zhyl
  2

• Add E2E examples and docs for iterative batch training with Flink source

  #728 opened 2 years ago by Sxnan
  0

• Unify Python Environment Configuration of DL on Flink and PyFlink

  #729 opened 3 years ago by Sxnan
  1

• TFUtils python API adapt to the new Java API

  #725 opened 3 years ago by Sxnan
  1

• Supports Flink iteration for batch training

  #713 opened 3 years ago by Sxnan
  1

• [Tensorflow On Flink]Tensorflow On Flink supports Flink 1.13 version

  #657 opened 3 years ago by geyydd
  1

• worker重启问题

  #720 opened 3 years ago by xdyun
  5

• Unstable unit test AppMasterServerTest#multiRegisterNode

  #699 opened 3 years ago by Sxnan
  0

• [Flink AI Flow] Kindly provide an example about real time feature engineering of window and global features

  #591 opened 3 years ago by LongxingTan
  3

• Quick start example run indefinitely on Tensorflow 2.3

  #706 opened 3 years ago by Sxnan
  0

• jar包下载不下来

  #701 opened 3 years ago by JaneFy
  5

• File system scheme 'queue' not implemented

  #696 opened 3 years ago by 1202zhyl
  2

• HTTP request sent, awaiting response... 403 Forbidden

  #655 opened 3 years ago by Curry30h
  2

• [Flink AI Flow] Pyflink job should support to upload jar packages

  #507 opened 3 years ago by wuchaochen
  1

• [Flink AI Flow] No state check before stopping a workflow execution

  #466 opened 3 years ago by bgeng777
  1

• [Notification Service] Support database version migration

  #660 opened 3 years ago by wuchaochen
  0

• [Notification Service] Support database related command line tools.

  #661 opened 3 years ago by wuchaochen
  0

• [Flink AI Flow] Support database upgrade and downgrade

  #541 opened 3 years ago by wuchaochen
  1

• [Airflow] CeleryExecutor throws error and stop updating task state.

  #644 opened 3 years ago by Sxnan
  1

• [Flink AI Flow] [Discussion Needed] Metadata client in Java cannot register workflow with ContextExtractor

  #487 opened 3 years ago by bgeng777
  1

• [AIFlow] AIFlow base docker image for deployment

  #440 opened 3 years ago by Sxnan
  0

• [AIFlow] Add job retry mechanism

  #442 opened 3 years ago by Sxnan
  0

• [AirFlow] 周期性作业恢复失败

  #627 opened 3 years ago by wuchaochen
  0

• 没有install_aiflow.sh这个文件

  #653 opened 3 years ago by Curry30h
  0

• Failed to execute goal org.apache.maven.plugins:maven-javadoc-plugin:2.9.1:jar (attach-javadocs) on project flink_ai_extended: Execution attach-javadocs of goal org.apache.maven.plugins:maven-javadoc-plugin:2.9.1:jar failed: Plugin org.apache.maven.plugins:maven-javadoc-plugin:2.9.1 or one of its dependencies could not be resolved: Could not transfer artifact org.apache.maven:maven-project:jar:2.2.1 from/to central

  #643 opened 3 years ago by Curry30h
  0

• [Flink AI Flow] Flink Job cannot be cancelled due to wrong flink command generation

  #539 opened 3 years ago by bgeng777
  0

• [Flink AI Flow]The wdl example cannot be run

  #632 opened 3 years ago by wuchaochen
  1

• [Flink AI Flow] Check webserver started gracefully

  #557 opened 3 years ago by jiangxin369
  0

• [Flink AI Flow] The state of dagrun is running even all tasks are finished

  #467 opened 3 years ago by jiangxin369
  0

• [Flink AI Flow] Remove existed apache-airflow failed in setup.py

  #471 opened 3 years ago by jiangxin369
  0

• [AIFlow] Add event condition and scheduling rule tracking

  #443 opened 3 years ago by Sxnan
  0

• [Airflow] Add helm chart to deploy AIFlow to kubernetes

  #444 opened 3 years ago by Sxnan
  0

• Performance issues in flink-ai-flow/ (by P3)

  #517 opened 3 years ago by DLPerf
  1

• Performance issues in flink-ai-flow/ai_flow/test/util/model_util/iris_data_utils.py(P2)

  #491 opened 3 years ago by DLPerf
  1

• [Flink AI Flow] Executor support CeleryExecutor

  #463 opened 3 years ago by aqua7regia
  1

• [Flink AI Flow][Plugins] Flink job plugin supports SQL run mode

  #462 opened 3 years ago by SteNicholas
  0

• [Flink AI Flow] Periodic config in workflow level does not work as expected

  #469 opened 3 years ago by bgeng777
  0

• [Flink AI Flow][Bug] When using FlinkPythonProcessor, not calling execution_context.statement_set.add_insert_sql will result in error, and missing job_id

  #475 opened 3 years ago by lisy09
  3

• Relationship or difference between Flink AI Extended vs Alink

  #521 opened 3 years ago by hongbo-miao
  1

• [Flink AI Flow] Flink Job Might Be Blocked in KILLING Status

  #536 opened 3 years ago by yunfengzhou-hub
  0

• [Flink AI Flow] Dagrun may not scheduled

  #547 opened 3 years ago by jiangxin369
  1

• [Flink AI Flow] CeleryExecutor may run task instance multiple times

  #544 opened 3 years ago by jiangxin369
  1

• [Flink AI Flow] EventBasedScheduler bug cause execute loop exited

  #543 opened 3 years ago by jiangxin369
  1

• 启动服务时报错

  #588 opened 3 years ago by Lesliexs
  2

• [Flink AI Flow] Duplicate key error when restart Airflow

  #545 opened 3 years ago by jiangxin369
  1

• [Notification Service] Sending event with HA client to non-HA server takes too much time

  #506 opened 3 years ago by jiangxin369
  1

• [Flink AI Flow][Bug][unit test] When running run_tests.sh, sometime grpc UNAVAILABLE happens

  #480 opened 3 years ago by lisy09
  1