[GitHub] [flink] flinkbot edited a comment on pull request #13735: [FLINK-19533][checkpoint] Add channel state reassignment for unaligned checkpoints.

2020-10-24 Thread GitBox
flinkbot edited a comment on pull request #13735: URL: https://github.com/apache/flink/pull/13735#issuecomment-714048414 ## CI report: * 458aee4e1d6779beb640f563c7c9b5a65e645237 UNKNOWN * 5e5340241b5811243463f96dda7455b2869cf268 Azure:

[GitHub] [flink] RocMarshal commented on pull request #13750: [FLINK-19394][docs-zh] Translate the 'Monitoring Checkpointing' page of 'Debugging & Monitoring' into Chinese

2020-10-24 Thread GitBox
RocMarshal commented on pull request #13750: URL: https://github.com/apache/flink/pull/13750#issuecomment-715906722 Hi, @klion26 Could you help me to review this PR if you have free time? Thank you. This is an

[GitHub] [flink] flinkbot edited a comment on pull request #13735: [FLINK-19533][checkpoint] Add channel state reassignment for unaligned checkpoints.

2020-10-24 Thread GitBox
flinkbot edited a comment on pull request #13735: URL: https://github.com/apache/flink/pull/13735#issuecomment-714048414 ## CI report: * 458aee4e1d6779beb640f563c7c9b5a65e645237 UNKNOWN * 5e5340241b5811243463f96dda7455b2869cf268 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13688: [FLINK-19238] Arena block size sanity

2020-10-24 Thread GitBox
flinkbot edited a comment on pull request #13688: URL: https://github.com/apache/flink/pull/13688#issuecomment-712121175 ## CI report: * 728efeb026459830372935d684b1e189869f26cb UNKNOWN * 7cef297fd3cb1534ca3c33ecd66dc6e73c57380d UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on pull request #13735: [FLINK-19533][checkpoint] Add channel state reassignment for unaligned checkpoints.

2020-10-24 Thread GitBox
flinkbot edited a comment on pull request #13735: URL: https://github.com/apache/flink/pull/13735#issuecomment-714048414 ## CI report: * 458aee4e1d6779beb640f563c7c9b5a65e645237 UNKNOWN * 470d466cfe4455aefd5a302cedd92b57750f2c57 Azure:

[GitHub] [flink] anonymouscodeholic commented on a change in pull request #13688: [FLINK-19238] Arena block size sanity

2020-10-24 Thread GitBox
anonymouscodeholic commented on a change in pull request #13688: URL: https://github.com/apache/flink/pull/13688#discussion_r511387433 ## File path:

[GitHub] [flink] flinkbot edited a comment on pull request #13688: [FLINK-19238] Arena block size sanity

2020-10-24 Thread GitBox
flinkbot edited a comment on pull request #13688: URL: https://github.com/apache/flink/pull/13688#issuecomment-712121175 ## CI report: * 728efeb026459830372935d684b1e189869f26cb UNKNOWN * 7cef297fd3cb1534ca3c33ecd66dc6e73c57380d UNKNOWN *

[GitHub] [flink] tillrohrmann commented on pull request #13774: [BP-1.11][FLINK-19677][runtime] Make JobManager lazily resolve hostname of TaskManager and provide an option to turn off reverse resolut

2020-10-24 Thread GitBox
tillrohrmann commented on pull request #13774: URL: https://github.com/apache/flink/pull/13774#issuecomment-715888230 Manually merged via d251ce5ab43d89d3d09a3f09ecf9a33435e5d901 This is an automated message from the Apache

[GitHub] [flink] tillrohrmann closed pull request #13774: [BP-1.11][FLINK-19677][runtime] Make JobManager lazily resolve hostname of TaskManager and provide an option to turn off reverse resolution en

2020-10-24 Thread GitBox
tillrohrmann closed pull request #13774: URL: https://github.com/apache/flink/pull/13774 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

[GitHub] [flink] tillrohrmann closed pull request #13706: [FLINK-19677][runtime] Make JobManager lazily resolve hostname of TaskManager and provide an option to turn off reverse resolution entirely

2020-10-24 Thread GitBox
tillrohrmann closed pull request #13706: URL: https://github.com/apache/flink/pull/13706 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

[GitHub] [flink] flinkbot edited a comment on pull request #13771: [FLINK-19789][hive] Migrate Hive connector to new table source sink interface

2020-10-24 Thread GitBox
flinkbot edited a comment on pull request #13771: URL: https://github.com/apache/flink/pull/13771#issuecomment-715323930 ## CI report: * e5442954ffac19a92ba1f9a4620584e61acb601a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13767: [FLINK-19787][table-runtime] Migrate Filesystem connector to new table source sink interface

2020-10-24 Thread GitBox
flinkbot edited a comment on pull request #13767: URL: https://github.com/apache/flink/pull/13767#issuecomment-715256450 ## CI report: * 11330173d2fcaeead16e067e1f7d31c50081c2e1 UNKNOWN * c532d886b68b7dd265c9056945a3cfc94e8352b7 Azure:

[GitHub] [flink] leonardBang commented on a change in pull request #13721: [FLINK-19694][table] Support Upsert ChangelogMode for ScanTableSource

2020-10-23 Thread GitBox
leonardBang commented on a change in pull request #13721: URL: https://github.com/apache/flink/pull/13721#discussion_r511321199 ## File path: flink-table/flink-table-planner-blink/src/test/resources/org/apache/flink/table/planner/plan/stream/sql/join/SemiAntiJoinTest.xml ##

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

2020-10-23 Thread GitBox
wangyang0918 commented on a change in pull request #13644: URL: https://github.com/apache/flink/pull/13644#discussion_r511277348 ## File path: flink-kubernetes/src/main/java/org/apache/flink/kubernetes/kubeclient/resources/KubernetesLeaderElector.java ## @@ -0,0 +1,80 @@ +/*

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

2020-10-23 Thread GitBox
wangyang0918 commented on a change in pull request #13644: URL: https://github.com/apache/flink/pull/13644#discussion_r511276860 ## File path: flink-kubernetes/src/test/java/org/apache/flink/kubernetes/highavailability/KubernetesLeaderElectionServiceTest.java ## @@ -0,0

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

2020-10-23 Thread GitBox
wangyang0918 commented on a change in pull request #13644: URL: https://github.com/apache/flink/pull/13644#discussion_r511274908 ## File path: flink-kubernetes/src/test/java/org/apache/flink/kubernetes/kubeclient/Fabric8FlinkKubeClientTest.java ## @@ -249,4 +265,69 @@ public

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

2020-10-23 Thread GitBox
wangyang0918 commented on a change in pull request #13644: URL: https://github.com/apache/flink/pull/13644#discussion_r511272629 ## File path: flink-kubernetes/src/main/java/org/apache/flink/kubernetes/kubeclient/FlinkKubeClient.java ## @@ -104,6 +106,67 @@ KubernetesWatch

[GitHub] [flink] flinkbot edited a comment on pull request #13771: [FLINK-19789][hive] Migrate Hive connector to new table source sink interface

2020-10-23 Thread GitBox
flinkbot edited a comment on pull request #13771: URL: https://github.com/apache/flink/pull/13771#issuecomment-715323930 ## CI report: * 03bad16b2027912ba61be7bf02b97c5503fa3141 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13767: [FLINK-19787][table-runtime] Migrate Filesystem connector to new table source sink interface

2020-10-23 Thread GitBox
flinkbot edited a comment on pull request #13767: URL: https://github.com/apache/flink/pull/13767#issuecomment-715256450 ## CI report: * 11330173d2fcaeead16e067e1f7d31c50081c2e1 UNKNOWN * 7e5bf1cc81043553e2f6df80a6b6412634c80609 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13771: [FLINK-19789][hive] Migrate Hive connector to new table source sink interface

2020-10-23 Thread GitBox
flinkbot edited a comment on pull request #13771: URL: https://github.com/apache/flink/pull/13771#issuecomment-715323930 ## CI report: * 03bad16b2027912ba61be7bf02b97c5503fa3141 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13767: [FLINK-19787][table-runtime] Migrate Filesystem connector to new table source sink interface

2020-10-23 Thread GitBox
flinkbot edited a comment on pull request #13767: URL: https://github.com/apache/flink/pull/13767#issuecomment-715256450 ## CI report: * 11330173d2fcaeead16e067e1f7d31c50081c2e1 UNKNOWN * 7e5bf1cc81043553e2f6df80a6b6412634c80609 Azure:

[GitHub] [flink] JingsongLi merged pull request #13696: [FLINK-19726][table] Implement new providers for blink planner

2020-10-23 Thread GitBox
JingsongLi merged pull request #13696: URL: https://github.com/apache/flink/pull/13696 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

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

2020-10-23 Thread GitBox
gm7y8 removed a comment on pull request #13458: URL: https://github.com/apache/flink/pull/13458#issuecomment-715456178 This is an automated message from the Apache Git Service. To respond to the message, please log on to

[GitHub] [flink] flinkbot edited a comment on pull request #13778: [FLINK-19791][network][test] Connect to an opened port instead of 8080

2020-10-23 Thread GitBox
flinkbot edited a comment on pull request #13778: URL: https://github.com/apache/flink/pull/13778#issuecomment-715524844 ## CI report: * 69c2228581c8c6b288d9a6e05f43a8f3287b57f8 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13778: [FLINK-19791][network][test] Connect to an opened port instead of 8080

2020-10-23 Thread GitBox
flinkbot edited a comment on pull request #13778: URL: https://github.com/apache/flink/pull/13778#issuecomment-715524844 ## CI report: * 3881f36e07d498a9be32b0bd73c0838b8344dcb7 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13735: [FLINK-19533][checkpoint] Add channel state reassignment for unaligned checkpoints.

2020-10-23 Thread GitBox
flinkbot edited a comment on pull request #13735: URL: https://github.com/apache/flink/pull/13735#issuecomment-714048414 ## CI report: * 458aee4e1d6779beb640f563c7c9b5a65e645237 UNKNOWN * 470d466cfe4455aefd5a302cedd92b57750f2c57 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13331: [FLINK-19079][table-runtime] Import rowtime deduplicate operator

2020-10-23 Thread GitBox
flinkbot edited a comment on pull request #13331: URL: https://github.com/apache/flink/pull/13331#issuecomment-687585649 ## CI report: * 42f18261f80da589a648414d6bd81c20730e0cc0 Azure:

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

2020-10-23 Thread GitBox
gm7y8 commented on pull request #13458: URL: https://github.com/apache/flink/pull/13458#issuecomment-715584720 @XComp @vthinkxie I have addressed the requested changes. Build also has passed. This is an automated message

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

2020-10-23 Thread GitBox
flinkbot edited a comment on pull request #13458: URL: https://github.com/apache/flink/pull/13458#issuecomment-697041219 ## CI report: * 7311b0d12d19a645391ea0359a9aa6318806363b UNKNOWN * e18067714e5c3f75ed860f97f7c86ddedc719130 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13778: [FLINK-19791][network][test] Connect to an opened port instead of 8080

2020-10-23 Thread GitBox
flinkbot edited a comment on pull request #13778: URL: https://github.com/apache/flink/pull/13778#issuecomment-715524844 ## CI report: * 3881f36e07d498a9be32b0bd73c0838b8344dcb7 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13735: [FLINK-19533][checkpoint] Add channel state reassignment for unaligned checkpoints.

2020-10-23 Thread GitBox
flinkbot edited a comment on pull request #13735: URL: https://github.com/apache/flink/pull/13735#issuecomment-714048414 ## CI report: * 458aee4e1d6779beb640f563c7c9b5a65e645237 UNKNOWN * 6bfcf5914a2742ce41f05b2b77b70f7df85fc696 Azure:

[GitHub] [flink] tillrohrmann closed pull request #13711: [FLINK-19721] [flink-runtime] Support exponential backoff retries in RpcGatewayRetriever

2020-10-23 Thread GitBox
tillrohrmann closed pull request #13711: URL: https://github.com/apache/flink/pull/13711 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

[GitHub] [flink] flinkbot edited a comment on pull request #13777: [FLINK-19790][json] Clear reused ObjectNode's content for map convert…

2020-10-23 Thread GitBox
flinkbot edited a comment on pull request #13777: URL: https://github.com/apache/flink/pull/13777#issuecomment-715418264 ## CI report: * 3cba4e1aec8d8e46b202c61528ff405be22076c0 Azure:

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

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

[GitHub] [flink] flinkbot edited a comment on pull request #13776: [FLINK-19717][connectors/common] Fix spurious InputStatus.END_OF_INPUT from SourceReaderBase.pollNext caused by split reader exceptio

2020-10-23 Thread GitBox
flinkbot edited a comment on pull request #13776: URL: https://github.com/apache/flink/pull/13776#issuecomment-715417467 ## CI report: * 100b67ca171766bec1ff561a66688471b24745be Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13752: [FLINK-19508][DataStream] Add collect() operation on DataStream

2020-10-23 Thread GitBox
flinkbot edited a comment on pull request #13752: URL: https://github.com/apache/flink/pull/13752#issuecomment-714761274 ## CI report: * 9cc1022536ed63c253fb890ba55c631c7bdb9c54 Azure:

[GitHub] [flink] kl0u closed pull request #13666: [FLINK-19640] Add an IT case for bounded execution

2020-10-23 Thread GitBox
kl0u closed pull request #13666: URL: https://github.com/apache/flink/pull/13666 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 #13778: [FLINK-19791][network][test] Connect to an opened port instead of 8080

2020-10-23 Thread GitBox
flinkbot edited a comment on pull request #13778: URL: https://github.com/apache/flink/pull/13778#issuecomment-715524844 ## CI report: * 3881f36e07d498a9be32b0bd73c0838b8344dcb7 Azure:

[GitHub] [flink] rkhachatryan commented on a change in pull request #13778: [FLINK-19791][network][test] Connect to an opened port instead of 8080

2020-10-23 Thread GitBox
rkhachatryan commented on a change in pull request #13778: URL: https://github.com/apache/flink/pull/13778#discussion_r511085900 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/io/network/netty/PartitionRequestClientFactoryTest.java ## @@ -131,8 +129,6 @@

[GitHub] [flink] rkhachatryan commented on a change in pull request #13778: [FLINK-19791][network][test] Connect to an opened port instead of 8080

2020-10-23 Thread GitBox
rkhachatryan commented on a change in pull request #13778: URL: https://github.com/apache/flink/pull/13778#discussion_r511087179 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/io/network/netty/PartitionRequestClientFactoryTest.java ## @@ -61,15 +61,23 @@

[GitHub] [flink] rkhachatryan commented on a change in pull request #13778: [FLINK-19791][network][test] Connect to an opened port instead of 8080

2020-10-23 Thread GitBox
rkhachatryan commented on a change in pull request #13778: URL: https://github.com/apache/flink/pull/13778#discussion_r511085900 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/io/network/netty/PartitionRequestClientFactoryTest.java ## @@ -131,8 +129,6 @@

[GitHub] [flink] flinkbot commented on pull request #13778: [FLINK-19791][network][test] Connect to an opened port instead of 8080

2020-10-23 Thread GitBox
flinkbot commented on pull request #13778: URL: https://github.com/apache/flink/pull/13778#issuecomment-715524844 ## CI report: * 3881f36e07d498a9be32b0bd73c0838b8344dcb7 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #13774: [BP-1.11][FLINK-19677][runtime] Make JobManager lazily resolve hostname of TaskManager and provide an option to turn off reverse reso

2020-10-23 Thread GitBox
flinkbot edited a comment on pull request #13774: URL: https://github.com/apache/flink/pull/13774#issuecomment-715404737 ## CI report: * fccd2d27ffdc5eac35d7d2359eb23336e90ad308 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13775: [FLINK-19479][DataStream] Allow explicitly configuring time behaviour on KeyedStream.intervalJoin()

2020-10-23 Thread GitBox
flinkbot edited a comment on pull request #13775: URL: https://github.com/apache/flink/pull/13775#issuecomment-715405075 ## CI report: * 85cf8ada38ff8b98898ff1deb7e501a2d14bbd98 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13735: [FLINK-19533][checkpoint] Add channel state reassignment for unaligned checkpoints.

2020-10-23 Thread GitBox
flinkbot edited a comment on pull request #13735: URL: https://github.com/apache/flink/pull/13735#issuecomment-714048414 ## CI report: * 458aee4e1d6779beb640f563c7c9b5a65e645237 UNKNOWN * 6bfcf5914a2742ce41f05b2b77b70f7df85fc696 Azure:

[GitHub] [flink] AHeise commented on a change in pull request #13778: [FLINK-19791][network][test] Connect to an opened port instead of 8080

2020-10-23 Thread GitBox
AHeise commented on a change in pull request #13778: URL: https://github.com/apache/flink/pull/13778#discussion_r511081704 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/io/network/netty/PartitionRequestClientFactoryTest.java ## @@ -131,8 +129,6 @@ public

[GitHub] [flink] flinkbot commented on pull request #13778: [FLINK-19791][network][test] Connect to an opened port instead of 8080

2020-10-23 Thread GitBox
flinkbot commented on pull request #13778: URL: https://github.com/apache/flink/pull/13778#issuecomment-715506368 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] rkhachatryan opened a new pull request #13778: [FLINK-19791][network][test] Connect to an opened port instead of 8080

2020-10-23 Thread GitBox
rkhachatryan opened a new pull request #13778: URL: https://github.com/apache/flink/pull/13778 ## What is the purpose of the change A recently added `PartitionRequestClientFactoryTest.testInterruptsNotCached` fails if failure is detected before `NetworkClientHandler` was

[GitHub] [flink] flinkbot edited a comment on pull request #13755: [FLINK-19700][k8s] Make Kubernetes Client in KubernetesResourceManagerDriver use io executor

2020-10-23 Thread GitBox
flinkbot edited a comment on pull request #13755: URL: https://github.com/apache/flink/pull/13755#issuecomment-714883306 ## CI report: * 1eb20b18a9b1ae6275017a84427a12357cad5598 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13706: [FLINK-19677][runtime] Make JobManager lazily resolve hostname of TaskManager and provide an option to turn off reverse resolution en

2020-10-23 Thread GitBox
flinkbot edited a comment on pull request #13706: URL: https://github.com/apache/flink/pull/13706#issuecomment-712871607 ## CI report: * 2304d7b64aeca64f970492539913756f9a3bb5e1 UNKNOWN * f591d6ebb05a7bd0087bfc291a052027816f651b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13696: [FLINK-19726][table] Implement new providers for blink planner

2020-10-23 Thread GitBox
flinkbot edited a comment on pull request #13696: URL: https://github.com/apache/flink/pull/13696#issuecomment-712617122 ## CI report: * 20472025efad132d5d9daf4c6de047a728131bb4 Azure:

[GitHub] [flink] carp84 commented on a change in pull request #13688: [FLINK-19238] Arena block size sanity

2020-10-23 Thread GitBox
carp84 commented on a change in pull request #13688: URL: https://github.com/apache/flink/pull/13688#discussion_r511004271 ## File path: flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBOperationUtils.java ## @@

[GitHub] [flink] flinkbot edited a comment on pull request #13711: [FLINK-19721] [flink-runtime] Support exponential backoff retries in RpcGatewayRetriever

2020-10-23 Thread GitBox
flinkbot edited a comment on pull request #13711: URL: https://github.com/apache/flink/pull/13711#issuecomment-713051309 ## CI report: * aba275090e92c577fb19d98fb5019ee725421b62 Azure:

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

2020-10-23 Thread GitBox
flinkbot edited a comment on pull request #13458: URL: https://github.com/apache/flink/pull/13458#issuecomment-697041219 ## CI report: * 7311b0d12d19a645391ea0359a9aa6318806363b UNKNOWN * e18067714e5c3f75ed860f97f7c86ddedc719130 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13331: [FLINK-19079][table-runtime] Import rowtime deduplicate operator

2020-10-23 Thread GitBox
flinkbot edited a comment on pull request #13331: URL: https://github.com/apache/flink/pull/13331#issuecomment-687585649 ## CI report: * b4a2d274bd70b8006c267be02ee48ee5b9def3bb Azure:

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

2020-10-23 Thread GitBox
tillrohrmann commented on a change in pull request #13644: URL: https://github.com/apache/flink/pull/13644#discussion_r510988071 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/concurrent/FutureUtils.java ## @@ -137,8 +137,11 @@

[GitHub] [flink] flinkbot edited a comment on pull request #13761: [FLINK-19741] Allow AbstractStreamOperator to skip restoring timers if subclasses are using raw keyed state

2020-10-23 Thread GitBox
flinkbot edited a comment on pull request #13761: URL: https://github.com/apache/flink/pull/13761#issuecomment-715133167 ## CI report: * ebaacde136d9687728faa0bef1028fcbd5e46579 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13769: [FLINK-19278] Bump Scala Macros to 2.1.1

2020-10-23 Thread GitBox
flinkbot edited a comment on pull request #13769: URL: https://github.com/apache/flink/pull/13769#issuecomment-715322699 ## CI report: * f4939150f6361a6a4f703eacefcd9fa4170b8869 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13696: [FLINK-19726][table] Implement new providers for blink planner

2020-10-23 Thread GitBox
flinkbot edited a comment on pull request #13696: URL: https://github.com/apache/flink/pull/13696#issuecomment-712617122 ## CI report: * b008b76be939c752d322686889f73b48d08d9771 Azure:

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

2020-10-23 Thread GitBox
flinkbot edited a comment on pull request #13458: URL: https://github.com/apache/flink/pull/13458#issuecomment-697041219 ## CI report: * 7311b0d12d19a645391ea0359a9aa6318806363b UNKNOWN * e18067714e5c3f75ed860f97f7c86ddedc719130 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13331: [FLINK-19079][table-runtime] Import rowtime deduplicate operator

2020-10-23 Thread GitBox
flinkbot edited a comment on pull request #13331: URL: https://github.com/apache/flink/pull/13331#issuecomment-687585649 ## CI report: * b4a2d274bd70b8006c267be02ee48ee5b9def3bb Azure:

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

2020-10-23 Thread GitBox
gm7y8 edited a comment on pull request #13458: URL: https://github.com/apache/flink/pull/13458#issuecomment-715456178 @XComp For some reason its failing in the HBase module i retriggered the build This is an automated

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

2020-10-23 Thread GitBox
gm7y8 commented on pull request #13458: URL: https://github.com/apache/flink/pull/13458#issuecomment-715456178 @XComp For some reason its failing in the HBase repo i retriggered the build This is an automated message from

[GitHub] [flink] flinkbot edited a comment on pull request #13762: [backport-1.11] [FLINK-19741] Allow AbstractStreamOperator to skip restoring timers if subclasses are using raw keyed state

2020-10-23 Thread GitBox
flinkbot edited a comment on pull request #13762: URL: https://github.com/apache/flink/pull/13762#issuecomment-715194794 ## CI report: * 3b60303f653b80c759abb9de57d55c71d75b428d Azure:

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

2020-10-23 Thread GitBox
gm7y8 commented on pull request #13458: URL: https://github.com/apache/flink/pull/13458#issuecomment-715452694 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message, please

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

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

[GitHub] [flink] flinkbot edited a comment on pull request #13777: [FLINK-19790][json] Clear reused ObjectNode's content for map convert…

2020-10-23 Thread GitBox
flinkbot edited a comment on pull request #13777: URL: https://github.com/apache/flink/pull/13777#issuecomment-715418264 ## CI report: * 3cba4e1aec8d8e46b202c61528ff405be22076c0 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13776: [FLINK-19717][connectors/common] Fix spurious InputStatus.END_OF_INPUT from SourceReaderBase.pollNext caused by split reader exceptio

2020-10-23 Thread GitBox
flinkbot edited a comment on pull request #13776: URL: https://github.com/apache/flink/pull/13776#issuecomment-715417467 ## CI report: * 100b67ca171766bec1ff561a66688471b24745be Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13752: [FLINK-19508][DataStream] Add collect() operation on DataStream

2020-10-23 Thread GitBox
flinkbot edited a comment on pull request #13752: URL: https://github.com/apache/flink/pull/13752#issuecomment-714761274 ## CI report: * f621e5d663256a794e2bf416e197bd9ad605959d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13747: [FLINK-19662][runtime] Exposing the JobManager's memory configuration through /jobmanager/config

2020-10-23 Thread GitBox
flinkbot edited a comment on pull request #13747: URL: https://github.com/apache/flink/pull/13747#issuecomment-714516971 ## CI report: * 291650ee0b8802a168b227cd4749f58d14a256a3 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13735: [FLINK-19533][checkpoint] Add channel state reassignment for unaligned checkpoints.

2020-10-23 Thread GitBox
flinkbot edited a comment on pull request #13735: URL: https://github.com/apache/flink/pull/13735#issuecomment-714048414 ## CI report: * 458aee4e1d6779beb640f563c7c9b5a65e645237 UNKNOWN * 6bfcf5914a2742ce41f05b2b77b70f7df85fc696 Azure:

[GitHub] [flink] StephanEwen edited a comment on pull request #13574: [FLINK-18323] Add a Kafka source implementation based on FLIP-27.

2020-10-23 Thread GitBox
StephanEwen edited a comment on pull request #13574: URL: https://github.com/apache/flink/pull/13574#issuecomment-715423024 First of all, want to say nice work, this is a big piece after all!  The first thing that struck me is that I believe we need to rethink the Maven Module

[GitHub] [flink] StephanEwen commented on pull request #13574: [FLINK-18323] Add a Kafka source implementation based on FLIP-27.

2020-10-23 Thread GitBox
StephanEwen commented on pull request #13574: URL: https://github.com/apache/flink/pull/13574#issuecomment-715432448 A quick question in the closing behavior of the Kafka Enumerator. The code here is handling the closing in a separate thread, but blocks for a timeout. I am not sure if

[GitHub] [flink] StephanEwen commented on pull request #13574: [FLINK-18323] Add a Kafka source implementation based on FLIP-27.

2020-10-23 Thread GitBox
StephanEwen commented on pull request #13574: URL: https://github.com/apache/flink/pull/13574#issuecomment-715423024 We need to rethink the Maven Module setup here: The `flink-connector-base` is not Scala-versioned (has no Scala version suffix). Because of that it must not release

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

2020-10-23 Thread GitBox
tillrohrmann commented on a change in pull request #13644: URL: https://github.com/apache/flink/pull/13644#discussion_r510976264 ## File path: flink-kubernetes/src/main/java/org/apache/flink/kubernetes/kubeclient/FlinkKubeClient.java ## @@ -104,6 +106,67 @@ KubernetesWatch

[GitHub] [flink] flinkbot commented on pull request #13777: [FLINK-19790][json] Clear reused ObjectNode's content for map convert…

2020-10-23 Thread GitBox
flinkbot commented on pull request #13777: URL: https://github.com/apache/flink/pull/13777#issuecomment-715418264 ## CI report: * 3cba4e1aec8d8e46b202c61528ff405be22076c0 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot commented on pull request #13776: [FLINK-19717][connectors/common] Fix spurious InputStatus.END_OF_INPUT from SourceReaderBase.pollNext caused by split reader exception

2020-10-23 Thread GitBox
flinkbot commented on pull request #13776: URL: https://github.com/apache/flink/pull/13776#issuecomment-715417467 ## CI report: * 100b67ca171766bec1ff561a66688471b24745be UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #13775: [FLINK-19479][DataStream] Allow explicitly configuring time behaviour on KeyedStream.intervalJoin()

2020-10-23 Thread GitBox
flinkbot edited a comment on pull request #13775: URL: https://github.com/apache/flink/pull/13775#issuecomment-715405075 ## CI report: * 85cf8ada38ff8b98898ff1deb7e501a2d14bbd98 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13774: [BP-1.11][FLINK-19677][runtime] Make JobManager lazily resolve hostname of TaskManager and provide an option to turn off reverse reso

2020-10-23 Thread GitBox
flinkbot edited a comment on pull request #13774: URL: https://github.com/apache/flink/pull/13774#issuecomment-715404737 ## CI report: * fccd2d27ffdc5eac35d7d2359eb23336e90ad308 Azure:

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

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

[GitHub] [flink] flinkbot edited a comment on pull request #13752: [FLINK-19508][DataStream] Add collect() operation on DataStream

2020-10-23 Thread GitBox
flinkbot edited a comment on pull request #13752: URL: https://github.com/apache/flink/pull/13752#issuecomment-714761274 ## CI report: * f621e5d663256a794e2bf416e197bd9ad605959d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13761: [FLINK-19741] Allow AbstractStreamOperator to skip restoring timers if subclasses are using raw keyed state

2020-10-23 Thread GitBox
flinkbot edited a comment on pull request #13761: URL: https://github.com/apache/flink/pull/13761#issuecomment-715133167 ## CI report: * 8981564fa1732b78104ff3b9f3b52261011fb10b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13735: [FLINK-19533][checkpoint] Add channel state reassignment for unaligned checkpoints.

2020-10-23 Thread GitBox
flinkbot edited a comment on pull request #13735: URL: https://github.com/apache/flink/pull/13735#issuecomment-714048414 ## CI report: * 458aee4e1d6779beb640f563c7c9b5a65e645237 UNKNOWN * 1b1a34de33af36c301266d175cb72151b1bc51c4 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13644: [FLINK-19542][k8s]Implement LeaderElectionService and LeaderRetrievalService based on Kubernetes API

2020-10-23 Thread GitBox
flinkbot edited a comment on pull request #13644: URL: https://github.com/apache/flink/pull/13644#issuecomment-708933599 ## CI report: * e60cdbfeb10a33d4df62453679cd309fc39ee198 UNKNOWN * 5e2cfa21731b9fb5dd976cce821bfda78daa91b7 Azure:

[GitHub] [flink] tillrohrmann commented on a change in pull request #13747: [FLINK-19662][runtime] Exposing the JobManager's memory configuration through /jobmanager/config

2020-10-23 Thread GitBox
tillrohrmann commented on a change in pull request #13747: URL: https://github.com/apache/flink/pull/13747#discussion_r510950775 ## File path: flink-dist/src/main/flink-bin/bin/jobmanager.sh ## @@ -51,6 +51,10 @@ if [[ $STARTSTOP == "start" ]] || [[ $STARTSTOP ==

[GitHub] [flink] flinkbot commented on pull request #13775: [FLINK-19479][DataStream] Allow explicitly configuring time behaviour on KeyedStream.intervalJoin()

2020-10-23 Thread GitBox
flinkbot commented on pull request #13775: URL: https://github.com/apache/flink/pull/13775#issuecomment-715405075 ## CI report: * 85cf8ada38ff8b98898ff1deb7e501a2d14bbd98 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot commented on pull request #13774: [BP-1.11][FLINK-19677][runtime] Make JobManager lazily resolve hostname of TaskManager and provide an option to turn off reverse resolution

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

[GitHub] [flink] flinkbot edited a comment on pull request #13772: [FLINK-19748] Iterating key groups in raw keyed stream on restore fails if some key groups weren't written

2020-10-23 Thread GitBox
flinkbot edited a comment on pull request #13772: URL: https://github.com/apache/flink/pull/13772#issuecomment-715366899 ## CI report: * c6bae683ccd3cc80b9957f3316ca234acf0fbbab Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13762: [backport-1.11] [FLINK-19741] Allow AbstractStreamOperator to skip restoring timers if subclasses are using raw keyed state

2020-10-23 Thread GitBox
flinkbot edited a comment on pull request #13762: URL: https://github.com/apache/flink/pull/13762#issuecomment-715194794 ## CI report: * dd767d54953f6a38d2738f82a7bbcc67ae402b2f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13773: [backport-1.11] [FLINK-19748] Iterating key groups in raw keyed stream on restore fails if some key groups weren't written

2020-10-23 Thread GitBox
flinkbot edited a comment on pull request #13773: URL: https://github.com/apache/flink/pull/13773#issuecomment-715370664 ## CI report: * 86d9c5d8166af669754a8e8356a3cfced610c186 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13768: [FLINK-19777][table-runtime-blink] Fix NullPointException for WindowOperator.close()

2020-10-23 Thread GitBox
flinkbot edited a comment on pull request #13768: URL: https://github.com/apache/flink/pull/13768#issuecomment-715278427 ## CI report: * f9837e6e6e41f90365145eaa0142426aa714edb3 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13755: [FLINK-19700][k8s] Make Kubernetes Client in KubernetesResourceManagerDriver use io executor

2020-10-23 Thread GitBox
flinkbot edited a comment on pull request #13755: URL: https://github.com/apache/flink/pull/13755#issuecomment-714883306 ## CI report: * 6e6f684752fae0918f17c60a7e30b4140bef61a0 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13735: [FLINK-19533][checkpoint] Add channel state reassignment for unaligned checkpoints.

2020-10-23 Thread GitBox
flinkbot edited a comment on pull request #13735: URL: https://github.com/apache/flink/pull/13735#issuecomment-714048414 ## CI report: * 458aee4e1d6779beb640f563c7c9b5a65e645237 UNKNOWN * 1b1a34de33af36c301266d175cb72151b1bc51c4 Azure:

[GitHub] [flink] flinkbot commented on pull request #13777: [FLINK-19790][json] Clear reused ObjectNode's content for map convert…

2020-10-23 Thread GitBox
flinkbot commented on pull request #13777: URL: https://github.com/apache/flink/pull/13777#issuecomment-715403605 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] flinkbot edited a comment on pull request #13711: [FLINK-19721] [flink-runtime] Support exponential backoff retries in RpcGatewayRetriever

2020-10-23 Thread GitBox
flinkbot edited a comment on pull request #13711: URL: https://github.com/apache/flink/pull/13711#issuecomment-713051309 ## CI report: * c2976b53fc0f384b408bc49ae459bc3dc83afd10 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13706: [FLINK-19677][runtime] Make JobManager lazily resolve hostname of TaskManager and provide an option to turn off reverse resolution en

2020-10-23 Thread GitBox
flinkbot edited a comment on pull request #13706: URL: https://github.com/apache/flink/pull/13706#issuecomment-712871607 ## CI report: * 2304d7b64aeca64f970492539913756f9a3bb5e1 UNKNOWN * 18ddcc0a705c7554d18fa8faaf84279ff9cc52d1 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13696: [FLINK-19726][table] Implement new providers for blink planner

2020-10-23 Thread GitBox
flinkbot edited a comment on pull request #13696: URL: https://github.com/apache/flink/pull/13696#issuecomment-712617122 ## CI report: * 91ff192ecab44525f1e088777c52c815ea54b548 Azure:

[GitHub] [flink] libenchao opened a new pull request #13777: [FLINK-19790][json] Clear reused ObjectNode's content for map convert…

2020-10-23 Thread GitBox
libenchao opened a new pull request #13777: URL: https://github.com/apache/flink/pull/13777 …er in RowDataToJsonConverters ## What is the purpose of the change Fix JSON format serializing map type error. ## Brief change log * Clear reused ObjectNode's

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

2020-10-23 Thread GitBox
flinkbot edited a comment on pull request #13458: URL: https://github.com/apache/flink/pull/13458#issuecomment-697041219 ## CI report: * 7311b0d12d19a645391ea0359a9aa6318806363b UNKNOWN * e18067714e5c3f75ed860f97f7c86ddedc719130 Azure:

[GitHub] [flink] flinkbot commented on pull request #13776: [FLINK-19717][connectors/common] Fix spurious InputStatus.END_OF_INPUT from SourceReaderBase.pollNext caused by split reader exception

2020-10-23 Thread GitBox
flinkbot commented on pull request #13776: URL: https://github.com/apache/flink/pull/13776#issuecomment-715399198 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

  1   2   3   4   5   6   7   8   9   10   >