[GitHub] [flink] libenchao commented on a change in pull request #12421: [FLINK-18002][json] Correct the behavior for ContainerNode as varchar…

2020-06-01 Thread GitBox
libenchao commented on a change in pull request #12421: URL: https://github.com/apache/flink/pull/12421#discussion_r433055376 ## File path: flink-formats/flink-json/src/test/java/org/apache/flink/formats/json/JsonRowDataSerDeSchemaTest.java ## @@ -375,8 +375,12 @@ private

[jira] [Updated] (FLINK-18047) [DDL] ExecutotionEnvironment set the parallelism did not take effect

2020-06-01 Thread pengnengsong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18047?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] pengnengsong updated FLINK-18047: - Issue Type: Bug (was: Improvement) > [DDL] ExecutotionEnvironment set the parallelism did not

[jira] [Created] (FLINK-18047) [DDL] ExecutotionEnvironment set the parallelism did not take effect

2020-06-01 Thread pengnengsong (Jira)
pengnengsong created FLINK-18047: Summary: [DDL] ExecutotionEnvironment set the parallelism did not take effect Key: FLINK-18047 URL: https://issues.apache.org/jira/browse/FLINK-18047 Project: Flink

[jira] [Closed] (FLINK-17230) Fix incorrect returned address of Endpoint for the ClusterIP Service

2020-06-01 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17230?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-17230. -- Fix Version/s: (was: 1.12.0) Resolution: Fixed merged commit 9737f50 into

[jira] [Comment Edited] (FLINK-17230) Fix incorrect returned address of Endpoint for the ClusterIP Service

2020-06-01 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17230?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17120814#comment-17120814 ] Piotr Nowojski edited comment on FLINK-17230 at 6/1/20, 7:59 AM: - merged

[jira] [Updated] (FLINK-18016) Document Unix Socket Remote Functions

2020-06-01 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18016?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-18016: --- Labels: pull-request-available (was: ) > Document Unix Socket Remote Functions >

[GitHub] [flink-statefun] tzulitai opened a new pull request #124: [FLINK-18016] [doc] Add documentation for UDS domain socket transport

2020-06-01 Thread GitBox
tzulitai opened a new pull request #124: URL: https://github.com/apache/flink-statefun/pull/124 Based on #123 just to avoid any merge conflicts in the docs. cc @sjwiesman @igalshilman This is an automated message from

[jira] [Commented] (FLINK-18043) Translate "Scala API Extensions" page of "DataStream API" into Chinese

2020-06-01 Thread Zhiye Zou (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18043?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17120847#comment-17120847 ] Zhiye Zou commented on FLINK-18043: --- OK :) > Translate "Scala API Extensions" page of "DataStream

[GitHub] [flink] zhuzhurk commented on a change in pull request #12278: [FLINK-17019][runtime] Fulfill slot requests in request order

2020-06-01 Thread GitBox
zhuzhurk commented on a change in pull request #12278: URL: https://github.com/apache/flink/pull/12278#discussion_r433113663 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/jobmaster/slotpool/SlotPoolRequestCompletionTest.java ## @@ -103,7 +123,7 @@ private

[GitHub] [flink] zhuzhurk commented on a change in pull request #12278: [FLINK-17019][runtime] Fulfill slot requests in request order

2020-06-01 Thread GitBox
zhuzhurk commented on a change in pull request #12278: URL: https://github.com/apache/flink/pull/12278#discussion_r433114179 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/SlotPoolImpl.java ## @@ -698,13 +680,13 @@ boolean offerSlot(

[GitHub] [flink] flinkbot edited a comment on pull request #12423: [FLINK-18034][runtime] Introduce PreferredLocationsRetriever

2020-06-01 Thread GitBox
flinkbot edited a comment on pull request #12423: URL: https://github.com/apache/flink/pull/12423#issuecomment-636712044 ## CI report: * 362a6480b17c1133aae420e09518b08482edf7e7 Azure:

[jira] [Commented] (FLINK-17788) scala shell in yarn mode is broken

2020-06-01 Thread Jeff Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17788?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17120871#comment-17120871 ] Jeff Zhang commented on FLINK-17788: [~kkl0u] The second yarn app fail to launch due to port

[jira] [Commented] (FLINK-18048) "--host" option could not take effect for standalone application cluster

2020-06-01 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18048?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17120887#comment-17120887 ] Yang Wang commented on FLINK-18048: --- [~kkl0u] Could you assign this ticket to me? I will attach a PR

[jira] [Updated] (FLINK-18046) Decimal column stats not supported for Hive table

2020-06-01 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18046?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-18046: --- Labels: pull-request-available (was: ) > Decimal column stats not supported for Hive table

[GitHub] [flink] lirui-apache opened a new pull request #12424: [FLINK-18046][hive] Support stats for decimal columns in Hive table

2020-06-01 Thread GitBox
lirui-apache opened a new pull request #12424: URL: https://github.com/apache/flink/pull/12424 ## What is the purpose of the change Fix the issue that Hive table decimal column stats is not supported ## Brief change log - Return

[jira] [Created] (FLINK-18046) Decimal column stats not supported for Hive table

2020-06-01 Thread Rui Li (Jira)
Rui Li created FLINK-18046: -- Summary: Decimal column stats not supported for Hive table Key: FLINK-18046 URL: https://issues.apache.org/jira/browse/FLINK-18046 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-18030) Hive UDF doesn't accept empty string literal parameter

2020-06-01 Thread Rui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18030?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li updated FLINK-18030: --- Fix Version/s: (was: 1.12.0) 1.11.0 > Hive UDF doesn't accept empty string literal

[GitHub] [flink] flinkbot edited a comment on pull request #12406: [FLINK-17994][checkpointing] Fix the race condition between CheckpointBarrierUnaligner#processBarrier and #notifyBarrierReceived

2020-06-01 Thread GitBox
flinkbot edited a comment on pull request #12406: URL: https://github.com/apache/flink/pull/12406#issuecomment-635907759 ## CI report: * b47a7645fd5636a98050231522a076537576e9a8 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12378: [FLINK-17965][sql-parser-hive] Hive dialect needs to unescape backslash in string literals

2020-06-01 Thread GitBox
flinkbot edited a comment on pull request #12378: URL: https://github.com/apache/flink/pull/12378#issuecomment-635291016 ## CI report: * 4b4156796eded5a87a097c589c2d7d06a829bafa Azure:

[jira] [Commented] (FLINK-18006) It will throw Invalid lambda deserialization Exception when writing to elastic search with new format

2020-06-01 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18006?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17120834#comment-17120834 ] Jark Wu commented on FLINK-18006: - I also reproduced this problem by using SQL CLIENT. But I didn't find

[GitHub] [flink] zhijiangW commented on pull request #12406: [FLINK-17994][checkpointing] Fix the race condition between CheckpointBarrierUnaligner#processBarrier and #notifyBarrierReceived

2020-06-01 Thread GitBox
zhijiangW commented on pull request #12406: URL: https://github.com/apache/flink/pull/12406#issuecomment-636698426 Thanks for the review @pnowojski , merging! This is an automated message from the Apache Git Service. To

[GitHub] [flink] zhijiangW edited a comment on pull request #12406: [FLINK-17994][checkpointing] Fix the race condition between CheckpointBarrierUnaligner#processBarrier and #notifyBarrierReceived

2020-06-01 Thread GitBox
zhijiangW edited a comment on pull request #12406: URL: https://github.com/apache/flink/pull/12406#issuecomment-636698426 Thanks for the review @pnowojski , i will squash the last two commits and merge! This is an automated

[GitHub] [flink] flinkbot edited a comment on pull request #12144: [FLINK-17384][flink-dist] support read hbase conf dir from flink.conf.

2020-06-01 Thread GitBox
flinkbot edited a comment on pull request #12144: URL: https://github.com/apache/flink/pull/12144#issuecomment-628475376 ## CI report: * d36b959fb16a91c15babda10dd884cbbdec58420 UNKNOWN * a0fd8094daa24b484fbfdf2f2a0ec6d2b79271e6 Azure:

[jira] [Commented] (FLINK-17726) Scheduler should take care of tasks directly canceled by TaskManager

2020-06-01 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17726?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17120883#comment-17120883 ] Nicholas Jiang commented on FLINK-17726: [~zhuzh]I have double checked the methods that trigger

[jira] [Comment Edited] (FLINK-18048) "--host" option could not take effect for standalone application cluster

2020-06-01 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18048?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17120887#comment-17120887 ] Yang Wang edited comment on FLINK-18048 at 6/1/20, 9:37 AM: [~zhuzh] Could

[jira] [Updated] (FLINK-17901) Add module interface in PyFlink

2020-06-01 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17901?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-17901: --- Labels: pull-request-available starter (was: starter) > Add module interface in PyFlink >

[GitHub] [flink] SteNicholas opened a new pull request #12422: [FLINK-17901][python] Add module interface in PyFlink

2020-06-01 Thread GitBox
SteNicholas opened a new pull request #12422: URL: https://github.com/apache/flink/pull/12422 ## What is the purpose of the change *Method ```loadModule``` and ```unloadModule``` interfaces in the Java TableEnvironment are not available in the PyFlink Table API, that should provide

[GitHub] [flink] flinkbot edited a comment on pull request #12421: [FLINK-18002][json] Correct the behavior for ContainerNode as varchar…

2020-06-01 Thread GitBox
flinkbot edited a comment on pull request #12421: URL: https://github.com/apache/flink/pull/12421#issuecomment-636607751 ## CI report: * 4947ec157537f1bc8dfab601ab8ad885eb725200 Azure:

[GitHub] [flink] flinkbot commented on pull request #12422: [FLINK-17901][python] Add module interface in PyFlink

2020-06-01 Thread GitBox
flinkbot commented on pull request #12422: URL: https://github.com/apache/flink/pull/12422#issuecomment-636639198 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

[GitHub] [flink] flinkbot edited a comment on pull request #12421: [FLINK-18002][json] Correct the behavior for ContainerNode as varchar…

2020-06-01 Thread GitBox
flinkbot edited a comment on pull request #12421: URL: https://github.com/apache/flink/pull/12421#issuecomment-636607751 ## CI report: * 4947ec157537f1bc8dfab601ab8ad885eb725200 Azure:

[GitHub] [flink] flinkbot commented on pull request #12422: [FLINK-17901][python] Add module interface in PyFlink

2020-06-01 Thread GitBox
flinkbot commented on pull request #12422: URL: https://github.com/apache/flink/pull/12422#issuecomment-636647115 ## CI report: * 3a387da20f29d9b1f6baf1e57c6d9979d27dd81f UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #12146: [FLINK-17968][hbase] Fix Hadoop Configuration is not properly serialized in HBaseRowInputFormat

2020-06-01 Thread GitBox
flinkbot edited a comment on pull request #12146: URL: https://github.com/apache/flink/pull/12146#issuecomment-628508688 ## CI report: * ea008e0dffab41f7f3ac373746605cdc3f6a2388 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12144: [FLINK-17384][flink-dist] support read hbase conf dir from flink.conf.

2020-06-01 Thread GitBox
flinkbot edited a comment on pull request #12144: URL: https://github.com/apache/flink/pull/12144#issuecomment-628475376 ## CI report: * d36b959fb16a91c15babda10dd884cbbdec58420 UNKNOWN * 497b8ff078b4055c3a69b56e762dfecb7973c3a6 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12422: [FLINK-17901][python] Add module interface in PyFlink

2020-06-01 Thread GitBox
flinkbot edited a comment on pull request #12422: URL: https://github.com/apache/flink/pull/12422#issuecomment-636647115 ## CI report: * 3a387da20f29d9b1f6baf1e57c6d9979d27dd81f Azure:

[GitHub] [flink-statefun] tzulitai commented on a change in pull request #123: [FLINK-18015] [doc] Add documentation for state expiration

2020-06-01 Thread GitBox
tzulitai commented on a change in pull request #123: URL: https://github.com/apache/flink-statefun/pull/123#discussion_r433101685 ## File path: docs/sdk/java.md ## @@ -364,6 +364,47 @@ PersistedTable table = PersistedTable.of("my-table", String.cla PersistedAppendingBuffer

[GitHub] [flink-statefun] tzulitai opened a new pull request #123: [FLINK-18015] [doc] Add documentation for state expiration

2020-06-01 Thread GitBox
tzulitai opened a new pull request #123: URL: https://github.com/apache/flink-statefun/pull/123 cc @sjwiesman for review. This is an automated message from the Apache Git Service. To respond to the message, please log on to

[GitHub] [flink-statefun] tzulitai commented on a change in pull request #123: [FLINK-18015] [doc] Add documentation for state expiration

2020-06-01 Thread GitBox
tzulitai commented on a change in pull request #123: URL: https://github.com/apache/flink-statefun/pull/123#discussion_r433101941 ## File path: docs/sdk/python.md ## @@ -158,9 +158,8 @@ All stateful functions may contain state by merely storing values within the ``c The data

[jira] [Updated] (FLINK-18015) Document state TTL support in stateful functions

2020-06-01 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18015?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-18015: --- Labels: pull-request-available (was: ) > Document state TTL support in stateful functions

[GitHub] [flink] flinkbot commented on pull request #12423: [FLINK-18034][runtime] Introduce PreferredLocationsRetriever

2020-06-01 Thread GitBox
flinkbot commented on pull request #12423: URL: https://github.com/apache/flink/pull/12423#issuecomment-636697058 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

[GitHub] [flink] flinkbot commented on pull request #12423: [FLINK-18034][runtime] Introduce PreferredLocationsRetriever

2020-06-01 Thread GitBox
flinkbot commented on pull request #12423: URL: https://github.com/apache/flink/pull/12423#issuecomment-636712044 ## CI report: * 362a6480b17c1133aae420e09518b08482edf7e7 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #12375: [FLINK-17017][runtime] Implements bulk allocation for physical slots

2020-06-01 Thread GitBox
flinkbot edited a comment on pull request #12375: URL: https://github.com/apache/flink/pull/12375#issuecomment-635184560 ## CI report: * 395c6cba8c463cffe2cf3cc70d91e6c6ff0dbb9f Azure:

[jira] [Updated] (FLINK-18046) Decimal column stats not supported for Hive table

2020-06-01 Thread Rui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18046?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li updated FLINK-18046: --- Description: For now, we can just return {{CatalogColumnStatisticsDataDouble}} for decimal columns. >

[GitHub] [flink] flinkbot edited a comment on pull request #12378: [FLINK-17965][sql-parser-hive] Hive dialect needs to unescape backslash in string literals

2020-06-01 Thread GitBox
flinkbot edited a comment on pull request #12378: URL: https://github.com/apache/flink/pull/12378#issuecomment-635291016 ## CI report: * 4b4156796eded5a87a097c589c2d7d06a829bafa Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12421: [FLINK-18002][json] Correct the behavior for ContainerNode as varchar…

2020-06-01 Thread GitBox
flinkbot edited a comment on pull request #12421: URL: https://github.com/apache/flink/pull/12421#issuecomment-636607751 ## CI report: * 4947ec157537f1bc8dfab601ab8ad885eb725200 Azure:

[jira] [Comment Edited] (FLINK-18043) Translate "Scala API Extensions" page of "DataStream API" into Chinese

2020-06-01 Thread Yubin Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18043?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17120829#comment-17120829 ] Yubin Li edited comment on FLINK-18043 at 6/1/20, 8:26 AM: --- Hi [~zouzhiye],

[GitHub] [flink] zhuzhurk opened a new pull request #12423: [FLINK-18034][runtime] Introduce PreferredLocationsRetriever

2020-06-01 Thread GitBox
zhuzhurk opened a new pull request #12423: URL: https://github.com/apache/flink/pull/12423 ## What is the purpose of the change Preferred locations based on state and inputs are scattered into multiple components, which makes it harder to reasoning the calculation and complicates

[jira] [Commented] (FLINK-18006) It will throw Invalid lambda deserialization Exception when writing to elastic search with new format

2020-06-01 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18006?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17120837#comment-17120837 ] Jark Wu commented on FLINK-18006: - This maybe a bug of JDK:

[jira] [Updated] (FLINK-18047) [DDL] ExecutotionEnvironment set the parallelism did not take effect

2020-06-01 Thread pengnengsong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18047?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] pengnengsong updated FLINK-18047: - Description: using filesystem batch write csv data to file, we set parallelism to 1, but

[jira] [Created] (FLINK-18048) "--host" option could not take effect for standalone application cluster

2020-06-01 Thread Yang Wang (Jira)
Yang Wang created FLINK-18048: - Summary: "--host" option could not take effect for standalone application cluster Key: FLINK-18048 URL: https://issues.apache.org/jira/browse/FLINK-18048 Project: Flink

[jira] [Updated] (FLINK-10954) Hardlink from files of previous local stored state might cross devices

2020-06-01 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10954?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-10954: - Priority: Critical (was: Major) > Hardlink from files of previous local stored state might cross

[jira] [Updated] (FLINK-10954) Hardlink from files of previous local stored state might cross devices

2020-06-01 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10954?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-10954: - Fix Version/s: (was: 1.11.0) 1.12.0 > Hardlink from files of previous local

[jira] [Commented] (FLINK-18043) Translate "Scala API Extensions" page of "DataStream API" into Chinese

2020-06-01 Thread Zhiye Zou (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18043?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17120817#comment-17120817 ] Zhiye Zou commented on FLINK-18043: --- HI,[~liyubin117] . I'm a starter. I'm willing to translate this

[GitHub] [flink] zhijiangW merged pull request #12406: [FLINK-17994][checkpointing] Fix the race condition between CheckpointBarrierUnaligner#processBarrier and #notifyBarrierReceived

2020-06-01 Thread GitBox
zhijiangW merged pull request #12406: URL: https://github.com/apache/flink/pull/12406 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go

[jira] [Updated] (FLINK-17994) Fix the race condition between CheckpointBarrierUnaligner#processBarrier and #notifyBarrierReceived

2020-06-01 Thread Zhijiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17994?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang updated FLINK-17994: - Affects Version/s: 1.11.0 > Fix the race condition between CheckpointBarrierUnaligner#processBarrier

[jira] [Comment Edited] (FLINK-17918) Blink Jobs are loosing data on recovery

2020-06-01 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17918?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17120870#comment-17120870 ] Piotr Nowojski edited comment on FLINK-17918 at 6/1/20, 9:12 AM: - Some

[GitHub] [flink] flinkbot edited a comment on pull request #12375: [FLINK-17017][runtime] Implements bulk allocation for physical slots

2020-06-01 Thread GitBox
flinkbot edited a comment on pull request #12375: URL: https://github.com/apache/flink/pull/12375#issuecomment-635184560 ## CI report: * 395c6cba8c463cffe2cf3cc70d91e6c6ff0dbb9f Azure:

[jira] [Commented] (FLINK-17918) Blink Jobs are loosing data on recovery

2020-06-01 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17918?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17120870#comment-17120870 ] Piotr Nowojski commented on FLINK-17918: Some status update. [~AHeise] has added quite a big of

[jira] [Created] (FLINK-18044) Add the subtask index information to the SourceReaderContext.

2020-06-01 Thread Jiangjie Qin (Jira)
Jiangjie Qin created FLINK-18044: Summary: Add the subtask index information to the SourceReaderContext. Key: FLINK-18044 URL: https://issues.apache.org/jira/browse/FLINK-18044 Project: Flink

[jira] [Updated] (FLINK-18047) [DDL] ExecutotionEnvironment set the parallelism did not take effect

2020-06-01 Thread pengnengsong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18047?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] pengnengsong updated FLINK-18047: - Description: using filesystem batch write csv data to file, we set parallelism to 1, but

[jira] [Comment Edited] (FLINK-18043) Translate "Scala API Extensions" page of "DataStream API" into Chinese

2020-06-01 Thread Yubin Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18043?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17120829#comment-17120829 ] Yubin Li edited comment on FLINK-18043 at 6/1/20, 8:24 AM: --- Hi [~zouzhiye],

[jira] [Commented] (FLINK-18043) Translate "Scala API Extensions" page of "DataStream API" into Chinese

2020-06-01 Thread Yubin Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18043?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17120829#comment-17120829 ] Yubin Li commented on FLINK-18043: -- Hi [~zouzhiye], Sorry, I am also a starter, I dont have the right

[jira] [Updated] (FLINK-18006) It will throw Invalid lambda deserialization Exception when writing to elastic search with new format

2020-06-01 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18006?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-18006: Priority: Blocker (was: Critical) > It will throw Invalid lambda deserialization Exception when writing

[GitHub] [flink] senegalo commented on pull request #12056: [FLINK-17502] [flink-connector-rabbitmq] RMQSource refactor

2020-06-01 Thread GitBox
senegalo commented on pull request #12056: URL: https://github.com/apache/flink/pull/12056#issuecomment-636692690 @austince and @dawidwys it seems there is an issue with azure can't rerun the pipeline and when it ran on Saturday i couldn't find mvn in the e2e tests. Please advise.

[jira] [Updated] (FLINK-17994) Fix the race condition between CheckpointBarrierUnaligner#processBarrier and #notifyBarrierReceived

2020-06-01 Thread Zhijiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17994?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang updated FLINK-17994: - Fix Version/s: 1.12.0 > Fix the race condition between CheckpointBarrierUnaligner#processBarrier and >

[GitHub] [flink] jinglining commented on pull request #11752: [FLINK-14713][rest]Show All Attempts For Vertex SubTask In Rest Api

2020-06-01 Thread GitBox
jinglining commented on pull request #11752: URL: https://github.com/apache/flink/pull/11752#issuecomment-636715299 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message,

[jira] [Commented] (FLINK-17918) Blink Jobs are loosing data on recovery

2020-06-01 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17918?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17120903#comment-17120903 ] Kurt Young commented on FLINK-17918: >From above comment, it seems that the problem is caused by

[jira] [Created] (FLINK-18045) Newest version reintroduced a bug causing not working on secured MapR

2020-06-01 Thread Jira
Bartosz Krasiński created FLINK-18045: - Summary: Newest version reintroduced a bug causing not working on secured MapR Key: FLINK-18045 URL: https://issues.apache.org/jira/browse/FLINK-18045

[jira] [Updated] (FLINK-18034) Introduce PreferredLocationsRetriever

2020-06-01 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18034?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-18034: --- Labels: pull-request-available (was: ) > Introduce PreferredLocationsRetriever >

[GitHub] [flink] zhuzhurk commented on a change in pull request #12256: [FLINK-17018][runtime] Allocates slots in bulks for pipelined region scheduling

2020-06-01 Thread GitBox
zhuzhurk commented on a change in pull request #12256: URL: https://github.com/apache/flink/pull/12256#discussion_r433106488 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/DefaultExecutionSlotAllocator.java ## @@ -96,52 +97,88 @@ public

[jira] [Comment Edited] (FLINK-18043) Translate "Scala API Extensions" page of "DataStream API" into Chinese

2020-06-01 Thread Yubin Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18043?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17120829#comment-17120829 ] Yubin Li edited comment on FLINK-18043 at 6/1/20, 8:27 AM: --- Hi [~zouzhiye],

[jira] [Closed] (FLINK-17994) Fix the race condition between CheckpointBarrierUnaligner#processBarrier and #notifyBarrierReceived

2020-06-01 Thread Zhijiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17994?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang closed FLINK-17994. Resolution: Fixed Merged in release-1.11 : 64ca88ac989ee7525cb821670f293404b7b30d2d Will cherry-pick to

[GitHub] [flink-statefun] igalshilman commented on a change in pull request #124: [FLINK-18016] [doc] Add documentation for UDS domain socket transport

2020-06-01 Thread GitBox
igalshilman commented on a change in pull request #124: URL: https://github.com/apache/flink-statefun/pull/124#discussion_r433116138 ## File path: docs/sdk/java.md ## @@ -364,6 +364,47 @@ PersistedTable table = PersistedTable.of("my-table", String.cla

[jira] [Commented] (FLINK-18047) [DDL] ExecutotionEnvironment set the parallelism did not take effect

2020-06-01 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18047?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17120867#comment-17120867 ] godfrey he commented on FLINK-18047: {{TableEnvironment}} always holds

[jira] [Commented] (FLINK-17918) Blink Jobs are loosing data on recovery

2020-06-01 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17918?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17120902#comment-17120902 ] Kurt Young commented on FLINK-17918: cc [~jark]    > Blink Jobs are loosing data on recovery >

[GitHub] [flink] flinkbot edited a comment on pull request #12144: [FLINK-17384][flink-dist] support read hbase conf dir from flink.conf.

2020-06-01 Thread GitBox
flinkbot edited a comment on pull request #12144: URL: https://github.com/apache/flink/pull/12144#issuecomment-628475376 ## CI report: * d36b959fb16a91c15babda10dd884cbbdec58420 UNKNOWN * 497b8ff078b4055c3a69b56e762dfecb7973c3a6 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12419: [FLINK-17996][table-planner-blink] NPE in CatalogTableStatisticsConverter.convertToColumnStats method

2020-06-01 Thread GitBox
flinkbot edited a comment on pull request #12419: URL: https://github.com/apache/flink/pull/12419#issuecomment-636436128 ## CI report: * 64195fc52bf63e7631d059f87b63cc6dcd3b9b8d Azure:

[GitHub] [flink] pnowojski merged pull request #12397: [FLINK-17230] Fix incorrect address of Endpoint for external Service with ClusterIP type

2020-06-01 Thread GitBox
pnowojski merged pull request #12397: URL: https://github.com/apache/flink/pull/12397 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go

[jira] [Updated] (FLINK-17918) Blink Jobs are loosing data on recovery

2020-06-01 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17918?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-17918: --- Summary: Blink Jobs are loosing data on recovery (was: Jobs with two input operators are

[GitHub] [flink] flinkbot commented on pull request #12424: [FLINK-18046][hive] Support stats for decimal columns in Hive table

2020-06-01 Thread GitBox
flinkbot commented on pull request #12424: URL: https://github.com/apache/flink/pull/12424#issuecomment-636748319 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

[jira] [Assigned] (FLINK-18048) "--host" option could not take effect for standalone application cluster

2020-06-01 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18048?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu reassigned FLINK-18048: --- Assignee: Yang Wang > "--host" option could not take effect for standalone application cluster >

[jira] [Commented] (FLINK-18048) "--host" option could not take effect for standalone application cluster

2020-06-01 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18048?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17120901#comment-17120901 ] Zhu Zhu commented on FLINK-18048: - Yes you are right that host option should be added to `getOptions()`

[GitHub] [flink] SteNicholas removed a comment on pull request #12419: [FLINK-17996][table-planner-blink] NPE in CatalogTableStatisticsConverter.convertToColumnStats method

2020-06-01 Thread GitBox
SteNicholas removed a comment on pull request #12419: URL: https://github.com/apache/flink/pull/12419#issuecomment-636850914 @JingsongLi @wuchong Would you please help to merge? This is an automated message from the Apache

[GitHub] [flink] libenchao commented on a change in pull request #12429: [FLINK-17340][docs] Update docs which related to default planner changing

2020-06-01 Thread GitBox
libenchao commented on a change in pull request #12429: URL: https://github.com/apache/flink/pull/12429#discussion_r433588491 ## File path: docs/dev/table/common.md ## @@ -32,12 +32,11 @@ Main Differences Between the Two Planners 1. Blink treats batch jobs as a special case

[GitHub] [flink] zhijiangW commented on pull request #12430: [FLINK-17823][network] Resolve the race condition while releasing RemoteInputChannel

2020-06-01 Thread GitBox
zhijiangW commented on pull request #12430: URL: https://github.com/apache/flink/pull/12430#issuecomment-637237923 Cherry-pick from release-1.11 to master, the original PR #12261 was already reviewed and approved, merging when azure pass.

[jira] [Closed] (FLINK-18000) Flink-job-manger Get a X509 error, when I try to delpoy flink on kubelet 1.18.2

2020-06-01 Thread Max (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18000?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Max closed FLINK-18000. --- Resolution: Not A Problem > Flink-job-manger Get a X509 error, when I try to delpoy flink on kubelet > 1.18.2 >

[GitHub] [flink] flinkbot commented on pull request #12430: [FLINK-17823][network] Resolve the race condition while releasing RemoteInputChannel

2020-06-01 Thread GitBox
flinkbot commented on pull request #12430: URL: https://github.com/apache/flink/pull/12430#issuecomment-637238327 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

[jira] [Assigned] (FLINK-17918) Blink Jobs are loosing data on recovery

2020-06-01 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17918?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-17918: --- Assignee: (was: Jark Wu) > Blink Jobs are loosing data on recovery >

[jira] [Assigned] (FLINK-17918) Blink Jobs are loosing data on recovery

2020-06-01 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17918?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-17918: --- Assignee: Jark Wu (was: Arvid Heise) > Blink Jobs are loosing data on recovery >

[GitHub] [flink] wuchong commented on a change in pull request #12386: [FLINK-17995][docs][connectors] Redesign Table & SQL Connectors page and add HBase connector documentation

2020-06-01 Thread GitBox
wuchong commented on a change in pull request #12386: URL: https://github.com/apache/flink/pull/12386#discussion_r433601307 ## File path: docs/dev/table/connectors/hbase.md ## @@ -0,0 +1,291 @@ +--- +title: "HBase SQL Connector" +nav-title: HBase +nav-parent_id: sql-connectors

[GitHub] [flink] wuchong commented on a change in pull request #12386: [FLINK-17995][docs][connectors] Redesign Table & SQL Connectors page and add HBase connector documentation

2020-06-01 Thread GitBox
wuchong commented on a change in pull request #12386: URL: https://github.com/apache/flink/pull/12386#discussion_r433601187 ## File path: docs/dev/table/connectors/hbase.md ## @@ -0,0 +1,291 @@ +--- +title: "HBase SQL Connector" +nav-title: HBase +nav-parent_id: sql-connectors

[jira] [Comment Edited] (FLINK-17918) Blink Jobs are loosing data on recovery

2020-06-01 Thread Yu Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17918?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17121532#comment-17121532 ] Yu Li edited comment on FLINK-17918 at 6/2/20, 3:38 AM: Thanks [~jark], I was

[jira] [Commented] (FLINK-17918) Blink Jobs are loosing data on recovery

2020-06-01 Thread Yu Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17918?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17121532#comment-17121532 ] Yu Li commented on FLINK-17918: --- Thanks [~jark], I was about to add the same comments, that the observed

[jira] [Reopened] (FLINK-16397) flink metric graphite will format double metrics to "%2.2f"

2020-06-01 Thread BlaBlabla (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16397?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] BlaBlabla reopened FLINK-16397: --- There is a new feature to support custom floating point formatter in Graphite reporter, can flink

[GitHub] [flink] SteNicholas edited a comment on pull request #12367: [FLINK-17960][python][docs] Improve commands in the "Common Questions" document for PyFlink

2020-06-01 Thread GitBox
SteNicholas edited a comment on pull request #12367: URL: https://github.com/apache/flink/pull/12367#issuecomment-636436145 @zentol Sorry for disturbing your work, I would like to confirm with you whether the value of ```{{ site.baseurl }}``` doesn't start with ```https:```.

[GitHub] [flink] yangyichao-mango commented on pull request #12417: [hotfix][docs] Remove the redundant punctuation in dev/training/index.md

2020-06-01 Thread GitBox
yangyichao-mango commented on pull request #12417: URL: https://github.com/apache/flink/pull/12417#issuecomment-637221586 Hi @alpinegizmo . Can you help to review this commit? This is an automated message from the Apache Git

[GitHub] [flink] danny0405 commented on a change in pull request #12386: [FLINK-17995][docs][connectors] Redesign Table & SQL Connectors page and add HBase connector documentation

2020-06-01 Thread GitBox
danny0405 commented on a change in pull request #12386: URL: https://github.com/apache/flink/pull/12386#discussion_r433589932 ## File path: docs/dev/table/connectors/index.md ## @@ -0,0 +1,268 @@ +--- +title: "Table & SQL Connectors" +nav-id: sql-connectors +nav-parent_id:

[jira] [Commented] (FLINK-17726) Scheduler should take care of tasks directly canceled by TaskManager

2020-06-01 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17726?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17121514#comment-17121514 ] Zhu Zhu commented on FLINK-17726: - [~nicholasjiang] What I mean is that not all kinds of directly

[GitHub] [flink] libenchao commented on a change in pull request #12428: [FLINK-18049] the AvroRowDeserializationSchema can not read the avro …

2020-06-01 Thread GitBox
libenchao commented on a change in pull request #12428: URL: https://github.com/apache/flink/pull/12428#discussion_r433593166 ## File path: flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroRowDeserializationSchema.java ## @@ -157,13 +150,13 @@ public

[GitHub] [flink] libenchao commented on pull request #12429: [FLINK-17340][docs] Update docs which related to default planner changing

2020-06-01 Thread GitBox
libenchao commented on pull request #12429: URL: https://github.com/apache/flink/pull/12429#issuecomment-637244509 @KurtYoung Thanks for addressing my comments, the changes LGTM now. This is an automated message from the

[jira] [Comment Edited] (FLINK-17918) Blink Jobs are loosing data on recovery

2020-06-01 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17918?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17121526#comment-17121526 ] Jark Wu edited comment on FLINK-17918 at 6/2/20, 3:23 AM: -- Thanks [~pnowojski]

  1   2   3   >