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

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 ##

[jira] [Commented] (FLINK-19727) Implement ParallelismProvider for sink in blink planner

[ https://issues.apache.org/jira/browse/FLINK-19727?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17220008#comment-17220008 ] Lsw_aka_laplace commented on FLINK-19727: - Hi [~lzljs3620320] I’m willing to doing this, shall

[jira] [Comment Edited] (FLINK-19778) Failed job reinitiated with wrong checkpoint after a ZK reconnection

[ https://issues.apache.org/jira/browse/FLINK-19778?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17219640#comment-17219640 ] Paul Lin edited comment on FLINK-19778 at 10/24/20, 3:20 AM: - [~kkl0u] Yes,

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

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

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

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

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

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

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

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

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

[jira] [Closed] (FLINK-19726) Implement new providers for blink planner

[ https://issues.apache.org/jira/browse/FLINK-19726?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-19726. Resolution: Fixed master (1.12): 8d7e323a30ec851d7a31cb6c2443d3929419 > Implement new

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

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

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

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

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.

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

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

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

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

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.

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

[jira] [Closed] (FLINK-19721) Speed up the frequency of checks in RpcGatewayRetriever

[ https://issues.apache.org/jira/browse/FLINK-19721?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-19721. - Fix Version/s: 1.12.0 Resolution: Fixed Fixed via

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

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…

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

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

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

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

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

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

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

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

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

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

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()

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.

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

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

[jira] [Updated] (FLINK-19791) PartitionRequestClientFactoryTest.testInterruptsNotCached fails with NullPointerException

[ https://issues.apache.org/jira/browse/FLINK-19791?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-19791: -- Fix Version/s: 1.12.0 > PartitionRequestClientFactoryTest.testInterruptsNotCached

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

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

[jira] [Updated] (FLINK-19791) PartitionRequestClientFactoryTest.testInterruptsNotCached fails with NullPointerException

[ https://issues.apache.org/jira/browse/FLINK-19791?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-19791: --- Labels: pull-request-available test-stability (was: test-stability) >

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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…

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

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

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

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.

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.

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.

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

[jira] [Updated] (FLINK-19793) KafkaTableITCase.testKafkaSourceSinkWithMetadata fails on AZP

[ https://issues.apache.org/jira/browse/FLINK-19793?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-19793: -- Description: The {{KafkaTableITCase.testKafkaSourceSinkWithMetadata}} seems to fail on AZP:

[jira] [Commented] (FLINK-19275) Allow to read and write metadata in Kafka table source/sink

[ https://issues.apache.org/jira/browse/FLINK-19275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17219763#comment-17219763 ] Till Rohrmann commented on FLINK-19275: --- I think this issue introduced an unstable test:

[jira] [Created] (FLINK-19793) KafkaTableITCase.testKafkaSourceSinkWithMetadata fails on AZP

Till Rohrmann created FLINK-19793: - Summary: KafkaTableITCase.testKafkaSourceSinkWithMetadata fails on AZP Key: FLINK-19793 URL: https://issues.apache.org/jira/browse/FLINK-19793 Project: Flink

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

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

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…

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

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()

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

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

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

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

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.

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

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

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()

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

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

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

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

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()

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

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.

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…

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

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

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

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

[jira] [Updated] (FLINK-19790) Writing MAP to Kafka with JSON format produces incorrect data.

[ https://issues.apache.org/jira/browse/FLINK-19790?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-19790: --- Labels: pull-request-available (was: ) > Writing MAP to Kafka with JSON format produces

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

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

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

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

[jira] [Created] (FLINK-19792) Interval join with equal time attributes is not recognized

Timo Walther created FLINK-19792: Summary: Interval join with equal time attributes is not recognized Key: FLINK-19792 URL: https://issues.apache.org/jira/browse/FLINK-19792 Project: Flink

[jira] [Updated] (FLINK-19717) SourceReaderBase.pollNext may return END_OF_INPUT if SplitReader.fetch throws

[ https://issues.apache.org/jira/browse/FLINK-19717?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-19717: --- Labels: pull-request-available (was: ) > SourceReaderBase.pollNext may return END_OF_INPUT

  1   2   3   4   5   6   >