flink web Jmeter 板作业提交挂起

6tr1vspr  于 2021-06-25  发布在  Flink
关注(0)|答案(0)|浏览(241)

我能够运行示例flink jobs&我的基本流计算。只是试图通过flink web dashboard运行一个相对复杂的iterativestream计算jar,它甚至一直挂着“show plan”。
看不到任何记录,以及任何建议如何调试这个。
我可以通过ide运行相同的程序,下面是计划可视化json->

{"nodes":
    [{"id":-1,"type":"IterationSource-2","pact":"Data Source","contents":"IterationSource-2","parallelism":1},
        {"id":1,"type":"Source: BOND_PRICING_CONFIG","pact":"Data Source","contents":"Source: BOND_PRICING_CONFIG","parallelism":1},
        {"id":3,"type":"Source: TW_CHAIN_DATA_SOURCE","pact":"Data Source","contents":"Source: TW_CHAIN_DATA_SOURCE","parallelism":1},
        {"id":4,"type":"Map","pact":"Operator","contents":"Map","parallelism":4,"predecessors":[{"id":3,"ship_strategy":"REBALANCE","side":"second"}
    ]},
    {"id":5,"type":"Filter","pact":"Operator","contents":"Filter","parallelism":4,"predecessors":[{"id":4,"ship_strategy":"FORWARD","side":"second"}]},
    {"id":6,"type":"TW_PRICING_FILTER","pact":"Operator","contents":"TW_PRICING_FILTER","parallelism":4,"predecessors":
        [{"id":1,"ship_strategy":"REBALANCE","side":"second"},{"id":-1,"ship_strategy":"REBALANCE","side":"second"}]},
        {"id":9,"type":"TW_PRICE_COPIER","pact":"Operator","contents":"TW_PRICE_COPIER","parallelism":4,"predecessors":
            [{"id":6,"ship_strategy":"HASH","side":"second"},{"id":5,"ship_strategy":"HASH","side":"second"}]},
            {"id":10,"type":"TW_PRICE_TO_YIELD","pact":"Operator","contents":"TW_PRICE_TO_YIELD","parallelism":4,"predecessors":
                [{"id":9,"ship_strategy":"FORWARD","side":"second"}]},
                {"id":12,"type":"TW_REDUCE_DUPLICATE","pact":"Operator","contents":"TW_REDUCE_DUPLICATE","parallelism":4,"predecessors":
                    [{"id":10,"ship_strategy":"HASH","side":"second"}]},
                    {"id":-2,"type":"IterationSink-2","pact":"Data Sink","contents":"IterationSink-2","parallelism":1,"predecessors":
                        [{"id":1,"ship_strategy":"FORWARD","side":"second"},{"id":-1,"ship_strategy":"FORWARD","side":"second"}]},
                        {"id":13,"type":"Sink: Unnamed","pact":"Data Sink","contents":"Sink: Unnamed","parallelism":4,"predecessors":
                            [{"id":12,"ship_strategy":"FORWARD","side":"second"}]}]}

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题