DataSkewRuntimePass balances data distribution based on partition size. Compression reduces partition size, and I've noticed DataSkewRuntimePass conflicts with CompressionPass. (Program executes well, but it gives wrong result.) We need a fix on DataSkewRuntimePass.
DataSkewRuntimePass balances data distribution based on partition size. Compression reduces partition size, and I've noticed DataSkewRuntimePass conflicts with CompressionPass. (Program executes well, but it gives wrong result.) We need a fix on DataSkewRuntimePass.