Github user tonycox commented on the issue:
https://github.com/apache/flink/pull/3760
@ramkrish86 Hi, Thank you for the PR. Could you repush commit?
```
git commit --amend
gut push origin FLINK-5752 -f
```
---
If your project is set up for it, you can reply
Github user tonycox commented on the issue:
https://github.com/apache/flink/pull/3127
@StephanEwen I fixed
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so
Github user tonycox commented on the issue:
https://github.com/apache/flink/pull/3269
@fhueske What dou you think about this PR?
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
Github user tonycox commented on a diff in the pull request:
https://github.com/apache/flink/pull/3127#discussion_r106862331
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/Types.scala
---
@@ -17,29 +17,51 @@
*/
package
Github user tonycox commented on a diff in the pull request:
https://github.com/apache/flink/pull/3127#discussion_r106668425
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/Types.scala
---
@@ -17,29 +17,51 @@
*/
package
Github user tonycox commented on a diff in the pull request:
https://github.com/apache/flink/pull/3127#discussion_r106647040
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/Types.scala
---
@@ -17,29 +17,51 @@
*/
package
Github user tonycox closed the pull request at:
https://github.com/apache/flink/pull/3166
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature
Github user tonycox commented on the issue:
https://github.com/apache/flink/pull/3127
Hi @StephanEwen
I added javadoc
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
Github user tonycox commented on the issue:
https://github.com/apache/flink/pull/3269
Hi @fhueske I've addressed all comments
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
Github user tonycox commented on a diff in the pull request:
https://github.com/apache/flink/pull/3269#discussion_r106208275
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/rules/util/RexProgramProjectExtractor.scala
---
@@ -84,6 +108,49 @@ object
Github user tonycox closed the pull request at:
https://github.com/apache/flink/pull/3297
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature
Github user tonycox commented on a diff in the pull request:
https://github.com/apache/flink/pull/3127#discussion_r105972293
--- Diff:
flink-core/src/main/java/org/apache/flink/api/java/typeutils/Types.java ---
@@ -0,0 +1,53 @@
+/*
+ * Licensed to the Apache Software
Github user tonycox commented on a diff in the pull request:
https://github.com/apache/flink/pull/3127#discussion_r105972317
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/Types.scala
---
@@ -17,29 +17,34 @@
*/
package
Github user tonycox commented on the issue:
https://github.com/apache/flink/pull/3040
@fhueske I fixed commented points.
Could you explain the join keys forwarding?
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well
Github user tonycox commented on a diff in the pull request:
https://github.com/apache/flink/pull/3040#discussion_r105600606
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/dataset/forwarding/FieldForwardingUtils.scala
---
@@ -0,0 +1,143
Github user tonycox commented on the issue:
https://github.com/apache/flink/pull/3166
Hi @fhueske I cant continue on this PR, have not enough time for now. If
you need implementation of it immediately I will unassign
---
If your project is set up for it, you can reply to this email
Github user tonycox commented on the issue:
https://github.com/apache/flink/pull/3297
@zentol What do you think about this PR ?
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
Github user tonycox commented on the issue:
https://github.com/apache/flink/pull/3040
@fhueske @KurtYoung @twalthr What do you think about this PR ?
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does
Github user tonycox commented on the issue:
https://github.com/apache/flink/pull/3127
@StephanEwen @twalthr What do you think about this PR ?
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have
Github user tonycox commented on the issue:
https://github.com/apache/flink/pull/3166
@fhueske could you look at this approach of transfering `RexNode` to
`Expression`, it's stil in wip state, but I need your adjustment
---
If your project is set up for it, you can reply
Github user tonycox commented on the issue:
https://github.com/apache/flink/pull/3040
Hi,
Do we need field forwarding in `DataSetMinus`, `DataSetIntersect` and
`DataSetSort`?
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub
Github user tonycox commented on the issue:
https://github.com/apache/flink/pull/3166
Hi @fhueske,
what do you think about this PR?
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have
Github user tonycox commented on the issue:
https://github.com/apache/flink/pull/3149
@ramkrish86 java8 has different memory model,
https://dzone.com/articles/java-8-permgen-metaspace
---
If your project is set up for it, you can reply to this email and have your
reply appear
Github user tonycox commented on the issue:
https://github.com/apache/flink/pull/3012
@ex00 default value of any empty field is null
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have
Github user tonycox commented on the issue:
https://github.com/apache/flink/pull/3149
@ramkrish86 You can use jhat to read hprof dump file.
If set `-XX:MaxPermSize=128m`
```xml
org.apache.maven.plugins
maven-surefire-plugin
2.19.1
GitHub user tonycox opened a pull request:
https://github.com/apache/flink/pull/3297
[FLINK-5431] Add configurable timePattern for client akka status
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the following check list into consideration
Github user tonycox commented on the issue:
https://github.com/apache/flink/pull/3271
Hi @huawei-flink,
please name your PR with "[FLINK-XXX] Jira title text" pattern
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitH
Github user tonycox commented on the issue:
https://github.com/apache/flink/pull/3127
I think I should rename this issuea to "Simplify Row creation".
What do you think?
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitH
Github user tonycox commented on the issue:
https://github.com/apache/flink/pull/3149
@ramkrish86 Try to add
```
-XX:+HeapDumpOnOutOfMemoryError
-XX:HeapDumpPath="/tmp"
```
as parameter of JVM
---
If your project is set up for it, you can reply to
Github user tonycox commented on the issue:
https://github.com/apache/flink/pull/3149
@ramkrish86 what is your environment?
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
Github user tonycox commented on the issue:
https://github.com/apache/flink/pull/3012
@ex00 Thank you for review,
If typeMap does not match with fields type in file it will fall with
`ParseException`.
But if `Double parser` try to parse an integer it will be okay.
Do
Github user tonycox commented on a diff in the pull request:
https://github.com/apache/flink/pull/3012#discussion_r10033
--- Diff:
flink-scala/src/main/scala/org/apache/flink/api/scala/ExecutionEnvironment.scala
---
@@ -348,6 +349,47 @@ class ExecutionEnvironment(javaEnv
Github user tonycox commented on a diff in the pull request:
https://github.com/apache/flink/pull/3012#discussion_r100337562
--- Diff:
flink-tests/src/test/java/org/apache/flink/test/io/CsvReaderITCase.java ---
@@ -122,6 +127,80 @@ public void testValueTypes() throws Exception
Github user tonycox commented on the issue:
https://github.com/apache/flink/pull/3149
Try to run in flink folder (I ran it onto ubuntu 16.04)
```bash
export JAVA_HOME=/path/to/java-7-oracle/jre
mvn -B -Dhadoop.version=2.3.0 \
test -Dtest
Github user tonycox commented on the issue:
https://github.com/apache/flink/pull/3269
Hi @wuchong
Thank you for excellent advice
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have
Github user tonycox commented on a diff in the pull request:
https://github.com/apache/flink/pull/3205#discussion_r100159827
--- Diff: flink-contrib/docker-flink/docker-compose.yml ---
@@ -16,21 +16,22 @@
# limitations under the License
Github user tonycox commented on a diff in the pull request:
https://github.com/apache/flink/pull/3205#discussion_r100156082
--- Diff: flink-contrib/docker-flink/Dockerfile ---
@@ -36,22 +31,25 @@ ENV PATH $PATH:$FLINK_HOME/bin
EXPOSE 8081
EXPOSE 6123
+# flink
Github user tonycox commented on a diff in the pull request:
https://github.com/apache/flink/pull/3205#discussion_r100148697
--- Diff: flink-contrib/docker-flink/Dockerfile ---
@@ -36,22 +31,25 @@ ENV PATH $PATH:$FLINK_HOME/bin
EXPOSE 8081
EXPOSE 6123
+# flink
GitHub user tonycox opened a pull request:
https://github.com/apache/flink/pull/3269
[FLINK-5698] Add NestedFieldsProjectableTableSource trait
- add extraction of RexFieldAccess method
- complete PushProjectIntoBatchTableSourceScanRule with new interface
Thanks
Github user tonycox commented on the issue:
https://github.com/apache/flink/pull/308
Okay, I'll add it to clean up jira list
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
Github user tonycox commented on the issue:
https://github.com/apache/flink/pull/308
Hi @FelixNeutatz Can you finish this PR ?
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
Github user tonycox commented on the issue:
https://github.com/apache/flink/pull/3166
However I think we need a tool for converting RexNodes to Table API
Expressions.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well
Github user tonycox commented on the issue:
https://github.com/apache/flink/pull/3127
```scala
import Types._
ROW(Array("person", "additional"),
ROW(Array("name", "age"), STRING, STRING),
ROW(Array(&
Github user tonycox commented on the issue:
https://github.com/apache/flink/pull/3149
@ramkrish86 ProjectableTableSource works in scan process. Without it
TableScan is scanning all collumns and applying flatMap function on the whole
data to project and filter. It's inefficient
Github user tonycox commented on the issue:
https://github.com/apache/flink/pull/3149
@fhueske I preffer a better API with nesting. We can extend
`ProjectableTableSource` with a method like this
```scala
def projectNestedFields(fields: Array[String]): ProjectableTableSource[T
Github user tonycox commented on the issue:
https://github.com/apache/flink/pull/3127
@twalthr I think it's good way.
Should I move `TimeIntervalTypeInfo` to core as well or not?
---
If your project is set up for it, you can reply to this email and have your
reply appear
Github user tonycox commented on a diff in the pull request:
https://github.com/apache/flink/pull/3149#discussion_r98455947
--- Diff:
flink-connectors/flink-hbase/src/main/java/org/apache/flink/addons/hbase/HBaseTableSchema.java
---
@@ -0,0 +1,140 @@
+/*
+ * Licensed
Github user tonycox commented on a diff in the pull request:
https://github.com/apache/flink/pull/3149#discussion_r98435113
--- Diff:
flink-connectors/flink-hbase/src/main/java/org/apache/flink/addons/hbase/HBaseTableSchema.java
---
@@ -0,0 +1,140 @@
+/*
+ * Licensed
Github user tonycox commented on a diff in the pull request:
https://github.com/apache/flink/pull/3149#discussion_r98434792
--- Diff:
flink-connectors/flink-hbase/src/main/java/org/apache/flink/addons/hbase/HBaseTableSchema.java
---
@@ -0,0 +1,140 @@
+/*
+ * Licensed
Github user tonycox commented on the issue:
https://github.com/apache/flink/pull/3149
@ramkrish86 sorry for confusing, don't pay attention to new generating maps.
I think `PushProjectIntoBatchTableSourceScanRule` is not good enough for
nested data types. but we can project
Github user tonycox commented on the issue:
https://github.com/apache/flink/pull/3127
I suggest add a little bit more sugar
```java
TypeInformation infoNew = RowTypeInfo.from(
new String[]{"1c", "2c"},
RowTypeInfo.from(
new S
Github user tonycox commented on the issue:
https://github.com/apache/flink/pull/3149
`HBaseTableSchema` is initial information of table columns, so we can add
more maps that generate after familyMap has set
```java
Map<String, List<Pair<String, TypeInformation>
Github user tonycox commented on the issue:
https://github.com/apache/flink/pull/3127
I think all it's just a syntax sugar
```scala
val data = List(
Row.of(Row.of("data_1", "dob"), Row.of("info_4", "dub")),
Github user tonycox commented on the issue:
https://github.com/apache/flink/pull/3149
@ramkrish86 I think you need implement projectable interface in HBase source
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your
Github user tonycox commented on the issue:
https://github.com/apache/flink/pull/3127
@StephanEwen I agree with types conflicting and that it's not common type
for collection.
So how should generating a row type info look like?
---
If your project is set up for it, you can reply
Github user tonycox commented on the issue:
https://github.com/apache/flink/pull/3040
Hi,
Nickolay cannot continue work on this PR, so I'm going to try finish it for
him.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub
Github user tonycox commented on a diff in the pull request:
https://github.com/apache/flink/pull/3149#discussion_r97898531
--- Diff:
flink-connectors/flink-hbase/src/main/java/org/apache/flink/addons/hbase/HBaseTableSchema.java
---
@@ -0,0 +1,137 @@
+/*
+ * Licensed
Github user tonycox commented on a diff in the pull request:
https://github.com/apache/flink/pull/3149#discussion_r97903962
--- Diff:
flink-connectors/flink-hbase/src/test/java/org/apache/flink/addons/hbase/example/HBaseTableSourceITCase.java
---
@@ -0,0 +1,248
Github user tonycox commented on a diff in the pull request:
https://github.com/apache/flink/pull/3149#discussion_r97897602
--- Diff:
flink-connectors/flink-hbase/src/main/java/org/apache/flink/addons/hbase/HBaseTableSchema.java
---
@@ -0,0 +1,137 @@
+/*
+ * Licensed
Github user tonycox commented on a diff in the pull request:
https://github.com/apache/flink/pull/3149#discussion_r97903708
--- Diff:
flink-connectors/flink-hbase/src/test/java/org/apache/flink/addons/hbase/example/HBaseTableSourceITCase.java
---
@@ -0,0 +1,248
Github user tonycox commented on a diff in the pull request:
https://github.com/apache/flink/pull/3149#discussion_r97901774
--- Diff:
flink-connectors/flink-hbase/src/main/java/org/apache/flink/addons/hbase/HBaseTableSource.java
---
@@ -0,0 +1,65 @@
+/*
+ * Licensed
Github user tonycox commented on a diff in the pull request:
https://github.com/apache/flink/pull/3149#discussion_r97904966
--- Diff:
flink-connectors/flink-hbase/src/test/java/org/apache/flink/addons/hbase/example/HBaseTableSourceITCase.java
---
@@ -0,0 +1,248
Github user tonycox commented on a diff in the pull request:
https://github.com/apache/flink/pull/3149#discussion_r97900030
--- Diff:
flink-connectors/flink-hbase/src/main/java/org/apache/flink/addons/hbase/HBaseTableSchema.java
---
@@ -0,0 +1,137 @@
+/*
+ * Licensed
Github user tonycox commented on a diff in the pull request:
https://github.com/apache/flink/pull/3149#discussion_r97074517
--- Diff:
flink-connectors/flink-hbase/src/main/java/org/apache/flink/addons/hbase/HBaseTableSource.java
---
@@ -0,0 +1,75 @@
+/*
+ * Licensed
Github user tonycox commented on a diff in the pull request:
https://github.com/apache/flink/pull/3149#discussion_r97067569
--- Diff:
flink-connectors/flink-hbase/src/main/java/org/apache/flink/addons/hbase/HBaseTableSource.java
---
@@ -0,0 +1,75 @@
+/*
+ * Licensed
Github user tonycox commented on the issue:
https://github.com/apache/flink/pull/3149
As Jark Wu said in [jira](https://issues.apache.org/jira/browse/FLINK-5554)
> I think the HBaseTableSource should return a composite type (with column
family and qualifier), and we can
Github user tonycox commented on a diff in the pull request:
https://github.com/apache/flink/pull/3149#discussion_r96802576
--- Diff:
flink-connectors/flink-hbase/src/main/java/org/apache/flink/addons/hbase/HBaseTableSourceInputFormat.java
---
@@ -0,0 +1,322
GitHub user tonycox opened a pull request:
https://github.com/apache/flink/pull/3166
[FLINK-3849] [WIP] Add FilterableTableSource interface and Rules for
pushing it
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the following check list
Github user tonycox commented on a diff in the pull request:
https://github.com/apache/flink/pull/3149#discussion_r9157
--- Diff:
flink-connectors/flink-hbase/src/test/java/org/apache/flink/addons/hbase/example/HBaseTableSourceITCase.java
---
@@ -0,0 +1,117
Github user tonycox commented on the issue:
https://github.com/apache/flink/pull/3149
We need discuss that
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so
Github user tonycox commented on a diff in the pull request:
https://github.com/apache/flink/pull/3149#discussion_r96668950
--- Diff:
flink-connectors/flink-hbase/src/main/java/org/apache/flink/addons/hbase/HBaseTableSourceInputFormat.java
---
@@ -0,0 +1,322
Github user tonycox commented on a diff in the pull request:
https://github.com/apache/flink/pull/3149#discussion_r96665731
--- Diff:
flink-connectors/flink-hbase/src/test/java/org/apache/flink/addons/hbase/example/HBaseTableSourceITCase.java
---
@@ -0,0 +1,117
Github user tonycox commented on a diff in the pull request:
https://github.com/apache/flink/pull/3149#discussion_r96665689
--- Diff:
flink-connectors/flink-hbase/src/test/java/org/apache/flink/addons/hbase/example/HBaseTableSourceITCase.java
---
@@ -0,0 +1,117
Github user tonycox commented on a diff in the pull request:
https://github.com/apache/flink/pull/3149#discussion_r96665755
--- Diff:
flink-connectors/flink-hbase/src/test/java/org/apache/flink/addons/hbase/example/HBaseTableSourceITCase.java
---
@@ -0,0 +1,117
Github user tonycox commented on the issue:
https://github.com/apache/flink/pull/3149
And could you extend with `StreamTableSource` also ?
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have
Github user tonycox commented on the issue:
https://github.com/apache/flink/pull/3149
I think it can be solved in different issue to provide a new api in
`table.api` for selecting from HBase
---
If your project is set up for it, you can reply to this email and have your
reply appear
Github user tonycox commented on the issue:
https://github.com/apache/flink/pull/3149
@ramkrish86 @fhueske what do you think about to throw `Tuple` (`T extends
Tuple`) out of `org.apache.flink.addons.hbase.TableInputFormat` and implement
this abstract class in your
Github user tonycox commented on the issue:
https://github.com/apache/flink/pull/3149
You need to recompile `TableSource` trait manually and implement
`DefinedFieldNames` in `HBaseTableSource`
---
If your project is set up for it, you can reply to this email and have your
reply
Github user tonycox commented on the issue:
https://github.com/apache/flink/pull/3127
@zentol I rewrite as you pointed
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled
Github user tonycox commented on the issue:
https://github.com/apache/flink/pull/243
Ok, cool. I can go through abandoned PRs and add them to
https://issues.apache.org/jira/browse/FLINK-5384. Wouldn't you mind @fhueske ?
---
If your project is set up for it, you can reply
Github user tonycox commented on the issue:
https://github.com/apache/flink/pull/243
Is this PR still alive?
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes
GitHub user tonycox opened a pull request:
https://github.com/apache/flink/pull/3127
[FLINK-5481] Add type extraction from collection
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the following check list into consideration.
If your
Github user tonycox closed the pull request at:
https://github.com/apache/flink/pull/3018
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature
GitHub user tonycox opened a pull request:
https://github.com/apache/flink/pull/3044
[FLINK-5388] Change private Graph.() to protected
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the following check list into consideration.
If your
Github user tonycox commented on a diff in the pull request:
https://github.com/apache/flink/pull/3027#discussion_r93848593
--- Diff:
flink-core/src/test/java/org/apache/flink/api/java/typeutils/TypeExtractorTest.java
---
@@ -345,8 +346,25 @@ public CustomType cross(CustomType
Github user tonycox commented on the issue:
https://github.com/apache/flink/pull/3027
Hi @fhueske could you look at this PR?
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
Github user tonycox commented on the issue:
https://github.com/apache/flink/pull/3012
Hi @StephanEwen could you look at this PR?
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
GitHub user tonycox opened a pull request:
https://github.com/apache/flink/pull/3027
[FLINK-5358] add RowTypeInfo exctraction in TypeExtractor
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the following check list into consideration
Github user tonycox commented on the issue:
https://github.com/apache/flink/pull/3020
@wuchong sorry, my fault, didn't spot duplicate field names checkers. What
about cases, Is flink-table case-sensitive?
---
If your project is set up for it, you can reply to this email and have
Github user tonycox commented on the issue:
https://github.com/apache/flink/pull/3020
Hi @wuchong , in this case I think you should adapt `getFieldIndex`
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project
GitHub user tonycox opened a pull request:
https://github.com/apache/flink/pull/3018
[FLINK-5336] Remove IOReadableWritable interface from Path
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the following check list into consideration
Github user tonycox commented on the issue:
https://github.com/apache/flink/pull/2810
@fhueske I update this PR according to last changes in master
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does
GitHub user tonycox opened a pull request:
https://github.com/apache/flink/pull/3012
[FLINK-2186] Add readCsvAsRow methods to CsvReader and scala ExecutionEnv
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the following check list
Github user tonycox commented on the issue:
https://github.com/apache/flink/pull/2926
@fhueske is there any sense to createcost optimization for Stream?
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project
Github user tonycox commented on the issue:
https://github.com/apache/flink/pull/3003
Hi @fhueske okay, as you wish
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled
GitHub user tonycox opened a pull request:
https://github.com/apache/flink/pull/3004
[Flink-5189] Delete Row and its related classes from table api
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the following check list into consideration
GitHub user tonycox opened a pull request:
https://github.com/apache/flink/pull/3003
[Flink-5188] Create analog of RowCsvInputFormat in java and adjust all the
imports of Row and RowTypeInfo
Thanks for contributing to Apache Flink. Before you open your pull request,
please take
Github user tonycox commented on the issue:
https://github.com/apache/flink/pull/2810
Hi @fhueske , what should I finish first, this PR or FLINK-5188 ?
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project
Github user tonycox commented on the issue:
https://github.com/apache/flink/pull/2968
@fhueske Yes. I already started
https://github.com/tonycox/flink/tree/FLINK-5188
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well
Github user tonycox commented on a diff in the pull request:
https://github.com/apache/flink/pull/2968#discussion_r91941722
--- Diff: flink-core/src/main/java/org/apache/flink/types/Row.java ---
@@ -0,0 +1,110 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF
1 - 100 of 141 matches
Mail list logo
