diff --git a/pkg/exchange/binance/futures.go b/pkg/exchange/binance/futures.go
index f6bcd1301..3374a79d5 100644
--- a/pkg/exchange/binance/futures.go
+++ b/pkg/exchange/binance/futures.go
@@ -369,9 +369,10 @@ func (e *Exchange) queryFuturesDepth(ctx context.Context, symbol string) (snapsh
 // QueryFuturesIncomeHistory queries the income history on the binance futures account
 // This is more binance futures specific API, the convert function is not designed yet.
 // TODO: consider other futures platforms and design the common data structure for this
-func (e *Exchange) QueryFuturesIncomeHistory(ctx context.Context, symbol string, startTime, endTime time.Time) ([]binanceapi.FuturesIncome, error) {
+func (e *Exchange) QueryFuturesIncomeHistory(ctx context.Context, symbol string, incomeType binanceapi.FuturesIncomeType, startTime, endTime time.Time) ([]binanceapi.FuturesIncome, error) {
 	req := e.futuresClient2.NewFuturesGetIncomeHistoryRequest()
 	req.Symbol(symbol)
+	req.IncomeType(incomeType)
 	req.StartTime(startTime)
 	req.EndTime(endTime)
 	resp, err := req.Do(ctx)