[GitHub] [flink] JingsongLi merged pull request #12217: [FLINK-17786][sql-client] Remove dialect from ExecutionEntry

2020-05-19 Thread GitBox
JingsongLi merged pull request #12217: URL: https://github.com/apache/flink/pull/12217 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

[GitHub] [flink] twalthr commented on pull request #12232: [FLINK-15947] Finish moving scala expression DSL to flink-table-api-scala

2020-05-19 Thread GitBox
twalthr commented on pull request #12232: URL: https://github.com/apache/flink/pull/12232#issuecomment-630625826 Thanks for opening a PR for this topic @dawidwys. I wish we could avoid this but I don't see a possibility to prevent this change. The clash with the Scala macro and the annoyin

[GitHub] [flink] curcur commented on a change in pull request #12205: [FLINK-17780][checkpointing] Add task name to log statements of ChannelStateWriter.

2020-05-19 Thread GitBox
curcur commented on a change in pull request #12205: URL: https://github.com/apache/flink/pull/12205#discussion_r427066016 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/channel/ChannelStateWriteRequestExecutorImpl.java ## @@ -79,7 +84,7 @@ priva

[jira] [Closed] (FLINK-17786) Cannot switch dialect in SQL CLI

2020-05-19 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17786?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-17786. Resolution: Fixed master: ce0f334713a4d994183cc5f415fcf8896cd793fc release-1.11: 90982ca1a9595bda

[jira] [Created] (FLINK-17805) InputProcessorUtil doesn't handle indexes for multiple inputs operators correctly

2020-05-19 Thread Piotr Nowojski (Jira)
Piotr Nowojski created FLINK-17805: -- Summary: InputProcessorUtil doesn't handle indexes for multiple inputs operators correctly Key: FLINK-17805 URL: https://issues.apache.org/jira/browse/FLINK-17805

[jira] [Commented] (FLINK-12030) KafkaITCase.testMultipleSourcesOnePartition is unstable: This server does not host this topic-partition

2020-05-19 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12030?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17110910#comment-17110910 ] Robert Metzger commented on FLINK-12030: https://dev.azure.com/apache-flink/apac

[GitHub] [flink] curcur commented on a change in pull request #12205: [FLINK-17780][checkpointing] Add task name to log statements of ChannelStateWriter.

2020-05-19 Thread GitBox
curcur commented on a change in pull request #12205: URL: https://github.com/apache/flink/pull/12205#discussion_r427066016 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/channel/ChannelStateWriteRequestExecutorImpl.java ## @@ -79,7 +84,7 @@ priva

[GitHub] [flink] flinkbot edited a comment on pull request #12181: [FLINK-17645][runtime] Fix SafetyNetCloseableRegistry constructor bug.

2020-05-19 Thread GitBox
flinkbot edited a comment on pull request #12181: URL: https://github.com/apache/flink/pull/12181#issuecomment-629344595 ## CI report: * caf4400401fbaffaaeb0e16fafe3de1bcee1cc8b Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-12030) KafkaITCase.testMultipleSourcesOnePartition is unstable: This server does not host this topic-partition

2020-05-19 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12030?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17110911#comment-17110911 ] Robert Metzger commented on FLINK-12030: https://dev.azure.com/apache-flink/apac

[GitHub] [flink] curcur commented on a change in pull request #12205: [FLINK-17780][checkpointing] Add task name to log statements of ChannelStateWriter.

2020-05-19 Thread GitBox
curcur commented on a change in pull request #12205: URL: https://github.com/apache/flink/pull/12205#discussion_r427066016 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/channel/ChannelStateWriteRequestExecutorImpl.java ## @@ -79,7 +84,7 @@ priva

[GitHub] [flink] curcur commented on a change in pull request #12205: [FLINK-17780][checkpointing] Add task name to log statements of ChannelStateWriter.

2020-05-19 Thread GitBox
curcur commented on a change in pull request #12205: URL: https://github.com/apache/flink/pull/12205#discussion_r427066016 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/channel/ChannelStateWriteRequestExecutorImpl.java ## @@ -79,7 +84,7 @@ priva

[GitHub] [flink] flinkbot edited a comment on pull request #12212: [FLINK-17626][fs-connector] Fs connector should use FLIP-122 format options style

2020-05-19 Thread GitBox
flinkbot edited a comment on pull request #12212: URL: https://github.com/apache/flink/pull/12212#issuecomment-630019032 ## CI report: * 14ab5f81d7f9d7324e3a0f7ab51d47bf9242abee Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #12199: [FLINK-17774] [table] supports all kinds of changes for select result

2020-05-19 Thread GitBox
flinkbot edited a comment on pull request #12199: URL: https://github.com/apache/flink/pull/12199#issuecomment-629793563 ## CI report: * cff8424e532db0bfc3ca58b8b6da13d3d69b0559 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #12230: [FLINK-17504][docs] Update Chinese translation of Getting Started / O…

2020-05-19 Thread GitBox
flinkbot edited a comment on pull request #12230: URL: https://github.com/apache/flink/pull/12230#issuecomment-630205457 ## CI report: * de4251b2c2ee31ababe1c82505c15822546a59b1 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[jira] [Assigned] (FLINK-17474) Test and correct case insensitive for parquet and orc in hive

2020-05-19 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17474?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-17474: Assignee: Jingsong Lee > Test and correct case insensitive for parquet and orc in hive >

[jira] [Commented] (FLINK-17565) Bump fabric8 version from 4.5.2 to 4.9.1

2020-05-19 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17110916#comment-17110916 ] Yang Wang commented on FLINK-17565: --- Yes, i agree with you that 4.9.x is more stable.

[jira] [Commented] (FLINK-17793) Replace TableSchema with dedicated CatalogSchema

2020-05-19 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17110918#comment-17110918 ] Timo Walther commented on FLINK-17793: -- Computed columns, atermarks, primary key ar

[jira] [Comment Edited] (FLINK-17793) Replace TableSchema with dedicated CatalogSchema

2020-05-19 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17110918#comment-17110918 ] Timo Walther edited comment on FLINK-17793 at 5/19/20, 7:19 AM: --

[GitHub] [flink] klion26 commented on pull request #12096: [FLINK-16074][docs-zh] Translate the Overview page for State & Fault Tolerance into Chinese

2020-05-19 Thread GitBox
klion26 commented on pull request #12096: URL: https://github.com/apache/flink/pull/12096#issuecomment-630634589 @carp84 thanks for the review, addressed the comment, please take another look when you're free. This is an aut

[jira] [Updated] (FLINK-17639) Document which FileSystems are supported by the StreamingFileSink

2020-05-19 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17639?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-17639: -- Fix Version/s: 1.11.0 > Document which FileSystems are supported by the StreamingFileSink > --

[jira] [Commented] (FLINK-12030) KafkaITCase.testMultipleSourcesOnePartition is unstable: This server does not host this topic-partition

2020-05-19 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12030?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17110919#comment-17110919 ] Robert Metzger commented on FLINK-12030: https://dev.azure.com/apache-flink/apac

[jira] [Updated] (FLINK-17801) TaskExecutorTest.testHeartbeatTimeoutWithResourceManager timeout

2020-05-19 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17801?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-17801: -- Fix Version/s: 1.11.0 > TaskExecutorTest.testHeartbeatTimeoutWithResourceManager timeout > ---

[GitHub] [flink] dawidwys commented on pull request #12232: [FLINK-15947] Finish moving scala expression DSL to flink-table-api-scala

2020-05-19 Thread GitBox
dawidwys commented on pull request #12232: URL: https://github.com/apache/flink/pull/12232#issuecomment-630636630 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message, please

[GitHub] [flink] rkhachatryan commented on a change in pull request #12120: [FLINK-17547] Support unaligned checkpoints for records spilled to files

2020-05-19 Thread GitBox
rkhachatryan commented on a change in pull request #12120: URL: https://github.com/apache/flink/pull/12120#discussion_r427084714 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/disk/FileBasedBufferIterator.java ## @@ -85,6 +90,6 @@ private int read(byte[]

[jira] [Commented] (FLINK-15792) Make Flink logs accessible via kubectl logs per default

2020-05-19 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17110921#comment-17110921 ] Till Rohrmann commented on FLINK-15792: --- Done [~fly_in_gis]. > Make Flink logs ac

[jira] [Assigned] (FLINK-15792) Make Flink logs accessible via kubectl logs per default

2020-05-19 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15792?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-15792: - Assignee: Yang Wang > Make Flink logs accessible via kubectl logs per default > ---

[GitHub] [flink] flinkbot edited a comment on pull request #12199: [FLINK-17774] [table] supports all kinds of changes for select result

2020-05-19 Thread GitBox
flinkbot edited a comment on pull request #12199: URL: https://github.com/apache/flink/pull/12199#issuecomment-629793563 ## CI report: * cff8424e532db0bfc3ca58b8b6da13d3d69b0559 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #12238: [FLINK-17626][fs-connector] Fs connector should use FLIP-122 format options style

2020-05-19 Thread GitBox
flinkbot edited a comment on pull request #12238: URL: https://github.com/apache/flink/pull/12238#issuecomment-630603058 ## CI report: * 50937916a7724ea232c71a6a42510984187adb19 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] tillrohrmann commented on pull request #12213: Revert "[FLINK-13827][script] shell variable should be escaped"

2020-05-19 Thread GitBox
tillrohrmann commented on pull request #12213: URL: https://github.com/apache/flink/pull/12213#issuecomment-630638359 Sounds good @zentol. This is an automated message from the Apache Git Service. To respond to the message, p

[GitHub] [flink] tillrohrmann commented on pull request #12211: [FLINK-17790][kafka] Fix JDK 11 compile error

2020-05-19 Thread GitBox
tillrohrmann commented on pull request #12211: URL: https://github.com/apache/flink/pull/12211#issuecomment-630638234 Ok, will merge my commit now. This is an automated message from the Apache Git Service. To respond to the m

[jira] [Commented] (FLINK-17730) HadoopS3RecoverableWriterITCase.testRecoverAfterMultiplePersistsStateWithMultiPart times out

2020-05-19 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17730?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17110922#comment-17110922 ] Robert Metzger commented on FLINK-17730: Case with 15 minutes :( https://dev.az

[jira] [Commented] (FLINK-16911) PrestoS3FileSystemITCase#testSimpleFileWriteAndRead fails on checkPathExistence

2020-05-19 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16911?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17110924#comment-17110924 ] Robert Metzger commented on FLINK-16911: https://dev.azure.com/apache-flink/apac

[jira] [Updated] (FLINK-16911) PrestoS3FileSystemITCase#testSimpleFileWriteAndRead fails on checkPathExistence

2020-05-19 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16911?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-16911: --- Priority: Critical (was: Major) > PrestoS3FileSystemITCase#testSimpleFileWriteAndRead fails

[jira] [Assigned] (FLINK-17790) flink-connector-kafka-base does not compile on Java11

2020-05-19 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17790?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-17790: - Assignee: Till Rohrmann (was: Chesnay Schepler) > flink-connector-kafka-base does not

[jira] [Commented] (FLINK-17721) AbstractHadoopFileSystemITTest .cleanupDirectoryWithRetry fails with AssertionError

2020-05-19 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17721?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17110927#comment-17110927 ] Robert Metzger commented on FLINK-17721: https://dev.azure.com/apache-flink/apac

[jira] [Updated] (FLINK-17721) AbstractHadoopFileSystemITTest .cleanupDirectoryWithRetry fails with AssertionError

2020-05-19 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17721?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-17721: --- Priority: Critical (was: Major) > AbstractHadoopFileSystemITTest .cleanupDirectoryWithRetry

[jira] [Resolved] (FLINK-17790) flink-connector-kafka-base does not compile on Java11

2020-05-19 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17790?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-17790. --- Resolution: Fixed Fixed via master: d0fc02839d2f3d99be2c6420758ab50fb4828bc3 1.11.0: fdec46

[jira] [Commented] (FLINK-16267) Flink uses more memory than taskmanager.memory.process.size in Kubernetes

2020-05-19 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16267?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17110930#comment-17110930 ] Yun Tang commented on FLINK-16267: -- [~trystan] Unfortunately to hear your story to have

[GitHub] [flink] tillrohrmann closed pull request #12211: [FLINK-17790][kafka] Fix JDK 11 compile error

2020-05-19 Thread GitBox
tillrohrmann closed pull request #12211: URL: https://github.com/apache/flink/pull/12211 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 g

[jira] [Comment Edited] (FLINK-17793) Replace TableSchema with dedicated CatalogSchema

2020-05-19 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17110918#comment-17110918 ] Timo Walther edited comment on FLINK-17793 at 5/19/20, 7:32 AM: --

[GitHub] [flink] tillrohrmann commented on pull request #12211: [FLINK-17790][kafka] Fix JDK 11 compile error

2020-05-19 Thread GitBox
tillrohrmann commented on pull request #12211: URL: https://github.com/apache/flink/pull/12211#issuecomment-630641268 Merged via d0fc02839d2f3d99be2c6420758ab50fb4828bc3 This is an automated message from the Apache Git Servic

[GitHub] [flink] leonardBang commented on a change in pull request #12090: [FLINK-17622][connectors / jdbc] Remove useless switch for decimal in PostgresCatalog

2020-05-19 Thread GitBox
leonardBang commented on a change in pull request #12090: URL: https://github.com/apache/flink/pull/12090#discussion_r427076675 ## File path: flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/catalog/PostgresCatalog.java ## @@ -258,6 +256,8 @@

[jira] [Created] (FLINK-17806) CollectSinkFunctionTest.testCheckpointedFunction fails with expected:<50> but was:<0>

2020-05-19 Thread Robert Metzger (Jira)
Robert Metzger created FLINK-17806: -- Summary: CollectSinkFunctionTest.testCheckpointedFunction fails with expected:<50> but was:<0> Key: FLINK-17806 URL: https://issues.apache.org/jira/browse/FLINK-17806

[GitHub] [flink] dawidwys opened a new pull request #12239: [FLINK-17027][hotfix] Rename back-off infix to backoff in new Elasticsearch properties

2020-05-19 Thread GitBox
dawidwys opened a new pull request #12239: URL: https://github.com/apache/flink/pull/12239 Trivial fix of a typo in an infix of es properties. This is an automated message from the Apache Git Service. To respond to the messag

[jira] [Commented] (FLINK-17793) Replace TableSchema with dedicated CatalogSchema

2020-05-19 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17110933#comment-17110933 ] Jingsong Lee commented on FLINK-17793: -- +++1, There are still some potential bugs b

[jira] [Commented] (FLINK-16267) Flink uses more memory than taskmanager.memory.process.size in Kubernetes

2020-05-19 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16267?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17110934#comment-17110934 ] Yun Tang commented on FLINK-16267: -- [~czchen] I think you might not run jobs with rocks

[GitHub] [flink] TsReaper commented on a change in pull request #12199: [FLINK-17774] [table] supports all kinds of changes for select result

2020-05-19 Thread GitBox
TsReaper commented on a change in pull request #12199: URL: https://github.com/apache/flink/pull/12199#discussion_r427093164 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/sinks/SelectTableSinkBase.java ## @@ -28,61 +28,102 @@

[GitHub] [flink] wuchong closed pull request #12196: [FLINK-17353][docs] Fix Broken links in Flink docs master

2020-05-19 Thread GitBox
wuchong closed pull request #12196: URL: https://github.com/apache/flink/pull/12196 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 to

[jira] [Closed] (FLINK-15758) Investigate potential out-of-memory problems due to managed unsafe memory allocation

2020-05-19 Thread Andrey Zagrebin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15758?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin closed FLINK-15758. --- Resolution: Fixed merged into master by 10c29b73fdbc2bcfe7cb6f9394ad8db7836041c3 merged into

[jira] [Created] (FLINK-17807) Fix the broken link "/zh/ops/memory/mem_detail.html" in documentation

2020-05-19 Thread Jark Wu (Jira)
Jark Wu created FLINK-17807: --- Summary: Fix the broken link "/zh/ops/memory/mem_detail.html" in documentation Key: FLINK-17807 URL: https://issues.apache.org/jira/browse/FLINK-17807 Project: Flink

[GitHub] [flink] flinkbot commented on pull request #12239: [FLINK-17027][hotfix] Rename back-off infix to backoff in new Elasticsearch properties

2020-05-19 Thread GitBox
flinkbot commented on pull request #12239: URL: https://github.com/apache/flink/pull/12239#issuecomment-630648333 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 pro

[GitHub] [flink] wuchong commented on pull request #12196: [FLINK-17353][docs] Fix Broken links in Flink docs master

2020-05-19 Thread GitBox
wuchong commented on pull request #12196: URL: https://github.com/apache/flink/pull/12196#issuecomment-630648400 Merged and created an following up issue FLINK-17807 to resolve this brocken link. This is an automated message

[jira] [Closed] (FLINK-17803) Flink batch sql job read hive table which contains map type, raise exception: " scala.MatchError: MAP"

2020-05-19 Thread zouyunhe (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17803?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zouyunhe closed FLINK-17803. Resolution: Not A Problem > Flink batch sql job read hive table which contains map type, raise exception:

[GitHub] [flink] azagrebin commented on pull request #11245: [FLINK-15794][Kubernetes] Generate the Kubernetes default image version

2020-05-19 Thread GitBox
azagrebin commented on pull request #11245: URL: https://github.com/apache/flink/pull/11245#issuecomment-630649648 ok, thanks for the update This is an automated message from the Apache Git Service. To respond to the message,

[jira] [Updated] (FLINK-15792) Make Flink logs accessible via kubectl logs per default

2020-05-19 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15792?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-15792: --- Labels: pull-request-available (was: ) > Make Flink logs accessible via kubectl logs per de

[GitHub] [flink] wangyang0918 opened a new pull request #12240: [FLINK-15792][k8s] Make Flink logs accessible via kubectl logs per default

2020-05-19 Thread GitBox
wangyang0918 opened a new pull request #12240: URL: https://github.com/apache/flink/pull/12240 ## What is the purpose of the change Currently, the users could not view the JobManager/TaskManager logs via `kubectl logs`. It is not convenient especially for debugging(i.e. when

[GitHub] [flink] flinkbot commented on pull request #12240: [FLINK-15792][k8s] Make Flink logs accessible via kubectl logs per default

2020-05-19 Thread GitBox
flinkbot commented on pull request #12240: URL: https://github.com/apache/flink/pull/12240#issuecomment-630653015 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 pro

[jira] [Created] (FLINK-17808) Rename checkpoint meta file to "_metadata" until it has completed writing

2020-05-19 Thread Yun Tang (Jira)
Yun Tang created FLINK-17808: Summary: Rename checkpoint meta file to "_metadata" until it has completed writing Key: FLINK-17808 URL: https://issues.apache.org/jira/browse/FLINK-17808 Project: Flink

[jira] [Assigned] (FLINK-17808) Rename checkpoint meta file to "_metadata" until it has completed writing

2020-05-19 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17808?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang reassigned FLINK-17808: Assignee: Yun Tang > Rename checkpoint meta file to "_metadata" until it has completed writing >

[GitHub] [flink] nielsbasjes edited a comment on pull request #11245: [FLINK-15794][Kubernetes] Generate the Kubernetes default image version

2020-05-19 Thread GitBox
nielsbasjes edited a comment on pull request #11245: URL: https://github.com/apache/flink/pull/11245#issuecomment-630350138 Yes, this is the next thing on my todo list. Right now I'm preparing my talk for BerlinBuzzwords which is in a few weeks: https://berlinbuzzwords.de/session/when-your

[GitHub] [flink] tillrohrmann commented on a change in pull request #12236: [FLINK-17527][flink-dist] Make kubernetes-session.sh use session log4j/logback configuration files

2020-05-19 Thread GitBox
tillrohrmann commented on a change in pull request #12236: URL: https://github.com/apache/flink/pull/12236#discussion_r427105554 ## File path: docs/monitoring/logging.md ## @@ -35,7 +35,7 @@ Log4j2 is controlled using property files. In Flink's case, the file is usually Flink

[GitHub] [flink] Myasuka commented on pull request #8693: [FLINK-8871] Support to cancel checkpoing via notification

2020-05-19 Thread GitBox
Myasuka commented on pull request #8693: URL: https://github.com/apache/flink/pull/8693#issuecomment-630659431 @pnowojski thanks for your remind. I think I have addressed all comments to update the commits. Since current CI is still pending, my local pipeline based on the same com

[GitHub] [flink] flinkbot edited a comment on pull request #12096: [FLINK-16074][docs-zh] Translate the Overview page for State & Fault Tolerance into Chinese

2020-05-19 Thread GitBox
flinkbot edited a comment on pull request #12096: URL: https://github.com/apache/flink/pull/12096#issuecomment-627237312 ## CI report: * 3904e9683662c4ba2c99b451169d639519d3484f Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #12199: [FLINK-17774] [table] supports all kinds of changes for select result

2020-05-19 Thread GitBox
flinkbot edited a comment on pull request #12199: URL: https://github.com/apache/flink/pull/12199#issuecomment-629793563 ## CI report: * 4ffe1d6e34ee30dbbc59fd59b77110a241391510 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #12237: [FLINK-17290] [chinese-translation, Documentation / Training] Transla…

2020-05-19 Thread GitBox
flinkbot edited a comment on pull request #12237: URL: https://github.com/apache/flink/pull/12237#issuecomment-630566246 ## CI report: * 0c911fb0b8ae6fc7dabf929ae10b27b24e0b604d Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #12212: [FLINK-17626][fs-connector] Fs connector should use FLIP-122 format options style

2020-05-19 Thread GitBox
flinkbot edited a comment on pull request #12212: URL: https://github.com/apache/flink/pull/12212#issuecomment-630019032 ## CI report: * 14ab5f81d7f9d7324e3a0f7ab51d47bf9242abee Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot commented on pull request #12239: [FLINK-17027][hotfix] Rename back-off infix to backoff in new Elasticsearch properties

2020-05-19 Thread GitBox
flinkbot commented on pull request #12239: URL: https://github.com/apache/flink/pull/12239#issuecomment-630660922 ## CI report: * 6f24105ca9b36bb71f955c6ebaa2037c62092193 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot commented on pull request #12240: [FLINK-15792][k8s] Make Flink logs accessible via kubectl logs per default

2020-05-19 Thread GitBox
flinkbot commented on pull request #12240: URL: https://github.com/apache/flink/pull/12240#issuecomment-630661048 ## CI report: * 7ae117dbf4d94f345f70d6f1e8cec97f71086a36 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot edited a comment on pull request #12238: [FLINK-17626][fs-connector] Fs connector should use FLIP-122 format options style

2020-05-19 Thread GitBox
flinkbot edited a comment on pull request #12238: URL: https://github.com/apache/flink/pull/12238#issuecomment-630603058 ## CI report: * 50937916a7724ea232c71a6a42510984187adb19 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Assigned] (FLINK-17805) InputProcessorUtil doesn't handle indexes for multiple inputs operators correctly

2020-05-19 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17805?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reassigned FLINK-17805: -- Assignee: Piotr Nowojski > InputProcessorUtil doesn't handle indexes for multiple inp

[GitHub] [flink] zentol commented on pull request #12100: [FLINK-17634][rest] Reject multiple registration for the same endpoint

2020-05-19 Thread GitBox
zentol commented on pull request #12100: URL: https://github.com/apache/flink/pull/12100#issuecomment-630661752 @tillrohrmann The branch did not include the fix for FLINK-17562, and failed accordingly. So it works at least, an the build is now green after a rebase. ---

[jira] [Assigned] (FLINK-14632) ExecutionGraphSchedulingTest.testSlotReleasingFailsSchedulingOperation deadlocks

2020-05-19 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14632?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-14632: - Assignee: Till Rohrmann > ExecutionGraphSchedulingTest.testSlotReleasingFailsScheduling

[GitHub] [flink] wuchong edited a comment on pull request #12196: [FLINK-17353][docs] Fix Broken links in Flink docs master

2020-05-19 Thread GitBox
wuchong edited a comment on pull request #12196: URL: https://github.com/apache/flink/pull/12196#issuecomment-630648400 Merged and created an following up issue FLINK-17807 to resolve this broken link. This is an automated m

[GitHub] [flink] klion26 commented on a change in pull request #12078: [FLINK-17610][state]Align the behavior of result of internal map state to re…

2020-05-19 Thread GitBox
klion26 commented on a change in pull request #12078: URL: https://github.com/apache/flink/pull/12078#discussion_r427116721 ## File path: flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBMapState.java ## @@ -227,6 +2

[jira] [Closed] (FLINK-17353) Broken links in Flink docs master

2020-05-19 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17353?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-17353. --- Fix Version/s: 1.11.0 Resolution: Fixed - master (1.12.0): 4dc3bdaa460f35ea6e0fa31ce9068a7dba54316d -

[jira] [Commented] (FLINK-16076) Translate "Queryable State" page into Chinese

2020-05-19 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16076?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17110966#comment-17110966 ] Jark Wu commented on FLINK-16076: - Cherry-picked to 1.11.0: 2f1a6b0aa3eeae973e8a6124bef8

[GitHub] [flink] JingsongLi opened a new pull request #12241: [FLINK-17474][parquet][hive] Parquet reader should be case insensitive for hive

2020-05-19 Thread GitBox
JingsongLi opened a new pull request #12241: URL: https://github.com/apache/flink/pull/12241 ## What is the purpose of the change Parquet reader should be case insensitive field names for hive ## Brief change log - Introduce case sensitive flag to parquet reader -

[jira] [Updated] (FLINK-17474) Test and correct case insensitive for parquet and orc in hive

2020-05-19 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17474?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-17474: --- Labels: pull-request-available (was: ) > Test and correct case insensitive for parquet and

[jira] [Commented] (FLINK-17086) Flink sql client not able to read parquet hive table because `HiveMapredSplitReader` not supports name mapping reading for parquet format.

2020-05-19 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17086?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17110967#comment-17110967 ] Jingsong Lee commented on FLINK-17086: -- FLINK-17474 will be fixed in 1.11 > Flink

[jira] [Closed] (FLINK-14632) ExecutionGraphSchedulingTest.testSlotReleasingFailsSchedulingOperation deadlocks

2020-05-19 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14632?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-14632. - Fix Version/s: (was: 1.11.0) Resolution: Cannot Reproduce Unable to reproduce the pro

[GitHub] [flink] flinkbot edited a comment on pull request #12096: [FLINK-16074][docs-zh] Translate the Overview page for State & Fault Tolerance into Chinese

2020-05-19 Thread GitBox
flinkbot edited a comment on pull request #12096: URL: https://github.com/apache/flink/pull/12096#issuecomment-627237312 ## CI report: * 3904e9683662c4ba2c99b451169d639519d3484f Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot commented on pull request #12241: [FLINK-17474][parquet][hive] Parquet reader should be case insensitive for hive

2020-05-19 Thread GitBox
flinkbot commented on pull request #12241: URL: https://github.com/apache/flink/pull/12241#issuecomment-630673426 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 pro

[GitHub] [flink] flinkbot edited a comment on pull request #12212: [FLINK-17626][fs-connector] Fs connector should use FLIP-122 format options style

2020-05-19 Thread GitBox
flinkbot edited a comment on pull request #12212: URL: https://github.com/apache/flink/pull/12212#issuecomment-630019032 ## CI report: * 14ab5f81d7f9d7324e3a0f7ab51d47bf9242abee Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #12199: [FLINK-17774] [table] supports all kinds of changes for select result

2020-05-19 Thread GitBox
flinkbot edited a comment on pull request #12199: URL: https://github.com/apache/flink/pull/12199#issuecomment-629793563 ## CI report: * 4ffe1d6e34ee30dbbc59fd59b77110a241391510 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #12234: [FLINK-16986][coordination] Provide exactly-once guaranteed around checkpoints and operator event sending

2020-05-19 Thread GitBox
flinkbot edited a comment on pull request #12234: URL: https://github.com/apache/flink/pull/12234#issuecomment-630433269 ## CI report: * c39a9703b6e8d5fe3ecc4cd59d2e5c5d4dd1c82e Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #12236: [FLINK-17527][flink-dist] Make kubernetes-session.sh use session log4j/logback configuration files

2020-05-19 Thread GitBox
flinkbot edited a comment on pull request #12236: URL: https://github.com/apache/flink/pull/12236#issuecomment-630547436 ## CI report: * c3caf6974bdf8298376d150b00fd7e7125089986 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #12238: [FLINK-17626][fs-connector] Fs connector should use FLIP-122 format options style

2020-05-19 Thread GitBox
flinkbot edited a comment on pull request #12238: URL: https://github.com/apache/flink/pull/12238#issuecomment-630603058 ## CI report: * 50937916a7724ea232c71a6a42510984187adb19 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] StephanEwen commented on pull request #12234: [FLINK-16986][coordination] Provide exactly-once guaranteed around checkpoints and operator event sending

2020-05-19 Thread GitBox
StephanEwen commented on pull request #12234: URL: https://github.com/apache/flink/pull/12234#issuecomment-630674853 CI failure is due to an unrelated test in the State Processor API. This is an automated message from the Ap

[GitHub] [flink] flinkbot edited a comment on pull request #12240: [FLINK-15792][k8s] Make Flink logs accessible via kubectl logs per default

2020-05-19 Thread GitBox
flinkbot edited a comment on pull request #12240: URL: https://github.com/apache/flink/pull/12240#issuecomment-630661048 ## CI report: * 7ae117dbf4d94f345f70d6f1e8cec97f71086a36 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #12239: [FLINK-17027][hotfix] Rename back-off infix to backoff in new Elasticsearch properties

2020-05-19 Thread GitBox
flinkbot edited a comment on pull request #12239: URL: https://github.com/apache/flink/pull/12239#issuecomment-630660922 ## CI report: * 6f24105ca9b36bb71f955c6ebaa2037c62092193 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] fpompermaier commented on a change in pull request #12090: [FLINK-17622][connectors / jdbc] Remove useless switch for decimal in PostgresCatalog

2020-05-19 Thread GitBox
fpompermaier commented on a change in pull request #12090: URL: https://github.com/apache/flink/pull/12090#discussion_r427132837 ## File path: flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/catalog/PostgresCatalog.java ## @@ -258,6 +256,8 @

[jira] [Updated] (FLINK-17806) CollectSinkFunctionTest.testCheckpointedFunction fails with expected:<50> but was:<0>

2020-05-19 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17806?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-17806: --- Priority: Blocker (was: Major) > CollectSinkFunctionTest.testCheckpointedFunction fails with expec

[jira] [Updated] (FLINK-17806) CollectSinkFunctionTest.testCheckpointedFunction fails with expected:<50> but was:<0>

2020-05-19 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17806?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-17806: --- Affects Version/s: (was: 1.12.0) 1.11.0 > CollectSinkFunctionTest.testChe

[jira] [Updated] (FLINK-17806) CollectSinkFunctionTest.testCheckpointedFunction fails with expected:<50> but was:<0>

2020-05-19 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17806?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-17806: --- Fix Version/s: 1.11.0 > CollectSinkFunctionTest.testCheckpointedFunction fails with expected:<50>

[jira] [Commented] (FLINK-17806) CollectSinkFunctionTest.testCheckpointedFunction fails with expected:<50> but was:<0>

2020-05-19 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17806?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17110976#comment-17110976 ] Kurt Young commented on FLINK-17806: cc [~TsReaper] > CollectSinkFunctionTest.testC

[jira] [Comment Edited] (FLINK-17806) CollectSinkFunctionTest.testCheckpointedFunction fails with expected:<50> but was:<0>

2020-05-19 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17806?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17110976#comment-17110976 ] Kurt Young edited comment on FLINK-17806 at 5/19/20, 8:46 AM:

[jira] [Assigned] (FLINK-17806) CollectSinkFunctionTest.testCheckpointedFunction fails with expected:<50> but was:<0>

2020-05-19 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17806?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-17806: -- Assignee: Caizhi Weng > CollectSinkFunctionTest.testCheckpointedFunction fails with expected

[GitHub] [flink] zentol commented on pull request #12233: [FLINK-17745] Remove nested jar handling from PackagedProgram

2020-05-19 Thread GitBox
zentol commented on pull request #12233: URL: https://github.com/apache/flink/pull/12233#issuecomment-630680324 I'm just pointing out that you are removing functionality and potentially break user-setups; see also the discussions in the JIRA. I'll leave the decision to you. -

[jira] [Assigned] (FLINK-17801) TaskExecutorTest.testHeartbeatTimeoutWithResourceManager timeout

2020-05-19 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17801?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-17801: - Assignee: Till Rohrmann > TaskExecutorTest.testHeartbeatTimeoutWithResourceManager time

[jira] [Commented] (FLINK-17801) TaskExecutorTest.testHeartbeatTimeoutWithResourceManager timeout

2020-05-19 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17801?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17110979#comment-17110979 ] Till Rohrmann commented on FLINK-17801: --- It looks to me as if the timeout in {{Tas

  1   2   3   4   5   6   7   >