[jira] [Created] (FLINK-18372) NullPointerException can happen in SlotPoolImpl#maybeRemapOrphanedAllocation

Zhu Zhu created FLINK-18372: --- Summary: NullPointerException can happen in SlotPoolImpl#maybeRemapOrphanedAllocation Key: FLINK-18372 URL: https://issues.apache.org/jira/browse/FLINK-18372 Project: Flink

Re: [DISCUSS] Upgrade HBase connector to 2.2.x

+1 to support HBase 2.x But not sure about dropping support for 1.4.x I cc'ed to user@ and user-zh@ to hear more feedback from users. Best, Jark On Thu, 18 Jun 2020 at 21:25, Gyula Fóra wrote: > Hi All! > > I would like to revive an old ticket >

[jira] [Created] (FLINK-18371) NPE of "org.apache.flink.table.data.util.DataFormatConverters$BigDecimalConverter.toExternalImpl(DataFormatConverters.java:680)"

xiaojin.wy created FLINK-18371: -- Summary: NPE of "org.apache.flink.table.data.util.DataFormatConverters$BigDecimalConverter.toExternalImpl(DataFormatConverters.java:680)" Key: FLINK-18371 URL:

S3 Checkpointing taking long time with stateful operations

Hi, We are running a stateful application in Flink with RocksDB as backend and set incremental state to true with checkpoints written to S3. * 10 task managers each with 2 task slots * Checkpoint interval 3 minutes * Checkpointing mode – At-least once processing After running app

Re: [ANNOUNCE] Apache Flink 1.11.0, release candidate #2

Thanks a lot for creating another RC. The good news first: WordCount works on my Mac :) I didn't find this information in the email: This is the commit the RC is based on: https://github.com/apache/flink/commit/c4132de4a50ab9b8f653c69af1ba15af44ff29a2 Additionally, I've created [1] a docker

[jira] [Created] (FLINK-18370) Test Flink on Azure-hosted VMs nightly

Robert Metzger created FLINK-18370: -- Summary: Test Flink on Azure-hosted VMs nightly Key: FLINK-18370 URL: https://issues.apache.org/jira/browse/FLINK-18370 Project: Flink Issue Type:

[jira] [Created] (FLINK-18369) TableEnvironmentITCase.testStatementSetWithSameSinkTableNames failed on azure

Piotr Nowojski created FLINK-18369: -- Summary: TableEnvironmentITCase.testStatementSetWithSameSinkTableNames failed on azure Key: FLINK-18369 URL: https://issues.apache.org/jira/browse/FLINK-18369

[jira] [Created] (FLINK-18368) HadoopRecoverableWriterOldHadoopWithNoTruncateSupportTest.createHDFS fails with "Running in secure mode, but config doesn't have a keytab"

Robert Metzger created FLINK-18368: -- Summary: HadoopRecoverableWriterOldHadoopWithNoTruncateSupportTest.createHDFS fails with "Running in secure mode, but config doesn't have a keytab" Key: FLINK-18368 URL:

Re: [DISCUSS] Re-renaming "Flink Master" back to JobManager

+1 I've found the term Flink Master a tad bit confusing myself, in the past, as it's not used consistently throughout the documentation (as you mention). Thanks for following up on this, Aljoscha! On Wed, Jun 17, 2020 at 5:16 PM Robert Metzger wrote: > Thanks a lot for looking into this! > >

[DISCUSS] Upgrade HBase connector to 2.2.x

Hi All! I would like to revive an old ticket and discussion around upgrading the HBase version of the connector. The current HBase version is 1.4.3 which is over 2 years old at this point and incompatible with the newer HBase versions used at

[jira] [Created] (FLINK-18367) Flink HA Mode in Kubernetes. Fencing token not set

An created FLINK-18367: -- Summary: Flink HA Mode in Kubernetes. Fencing token not set Key: FLINK-18367 URL: https://issues.apache.org/jira/browse/FLINK-18367 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-18366) Track E2E test durations centrally

Robert Metzger created FLINK-18366: -- Summary: Track E2E test durations centrally Key: FLINK-18366 URL: https://issues.apache.org/jira/browse/FLINK-18366 Project: Flink Issue Type:

Re: [ANNOUNCE] Apache Flink 1.11.0, release candidate #2

Hi all, Apache Flink-1.11.0-RC2 has been created. It has all the artifacts that we would typically have for a release. This RC might have still a couple of missing licensing notices (like the one mentioned by Jingsong Li), but as for today morning, there were no open release blocking bugs. No

[jira] [Created] (FLINK-18365) The same sql in a batch env and a streaming env has different value.

xiaojin.wy created FLINK-18365: -- Summary: The same sql in a batch env and a streaming env has different value. Key: FLINK-18365 URL: https://issues.apache.org/jira/browse/FLINK-18365 Project: Flink

[jira] [Created] (FLINK-18364) A streaming sql cause "org.apache.flink.table.api.ValidationException: Type TIMESTAMP(6) of table field 'rowtime' does not match with the physical type TIMESTAMP(3) of t

xiaojin.wy created FLINK-18364: -- Summary: A streaming sql cause "org.apache.flink.table.api.ValidationException: Type TIMESTAMP(6) of table field 'rowtime' does not match with the physical type TIMESTAMP(3) of the 'rowtime' field of the TableSink

Re: [ANNOUNCE] Yu Li is now part of the Flink PMC

Congrats! :-) – Ufuk On Thu, Jun 18, 2020 at 9:47 AM Marta Paes Moreira wrote: > Awesome! Congratulations, Yu! > > On Thu, Jun 18, 2020 at 9:16 AM Zhu Zhu wrote: > > > Congratulations! > > > > Thanks, > > Zhu Zhu > > > > Guowei Ma 于2020年6月18日周四 上午10:41写道： > > > > > Congratulations , Yu! > >

[jira] [Created] (FLINK-18363) Add user classloader to context in DeSerializationSchema

Timo Walther created FLINK-18363: Summary: Add user classloader to context in DeSerializationSchema Key: FLINK-18363 URL: https://issues.apache.org/jira/browse/FLINK-18363 Project: Flink

[jira] [Created] (FLINK-18362) Shipping jdk by shipping archive

Noah created FLINK-18362: Summary: Shipping jdk by shipping archive Key: FLINK-18362 URL: https://issues.apache.org/jira/browse/FLINK-18362 Project: Flink Issue Type: Wish Affects Versions:

[jira] [Created] (FLINK-18361) Support username and password options for new Elasticsearch connector

Yangze Guo created FLINK-18361: -- Summary: Support username and password options for new Elasticsearch connector Key: FLINK-18361 URL: https://issues.apache.org/jira/browse/FLINK-18361 Project: Flink

Re: [DISCUSS] Sql-client lack support for new features

+1 for #1 I think this is what we are currently doing, that forward SQL statements to TableEnv#executeSql, e.g. FLINK-17113, FLINK-18059. But IMO the SQL CLI specific statements (EXIT, QUIT) should still stay only in SQL CLI. Another idea is that, the reviewer/committer should check tests are

[jira] [Created] (FLINK-18360) Flink History Server doesn't show correctly table of Completed jobs when there are no archived jobs are in the archive directory

Jindrich Vimr created FLINK-18360: - Summary: Flink History Server doesn't show correctly table of Completed jobs when there are no archived jobs are in the archive directory Key: FLINK-18360 URL:

[jira] [Created] (FLINK-18359) Improve error-log strategy for Elasticsearch sink for large data documentId conflict when using create mode for `insert ignore` semantics

rinkako created FLINK-18359: --- Summary: Improve error-log strategy for Elasticsearch sink for large data documentId conflict when using create mode for `insert ignore` semantics Key: FLINK-18359 URL:

Re: [ANNOUNCE] Yu Li is now part of the Flink PMC

Awesome! Congratulations, Yu! On Thu, Jun 18, 2020 at 9:16 AM Zhu Zhu wrote: > Congratulations! > > Thanks, > Zhu Zhu > > Guowei Ma 于2020年6月18日周四 上午10:41写道： > > > Congratulations , Yu! > > Best, > > Guowei > > > > > > Yang Wang 于2020年6月18日周四 上午10:36写道： > > > > > Congratulations , Yu! > > > >

Re: [DISCUSS] Sql-client lack support for new features

Thanks Jingsong for bringing up the discussion. Perhaps we can do both #1 and #2? I like the idea that SQL Client should just forward SQL statements to TableEnvironment. IIUC, with TableEnvironment::executeSql in place, most statements can be forwarded. Only a very limited set of statements need

[jira] [Created] (FLINK-18358) TableEnvironmentITCase.testSqlUpdateAndToDataSetWithTableSource:245 unstable: result mismatch

Robert Metzger created FLINK-18358: -- Summary: TableEnvironmentITCase.testSqlUpdateAndToDataSetWithTableSource:245 unstable: result mismatch Key: FLINK-18358 URL:

Re: [DISCUSS] Sql-client lack support for new features

Thanks Jingsong for bringing up this discussion! +1 for #1 I think it would always be a good practice to have a unify implementation for two different user-facing API of the same functionality. The divergence of two different implementations always bothers users. In the past, users complains a

[DISCUSS] Sql-client lack support for new features

Hi all, I'd like to start a discussion for the new features lacking support of Sql-client. I've seen the new DDL syntax that SQL client lacks support for many times. For every new DDL syntax, we need to add support in sql-client. Add a corresponding SqlCommand in sql-client, otherwise this DDL

Re: [ANNOUNCE] Yu Li is now part of the Flink PMC

Congratulations! Thanks, Zhu Zhu Guowei Ma 于2020年6月18日周四 上午10:41写道： > Congratulations , Yu! > Best, > Guowei > > > Yang Wang 于2020年6月18日周四 上午10:36写道： > > > Congratulations , Yu! > > > > Best, > > Yang > > > > Piotr Nowojski 于2020年6月17日周三 下午9:21写道： > > > > > Congratulations :) > > > > > > >

[jira] [Created] (FLINK-18357) ContinuousFileReaderOperator checkpoint timeout when files and directories get larger

Jark Wu created FLINK-18357: --- Summary: ContinuousFileReaderOperator checkpoint timeout when files and directories get larger Key: FLINK-18357 URL: https://issues.apache.org/jira/browse/FLINK-18357 Project:

[jira] [Created] (FLINK-18356) Exit code 137 returned from process when testing pyflink

Piotr Nowojski created FLINK-18356: -- Summary: Exit code 137 returned from process when testing pyflink Key: FLINK-18356 URL: https://issues.apache.org/jira/browse/FLINK-18356 Project: Flink