Re: Flink 1.10 exception : Unable to instantiate java compiler

Same problem! On Thu, Feb 27, 2020 at 11:10 PM LakeShen wrote: > Hi community, > now I am using the flink 1.10 to run the flink task > ,cluster type is yarn . I use commandline to submit my flink job , the > commandline just like this : > > flink run -m yarn-cluster

Flink 1.10 exception : Unable to instantiate java compiler

Hi community, now I am using the flink 1.10 to run the flink task ,cluster type is yarn . I use commandline to submit my flink job , the commandline just like this : flink run -m yarn-cluster --allowNonRestoredState -c xxx.xxx.xx flink-stream-xxx.jar Bug there is a exception

Re: [VOTE] FLIP-84: Improve & Refactor API of TableEnvironment

Nice!! Sent from my iPhone > On Feb 27, 2020, at 9:03 PM, godfrey he wrote: > > Hi kant, yes. We hope to deprecate the methods which confuse users ASAP. > > Bests, > godfrey > > kant kodali 于2020年2月28日周五 上午11:17写道： > >> Is this targeted towards Flink 1.11? >> >>> On Thu, Feb 27, 2020 at

Re: [VOTE] FLIP-99: Make Max Exception Configurable

Thanks all for the votes. So far, we have - 3 binding +1 votes (Jark, Till, Gary) - 3 non-binding +1 votes (CongXian BenChao, zoudan) - No -1 votes The voting time has past and there are enough +1 votes to consider the FLIP-99 approved. Thank you all. Gary Yao 于2020年2月28日周五 上午12:03写道： > +1

[jira] [Created] (FLINK-16325) A connection check is required, and it needs to be reopened when the JDBC connection is interrupted

renjianxu created FLINK-16325: - Summary: A connection check is required, and it needs to be reopened when the JDBC connection is interrupted Key: FLINK-16325 URL: https://issues.apache.org/jira/browse/FLINK-16325

[jira] [Created] (FLINK-16324) Checkpoint tasks progress would display 100% in web UI even not all tasks finished

Yun Tang created FLINK-16324: Summary: Checkpoint tasks progress would display 100% in web UI even not all tasks finished Key: FLINK-16324 URL: https://issues.apache.org/jira/browse/FLINK-16324 Project:

[jira] [Created] (FLINK-16323) Support to join a static table in streaming mode

Jark Wu created FLINK-16323: --- Summary: Support to join a static table in streaming mode Key: FLINK-16323 URL: https://issues.apache.org/jira/browse/FLINK-16323 Project: Flink Issue Type: New

Re: [VOTE] FLIP-84: Improve & Refactor API of TableEnvironment

Hi kant, yes. We hope to deprecate the methods which confuse users ASAP. Bests, godfrey kant kodali 于2020年2月28日周五 上午11:17写道： > Is this targeted towards Flink 1.11? > > On Thu, Feb 27, 2020 at 6:32 PM Kurt Young wrote: > > > +1 (binding) > > > > Best, > > Kurt > > > > > > On Fri, Feb 28, 2020

Re: [VOTE] FLIP-84: Improve & Refactor API of TableEnvironment

Is this targeted towards Flink 1.11? On Thu, Feb 27, 2020 at 6:32 PM Kurt Young wrote: > +1 (binding) > > Best, > Kurt > > > On Fri, Feb 28, 2020 at 9:15 AM Terry Wang wrote: > > > I look through the whole design and it’s a big improvement of usability > on > > TableEnvironment’s api. > > > >

[jira] [Created] (FLINK-16322) wrong result after filter push down in parquet table source

godfrey he created FLINK-16322: -- Summary: wrong result after filter push down in parquet table source Key: FLINK-16322 URL: https://issues.apache.org/jira/browse/FLINK-16322 Project: Flink

Re: [VOTE] FLIP-84: Improve & Refactor API of TableEnvironment

+1 (binding) Best, Kurt On Fri, Feb 28, 2020 at 9:15 AM Terry Wang wrote: > I look through the whole design and it’s a big improvement of usability on > TableEnvironment’s api. > > +1 (non-binding) > > Best, > Terry Wang > > > > > 2020年2月27日 14:59，godfrey he 写道： > > > > Hi everyone, > > > >

Re: [DISCUSS] FLINK-16194: Refactor the Kubernetes architecture design

Thanks very much Yang Wang. Cheers, Canbin Zheng Yang Wang 于2020年2月27日周四 下午9:19写道： > Great work! I could help to review and test. > > Best, > Yang > > Canbin Zheng 于2020年2月27日周四 下午4:24写道： > >> Hi, everyone, >> >> I have pushed a PR for this >>

Re: [VOTE] FLIP-84: Improve & Refactor API of TableEnvironment

I look through the whole design and it’s a big improvement of usability on TableEnvironment’s api. +1 (non-binding) Best, Terry Wang > 2020年2月27日 14:59，godfrey he 写道： > > Hi everyone, > > I'd like to start the vote of FLIP-84[1], which proposes to deprecate some > old APIs and introduce

[jira] [Created] (FLINK-16321) Refactor HttpFunction to improve testability

Igal Shilman created FLINK-16321: Summary: Refactor HttpFunction to improve testability Key: FLINK-16321 URL: https://issues.apache.org/jira/browse/FLINK-16321 Project: Flink Issue Type:

[VOTE] FLIP-93: JDBC catalog and Postgres catalog

Hi all, I'd like to kick off the vote for FLIP-93 [1] to add JDBC catalog and Postgres catalog. The vote will last for at least 72 hours, following the consensus voting protocol. [1] https://cwiki.apache.org/confluence/display/FLINK/FLIP-93%3A+JDBC+catalog+and+Postgres+catalog Discussion

[jira] [Created] (FLINK-16319) Pubsub-/Broadcast implementation

Dan Pettersson created FLINK-16319: -- Summary: Pubsub-/Broadcast implementation Key: FLINK-16319 URL: https://issues.apache.org/jira/browse/FLINK-16319 Project: Flink Issue Type: Improvement

Re: [VOTE] FLIP-99: Make Max Exception Configurable

+1 (binding) Best, Gary On Thu, Feb 20, 2020 at 10:39 AM Yadong Xie wrote: > Hi all > > I want to start the vote for FLIP-99, which proposes to make the max > exception configurable in web UI. > > To help everyone better understand the proposal, we spent some efforts on > making an online POC

Re: [DISCUSS] FLIP-76: Unaligned checkpoints

Hi Yu, Re 4. Dynamic switching between unaligned and aligned checkpoints based on some kind of thresholds (timeout, or checkpoint size) is definitely one of the very first improvement that we want to tackle after implementing the MVP. Depending on the time constraints, dynamic switching can

[jira] [Created] (FLINK-16318) PersistedTable and AppendingBufferAccessor use different type system then Persisted Value

Seth Wiesman created FLINK-16318: Summary: PersistedTable and AppendingBufferAccessor use different type system then Persisted Value Key: FLINK-16318 URL: https://issues.apache.org/jira/browse/FLINK-16318

[jira] [Created] (FLINK-16317) Implement missing features for MultipleInputStreamOperator

Piotr Nowojski created FLINK-16317: -- Summary: Implement missing features for MultipleInputStreamOperator Key: FLINK-16317 URL: https://issues.apache.org/jira/browse/FLINK-16317 Project: Flink

[jira] [Created] (FLINK-16316) Provide new base class for StreamOperators

Piotr Nowojski created FLINK-16316: -- Summary: Provide new base class for StreamOperators Key: FLINK-16316 URL: https://issues.apache.org/jira/browse/FLINK-16316 Project: Flink Issue Type:

[jira] [Created] (FLINK-16315) throw JsonMappingException when using BatchTableEnvironment#explain to get the plan of sql with constant string

godfrey he created FLINK-16315: -- Summary: throw JsonMappingException when using BatchTableEnvironment#explain to get the plan of sql with constant string Key: FLINK-16315 URL:

Re: [VOTE] FLIP-102: Add More Metrics to TaskManager

Thinking a bit more about the problem whether to report the aggregated memory statistics or the individual slot statistics, I think reporting it on a per slot basis won't work nicely together with FLIP-56 (dynamic slot allocation). The problem is that with FLIP-56, we will no longer have dedicated

[jira] [Created] (FLINK-16314) Revisit FlinkTypeFactory

Timo Walther created FLINK-16314: Summary: Revisit FlinkTypeFactory Key: FLINK-16314 URL: https://issues.apache.org/jira/browse/FLINK-16314 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-16313) flink-state-processor-api: surefire execution unstable on Azure

Robert Metzger created FLINK-16313: -- Summary: flink-state-processor-api: surefire execution unstable on Azure Key: FLINK-16313 URL: https://issues.apache.org/jira/browse/FLINK-16313 Project: Flink

Re: [VOTE] FLIP-100: Add Attempt Information

I think your proposal is better because then we don't have to bump the REST API version. Cheers, Till On Thu, Feb 27, 2020 at 8:02 AM Yadong Xie wrote: > Hi Till > > We keep response a flattened SubtaskTimeInfo and an array of > SubtaskTimeInfo to keep the restAPI backward compatible, since

[jira] [Created] (FLINK-16312) Stateful Function's HttpFunction falls into endless loop resending 0-sized batch requests

Tzu-Li (Gordon) Tai created FLINK-16312: --- Summary: Stateful Function's HttpFunction falls into endless loop resending 0-sized batch requests Key: FLINK-16312 URL:

[jira] [Created] (FLINK-16311) PersistedAppendingBuffer state primitive has incorrect contracts for view() method

Tzu-Li (Gordon) Tai created FLINK-16311: --- Summary: PersistedAppendingBuffer state primitive has incorrect contracts for view() method Key: FLINK-16311 URL: https://issues.apache.org/jira/browse/FLINK-16311

[jira] [Created] (FLINK-16310) Javadoc of AppendingState.get() contradicts with behavior of UserFacingListState

Tzu-Li (Gordon) Tai created FLINK-16310: --- Summary: Javadoc of AppendingState.get() contradicts with behavior of UserFacingListState Key: FLINK-16310 URL: https://issues.apache.org/jira/browse/FLINK-16310

Re: [DISCUSS] FLINK-16194: Refactor the Kubernetes architecture design

Great work! I could help to review and test. Best, Yang Canbin Zheng 于2020年2月27日周四 下午4:24写道： > Hi, everyone, > > I have pushed a PR for this > issue, looking forward to your feedback. > > > Cheers, > Canbin Zheng > > Canbin Zheng 于2020年2月26日周三

[jira] [Created] (FLINK-16309) ElasticSearch 7 connector is missing in SQL connector list

Fabian Hueske created FLINK-16309: - Summary: ElasticSearch 7 connector is missing in SQL connector list Key: FLINK-16309 URL: https://issues.apache.org/jira/browse/FLINK-16309 Project: Flink

[jira] [Created] (FLINK-16308) SQL connector download links are broken

Fabian Hueske created FLINK-16308: - Summary: SQL connector download links are broken Key: FLINK-16308 URL: https://issues.apache.org/jira/browse/FLINK-16308 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-16307) LocalStandaloneFlinkResource should use Dist#startFlinkCluster

Chesnay Schepler created FLINK-16307: Summary: LocalStandaloneFlinkResource should use Dist#startFlinkCluster Key: FLINK-16307 URL: https://issues.apache.org/jira/browse/FLINK-16307 Project:

[jira] [Created] (FLINK-16306) Validate YARN session state before job submission

Daniel Laszlo Magyar created FLINK-16306: Summary: Validate YARN session state before job submission Key: FLINK-16306 URL: https://issues.apache.org/jira/browse/FLINK-16306 Project: Flink

[jira] [Created] (FLINK-16305) FlinkYarnSessionClI ignores target executor and uses yarn-session if YARN properties file is present

Daniel Laszlo Magyar created FLINK-16305: Summary: FlinkYarnSessionClI ignores target executor and uses yarn-session if YARN properties file is present Key: FLINK-16305 URL:

[jira] [Created] (FLINK-16304) Remove python packages bundled in the flink-python jar

Wei Zhong created FLINK-16304: - Summary: Remove python packages bundled in the flink-python jar Key: FLINK-16304 URL: https://issues.apache.org/jira/browse/FLINK-16304 Project: Flink Issue Type:

[jira] [Created] (FLINK-16303) add log list and read log by name for jobmanager

lining created FLINK-16303: -- Summary: add log list and read log by name for jobmanager Key: FLINK-16303 URL: https://issues.apache.org/jira/browse/FLINK-16303 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-16302) add log list and read log by name for taskmanager

lining created FLINK-16302: -- Summary: add log list and read log by name for taskmanager Key: FLINK-16302 URL: https://issues.apache.org/jira/browse/FLINK-16302 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-16301) Annoying "Cannot find FunctionDefinition" messages with SQL for f_proctime or =

Nico Kruber created FLINK-16301: --- Summary: Annoying "Cannot find FunctionDefinition" messages with SQL for f_proctime or = Key: FLINK-16301 URL: https://issues.apache.org/jira/browse/FLINK-16301

Re: [DISCUSS] FLINK-16194: Refactor the Kubernetes architecture design

Hi, everyone, I have pushed a PR for this issue, looking forward to your feedback. Cheers, Canbin Zheng Canbin Zheng 于2020年2月26日周三 上午10:39写道： > Thanks for the detailed PR advice, I would separate the commits as clear > as possible to help the code