Re: java.lang.StackOverflowError

I am using flink 1.6.2 on yarn. State backend is rocksdb. > 2020年1月22日 上午10:15，刘建刚 写道： > > I have a flink job which fails occasionally. I am eager to avoid this > problem. Can anyone help me? The error stacktrace is as following: > java.io.IOException: java.lang.StackOverflowError >

java.lang.StackOverflowError

I have a flink job which fails occasionally. I am eager to avoid this problem. Can anyone help me? The error stacktrace is as following: java.io.IOException: java.lang.StackOverflowError at org.apache.flink.runtime.io.network.partition.consumer.InputChannel.checkError(InputChannel.j

Re: [DISCUSS] FLIP-92: JDBC catalog and Postgres catalog

Hi all, I'm happy to see a lot of interest in easing the integration with JDBC data sources. Maybe this could be a rare situation (not in my experience however..) but what if I have to connect to the same type of source (e.g. Mysql) with 2 incompatible version...? How can I load the 2 (or more) con

Re: [DISCUSS] Releasing Flink 1.9.2

Cool, looking forward the first RC of release 1.9.2. Best, Jincheng Hequn Cheng 于2020年1月21日周二 下午10:02写道： > Hi everyone, > > Considering that we are on the finishing line for release-1.10.0 and that > there are no blockers for release-1.9.2, I'm proposing to resume this > discussion. > If there

[jira] [Created] (FLINK-15728) JDBCUpsertOutputFormat does not set bind parameter keyFields in updateStaement

Bhagavan created FLINK-15728: Summary: JDBCUpsertOutputFormat does not set bind parameter keyFields in updateStaement Key: FLINK-15728 URL: https://issues.apache.org/jira/browse/FLINK-15728 Project: Flink

[jira] [Created] (FLINK-15727) Let BashJavaUtils return dynamic configs and JVM parameters in one call

Till Rohrmann created FLINK-15727: - Summary: Let BashJavaUtils return dynamic configs and JVM parameters in one call Key: FLINK-15727 URL: https://issues.apache.org/jira/browse/FLINK-15727 Project: Fl

Call for presentations for ApacheCon North America 2020 now open

Dear Apache enthusiast, (You’re receiving this message because you are subscribed to one or more project mailing lists at the Apache Software Foundation.) The call for presentations for ApacheCon North America 2020 is now open at https://apachecon.com/acna2020/cfp ApacheCon will be held at

Re: [DISCUSS] Releasing Flink 1.9.2

Hi everyone, Considering that we are on the finishing line for release-1.10.0 and that there are no blockers for release-1.9.2, I'm proposing to resume this discussion. If there are no more concerns or any critical issues for releasing 1.9.2, I would like to create the first RC soon :) Best, Hequ

Re: Join of three streams with different frequency

Temporal table functions is supported by both planners, feel free to use any of them. Best, Kurt Dominik Wosiński 于2020年1月21日 周二19:39写道： > Thanksy!! > > I will take a look at the provided links. > Best Regrads, > Dom. > > wt., 21 sty 2020 o 12:35 Piotr Nowojski napisał(a): > > > In Flink Planne

Re: Join of three streams with different frequency

Thanksy!! I will take a look at the provided links. Best Regrads, Dom. wt., 21 sty 2020 o 12:35 Piotr Nowojski napisał(a): > In Flink Planner this functionality is supported and exposed via Temporal > Table Functions [2] and it does support event-time [3]. Only the non > function Temporal Table

Re: Join of three streams with different frequency

In Flink Planner this functionality is supported and exposed via Temporal Table Functions [2] and it does support event-time [3]. Only the non function Temporal Table syntax is supported only by the Blink, but functionality as far as I recall is the same. [2] https://ci.apache.org/projects/fl

[jira] [Created] (FLINK-15726) Fixing error message in StreamExecTableSourceScan

Benoît Paris created FLINK-15726: Summary: Fixing error message in StreamExecTableSourceScan Key: FLINK-15726 URL: https://issues.apache.org/jira/browse/FLINK-15726 Project: Flink Issue Type:

[jira] [Created] (FLINK-15725) Update FlinkKinesisConsumerMigrationTest to restore from 1.10 savepoint

vinoyang created FLINK-15725: Summary: Update FlinkKinesisConsumerMigrationTest to restore from 1.10 savepoint Key: FLINK-15725 URL: https://issues.apache.org/jira/browse/FLINK-15725 Project: Flink

[jira] [Created] (FLINK-15724) Update AbstractNonKeyedOperatorRestoreTestBase to restore from 1.10 savepoint

vinoyang created FLINK-15724: Summary: Update AbstractNonKeyedOperatorRestoreTestBase to restore from 1.10 savepoint Key: FLINK-15724 URL: https://issues.apache.org/jira/browse/FLINK-15724 Project: Flink

[jira] [Created] (FLINK-15722) Update TypeSerializerSnapshotMigrationITCase to restore from 1.10 savepoint

vinoyang created FLINK-15722: Summary: Update TypeSerializerSnapshotMigrationITCase to restore from 1.10 savepoint Key: FLINK-15722 URL: https://issues.apache.org/jira/browse/FLINK-15722 Project: Flink

[jira] [Created] (FLINK-15723) Update AbstractKeyedOperatorRestoreTestBase to restore from 1.10 savepoint

vinoyang created FLINK-15723: Summary: Update AbstractKeyedOperatorRestoreTestBase to restore from 1.10 savepoint Key: FLINK-15723 URL: https://issues.apache.org/jira/browse/FLINK-15723 Project: Flink

Re: Join of three streams with different frequency

Hey, I have considered the Temporal Table Joins, but as far as I know from the docs, it is only currently supported in the Blink Planner and does not currently support event time join, which is why I was trying to find a different solution. Or has anything changed or is my understanding incorrect

[jira] [Created] (FLINK-15721) Update StatefulJobWBroadcastStateMigrationITCase to restore from 1.10 savepoint

vinoyang created FLINK-15721: Summary: Update StatefulJobWBroadcastStateMigrationITCase to restore from 1.10 savepoint Key: FLINK-15721 URL: https://issues.apache.org/jira/browse/FLINK-15721 Project: Flin

[jira] [Created] (FLINK-15720) Update StatefulJobWBroadcastStateMigrationITCase.scala to restore from 1.10 savepoint

vinoyang created FLINK-15720: Summary: Update StatefulJobWBroadcastStateMigrationITCase.scala to restore from 1.10 savepoint Key: FLINK-15720 URL: https://issues.apache.org/jira/browse/FLINK-15720 Project

Re: Join of three streams with different frequency

Hi, You have basically a motivating example between Temporal Table Joins [1]. Please take a look at them. Piotrek [1] https://ci.apache.org/projects/flink/flink-docs-stable/dev/table/streaming/temporal_tables.html

[jira] [Created] (FLINK-15719) Exceptions when using scala types directly with the State Process API

Ying Z created FLINK-15719: -- Summary: Exceptions when using scala types directly with the State Process API Key: FLINK-15719 URL: https://issues.apache.org/jira/browse/FLINK-15719 Project: Flink Is

[jira] [Created] (FLINK-15718) Update StatefulJobSavepointMigrationITCase to restore from 1.10 savepoint

vinoyang created FLINK-15718: Summary: Update StatefulJobSavepointMigrationITCase to restore from 1.10 savepoint Key: FLINK-15718 URL: https://issues.apache.org/jira/browse/FLINK-15718 Project: Flink

[jira] [Created] (FLINK-15716) Update WindowOperatorMigrationTest to restore from 1.10 savepoint

vinoyang created FLINK-15716: Summary: Update WindowOperatorMigrationTest to restore from 1.10 savepoint Key: FLINK-15716 URL: https://issues.apache.org/jira/browse/FLINK-15716 Project: Flink Is

[jira] [Created] (FLINK-15717) Update StatefulJobSavepointMigrationITCase.scala to restore from 1.10 savepoint

vinoyang created FLINK-15717: Summary: Update StatefulJobSavepointMigrationITCase.scala to restore from 1.10 savepoint Key: FLINK-15717 URL: https://issues.apache.org/jira/browse/FLINK-15717 Project: Flin

[jira] [Created] (FLINK-15715) Update ContinuousFileProcessingMigrationTest to restore from 1.10 savepoint

vinoyang created FLINK-15715: Summary: Update ContinuousFileProcessingMigrationTest to restore from 1.10 savepoint Key: FLINK-15715 URL: https://issues.apache.org/jira/browse/FLINK-15715 Project: Flink

[jira] [Created] (FLINK-15714) Update FlinkKafkaProducerMigrationTest to restore from 1.10 savepoint

vinoyang created FLINK-15714: Summary: Update FlinkKafkaProducerMigrationTest to restore from 1.10 savepoint Key: FLINK-15714 URL: https://issues.apache.org/jira/browse/FLINK-15714 Project: Flink

[jira] [Created] (FLINK-15713) Update FlinkKafkaProducerMigrationOperatorTest to restore from 1.10 savepoint

vinoyang created FLINK-15713: Summary: Update FlinkKafkaProducerMigrationOperatorTest to restore from 1.10 savepoint Key: FLINK-15713 URL: https://issues.apache.org/jira/browse/FLINK-15713 Project: Flink

[jira] [Created] (FLINK-15712) Update FlinkKafkaConsumerBaseMigrationTest to restore from 1.10 savepoint

vinoyang created FLINK-15712: Summary: Update FlinkKafkaConsumerBaseMigrationTest to restore from 1.10 savepoint Key: FLINK-15712 URL: https://issues.apache.org/jira/browse/FLINK-15712 Project: Flink

[jira] [Created] (FLINK-15711) Update FlinkKafkaProducer011MigrationTest to restore from 1.10 savepoint

vinoyang created FLINK-15711: Summary: Update FlinkKafkaProducer011MigrationTest to restore from 1.10 savepoint Key: FLINK-15711 URL: https://issues.apache.org/jira/browse/FLINK-15711 Project: Flink

[jira] [Created] (FLINK-15710) Update BucketingSinkMigrationTest to restore from 1.10 savepoint

vinoyang created FLINK-15710: Summary: Update BucketingSinkMigrationTest to restore from 1.10 savepoint Key: FLINK-15710 URL: https://issues.apache.org/jira/browse/FLINK-15710 Project: Flink Iss

[jira] [Created] (FLINK-15709) Update CEPMigrationTest to restore from 1.10 savepoint

vinoyang created FLINK-15709: Summary: Update CEPMigrationTest to restore from 1.10 savepoint Key: FLINK-15709 URL: https://issues.apache.org/jira/browse/FLINK-15709 Project: Flink Issue Type: Su

[jira] [Created] (FLINK-15708) Add MigrationVersion.v1_10

vinoyang created FLINK-15708: Summary: Add MigrationVersion.v1_10 Key: FLINK-15708 URL: https://issues.apache.org/jira/browse/FLINK-15708 Project: Flink Issue Type: Sub-task Components:

[jira] [Created] (FLINK-15707) Update state migration tests for Flink 1.10

vinoyang created FLINK-15707: Summary: Update state migration tests for Flink 1.10 Key: FLINK-15707 URL: https://issues.apache.org/jira/browse/FLINK-15707 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-15706) LastValueAggFunctionWithOrderTest compilation error due to incompatible types

Yu Li created FLINK-15706: - Summary: LastValueAggFunctionWithOrderTest compilation error due to incompatible types Key: FLINK-15706 URL: https://issues.apache.org/jira/browse/FLINK-15706 Project: Flink

[jira] [Created] (FLINK-15705) testEventTimeSlidingGroupWindowOverTimeOverlappingSplitPane Job execution failed.

Piotr Nowojski created FLINK-15705: -- Summary: testEventTimeSlidingGroupWindowOverTimeOverlappingSplitPane Job execution failed. Key: FLINK-15705 URL: https://issues.apache.org/jira/browse/FLINK-15705