[GitHub] [flink] zhijiangW commented on a change in pull request #11507: [FLINK-16587] Add basic CheckpointBarrierHandler for unaligned checkpoint

2020-03-31 Thread GitBox
zhijiangW commented on a change in pull request #11507: [FLINK-16587] Add basic CheckpointBarrierHandler for unaligned checkpoint URL: https://github.com/apache/flink/pull/11507#discussion_r400823738 ## File path:

[jira] [Comment Edited] (FLINK-16809) Support setting CallerContext on YARN deployments

2020-03-31 Thread Aljoscha Krettek (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16809?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17071677#comment-17071677 ] Aljoscha Krettek edited comment on FLINK-16809 at 3/31/20, 11:00 AM: -

[jira] [Commented] (FLINK-16809) Support setting CallerContext on YARN deployments

2020-03-31 Thread Aljoscha Krettek (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16809?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17071677#comment-17071677 ] Aljoscha Krettek commented on FLINK-16809: -- I believe {{CallerContext}} is a Hadoop concept

[jira] [Updated] (FLINK-16809) Support setting CallerContext on YARN deployments

2020-03-31 Thread Aljoscha Krettek (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16809?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-16809: - Summary: Support setting CallerContext on YARN deployments (was: Support adding

[jira] [Updated] (FLINK-16809) Support adding CallerContext on YARN deployments

2020-03-31 Thread Aljoscha Krettek (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16809?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-16809: - Summary: Support adding CallerContext on YARN deployments (was: Add Caller Context in

[GitHub] [flink-statefun-docker] tzulitai opened a new pull request #2: [release] Add Dockerfiles for release 2.0.0

2020-03-31 Thread GitBox
tzulitai opened a new pull request #2: [release] Add Dockerfiles for release 2.0.0 URL: https://github.com/apache/flink-statefun-docker/pull/2 This PR is based on #1, and uses the scripts added there to generate the new Dockerfiles in this PR, by doing: ``` ./add-version.sh -s 2.0.0

[GitHub] [flink] zhijiangW commented on a change in pull request #11507: [FLINK-16587] Add basic CheckpointBarrierHandler for unaligned checkpoint

2020-03-31 Thread GitBox
zhijiangW commented on a change in pull request #11507: [FLINK-16587] Add basic CheckpointBarrierHandler for unaligned checkpoint URL: https://github.com/apache/flink/pull/11507#discussion_r400820857 ## File path:

[GitHub] [flink] zhijiangW commented on a change in pull request #11507: [FLINK-16587] Add basic CheckpointBarrierHandler for unaligned checkpoint

2020-03-31 Thread GitBox
zhijiangW commented on a change in pull request #11507: [FLINK-16587] Add basic CheckpointBarrierHandler for unaligned checkpoint URL: https://github.com/apache/flink/pull/11507#discussion_r400820857 ## File path:

[GitHub] [flink] kl0u edited a comment on issue #11460: [FLINK-16655][FLINK-16657] Introduce embedded executor and use it for Web Submission

2020-03-31 Thread GitBox
kl0u edited a comment on issue #11460: [FLINK-16655][FLINK-16657] Introduce embedded executor and use it for Web Submission URL: https://github.com/apache/flink/pull/11460#issuecomment-606548673 Thanks for looking into it @wangyang0918 ! Even before, batch jobs with `collect()` or

[jira] [Closed] (FLINK-16836) Losing leadership does not clear rpc connection in JobManagerLeaderListener

2020-03-31 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16836?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-16836. - Resolution: Fixed Fixed via 7ff9ce16607fe345fa41d0c92eb956df4b31e067 > Losing leadership does

[jira] [Updated] (FLINK-16777) expose Pipeline in JobClient

2020-03-31 Thread Aljoscha Krettek (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16777?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-16777: - Fix Version/s: (was: 1.11.0) > expose Pipeline in JobClient >

[GitHub] [flink] tillrohrmann closed pull request #11552: [FLINK-16836] Clear rpcConnection field in JobManagerLeaderListener when target loses leadership

2020-03-31 Thread GitBox
tillrohrmann closed pull request #11552: [FLINK-16836] Clear rpcConnection field in JobManagerLeaderListener when target loses leadership URL: https://github.com/apache/flink/pull/11552 This is an automated message from the

[jira] [Updated] (FLINK-16880) Adapt Dockerfiles from flink-statefun to be added to flink-statefun-docker

2020-03-31 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16880?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-16880: --- Labels: pull-request-available (was: ) > Adapt Dockerfiles from flink-statefun to be added

[GitHub] [flink] zhijiangW commented on a change in pull request #11507: [FLINK-16587] Add basic CheckpointBarrierHandler for unaligned checkpoint

2020-03-31 Thread GitBox
zhijiangW commented on a change in pull request #11507: [FLINK-16587] Add basic CheckpointBarrierHandler for unaligned checkpoint URL: https://github.com/apache/flink/pull/11507#discussion_r400817529 ## File path:

[GitHub] [flink-statefun-docker] tzulitai opened a new pull request #1: [FLINK-16880] Add tools and template Dockerfiles to facilitate release workflow

2020-03-31 Thread GitBox
tzulitai opened a new pull request #1: [FLINK-16880] Add tools and template Dockerfiles to facilitate release workflow URL: https://github.com/apache/flink-statefun-docker/pull/1 This PR adds: - A template for the Dockerfiles of releases, under the `template` directory. - A

[GitHub] [flink] flinkbot edited a comment on issue #11575: [FLINK-16878][e2e][table] Fix dependency shading of table modules test failure after …

2020-03-31 Thread GitBox
flinkbot edited a comment on issue #11575: [FLINK-16878][e2e][table] Fix dependency shading of table modules test failure after … URL: https://github.com/apache/flink/pull/11575#issuecomment-606453461 ## CI report: * 143df1c651acec79142bc90dcf5820695a51f1c3 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11579: [FLINK-16767][hive] Failed to read Hive table with RegexSerDe

2020-03-31 Thread GitBox
flinkbot edited a comment on issue #11579: [FLINK-16767][hive] Failed to read Hive table with RegexSerDe URL: https://github.com/apache/flink/pull/11579#issuecomment-606537991 ## CI report: * 5febafb727b8a54a377c2352ff5d3de1afa99d1e Travis:

[jira] [Updated] (FLINK-16764) Allow custom Kafka topic discovery logic

2020-03-31 Thread Aljoscha Krettek (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16764?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-16764: - Summary: Allow custom Kafka topic discovery logic (was: Kafka topic discovery) >

[GitHub] [flink] flinkbot edited a comment on issue #11376: [FLINK-16535] [table] BatchTableSink#emitDataSet returns DataSink

2020-03-31 Thread GitBox
flinkbot edited a comment on issue #11376: [FLINK-16535] [table] BatchTableSink#emitDataSet returns DataSink URL: https://github.com/apache/flink/pull/11376#issuecomment-597520890 ## CI report: * f0ba2bfc98fd1e62d065f547a0f2eb985b475825 Travis:

[GitHub] [flink] kl0u commented on issue #11460: [FLINK-16655][FLINK-16657] Introduce embedded executor and use it for Web Submission

2020-03-31 Thread GitBox
kl0u commented on issue #11460: [FLINK-16655][FLINK-16657] Introduce embedded executor and use it for Web Submission URL: https://github.com/apache/flink/pull/11460#issuecomment-606548673 Thanks for looking into it @wangyang0918 ! Even before, batch jobs with `collect()` or `count()` were

[jira] [Commented] (FLINK-16760) Support the yaml file submission for native Kubernetes integration

2020-03-31 Thread Aljoscha Krettek (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16760?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17071672#comment-17071672 ] Aljoscha Krettek commented on FLINK-16760: -- An important part of this will also be the

[GitHub] [flink] flinkbot edited a comment on issue #11481: [FLINK-13691][Table]Remove deprecated query config

2020-03-31 Thread GitBox
flinkbot edited a comment on issue #11481: [FLINK-13691][Table]Remove deprecated query config URL: https://github.com/apache/flink/pull/11481#issuecomment-602174011 ## CI report: * 7496b16e60235e78f93bb3a8538a1aaf5a5cb0ea Travis:

[GitHub] [flink] tillrohrmann commented on issue #11552: [FLINK-16836] Clear rpcConnection field in JobManagerLeaderListener when target loses leadership

2020-03-31 Thread GitBox
tillrohrmann commented on issue #11552: [FLINK-16836] Clear rpcConnection field in JobManagerLeaderListener when target loses leadership URL: https://github.com/apache/flink/pull/11552#issuecomment-606548723 Thanks for the review @GJL. Merging this PR after addressing your comments.

[GitHub] [flink] flinkbot edited a comment on issue #11290: [FLINK-16379][table] Introduce fromValues in TableEnvironment

2020-03-31 Thread GitBox
flinkbot edited a comment on issue #11290: [FLINK-16379][table] Introduce fromValues in TableEnvironment URL: https://github.com/apache/flink/pull/11290#issuecomment-593487396 ## CI report: * 3f0a7c1bbd3f4124d82a75c22abcb6723ef6cda9 Travis:

[jira] [Resolved] (FLINK-16703) AkkaRpcActor state machine does not record transition to terminating state.

2020-03-31 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16703?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-16703. --- Resolution: Fixed Fixed via 1.11.0: 1e0db6425f18b8d69b69176b9cb75e8b000bf768 1.10.1:

[GitHub] [flink] zhijiangW commented on a change in pull request #11507: [FLINK-16587] Add basic CheckpointBarrierHandler for unaligned checkpoint

2020-03-31 Thread GitBox
zhijiangW commented on a change in pull request #11507: [FLINK-16587] Add basic CheckpointBarrierHandler for unaligned checkpoint URL: https://github.com/apache/flink/pull/11507#discussion_r400815721 ## File path:

[jira] [Commented] (FLINK-16735) FlinkKafkaProducer should check that it is not null before sending a record

2020-03-31 Thread Aljoscha Krettek (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16735?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17071670#comment-17071670 ] Aljoscha Krettek commented on FLINK-16735: -- I think the current behaviour is the expected

[GitHub] [flink] zhijiangW commented on a change in pull request #11507: [FLINK-16587] Add basic CheckpointBarrierHandler for unaligned checkpoint

2020-03-31 Thread GitBox
zhijiangW commented on a change in pull request #11507: [FLINK-16587] Add basic CheckpointBarrierHandler for unaligned checkpoint URL: https://github.com/apache/flink/pull/11507#discussion_r400814235 ## File path:

[jira] [Updated] (FLINK-16703) AkkaRpcActor state machine does not record transition to terminating state.

2020-03-31 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16703?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-16703: -- Fix Version/s: 1.11.0 1.10.1 1.9.3 > AkkaRpcActor state

[GitHub] [flink] tillrohrmann closed pull request #11549: [FLINK-16703][rpc] Set AkkaRpcActor state to TERMINATING when terminating

2020-03-31 Thread GitBox
tillrohrmann closed pull request #11549: [FLINK-16703][rpc] Set AkkaRpcActor state to TERMINATING when terminating URL: https://github.com/apache/flink/pull/11549 This is an automated message from the Apache Git Service. To

[GitHub] [flink] tillrohrmann commented on issue #11549: [FLINK-16703][rpc] Set AkkaRpcActor state to TERMINATING when terminating

2020-03-31 Thread GitBox
tillrohrmann commented on issue #11549: [FLINK-16703][rpc] Set AkkaRpcActor state to TERMINATING when terminating URL: https://github.com/apache/flink/pull/11549#issuecomment-606544032 Thanks for the review @GJL. I've addressed your comments. Merging this PR now.

[GitHub] [flink] GJL commented on a change in pull request #11549: [FLINK-16703][rpc] Set AkkaRpcActor state to TERMINATING when terminating

2020-03-31 Thread GitBox
GJL commented on a change in pull request #11549: [FLINK-16703][rpc] Set AkkaRpcActor state to TERMINATING when terminating URL: https://github.com/apache/flink/pull/11549#discussion_r400811942 ## File path:

[jira] [Closed] (FLINK-16232) Remove redundant log4j2 exclusions from hive connector

2020-03-31 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16232?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-16232. Fix Version/s: (was: 1.11.0) Resolution: Won't Fix Hive is a bit of a special

[GitHub] [flink] zentol closed pull request #11184: [FLINK-16232][hive][build] Remove log4j2 exclusions

2020-03-31 Thread GitBox
zentol closed pull request #11184: [FLINK-16232][hive][build] Remove log4j2 exclusions URL: https://github.com/apache/flink/pull/11184 This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [flink] zhijiangW commented on a change in pull request #11507: [FLINK-16587] Add basic CheckpointBarrierHandler for unaligned checkpoint

2020-03-31 Thread GitBox
zhijiangW commented on a change in pull request #11507: [FLINK-16587] Add basic CheckpointBarrierHandler for unaligned checkpoint URL: https://github.com/apache/flink/pull/11507#discussion_r400806571 ## File path:

[GitHub] [flink] flinkbot commented on issue #11579: [FLINK-16767][hive] Failed to read Hive table with RegexSerDe

2020-03-31 Thread GitBox
flinkbot commented on issue #11579: [FLINK-16767][hive] Failed to read Hive table with RegexSerDe URL: https://github.com/apache/flink/pull/11579#issuecomment-606537991 ## CI report: * 5febafb727b8a54a377c2352ff5d3de1afa99d1e UNKNOWN Bot commands The @flinkbot

[jira] [Commented] (FLINK-16876) Make TtlTimeProvider configurable when creating keyed state backend

2020-03-31 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16876?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17071658#comment-17071658 ] dalongliu commented on FLINK-16876: --- +1 > Make TtlTimeProvider configurable when creating keyed state

[GitHub] [flink] flinkbot edited a comment on issue #11574: [FLINK-16859][table-runtime] Introduce FileSystemTableFactory

2020-03-31 Thread GitBox
flinkbot edited a comment on issue #11574: [FLINK-16859][table-runtime] Introduce FileSystemTableFactory URL: https://github.com/apache/flink/pull/11574#issuecomment-606453374 ## CI report: * 20fa6efb98f1ac2e1d3158883525da97fbf4126d 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

2020-03-31 Thread GitBox
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: *

[jira] [Commented] (FLINK-16793) Add jobName to log4j ConversionPattern

2020-03-31 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17071652#comment-17071652 ] Chesnay Schepler commented on FLINK-16793: -- Have you tried setting the

[GitHub] [flink] zhijiangW commented on a change in pull request #11507: [FLINK-16587] Add basic CheckpointBarrierHandler for unaligned checkpoint

2020-03-31 Thread GitBox
zhijiangW commented on a change in pull request #11507: [FLINK-16587] Add basic CheckpointBarrierHandler for unaligned checkpoint URL: https://github.com/apache/flink/pull/11507#discussion_r400802337 ## File path:

[jira] [Commented] (FLINK-16793) Add jobName to log4j ConversionPattern

2020-03-31 Thread jinhai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17071646#comment-17071646 ] jinhai commented on FLINK-16793: [~chesnay] when submit a job by shell command like: flink run

[jira] [Created] (FLINK-16884) The "rest.port" configuration is always "0" with flink-yarn jobs

2020-03-31 Thread Victor Wong (Jira)
Victor Wong created FLINK-16884: --- Summary: The "rest.port" configuration is always "0" with flink-yarn jobs Key: FLINK-16884 URL: https://issues.apache.org/jira/browse/FLINK-16884 Project: Flink

[GitHub] [flink] tillrohrmann commented on a change in pull request #11549: [FLINK-16703][rpc] Set AkkaRpcActor state to TERMINATING when terminating

2020-03-31 Thread GitBox
tillrohrmann commented on a change in pull request #11549: [FLINK-16703][rpc] Set AkkaRpcActor state to TERMINATING when terminating URL: https://github.com/apache/flink/pull/11549#discussion_r400797121 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #11549: [FLINK-16703][rpc] Set AkkaRpcActor state to TERMINATING when terminating

2020-03-31 Thread GitBox
tillrohrmann commented on a change in pull request #11549: [FLINK-16703][rpc] Set AkkaRpcActor state to TERMINATING when terminating URL: https://github.com/apache/flink/pull/11549#discussion_r400797236 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #11574: [FLINK-16859][table-runtime] Introduce FileSystemTableFactory

2020-03-31 Thread GitBox
flinkbot edited a comment on issue #11574: [FLINK-16859][table-runtime] Introduce FileSystemTableFactory URL: https://github.com/apache/flink/pull/11574#issuecomment-606453374 ## CI report: * 20fa6efb98f1ac2e1d3158883525da97fbf4126d Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11573: [FLINK-16823][table-planner-blink] Fix TIMESTAMPDIFF/TIMESTAMPADD yie…

2020-03-31 Thread GitBox
flinkbot edited a comment on issue #11573: [FLINK-16823][table-planner-blink] Fix TIMESTAMPDIFF/TIMESTAMPADD yie… URL: https://github.com/apache/flink/pull/11573#issuecomment-606453288 ## CI report: * dfd2474f4258e35613f301ed9daeb9ed3c8a2cb4 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11576: [FLINK-16674][python][docs] Add documentation about how to use user-defined metrics for Python UDF

2020-03-31 Thread GitBox
flinkbot edited a comment on issue #11576: [FLINK-16674][python][docs] Add documentation about how to use user-defined metrics for Python UDF URL: https://github.com/apache/flink/pull/11576#issuecomment-606478822 ## CI report: * 79211d48e21442a9be627dd6ee806c899aef208e Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11578: [RELEASE-1.10][FLINK-16874] Respect the dynamic options when calculating memory opt…

2020-03-31 Thread GitBox
flinkbot edited a comment on issue #11578: [RELEASE-1.10][FLINK-16874] Respect the dynamic options when calculating memory opt… URL: https://github.com/apache/flink/pull/11578#issuecomment-606518441 ## CI report: * 75d844fecd7c9da0db0d252bb5a3f082c6979ceb Travis:

[jira] [Resolved] (FLINK-16018) Improve error reporting when submitting batch job (instead of AskTimeoutException)

2020-03-31 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-16018. --- Fix Version/s: 1.9.3 Resolution: Fixed Fixed via master:

[GitHub] [flink] flinkbot edited a comment on issue #11376: [FLINK-16535] [table] BatchTableSink#emitDataSet returns DataSink

2020-03-31 Thread GitBox
flinkbot edited a comment on issue #11376: [FLINK-16535] [table] BatchTableSink#emitDataSet returns DataSink URL: https://github.com/apache/flink/pull/11376#issuecomment-597520890 ## CI report: * f0ba2bfc98fd1e62d065f547a0f2eb985b475825 Travis:

[GitHub] [flink] zhijiangW commented on a change in pull request #11507: [FLINK-16587] Add basic CheckpointBarrierHandler for unaligned checkpoint

2020-03-31 Thread GitBox
zhijiangW commented on a change in pull request #11507: [FLINK-16587] Add basic CheckpointBarrierHandler for unaligned checkpoint URL: https://github.com/apache/flink/pull/11507#discussion_r400792947 ## File path:

[GitHub] [flink] flinkbot commented on issue #11579: [FLINK-16767][hive] Failed to read Hive table with RegexSerDe

2020-03-31 Thread GitBox
flinkbot commented on issue #11579: [FLINK-16767][hive] Failed to read Hive table with RegexSerDe URL: https://github.com/apache/flink/pull/11579#issuecomment-606525880 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review

[jira] [Commented] (FLINK-16666) Support new Python dependency configuration options in flink-java, flink-streaming-java and flink-table

2020-03-31 Thread Wei Zhong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-1?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17071640#comment-17071640 ] Wei Zhong commented on FLINK-1: --- Hi [~aljoscha], Yes we don't really support executing Python

[jira] [Commented] (FLINK-16883) No support for log4j2 configuration formats besides properties

2020-03-31 Thread Fabian Paul (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16883?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17071639#comment-17071639 ] Fabian Paul commented on FLINK-16883: - I agree, your idea sounds also suitable. I will implement

[jira] [Commented] (FLINK-16866) Make job submission non-blocking

2020-03-31 Thread Yingjie Cao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16866?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17071638#comment-17071638 ] Yingjie Cao commented on FLINK-16866: - I wonder whether a user can query the job information (may

[GitHub] [flink] tillrohrmann closed pull request #11565: [FLINK-16018] Increase default value of web.timeout to 10 minutes

2020-03-31 Thread GitBox
tillrohrmann closed pull request #11565: [FLINK-16018] Increase default value of web.timeout to 10 minutes URL: https://github.com/apache/flink/pull/11565 This is an automated message from the Apache Git Service. To respond

[GitHub] [flink] lirui-apache opened a new pull request #11579: [FLINK-16767][hive] Failed to read Hive table with RegexSerDe

2020-03-31 Thread GitBox
lirui-apache opened a new pull request #11579: [FLINK-16767][hive] Failed to read Hive table with RegexSerDe URL: https://github.com/apache/flink/pull/11579 ## What is the purpose of the change Fix reading Hive tables with RegexSerDe. RegexSerDe initialization fails with

[GitHub] [flink] zhijiangW commented on a change in pull request #11507: [FLINK-16587] Add basic CheckpointBarrierHandler for unaligned checkpoint

2020-03-31 Thread GitBox
zhijiangW commented on a change in pull request #11507: [FLINK-16587] Add basic CheckpointBarrierHandler for unaligned checkpoint URL: https://github.com/apache/flink/pull/11507#discussion_r400788870 ## File path:

[jira] [Assigned] (FLINK-16883) No support for log4j2 configuration formats besides properties

2020-03-31 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16883?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-16883: Assignee: Fabian Paul > No support for log4j2 configuration formats besides

[GitHub] [flink] tillrohrmann commented on issue #11565: [FLINK-16018] Increase default value of web.timeout to 10 minutes

2020-03-31 Thread GitBox
tillrohrmann commented on issue #11565: [FLINK-16018] Increase default value of web.timeout to 10 minutes URL: https://github.com/apache/flink/pull/11565#issuecomment-606523037 Thanks for the review @azagrebin. Merging this PR into `master`, `release-1.10` and `release-1.9`.

[jira] [Commented] (FLINK-16883) No support for log4j2 configuration formats besides properties

2020-03-31 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16883?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17071636#comment-17071636 ] Chesnay Schepler commented on FLINK-16883: -- hmm..I get the idea, but I'm wondering if the

[jira] [Commented] (FLINK-16876) Make TtlTimeProvider configurable when creating keyed state backend

2020-03-31 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16876?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17071635#comment-17071635 ] Yun Tang commented on FLINK-16876: -- [~azagrebin] From my point of view, the different ttl time provider

[GitHub] [flink] zhijiangW commented on a change in pull request #11507: [FLINK-16587] Add basic CheckpointBarrierHandler for unaligned checkpoint

2020-03-31 Thread GitBox
zhijiangW commented on a change in pull request #11507: [FLINK-16587] Add basic CheckpointBarrierHandler for unaligned checkpoint URL: https://github.com/apache/flink/pull/11507#discussion_r400784511 ## File path:

[GitHub] [flink] JingsongLi commented on issue #11574: [FLINK-16859][table-runtime] Introduce FileSystemTableFactory

2020-03-31 Thread GitBox
JingsongLi commented on issue #11574: [FLINK-16859][table-runtime] Introduce FileSystemTableFactory URL: https://github.com/apache/flink/pull/11574#issuecomment-606519531 @flinkbot run travis This is an automated message

[GitHub] [flink] rkhachatryan commented on a change in pull request #11534: [FLINK-16537][network] Implement ResultPartition state recovery for unaligned checkpoint

2020-03-31 Thread GitBox
rkhachatryan commented on a change in pull request #11534: [FLINK-16537][network] Implement ResultPartition state recovery for unaligned checkpoint URL: https://github.com/apache/flink/pull/11534#discussion_r400782576 ## File path:

[GitHub] [flink] flinkbot commented on issue #11578: [RELEASE-1.10][FLINK-16874] Respect the dynamic options when calculating memory opt…

2020-03-31 Thread GitBox
flinkbot commented on issue #11578: [RELEASE-1.10][FLINK-16874] Respect the dynamic options when calculating memory opt… URL: https://github.com/apache/flink/pull/11578#issuecomment-606518441 ## CI report: * 75d844fecd7c9da0db0d252bb5a3f082c6979ceb UNKNOWN Bot

[GitHub] [flink] flinkbot edited a comment on issue #11573: [FLINK-16823][table-planner-blink] Fix TIMESTAMPDIFF/TIMESTAMPADD yie…

2020-03-31 Thread GitBox
flinkbot edited a comment on issue #11573: [FLINK-16823][table-planner-blink] Fix TIMESTAMPDIFF/TIMESTAMPADD yie… URL: https://github.com/apache/flink/pull/11573#issuecomment-606453288 ## CI report: * dfd2474f4258e35613f301ed9daeb9ed3c8a2cb4 Travis:

[jira] [Updated] (FLINK-16883) No support for log4j2 configuration formats besides properties

2020-03-31 Thread Fabian Paul (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16883?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Paul updated FLINK-16883: Description: If `flink.console.sh` is used to start a Flink cluster the env java opts precede

[GitHub] [flink] flinkbot edited a comment on issue #11577: [FLINK-16874] Respect the dynamic options when calculating memory options in taskmanager.sh

2020-03-31 Thread GitBox
flinkbot edited a comment on issue #11577: [FLINK-16874] Respect the dynamic options when calculating memory options in taskmanager.sh URL: https://github.com/apache/flink/pull/11577#issuecomment-606487840 ## CI report: * 8247e253975dd23c4c8804aa4980332d0d58d186 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11507: [FLINK-16587] Add basic CheckpointBarrierHandler for unaligned checkpoint

2020-03-31 Thread GitBox
flinkbot edited a comment on issue #11507: [FLINK-16587] Add basic CheckpointBarrierHandler for unaligned checkpoint URL: https://github.com/apache/flink/pull/11507#issuecomment-603776093 ## CI report: * dee2b337e5e72d8f7b1f5098b74f2958d000fb3c UNKNOWN *

[jira] [Updated] (FLINK-16883) No support for log4j2 configuration formats besides properties

2020-03-31 Thread Fabian Paul (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16883?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Paul updated FLINK-16883: Description: If `flink.console.sh` is used to start a Flink cluster the env java opts precede

[GitHub] [flink] flinkbot edited a comment on issue #11575: [FLINK-16878][e2e][table] Fix dependency shading of table modules test failure after …

2020-03-31 Thread GitBox
flinkbot edited a comment on issue #11575: [FLINK-16878][e2e][table] Fix dependency shading of table modules test failure after … URL: https://github.com/apache/flink/pull/11575#issuecomment-606453461 ## CI report: * 143df1c651acec79142bc90dcf5820695a51f1c3 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11481: [FLINK-13691][Table]Remove deprecated query config

2020-03-31 Thread GitBox
flinkbot edited a comment on issue #11481: [FLINK-13691][Table]Remove deprecated query config URL: https://github.com/apache/flink/pull/11481#issuecomment-602174011 ## CI report: * 7496b16e60235e78f93bb3a8538a1aaf5a5cb0ea Travis:

[GitHub] [flink] zhijiangW commented on a change in pull request #11507: [FLINK-16587] Add basic CheckpointBarrierHandler for unaligned checkpoint

2020-03-31 Thread GitBox
zhijiangW commented on a change in pull request #11507: [FLINK-16587] Add basic CheckpointBarrierHandler for unaligned checkpoint URL: https://github.com/apache/flink/pull/11507#discussion_r400781265 ## File path:

[GitHub] [flink] wuchong commented on issue #11575: [hot-fix] Fix dependency shading of table modules test failure after …

2020-03-31 Thread GitBox
wuchong commented on issue #11575: [hot-fix] Fix dependency shading of table modules test failure after … URL: https://github.com/apache/flink/pull/11575#issuecomment-606517563 @flinkbot run azure This is an automated

[GitHub] [flink] wuchong commented on issue #11575: [hot-fix] Fix dependency shading of table modules test failure after …

2020-03-31 Thread GitBox
wuchong commented on issue #11575: [hot-fix] Fix dependency shading of table modules test failure after … URL: https://github.com/apache/flink/pull/11575#issuecomment-606517476 We have to retrigger the Azure, because `e2e_ci` is failed before `Dependency shading of table modules test`

[GitHub] [flink] Li-Aihua closed pull request #10436: [FLINK-14920] [flink-end-to-end-perf-tests] Set up environment to run performance e2e tests

2020-03-31 Thread GitBox
Li-Aihua closed pull request #10436: [FLINK-14920] [flink-end-to-end-perf-tests] Set up environment to run performance e2e tests URL: https://github.com/apache/flink/pull/10436 This is an automated message from the Apache

[GitHub] [flink] flinkbot edited a comment on issue #11321: [FLINK-15585] [table] Improve function identifier string in plan digest

2020-03-31 Thread GitBox
flinkbot edited a comment on issue #11321: [FLINK-15585] [table] Improve function identifier string in plan digest URL: https://github.com/apache/flink/pull/11321#issuecomment-595208662 ## CI report: * f9764afefd7a2e1a462de4d07a20f1b1d09a5be3 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

2020-03-31 Thread GitBox
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: *

[GitHub] [flink] zhijiangW commented on a change in pull request #11507: [FLINK-16587] Add basic CheckpointBarrierHandler for unaligned checkpoint

2020-03-31 Thread GitBox
zhijiangW commented on a change in pull request #11507: [FLINK-16587] Add basic CheckpointBarrierHandler for unaligned checkpoint URL: https://github.com/apache/flink/pull/11507#discussion_r400780409 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #10436: [FLINK-14920] [flink-end-to-end-perf-tests] Set up environment to run performance e2e tests

2020-03-31 Thread GitBox
flinkbot edited a comment on issue #10436: [FLINK-14920] [flink-end-to-end-perf-tests] Set up environment to run performance e2e tests URL: https://github.com/apache/flink/pull/10436#issuecomment-562103759 ## CI report: * 0dcd1e2f5c7d20a23bbb5699f4e0c6c32583daba Travis:

[GitHub] [flink] zhijiangW commented on a change in pull request #11507: [FLINK-16587] Add basic CheckpointBarrierHandler for unaligned checkpoint

2020-03-31 Thread GitBox
zhijiangW commented on a change in pull request #11507: [FLINK-16587] Add basic CheckpointBarrierHandler for unaligned checkpoint URL: https://github.com/apache/flink/pull/11507#discussion_r400777298 ## File path:

[jira] [Closed] (FLINK-16245) Use a delegating classloader as the user code classloader to prevent class leaks.

2020-03-31 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16245?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-16245. Resolution: Fixed master: b0dff77a85237b76c20c9db4138651f7fd7b8fce

[jira] [Updated] (FLINK-16245) Use a delegating classloader as the user code classloader to prevent class leaks.

2020-03-31 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16245?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-16245: --- Labels: pull-request-available usability (was: usability) > Use a delegating classloader

[jira] [Issue Comment Deleted] (FLINK-16882) NPE when reading hive table with RegexSerde

2020-03-31 Thread linweijiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16882?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] linweijiang updated FLINK-16882: Comment: was deleted (was: Sure, my pleasure) > NPE when reading hive table with RegexSerde >

[GitHub] [flink] zentol merged pull request #11303: [FLINK-16245] Decoupling user classloader from context classloader.

2020-03-31 Thread GitBox
zentol merged pull request #11303: [FLINK-16245] Decoupling user classloader from context classloader. URL: https://github.com/apache/flink/pull/11303 This is an automated message from the Apache Git Service. To respond to

[GitHub] [flink] azagrebin commented on a change in pull request #11545: [FLINK-16742][runtime][dist] Extend and use BashJavaUtils to start JM JVM process and pass JVM memory args

2020-03-31 Thread GitBox
azagrebin commented on a change in pull request #11545: [FLINK-16742][runtime][dist] Extend and use BashJavaUtils to start JM JVM process and pass JVM memory args URL: https://github.com/apache/flink/pull/11545#discussion_r400752292 ## File path:

[GitHub] [flink] azagrebin commented on a change in pull request #11545: [FLINK-16742][runtime][dist] Extend and use BashJavaUtils to start JM JVM process and pass JVM memory args

2020-03-31 Thread GitBox
azagrebin commented on a change in pull request #11545: [FLINK-16742][runtime][dist] Extend and use BashJavaUtils to start JM JVM process and pass JVM memory args URL: https://github.com/apache/flink/pull/11545#discussion_r400749399 ## File path:

[GitHub] [flink] azagrebin commented on a change in pull request #11545: [FLINK-16742][runtime][dist] Extend and use BashJavaUtils to start JM JVM process and pass JVM memory args

2020-03-31 Thread GitBox
azagrebin commented on a change in pull request #11545: [FLINK-16742][runtime][dist] Extend and use BashJavaUtils to start JM JVM process and pass JVM memory args URL: https://github.com/apache/flink/pull/11545#discussion_r400762255 ## File path:

[GitHub] [flink] azagrebin commented on a change in pull request #11545: [FLINK-16742][runtime][dist] Extend and use BashJavaUtils to start JM JVM process and pass JVM memory args

2020-03-31 Thread GitBox
azagrebin commented on a change in pull request #11545: [FLINK-16742][runtime][dist] Extend and use BashJavaUtils to start JM JVM process and pass JVM memory args URL: https://github.com/apache/flink/pull/11545#discussion_r400751296 ## File path:

[jira] [Updated] (FLINK-16561) Resuming Externalized Checkpoint (rocks, incremental, no parallelism change) end-to-end test fails on Azure

2020-03-31 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16561?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-16561: --- Issue Type: Bug (was: Test) > Resuming Externalized Checkpoint (rocks, incremental, no

[jira] [Updated] (FLINK-16878) flink-table-planner contains unwanted dependency org.apiguardian.api

2020-03-31 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16878?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-16878: --- Fix Version/s: 1.11.0 > flink-table-planner contains unwanted dependency

[GitHub] [flink] zhijiangW commented on a change in pull request #11507: [FLINK-16587] Add basic CheckpointBarrierHandler for unaligned checkpoint

2020-03-31 Thread GitBox
zhijiangW commented on a change in pull request #11507: [FLINK-16587] Add basic CheckpointBarrierHandler for unaligned checkpoint URL: https://github.com/apache/flink/pull/11507#discussion_r400766640 ## File path:

[jira] [Updated] (FLINK-16821) Run Kubernetes test failed with invalid named "minikube"

2020-03-31 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16821?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-16821: --- Affects Version/s: 1.10.0 > Run Kubernetes test failed with invalid named "minikube" >

[jira] [Created] (FLINK-16883) No support for log4j2 configuration formats besides properties

2020-03-31 Thread Fabian Paul (Jira)
Fabian Paul created FLINK-16883: --- Summary: No support for log4j2 configuration formats besides properties Key: FLINK-16883 URL: https://issues.apache.org/jira/browse/FLINK-16883 Project: Flink

[jira] [Updated] (FLINK-16883) No support for log4j2 configuration formats besides properties

2020-03-31 Thread Fabian Paul (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16883?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Paul updated FLINK-16883: Description: If `flink.console.sh` is used to start a Flink cluster the env java opts precede

[jira] [Updated] (FLINK-16883) No support for log4j2 configuration formats besides properties

2020-03-31 Thread Fabian Paul (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16883?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Paul updated FLINK-16883: Description: If `flink.console.sh` is used to start a Flink cluster the env java opts precede

[jira] [Commented] (FLINK-16821) Run Kubernetes test failed with invalid named "minikube"

2020-03-31 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17071618#comment-17071618 ] Piotr Nowojski commented on FLINK-16821: Yes, another instance for 1.10:

[GitHub] [flink] rkhachatryan commented on a change in pull request #11534: [FLINK-16537][network] Implement ResultPartition state recovery for unaligned checkpoint

2020-03-31 Thread GitBox
rkhachatryan commented on a change in pull request #11534: [FLINK-16537][network] Implement ResultPartition state recovery for unaligned checkpoint URL: https://github.com/apache/flink/pull/11534#discussion_r400761641 ## File path:

<    1   2   3   4   5   6   >