小编Ana*_*ail的帖子

我有一个MySQL源，正在从中创建带有谓词下推条件的Glue动态框架，如下所示

datasource = glueContext.create_dynamic_frame_from_catalog(
    database = source_catalog_db, 
    table_name = source_catalog_tbl, 
    push_down_predicate = "id > 1531812324", 
    transformation_ctx = "datasource")

无论我在“ push_down_predicate”中添加什么条件，我总是会在“数据源”中获取所有记录。我想念什么？