[
https://issues.apache.org/jira/browse/FLINK-1707?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Josep Rubió updated FLINK-1707:
---
Description:
This issue proposes adding the an implementation of the Affinity Propagation
algorithm a
[
https://issues.apache.org/jira/browse/FLINK-4280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15698724#comment-15698724
]
ASF GitHub Bot commented on FLINK-4280:
---
Github user tzulitai commented on a diff in
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/2509#discussion_r89680317
--- Diff:
flink-streaming-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaConsumerTestBase.java
---
@@
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/2876
The test should be changed to use more specific folder names including a
random component. If the directory we are trying to create already exists we
should most definitely not just delete everything
[
https://issues.apache.org/jira/browse/FLINK-5166?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15698373#comment-15698373
]
ASF GitHub Bot commented on FLINK-5166:
---
Github user zentol commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15698090#comment-15698090
]
Jark Wu commented on FLINK-4692:
Hi [~fhueske] [~twalthr], I have proposed a [design
doc|
Github user wuchong commented on a diff in the pull request:
https://github.com/apache/flink/pull/2810#discussion_r89670370
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/rules/dataSet/BatchProjectableTableSourceScanRule.scala
---
@@ -0,0 +1,8
Github user wuchong commented on a diff in the pull request:
https://github.com/apache/flink/pull/2810#discussion_r89671607
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/rules/datastream/StreamProjectableTableSourceScanRule.scala
---
@@ -0,0
[
https://issues.apache.org/jira/browse/FLINK-3848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15697951#comment-15697951
]
ASF GitHub Bot commented on FLINK-3848:
---
Github user wuchong commented on a diff in
Github user wuchong commented on a diff in the pull request:
https://github.com/apache/flink/pull/2810#discussion_r89671603
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/rules/dataSet/BatchProjectableTableSourceScanRule.scala
---
@@ -0,0 +1,8
[
https://issues.apache.org/jira/browse/FLINK-3848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15697949#comment-15697949
]
ASF GitHub Bot commented on FLINK-3848:
---
Github user wuchong commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-3848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15697940#comment-15697940
]
ASF GitHub Bot commented on FLINK-3848:
---
Github user wuchong commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-3848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15697946#comment-15697946
]
ASF GitHub Bot commented on FLINK-3848:
---
Github user wuchong commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-3848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15697954#comment-15697954
]
ASF GitHub Bot commented on FLINK-3848:
---
Github user wuchong commented on a diff in
Github user wuchong commented on a diff in the pull request:
https://github.com/apache/flink/pull/2810#discussion_r89246478
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/sources/ProjectableTableSource.scala
---
@@ -0,0 +1,32 @@
+/*
+ * Lic
Github user wuchong commented on a diff in the pull request:
https://github.com/apache/flink/pull/2810#discussion_r89671537
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/nodes/datastream/StreamProjectableTableSourceScan.scala
---
@@ -0,0 +1,7
[
https://issues.apache.org/jira/browse/FLINK-3848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15697942#comment-15697942
]
ASF GitHub Bot commented on FLINK-3848:
---
Github user wuchong commented on a diff in
Github user wuchong commented on a diff in the pull request:
https://github.com/apache/flink/pull/2810#discussion_r89671731
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/rules/datastream/StreamProjectableTableSourceScanRule.scala
---
@@ -0,0
[
https://issues.apache.org/jira/browse/FLINK-3848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15697952#comment-15697952
]
ASF GitHub Bot commented on FLINK-3848:
---
Github user wuchong commented on a diff in
Github user wuchong commented on a diff in the pull request:
https://github.com/apache/flink/pull/2810#discussion_r89671523
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/nodes/dataset/BatchProjectableTableSourceScan.scala
---
@@ -0,0 +1,74 @@
Github user wuchong commented on a diff in the pull request:
https://github.com/apache/flink/pull/2810#discussion_r89671437
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/rules/dataSet/BatchProjectableTableSourceScanRule.scala
---
@@ -0,0 +1,8
Github user wuchong commented on a diff in the pull request:
https://github.com/apache/flink/pull/2810#discussion_r89671462
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/nodes/dataset/BatchProjectableTableSourceScan.scala
---
@@ -0,0 +1,74 @@
[
https://issues.apache.org/jira/browse/FLINK-3848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15697937#comment-15697937
]
ASF GitHub Bot commented on FLINK-3848:
---
Github user wuchong commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-3848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15697941#comment-15697941
]
ASF GitHub Bot commented on FLINK-3848:
---
Github user wuchong commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-3848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15697944#comment-15697944
]
ASF GitHub Bot commented on FLINK-3848:
---
Github user wuchong commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-3848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15697943#comment-15697943
]
ASF GitHub Bot commented on FLINK-3848:
---
Github user wuchong commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-3848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15697939#comment-15697939
]
ASF GitHub Bot commented on FLINK-3848:
---
Github user wuchong commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-3848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15697945#comment-15697945
]
ASF GitHub Bot commented on FLINK-3848:
---
Github user wuchong commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-3848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15697947#comment-15697947
]
ASF GitHub Bot commented on FLINK-3848:
---
Github user wuchong commented on a diff in
Github user wuchong commented on a diff in the pull request:
https://github.com/apache/flink/pull/2810#discussion_r89671175
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/rules/dataSet/BatchProjectableTableSourceScanRule.scala
---
@@ -0,0 +1,8
[
https://issues.apache.org/jira/browse/FLINK-3848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15697955#comment-15697955
]
ASF GitHub Bot commented on FLINK-3848:
---
Github user wuchong commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-3848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15697948#comment-15697948
]
ASF GitHub Bot commented on FLINK-3848:
---
Github user wuchong commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-3848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15697953#comment-15697953
]
ASF GitHub Bot commented on FLINK-3848:
---
Github user wuchong commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-3848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15697938#comment-15697938
]
ASF GitHub Bot commented on FLINK-3848:
---
Github user wuchong commented on a diff in
Github user wuchong commented on a diff in the pull request:
https://github.com/apache/flink/pull/2810#discussion_r89670435
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/rules/dataSet/BatchProjectableTableSourceScanRule.scala
---
@@ -0,0 +1,8
Github user wuchong commented on a diff in the pull request:
https://github.com/apache/flink/pull/2810#discussion_r89246193
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/nodes/datastream/StreamProjectableTableSourceScan.scala
---
@@ -0,0 +1,7
Github user wuchong commented on a diff in the pull request:
https://github.com/apache/flink/pull/2810#discussion_r89671556
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/nodes/dataset/BatchProjectableTableSourceScan.scala
---
@@ -0,0 +1,74 @@
Github user wuchong commented on a diff in the pull request:
https://github.com/apache/flink/pull/2810#discussion_r89671180
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/rules/datastream/StreamProjectableTableSourceScanRule.scala
---
@@ -0,0
Github user wuchong commented on a diff in the pull request:
https://github.com/apache/flink/pull/2810#discussion_r89671736
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/api/scala/batch/TableSourceITCase.scala
---
@@ -131,6 +101,33 @@ class TableSourceITCas
Github user wuchong commented on a diff in the pull request:
https://github.com/apache/flink/pull/2810#discussion_r89670471
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/rules/datastream/StreamProjectableTableSourceScanRule.scala
---
@@ -0,0
[
https://issues.apache.org/jira/browse/FLINK-3848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15697950#comment-15697950
]
ASF GitHub Bot commented on FLINK-3848:
---
Github user wuchong commented on a diff in
Github user wuchong commented on a diff in the pull request:
https://github.com/apache/flink/pull/2810#discussion_r89671544
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/nodes/datastream/StreamProjectableTableSourceScan.scala
---
@@ -0,0 +1,7
Github user wuchong commented on a diff in the pull request:
https://github.com/apache/flink/pull/2810#discussion_r89246096
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/nodes/datastream/StreamProjectableTableSourceScan.scala
---
@@ -0,0 +1,7
Github user wuchong commented on a diff in the pull request:
https://github.com/apache/flink/pull/2810#discussion_r89671128
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/sources/CsvTableSource.scala
---
@@ -102,11 +107,43 @@ class CsvTableSource(
[
https://issues.apache.org/jira/browse/FLINK-5166?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15697655#comment-15697655
]
ASF GitHub Bot commented on FLINK-5166:
---
GitHub user shijinkui opened a pull request
GitHub user shijinkui opened a pull request:
https://github.com/apache/flink/pull/2876
[FLINK-5166] TextInputFormatTest.testNestedFileRead
- [x] General
- The pull request references the related JIRA issue ("[FLINK-XXX] Jira
title text")
- The pull request addresses
[
https://issues.apache.org/jira/browse/FLINK-5166?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15697644#comment-15697644
]
shijinkui commented on FLINK-5166:
--
Debug, found that:
there four tmp file in the `expect
[
https://issues.apache.org/jira/browse/FLINK-5167?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15697631#comment-15697631
]
ASF GitHub Bot commented on FLINK-5167:
---
Github user shijinkui commented on the issu
Github user shijinkui commented on the issue:
https://github.com/apache/flink/pull/2874
> The PR changes several @Public and @PublicEvolving methods.
hi, @fhueske
Today when set some config, find some function cant't chained one by one.
So want to complete all the function nee
[
https://issues.apache.org/jira/browse/FLINK-5166?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-5166:
Component/s: (was: Build System)
Tests
Batch Connectors
[
https://issues.apache.org/jira/browse/FLINK-5166?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15697607#comment-15697607
]
Chesnay Schepler commented on FLINK-5166:
-
can you include the exception that you
[
https://issues.apache.org/jira/browse/FLINK-5167?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15697575#comment-15697575
]
ASF GitHub Bot commented on FLINK-5167:
---
Github user fhueske commented on the issue:
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/2874
The PR changes several `@Public` and `@PublicEvolving` methods.
We do not touch @Public interfaces for 1.x releases and also try to avoid
to modify `@PublicEvolving` interface except for ver
[
https://issues.apache.org/jira/browse/FLINK-5166?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
shijinkui updated FLINK-5166:
-
Description:
`mvn clean package -P \!scala-2.11,scala-2.11 -U`
Failed tests:
TextInputFormatTest.testN
[
https://issues.apache.org/jira/browse/FLINK-5166?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
shijinkui updated FLINK-5166:
-
Description:
mvn clean package -P \\!scala-2.11,scala-2.11 -U
Failed tests:
TextInputFormatTest.testNe
[
https://issues.apache.org/jira/browse/FLINK-5168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15697531#comment-15697531
]
ASF GitHub Bot commented on FLINK-5168:
---
GitHub user shijinkui opened a pull request
GitHub user shijinkui opened a pull request:
https://github.com/apache/flink/pull/2875
[FLINK-5168] Scaladoc annotation link use [[]] instead of {@link}
`{@link StreamExecutionEnvironment#readFile(FileInputFormat, * String,
FileProcessingMode, long)}`
==>
`[StreamE
shijinkui created FLINK-5168:
Summary: Scaladoc annotation link use [[]] instead of {@link}
Key: FLINK-5168
URL: https://issues.apache.org/jira/browse/FLINK-5168
Project: Flink
Issue Type: Improv
58 matches
Mail list logo
