我能够运行示例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"}]}]}
暂无答案!
目前还没有任何答案,快来回答吧!