[jira] [Commented] (FLINK-15247) Closing (Testing)MiniCluster may cause ConcurrentModificationException

2020-01-16 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15247?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17016653#comment-17016653 ] Piotr Nowojski commented on FLINK-15247: another instance:

[jira] [Resolved] (FLINK-15145) Tune default values for FLIP-49 TM memory configurations with real production jobs.

2020-01-16 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15145?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-15145. --- Resolution: Done Done via master: 6ec4b5684d60007fe4570107aaa61c808e4fd5f9

[jira] [Updated] (FLINK-15592) Streaming sql throw hive exception when it doesn't use any hive table

2020-01-16 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15592?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-15592: - Priority: Major (was: Critical) > Streaming sql throw hive exception when it doesn't use any

[jira] [Comment Edited] (FLINK-14812) Add custom libs to Flink classpath with an environment variable.

2020-01-16 Thread Eui Heo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14812?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17016428#comment-17016428 ] Eui Heo edited comment on FLINK-14812 at 1/16/20 8:17 AM: -- In particular,

[GitHub] [flink] rkhachatryan commented on a change in pull request #10151: [FLINK-14231] Handle the pending processing-time timers to make endInput semantics on the operator chain strict

2020-01-16 Thread GitBox
rkhachatryan commented on a change in pull request #10151: [FLINK-14231] Handle the pending processing-time timers to make endInput semantics on the operator chain strict URL: https://github.com/apache/flink/pull/10151#discussion_r367288070 ## File path:

[jira] [Commented] (FLINK-15609) Add blink built-in functions from FlinkSqlOperatorTable to BuiltInFunctionDefinitions

2020-01-16 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15609?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17016646#comment-17016646 ] Jark Wu commented on FLINK-15609: - Sorry, I misunderstood this. > Add blink built-in functions from

[GitHub] [flink] tillrohrmann closed pull request #10860: [FLINK-15145][config] Change TM memory configuration default values for FLIP-49.

2020-01-16 Thread GitBox
tillrohrmann closed pull request #10860: [FLINK-15145][config] Change TM memory configuration default values for FLIP-49. URL: https://github.com/apache/flink/pull/10860 This is an automated message from the Apache Git

[GitHub] [flink] flinkbot edited a comment on issue #10832: [FLINK-14163][runtime]Enforce synchronous registration of Execution#producedPartitions

2020-01-16 Thread GitBox
flinkbot edited a comment on issue #10832: [FLINK-14163][runtime]Enforce synchronous registration of Execution#producedPartitions URL: https://github.com/apache/flink/pull/10832#issuecomment-573276729 ## CI report: * 5eb1599945f1bee35c342f762cc25684013d2d83 Travis:

[GitHub] [flink] tillrohrmann commented on a change in pull request #10866: Enable TTL compaction filter by default and deprecate/remove some other TTL API

2020-01-16 Thread GitBox
tillrohrmann commented on a change in pull request #10866: Enable TTL compaction filter by default and deprecate/remove some other TTL API URL: https://github.com/apache/flink/pull/10866#discussion_r367278057 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #10852: [FLINK-15564][yarn][test] Fix YarnClusterDescriptorTest that failed to validate the original intended behavior

2020-01-16 Thread GitBox
flinkbot edited a comment on issue #10852: [FLINK-15564][yarn][test] Fix YarnClusterDescriptorTest that failed to validate the original intended behavior URL: https://github.com/apache/flink/pull/10852#issuecomment-574107516 ## CI report: *

[GitHub] [flink] flinkbot commented on issue #10868: [FLINK-15278][docs-zh] Update Chinese version StreamingFileSink dock

2020-01-16 Thread GitBox
flinkbot commented on issue #10868: [FLINK-15278][docs-zh] Update Chinese version StreamingFileSink dock URL: https://github.com/apache/flink/pull/10868#issuecomment-575033614 ## CI report: * 6738a937a595abc0af8e89fe39b29d28bc96d44a UNKNOWN Bot commands The

[GitHub] [flink] pnowojski commented on a change in pull request #10845: [FLINK-15355][plugins]Classloader restricts access to parent to whitelist.

2020-01-16 Thread GitBox
pnowojski commented on a change in pull request #10845: [FLINK-15355][plugins]Classloader restricts access to parent to whitelist. URL: https://github.com/apache/flink/pull/10845#discussion_r367276414 ## File path:

[GitHub] [flink] pnowojski commented on a change in pull request #10845: [FLINK-15355][plugins]Classloader restricts access to parent to whitelist.

2020-01-16 Thread GitBox
pnowojski commented on a change in pull request #10845: [FLINK-15355][plugins]Classloader restricts access to parent to whitelist. URL: https://github.com/apache/flink/pull/10845#discussion_r367279519 ## File path:

[GitHub] [flink] pnowojski commented on a change in pull request #10845: [FLINK-15355][plugins]Classloader restricts access to parent to whitelist.

2020-01-16 Thread GitBox
pnowojski commented on a change in pull request #10845: [FLINK-15355][plugins]Classloader restricts access to parent to whitelist. URL: https://github.com/apache/flink/pull/10845#discussion_r367279915 ## File path:

[GitHub] [flink] tillrohrmann commented on issue #10860: [FLINK-15145][config] Change TM memory configuration default values for FLIP-49.

2020-01-16 Thread GitBox
tillrohrmann commented on issue #10860: [FLINK-15145][config] Change TM memory configuration default values for FLIP-49. URL: https://github.com/apache/flink/pull/10860#issuecomment-575030417 Thanks @xintongsong for addressing my comments so quickly. Merging this PR now.

[GitHub] [flink] flinkbot edited a comment on issue #10822: [FLINK-15081][docs-zh]Translate "Concepts & Common API" page of Table…

2020-01-16 Thread GitBox
flinkbot edited a comment on issue #10822: [FLINK-15081][docs-zh]Translate "Concepts & Common API" page of Table… URL: https://github.com/apache/flink/pull/10822#issuecomment-572897310 ## CI report: * 6a9eb6f6b70dc406a0c2285da4b02b17a18e4c7b Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10822: [FLINK-15081][docs-zh]Translate "Concepts & Common API" page of Table…

2020-01-16 Thread GitBox
flinkbot edited a comment on issue #10822: [FLINK-15081][docs-zh]Translate "Concepts & Common API" page of Table… URL: https://github.com/apache/flink/pull/10822#issuecomment-572897310 ## CI report: * 6a9eb6f6b70dc406a0c2285da4b02b17a18e4c7b Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10852: [FLINK-15564][yarn][test] Fix YarnClusterDescriptorTest that failed to validate the original intended behavior

2020-01-16 Thread GitBox
flinkbot edited a comment on issue #10852: [FLINK-15564][yarn][test] Fix YarnClusterDescriptorTest that failed to validate the original intended behavior URL: https://github.com/apache/flink/pull/10852#issuecomment-574107516 ## CI report: *

[jira] [Commented] (FLINK-15610) How to achieve the udf that the number of return column is uncertain

2020-01-16 Thread hehuiyuan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15610?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17016693#comment-17016693 ] hehuiyuan commented on FLINK-15610: --- [~jark] > How to achieve the udf that the number of return

[GitHub] [flink] godfreyhe commented on issue #10854: [FLINK-15577][table-planner] Fix similar aggregations with different windows being considered the same

2020-01-16 Thread GitBox
godfreyhe commented on issue #10854: [FLINK-15577][table-planner] Fix similar aggregations with different windows being considered the same URL: https://github.com/apache/flink/pull/10854#issuecomment-575042514 LGTM, +1 to merge, thanks for the fix @BenoitHanotte.

[jira] [Created] (FLINK-15612) Implement a DataTypeLookup

2020-01-16 Thread Timo Walther (Jira)
Timo Walther created FLINK-15612: Summary: Implement a DataTypeLookup Key: FLINK-15612 URL: https://issues.apache.org/jira/browse/FLINK-15612 Project: Flink Issue Type: Sub-task

[jira] [Commented] (FLINK-15610) How to achieve the udf that the number of return column is uncertain

2020-01-16 Thread hehuiyuan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15610?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17016716#comment-17016716 ] hehuiyuan commented on FLINK-15610: --- [~lzljs3620320] thx. > How to achieve the udf that the number of

[jira] [Closed] (FLINK-13465) Bump javassist to 3.24.0-GA

2020-01-16 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13465?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-13465. Resolution: Fixed > Bump javassist to 3.24.0-GA > --- > >

[jira] [Commented] (FLINK-15586) BucketingSink is ignoring plugins when trying to re-instantiate the HadoopFileSystem

2020-01-16 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15586?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17016727#comment-17016727 ] Piotr Nowojski commented on FLINK-15586: Removing the release blocker status for 1.10. It's true

[jira] [Updated] (FLINK-15586) BucketingSink is ignoring plugins when trying to re-instantiate the HadoopFileSystem

2020-01-16 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15586?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-15586: --- Priority: Minor (was: Major) > BucketingSink is ignoring plugins when trying to

[jira] [Comment Edited] (FLINK-15602) Blink planner does not respect the precision when casting timestamp to varchar

2020-01-16 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15602?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17016723#comment-17016723 ] Dawid Wysakowicz edited comment on FLINK-15602 at 1/16/20 9:13 AM: ---

[jira] [Comment Edited] (FLINK-15602) Blink planner does not respect the precision when casting timestamp to varchar

2020-01-16 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15602?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17016723#comment-17016723 ] Dawid Wysakowicz edited comment on FLINK-15602 at 1/16/20 9:13 AM: ---

[jira] [Commented] (FLINK-14122) Extend State Processor API to read ListCheckpointed operator state

2020-01-16 Thread Aljoscha Krettek (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14122?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17016730#comment-17016730 ] Aljoscha Krettek commented on FLINK-14122: -- I'm wondering of we should do this because I don't

[jira] [Closed] (FLINK-15540) flink-shaded-hadoop-2-uber bundles wrong dependency versions

2020-01-16 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15540?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-15540. Resolution: Fixed master: 01e95ca2975b409d4b367c4c0c81614846797963 >

[jira] [Assigned] (FLINK-15150) ZooKeeperLeaderElectionITCase.testJobExecutionOnClusterWithLeaderChange failed on Travis

2020-01-16 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15150?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-15150: Assignee: Chesnay Schepler >

[jira] [Commented] (FLINK-15602) Blink planner does not respect the precision when casting timestamp to varchar

2020-01-16 Thread Zhenghua Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15602?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17016745#comment-17016745 ] Zhenghua Gao commented on FLINK-15602: -- [~dwysakowicz] [~twalthr] [~jark] Let's padding the

[GitHub] [flink] pnowojski merged pull request #10824: [FLINK-15152][checkpointing] Restatrt CheckpointCoordinator if StopWithSavepoint failed

2020-01-16 Thread GitBox
pnowojski merged pull request #10824: [FLINK-15152][checkpointing] Restatrt CheckpointCoordinator if StopWithSavepoint failed URL: https://github.com/apache/flink/pull/10824 This is an automated message from the Apache Git

[jira] [Closed] (FLINK-14843) Streaming bucketing end-to-end test can fail with Output hash mismatch

2020-01-16 Thread Kostas Kloudas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14843?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-14843. -- Resolution: Fixed Merged on master with 9a58dedebef57cddd6e325ae40edc74aff6c6248 and on

[GitHub] [flink] dawidwys closed pull request #10674: [FLINK-15220][Connector/Kafka][Table] Add startFromTimestamp in KafkaTableSource

2020-01-16 Thread GitBox
dawidwys closed pull request #10674: [FLINK-15220][Connector/Kafka][Table] Add startFromTimestamp in KafkaTableSource URL: https://github.com/apache/flink/pull/10674 This is an automated message from the Apache Git Service.

[GitHub] [flink] tillrohrmann commented on issue #10866: Enable TTL compaction filter by default and deprecate/remove some other TTL API

2020-01-16 Thread GitBox
tillrohrmann commented on issue #10866: Enable TTL compaction filter by default and deprecate/remove some other TTL API URL: https://github.com/apache/flink/pull/10866#issuecomment-575070109 @flinkbot run travis This is an

[GitHub] [flink] xuyang1706 commented on issue #9413: [FLINK-13676][ml] Add class of Vector to Columns mapper

2020-01-16 Thread GitBox
xuyang1706 commented on issue #9413: [FLINK-13676][ml] Add class of Vector to Columns mapper URL: https://github.com/apache/flink/pull/9413#issuecomment-575073494 > @xuyang1706 overall it looks good. I changed the `RowCollector` test bug in

[jira] [Commented] (FLINK-15595) Entirely implement resolution order as FLIP-68 concept

2020-01-16 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15595?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17016783#comment-17016783 ] Dawid Wysakowicz commented on FLINK-15595: -- You are right. The {{CoreModule}} is entirely

[jira] [Created] (FLINK-15615) Docs: wrong guarantees stated for the file sink

2020-01-16 Thread Roman Khachatryan (Jira)
Roman Khachatryan created FLINK-15615: - Summary: Docs: wrong guarantees stated for the file sink Key: FLINK-15615 URL: https://issues.apache.org/jira/browse/FLINK-15615 Project: Flink

[jira] [Comment Edited] (FLINK-13758) failed to submit JobGraph when registered hdfs file in DistributedCache

2020-01-16 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13758?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17015615#comment-17015615 ] Yang Wang edited comment on FLINK-13758 at 1/16/20 8:49 AM: [~luoguohao] Are

[jira] [Commented] (FLINK-14369) KafkaProducerAtLeastOnceITCase>KafkaProducerTestBase.testOneToOneAtLeastOnceCustomOperator fails on Travis

2020-01-16 Thread Gary Yao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14369?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17016712#comment-17016712 ] Gary Yao commented on FLINK-14369: -- Are you also looking at this [~becket_qin]? >

[jira] [Commented] (FLINK-13758) failed to submit JobGraph when registered hdfs file in DistributedCache

2020-01-16 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13758?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17016718#comment-17016718 ] Yang Wang commented on FLINK-13758: --- After offline discussion with [~trohrmann], we hope this ticket

[jira] [Updated] (FLINK-15586) BucketingSink is ignoring plugins when trying to re-instantiate the HadoopFileSystem

2020-01-16 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15586?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-15586: --- Priority: Major (was: Blocker) > BucketingSink is ignoring plugins when trying to

[jira] [Updated] (FLINK-15586) BucketingSink is ignoring plugins when trying to re-instantiate the HadoopFileSystem

2020-01-16 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15586?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-15586: --- Fix Version/s: (was: 1.10.0) 1.11.0 > BucketingSink is ignoring

[jira] [Updated] (FLINK-13758) failed to submit JobGraph when registered hdfs file in DistributedCache

2020-01-16 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13758?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang updated FLINK-13758: -- Fix Version/s: 1.10.0 > failed to submit JobGraph when registered hdfs file in DistributedCache >

[jira] [Commented] (FLINK-14013) Support Flink Python User-Defined Stateless Function for Table

2020-01-16 Thread sunjincheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17016725#comment-17016725 ] sunjincheng commented on FLINK-14013: - Hi [~dian.fu] can we close this ISSUE due to all of sub-issue

[jira] [Updated] (FLINK-14013) Support Flink Python User-Defined Stateless Function for Table

2020-01-16 Thread sunjincheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14013?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-14013: Fix Version/s: 1.10.0 > Support Flink Python User-Defined Stateless Function for Table >

[GitHub] [flink] flinkbot edited a comment on issue #10852: [FLINK-15564][yarn][test] Fix YarnClusterDescriptorTest that failed to validate the original intended behavior

2020-01-16 Thread GitBox
flinkbot edited a comment on issue #10852: [FLINK-15564][yarn][test] Fix YarnClusterDescriptorTest that failed to validate the original intended behavior URL: https://github.com/apache/flink/pull/10852#issuecomment-574107516 ## CI report: *

[GitHub] [flink] zentol merged pull request #10801: [FLINK-15521][e2e] Follow symbolic link when copying distribution

2020-01-16 Thread GitBox
zentol merged pull request #10801: [FLINK-15521][e2e] Follow symbolic link when copying distribution URL: https://github.com/apache/flink/pull/10801 This is an automated message from the Apache Git Service. To respond to

[jira] [Comment Edited] (FLINK-15602) Blink planner does not respect the precision when casting timestamp to varchar

2020-01-16 Thread Zhenghua Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15602?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17016512#comment-17016512 ] Zhenghua Gao edited comment on FLINK-15602 at 1/16/20 9:16 AM: --- Hi

[jira] [Closed] (FLINK-14013) Support Flink Python User-Defined Stateless Function for Table

2020-01-16 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14013?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-14013. --- Resolution: Fixed > Support Flink Python User-Defined Stateless Function for Table >

[jira] [Commented] (FLINK-15602) Blink planner does not respect the precision when casting timestamp to varchar

2020-01-16 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15602?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17016747#comment-17016747 ] Jingsong Lee commented on FLINK-15602: -- +1 to pad. JDK LocalDateTime also pad to second,

[jira] [Commented] (FLINK-15602) Blink planner does not respect the precision when casting timestamp to varchar

2020-01-16 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15602?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17016759#comment-17016759 ] Timo Walther commented on FLINK-15602: -- [~docete] I would leave the old planner untouched to not

[jira] [Closed] (FLINK-15220) Add startFromTimestamp in KafkaTableSource

2020-01-16 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15220?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-15220. Fix Version/s: 1.11.0 Resolution: Fixed Implemented in

[jira] [Commented] (FLINK-15595) Resolution Order is chaotic not as FLIP-68 defined

2020-01-16 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15595?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17016763#comment-17016763 ] Jingsong Lee commented on FLINK-15595: -- Thanks [~twalthr] for involving. Yes, I think for a long

[jira] [Updated] (FLINK-15595) Entirely implement resolution order as FLIP-68 concept

2020-01-16 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15595?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-15595: - Summary: Entirely implement resolution order as FLIP-68 concept (was: Resolution Order is

[GitHub] [flink] xuyang1706 commented on a change in pull request #9413: [FLINK-13676][ml] Add class of Vector to Columns mapper

2020-01-16 Thread GitBox
xuyang1706 commented on a change in pull request #9413: [FLINK-13676][ml] Add class of Vector to Columns mapper URL: https://github.com/apache/flink/pull/9413#discussion_r367326107 ## File path:

[GitHub] [flink] xuyang1706 commented on a change in pull request #9413: [FLINK-13676][ml] Add class of Vector to Columns mapper

2020-01-16 Thread GitBox
xuyang1706 commented on a change in pull request #9413: [FLINK-13676][ml] Add class of Vector to Columns mapper URL: https://github.com/apache/flink/pull/9413#discussion_r367326208 ## File path:

[GitHub] [flink] xuyang1706 commented on a change in pull request #9413: [FLINK-13676][ml] Add class of Vector to Columns mapper

2020-01-16 Thread GitBox
xuyang1706 commented on a change in pull request #9413: [FLINK-13676][ml] Add class of Vector to Columns mapper URL: https://github.com/apache/flink/pull/9413#discussion_r367326548 ## File path:

[GitHub] [flink] xuyang1706 commented on a change in pull request #9413: [FLINK-13676][ml] Add class of Vector to Columns mapper

2020-01-16 Thread GitBox
xuyang1706 commented on a change in pull request #9413: [FLINK-13676][ml] Add class of Vector to Columns mapper URL: https://github.com/apache/flink/pull/9413#discussion_r367325817 ## File path:

[jira] [Commented] (FLINK-15552) SQL Client can not correctly create kafka table using --library to indicate a kafka connector directory

2020-01-16 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15552?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17016775#comment-17016775 ] Leonard Xu commented on FLINK-15552: Hi,[~jark] [~Terry1897] e2e test

[jira] [Closed] (FLINK-14853) Use higher granularity units in generated docs for Duration & MemorySize if possible

2020-01-16 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14853?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-14853. Resolution: Fixed Implemented in master: fa1ea5cddb6fd0b2b2eb3669ab70312af77d44d7

[jira] [Commented] (FLINK-15595) Entirely implement resolution order as FLIP-68 concept

2020-01-16 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15595?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17016794#comment-17016794 ] Timo Walther commented on FLINK-15595: -- I'm also fine with dropping the core module. Or we lookup

[GitHub] [flink] flinkbot edited a comment on issue #10868: [FLINK-15278][docs-zh] Update Chinese version StreamingFileSink dock

2020-01-16 Thread GitBox
flinkbot edited a comment on issue #10868: [FLINK-15278][docs-zh] Update Chinese version StreamingFileSink dock URL: https://github.com/apache/flink/pull/10868#issuecomment-575033614 ## CI report: * 6738a937a595abc0af8e89fe39b29d28bc96d44a Travis:

[jira] [Commented] (FLINK-15610) How to achieve the udf that the number of return column is uncertain

2020-01-16 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15610?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17016703#comment-17016703 ] Jingsong Lee commented on FLINK-15610: -- [~hehuiyuan] Now one way is passing a function Java

[jira] [Updated] (FLINK-13758) failed to submit JobGraph when registered hdfs file in DistributedCache

2020-01-16 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13758?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-13758: -- Priority: Critical (was: Major) > failed to submit JobGraph when registered hdfs file in

[jira] [Commented] (FLINK-15602) Blink planner does not respect the precision when casting timestamp to varchar

2020-01-16 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15602?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17016723#comment-17016723 ] Dawid Wysakowicz commented on FLINK-15602: -- [~docete] Thank you for checking it. I checked

[jira] [Comment Edited] (FLINK-15602) Blink planner does not respect the precision when casting timestamp to varchar

2020-01-16 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15602?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17016723#comment-17016723 ] Dawid Wysakowicz edited comment on FLINK-15602 at 1/16/20 9:11 AM: ---

[jira] [Commented] (FLINK-14013) Support Flink Python User-Defined Stateless Function for Table

2020-01-16 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17016738#comment-17016738 ] Dian Fu commented on FLINK-14013: - [~sunjincheng121] Thanks a lot for the remind. I will close it as all

[GitHub] [flink] flinkbot edited a comment on issue #10868: [FLINK-15278][docs-zh] Update Chinese version StreamingFileSink dock

2020-01-16 Thread GitBox
flinkbot edited a comment on issue #10868: [FLINK-15278][docs-zh] Update Chinese version StreamingFileSink dock URL: https://github.com/apache/flink/pull/10868#issuecomment-575033614 ## CI report: * 6738a937a595abc0af8e89fe39b29d28bc96d44a Travis:

[jira] [Closed] (FLINK-15521) TestUtils#copyDirectory should follow symbolic links

2020-01-16 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15521?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-15521. Resolution: Fixed master: 4cd4a04188d9dc0a6255eb8caed59b2e2389f822 1.10:

[jira] [Commented] (FLINK-15546) Obscure error message from ScalarOperatorGens::generateCast

2020-01-16 Thread Zhenghua Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15546?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17016740#comment-17016740 ] Zhenghua Gao commented on FLINK-15546: -- [~lzljs3620320] OK, I will file a PR soon. [~jark] Please

[jira] [Commented] (FLINK-14807) Add Table#collect api for fetching data to client

2020-01-16 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17016743#comment-17016743 ] Dawid Wysakowicz commented on FLINK-14807: -- [~aljoscha] Good point. The scope of FLINK-13943

[jira] [Created] (FLINK-15613) execute sql appear "java.lang.IndexOutOfBoundsException"

2020-01-16 Thread xiaojin.wy (Jira)
xiaojin.wy created FLINK-15613: -- Summary: execute sql appear "java.lang.IndexOutOfBoundsException" Key: FLINK-15613 URL: https://issues.apache.org/jira/browse/FLINK-15613 Project: Flink Issue

[jira] [Commented] (FLINK-15595) Resolution Order is chaotic not as FLIP-68 defined

2020-01-16 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15595?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17016751#comment-17016751 ] Timo Walther commented on FLINK-15595: -- The core problem is that FLIP-51 is still not entirely

[jira] [Closed] (FLINK-15152) Job running without periodic checkpoint for stop failed at the beginning

2020-01-16 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15152?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-15152. -- Resolution: Fixed merged commit e6aff96 into apache:master merged commit

[jira] [Commented] (FLINK-15595) Resolution Order is chaotic not as FLIP-68 defined

2020-01-16 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15595?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17016753#comment-17016753 ] Dawid Wysakowicz commented on FLINK-15595: -- My take is that the findings are correct and the

[GitHub] [flink] kl0u commented on issue #10685: [FLINK-14843][e2e] Refactor bucketing sink test to make it more stable and comprehensible

2020-01-16 Thread GitBox
kl0u commented on issue #10685: [FLINK-14843][e2e] Refactor bucketing sink test to make it more stable and comprehensible URL: https://github.com/apache/flink/pull/10685#issuecomment-575068069 Thanks for the work @banmoy ! Merged it

[GitHub] [flink] kl0u closed pull request #10685: [FLINK-14843][e2e] Refactor bucketing sink test to make it more stable and comprehensible

2020-01-16 Thread GitBox
kl0u closed pull request #10685: [FLINK-14843][e2e] Refactor bucketing sink test to make it more stable and comprehensible URL: https://github.com/apache/flink/pull/10685 This is an automated message from the Apache Git

[jira] [Commented] (FLINK-14122) Extend State Processor API to read ListCheckpointed operator state

2020-01-16 Thread Tzu-Li (Gordon) Tai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14122?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17016765#comment-17016765 ] Tzu-Li (Gordon) Tai commented on FLINK-14122: - One reason I see with supporting this is that

[jira] [Comment Edited] (FLINK-15595) Resolution Order is chaotic not as FLIP-68 defined

2020-01-16 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15595?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17016763#comment-17016763 ] Jingsong Lee edited comment on FLINK-15595 at 1/16/20 9:49 AM: --- Thanks 

[GitHub] [flink] flinkbot edited a comment on issue #10866: Enable TTL compaction filter by default and deprecate/remove some other TTL API

2020-01-16 Thread GitBox
flinkbot edited a comment on issue #10866: Enable TTL compaction filter by default and deprecate/remove some other TTL API URL: https://github.com/apache/flink/pull/10866#issuecomment-574738366 ## CI report: * b5f0c65665c7b395258e3bf9fe864e89d7c69f31 Travis:

[jira] [Commented] (FLINK-15595) Entirely implement resolution order as FLIP-68 concept

2020-01-16 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15595?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17016773#comment-17016773 ] Jingsong Lee commented on FLINK-15595: -- [~twalthr] [~dwysakowicz] BTW, another thing is that 

[jira] [Commented] (FLINK-15595) Entirely implement resolution order as FLIP-68 concept

2020-01-16 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15595?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17016781#comment-17016781 ] Timo Walther commented on FLINK-15595: -- We should use the {{FunctionKind}} to filter out function's

[jira] [Commented] (FLINK-14122) Extend State Processor API to read ListCheckpointed operator state

2020-01-16 Thread Aljoscha Krettek (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14122?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17016780#comment-17016780 ] Aljoscha Krettek commented on FLINK-14122: -- Yes, after I wrote my comment I also had that

[jira] [Created] (FLINK-15614) Consolidate documentation on how to integrate Hadoop

2020-01-16 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-15614: Summary: Consolidate documentation on how to integrate Hadoop Key: FLINK-15614 URL: https://issues.apache.org/jira/browse/FLINK-15614 Project: Flink

[GitHub] [flink] flinkbot edited a comment on issue #10852: [FLINK-15564][yarn][test] Fix YarnClusterDescriptorTest that failed to validate the original intended behavior

2020-01-16 Thread GitBox
flinkbot edited a comment on issue #10852: [FLINK-15564][yarn][test] Fix YarnClusterDescriptorTest that failed to validate the original intended behavior URL: https://github.com/apache/flink/pull/10852#issuecomment-574107516 ## CI report: *

[jira] [Assigned] (FLINK-15615) Docs: wrong guarantees stated for the file sink

2020-01-16 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15615?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reassigned FLINK-15615: -- Assignee: Roman Khachatryan > Docs: wrong guarantees stated for the file sink >

[GitHub] [flink] flinkbot edited a comment on issue #10866: Enable TTL compaction filter by default and deprecate/remove some other TTL API

2020-01-16 Thread GitBox
flinkbot edited a comment on issue #10866: Enable TTL compaction filter by default and deprecate/remove some other TTL API URL: https://github.com/apache/flink/pull/10866#issuecomment-574738366 ## CI report: * b5f0c65665c7b395258e3bf9fe864e89d7c69f31 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10845: [FLINK-15355][plugins]Classloader restricts access to parent to whitelist.

2020-01-16 Thread GitBox
flinkbot edited a comment on issue #10845: [FLINK-15355][plugins]Classloader restricts access to parent to whitelist. URL: https://github.com/apache/flink/pull/10845#issuecomment-573736294 ## CI report: * 0942cb8b913ba50ecf8d7ca28832c4c92bf78e6c Travis:

[GitHub] [flink] flinkbot edited a comment on issue #9413: [FLINK-13676][ml] Add class of Vector to Columns mapper

2020-01-16 Thread GitBox
flinkbot edited a comment on issue #9413: [FLINK-13676][ml] Add class of Vector to Columns mapper URL: https://github.com/apache/flink/pull/9413#issuecomment-519968250 ## CI report: * a585d0f8fef391d4da791b0cd1506e4f8b1acdc1 Travis:

[GitHub] [flink] dawidwys closed pull request #10829: [FLINK-14853][docs] Use higher granularity units in generated docs for Duration & MemorySize if possible

2020-01-16 Thread GitBox
dawidwys closed pull request #10829: [FLINK-14853][docs] Use higher granularity units in generated docs for Duration & MemorySize if possible URL: https://github.com/apache/flink/pull/10829 This is an automated message from

[GitHub] [flink] flinkbot commented on issue #10871: [FLINK-13758][client] Support to register DFS files as distributed cache

2020-01-16 Thread GitBox
flinkbot commented on issue #10871: [FLINK-13758][client] Support to register DFS files as distributed cache URL: https://github.com/apache/flink/pull/10871#issuecomment-575168528 ## CI report: * 8257d0ef74983dad3b34aa4fbcbabb9bae8f58b7 UNKNOWN Bot commands The

[GitHub] [flink] GJL commented on issue #10873: [hotfix][docs] Update docs/_config.yml for 1.10 release

2020-01-16 Thread GitBox
GJL commented on issue #10873: [hotfix][docs] Update docs/_config.yml for 1.10 release URL: https://github.com/apache/flink/pull/10873#issuecomment-575168498 Merged. This is an automated message from the Apache Git Service.

[GitHub] [flink] GJL closed pull request #10873: [hotfix][docs] Update docs/_config.yml for 1.10 release

2020-01-16 Thread GitBox
GJL closed pull request #10873: [hotfix][docs] Update docs/_config.yml for 1.10 release URL: https://github.com/apache/flink/pull/10873 This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [flink] flinkbot edited a comment on issue #10870: [FLINK-15616][python] Move boot error messages from python-udf-boot.log to taskmanager's log file

2020-01-16 Thread GitBox
flinkbot edited a comment on issue #10870: [FLINK-15616][python] Move boot error messages from python-udf-boot.log to taskmanager's log file URL: https://github.com/apache/flink/pull/10870#issuecomment-575153364 ## CI report: * 41d519bed15a88fdc2ee812bafa62daa4c13867e Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10866: Enable TTL compaction filter by default and deprecate/remove some other TTL API

2020-01-16 Thread GitBox
flinkbot edited a comment on issue #10866: Enable TTL compaction filter by default and deprecate/remove some other TTL API URL: https://github.com/apache/flink/pull/10866#issuecomment-574738366 ## CI report: * b5f0c65665c7b395258e3bf9fe864e89d7c69f31 Travis:

[GitHub] [flink] tillrohrmann merged pull request #10872: [hotfix][javadoc] Add a missing param doc for JobExecutionException

2020-01-16 Thread GitBox
tillrohrmann merged pull request #10872: [hotfix][javadoc] Add a missing param doc for JobExecutionException URL: https://github.com/apache/flink/pull/10872 This is an automated message from the Apache Git Service. To

[jira] [Commented] (FLINK-15552) SQL Client can not correctly create kafka table using --library to indicate a kafka connector directory

2020-01-16 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15552?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17016989#comment-17016989 ] Leonard Xu commented on FLINK-15552:   I fix and test it in my local environment and test e2e SQL

[GitHub] [flink] tillrohrmann closed pull request #10852: [FLINK-15564][yarn][test] Fix YarnClusterDescriptorTest that failed to validate the original intended behavior

2020-01-16 Thread GitBox
tillrohrmann closed pull request #10852: [FLINK-15564][yarn][test] Fix YarnClusterDescriptorTest that failed to validate the original intended behavior URL: https://github.com/apache/flink/pull/10852 This is an automated

[jira] [Commented] (FLINK-15620) State TTL: Remove deprecated enable default background cleanup

2020-01-16 Thread Andrey Zagrebin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15620?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17017046#comment-17017046 ] Andrey Zagrebin commented on FLINK-15620: - Follow-up for FLINK-15606. > State TTL: Remove

  1   2   3   4   5   >