[jira] [Created] (FLINK-20482) Support Map Operation in Python Table API

2020-12-03 Thread Huang Xingbo (Jira)
Huang Xingbo created FLINK-20482: Summary: Support Map Operation in Python Table API Key: FLINK-20482 URL: https://issues.apache.org/jira/browse/FLINK-20482 Project: Flink Issue Type:

[jira] [Created] (FLINK-20481) java.lang.ClassCastException: java.lang.Long cannot be cast to java.lang.Integer

2020-12-03 Thread zhisheng (Jira)
zhisheng created FLINK-20481: Summary: java.lang.ClassCastException: java.lang.Long cannot be cast to java.lang.Integer Key: FLINK-20481 URL: https://issues.apache.org/jira/browse/FLINK-20481 Project:

[jira] [Created] (FLINK-20480) Methods from CheckpointedFunction interface in FlinkKafkaConsumerBase are set to final

2020-12-03 Thread lidesheng (Jira)
lidesheng created FLINK-20480: - Summary: Methods from CheckpointedFunction interface in FlinkKafkaConsumerBase are set to final Key: FLINK-20480 URL: https://issues.apache.org/jira/browse/FLINK-20480

[jira] [Created] (FLINK-20479) Support Row-based Operations in Python Table API

2020-12-03 Thread Huang Xingbo (Jira)
Huang Xingbo created FLINK-20479: Summary: Support Row-based Operations in Python Table API Key: FLINK-20479 URL: https://issues.apache.org/jira/browse/FLINK-20479 Project: Flink Issue Type:

Re: [VOTE] Release 1.12.0, release candidate #3

2020-12-03 Thread Xintong Song
+1 (non-binding) - Verified checksums and signatures - No binaries found in source archive - Build from source - Tried a couple of example jobs in various deployment mode - Local - Standalone - Native Kubernetes Application - Native Kubernetes Session -

Re: [DISCUSS] Releasing Apache Flink 1.11.3

2020-12-03 Thread Xintong Song
Updates on the release progress. - FLIP-27 is stabilizing on the master branch. Becket is working on the final backportings, which is estimated to be finished this weekend. - There's a new blocker FLINK-20442, a license problem discovered during the 1.12.0 RC2 testings, which is already fixed for

[jira] [Created] (FLINK-20478) Show "Optimized Execution Plan" instead of "Physical Execution Plan" in explain result

2020-12-03 Thread godfrey he (Jira)
godfrey he created FLINK-20478: -- Summary: Show "Optimized Execution Plan" instead of "Physical Execution Plan" in explain result Key: FLINK-20478 URL: https://issues.apache.org/jira/browse/FLINK-20478

[jira] [Created] (FLINK-20477) Maven: Could not find the selected project in the reactor: flink-shaded-netty-tcnative-static

2020-12-03 Thread Huang Xingbo (Jira)
Huang Xingbo created FLINK-20477: Summary: Maven: Could not find the selected project in the reactor: flink-shaded-netty-tcnative-static Key: FLINK-20477 URL: https://issues.apache.org/jira/browse/FLINK-20477

[jira] [Created] (FLINK-20476) New File Sink end-to-end test Failed

2020-12-03 Thread Huang Xingbo (Jira)
Huang Xingbo created FLINK-20476: Summary: New File Sink end-to-end test Failed Key: FLINK-20476 URL: https://issues.apache.org/jira/browse/FLINK-20476 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-20475) Broken Link in gettingStarted.zh.md

2020-12-03 Thread Huang Xingbo (Jira)
Huang Xingbo created FLINK-20475: Summary: Broken Link in gettingStarted.zh.md Key: FLINK-20475 URL: https://issues.apache.org/jira/browse/FLINK-20475 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-20474) flink cep results of doc is not right

2020-12-03 Thread jackylau (Jira)
jackylau created FLINK-20474: Summary: flink cep results of doc is not right Key: FLINK-20474 URL: https://issues.apache.org/jira/browse/FLINK-20474 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-20473) when get metrics option, its hard to see the full name unless u choosed

2020-12-03 Thread tonychan (Jira)
tonychan created FLINK-20473: Summary: when get metrics option, its hard to see the full name unless u choosed Key: FLINK-20473 URL: https://issues.apache.org/jira/browse/FLINK-20473 Project: Flink

[jira] [Created] (FLINK-20472) Change quickstarts to have a dependency on "flink-dist"

2020-12-03 Thread Stephan Ewen (Jira)
Stephan Ewen created FLINK-20472: Summary: Change quickstarts to have a dependency on "flink-dist" Key: FLINK-20472 URL: https://issues.apache.org/jira/browse/FLINK-20472 Project: Flink

[jira] [Created] (FLINK-20471) flink1.10SQL中decimal精度溢出返回null的问题

2020-12-03 Thread sadfdddd (Jira)
sadf created FLINK-20471: Summary: flink1.10SQL中decimal精度溢出返回null的问题 Key: FLINK-20471 URL: https://issues.apache.org/jira/browse/FLINK-20471 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-20470) MissingNode can't be casted to ObjectNode when deserializing JSON

2020-12-03 Thread Jark Wu (Jira)
Jark Wu created FLINK-20470: --- Summary: MissingNode can't be casted to ObjectNode when deserializing JSON Key: FLINK-20470 URL: https://issues.apache.org/jira/browse/FLINK-20470 Project: Flink

[jira] [Created] (FLINK-20469) Enable TaskManager start and terminate in MiniCluster

2020-12-03 Thread Andrey Zagrebin (Jira)
Andrey Zagrebin created FLINK-20469: --- Summary: Enable TaskManager start and terminate in MiniCluster Key: FLINK-20469 URL: https://issues.apache.org/jira/browse/FLINK-20469 Project: Flink

Re: [VOTE] Release 1.12.0, release candidate #3

2020-12-03 Thread Rui Li
+1 (non-binding) Built from source and verified hive connector tests for different hive versions. Setup a cluster to connect to a real hive warehouse and run some queries successfully. On Thu, Dec 3, 2020 at 8:44 PM Xingbo Huang wrote: > +1 (non-binding) > > Checks: > 1. verified checksums and

Re: [VOTE] Release 1.12.0, release candidate #3

2020-12-03 Thread Xingbo Huang
+1 (non-binding) Checks: 1. verified checksums and signatures 2. build Flink with Scala 2.11 3. pip install pyflink in MacOS/CentOS under py35,py36,py37,py38 4. test Pandas UDAF/General UDAF/Python DataStream MapFunction 5. start standalone cluster and submit a python udf job. 6. verified

[jira] [Created] (FLINK-20468) Enable leadership control in MiniCluster to test JM failover

2020-12-03 Thread Andrey Zagrebin (Jira)
Andrey Zagrebin created FLINK-20468: --- Summary: Enable leadership control in MiniCluster to test JM failover Key: FLINK-20468 URL: https://issues.apache.org/jira/browse/FLINK-20468 Project: Flink

[jira] [Created] (FLINK-20467) Fix the Example in Python DataStream Doc

2020-12-03 Thread Huang Xingbo (Jira)
Huang Xingbo created FLINK-20467: Summary: Fix the Example in Python DataStream Doc Key: FLINK-20467 URL: https://issues.apache.org/jira/browse/FLINK-20467 Project: Flink Issue Type: Bug

Re: [VOTE] Release 1.12.0, release candidate #3

2020-12-03 Thread Robert Metzger
There's now a pull request for the announcement blog post, please help checking it: https://github.com/apache/flink-web/pull/397 On Thu, Dec 3, 2020 at 9:03 AM Robert Metzger wrote: > +1 (binding) > > > Checks: > - checksums seem correct > - source archive code compiles > - Compiled a test job

Re: Running Flink job as a rest

2020-12-03 Thread Chesnay Schepler
What you are asking for is an HTTP(s) source. This currently does not exist for Flink, so you would have to implement it yourself. Additionally you would have to figure out the host on which the source runs on yourself. It may be easier to setup a separate HTTP(s) server that accepts data,

[jira] [Created] (FLINK-20466) Table 'EXPR$1' not found with UNION ALL

2020-12-03 Thread wxmimperio (Jira)
wxmimperio created FLINK-20466: -- Summary: Table 'EXPR$1' not found with UNION ALL Key: FLINK-20466 URL: https://issues.apache.org/jira/browse/FLINK-20466 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-20465) Fail globally when not resuming from the latest checkpoint in regional failover

2020-12-03 Thread Till Rohrmann (Jira)
Till Rohrmann created FLINK-20465: - Summary: Fail globally when not resuming from the latest checkpoint in regional failover Key: FLINK-20465 URL: https://issues.apache.org/jira/browse/FLINK-20465

[jira] [Created] (FLINK-20464) Some Table examples have wrong program-class defined

2020-12-03 Thread Dawid Wysakowicz (Jira)
Dawid Wysakowicz created FLINK-20464: Summary: Some Table examples have wrong program-class defined Key: FLINK-20464 URL: https://issues.apache.org/jira/browse/FLINK-20464 Project: Flink

Re: [VOTE] Release 1.12.0, release candidate #3

2020-12-03 Thread Robert Metzger
+1 (binding) Checks: - checksums seem correct - source archive code compiles - Compiled a test job against the staging repository - launched a standalone cluster, ran some test jobs against it - quickstart contains correct version - regular jars contain correct NOTICE file - Looked a bit over