[GitHub] [flink] flinkbot edited a comment on pull request #13697: [FLINK-19357][FLINK-19357][fs-connector] Introduce createBucketWriter to BucketsBuilder & Introduce FileLifeCycleListener to Buckets

2020-10-28 Thread GitBox
flinkbot edited a comment on pull request #13697: URL: https://github.com/apache/flink/pull/13697#issuecomment-712672697 ## CI report: * bd25177243a782fad2e7f9d9ff508e6ba3758303 Azure:

[jira] [Updated] (FLINK-19870) Fix special case when the reuse of exchange causes the deadlock

2020-10-28 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19870?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng updated FLINK-19870: Description: Currently the reuse of exchange is not considered to be a deadlock because although

[jira] [Created] (FLINK-19870) Fix special case when the reuse of exchange causes the deadlock

2020-10-28 Thread Caizhi Weng (Jira)
Caizhi Weng created FLINK-19870: --- Summary: Fix special case when the reuse of exchange causes the deadlock Key: FLINK-19870 URL: https://issues.apache.org/jira/browse/FLINK-19870 Project: Flink

[jira] [Created] (FLINK-19869) Support java.util.UUID as RAW type in PostgresCatalog and handle it in PostgresRowConverter

2020-10-28 Thread Jingwei Zhang (Jira)
Jingwei Zhang created FLINK-19869: - Summary: Support java.util.UUID as RAW type in PostgresCatalog and handle it in PostgresRowConverter Key: FLINK-19869 URL: https://issues.apache.org/jira/browse/FLINK-19869

[jira] [Updated] (FLINK-19867) Validation fails for UDF that accepts var-args

2020-10-28 Thread Rui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19867?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li updated FLINK-19867: --- Fix Version/s: 1.12.0 > Validation fails for UDF that accepts var-args >

[GitHub] [flink] flinkbot edited a comment on pull request #13641: [WIP][FLINK-17760][tests] Rework tests to not rely on legacy scheduling logics in ExecutionGraph anymore

2020-10-28 Thread GitBox
flinkbot edited a comment on pull request #13641: URL: https://github.com/apache/flink/pull/13641#issuecomment-708569491 ## CI report: * 09d8deb89416f53dfe8b5c16fb9d723cbd98612c UNKNOWN * 9ea4cf7454f9b8e0c237ba8f540b224abdf9f7b0 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13833: [FLINK-19867][table-common] Validation fails for UDF that accepts var…

2020-10-28 Thread GitBox
flinkbot edited a comment on pull request #13833: URL: https://github.com/apache/flink/pull/13833#issuecomment-718355139 ## CI report: * 4bec3f4f3950b243ef9f87f24ef481c5e73ceb17 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13641: [WIP][FLINK-17760][tests] Rework tests to not rely on legacy scheduling logics in ExecutionGraph anymore

2020-10-28 Thread GitBox
flinkbot edited a comment on pull request #13641: URL: https://github.com/apache/flink/pull/13641#issuecomment-708569491 ## CI report: * 09d8deb89416f53dfe8b5c16fb9d723cbd98612c UNKNOWN * 9ea4cf7454f9b8e0c237ba8f540b224abdf9f7b0 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13073: [FLINK-18820] SourceOperator should send MAX_WATERMARK to downstream operator when closed

2020-10-28 Thread GitBox
flinkbot edited a comment on pull request #13073: URL: https://github.com/apache/flink/pull/13073#issuecomment-669650373 ## CI report: * 406f3764484bb5b004988002f620bd20c0c34fd6 Azure:

[GitHub] [flink] wuchong merged pull request #13809: [Hotfix][json] Add serialVersionUID to JsonInputFormat class

2020-10-28 Thread GitBox
wuchong merged pull request #13809: URL: https://github.com/apache/flink/pull/13809 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to

[GitHub] [flink] flinkbot commented on pull request #13833: [FLINK-19867][table-common] Validation fails for UDF that accepts var…

2020-10-28 Thread GitBox
flinkbot commented on pull request #13833: URL: https://github.com/apache/flink/pull/13833#issuecomment-718355139 ## CI report: * 4bec3f4f3950b243ef9f87f24ef481c5e73ceb17 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] curcur edited a comment on pull request #13648: [FLINK-19632] Introduce a new ResultPartitionType for Approximate Local Recovery

2020-10-28 Thread GitBox
curcur edited a comment on pull request #13648: URL: https://github.com/apache/flink/pull/13648#issuecomment-718354004 Hey @tillrohrmann , thanks for bringing this up. We've nowhere explicitly explained why to bring a new ResultPartitionType, so I think here is a good place to discuss the

[GitHub] [flink] flinkbot edited a comment on pull request #13784: [FLINK-19698][connectors/common] API improvements to the Sources.

2020-10-28 Thread GitBox
flinkbot edited a comment on pull request #13784: URL: https://github.com/apache/flink/pull/13784#issuecomment-716153889 ## CI report: * f0dec4fa5d8e69761377a45df57106a4fbfe8152 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13763: [FLINK-19779][avro] Remove the record_ field name prefix for Confluen…

2020-10-28 Thread GitBox
flinkbot edited a comment on pull request #13763: URL: https://github.com/apache/flink/pull/13763#issuecomment-715195599 ## CI report: * 4c5a06b1ca2833fe7f63c25503660ed7acf9b77d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13685: [FLINK-19702][hive] Avoid using HiveConf::hiveSiteURL

2020-10-28 Thread GitBox
flinkbot edited a comment on pull request #13685: URL: https://github.com/apache/flink/pull/13685#issuecomment-711940021 ## CI report: * b49b477343603ef7568ec9c1de8c59807d85d232 Azure:

[GitHub] [flink] curcur edited a comment on pull request #13648: [FLINK-19632] Introduce a new ResultPartitionType for Approximate Local Recovery

2020-10-28 Thread GitBox
curcur edited a comment on pull request #13648: URL: https://github.com/apache/flink/pull/13648#issuecomment-718354004 Hey @tillrohrmann , thanks for bringing this up. We've nowhere explicitly explained why to bring a new ResultPartitionType, so I think here is a good place to discuss the

[GitHub] [flink] curcur commented on pull request #13648: [FLINK-19632] Introduce a new ResultPartitionType for Approximate Local Recovery

2020-10-28 Thread GitBox
curcur commented on pull request #13648: URL: https://github.com/apache/flink/pull/13648#issuecomment-718354004 Hey @tillrohrmann , thanks for bringing this up. We've nowhere explicitly explained why to bring a new ResultPartitionType, so I think here is a good place to discuss the

[GitHub] [flink] flinkbot edited a comment on pull request #13073: [FLINK-18820] SourceOperator should send MAX_WATERMARK to downstream operator when closed

2020-10-28 Thread GitBox
flinkbot edited a comment on pull request #13073: URL: https://github.com/apache/flink/pull/13073#issuecomment-669650373 ## CI report: * 406f3764484bb5b004988002f620bd20c0c34fd6 Azure:

[GitHub] [flink] JingsongLi commented on a change in pull request #13789: [FLINK-19727][table-runtime] Implement ParallelismProvider for sink i…

2020-10-28 Thread GitBox
JingsongLi commented on a change in pull request #13789: URL: https://github.com/apache/flink/pull/13789#discussion_r513954139 ## File path: flink-table/flink-table-common/src/main/java/org/apache/flink/table/connector/sink/OutputFormatProvider.java ## @@ -20,13 +20,15 @@

[jira] [Closed] (FLINK-19587) Error result when casting binary type as varchar

2020-10-28 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19587?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-19587. --- Resolution: Fixed > Error result when casting binary type as varchar >

[jira] [Comment Edited] (FLINK-19587) Error result when casting binary type as varchar

2020-10-28 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19587?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17221965#comment-17221965 ] Jark Wu edited comment on FLINK-19587 at 10/29/20, 4:22 AM: Fixed in: -

[GitHub] [flink] wuchong merged pull request #13826: [BP-1.11][FLINK-19587][table-planner-blink] Fix error result when casting binary as varchar

2020-10-28 Thread GitBox
wuchong merged pull request #13826: URL: https://github.com/apache/flink/pull/13826 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to

[GitHub] [flink] flinkbot edited a comment on pull request #13832: [FLINK-19822][table-planner] Remove redundant shuffle for streaming

2020-10-28 Thread GitBox
flinkbot edited a comment on pull request #13832: URL: https://github.com/apache/flink/pull/13832#issuecomment-718338774 ## CI report: * d32b02c2668093ff2745c4d124b11807f0b3f11c Azure:

[jira] [Updated] (FLINK-19868) Csv Serialization schema contains line delimiter

2020-10-28 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19868?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-19868: Fix Version/s: 1.12.0 > Csv Serialization schema contains line delimiter >

[jira] [Commented] (FLINK-19868) Csv Serialization schema contains line delimiter

2020-10-28 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19868?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17222700#comment-17222700 ] Jark Wu commented on FLINK-19868: - I think {{csv.line-delimiter}} is not a good option for csv format,

[GitHub] [flink] flinkbot edited a comment on pull request #13784: [FLINK-19698][connectors/common] API improvements to the Sources.

2020-10-28 Thread GitBox
flinkbot edited a comment on pull request #13784: URL: https://github.com/apache/flink/pull/13784#issuecomment-716153889 ## CI report: * f0dec4fa5d8e69761377a45df57106a4fbfe8152 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13763: [FLINK-19779][avro] Remove the record_ field name prefix for Confluen…

2020-10-28 Thread GitBox
flinkbot edited a comment on pull request #13763: URL: https://github.com/apache/flink/pull/13763#issuecomment-715195599 ## CI report: * 4c5a06b1ca2833fe7f63c25503660ed7acf9b77d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13685: [FLINK-19702][hive] Avoid using HiveConf::hiveSiteURL

2020-10-28 Thread GitBox
flinkbot edited a comment on pull request #13685: URL: https://github.com/apache/flink/pull/13685#issuecomment-711940021 ## CI report: * b49b477343603ef7568ec9c1de8c59807d85d232 Azure:

[jira] [Commented] (FLINK-19868) Csv Serialization schema contains line delimiter

2020-10-28 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19868?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17222697#comment-17222697 ] Jingsong Lee commented on FLINK-19868: -- Now the filesystem wants to reuse serialization schema, but

[GitHub] [flink] flinkbot commented on pull request #13833: [FLINK-19867][table-common] Validation fails for UDF that accepts var…

2020-10-28 Thread GitBox
flinkbot commented on pull request #13833: URL: https://github.com/apache/flink/pull/13833#issuecomment-718346736 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

[jira] [Updated] (FLINK-19868) Csv Serialization schema contains line delimiter

2020-10-28 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19868?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-19868: - Description: CsvRowSerializationSchema.serialize(Row.of("f0", "f1")) => f0,f1\n Csv

[jira] [Updated] (FLINK-19867) Validation fails for UDF that accepts var-args

2020-10-28 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19867?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-19867: --- Labels: pull-request-available (was: ) > Validation fails for UDF that accepts var-args >

[jira] [Created] (FLINK-19868) Csv Serialization schema contains line delimiter

2020-10-28 Thread Jingsong Lee (Jira)
Jingsong Lee created FLINK-19868: Summary: Csv Serialization schema contains line delimiter Key: FLINK-19868 URL: https://issues.apache.org/jira/browse/FLINK-19868 Project: Flink Issue Type:

[GitHub] [flink] lirui-apache opened a new pull request #13833: [FLINK-19867][table-common] Validation fails for UDF that accepts var…

2020-10-28 Thread GitBox
lirui-apache opened a new pull request #13833: URL: https://github.com/apache/flink/pull/13833 …-args ## What is the purpose of the change Fix the failure to extract eval method for functions with var-arg parameter. ## Brief change log - Check

[jira] [Created] (FLINK-19867) Validation fails for UDF that accepts var-args

2020-10-28 Thread Rui Li (Jira)
Rui Li created FLINK-19867: -- Summary: Validation fails for UDF that accepts var-args Key: FLINK-19867 URL: https://issues.apache.org/jira/browse/FLINK-19867 Project: Flink Issue Type: Bug

[GitHub] [flink] Sxnan commented on pull request #13073: [FLINK-18820] SourceOperator should send MAX_WATERMARK to downstream operator when closed

2020-10-28 Thread GitBox
Sxnan commented on pull request #13073: URL: https://github.com/apache/flink/pull/13073#issuecomment-718343253 I have made the change accordingly. @dawidwys Please have another look. This is an automated message from the

[jira] [Created] (FLINK-19866) FunctionsStateBootstrapOperator.createStateAccessor fails due to uninitialized runtimeContext

2020-10-28 Thread wang (Jira)
wang created FLINK-19866: Summary: FunctionsStateBootstrapOperator.createStateAccessor fails due to uninitialized runtimeContext Key: FLINK-19866 URL: https://issues.apache.org/jira/browse/FLINK-19866

[jira] [Commented] (FLINK-19768) The shell "./yarn-session.sh " not use log4j-session.properties , it use log4j.properties

2020-10-28 Thread YUJIANBO (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19768?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17222687#comment-17222687 ] YUJIANBO commented on FLINK-19768: -- Thanks a lot for your answer! I changed the log4j.properties

[GitHub] [flink] danny0405 commented on a change in pull request #13763: [FLINK-19779][avro] Remove the record_ field name prefix for Confluen…

2020-10-28 Thread GitBox
danny0405 commented on a change in pull request #13763: URL: https://github.com/apache/flink/pull/13763#discussion_r513927391 ## File path: flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/typeutils/AvroSchemaConverter.java ## @@ -297,17 +299,22 @@ private

[GitHub] [flink] danny0405 commented on a change in pull request #13763: [FLINK-19779][avro] Remove the record_ field name prefix for Confluen…

2020-10-28 Thread GitBox
danny0405 commented on a change in pull request #13763: URL: https://github.com/apache/flink/pull/13763#discussion_r513370899 ## File path: flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/typeutils/AvroSchemaConverter.java ## @@ -297,17 +299,22 @@ private

[GitHub] [flink] shuiqiangchen commented on a change in pull request #13803: [FLINK-19821][python] Add ProcessFunction and timer access for Python DataStream API.

2020-10-28 Thread GitBox
shuiqiangchen commented on a change in pull request #13803: URL: https://github.com/apache/flink/pull/13803#discussion_r513925523 ## File path: flink-end-to-end-tests/flink-python-test/python/datastream/data_stream_timer_job.py ## @@ -0,0 +1,89 @@

[jira] [Closed] (FLINK-19692) Can't restore feedback channel from savepoint

2020-10-28 Thread Tzu-Li (Gordon) Tai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19692?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-19692. --- Assignee: Igal Shilman Resolution: Fixed Fixed via - statefun/master:

[GitHub] [flink] flinkbot commented on pull request #13832: [FLINK-19822][table-planner] Remove redundant shuffle for streaming

2020-10-28 Thread GitBox
flinkbot commented on pull request #13832: URL: https://github.com/apache/flink/pull/13832#issuecomment-718338774 ## CI report: * d32b02c2668093ff2745c4d124b11807f0b3f11c UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #13831: [FLINK-19624][fix] Fix special case when the reuse of exchange causes the deadlock

2020-10-28 Thread GitBox
flinkbot edited a comment on pull request #13831: URL: https://github.com/apache/flink/pull/13831#issuecomment-718332223 ## CI report: * f7a377f9a04c5d630cb578ebc9040e936e6a60a4 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13830: [FLINK-14482][rocksdb] Bump FRocksDB verion to base on RocksDB-6.11.6

2020-10-28 Thread GitBox
flinkbot edited a comment on pull request #13830: URL: https://github.com/apache/flink/pull/13830#issuecomment-718331944 ## CI report: * e4cd22945ab2b3e7cb44c302e9db12231f52fdbc Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13803: [FLINK-19821][python] Add ProcessFunction and timer access for Python DataStream API.

2020-10-28 Thread GitBox
flinkbot edited a comment on pull request #13803: URL: https://github.com/apache/flink/pull/13803#issuecomment-717145782 ## CI report: * 2ab68a5e26b158ab43b128e0d0dbbc62cb8dea17 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13797: [FLINK-19465][runtime / statebackends] Add CheckpointStorage interface and wire through runtime

2020-10-28 Thread GitBox
flinkbot edited a comment on pull request #13797: URL: https://github.com/apache/flink/pull/13797#issuecomment-716854695 ## CI report: * c06b3dcd4eb4045f66352c8b65c14a7b60163ecd UNKNOWN * 185e46fd046c5f39a87ac3583ad559b065a275e1 UNKNOWN *

[GitHub] [flink] gaoyunhaii commented on a change in pull request #13697: [FLINK-19357][FLINK-19357][fs-connector] Introduce createBucketWriter to BucketsBuilder & Introduce FileLifeCycleListener to B

2020-10-28 Thread GitBox
gaoyunhaii commented on a change in pull request #13697: URL: https://github.com/apache/flink/pull/13697#discussion_r513921052 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/filesystem/FileLifeCycleListener.java ## @@ -0,0 +1,41

[GitHub] [flink] wangyang0918 commented on a change in pull request #13644: [FLINK-19542][k8s]Implement LeaderElectionService and LeaderRetrievalService based on Kubernetes API

2020-10-28 Thread GitBox
wangyang0918 commented on a change in pull request #13644: URL: https://github.com/apache/flink/pull/13644#discussion_r513920680 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/leaderelection/ZooKeeperLeaderElectionDriver.java ## @@ -0,0 +1,314 @@ +/* + *

[GitHub] [flink] flinkbot edited a comment on pull request #13744: [FLINK-19766][table-runtime] Introduce File streaming compaction operators

2020-10-28 Thread GitBox
flinkbot edited a comment on pull request #13744: URL: https://github.com/apache/flink/pull/13744#issuecomment-714369975 ## CI report: * a01ecf0bade9f8e4a56052fb5b5d25c5034fe511 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13605: [FLINK-19599][table] Introduce Filesystem format factories to integrate new FileSource to table

2020-10-28 Thread GitBox
flinkbot edited a comment on pull request #13605: URL: https://github.com/apache/flink/pull/13605#issuecomment-707521684 ## CI report: * a9df8a1384eb6306656b4fd952edd4be5d7a857d UNKNOWN * 96468e31f7614ef314c655f97a63fcabe83505a8 Azure:

[GitHub] [flink] dianfu commented on a change in pull request #13803: [FLINK-19821][python] Add ProcessFunction and timer access for Python DataStream API.

2020-10-28 Thread GitBox
dianfu commented on a change in pull request #13803: URL: https://github.com/apache/flink/pull/13803#discussion_r513882412 ## File path: flink-end-to-end-tests/flink-python-test/python/datastream/data_stream_timer_job.py ## @@ -0,0 +1,89 @@

[GitHub] [flink] flinkbot commented on pull request #13831: [FLINK-19624][fix] Fix special case when the reuse of exchange causes the deadlock

2020-10-28 Thread GitBox
flinkbot commented on pull request #13831: URL: https://github.com/apache/flink/pull/13831#issuecomment-718332223 ## CI report: * f7a377f9a04c5d630cb578ebc9040e936e6a60a4 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot commented on pull request #13830: [FLINK-14482][rocksdb] Bump FRocksDB verion to base on RocksDB-6.11.6

2020-10-28 Thread GitBox
flinkbot commented on pull request #13830: URL: https://github.com/apache/flink/pull/13830#issuecomment-718331944 ## CI report: * e4cd22945ab2b3e7cb44c302e9db12231f52fdbc UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #13803: [FLINK-19821][python] Add ProcessFunction and timer access for Python DataStream API.

2020-10-28 Thread GitBox
flinkbot edited a comment on pull request #13803: URL: https://github.com/apache/flink/pull/13803#issuecomment-717145782 ## CI report: * 2ab68a5e26b158ab43b128e0d0dbbc62cb8dea17 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13822: [FLINK-19856][network] Emit EndOfChannelRecoveryEvent

2020-10-28 Thread GitBox
flinkbot edited a comment on pull request #13822: URL: https://github.com/apache/flink/pull/13822#issuecomment-717894411 ## CI report: * 6e23ce525a7af28103e7abd8547b2ba6c9850567 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13744: [FLINK-19766][table-runtime] Introduce File streaming compaction operators

2020-10-28 Thread GitBox
flinkbot edited a comment on pull request #13744: URL: https://github.com/apache/flink/pull/13744#issuecomment-714369975 ## CI report: * a01ecf0bade9f8e4a56052fb5b5d25c5034fe511 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13605: [FLINK-19599][table] Introduce Filesystem format factories to integrate new FileSource to table

2020-10-28 Thread GitBox
flinkbot edited a comment on pull request #13605: URL: https://github.com/apache/flink/pull/13605#issuecomment-707521684 ## CI report: * a9df8a1384eb6306656b4fd952edd4be5d7a857d UNKNOWN * 96468e31f7614ef314c655f97a63fcabe83505a8 Azure:

[GitHub] [flink] wuchong commented on a change in pull request #13307: [FLINK-19078][table-runtime] Import rowtime join temporal operator

2020-10-28 Thread GitBox
wuchong commented on a change in pull request #13307: URL: https://github.com/apache/flink/pull/13307#discussion_r513890085 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/stream/StreamExecTemporalJoin.scala

[GitHub] [flink] flinkbot commented on pull request #13832: [FLINK-19822][table-planner] Remove redundant shuffle for streaming

2020-10-28 Thread GitBox
flinkbot commented on pull request #13832: URL: https://github.com/apache/flink/pull/13832#issuecomment-718329744 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

[GitHub] [flink] wangyang0918 commented on a change in pull request #13644: [FLINK-19542][k8s]Implement LeaderElectionService and LeaderRetrievalService based on Kubernetes API

2020-10-28 Thread GitBox
wangyang0918 commented on a change in pull request #13644: URL: https://github.com/apache/flink/pull/13644#discussion_r513904491 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/leaderelection/ZooKeeperLeaderElectionDriver.java ## @@ -0,0 +1,314 @@ +/* + *

[GitHub] [flink] wangyang0918 commented on a change in pull request #13644: [FLINK-19542][k8s]Implement LeaderElectionService and LeaderRetrievalService based on Kubernetes API

2020-10-28 Thread GitBox
wangyang0918 commented on a change in pull request #13644: URL: https://github.com/apache/flink/pull/13644#discussion_r513904491 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/leaderelection/ZooKeeperLeaderElectionDriver.java ## @@ -0,0 +1,314 @@ +/* + *

[jira] [Updated] (FLINK-19822) Remove redundant shuffle for streaming

2020-10-28 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19822?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-19822: --- Labels: pull-request-available (was: ) > Remove redundant shuffle for streaming >

[GitHub] [flink] godfreyhe opened a new pull request #13832: [FLINK-19822][table-planner] Remove redundant shuffle for streaming

2020-10-28 Thread GitBox
godfreyhe opened a new pull request #13832: URL: https://github.com/apache/flink/pull/13832 ## What is the purpose of the change *Shuffle is one of the most heavy operation, and many shuffle operations is redundant, because the input operators have provide the required

[GitHub] [flink] becketqin commented on a change in pull request #13784: [FLINK-19698][connectors/common] API improvements to the Sources.

2020-10-28 Thread GitBox
becketqin commented on a change in pull request #13784: URL: https://github.com/apache/flink/pull/13784#discussion_r513902647 ## File path: flink-core/src/main/java/org/apache/flink/util/ExceptionUtils.java ## @@ -565,6 +565,20 @@ else if (t instanceof Error) {

[jira] [Updated] (FLINK-19822) Remove redundant shuffle for streaming

2020-10-28 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19822?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-19822: --- Description: This is similar [FLINK-12575|https://issues.apache.org/jira/browse/FLINK-12575], we

[GitHub] [flink] flinkbot commented on pull request #13831: [FLINK-19624][fix] Fix special case when the reuse of exchange causes the deadlock

2020-10-28 Thread GitBox
flinkbot commented on pull request #13831: URL: https://github.com/apache/flink/pull/13831#issuecomment-718326098 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

[GitHub] [flink] TsReaper opened a new pull request #13831: [FLINK-19624][fix] Fix special case when the reuse of exchange causes the deadlock

2020-10-28 Thread GitBox
TsReaper opened a new pull request #13831: URL: https://github.com/apache/flink/pull/13831 ## What is the purpose of the change This PR fixes the special case when the reuse of exchange causes the deadlock. Currently the reuse of exchange is not considered to be a deadlock

[GitHub] [flink] flinkbot commented on pull request #13830: [FLINK-14482][rocksdb] Bump FRocksDB verion to base on RocksDB-6.11.6

2020-10-28 Thread GitBox
flinkbot commented on pull request #13830: URL: https://github.com/apache/flink/pull/13830#issuecomment-718324551 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

[jira] [Updated] (FLINK-14482) Bump up rocksdb version

2020-10-28 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14482?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14482: --- Labels: pull-request-available (was: ) > Bump up rocksdb version > ---

[GitHub] [flink] Myasuka opened a new pull request #13830: [FLINK-14482][rocksdb] Bump FRocksDB verion to base on RocksDB-6.11.6

2020-10-28 Thread GitBox
Myasuka opened a new pull request #13830: URL: https://github.com/apache/flink/pull/13830 ## What is the purpose of the change Bump FRocksDB version to base on RocksDB-6.11.6 ## Brief change log - Bump FRocksDB version to base on RocksDB-6.11.6 ##

[GitHub] [flink] JingsongLi commented on pull request #13789: [FLINK-19727][table-runtime] Implement ParallelismProvider for sink i…

2020-10-28 Thread GitBox
JingsongLi commented on pull request #13789: URL: https://github.com/apache/flink/pull/13789#issuecomment-718319057 Thanks for the update, I will take a look these two days. This is an automated message from the Apache Git

[GitHub] [flink] JingsongLi merged pull request #13620: [hotfix][doc] the first FSDataOutputStream should be FSDataInputStream in FileSystem#L178

2020-10-28 Thread GitBox
JingsongLi merged pull request #13620: URL: https://github.com/apache/flink/pull/13620 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go

[jira] [Updated] (FLINK-19861) Improve the document of now() function

2020-10-28 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19861?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-19861: Component/s: Table SQL / API > Improve the document of now() function >

[jira] [Updated] (FLINK-19861) Improve the document of now() function

2020-10-28 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19861?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-19861: Description: `NOW()` function is deterministic in SQL standard, but not deterministic in Flink SQL.  We

[GitHub] [flink] flinkbot edited a comment on pull request #13307: [FLINK-19078][table-runtime] Import rowtime join temporal operator

2020-10-28 Thread GitBox
flinkbot edited a comment on pull request #13307: URL: https://github.com/apache/flink/pull/13307#issuecomment-685763264 ## CI report: * f8a62099663b658669488af7f0ecd5087d1e5da6 Azure:

[GitHub] [flink] vthinkxie commented on a change in pull request #13458: FLINK-18851 [runtime] Add checkpoint type to checkpoint history entries in Web UI

2020-10-28 Thread GitBox
vthinkxie commented on a change in pull request #13458: URL: https://github.com/apache/flink/pull/13458#discussion_r513882504 ## File path: flink-runtime-web/web-dashboard/src/app/pages/job/checkpoints/detail/job-checkpoints-detail.component.ts ## @@ -55,21 +59,38 @@ export

[GitHub] [flink] vthinkxie commented on a change in pull request #13458: FLINK-18851 [runtime] Add checkpoint type to checkpoint history entries in Web UI

2020-10-28 Thread GitBox
vthinkxie commented on a change in pull request #13458: URL: https://github.com/apache/flink/pull/13458#discussion_r513882504 ## File path: flink-runtime-web/web-dashboard/src/app/pages/job/checkpoints/detail/job-checkpoints-detail.component.ts ## @@ -55,21 +59,38 @@ export

[jira] [Updated] (FLINK-19770) PythonProgramOptionsTest requires package phase before execution

2020-10-28 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19770?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-19770: Affects Version/s: (was: 1.11.2) 1.12.0 > PythonProgramOptionsTest requires

[jira] [Closed] (FLINK-19770) PythonProgramOptionsTest requires package phase before execution

2020-10-28 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19770?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-19770. --- Fix Version/s: (was: 1.11.3) Resolution: Fixed Merged to master via

[jira] [Assigned] (FLINK-19770) PythonProgramOptionsTest requires package phase before execution

2020-10-28 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19770?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-19770: --- Assignee: Shuiqiang Chen > PythonProgramOptionsTest requires package phase before execution >

[GitHub] [flink] dianfu closed pull request #13756: [FLINK-19770][python][test] Changed the PythonProgramOptionTest to be an ITCase.

2020-10-28 Thread GitBox
dianfu closed pull request #13756: URL: https://github.com/apache/flink/pull/13756 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to

[GitHub] [flink] flinkbot edited a comment on pull request #13822: [FLINK-19856][network] Emit EndOfChannelRecoveryEvent

2020-10-28 Thread GitBox
flinkbot edited a comment on pull request #13822: URL: https://github.com/apache/flink/pull/13822#issuecomment-717894411 ## CI report: * c121f8a279bb69448c326dab7cee19fd5bb2096c Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13307: [FLINK-19078][table-runtime] Import rowtime join temporal operator

2020-10-28 Thread GitBox
flinkbot edited a comment on pull request #13307: URL: https://github.com/apache/flink/pull/13307#issuecomment-685763264 ## CI report: * f8a62099663b658669488af7f0ecd5087d1e5da6 Azure:

[jira] [Updated] (FLINK-19865) YARN tests failed with "java.lang.NumberFormatException: For input string: "${env:MAX_LOG_FILE_NUMBER}" java.lang.NumberFormatException: For input string: "${env:MAX_LOG

2020-10-28 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19865?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-19865: Labels: test-stability (was: ) > YARN tests failed with "java.lang.NumberFormatException: For input

[jira] [Created] (FLINK-19865) YARN tests failed with "java.lang.NumberFormatException: For input string: "${env:MAX_LOG_FILE_NUMBER}" java.lang.NumberFormatException: For input string: "${env:MAX_LOG

2020-10-28 Thread Dian Fu (Jira)
Dian Fu created FLINK-19865: --- Summary: YARN tests failed with "java.lang.NumberFormatException: For input string: "${env:MAX_LOG_FILE_NUMBER}" java.lang.NumberFormatException: For input string: "${env:MAX_LOG_FILE_NUMBER}"" Key:

[jira] [Commented] (FLINK-19843) ParquetFsStreamingSinkITCase.testPart failed with "Trying to access closed classloader"

2020-10-28 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19843?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17222652#comment-17222652 ] Dian Fu commented on FLINK-19843: -

[jira] [Created] (FLINK-19864) TwoInputStreamTaskTest.testWatermarkMetrics failed with "expected:<1> but was:<-9223372036854775808>"

2020-10-28 Thread Dian Fu (Jira)
Dian Fu created FLINK-19864: --- Summary: TwoInputStreamTaskTest.testWatermarkMetrics failed with "expected:<1> but was:<-9223372036854775808>" Key: FLINK-19864 URL: https://issues.apache.org/jira/browse/FLINK-19864

[jira] [Updated] (FLINK-19864) TwoInputStreamTaskTest.testWatermarkMetrics failed with "expected:<1> but was:<-9223372036854775808>"

2020-10-28 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19864?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-19864: Labels: test-stability (was: ) > TwoInputStreamTaskTest.testWatermarkMetrics failed with "expected:<1>

[jira] [Created] (FLINK-19863) SQLClientHBaseITCase.testHBase failed with "java.io.IOException: Process failed due to timeout"

2020-10-28 Thread Dian Fu (Jira)
Dian Fu created FLINK-19863: --- Summary: SQLClientHBaseITCase.testHBase failed with "java.io.IOException: Process failed due to timeout" Key: FLINK-19863 URL: https://issues.apache.org/jira/browse/FLINK-19863

[jira] [Updated] (FLINK-19863) SQLClientHBaseITCase.testHBase failed with "java.io.IOException: Process failed due to timeout"

2020-10-28 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19863?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-19863: Labels: test-stability (was: ) > SQLClientHBaseITCase.testHBase failed with "java.io.IOException:

[GitHub] [flink] flinkbot edited a comment on pull request #13822: [FLINK-19856][network] Emit EndOfChannelRecoveryEvent

2020-10-28 Thread GitBox
flinkbot edited a comment on pull request #13822: URL: https://github.com/apache/flink/pull/13822#issuecomment-717894411 ## CI report: * cecfabd36b9192284b4671fbdf48eb933ffc79e5 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13822: [FLINK-19856][network] Emit EndOfChannelRecoveryEvent

2020-10-28 Thread GitBox
flinkbot edited a comment on pull request #13822: URL: https://github.com/apache/flink/pull/13822#issuecomment-717894411 ## CI report: * cecfabd36b9192284b4671fbdf48eb933ffc79e5 Azure:

[GitHub] [flink] zentol commented on pull request #13796: [FLINK-19810][CI] Automatically run a basic NOTICE file check on CI

2020-10-28 Thread GitBox
zentol commented on pull request #13796: URL: https://github.com/apache/flink/pull/13796#issuecomment-718289508 > One benefit would be, that our release process is less complicated Doesn't really apply imo because this can be easily automated. While the (build) process is more

[GitHub] [flink] SteNicholas commented on a change in pull request #13828: [FLINK-19835] Don't emit intermediate watermarks from sources in BATCH execution mode

2020-10-28 Thread GitBox
SteNicholas commented on a change in pull request #13828: URL: https://github.com/apache/flink/pull/13828#discussion_r513842239 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/SourceOperator.java ## @@ -254,4 +269,10 @@ private void

[GitHub] [flink] SteNicholas commented on a change in pull request #13828: [FLINK-19835] Don't emit intermediate watermarks from sources in BATCH execution mode

2020-10-28 Thread GitBox
SteNicholas commented on a change in pull request #13828: URL: https://github.com/apache/flink/pull/13828#discussion_r513842239 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/SourceOperator.java ## @@ -254,4 +269,10 @@ private void

[GitHub] [flink] flinkbot edited a comment on pull request #13829: [FLINK-19862][coordination] Check for null

2020-10-28 Thread GitBox
flinkbot edited a comment on pull request #13829: URL: https://github.com/apache/flink/pull/13829#issuecomment-718159576 ## CI report: * 3e7b304163f959489fe85aaffa43f664b65b65e5 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13770: [FLINK-18858][connector-kinesis] Add Kinesis sources and sinks

2020-10-28 Thread GitBox
flinkbot edited a comment on pull request #13770: URL: https://github.com/apache/flink/pull/13770#issuecomment-715323245 ## CI report: * c1af295630bc8064312d310846613a8a3b23bbca UNKNOWN * c195c6d2c594e176fdbc038ee9672a90dd10ef80 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13797: [FLINK-19465][runtime / statebackends] Add CheckpointStorage interface and wire through runtime

2020-10-28 Thread GitBox
flinkbot edited a comment on pull request #13797: URL: https://github.com/apache/flink/pull/13797#issuecomment-716854695 ## CI report: * c06b3dcd4eb4045f66352c8b65c14a7b60163ecd UNKNOWN * 185e46fd046c5f39a87ac3583ad559b065a275e1 UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on pull request #13825: [FLINK-19836] Add SimpleVersionedSerializerTypeSerializerProxy

2020-10-28 Thread GitBox
flinkbot edited a comment on pull request #13825: URL: https://github.com/apache/flink/pull/13825#issuecomment-717897004 ## CI report: * 07988460fce9311f7ee7857fede86ba78f5629e5 Azure:

  1   2   3   4   5   6   >