[GitHub] [flink] flinkbot edited a comment on issue #11061: [FLINK-15782] [connectors/jdbc] JDBC sink DataStream API

flinkbot edited a comment on issue #11061: [FLINK-15782] [connectors/jdbc] JDBC sink DataStream API URL: https://github.com/apache/flink/pull/11061#issuecomment-584620778 ## CI report: * 06ba58a8738f28535d4858b5a5efc863cda620f9 Travis: [CANCELED](https://travis-ci.com/flink-ci/f

[jira] [Closed] (FLINK-15941) ConfluentSchemaRegistryCoder should not perform HTTP requests for all request

[ https://issues.apache.org/jira/browse/FLINK-15941?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-15941. Resolution: Fixed Implemented in 3cbee0afe2b59fa50b4f245bc3be1012dab6d101 > ConfluentSche

[GitHub] [flink] dawidwys commented on issue #11066: [FLINK-15941] [format-avro] RegistryAvroSerializationSchema registers schema on first message only

dawidwys commented on issue #11066: [FLINK-15941] [format-avro] RegistryAvroSerializationSchema registers schema on first message only URL: https://github.com/apache/flink/pull/11066#issuecomment-585075220 Thank you @swhelan091 for your contribution. Merged it into the master.

[GitHub] [flink] dawidwys merged pull request #11066: [FLINK-15941] [format-avro] RegistryAvroSerializationSchema registers schema on first message only

dawidwys merged pull request #11066: [FLINK-15941] [format-avro] RegistryAvroSerializationSchema registers schema on first message only URL: https://github.com/apache/flink/pull/11066 This is an automated message from the Ap

[jira] [Assigned] (FLINK-15982) 'Quickstarts Java nightly end-to-end test' is failed on travis

[ https://issues.apache.org/jira/browse/FLINK-15982?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-15982: -- Assignee: Robert Metzger > 'Quickstarts Java nightly end-to-end test' is failed on tr

[jira] [Commented] (FLINK-15982) 'Quickstarts Java nightly end-to-end test' is failed on travis

[ https://issues.apache.org/jira/browse/FLINK-15982?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17035112#comment-17035112 ] Robert Metzger commented on FLINK-15982: I ran into the issue as well. I believe

[jira] [Updated] (FLINK-15982) 'Quickstarts Java nightly end-to-end test' is failed on travis

[ https://issues.apache.org/jira/browse/FLINK-15982?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-15982: --- Affects Version/s: 1.11.0 > 'Quickstarts Java nightly end-to-end test' is failed on travis >

[GitHub] [flink] flinkbot edited a comment on issue #11066: [FLINK-15941] [format-avro] RegistryAvroSerializationSchema registers schema on first message only

flinkbot edited a comment on issue #11066: [FLINK-15941] [format-avro] RegistryAvroSerializationSchema registers schema on first message only URL: https://github.com/apache/flink/pull/11066#issuecomment-585041196 ## CI report: * 42576e72b45fb023ced6d80819d919ba6110c00c Travis: [

[jira] [Commented] (FLINK-15948) Resource will be wasted when the task manager memory is not a multiple of Yarn minimum allocation

[ https://issues.apache.org/jira/browse/FLINK-15948?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17035102#comment-17035102 ] Yang Wang commented on FLINK-15948: --- [~xintongsong] Thanks for your comments. It make

[jira] [Commented] (FLINK-16005) Propagate yarn.application.classpath from client to TaskManager Classpath

[ https://issues.apache.org/jira/browse/FLINK-16005?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17035101#comment-17035101 ] Yang Wang commented on FLINK-16005: --- I think this behavior is by design for Yarn. The

[GitHub] [flink] flinkbot edited a comment on issue #11065: [hotfix] Fix the wrong Javadoc of HadoopSecurityContext

flinkbot edited a comment on issue #11065: [hotfix] Fix the wrong Javadoc of HadoopSecurityContext URL: https://github.com/apache/flink/pull/11065#issuecomment-585019009 ## CI report: * 52cdf88abde4e96ae9b243989b8d57fd75525af9 Travis: [SUCCESS](https://travis-ci.com/flink-ci/fli

[jira] [Assigned] (FLINK-15988) Make JsonRowSerializationSchema's constructor private

[ https://issues.apache.org/jira/browse/FLINK-15988?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-15988: --- Assignee: Benchao Li > Make JsonRowSerializationSchema's constructor private > ---

[GitHub] [flink] flinkbot edited a comment on issue #11055: [FLINK-15990][table] Remove register source and sink in ConnectTableDescriptor

flinkbot edited a comment on issue #11055: [FLINK-15990][table] Remove register source and sink in ConnectTableDescriptor URL: https://github.com/apache/flink/pull/11055#issuecomment-584564020 ## CI report: * ff83531840d16c504cb18adc21e7e9a4271cf53f Travis: [FAILURE](https://tra

[jira] [Commented] (FLINK-15988) Make JsonRowSerializationSchema's constructor private

[ https://issues.apache.org/jira/browse/FLINK-15988?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17035096#comment-17035096 ] Jark Wu commented on FLINK-15988: - Sounds good to me. Assigned to you [~libenchao]. > M

[jira] [Updated] (FLINK-16013) List config option could not be parsed correctly

[ https://issues.apache.org/jira/browse/FLINK-16013?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang updated FLINK-16013: -- Description: Currently, if a config option is {{List}} type and written to a flink-conf.yaml, it coul

[jira] [Created] (FLINK-16013) List config option could not be parsed correctly

Yang Wang created FLINK-16013: - Summary: List config option could not be parsed correctly Key: FLINK-16013 URL: https://issues.apache.org/jira/browse/FLINK-16013 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-15988) Make JsonRowSerializationSchema's constructor private

[ https://issues.apache.org/jira/browse/FLINK-15988?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17035085#comment-17035085 ] Benchao Li commented on FLINK-15988: cc [~dwysakowicz] [~twalthr] [~jark] > Make Js

[GitHub] [flink] flinkbot edited a comment on issue #11066: [FLINK-15941] [format-avro] RegistryAvroSerializationSchema registers schema on first message only

flinkbot edited a comment on issue #11066: [FLINK-15941] [format-avro] RegistryAvroSerializationSchema registers schema on first message only URL: https://github.com/apache/flink/pull/11066#issuecomment-585041196 ## CI report: * 42576e72b45fb023ced6d80819d919ba6110c00c Travis: [

[GitHub] [flink] flinkbot edited a comment on issue #11063: [FLINK-15938][table-planner-blink] Enable state cleanup in background…

flinkbot edited a comment on issue #11063: [FLINK-15938][table-planner-blink] Enable state cleanup in background… URL: https://github.com/apache/flink/pull/11063#issuecomment-584684124 ## CI report: * 420d42f48e38d837462e6c0eec4acd5f3ce4d935 Travis: [SUCCESS](https://travis-ci.c

[GitHub] [flink] flinkbot edited a comment on issue #11060: [FLINK-15994][Table-planner-blink]Support byte array argument for FROM_BASE64 function

flinkbot edited a comment on issue #11060: [FLINK-15994][Table-planner-blink]Support byte array argument for FROM_BASE64 function URL: https://github.com/apache/flink/pull/11060#issuecomment-584620729 ## CI report: * e919c3a4c8d702ad6583c004b62bed7df782ccb6 Travis: [SUCCESS](ht

[GitHub] [flink] flinkbot edited a comment on issue #10745: [FLINK-15445][connectors/jdbc] JDBC Table Source didn't work for Type…

flinkbot edited a comment on issue #10745: [FLINK-15445][connectors/jdbc] JDBC Table Source didn't work for Type… URL: https://github.com/apache/flink/pull/10745#issuecomment-570165880 ## CI report: * 862f3c5fd9e77184af08aea1231cf3a00e03b193 Travis: [CANCELED](https://travis-ci.

[jira] [Updated] (FLINK-16012) Reduce the default number of exclusive buffers from 2 to 1 on receiver side

[ https://issues.apache.org/jira/browse/FLINK-16012?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhijiang updated FLINK-16012: - Fix Version/s: 1.11.0 > Reduce the default number of exclusive buffers from 2 to 1 on receiver side > --

[jira] [Assigned] (FLINK-16012) Reduce the default number of exclusive buffers from 2 to 1 on receiver side

[ https://issues.apache.org/jira/browse/FLINK-16012?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhijiang reassigned FLINK-16012: Assignee: Yingjie Cao > Reduce the default number of exclusive buffers from 2 to 1 on receiver si

[jira] [Created] (FLINK-16012) Reduce the default number of exclusive buffers from 2 to 1 on receiver side

zhijiang created FLINK-16012: Summary: Reduce the default number of exclusive buffers from 2 to 1 on receiver side Key: FLINK-16012 URL: https://issues.apache.org/jira/browse/FLINK-16012 Project: Flink

[GitHub] [flink] flinkbot commented on issue #11066: [FLINK-15941] [format-avro] RegistryAvroSerializationSchema registers schema on first message only

flinkbot commented on issue #11066: [FLINK-15941] [format-avro] RegistryAvroSerializationSchema registers schema on first message only URL: https://github.com/apache/flink/pull/11066#issuecomment-585041196 ## CI report: * 42576e72b45fb023ced6d80819d919ba6110c00c UNKNOWN

[GitHub] [flink] flinkbot edited a comment on issue #11065: [hotfix] Fix the wrong Javadoc of HadoopSecurityContext

flinkbot edited a comment on issue #11065: [hotfix] Fix the wrong Javadoc of HadoopSecurityContext URL: https://github.com/apache/flink/pull/11065#issuecomment-585019009 ## CI report: * 52cdf88abde4e96ae9b243989b8d57fd75525af9 Travis: [PENDING](https://travis-ci.com/flink-ci/fli

[GitHub] [flink] flinkbot edited a comment on issue #11060: [FLINK-15994][Table-planner-blink]Support byte array argument for FROM_BASE64 function

flinkbot edited a comment on issue #11060: [FLINK-15994][Table-planner-blink]Support byte array argument for FROM_BASE64 function URL: https://github.com/apache/flink/pull/11060#issuecomment-584620729 ## CI report: * e919c3a4c8d702ad6583c004b62bed7df782ccb6 Travis: [SUCCESS](ht

[GitHub] [flink] flinkbot edited a comment on issue #10745: [FLINK-15445][connectors/jdbc] JDBC Table Source didn't work for Type…

flinkbot edited a comment on issue #10745: [FLINK-15445][connectors/jdbc] JDBC Table Source didn't work for Type… URL: https://github.com/apache/flink/pull/10745#issuecomment-570165880 ## CI report: * 862f3c5fd9e77184af08aea1231cf3a00e03b193 Travis: [CANCELED](https://travis-ci.

[GitHub] [flink] flinkbot edited a comment on issue #10151: [FLINK-14231] Handle the pending processing-time timers to make endInput semantics on the operator chain strict

flinkbot edited a comment on issue #10151: [FLINK-14231] Handle the pending processing-time timers to make endInput semantics on the operator chain strict URL: https://github.com/apache/flink/pull/10151#issuecomment-552442468 ## CI report: * c6d7f5e864076448dca590035a6a590dc5e25c

[GitHub] [flink] flinkbot edited a comment on issue #11055: [FLINK-15990][table] Remove register source and sink in ConnectTableDescriptor

flinkbot edited a comment on issue #11055: [FLINK-15990][table] Remove register source and sink in ConnectTableDescriptor URL: https://github.com/apache/flink/pull/11055#issuecomment-584564020 ## CI report: * ff83531840d16c504cb18adc21e7e9a4271cf53f Travis: [FAILURE](https://tra

[GitHub] [flink] flinkbot commented on issue #11066: [FLINK-15941] [format-avro] RegistryAvroSerializationSchema registers schema on first message only

flinkbot commented on issue #11066: [FLINK-15941] [format-avro] RegistryAvroSerializationSchema registers schema on first message only URL: https://github.com/apache/flink/pull/11066#issuecomment-585033022 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I

[jira] [Updated] (FLINK-15941) ConfluentSchemaRegistryCoder should not perform HTTP requests for all request

[ https://issues.apache.org/jira/browse/FLINK-15941?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-15941: --- Labels: pull-request-available (was: ) > ConfluentSchemaRegistryCoder should not perform HT

[GitHub] [flink] swhelan091 opened a new pull request #11066: [FLINK-15941] [format-avro] RegistryAvroSerializationSchema registers schema on first message only

swhelan091 opened a new pull request #11066: [FLINK-15941] [format-avro] RegistryAvroSerializationSchema registers schema on first message only URL: https://github.com/apache/flink/pull/11066 ## What is the purpose of the change This pull request improves the RegistryAvroSerializat

[jira] [Commented] (FLINK-15981) Control the direct memory in FileChannelBoundedData.FileBufferReader

[ https://issues.apache.org/jira/browse/FLINK-15981?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17035052#comment-17035052 ] zhijiang commented on FLINK-15981: -- [~sewen] You really proposed some good and critical

[GitHub] [flink] flinkbot edited a comment on issue #10151: [FLINK-14231] Handle the pending processing-time timers to make endInput semantics on the operator chain strict

flinkbot edited a comment on issue #10151: [FLINK-14231] Handle the pending processing-time timers to make endInput semantics on the operator chain strict URL: https://github.com/apache/flink/pull/10151#issuecomment-552442468 ## CI report: * c6d7f5e864076448dca590035a6a590dc5e25c

[GitHub] [flink] flinkbot edited a comment on issue #11063: [FLINK-15938][table-planner-blink] Enable state cleanup in background…

flinkbot edited a comment on issue #11063: [FLINK-15938][table-planner-blink] Enable state cleanup in background… URL: https://github.com/apache/flink/pull/11063#issuecomment-584684124 ## CI report: * 420d42f48e38d837462e6c0eec4acd5f3ce4d935 Travis: [SUCCESS](https://travis-ci.c

[GitHub] [flink] flinkbot edited a comment on issue #11065: [hotfix] Fix the wrong Javadoc of HadoopSecurityContext

flinkbot edited a comment on issue #11065: [hotfix] Fix the wrong Javadoc of HadoopSecurityContext URL: https://github.com/apache/flink/pull/11065#issuecomment-585019009 ## CI report: * 52cdf88abde4e96ae9b243989b8d57fd75525af9 Travis: [PENDING](https://travis-ci.com/flink-ci/fli

[GitHub] [flink] flinkbot edited a comment on issue #11064: [FLINK-15992][table] Fix classloader when finding TableFactory

flinkbot edited a comment on issue #11064: [FLINK-15992][table] Fix classloader when finding TableFactory URL: https://github.com/apache/flink/pull/11064#issuecomment-584988879 ## CI report: * d803ebfd0ed066087c5330d88b9412c060740059 Travis: [SUCCESS](https://travis-ci.com/flink

[GitHub] [flink] flinkbot edited a comment on issue #11055: [FLINK-15990][table] Remove register source and sink in ConnectTableDescriptor

flinkbot edited a comment on issue #11055: [FLINK-15990][table] Remove register source and sink in ConnectTableDescriptor URL: https://github.com/apache/flink/pull/11055#issuecomment-584564020 ## CI report: * ff83531840d16c504cb18adc21e7e9a4271cf53f Travis: [FAILURE](https://tra

[GitHub] [flink] flinkbot edited a comment on issue #11054: [FLINK-15652][K8s] Support for imagePullSecrets K8s option.

flinkbot edited a comment on issue #11054: [FLINK-15652][K8s] Support for imagePullSecrets K8s option. URL: https://github.com/apache/flink/pull/11054#issuecomment-584462322 ## CI report: * 47f64cd0ddbb74874daff1607a30a999f4554ce1 Travis: [FAILURE](https://travis-ci.com/flink-ci

[GitHub] [flink] flinkbot edited a comment on issue #11060: [FLINK-15994][Table-planner-blink]Support byte array argument for FROM_BASE64 function

flinkbot edited a comment on issue #11060: [FLINK-15994][Table-planner-blink]Support byte array argument for FROM_BASE64 function URL: https://github.com/apache/flink/pull/11060#issuecomment-584620729 ## CI report: * e919c3a4c8d702ad6583c004b62bed7df782ccb6 Travis: [SUCCESS](ht

[GitHub] [flink] flinkbot edited a comment on issue #10883: [FLINK-15629][runtime] Remove LegacyScheduler class and the consequently unused codes

flinkbot edited a comment on issue #10883: [FLINK-15629][runtime] Remove LegacyScheduler class and the consequently unused codes URL: https://github.com/apache/flink/pull/10883#issuecomment-575556059 ## CI report: * 7b96f07104a110c1d1b0aafbc0427c45b38f14d8 Travis: [FAILURE](http

[GitHub] [flink] flinkbot edited a comment on issue #10745: [FLINK-15445][connectors/jdbc] JDBC Table Source didn't work for Type…

flinkbot edited a comment on issue #10745: [FLINK-15445][connectors/jdbc] JDBC Table Source didn't work for Type… URL: https://github.com/apache/flink/pull/10745#issuecomment-570165880 ## CI report: * 862f3c5fd9e77184af08aea1231cf3a00e03b193 Travis: [CANCELED](https://travis-ci.

[GitHub] [flink] flinkbot edited a comment on issue #11063: [FLINK-15938][table-planner-blink] Enable state cleanup in background…

flinkbot edited a comment on issue #11063: [FLINK-15938][table-planner-blink] Enable state cleanup in background… URL: https://github.com/apache/flink/pull/11063#issuecomment-584684124 ## CI report: * 420d42f48e38d837462e6c0eec4acd5f3ce4d935 Travis: [SUCCESS](https://travis-ci.c

[GitHub] [flink] flinkbot commented on issue #11065: [hotfix] Fix the wrong Javadoc of HadoopSecurityContext

flinkbot commented on issue #11065: [hotfix] Fix the wrong Javadoc of HadoopSecurityContext URL: https://github.com/apache/flink/pull/11065#issuecomment-585019009 ## CI report: * 52cdf88abde4e96ae9b243989b8d57fd75525af9 UNKNOWN Bot commands The @flinkbot bot suppo

[GitHub] [flink] flinkbot edited a comment on issue #11060: [FLINK-15994][Table-planner-blink]Support byte array argument for FROM_BASE64 function

flinkbot edited a comment on issue #11060: [FLINK-15994][Table-planner-blink]Support byte array argument for FROM_BASE64 function URL: https://github.com/apache/flink/pull/11060#issuecomment-584620729 ## CI report: * e919c3a4c8d702ad6583c004b62bed7df782ccb6 Travis: [SUCCESS](ht

[GitHub] [flink] zhengcanbin commented on a change in pull request #11054: [FLINK-15652][K8s] Support for imagePullSecrets K8s option.

zhengcanbin commented on a change in pull request #11054: [FLINK-15652][K8s] Support for imagePullSecrets K8s option. URL: https://github.com/apache/flink/pull/11054#discussion_r378032034 ## File path: flink-kubernetes/src/main/java/org/apache/flink/kubernetes/utils/KubernetesUtils

[GitHub] [flink-docker] carp84 commented on issue #6: [FLINK-15978] Add GPG key and Dockerfiles for 1.10.0 release

carp84 commented on issue #6: [FLINK-15978] Add GPG key and Dockerfiles for 1.10.0 release URL: https://github.com/apache/flink-docker/pull/6#issuecomment-585018565 Checked and confirmed the 1.10 binaries have been synced to all close mirrors on my site, and I've successfully built an imag

[GitHub] [flink] flinkbot edited a comment on issue #11010: [FLINK-15836][k8s] Start a new pods watcher in KubernetesResourceManager when the old one is closed with exception

flinkbot edited a comment on issue #11010: [FLINK-15836][k8s] Start a new pods watcher in KubernetesResourceManager when the old one is closed with exception URL: https://github.com/apache/flink/pull/11010#issuecomment-581769412 ## CI report: * e6722c5f11f17384bc94de89095c46d605

[GitHub] [flink] flinkbot edited a comment on issue #10899: [FLINK-15668][tests] Remove travis test stages for legacy scheduler

flinkbot edited a comment on issue #10899: [FLINK-15668][tests] Remove travis test stages for legacy scheduler URL: https://github.com/apache/flink/pull/10899#issuecomment-575987886 ## CI report: * edb45d1c1b293737afe771c4055ea5f83b8c5cf3 Travis: [SUCCESS](https://travis-ci.com/

[GitHub] [flink] docete commented on issue #11055: [FLINK-15990][table] Remove register source and sink in ConnectTableDescriptor

docete commented on issue #11055: [FLINK-15990][table] Remove register source and sink in ConnectTableDescriptor URL: https://github.com/apache/flink/pull/11055#issuecomment-585013817 Also remove Registration#createTableSource and Registration#createTableSink ?

[GitHub] [flink] flinkbot edited a comment on issue #10745: [FLINK-15445][connectors/jdbc] JDBC Table Source didn't work for Type…

flinkbot edited a comment on issue #10745: [FLINK-15445][connectors/jdbc] JDBC Table Source didn't work for Type… URL: https://github.com/apache/flink/pull/10745#issuecomment-570165880 ## CI report: * 862f3c5fd9e77184af08aea1231cf3a00e03b193 Travis: [CANCELED](https://travis-ci.

[GitHub] [flink] libenchao commented on a change in pull request #11063: [FLINK-15938][table-planner-blink] Enable state cleanup in background…

libenchao commented on a change in pull request #11063: [FLINK-15938][table-planner-blink] Enable state cleanup in background… URL: https://github.com/apache/flink/pull/11063#discussion_r378026483 ## File path: flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/ta

[GitHub] [flink] flinkbot edited a comment on issue #10151: [FLINK-14231] Handle the pending processing-time timers to make endInput semantics on the operator chain strict

flinkbot edited a comment on issue #10151: [FLINK-14231] Handle the pending processing-time timers to make endInput semantics on the operator chain strict URL: https://github.com/apache/flink/pull/10151#issuecomment-552442468 ## CI report: * c6d7f5e864076448dca590035a6a590dc5e25c

[GitHub] [flink] flinkbot edited a comment on issue #11055: [FLINK-15990][table] Remove register source and sink in ConnectTableDescriptor

flinkbot edited a comment on issue #11055: [FLINK-15990][table] Remove register source and sink in ConnectTableDescriptor URL: https://github.com/apache/flink/pull/11055#issuecomment-584564020 ## CI report: * ff83531840d16c504cb18adc21e7e9a4271cf53f Travis: [FAILURE](https://tra

[GitHub] [flink] flinkbot edited a comment on issue #11054: [FLINK-15652][K8s] Support for imagePullSecrets K8s option.

flinkbot edited a comment on issue #11054: [FLINK-15652][K8s] Support for imagePullSecrets K8s option. URL: https://github.com/apache/flink/pull/11054#issuecomment-584462322 ## CI report: * 47f64cd0ddbb74874daff1607a30a999f4554ce1 Travis: [FAILURE](https://travis-ci.com/flink-ci

[GitHub] [flink] flinkbot edited a comment on issue #11010: [FLINK-15836][k8s] Start a new pods watcher in KubernetesResourceManager when the old one is closed with exception

flinkbot edited a comment on issue #11010: [FLINK-15836][k8s] Start a new pods watcher in KubernetesResourceManager when the old one is closed with exception URL: https://github.com/apache/flink/pull/11010#issuecomment-581769412 ## CI report: * e6722c5f11f17384bc94de89095c46d605

[GitHub] [flink] wangxlong commented on a change in pull request #11060: [FLINK-15994][Table-planner-blink]Support byte array argument for FROM_BASE64 function

wangxlong commented on a change in pull request #11060: [FLINK-15994][Table-planner-blink]Support byte array argument for FROM_BASE64 function URL: https://github.com/apache/flink/pull/11060#discussion_r378024636 ## File path: flink-table/flink-table-planner-blink/src/test/scala/o

[GitHub] [flink] flinkbot edited a comment on issue #10883: [FLINK-15629][runtime] Remove LegacyScheduler class and the consequently unused codes

flinkbot edited a comment on issue #10883: [FLINK-15629][runtime] Remove LegacyScheduler class and the consequently unused codes URL: https://github.com/apache/flink/pull/10883#issuecomment-575556059 ## CI report: * 7b96f07104a110c1d1b0aafbc0427c45b38f14d8 Travis: [FAILURE](http

[GitHub] [flink] flinkbot edited a comment on issue #10858: [FLINK-15582][tests] Enable batch scheduling tests for both LegacyScheduler and DefaultScheduler

flinkbot edited a comment on issue #10858: [FLINK-15582][tests] Enable batch scheduling tests for both LegacyScheduler and DefaultScheduler URL: https://github.com/apache/flink/pull/10858#issuecomment-574561465 ## CI report: * cf716ecc2f23aa89683be8096f16725b1f1f8d26 Travis: [FA

[jira] [Created] (FLINK-16011) Normalize the within usage in Pattern

shuai.xu created FLINK-16011: Summary: Normalize the within usage in Pattern Key: FLINK-16011 URL: https://issues.apache.org/jira/browse/FLINK-16011 Project: Flink Issue Type: Improvement

[GitHub] [flink] wuchong commented on a change in pull request #11063: [FLINK-15938][table-planner-blink] Enable state cleanup in background…

wuchong commented on a change in pull request #11063: [FLINK-15938][table-planner-blink] Enable state cleanup in background… URL: https://github.com/apache/flink/pull/11063#discussion_r378023228 ## File path: flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/tabl

[GitHub] [flink] flinkbot commented on issue #11065: [hotfix] Fix the wrong Javadoc of HadoopSecurityContext

flinkbot commented on issue #11065: [hotfix] Fix the wrong Javadoc of HadoopSecurityContext URL: https://github.com/apache/flink/pull/11065#issuecomment-585007262 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull

[GitHub] [flink] wuchong commented on issue #10745: [FLINK-15445][connectors/jdbc] JDBC Table Source didn't work for Type…

wuchong commented on issue #10745: [FLINK-15445][connectors/jdbc] JDBC Table Source didn't work for Type… URL: https://github.com/apache/flink/pull/10745#issuecomment-585006962 Waiting for the travis. This is an automated mes

[GitHub] [flink] libenchao commented on a change in pull request #11063: [FLINK-15938][table-planner-blink] Enable state cleanup in background…

libenchao commented on a change in pull request #11063: [FLINK-15938][table-planner-blink] Enable state cleanup in background… URL: https://github.com/apache/flink/pull/11063#discussion_r378022373 ## File path: flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/ta

[GitHub] [flink] yanghua opened a new pull request #11065: [hotfix] Fix the wrong Javadoc of HadoopSecurityContext

yanghua opened a new pull request #11065: [hotfix] Fix the wrong Javadoc of HadoopSecurityContext URL: https://github.com/apache/flink/pull/11065 ## What is the purpose of the change *This pull request fixes the wrong javadoc of HadoopSecurityContext* ## Brief change l

[GitHub] [flink] wuchong commented on a change in pull request #11063: [FLINK-15938][table-planner-blink] Enable state cleanup in background…

wuchong commented on a change in pull request #11063: [FLINK-15938][table-planner-blink] Enable state cleanup in background… URL: https://github.com/apache/flink/pull/11063#discussion_r378021090 ## File path: flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/tabl

[GitHub] [flink] wuchong commented on a change in pull request #11063: [FLINK-15938][table-planner-blink] Enable state cleanup in background…

wuchong commented on a change in pull request #11063: [FLINK-15938][table-planner-blink] Enable state cleanup in background… URL: https://github.com/apache/flink/pull/11063#discussion_r378021090 ## File path: flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/tabl

[GitHub] [flink] TisonKun commented on a change in pull request #11054: [FLINK-15652][K8s] Support for imagePullSecrets K8s option.

TisonKun commented on a change in pull request #11054: [FLINK-15652][K8s] Support for imagePullSecrets K8s option. URL: https://github.com/apache/flink/pull/11054#discussion_r378020468 ## File path: flink-kubernetes/src/main/java/org/apache/flink/kubernetes/utils/KubernetesUtils.ja

[GitHub] [flink] flinkbot edited a comment on issue #10151: [FLINK-14231] Handle the pending processing-time timers to make endInput semantics on the operator chain strict

flinkbot edited a comment on issue #10151: [FLINK-14231] Handle the pending processing-time timers to make endInput semantics on the operator chain strict URL: https://github.com/apache/flink/pull/10151#issuecomment-552442468 ## CI report: * c6d7f5e864076448dca590035a6a590dc5e25c

[GitHub] [flink] flinkbot edited a comment on issue #11064: [FLINK-15992][table] Fix classloader when finding TableFactory

flinkbot edited a comment on issue #11064: [FLINK-15992][table] Fix classloader when finding TableFactory URL: https://github.com/apache/flink/pull/11064#issuecomment-584988879 ## CI report: * d803ebfd0ed066087c5330d88b9412c060740059 Travis: [PENDING](https://travis-ci.com/flink

[GitHub] [flink] flinkbot edited a comment on issue #11055: [FLINK-15990][table] Remove register source and sink in ConnectTableDescriptor

flinkbot edited a comment on issue #11055: [FLINK-15990][table] Remove register source and sink in ConnectTableDescriptor URL: https://github.com/apache/flink/pull/11055#issuecomment-584564020 ## CI report: * ff83531840d16c504cb18adc21e7e9a4271cf53f Travis: [FAILURE](https://tra

[GitHub] [flink] flinkbot edited a comment on issue #11058: [FLINK-15995][Table-planner-blink] Change TO_BASE64 sql operator defination

flinkbot edited a comment on issue #11058: [FLINK-15995][Table-planner-blink] Change TO_BASE64 sql operator defination URL: https://github.com/apache/flink/pull/11058#issuecomment-584608498 ## CI report: * 66514df47c1dcf00cb12be4f26a7ed26ee97da1f Travis: [SUCCESS](https://travis

[jira] [Resolved] (FLINK-15995) TO_BASE64 sql operator change operandTypeChecker from OperandTypes.ANY to OperandTypes.family(SqlTypeFamily.STRING)

[ https://issues.apache.org/jira/browse/FLINK-15995?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu resolved FLINK-15995. - Resolution: Resolved Resolved in master (1.11.0): 82731bbb5513cf07160ef84c31f1be27f475f827 > TO_BASE64

[GitHub] [flink] flinkbot edited a comment on issue #11054: [FLINK-15652][K8s] Support for imagePullSecrets K8s option.

flinkbot edited a comment on issue #11054: [FLINK-15652][K8s] Support for imagePullSecrets K8s option. URL: https://github.com/apache/flink/pull/11054#issuecomment-584462322 ## CI report: * 47f64cd0ddbb74874daff1607a30a999f4554ce1 Travis: [FAILURE](https://travis-ci.com/flink-ci

[GitHub] [flink] wuchong merged pull request #11058: [FLINK-15995][Table-planner-blink] Change TO_BASE64 sql operator defination

wuchong merged pull request #11058: [FLINK-15995][Table-planner-blink] Change TO_BASE64 sql operator defination URL: https://github.com/apache/flink/pull/11058 This is an automated message from the Apache Git Service. To res

[jira] [Created] (FLINK-16010) Support notFollowedBy with interval as the last part of a Pattern

shuai.xu created FLINK-16010: Summary: Support notFollowedBy with interval as the last part of a Pattern Key: FLINK-16010 URL: https://issues.apache.org/jira/browse/FLINK-16010 Project: Flink Is

[GitHub] [flink] flinkbot edited a comment on issue #10883: [FLINK-15629][runtime] Remove LegacyScheduler class and the consequently unused codes

flinkbot edited a comment on issue #10883: [FLINK-15629][runtime] Remove LegacyScheduler class and the consequently unused codes URL: https://github.com/apache/flink/pull/10883#issuecomment-575556059 ## CI report: * 7b96f07104a110c1d1b0aafbc0427c45b38f14d8 Travis: [FAILURE](http

[GitHub] [flink] wuchong commented on a change in pull request #11060: [FLINK-15994][Table-planner-blink]Support byte array argument for FROM_BASE64 function

wuchong commented on a change in pull request #11060: [FLINK-15994][Table-planner-blink]Support byte array argument for FROM_BASE64 function URL: https://github.com/apache/flink/pull/11060#discussion_r378015754 ## File path: flink-table/flink-table-planner-blink/src/test/scala/org

[GitHub] [flink] zhengcanbin commented on issue #11054: [FLINK-15652][K8s] Support for imagePullSecrets K8s option.

zhengcanbin commented on issue #11054: [FLINK-15652][K8s] Support for imagePullSecrets K8s option. URL: https://github.com/apache/flink/pull/11054#issuecomment-584992416 @flinkbot run travis This is an automated message from

[GitHub] [flink] sunhaibotb commented on issue #10151: [FLINK-14231] Handle the pending processing-time timers to make endInput semantics on the operator chain strict

sunhaibotb commented on issue #10151: [FLINK-14231] Handle the pending processing-time timers to make endInput semantics on the operator chain strict URL: https://github.com/apache/flink/pull/10151#issuecomment-584990787 I've updated the PR code to address comments. Thanks. @rkhachatryan

[jira] [Closed] (FLINK-15646) Configurable K8s context support

[ https://issues.apache.org/jira/browse/FLINK-15646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen closed FLINK-15646. - Resolution: Fixed master via 407b5bc6be31603c1f1a7d6637a3599ef98370e8 It is not a bugfix issue but a ne

[jira] [Updated] (FLINK-15646) Configurable K8s context support

[ https://issues.apache.org/jira/browse/FLINK-15646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen updated FLINK-15646: -- Fix Version/s: (was: 1.10.1) > Configurable K8s context support >

[jira] [Commented] (FLINK-16001) Avoid using Java Streams in construction of ExecutionGraph

[ https://issues.apache.org/jira/browse/FLINK-16001?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17034993#comment-17034993 ] Jiayi Liao commented on FLINK-16001: [~gjy] > Isn't the bulk of the computation don

[GitHub] [flink] flinkbot commented on issue #11064: [FLINK-15992][table] Fix classloader when finding TableFactory

flinkbot commented on issue #11064: [FLINK-15992][table] Fix classloader when finding TableFactory URL: https://github.com/apache/flink/pull/11064#issuecomment-584988879 ## CI report: * d803ebfd0ed066087c5330d88b9412c060740059 UNKNOWN Bot commands The @flinkbot bo

[GitHub] [flink] flinkbot edited a comment on issue #11010: [FLINK-15836][k8s] Start a new pods watcher in KubernetesResourceManager when the old one is closed with exception

flinkbot edited a comment on issue #11010: [FLINK-15836][k8s] Start a new pods watcher in KubernetesResourceManager when the old one is closed with exception URL: https://github.com/apache/flink/pull/11010#issuecomment-581769412 ## CI report: * e6722c5f11f17384bc94de89095c46d605

[GitHub] [flink] flinkbot edited a comment on issue #10899: [FLINK-15668][tests] Remove travis test stages for legacy scheduler

flinkbot edited a comment on issue #10899: [FLINK-15668][tests] Remove travis test stages for legacy scheduler URL: https://github.com/apache/flink/pull/10899#issuecomment-575987886 ## CI report: * edb45d1c1b293737afe771c4055ea5f83b8c5cf3 Travis: [SUCCESS](https://travis-ci.com/

[GitHub] [flink] flinkbot edited a comment on issue #10858: [FLINK-15582][tests] Enable batch scheduling tests for both LegacyScheduler and DefaultScheduler

flinkbot edited a comment on issue #10858: [FLINK-15582][tests] Enable batch scheduling tests for both LegacyScheduler and DefaultScheduler URL: https://github.com/apache/flink/pull/10858#issuecomment-574561465 ## CI report: * cf716ecc2f23aa89683be8096f16725b1f1f8d26 Travis: [FA

[GitHub] [flink] sunhaibotb commented on a change in pull request #10151: [FLINK-14231] Handle the pending processing-time timers to make endInput semantics on the operator chain strict

sunhaibotb commented on a change in pull request #10151: [FLINK-14231] Handle the pending processing-time timers to make endInput semantics on the operator chain strict URL: https://github.com/apache/flink/pull/10151#discussion_r378005602 ## File path: flink-streaming-java/src/mai

[jira] [Commented] (FLINK-16009) Native support for the Variable-length and Zig-zag Variable-length integers

[ https://issues.apache.org/jira/browse/FLINK-16009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17034977#comment-17034977 ] Yun Gao commented on FLINK-16009: - I will first perform some experiments to show if redu

[GitHub] [flink] sunhaibotb commented on a change in pull request #10151: [FLINK-14231] Handle the pending processing-time timers to make endInput semantics on the operator chain strict

sunhaibotb commented on a change in pull request #10151: [FLINK-14231] Handle the pending processing-time timers to make endInput semantics on the operator chain strict URL: https://github.com/apache/flink/pull/10151#discussion_r378005067 ## File path: flink-streaming-java/src/mai

[GitHub] [flink] sunhaibotb commented on a change in pull request #10151: [FLINK-14231] Handle the pending processing-time timers to make endInput semantics on the operator chain strict

sunhaibotb commented on a change in pull request #10151: [FLINK-14231] Handle the pending processing-time timers to make endInput semantics on the operator chain strict URL: https://github.com/apache/flink/pull/10151#discussion_r378005067 ## File path: flink-streaming-java/src/mai

[jira] [Created] (FLINK-16009) Native support for the Variable-length and Zig-zag Variable-length integers

Yun Gao created FLINK-16009: --- Summary: Native support for the Variable-length and Zig-zag Variable-length integers Key: FLINK-16009 URL: https://issues.apache.org/jira/browse/FLINK-16009 Project: Flink

[GitHub] [flink] flinkbot commented on issue #11064: [FLINK-15992][table] Fix classloader when finding TableFactory

flinkbot commented on issue #11064: [FLINK-15992][table] Fix classloader when finding TableFactory URL: https://github.com/apache/flink/pull/11064#issuecomment-584980819 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review you

[jira] [Updated] (FLINK-15992) Incorrect classloader when finding TableFactory

[ https://issues.apache.org/jira/browse/FLINK-15992?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-15992: --- Labels: pull-request-available (was: ) > Incorrect classloader when finding TableFactory >

[GitHub] [flink] jiasheng55 opened a new pull request #11064: [FLINK-15992][table] Fix classloader when finding TableFactory

jiasheng55 opened a new pull request #11064: [FLINK-15992][table] Fix classloader when finding TableFactory URL: https://github.com/apache/flink/pull/11064 ## What is the purpose of the change This pull request makes finding SerializationSchemaFactory with ClassLoader from `Thread.c

[GitHub] [flink] flinkbot edited a comment on issue #11058: [FLINK-15995][Table-planner-blink] Change TO_BASE64 sql operator defination

flinkbot edited a comment on issue #11058: [FLINK-15995][Table-planner-blink] Change TO_BASE64 sql operator defination URL: https://github.com/apache/flink/pull/11058#issuecomment-584608498 ## CI report: * 66514df47c1dcf00cb12be4f26a7ed26ee97da1f Travis: [SUCCESS](https://travis

[GitHub] [flink] flinkbot edited a comment on issue #11010: [FLINK-15836][k8s] Start a new pods watcher in KubernetesResourceManager when the old one is closed with exception

flinkbot edited a comment on issue #11010: [FLINK-15836][k8s] Start a new pods watcher in KubernetesResourceManager when the old one is closed with exception URL: https://github.com/apache/flink/pull/11010#issuecomment-581769412 ## CI report: * e6722c5f11f17384bc94de89095c46d605

[GitHub] [flink] flinkbot edited a comment on issue #10899: [FLINK-15668][tests] Remove travis test stages for legacy scheduler

flinkbot edited a comment on issue #10899: [FLINK-15668][tests] Remove travis test stages for legacy scheduler URL: https://github.com/apache/flink/pull/10899#issuecomment-575987886 ## CI report: * edb45d1c1b293737afe771c4055ea5f83b8c5cf3 Travis: [SUCCESS](https://travis-ci.com/

[GitHub] [flink] flinkbot edited a comment on issue #10858: [FLINK-15582][tests] Enable batch scheduling tests for both LegacyScheduler and DefaultScheduler

flinkbot edited a comment on issue #10858: [FLINK-15582][tests] Enable batch scheduling tests for both LegacyScheduler and DefaultScheduler URL: https://github.com/apache/flink/pull/10858#issuecomment-574561465 ## CI report: * cf716ecc2f23aa89683be8096f16725b1f1f8d26 Travis: [FA

  1   2   3   4   >