[jira] [Updated] (FLINK-14704) Remove uesless SynchronousSavepointLatch

2019-11-11 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14704?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14704: --- Labels: pull-request-available (was: ) > Remove uesless SynchronousSavepointLa

[jira] [Updated] (FLINK-14709) Allow outputting elements in close method of chained drivers.

2019-11-11 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14709?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14709: --- Labels: pull-request-available (was: ) > Allow outputting elements in close met

[jira] [Updated] (FLINK-14707) Refactor checkpoint related methods within Environment

2019-11-11 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14707?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-14707: - Component/s: Runtime / Checkpointing > Refactor checkpoint related methods within Environm

[jira] [Created] (FLINK-14709) Allow outputting elements in close method of chained drivers.

2019-11-11 Thread David Moravek (Jira)
David Moravek created FLINK-14709: - Summary: Allow outputting elements in close method of chained drivers. Key: FLINK-14709 URL: https://issues.apache.org/jira/browse/FLINK-14709 Project: Flink

[jira] [Created] (FLINK-14708) Introduce full restarts failover strategy for NG scheduler

2019-11-11 Thread Zhu Zhu (Jira)
Zhu Zhu created FLINK-14708: --- Summary: Introduce full restarts failover strategy for NG scheduler Key: FLINK-14708 URL: https://issues.apache.org/jira/browse/FLINK-14708 Project: Flink Issue Type

[jira] [Closed] (FLINK-7926) Bug in Hybrid Hash Join: Request to spill a partition with less than two buffers.

2019-11-11 Thread Aljoscha Krettek (Jira)
[ https://issues.apache.org/jira/browse/FLINK-7926?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-7926. --- Resolution: Won't Fix I'm closing this as "Abandoned", since there is no mor

[jira] [Assigned] (FLINK-14704) Remove uesless SynchronousSavepointLatch

2019-11-11 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14704?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reassigned FLINK-14704: -- Assignee: Yun Tang > Remove uesless SynchronousSavepointLa

[jira] [Updated] (FLINK-14704) Remove uesless SynchronousSavepointLatch

2019-11-11 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14704?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-14704: --- Component/s: Runtime / Task Runtime / Checkpointing > Remove uesl

[jira] [Commented] (FLINK-14704) Remove uesless SynchronousSavepointLatch

2019-11-11 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14704?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16971646#comment-16971646 ] Piotr Nowojski commented on FLINK-14704: Thanks for spotting this. Yes, those should be removed

[jira] [Updated] (FLINK-14704) Remove uesless SynchronousSavepointLatch

2019-11-11 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14704?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-14704: --- Affects Version/s: 1.10.0 > Remove uesless SynchronousSavepointLa

[jira] [Comment Edited] (FLINK-14433) Move generated Jaas conf file from /tmp directory to Job specific directory

2019-11-11 Thread Aljoscha Krettek (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14433?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16971643#comment-16971643 ] Aljoscha Krettek edited comment on FLINK-14433 at 11/11/19 2:31 PM

[jira] [Assigned] (FLINK-14433) Move generated Jaas conf file from /tmp directory to Job specific directory

2019-11-11 Thread Aljoscha Krettek (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14433?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-14433: Assignee: Congxian Qiu(klion26) (was: Aljoscha Krettek) > Move generated J

[jira] [Commented] (FLINK-14433) Move generated Jaas conf file from /tmp directory to Job specific directory

2019-11-11 Thread Aljoscha Krettek (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14433?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16971643#comment-16971643 ] Aljoscha Krettek commented on FLINK-14433: -- Sorry, I was on vacation. ☕ > Move generated J

[jira] [Assigned] (FLINK-14433) Move generated Jaas conf file from /tmp directory to Job specific directory

2019-11-11 Thread Aljoscha Krettek (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14433?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-14433: Assignee: Aljoscha Krettek > Move generated Jaas conf file from /tmp direct

[jira] [Commented] (FLINK-14264) Expose CheckpointBackend in checkpoint config RestAPI

2019-11-11 Thread Aljoscha Krettek (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14264?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16971641#comment-16971641 ] Aljoscha Krettek commented on FLINK-14264: -- This sounds valid. Should

[jira] [Commented] (FLINK-14514) Improve interface of FunctionContext#getJobParameter

2019-11-11 Thread Aljoscha Krettek (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16971626#comment-16971626 ] Aljoscha Krettek commented on FLINK-14514: -- This sounds fine, yes. > Improve interf

[jira] [Assigned] (FLINK-14481) Modify the Flink valid socket port check to 0 to 65535.

2019-11-11 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14481?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reassigned FLINK-14481: -- Assignee: AT-Fieldless > Modify the Flink valid socket port check to 0 to 65

[jira] [Closed] (FLINK-14380) Type Extractor POJO setter check does not allow for Immutable Case Class

2019-11-11 Thread Aljoscha Krettek (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14380?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-14380. Fix Version/s: 1.10.0 Resolution: Fixed Fixed on master

[jira] [Comment Edited] (FLINK-14481) Modify the Flink valid socket port check to 0 to 65535.

2019-11-11 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14481?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16971575#comment-16971575 ] Piotr Nowojski edited comment on FLINK-14481 at 11/11/19 2:15 PM: -- You

[jira] [Commented] (FLINK-14481) Modify the Flink valid socket port check to 0 to 65535.

2019-11-11 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14481?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16971575#comment-16971575 ] Piotr Nowojski commented on FLINK-14481: You can re-use your branch (rebase on the latest mater

[jira] [Updated] (FLINK-14697) Connection timeout occurs while checkpointing

2019-11-11 Thread Aljoscha Krettek (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14697?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-14697: - Component/s: Runtime / Network > Connection timeout occurs while checkpoint

[jira] [Commented] (FLINK-14699) Move ClosureCleaner to flink-core

2019-11-11 Thread Aljoscha Krettek (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14699?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16971573#comment-16971573 ] Aljoscha Krettek commented on FLINK-14699: -- This should be fine, yes. > Move ClosureClea

[jira] [Assigned] (FLINK-14380) Type Extractor POJO setter check does not allow for Immutable Case Class

2019-11-11 Thread Aljoscha Krettek (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14380?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-14380: Assignee: Marco Zühlke > Type Extractor POJO setter check does not al

[jira] [Commented] (FLINK-14707) Refactor checkpoint related methods within Environment

2019-11-11 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16971567#comment-16971567 ] Yun Tang commented on FLINK-14707: -- [~sewen], what do you think of this? > Refactor checkpoint rela

[jira] [Commented] (FLINK-14376) Introduce the Executor abstraction (FLIP-73)

2019-11-11 Thread Kostas Kloudas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14376?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16971568#comment-16971568 ] Kostas Kloudas commented on FLINK-14376: Hi [~tison]. So far, my the plan is the {{Configuration

[jira] [Created] (FLINK-14707) Refactor checkpoint related methods within Environment

2019-11-11 Thread Yun Tang (Jira)
Yun Tang created FLINK-14707: Summary: Refactor checkpoint related methods within Environment Key: FLINK-14707 URL: https://issues.apache.org/jira/browse/FLINK-14707 Project: Flink Issue Type

[jira] [Closed] (FLINK-14601) CLI documentation for list is missing '-a'

2019-11-11 Thread Aljoscha Krettek (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14601?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-14601. Fix Version/s: 1.10.0 Resolution: Fixed Fixed on master

[jira] [Updated] (FLINK-14525) buffer pool is destroyed

2019-11-11 Thread Aljoscha Krettek (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14525?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-14525: - Priority: Major (was: Blocker) > buffer pool is destro

[jira] [Updated] (FLINK-14619) Failed to fetch BLOB

2019-11-11 Thread Aljoscha Krettek (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14619?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-14619: - Component/s: Runtime / Coordination > Failed to fetch B

[jira] [Closed] (FLINK-14570) KeyedStateBootstrapFunction missed onTimer callback method to fire timer

2019-11-11 Thread Aljoscha Krettek (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14570?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-14570. Resolution: Not A Problem > KeyedStateBootstrapFunction missed onTimer callback met

[jira] [Closed] (FLINK-14554) Correct the comment of ExistingSavepoint#readKeyedState to generate java doc

2019-11-11 Thread Aljoscha Krettek (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14554?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-14554. Fix Version/s: 1.10.0 Resolution: Fixed Fixed on master

[jira] [Closed] (FLINK-14665) Support computed column in blink-planner

2019-11-11 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14665?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-14665. -- Assignee: Danny Chen Resolution: Fixed merged in 1.10.0

[jira] [Updated] (FLINK-14665) Support computed column in blink-planner

2019-11-11 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14665?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14665: --- Labels: pull-request-available (was: ) > Support computed column in blink-plan

[jira] [Commented] (FLINK-14664) Support to reference user defined functions of external catalog in computed columns

2019-11-11 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14664?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16971519#comment-16971519 ] Kurt Young commented on FLINK-14664: Is this already covered by FLINK-14665? > Support to refere

[jira] [Commented] (FLINK-14706) Remove legacy KvStateMessage

2019-11-11 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14706?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16971508#comment-16971508 ] Yun Tang commented on FLINK-14706: -- CC [~trohrmann], please assign this to me. > Remove leg

[jira] [Created] (FLINK-14706) Remove legacy KvStateMessage

2019-11-11 Thread Yun Tang (Jira)
Yun Tang created FLINK-14706: Summary: Remove legacy KvStateMessage Key: FLINK-14706 URL: https://issues.apache.org/jira/browse/FLINK-14706 Project: Flink Issue Type: Sub-task

[jira] [Updated] (FLINK-14231) Support the timers of the upstream operator with endInput properly

2019-11-11 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14231?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14231: --- Labels: pull-request-available (was: ) > Support the timers of the upstream opera

[jira] [Updated] (FLINK-14689) Add catalog related DDLs support in SQL Parser

2019-11-11 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14689?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14689: --- Labels: pull-request-available (was: ) > Add catalog related DDLs support in SQL Par

[jira] [Updated] (FLINK-14693) python tox checks fails on travis

2019-11-11 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14693?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14693: --- Labels: pull-request-available (was: ) > python tox checks fails on tra

[jira] [Created] (FLINK-14705) Remove nullables argument of BatchTestBase.registerCollection in blink planner

2019-11-11 Thread Danny Chen (Jira)
Danny Chen created FLINK-14705: -- Summary: Remove nullables argument of BatchTestBase.registerCollection in blink planner Key: FLINK-14705 URL: https://issues.apache.org/jira/browse/FLINK-14705 Project

[jira] [Updated] (FLINK-14676) Introduce parallelism inference for InputFormatTableSource

2019-11-11 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14676?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14676: --- Labels: pull-request-available (was: ) > Introduce parallelism infere

[jira] [Commented] (FLINK-14704) Remove uesless SynchronousSavepointLatch

2019-11-11 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14704?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16971449#comment-16971449 ] Yun Tang commented on FLINK-14704: -- [~pnowojski], what do you think of this? please assign to me

[jira] [Commented] (FLINK-14164) Add a metric to show failover count regarding fine grained recovery

2019-11-11 Thread Gary Yao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14164?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16971446#comment-16971446 ] Gary Yao commented on FLINK-14164: -- Ok sounds good. > Add a metric to show failover count regard

[jira] [Updated] (FLINK-14704) Remove uesless SynchronousSavepointLatch

2019-11-11 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14704?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-14704: - Fix Version/s: (was: 1.11.0) 1.10.0 > Remove uesless SynchronousSavepointLa

[jira] [Assigned] (FLINK-14676) Introduce parallelism inference for InputFormatTableSource

2019-11-11 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14676?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-14676: -- Assignee: Jingsong Lee > Introduce parallelism inference for InputFormatTableSou

[jira] [Closed] (FLINK-14395) Refactor ES 7 connectors to make them keep consistency with es 6 connectors

2019-11-11 Thread Aljoscha Krettek (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14395?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-14395. Fix Version/s: 1.10.0 Resolution: Fixed Fixed on master

[jira] [Commented] (FLINK-14164) Add a metric to show failover count regarding fine grained recovery

2019-11-11 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14164?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16971413#comment-16971413 ] Zhu Zhu commented on FLINK-14164: - I misunderstood the new problem. [~gjy] You are right. We should also

[jira] [Updated] (FLINK-14701) Slot leaks if SharedSlotOversubscribedException happens

2019-11-11 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14701?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-14701: Priority: Critical (was: Blocker) > Slot leaks if SharedSlotOversubscribedException happ

[jira] [Commented] (FLINK-14676) Introduce parallelism inference for InputFormatTableSource

2019-11-11 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16971408#comment-16971408 ] Jingsong Lee commented on FLINK-14676: -- Hi [~jark], the parallelism of StreamTableSource need

[jira] [Created] (FLINK-14704) Remove uesless SynchronousSavepointLatch

2019-11-11 Thread Yun Tang (Jira)
Yun Tang created FLINK-14704: Summary: Remove uesless SynchronousSavepointLatch Key: FLINK-14704 URL: https://issues.apache.org/jira/browse/FLINK-14704 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-14703) Port the Kafka SQL related tests.

2019-11-11 Thread Zheng Hu (Jira)
Zheng Hu created FLINK-14703: Summary: Port the Kafka SQL related tests. Key: FLINK-14703 URL: https://issues.apache.org/jira/browse/FLINK-14703 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-14702) Rewrite the tpch ( test_tpch.sh ) e2e tests by using the newly introduced java framework

2019-11-10 Thread Zheng Hu (Jira)
Zheng Hu created FLINK-14702: Summary: Rewrite the tpch ( test_tpch.sh ) e2e tests by using the newly introduced java framework Key: FLINK-14702 URL: https://issues.apache.org/jira/browse/FLINK-14702

[jira] [Commented] (FLINK-14674) some tpc-ds query hang in scheduled stage for long time

2019-11-10 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16971363#comment-16971363 ] Zhu Zhu commented on FLINK-14674: - The job hangs due to FLINK-14701, which happen

[jira] [Commented] (FLINK-14701) Slot leaks if SharedSlotOversubscribedException happens

2019-11-10 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14701?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16971359#comment-16971359 ] Zhu Zhu commented on FLINK-14701: - [~chesnay], what do you think of the issue and the proposed solution

[jira] [Created] (FLINK-14701) Slot leaks if SharedSlotOversubscribedException happens

2019-11-10 Thread Zhu Zhu (Jira)
Zhu Zhu created FLINK-14701: --- Summary: Slot leaks if SharedSlotOversubscribedException happens Key: FLINK-14701 URL: https://issues.apache.org/jira/browse/FLINK-14701 Project: Flink Issue Type

[jira] [Created] (FLINK-14700) Consider to set the random listen port in e2e flink cluster.

2019-11-10 Thread Zheng Hu (Jira)
Zheng Hu created FLINK-14700: Summary: Consider to set the random listen port in e2e flink cluster. Key: FLINK-14700 URL: https://issues.apache.org/jira/browse/FLINK-14700 Project: Flink Issue

[jira] [Created] (FLINK-14699) Move ClosureCleaner to flink-core

2019-11-10 Thread Zili Chen (Jira)
Zili Chen created FLINK-14699: - Summary: Move ClosureCleaner to flink-core Key: FLINK-14699 URL: https://issues.apache.org/jira/browse/FLINK-14699 Project: Flink Issue Type: Improvement

[jira] [Closed] (FLINK-14698) Refactor the SQL CLI parser to reuse flink-sql-parser

2019-11-10 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14698?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-14698. -- Fix Version/s: (was: 1.10.0) Resolution: Duplicate > Refactor the SQL CLI parser to re

[jira] [Commented] (FLINK-14698) Refactor the SQL CLI parser to reuse flink-sql-parser

2019-11-10 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14698?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16971335#comment-16971335 ] Kurt Young commented on FLINK-14698: I've already create this one: https://issues.apache.org/jira

[jira] [Closed] (FLINK-14666) support multiple catalog in flink table sql

2019-11-10 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14666?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-14666. -- Fix Version/s: 1.10.0 Resolution: Not A Problem > support multiple catalog in flink table

[jira] [Reopened] (FLINK-14666) support multiple catalog in flink table sql

2019-11-10 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14666?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reopened FLINK-14666: > support multiple catalog in flink table

[jira] [Updated] (FLINK-14188) TaskExecutor derive and register with default slot resource profile

2019-11-10 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14188?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14188: --- Labels: pull-request-available (was: ) > TaskExecutor derive and register with defa

[jira] [Created] (FLINK-14698) Refactor the SQL CLI parser to reuse flink-sql-parser

2019-11-10 Thread Danny Chen (Jira)
Danny Chen created FLINK-14698: -- Summary: Refactor the SQL CLI parser to reuse flink-sql-parser Key: FLINK-14698 URL: https://issues.apache.org/jira/browse/FLINK-14698 Project: Flink Issue Type

[jira] [Updated] (FLINK-14697) Connection timeout occurs while checkpointing

2019-11-10 Thread dmgkeke (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14697?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] dmgkeke updated FLINK-14697: Environment: Flink version : 1.8.0 Yarn cluster mode 8 nodes 16 yarn containers checkpoint path

[jira] [Created] (FLINK-14697) Connection timeout occurs while checkpointing

2019-11-10 Thread dmgkeke (Jira)
dmgkeke created FLINK-14697: --- Summary: Connection timeout occurs while checkpointing Key: FLINK-14697 URL: https://issues.apache.org/jira/browse/FLINK-14697 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-14693) python tox checks fails on travis

2019-11-10 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14693?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16971309#comment-16971309 ] Dian Fu commented on FLINK-14693: - Great thanks for reporting this issue. We have also found this issue

[jira] [Created] (FLINK-14696) Support precision of TimestampType in built-in SQL functions and operators

2019-11-10 Thread Zhenghua Gao (Jira)
Zhenghua Gao created FLINK-14696: Summary: Support precision of TimestampType in built-in SQL functions and operators Key: FLINK-14696 URL: https://issues.apache.org/jira/browse/FLINK-14696 Project

[jira] [Commented] (FLINK-14674) some tpc-ds query hang in scheduled stage for long time

2019-11-10 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16971288#comment-16971288 ] Leonard Xu commented on FLINK-14674: [~lzljs3620320] I think [~ykt836] 's analysis is right

[jira] [Created] (FLINK-14695) Elasticsearch 5.1.2 doesn't work on Ubuntu 18.04

2019-11-10 Thread wangxiyuan (Jira)
wangxiyuan created FLINK-14695: -- Summary: Elasticsearch 5.1.2 doesn't work on Ubuntu 18.04 Key: FLINK-14695 URL: https://issues.apache.org/jira/browse/FLINK-14695 Project: Flink Issue Type: Bug

[jira] [Closed] (FLINK-14666) support multiple catalog in flink table sql

2019-11-10 Thread yuemeng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14666?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] yuemeng closed FLINK-14666. --- Resolution: Implemented > support multiple catalog in flink table

[jira] [Commented] (FLINK-14666) support multiple catalog in flink table sql

2019-11-10 Thread yuemeng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14666?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16971278#comment-16971278 ] yuemeng commented on FLINK-14666: - [~dwysakowicz] I will close the issue because of your new feature

[jira] [Commented] (FLINK-14481) Modify the Flink valid socket port check to 0 to 65535.

2019-11-10 Thread AT-Fieldless (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14481?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16971275#comment-16971275 ] AT-Fieldless commented on FLINK-14481: -- Thanks for pointing it out. I will check full Flink project

[jira] [Commented] (FLINK-13482) How can I cleanly shutdown streaming jobs in local mode?

2019-11-10 Thread Donghui Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13482?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16971270#comment-16971270 ] Donghui Xu commented on FLINK-13482: Thank you for your advice. [~azagrebin] I want to kill

[jira] [Updated] (FLINK-13482) How can I cleanly shutdown streaming jobs in local mode?

2019-11-10 Thread Donghui Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13482?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Donghui Xu updated FLINK-13482: --- Affects Version/s: 1.6.4 > How can I cleanly shutdown streaming jobs in local m

[jira] [Comment Edited] (FLINK-14694) Most tests from package o.a.f.table.planner.functions.aggfunctions are not executed during mvn test

2019-11-10 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14694?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16971143#comment-16971143 ] godfrey he edited comment on FLINK-14694 at 11/10/19 3:12 PM: -- The reason

[jira] [Commented] (FLINK-14694) Most tests from package o.a.f.table.planner.functions.aggfunctions are not executed during mvn test

2019-11-10 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14694?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16971143#comment-16971143 ] godfrey he commented on FLINK-14694: The reason is test classes (excluding

[jira] [Comment Edited] (FLINK-14694) Most tests from package o.a.f.table.planner.functions.aggfunctions are not executed during mvn test

2019-11-10 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14694?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16971097#comment-16971097 ] godfrey he edited comment on FLINK-14694 at 11/10/19 2:41 PM: -- i would like

[jira] [Closed] (FLINK-14657) Generalize and move YarnConfigUtils from flink-yarn to flink-core

2019-11-10 Thread Kostas Kloudas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14657?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-14657. -- Resolution: Fixed Merged with ef4055ab989db431e29e0071573619d26796 > Generalize and m

[jira] [Updated] (FLINK-14657) Generalize and move YarnConfigUtils from flink-yarn to flink-core

2019-11-10 Thread Kostas Kloudas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14657?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-14657: --- Fix Version/s: 1.10.0 > Generalize and move YarnConfigUtils from flink-yarn to flink-c

[jira] [Closed] (FLINK-14325) Convert CatalogTable to TableSourceTable with additional watermark information

2019-11-10 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14325?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-14325. --- Fix Version/s: 1.10.0 Resolution: Done It has been covered by FLINK-14326. > Convert CatalogTa

[jira] [Updated] (FLINK-14694) Most tests from package o.a.f.table.planner.functions.aggfunctions are not executed during mvn test

2019-11-10 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14694?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-14694: Fix Version/s: 1.10.0 > Most tests from package o.a.f.table.planner.functions.aggfuncti

[jira] [Updated] (FLINK-14694) Most tests from package o.a.f.table.planner.functions.aggfunctions are not executed during mvn test

2019-11-10 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14694?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-14694: Priority: Blocker (was: Major) > Most tests from package o.a.f.table.planner.functions.aggfuncti

[jira] [Closed] (FLINK-14667) flink1.9,1.8.2 run flinkSql fat jar ,can't load the right tableFactory (TableSourceFactory) for the kafka

2019-11-10 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14667?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-14667. --- Resolution: Not A Problem > flink1.9,1.8.2 run flinkSql fat jar ,can't load the right tableFact

[jira] [Commented] (FLINK-14667) flink1.9,1.8.2 run flinkSql fat jar ,can't load the right tableFactory (TableSourceFactory) for the kafka

2019-11-10 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14667?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16971112#comment-16971112 ] Jark Wu commented on FLINK-14667: - I will close this issue then, as it is not a bug. > flink1.9,1.

[jira] [Commented] (FLINK-14667) flink1.9,1.8.2 run flinkSql fat jar ,can't load the right tableFactory (TableSourceFactory) for the kafka

2019-11-10 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14667?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1697#comment-1697 ] Jark Wu commented on FLINK-14667: - Thanks [~wenlong.lwl] for the tip. I think the reason is service file

[jira] [Comment Edited] (FLINK-13184) Starting a TaskExecutor blocks the YarnResourceManager's main thread

2019-11-10 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16971079#comment-16971079 ] Yang Wang edited comment on FLINK-13184 at 11/10/19 12:24 PM: -- [~trohrmann

[jira] [Commented] (FLINK-14676) Introduce parallelism inference for InputFormatTableSource

2019-11-10 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16971109#comment-16971109 ] Jark Wu commented on FLINK-14676: - Could you use {{StreamTableSource}} instead? The returned DataStream

[jira] [Assigned] (FLINK-14694) Most tests from package o.a.f.table.planner.functions.aggfunctions are not executed during mvn test

2019-11-10 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14694?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-14694: -- Assignee: godfrey he > Most tests from package o.a.f.table.planner.functions.aggfuncti

[jira] [Commented] (FLINK-14694) Most tests from package o.a.f.table.planner.functions.aggfunctions are not executed during mvn test

2019-11-10 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14694?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16971097#comment-16971097 ] godfrey he commented on FLINK-14694: i would like take this ticket > Most tests from pack

[jira] [Updated] (FLINK-14694) Most tests from package o.a.f.table.planner.functions.aggfunctions are not executed during mvn test

2019-11-10 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14694?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-14694: --- Issue Type: Bug (was: Improvement) > Most tests from pack

[jira] [Updated] (FLINK-14694) Most tests from package o.a.f.table.planner.functions.aggfunctions are not executed during mvn test

2019-11-10 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14694?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-14694: --- Component/s: Tests > Most tests from package o.a.f.table.planner.functions.aggfuncti

[jira] [Commented] (FLINK-14694) Most tests from package o.a.f.table.planner.functions.aggfunctions are not executed during mvn test

2019-11-10 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14694?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16971094#comment-16971094 ] Kurt Young commented on FLINK-14694: cc [~godfreyhe] > Most tests from pack

[jira] [Created] (FLINK-14694) Most tests from package o.a.f.table.planner.functions.aggfunctions are not executed during mvn test

2019-11-10 Thread Kurt Young (Jira)
Kurt Young created FLINK-14694: -- Summary: Most tests from package o.a.f.table.planner.functions.aggfunctions are not executed during mvn test Key: FLINK-14694 URL: https://issues.apache.org/jira/browse/FLINK-14694

[jira] [Commented] (FLINK-13184) Starting a TaskExecutor blocks the YarnResourceManager's main thread

2019-11-10 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16971079#comment-16971079 ] Yang Wang commented on FLINK-13184: --- [~trohrmann] `NMClientAsync` use a internal thread pool

[jira] [Updated] (FLINK-14613) Add validation check when applying UDF to tempral table key in Temporal Table Join condition

2019-11-10 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14613?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14613: --- Labels: pull-request-available (was: ) > Add validation check when applying

[jira] [Updated] (FLINK-14693) python tox checks fails on travis

2019-11-10 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14693?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-14693: --- Description: ImportError: cannot import name 'ensure_is_path' from 'importlib_metadata._compat

[jira] [Created] (FLINK-14693) python tox checks fails on travis

2019-11-10 Thread Kurt Young (Jira)
Kurt Young created FLINK-14693: -- Summary: python tox checks fails on travis Key: FLINK-14693 URL: https://issues.apache.org/jira/browse/FLINK-14693 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-14692) Support Table related DDLs in TableEnvironment

2019-11-09 Thread Terry Wang (Jira)
Terry Wang created FLINK-14692: -- Summary: Support Table related DDLs in TableEnvironment Key: FLINK-14692 URL: https://issues.apache.org/jira/browse/FLINK-14692 Project: Flink Issue Type: Sub

[jira] [Created] (FLINK-14691) Support database related DDLs in TableEnvironment

2019-11-09 Thread Terry Wang (Jira)
Terry Wang created FLINK-14691: -- Summary: Support database related DDLs in TableEnvironment Key: FLINK-14691 URL: https://issues.apache.org/jira/browse/FLINK-14691 Project: Flink Issue Type

[jira] [Created] (FLINK-14690) Support catalog related DDLs in TableEnvironment

2019-11-09 Thread Terry Wang (Jira)
Terry Wang created FLINK-14690: -- Summary: Support catalog related DDLs in TableEnvironment Key: FLINK-14690 URL: https://issues.apache.org/jira/browse/FLINK-14690 Project: Flink Issue Type: Sub

  1   2   3   4   5   6   7   8   9   10   >