HyukjinKwon commented on a change in pull request #34323:
URL: https://github.com/apache/spark/pull/34323#discussion_r734239196
##
File path: python/pyspark/streaming/kinesis.py
##
@@ -14,17 +14,21 @@
# See the License for the specific language governing permissions and
#
HyukjinKwon commented on a change in pull request #34323:
URL: https://github.com/apache/spark/pull/34323#discussion_r734226805
##
File path: python/pyspark/streaming/kinesis.py
##
@@ -34,11 +38,22 @@ def utf8_decoder(s):
class KinesisUtils(object):
@staticmethod
-
HyukjinKwon commented on a change in pull request #34323:
URL: https://github.com/apache/spark/pull/34323#discussion_r734139380
##
File path: python/pyspark/streaming/kinesis.py
##
@@ -34,11 +38,22 @@ def utf8_decoder(s):
class KinesisUtils(object):
@staticmethod
-